package com.java110.api.listener.activities; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.java110.api.listener.AbstractServiceApiListener; import com.java110.core.annotation.Java110Listener; import com.java110.core.context.DataFlowContext; import com.java110.core.factory.GenerateCodeFactory; 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.FileDto; import com.java110.dto.file.FileRelDto; import com.java110.entity.center.AppService; import com.java110.event.service.api.ServiceDataFlowEvent; import com.java110.utils.constant.BusinessTypeConstant; import com.java110.utils.constant.CommonConstant; import com.java110.utils.constant.ResponseConstant; import com.java110.utils.constant.ServiceCodeActivitiesConstant; import com.java110.utils.exception.ListenerExecuteException; import com.java110.utils.util.Assert; import com.java110.utils.util.BeanConvertUtil; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.http.HttpHeaders; import org.springframework.http.HttpMethod; import org.springframework.http.ResponseEntity; import java.util.List; /** * 保存活动侦听 * add by wuxw 2019-06-30 */ @Java110Listener("updateActivitiesListener") public class UpdateActivitiesListener extends AbstractServiceApiListener { @Autowired private IActivitiesInnerServiceSMO activitiesInnerServiceSMOImpl; @Autowired private IFileInnerServiceSMO fileInnerServiceSMOImpl; @Autowired private IFileRelInnerServiceSMO fileRelInnerServiceSMOImpl; @Override protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) { Assert.hasKeyAndValue(reqJson, "activitiesId", "活动ID不能为空"); Assert.hasKeyAndValue(reqJson, "communityId", "小区ID不能为空"); Assert.hasKeyAndValue(reqJson, "title", "必填，请填写业活动标题"); Assert.hasKeyAndValue(reqJson, "typeCd", "必填，请选择活动类型"); Assert.hasKeyAndValue(reqJson, "headerImg", "必填，请选择头部照片"); Assert.hasKeyAndValue(reqJson, "context", "必填，请填写活动内容"); Assert.hasKeyAndValue(reqJson, "startTime", "必填，请选择开始时间"); Assert.hasKeyAndValue(reqJson, "endTime", "必填，请选择结束时间"); } @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(); if (reqJson.containsKey("headerImg") && !StringUtils.isEmpty(reqJson.getString("headerImg"))) { FileDto fileDto = new FileDto(); fileDto.setFileId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_file_id)); fileDto.setFileName(fileDto.getFileId()); fileDto.setContext(reqJson.getString("headerImg")); fileDto.setSuffix("jpeg"); fileDto.setCommunityId(reqJson.getString("communityId")); String fileName = fileInnerServiceSMOImpl.saveFile(fileDto); reqJson.put("headerImg", fileDto.getFileId()); reqJson.put("fileSaveName", fileName); businesses.add(editHeaderImg(reqJson, context)); } //添加单元信息 businesses.add(updateActivities(reqJson, context)); JSONObject paramInObj = super.restToCenterProtocol(businesses, context.getRequestCurrentHeaders()); //将 rest header 信息传递到下层服务中去 super.freshHttpHeader(header, context.getRequestCurrentHeaders()); ResponseEntity responseEntity = this.callService(context, service.getServiceCode(), paramInObj); context.setResponseEntity(responseEntity); } /** * 修改头部照片 * * @param paramInJson 接口调用放传入入参 * @param dataFlowContext 数据上下文 * @return 订单服务能够接受的报文 */ private JSONObject editHeaderImg(JSONObject paramInJson, DataFlowContext dataFlowContext) { FileRelDto fileRelDto = new FileRelDto(); fileRelDto.setRelTypeCd("70000"); fileRelDto.setObjId(paramInJson.getString("activitiesId")); List 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; } @Override public String getServiceCode() { return ServiceCodeActivitiesConstant.UPDATE_ACTIVITIES; } @Override public HttpMethod getHttpMethod() { return HttpMethod.POST; } @Override public int getOrder() { return DEFAULT_ORDER; } /** * 添加活动信息 * * @param paramInJson 接口调用放传入入参 * @param dataFlowContext 数据上下文 * @return 订单服务能够接受的报文 */ private JSONObject updateActivities(JSONObject paramInJson, DataFlowContext dataFlowContext) { ActivitiesDto activitiesDto = new ActivitiesDto(); activitiesDto.setActivitiesId(paramInJson.getString("activitiesId")); activitiesDto.setCommunityId(paramInJson.getString("communityId")); List 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; } }