From bb198fb66045329b6dc47a031f202aabc6b8a1dd Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期日, 31 五月 2020 21:33:01 +0800
Subject: [PATCH] 优化代码
---
Api/src/main/java/com/java110/api/bmo/ApiBaseBMO.java | 65 ++++++++++++++++++++++++++++++--
1 files changed, 61 insertions(+), 4 deletions(-)
diff --git a/Api/src/main/java/com/java110/api/bmo/ApiBaseBMO.java b/Api/src/main/java/com/java110/api/bmo/ApiBaseBMO.java
index 8f0cc39..15938e3 100644
--- a/Api/src/main/java/com/java110/api/bmo/ApiBaseBMO.java
+++ b/Api/src/main/java/com/java110/api/bmo/ApiBaseBMO.java
@@ -5,10 +5,10 @@
import com.java110.core.context.DataFlowContext;
import com.java110.core.factory.DataFlowFactory;
import com.java110.entity.center.AppService;
-import com.java110.entity.order.Orders;
-import com.java110.event.service.api.ServiceDataFlowEvent;
+import com.java110.core.event.service.api.ServiceDataFlowEvent;
import com.java110.utils.constant.CommonConstant;
import com.java110.utils.constant.ServiceCodeConstant;
+import com.java110.utils.util.BeanConvertUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.*;
import org.springframework.web.client.HttpStatusCodeException;
@@ -203,8 +203,8 @@
orders.put("orderProcess", headers.get(CommonConstant.ORDER_PROCESS));
}
- if(CommonConstant.ORDER_PROCESS.equals("olId")){
- orders.put("olId", headers.get("olId"));
+ if(CommonConstant.O_ID.equals(key)){
+ orders.put("oId", headers.get(CommonConstant.O_ID));
}
}
@@ -238,4 +238,61 @@
}
}
+
+ /**
+ * 鏂板鏁版嵁鏂规硶
+ *
+ * @param context 涓婁笅鏂囧璞�
+ * @param param po瀵硅薄
+ */
+ public void insert(DataFlowContext context, Object param, String businessType) {
+ JSONObject business = JSONObject.parseObject("{\"datas\":{}}");
+ business.put(CommonConstant.HTTP_BUSINESS_TYPE_CD, businessType);
+ business.put(CommonConstant.HTTP_SEQ, DEFAULT_SEQ);
+ business.put(CommonConstant.HTTP_INVOKE_MODEL, CommonConstant.HTTP_INVOKE_MODEL_S);
+ JSONObject businessObj = new JSONObject();
+ businessObj = JSONObject.parseObject(JSONObject.toJSONString(BeanConvertUtil.beanCovertMap(param)));
+ JSONArray businessArr = new JSONArray();
+ businessArr.add(businessObj);
+ business.getJSONObject(CommonConstant.HTTP_BUSINESS_DATAS).put(param.getClass().getSimpleName(), businessArr);
+ context.addServiceBusiness(business);
+ }
+
+ /**
+ * 鏂板鏁版嵁鏂规硶
+ *
+ * @param context 涓婁笅鏂囧璞�
+ * @param param po瀵硅薄
+ */
+ public void update(DataFlowContext context, Object param, String businessType) {
+ JSONObject business = JSONObject.parseObject("{\"datas\":{}}");
+ business.put(CommonConstant.HTTP_BUSINESS_TYPE_CD, businessType);
+ business.put(CommonConstant.HTTP_SEQ, DEFAULT_SEQ);
+ business.put(CommonConstant.HTTP_INVOKE_MODEL, CommonConstant.HTTP_INVOKE_MODEL_S);
+ JSONObject businessObj = new JSONObject();
+ businessObj = JSONObject.parseObject(JSONObject.toJSONString(BeanConvertUtil.beanCovertMap(param)));
+ JSONArray businessArr = new JSONArray();
+ businessArr.add(businessObj);
+ business.getJSONObject(CommonConstant.HTTP_BUSINESS_DATAS).put(param.getClass().getSimpleName(), businessArr);
+ context.addServiceBusiness(business);
+ }
+
+ /**
+ * 鏂板鏁版嵁鏂规硶
+ *
+ * @param context 涓婁笅鏂囧璞�
+ * @param param po瀵硅薄
+ */
+ public void delete(DataFlowContext context, Object param, String businessType) {
+ JSONObject business = JSONObject.parseObject("{\"datas\":{}}");
+ business.put(CommonConstant.HTTP_BUSINESS_TYPE_CD, businessType);
+ business.put(CommonConstant.HTTP_SEQ, DEFAULT_SEQ);
+ business.put(CommonConstant.HTTP_INVOKE_MODEL, CommonConstant.HTTP_INVOKE_MODEL_S);
+ JSONObject businessObj = new JSONObject();
+ businessObj = JSONObject.parseObject(JSONObject.toJSONString(BeanConvertUtil.beanCovertMap(param)));
+ JSONArray businessArr = new JSONArray();
+ businessArr.add(businessObj);
+ business.getJSONObject(CommonConstant.HTTP_BUSINESS_DATAS).put(param.getClass().getSimpleName(), businessArr);
+ context.addServiceBusiness(business);
+ }
}
--
Gitblit v1.8.0