From 6c017505f741d69c15361cc583611fc960a75779 Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期二, 10 三月 2020 00:30:21 +0800
Subject: [PATCH] 后端服务调整完成进入 测试阶段
---
Api/src/main/java/com/java110/api/bmo/advert/impl/AdvertBMOImpl.java | 210 ++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 210 insertions(+), 0 deletions(-)
diff --git a/Api/src/main/java/com/java110/api/bmo/advert/impl/AdvertBMOImpl.java b/Api/src/main/java/com/java110/api/bmo/advert/impl/AdvertBMOImpl.java
index 7d7a9fe..c55cc3c 100644
--- a/Api/src/main/java/com/java110/api/bmo/advert/impl/AdvertBMOImpl.java
+++ b/Api/src/main/java/com/java110/api/bmo/advert/impl/AdvertBMOImpl.java
@@ -4,11 +4,34 @@
import com.java110.api.bmo.ApiBaseBMO;
import com.java110.api.bmo.advert.IAdvertBMO;
import com.java110.core.context.DataFlowContext;
+import com.java110.core.factory.GenerateCodeFactory;
+import com.java110.core.smo.advert.IAdvertInnerServiceSMO;
+import com.java110.core.smo.advert.IAdvertItemInnerServiceSMO;
+import com.java110.core.smo.file.IFileInnerServiceSMO;
+import com.java110.core.smo.file.IFileRelInnerServiceSMO;
+import com.java110.dto.advert.AdvertDto;
+import com.java110.dto.advert.AdvertItemDto;
+import com.java110.dto.file.FileDto;
+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 org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import java.util.List;
+@Service("advertBMOImpl")
public class AdvertBMOImpl extends ApiBaseBMO implements IAdvertBMO {
+ @Autowired
+ private IFileRelInnerServiceSMO fileRelInnerServiceSMOImpl;
+ @Autowired
+ private IFileInnerServiceSMO fileInnerServiceSMOImpl;
+ @Autowired
+ private IAdvertInnerServiceSMO advertInnerServiceSMOImpl;
+
+ @Autowired
+ private IAdvertItemInnerServiceSMO advertItemInnerServiceSMOImpl;
/**
* 娣诲姞灏忓尯淇℃伅
*
@@ -29,4 +52,191 @@
business.getJSONObject(CommonConstant.HTTP_BUSINESS_DATAS).put("businessAdvert", businessAdvert);
return business;
}
+
+
+ public JSONObject addAdvertItemPhoto(JSONObject paramInJson, DataFlowContext dataFlowContext, String photo) {
+
+ String itemTypeCd = "";
+ String url = "";
+
+ FileDto fileDto = new FileDto();
+ fileDto.setFileId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_file_id));
+ fileDto.setFileName(fileDto.getFileId());
+ fileDto.setContext(photo);
+ fileDto.setSuffix("jpeg");
+ fileDto.setCommunityId(paramInJson.getString("communityId"));
+ String fileName = fileInnerServiceSMOImpl.saveFile(fileDto);
+ paramInJson.put("fileSaveName", fileName);
+ paramInJson.put("advertPhotoId", fileDto.getFileId());
+ itemTypeCd = "8888";
+ url = fileDto.getFileId();
+
+
+ JSONObject business = JSONObject.parseObject("{\"datas\":{}}");
+ business.put(CommonConstant.HTTP_BUSINESS_TYPE_CD, BusinessTypeConstant.BUSINESS_TYPE_SAVE_ADVERT_ITEM);
+ business.put(CommonConstant.HTTP_SEQ, DEFAULT_SEQ);
+ business.put(CommonConstant.HTTP_INVOKE_MODEL, CommonConstant.HTTP_INVOKE_MODEL_S);
+ JSONObject businessAdvertItem = new JSONObject();
+ businessAdvertItem.put("advertId", paramInJson.getString("advertId"));
+ businessAdvertItem.put("itemTypeCd", itemTypeCd);
+ businessAdvertItem.put("url", url);
+ businessAdvertItem.put("seq", 1);
+ businessAdvertItem.put("advertItemId", "-1");
+ businessAdvertItem.put("communityId", paramInJson.getString("communityId"));
+ //璁＄畻 搴旀敹閲戦
+ business.getJSONObject(CommonConstant.HTTP_BUSINESS_DATAS).put("businessAdvertItem", businessAdvertItem);
+ return business;
+ }
+
+ /**
+ * 娣诲姞灏忓尯淇℃伅
+ *
+ * @param paramInJson 鎺ュ彛璋冪敤鏀句紶鍏ュ叆鍙�
+ * @param dataFlowContext 鏁版嵁涓婁笅鏂�
+ * @return 璁㈠崟鏈嶅姟鑳藉鎺ュ彈鐨勬姤鏂�
+ */
+ public JSONObject addAdvertItemVedio(JSONObject paramInJson, DataFlowContext dataFlowContext) {
+
+ String itemTypeCd = "";
+ String url = "";
+
+ itemTypeCd = "9999";
+ url = paramInJson.getString("vedioName");
+ paramInJson.put("advertPhotoId", url);
+
+ JSONObject business = JSONObject.parseObject("{\"datas\":{}}");
+ business.put(CommonConstant.HTTP_BUSINESS_TYPE_CD, BusinessTypeConstant.BUSINESS_TYPE_SAVE_ADVERT_ITEM);
+ business.put(CommonConstant.HTTP_SEQ, DEFAULT_SEQ);
+ business.put(CommonConstant.HTTP_INVOKE_MODEL, CommonConstant.HTTP_INVOKE_MODEL_S);
+ JSONObject businessAdvertItem = new JSONObject();
+ businessAdvertItem.put("advertId", paramInJson.getString("advertId"));
+ businessAdvertItem.put("itemTypeCd", itemTypeCd);
+ businessAdvertItem.put("url", url);
+ businessAdvertItem.put("seq", 1);
+ businessAdvertItem.put("advertItemId", "-1");
+ businessAdvertItem.put("communityId", paramInJson.getString("communityId"));
+ //璁＄畻 搴旀敹閲戦
+ business.getJSONObject(CommonConstant.HTTP_BUSINESS_DATAS).put("businessAdvertItem", businessAdvertItem);
+ return business;
+ }
+
+
+ /**
+ * 娣诲姞鐗╀笟璐圭敤
+ *
+ * @param paramInJson 鎺ュ彛璋冪敤鏀句紶鍏ュ叆鍙�
+ * @param dataFlowContext 鏁版嵁涓婁笅鏂�
+ * @return 璁㈠崟鏈嶅姟鑳藉鎺ュ彈鐨勬姤鏂�
+ */
+ public JSONObject addAdvertFileRel(JSONObject paramInJson, DataFlowContext dataFlowContext, String relTypeCd) {
+
+
+ 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", relTypeCd);
+ businessUnit.put("saveWay", "40000".equals(relTypeCd) ? "table" : "ftp");
+ businessUnit.put("objId", paramInJson.getString("advertId"));
+ businessUnit.put("fileRealName", paramInJson.getString("advertPhotoId"));
+ businessUnit.put("fileSaveName", paramInJson.getString("fileSaveName"));
+ business.getJSONObject(CommonConstant.HTTP_BUSINESS_DATAS).put("businessFileRel", businessUnit);
+
+ return business;
+ }
+
+ /**
+ * 娣诲姞灏忓尯淇℃伅
+ *
+ * @param paramInJson 鎺ュ彛璋冪敤鏀句紶鍏ュ叆鍙�
+ * @param dataFlowContext 鏁版嵁涓婁笅鏂�
+ * @return 璁㈠崟鏈嶅姟鑳藉鎺ュ彈鐨勬姤鏂�
+ */
+ public JSONObject addAdvert(JSONObject paramInJson, DataFlowContext dataFlowContext) {
+
+ String advertId = GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_advertId);
+ paramInJson.put("advertId", advertId);
+ JSONObject business = JSONObject.parseObject("{\"datas\":{}}");
+ business.put(CommonConstant.HTTP_BUSINESS_TYPE_CD, BusinessTypeConstant.BUSINESS_TYPE_SAVE_ADVERT);
+ business.put(CommonConstant.HTTP_SEQ, DEFAULT_SEQ);
+ business.put(CommonConstant.HTTP_INVOKE_MODEL, CommonConstant.HTTP_INVOKE_MODEL_S);
+ JSONObject businessAdvert = new JSONObject();
+ businessAdvert.putAll(paramInJson);
+ businessAdvert.put("advertId", advertId);
+ businessAdvert.put("state", "1000");
+ //璁＄畻 搴旀敹閲戦
+ business.getJSONObject(CommonConstant.HTTP_BUSINESS_DATAS).put("businessAdvert", businessAdvert);
+ return business;
+ }
+
+ /**
+ * 鍒犻櫎鎵�鏈夌殑鐓х墖鎴栬棰戜俊鎭�
+ *
+ * @param advertItemDto
+ * @param context
+ * @return
+ */
+ public JSONObject delAdvertItemPhotoOrVideo(AdvertItemDto advertItemDto, DataFlowContext context) {
+ JSONObject business = JSONObject.parseObject("{\"datas\":{}}");
+ business.put(CommonConstant.HTTP_BUSINESS_TYPE_CD, BusinessTypeConstant.BUSINESS_TYPE_DELETE_ADVERT_ITEM);
+ business.put(CommonConstant.HTTP_SEQ, DEFAULT_SEQ);
+ business.put(CommonConstant.HTTP_INVOKE_MODEL, CommonConstant.HTTP_INVOKE_MODEL_S);
+ JSONObject businessAdvertItem = new JSONObject();
+ businessAdvertItem.put("advertItemId", advertItemDto.getAdvertItemId());
+ businessAdvertItem.put("communityId", advertItemDto.getCommunityId());
+ //璁＄畻 搴旀敹閲戦
+ business.getJSONObject(CommonConstant.HTTP_BUSINESS_DATAS).put("businessAdvertItem", businessAdvertItem);
+ return business;
+ }
+
+
+ /**
+ * 鍒犻櫎骞垮憡鏂囦欢鍏崇郴
+ *
+ * @param fileRelDto 鎺ュ彛璋冪敤鏀句紶鍏ュ叆鍙�
+ * @param dataFlowContext 鏁版嵁涓婁笅鏂�
+ * @return 璁㈠崟鏈嶅姟鑳藉鎺ュ彈鐨勬姤鏂�
+ */
+ public JSONObject delAdvertFileRel(FileRelDto fileRelDto, DataFlowContext dataFlowContext) {
+
+
+ JSONObject business = JSONObject.parseObject("{\"datas\":{}}");
+ business.put(CommonConstant.HTTP_BUSINESS_TYPE_CD, BusinessTypeConstant.BUSINESS_TYPE_DELETE_FILE_REL);
+ business.put(CommonConstant.HTTP_SEQ, DEFAULT_SEQ + 1);
+ business.put(CommonConstant.HTTP_INVOKE_MODEL, CommonConstant.HTTP_INVOKE_MODEL_S);
+ JSONObject businessUnit = new JSONObject();
+ businessUnit.put("fileRelId", fileRelDto.getFileRelId());
+ business.getJSONObject(CommonConstant.HTTP_BUSINESS_DATAS).put("businessFileRel", businessUnit);
+ return business;
+ }
+
+ /**
+ * 娣诲姞鍙戝竷骞垮憡淇℃伅
+ *
+ * @param paramInJson 鎺ュ彛璋冪敤鏀句紶鍏ュ叆鍙�
+ * @param dataFlowContext 鏁版嵁涓婁笅鏂�
+ * @return 璁㈠崟鏈嶅姟鑳藉鎺ュ彈鐨勬姤鏂�
+ */
+ public JSONObject updateAdvert(JSONObject paramInJson, DataFlowContext dataFlowContext) {
+
+ AdvertDto advertDto = new AdvertDto();
+ advertDto.setAdvertId(paramInJson.getString("advertId"));
+ advertDto.setCommunityId(paramInJson.getString("communityId"));
+ List<AdvertDto> advertDtos = advertInnerServiceSMOImpl.queryAdverts(advertDto);
+
+ Assert.listOnlyOne(advertDtos, "涓嶅瓨鍦ㄨ鏉″箍鍛� 鎴栧瓨鍦ㄥ鏉℃暟鎹�");
+
+ JSONObject business = JSONObject.parseObject("{\"datas\":{}}");
+ business.put(CommonConstant.HTTP_BUSINESS_TYPE_CD, BusinessTypeConstant.BUSINESS_TYPE_UPDATE_ADVERT);
+ business.put(CommonConstant.HTTP_SEQ, DEFAULT_SEQ);
+ business.put(CommonConstant.HTTP_INVOKE_MODEL, CommonConstant.HTTP_INVOKE_MODEL_S);
+ JSONObject businessAdvert = new JSONObject();
+ businessAdvert.putAll(paramInJson);
+ businessAdvert.put("state", advertDtos.get(0).getState());
+ //璁＄畻 搴旀敹閲戦
+ business.getJSONObject(CommonConstant.HTTP_BUSINESS_DATAS).put("businessAdvert", businessAdvert);
+ return business;
+ }
}
--
Gitblit v1.8.0