From 5c95266d4cb2b4ac2d4515b1a64ede30c1b5b05f Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期一, 09 三月 2020 15:58:39 +0800
Subject: [PATCH] 优化listener 之后 加入bmo 类处理 报文拼装
---
Api/src/main/java/com/java110/api/bmo/activities/impl/ActivitiesBMOImpl.java | 116 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 116 insertions(+), 0 deletions(-)
diff --git a/Api/src/main/java/com/java110/api/bmo/activities/impl/ActivitiesBMOImpl.java b/Api/src/main/java/com/java110/api/bmo/activities/impl/ActivitiesBMOImpl.java
index fe214dc..1bda390 100644
--- a/Api/src/main/java/com/java110/api/bmo/activities/impl/ActivitiesBMOImpl.java
+++ b/Api/src/main/java/com/java110/api/bmo/activities/impl/ActivitiesBMOImpl.java
@@ -5,14 +5,32 @@
import com.java110.api.bmo.ApiBaseBMO;
import com.java110.api.bmo.activities.IActivitiesBMO;
import com.java110.core.context.DataFlowContext;
+import com.java110.core.smo.community.IActivitiesInnerServiceSMO;
+import com.java110.core.smo.file.IFileInnerServiceSMO;
+import com.java110.core.smo.file.IFileRelInnerServiceSMO;
+import com.java110.dto.activities.ActivitiesDto;
+import com.java110.dto.file.FileRelDto;
import com.java110.utils.constant.BusinessTypeConstant;
import com.java110.utils.constant.CommonConstant;
+import com.java110.utils.util.Assert;
+import com.java110.utils.util.BeanConvertUtil;
+import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Service;
+
+import java.util.List;
@Service("activitiesBMOImpl")
public class ActivitiesBMOImpl extends ApiBaseBMO implements IActivitiesBMO {
+ @Autowired
+ private IActivitiesInnerServiceSMO activitiesInnerServiceSMOImpl;
+
+ @Autowired
+ private IFileInnerServiceSMO fileInnerServiceSMOImpl;
+
+ @Autowired
+ private IFileRelInnerServiceSMO fileRelInnerServiceSMOImpl;
/**
* 娣诲姞鐗╀笟璐圭敤
*
@@ -65,4 +83,102 @@
return business;
}
+ /**
+ * 淇敼澶撮儴鐓х墖
+ *
+ * @param paramInJson 鎺ュ彛璋冪敤鏀句紶鍏ュ叆鍙�
+ * @param dataFlowContext 鏁版嵁涓婁笅鏂�
+ * @return 璁㈠崟鏈嶅姟鑳藉鎺ュ彈鐨勬姤鏂�
+ */
+ public JSONObject editHeaderImg(JSONObject paramInJson, DataFlowContext dataFlowContext) {
+
+ FileRelDto fileRelDto = new FileRelDto();
+ fileRelDto.setRelTypeCd("70000");
+ fileRelDto.setObjId(paramInJson.getString("activitiesId"));
+ List<FileRelDto> fileRelDtos = fileRelInnerServiceSMOImpl.queryFileRels(fileRelDto);
+ if (fileRelDtos == null || fileRelDtos.size() == 0) {
+ 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;
+ }
+ JSONObject business = JSONObject.parseObject("{\"datas\":{}}");
+ business.put(CommonConstant.HTTP_BUSINESS_TYPE_CD, BusinessTypeConstant.BUSINESS_TYPE_UPDATE_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.putAll(BeanConvertUtil.beanCovertMap(fileRelDtos.get(0)));
+ businessUnit.put("fileRealName", paramInJson.getString("headerImg"));
+ businessUnit.put("fileSaveName", paramInJson.getString("headerImg"));
+ business.getJSONObject(CommonConstant.HTTP_BUSINESS_DATAS).put("businessFileRel", businessUnit);
+ return business;
+ }
+
+
+ /**
+ * 娣诲姞娲诲姩淇℃伅
+ *
+ * @param paramInJson 鎺ュ彛璋冪敤鏀句紶鍏ュ叆鍙�
+ * @param dataFlowContext 鏁版嵁涓婁笅鏂�
+ * @return 璁㈠崟鏈嶅姟鑳藉鎺ュ彈鐨勬姤鏂�
+ */
+ public JSONObject updateActivities(JSONObject paramInJson, DataFlowContext dataFlowContext) {
+
+ ActivitiesDto activitiesDto = new ActivitiesDto();
+ activitiesDto.setActivitiesId(paramInJson.getString("activitiesId"));
+ activitiesDto.setCommunityId(paramInJson.getString("communityId"));
+ List<ActivitiesDto> activitiesDtos = activitiesInnerServiceSMOImpl.queryActivitiess(activitiesDto);
+
+ Assert.listOnlyOne(activitiesDtos, "鏈壘鍒伴渶瑕佷慨鏀圭殑娲诲姩 鎴栧鏉℃暟鎹�");
+
+
+ JSONObject business = JSONObject.parseObject("{\"datas\":{}}");
+ business.put(CommonConstant.HTTP_BUSINESS_TYPE_CD, BusinessTypeConstant.BUSINESS_TYPE_UPDATE_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("userId",activitiesDtos.get(0).getUserId());
+ businessActivities.put("userName",activitiesDtos.get(0).getUserName());
+ businessActivities.put("readCount",activitiesDtos.get(0).getReadCount());
+ businessActivities.put("likeCount",activitiesDtos.get(0).getLikeCount());
+ businessActivities.put("collectCount",activitiesDtos.get(0).getCollectCount());
+ businessActivities.put("state",activitiesDtos.get(0).getState()); // 鍏堣缃负涓嶅鏍�
+ //璁＄畻 搴旀敹閲戦
+ business.getJSONObject(CommonConstant.HTTP_BUSINESS_DATAS).put("businessActivities", businessActivities);
+ return business;
+ }
+
+
+
+ /**
+ * 娣诲姞灏忓尯淇℃伅
+ *
+ * @param paramInJson 鎺ュ彛璋冪敤鏀句紶鍏ュ叆鍙�
+ * @param dataFlowContext 鏁版嵁涓婁笅鏂�
+ * @return 璁㈠崟鏈嶅姟鑳藉鎺ュ彈鐨勬姤鏂�
+ */
+ public JSONObject deleteActivities(JSONObject paramInJson, DataFlowContext dataFlowContext) {
+
+
+ JSONObject business = JSONObject.parseObject("{\"datas\":{}}");
+ business.put(CommonConstant.HTTP_BUSINESS_TYPE_CD, BusinessTypeConstant.BUSINESS_TYPE_DELETE_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);
+ //璁＄畻 搴旀敹閲戦
+ business.getJSONObject(CommonConstant.HTTP_BUSINESS_DATAS).put("businessActivities", businessActivities);
+ return business;
+ }
+
}
--
Gitblit v1.8.0