From a4ef0d013b9b2b7af152ec05623ccae0bf73ba2a Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期一, 09 三月 2020 15:45:30 +0800
Subject: [PATCH] 在listener 中加入bmo
---
Api/src/main/java/com/java110/api/listener/activities/SaveActivitiesListener.java | 75 ++++---------------------------------
1 files changed, 9 insertions(+), 66 deletions(-)
diff --git a/Api/src/main/java/com/java110/api/listener/activities/SaveActivitiesListener.java b/Api/src/main/java/com/java110/api/listener/activities/SaveActivitiesListener.java
index 3ffdf36..995544b 100644
--- a/Api/src/main/java/com/java110/api/listener/activities/SaveActivitiesListener.java
+++ b/Api/src/main/java/com/java110/api/listener/activities/SaveActivitiesListener.java
@@ -2,6 +2,7 @@
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
+import com.java110.api.bmo.activities.IActivitiesBMO;
import com.java110.api.listener.AbstractServiceApiListener;
import com.java110.core.factory.GenerateCodeFactory;
import com.java110.core.smo.file.IFileInnerServiceSMO;
@@ -30,10 +31,13 @@
@Autowired
private IFileInnerServiceSMO fileInnerServiceSMOImpl;
+
+ @Autowired
+ private IActivitiesBMO activitiesBMOImpl;
+
@Override
protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) {
//Assert.hasKeyAndValue(reqJson, "xxx", "xxx");
-
Assert.hasKeyAndValue(reqJson, "title", "蹇呭～锛岃濉啓涓氭椿鍔ㄦ爣棰�");
Assert.hasKeyAndValue(reqJson, "typeCd", "蹇呭～锛岃閫夋嫨娲诲姩绫诲瀷");
Assert.hasKeyAndValue(reqJson, "headerImg", "蹇呭～锛岃閫夋嫨澶撮儴鐓х墖");
@@ -48,15 +52,12 @@
@Override
protected void doSoService(ServiceDataFlowEvent event, DataFlowContext context, JSONObject reqJson) {
- HttpHeaders header = new HttpHeaders();
- context.getRequestCurrentHeaders().put(CommonConstant.HTTP_ORDER_TYPE_CD, "D");
+
JSONArray businesses = new JSONArray();
AppService service = event.getAppService();
reqJson.put("activitiesId",GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_activitiesId));
-
-
if (reqJson.containsKey("headerImg") && !StringUtils.isEmpty(reqJson.getString("headerImg"))) {
FileDto fileDto = new FileDto();
@@ -70,48 +71,18 @@
reqJson.put("headerImg", fileDto.getFileId());
reqJson.put("fileSaveName", fileName);
- businesses.add(addHeaderImg(reqJson, context));
+ businesses.add(activitiesBMOImpl.addHeaderImg(reqJson, context));
}
-
//娣诲姞鍗曞厓淇℃伅
- businesses.add(addActivities(reqJson, context));
+ businesses.add(activitiesBMOImpl.addActivities(reqJson, context));
- JSONObject paramInObj = super.restToCenterProtocol(businesses, context.getRequestCurrentHeaders());
-
- //灏� rest header 淇℃伅浼犻�掑埌涓嬪眰鏈嶅姟涓幓
- super.freshHttpHeader(header, context.getRequestCurrentHeaders());
-
- ResponseEntity<String> responseEntity = this.callService(context, service.getServiceCode(), paramInObj);
+ ResponseEntity<String> responseEntity = activitiesBMOImpl.callService(context, service.getServiceCode(), businesses);
context.setResponseEntity(responseEntity);
}
- /**
- * 娣诲姞鐗╀笟璐圭敤
- *
- * @param paramInJson 鎺ュ彛璋冪敤鏀句紶鍏ュ叆鍙�
- * @param dataFlowContext 鏁版嵁涓婁笅鏂�
- * @return 璁㈠崟鏈嶅姟鑳藉鎺ュ彈鐨勬姤鏂�
- */
- private JSONObject addHeaderImg(JSONObject paramInJson, DataFlowContext dataFlowContext) {
-
- JSONObject business = JSONObject.parseObject("{\"datas\":{}}");
- business.put(CommonConstant.HTTP_BUSINESS_TYPE_CD, BusinessTypeConstant.BUSINESS_TYPE_SAVE_FILE_REL);
- business.put(CommonConstant.HTTP_SEQ, DEFAULT_SEQ + 2);
- business.put(CommonConstant.HTTP_INVOKE_MODEL, CommonConstant.HTTP_INVOKE_MODEL_S);
- JSONObject businessUnit = new JSONObject();
- businessUnit.put("fileRelId", "-1");
- businessUnit.put("relTypeCd", "70000");
- businessUnit.put("saveWay", "table");
- businessUnit.put("objId", paramInJson.getString("activitiesId"));
- businessUnit.put("fileRealName", paramInJson.getString("headerImg"));
- businessUnit.put("fileSaveName", paramInJson.getString("fileSaveName"));
- business.getJSONObject(CommonConstant.HTTP_BUSINESS_DATAS).put("businessFileRel", businessUnit);
-
- return business;
- }
@Override
public String getServiceCode() {
@@ -127,32 +98,4 @@
public int getOrder() {
return DEFAULT_ORDER;
}
-
-
- /**
- * 娣诲姞灏忓尯淇℃伅
- *
- * @param paramInJson 鎺ュ彛璋冪敤鏀句紶鍏ュ叆鍙�
- * @param dataFlowContext 鏁版嵁涓婁笅鏂�
- * @return 璁㈠崟鏈嶅姟鑳藉鎺ュ彈鐨勬姤鏂�
- */
- private JSONObject addActivities(JSONObject paramInJson, DataFlowContext dataFlowContext) {
-
-
- JSONObject business = JSONObject.parseObject("{\"datas\":{}}");
- business.put(CommonConstant.HTTP_BUSINESS_TYPE_CD, BusinessTypeConstant.BUSINESS_TYPE_SAVE_ACTIVITIES);
- business.put(CommonConstant.HTTP_SEQ, DEFAULT_SEQ);
- business.put(CommonConstant.HTTP_INVOKE_MODEL, CommonConstant.HTTP_INVOKE_MODEL_S);
- JSONObject businessActivities = new JSONObject();
- businessActivities.putAll(paramInJson);
- businessActivities.put("readCount","0");
- businessActivities.put("likeCount","0");
- businessActivities.put("collectCount","0");
- businessActivities.put("state","11000"); // 鍏堣缃负涓嶅鏍�
- //businessActivities.put("activitiesId", "-1");
- //璁＄畻 搴旀敹閲戦
- business.getJSONObject(CommonConstant.HTTP_BUSINESS_DATAS).put("businessActivities", businessActivities);
- return business;
- }
-
}
--
Gitblit v1.8.0