From 70834eb8e4cc07a7e076ad79b6230f23b277ba52 Mon Sep 17 00:00:00 2001 From: yinzuomei <576302893@qq.com> Date: Tue, 23 May 2023 14:06:20 +0800 Subject: [PATCH 01/14] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E6=B3=A8=E9=87=8A?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/elink/esua/epdc/controller/ApiItemController.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/esua-epdc/epdc-module/epdc-api/epdc-api-server/src/main/java/com/elink/esua/epdc/controller/ApiItemController.java b/esua-epdc/epdc-module/epdc-api/epdc-api-server/src/main/java/com/elink/esua/epdc/controller/ApiItemController.java index bce25d11d..61f5f093f 100644 --- a/esua-epdc/epdc-module/epdc-api/epdc-api-server/src/main/java/com/elink/esua/epdc/controller/ApiItemController.java +++ b/esua-epdc/epdc-module/epdc-api/epdc-api-server/src/main/java/com/elink/esua/epdc/controller/ApiItemController.java @@ -172,7 +172,13 @@ public class ApiItemController { /** * 新新向党，外部调用，推送随手拍数据 - * + * 返参示例：{ + * "code": 0, //0成功 + * "data": { + * "id": "37bcc5f4419b62634f2802aef8c3492f" + * }, + * "msg": "success" + * } * @param fromDTO * @return */ From f4c5afb175994e3ee3ae148d27eda96699852768 Mon Sep 17 00:00:00 2001 From: yinzuomei <576302893@qq.com> Date: Tue, 23 May 2023 15:13:57 +0800 Subject: [PATCH 02/14] =?UTF-8?q?xxxd=5Fevent=E8=A1=A8=E6=96=B0=E5=A2=9E6?= =?UTF-8?q?=E5=88=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../esua/epdc/dto/events/XxxdEventDTO.java | 41 ++++++++++++++++--- .../events/entity/XxxdEventEntity.java | 39 +++++++++++++++--- 2 files changed, 69 insertions(+), 11 deletions(-) diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/events/XxxdEventDTO.java b/esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/events/XxxdEventDTO.java index 639550644..c256d0ed6 100644 --- a/esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/events/XxxdEventDTO.java +++ b/esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/events/XxxdEventDTO.java @@ -4,7 +4,6 @@ import java.io.Serializable; import java.util.Date; import com.fasterxml.jackson.annotation.JsonFormat; -import com.fasterxml.jackson.annotation.JsonIgnore; import lombok.Data; @@ -88,11 +87,6 @@ public class XxxdEventDTO implements Serializable { */ private String[] audios; - /** - * 北上速办事件id - */ - private String bssbEventId; - /** * 处理状态：0-未处理；1-已处理；5-不予处理 */ @@ -118,6 +112,41 @@ public class XxxdEventDTO implements Serializable { */ private Integer sync; + /** + * 0已接收；1已转北上速办事件；2已完结 + */ + private String internalStatus; + + /** + * 北上速办事件id + */ + private String bssbEventId; + + /** + * 内部备注 + */ + private String internalRemark; + + /** + * 网格id + */ + private String gridId; + + /** + * 网格名称 + */ + private String gridName; + + /** + * 社区id + */ + private String communityId; + + /** + * 街道id + */ + private String streetId; + /** * 删除标识 0：未删除，1：已删除 */ diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/entity/XxxdEventEntity.java b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/entity/XxxdEventEntity.java index 2c9b1f062..fee644e94 100644 --- a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/entity/XxxdEventEntity.java +++ b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/entity/XxxdEventEntity.java @@ -76,11 +76,6 @@ public class XxxdEventEntity extends BaseEpdcEntity { */ private String audios; - /** - * 北上速办事件id - */ - private String bssbEventId; - /** * 处理状态：0-未处理；1-已处理；5-不予处理 */ @@ -106,4 +101,38 @@ public class XxxdEventEntity extends BaseEpdcEntity { */ private Integer sync; + /** + * 0已接收；1已转北上速办事件；2已完结 + */ + private String internalStatus; + + /** + * 北上速办事件id + */ + private String bssbEventId; + + /** + * 内部备注 + */ + private String internalRemark; + + /** + * 网格id + */ + private String gridId; + + /** + * 网格名称 + */ + private String gridName; + + /** + * 社区id + */ + private String communityId; + + /** + * 街道id + */ + private String streetId; } From 303003226a7aac5aabc2172fdeee380ec921a576 Mon Sep 17 00:00:00 2001 From: yinzuomei <576302893@qq.com> Date: Tue, 23 May 2023 15:15:57 +0800 Subject: [PATCH 03/14] =?UTF-8?q?=E6=8E=A5=E6=94=B6INTERNAL=5FSTATUS?= =?UTF-8?q?=E9=BB=98=E8=AE=A40?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../epdc/modules/events/service/impl/XxxdEventServiceImpl.java | 1 + 1 file changed, 1 insertion(+) diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/service/impl/XxxdEventServiceImpl.java b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/service/impl/XxxdEventServiceImpl.java index 6a4f8ec20..fc9ccc0c2 100644 --- a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/service/impl/XxxdEventServiceImpl.java +++ b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/service/impl/XxxdEventServiceImpl.java @@ -68,6 +68,7 @@ public class XxxdEventServiceImpl extends BaseServiceImpl Date: Tue, 23 May 2023 19:12:42 +0800 Subject: [PATCH 04/14] =?UTF-8?q?=E6=8E=A5=E6=94=B6=E6=96=B0=E6=96=B0?= =?UTF-8?q?=E5=90=91=E5=85=9A=EF=BC=8C=E5=90=8C=E6=97=B6=E4=B8=8A=E4=BC=A0?= =?UTF-8?q?=E5=88=B0=E6=B0=91=E7=94=9F=E8=AF=89=E6=B1=82?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../esua/epdc/feign/AdminFeignClient.java | 1 + .../epdc/dto/item/form/SubmitItemFormDTO.java | 8 +- .../service/impl/XxxdEventServiceImpl.java | 35 +++- .../epdc/modules/feign/AdminFeignClient.java | 14 +- .../fallback/AdminFeignClientFallback.java | 4 + .../item/service/impl/ItemServiceImpl.java | 172 ++++++++++++++++++ 6 files changed, 230 insertions(+), 4 deletions(-) diff --git a/esua-epdc/epdc-module/epdc-api/epdc-api-server/src/main/java/com/elink/esua/epdc/feign/AdminFeignClient.java b/esua-epdc/epdc-module/epdc-api/epdc-api-server/src/main/java/com/elink/esua/epdc/feign/AdminFeignClient.java index 190f89592..92b58fcdf 100644 --- a/esua-epdc/epdc-module/epdc-api/epdc-api-server/src/main/java/com/elink/esua/epdc/feign/AdminFeignClient.java +++ b/esua-epdc/epdc-module/epdc-api/epdc-api-server/src/main/java/com/elink/esua/epdc/feign/AdminFeignClient.java @@ -27,6 +27,7 @@ import java.util.List; * @date 2019/9/7 9:27 */ @FeignClient(name = ServiceConstant.EPDC_ADMIN_SERVER, fallback = AdminFeignClientFallback.class) +// @FeignClient(name = ServiceConstant.EPDC_ADMIN_SERVER, fallback = AdminFeignClientFallback.class,url = "http://127.0.0.1:9092") public interface AdminFeignClient { /** diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/item/form/SubmitItemFormDTO.java b/esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/item/form/SubmitItemFormDTO.java index b110070b2..da8b58378 100644 --- a/esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/item/form/SubmitItemFormDTO.java +++ b/esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/item/form/SubmitItemFormDTO.java @@ -6,6 +6,7 @@ import lombok.Data; import javax.validation.constraints.NotBlank; import javax.validation.constraints.NotNull; import java.io.Serializable; +import java.util.Date; import java.util.List; /** @@ -140,10 +141,13 @@ public class SubmitItemFormDTO implements Serializable { /** - * 区分 0 网格员上报还是 1 居民上报 + * 区分 0 网格员上报还是 1 居民上报;2：新新向党随手拍 */ private String appealSource; - + /** + * 发布时间 + */ + private Date distributeTime; } diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/service/impl/XxxdEventServiceImpl.java b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/service/impl/XxxdEventServiceImpl.java index fc9ccc0c2..bbe50592a 100644 --- a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/service/impl/XxxdEventServiceImpl.java +++ b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/service/impl/XxxdEventServiceImpl.java @@ -13,15 +13,20 @@ import com.elink.esua.epdc.commons.tools.constant.NumConstant; import com.elink.esua.epdc.commons.tools.constant.StrConstant; import com.elink.esua.epdc.commons.tools.exception.RenException; import com.elink.esua.epdc.commons.tools.utils.ConvertUtils; +import com.elink.esua.epdc.commons.tools.utils.DateUtils; +import com.elink.esua.epdc.commons.tools.utils.SpringContextUtils; import com.elink.esua.epdc.constant.XxxdConstant; import com.elink.esua.epdc.dto.events.XxxdEventDTO; import com.elink.esua.epdc.dto.events.form.XxxdFeedBackQuestionFormDTO; import com.elink.esua.epdc.dto.events.result.XxxdFeedBackResultDTO; +import com.elink.esua.epdc.dto.item.form.SubmitItemFormDTO; import com.elink.esua.epdc.modules.events.dao.XxxdEventDao; import com.elink.esua.epdc.modules.events.entity.XxxdEventEntity; import com.elink.esua.epdc.modules.events.service.XxxdEventService; -import com.google.zxing.oned.UPCAReader; +import com.elink.esua.epdc.modules.item.service.ItemService; +import com.elink.esua.epdc.modules.item.service.impl.ItemServiceImpl; import lombok.extern.slf4j.Slf4j; +import org.apache.commons.collections4.CollectionUtils; import org.apache.commons.lang3.StringUtils; import org.springframework.http.*; import org.springframework.stereotype.Service; @@ -31,6 +36,7 @@ import org.springframework.web.client.RestTemplate; import java.time.LocalDateTime; import java.time.format.DateTimeFormatter; +import java.util.Arrays; import java.util.Date; import java.util.List; @@ -74,6 +80,33 @@ public class XxxdEventServiceImpl extends BaseServiceImpl picList = Arrays.asList(entity.getPics().split(StrConstant.SEMICOLON)); + submitItemFormDTO.setImages(picList); + } + if(StringUtils.isNotBlank(entity.getAudios())){ + // 随手拍语音为多段，epdc_item表语音只能上传一个，这里默认取第一个 + List audioList = Arrays.asList(entity.getAudios().split(StrConstant.SEMICOLON)); + if (CollectionUtils.isNotEmpty(audioList)) { + submitItemFormDTO.setItemVoice(audioList.get(NumConstant.ZERO)); + } + } + SpringContextUtils.getBean(ItemServiceImpl.class).submitXxxdEventToItem(entity.getId(), entity.getLongitude(), entity.getLatitude(), submitItemFormDTO); return entity.getId(); } diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/feign/AdminFeignClient.java b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/feign/AdminFeignClient.java index 2c4fb4ced..f9f70ef7b 100644 --- a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/feign/AdminFeignClient.java +++ b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/feign/AdminFeignClient.java @@ -19,7 +19,8 @@ import java.util.List; * @email yujintao@elink-cn.com * @date 2019/9/7 9:27 */ -@FeignClient(name = ServiceConstant.EPDC_ADMIN_SERVER, fallback = AdminFeignClientFallback.class) +// @FeignClient(name = ServiceConstant.EPDC_ADMIN_SERVER, fallback = AdminFeignClientFallback.class) +@FeignClient(name = ServiceConstant.EPDC_ADMIN_SERVER, fallback = AdminFeignClientFallback.class,url = "http://127.0.0.1:9092") public interface AdminFeignClient { /** @@ -138,4 +139,15 @@ public interface AdminFeignClient { @PostMapping(value = "sys/dept/meta/all", consumes = MediaType.APPLICATION_JSON_VALUE) Result> getAllDept(); + + /** + * 根据坐标获取系统网格 + * + * @param formDto + * @return com.elink.esua.epdc.commons.tools.utils.Result + * @author zhy + * @date 2022/9/5 15:53 + */ + @PostMapping("sys/appsys/dept/gis/getGridByCoordinate") + Result getGridByCoordinate(GisFormDTO formDto); } diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/feign/fallback/AdminFeignClientFallback.java b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/feign/fallback/AdminFeignClientFallback.java index 534b07ebc..52c317206 100644 --- a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/feign/fallback/AdminFeignClientFallback.java +++ b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/feign/fallback/AdminFeignClientFallback.java @@ -85,4 +85,8 @@ public class AdminFeignClientFallback implements AdminFeignClient { return ModuleUtils.feignConError(ServiceConstant.EPDC_ADMIN_SERVER, "getAllDept"); } + @Override + public Result getGridByCoordinate(GisFormDTO formDTO) { + return ModuleUtils.feignConError(ServiceConstant.EPDC_ADMIN_SERVER, "getGridByCoordinate",formDTO); + } } diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/impl/ItemServiceImpl.java b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/impl/ItemServiceImpl.java index b849c3985..ed1d21d38 100755 --- a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/impl/ItemServiceImpl.java +++ b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/impl/ItemServiceImpl.java @@ -23,11 +23,13 @@ import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.elink.esua.epdc.commons.mybatis.service.impl.BaseServiceImpl; import com.elink.esua.epdc.commons.tools.constant.FieldConstant; import com.elink.esua.epdc.commons.tools.constant.NumConstant; import com.elink.esua.epdc.commons.tools.constant.OrganizationTypeConstant; +import com.elink.esua.epdc.commons.tools.constant.StrConstant; import com.elink.esua.epdc.commons.tools.enums.*; import com.elink.esua.epdc.commons.tools.exception.RenException; import com.elink.esua.epdc.commons.tools.page.PageData; @@ -42,6 +44,7 @@ import com.elink.esua.epdc.commons.tools.security.content.dto.result.CheckResult import com.elink.esua.epdc.commons.tools.security.user.SecurityUser; import com.elink.esua.epdc.commons.tools.security.user.UserDetail; import com.elink.esua.epdc.commons.tools.utils.*; +import com.elink.esua.epdc.commons.tools.validator.ValidatorUtils; import com.elink.esua.epdc.constant.*; import com.elink.esua.epdc.constants.MenuCodeConstant; import com.elink.esua.epdc.dto.*; @@ -76,7 +79,9 @@ import com.elink.esua.epdc.modules.category.dao.CategoryDao; import com.elink.esua.epdc.modules.category.entity.CategoryEntity; import com.elink.esua.epdc.modules.category.service.CategoryService; import com.elink.esua.epdc.modules.events.dao.ImgDao; +import com.elink.esua.epdc.modules.events.dao.XxxdEventDao; import com.elink.esua.epdc.modules.events.entity.ImgEntity; +import com.elink.esua.epdc.modules.events.entity.XxxdEventEntity; import com.elink.esua.epdc.modules.events.service.EpdcEventsService; import com.elink.esua.epdc.modules.events.service.ImgService; import com.elink.esua.epdc.modules.feign.AdminFeignClient; @@ -106,6 +111,7 @@ import org.apache.commons.lang3.StringUtils; import org.joda.time.DateTime; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.web.bind.annotation.RequestParam; @@ -231,6 +237,8 @@ public class ItemServiceImpl extends BaseServiceImpl implem // private ItemProcessModifyProducer itemProcessModifyProducer; @Resource private ItemDeptDao itemDeptDao; + @Autowired + private XxxdEventDao xxxdEventDao; @Override public PageData page(Map params) { @@ -3441,6 +3449,102 @@ public class ItemServiceImpl extends BaseServiceImpl implem return new Result().ok(entity.getSerialNum()); } + /** + * 新新向党的事件推送过来，调用此方法。 + * 此方法与上面的submitMsFzItemResi逻辑一致，只是返参返回epdc_item.id + * @param formDto + * @return + */ + @Transactional(rollbackFor = Exception.class) + public String submitMsFzItemResiForXxxd(SubmitItemFormDTO formDto) { + ValidatorUtils.validateEntity(formDto); + imageCheck(formDto.getImages()); + ItemEntity entity = ConvertUtils.sourceToTarget(formDto, ItemEntity.class); + if (null == formDto.getDistributeTime()) { + entity.setDistributeTime(new Date()); + } + entity.setItemState(0);//处理中 + entity.setLastHandleTime(new Date()); + entity.setCategoryCode("13"); + entity.setCategoryFullName("其他"); + entity.setFirstCategoryCode("13"); + entity.setItemCode("PT" + System.currentTimeMillis());//项目编号 + entity.setIsPeople("1");//诉求上报 + entity.setAppealSource(formDto.getAppealSource()); + String code = ""; + if (NumConstant.ZERO_STR.equals(formDto.getPeopleFlag())) { + //民生诉求所属网格对应的所属社区的市中心编码 + Result result = adminFeignClient.getCompleteDept(entity.getGridId()); + if (result.success()) { + code = result.getData().getCommunityDisCenterZoningCode(); + } + entity.setSerialNum(getSerialNum("MS" + code)); + } else if (NumConstant.ONE_STR.equals(formDto.getPeopleFlag())) { + //执法诉求所属街道的市中心编码 + Result dtoResult = adminFeignClient.getSysDeptInfo(entity.getGridId()); + if (dtoResult.success()) { + code = dtoResult.getData().getDisCenterZoningCode(); + // 因为是街道账号，所以上级一定是市北区委 + Long pids = dtoResult.getData().getPid(); + String pnames = dtoResult.getData().getParentName(); + entity.setParentDeptIds(pids + ""); + entity.setParentDeptNames(pnames); + entity.setAllDeptIds(pids + "," + entity.getGridId()); + entity.setAllDeptNames(pnames + "-" + entity.getGrid()); + } + + entity.setSerialNum(getSerialNum("FZ" + code)); + } + baseDao.insert(entity); + //插入项目部门关联表 + itemDeptService.savePeopleSubmitInfo(entity); + // 保存图片 + imgService.saveImages(formDto.getImages(), entity.getId(), ImageConstant.TYPE_IMAGE_BIZ_EVENTS); + // 插入项目处理流程表 + ItemHandleProcessEntity itemHandleProcessEntity = new ItemHandleProcessEntity(); + itemHandleProcessEntity.setItemId(entity.getId()); + itemHandleProcessEntity.setState(ItemHandleCategoryEnum.HANDLE_I_HANDLE_GRID_TOP.getValue()); + itemHandleProcessEntity.setHandleAdvice("诉求已查收，正在办理。"); + itemHandleProcessEntity.setOutHandleAdvice("诉求已查收，正在办理。"); + itemHandleProcessEntity.setHandlerDeptId(entity.getGridId()); + itemHandleProcessEntity.setHandlerDept(entity.getGrid()); + itemHandleProcessService.insert(itemHandleProcessEntity); + //发送事件至区中心 + if ("1".equals(formDto.getPeopleFlag())) { + //保存至企业表 + itemEnterpriseService.savaZfInfo(entity, formDto); + ItemHandleSubmitFormDTO dto = new ItemHandleSubmitFormDTO(); + dto.setId(entity.getId()); + dto.setOutHandleAdvice(itemHandleProcessEntity.getOutHandleAdvice()); + dto.setHandleCategory(ItemHandleCategoryEnum.HANDLE_CLOSING_CASE_APPLY.getValue()); + sendItemToDsf(dto, itemHandleProcessEntity); + } + //发送到市平台 + /*try { + if (NumConstant.ZERO_STR.equals(formDto.getPeopleFlag())) { + //民生 + sendCaseLivelihood(entity); + } else if (NumConstant.ONE_STR.equals(formDto.getPeopleFlag())) { + //发展 + sendCaseDevelop(entity); + } + } catch (Exception e) { + StringBuffer str = new StringBuffer(); + switch (formDto.getPeopleFlag()) { + case NumConstant.ZERO_STR: + str.append("民生"); + break; + case NumConstant.ONE_STR: + str.append("发展"); + break; + } + str.append("诉求上报，发送事件数据到市中心错误，诉求项目Id->").append(entity.getId()); + log.error(str.toString()); + e.printStackTrace(); + }*/ + return entity.getId(); + } + /** * @return void * @describe: 民生诉求 组装数据到市平台 @@ -5430,4 +5534,72 @@ public class ItemServiceImpl extends BaseServiceImpl implem } } + + /** + * 新新向党随手拍事件，保存到民生诉求epdc_item表 + * + * @param submitItemFormDTO :新新向党的随手拍事件 + */ + public void submitXxxdEventToItem(String xxxdEventEntityId,String longitude,String latitude,SubmitItemFormDTO submitItemFormDTO) { + // 0已接收；1已转北上速办事件；2已完结 + String internalStatus = ""; + // 北上速办事件id + String bssbEventId = ""; + // 内部备注 + String internalRemark = ""; + // 网格id + String gridId = ""; + // 网格名称 + String gridName = ""; + // 社区id + String communityId = ""; + // 街道id + String streetId = ""; + LambdaUpdateWrapper updateWrapper = new LambdaUpdateWrapper<>(); + updateWrapper.eq(XxxdEventEntity::getId, xxxdEventEntityId); + try { + // 查询网格信息 + GisFormDTO gisFormDTO = new GisFormDTO(); + gisFormDTO.setLongitude(longitude); + gisFormDTO.setLatitude(latitude); + Result gisGridRes = adminFeignClient.getGridByCoordinate(gisFormDTO); + if (!gisGridRes.success() || null == gisGridRes.getData()) { + internalRemark = "根据经纬度获取网格信息失败:" + gisGridRes.getMsg(); + // return; + }else{ + gridId = String.valueOf(gisGridRes.getData().getGridId()); + gridName = gisGridRes.getData().getGridName(); + communityId = String.valueOf(gisGridRes.getData().getCommunityId()); + streetId = String.valueOf(gisGridRes.getData().getStreetId()); + + // 调用北上诉办-民生诉求方法 + submitItemFormDTO.setGridId(gisGridRes.getData().getGridId()); + submitItemFormDTO.setGrid(gisGridRes.getData().getGridName()); + } + submitItemFormDTO.setGridId(1001L); + submitItemFormDTO.setGrid("test"); + + bssbEventId = this.submitMsFzItemResiForXxxd(submitItemFormDTO); + + } catch (Exception e) { + internalRemark="上传到民生诉求异常"; + log.error("submitXxxdEventToItem上传到民生诉求异常",e); + } finally { + log.info("最终都会被执行-------------------"); + updateWrapper.set(StringUtils.isNotBlank(internalStatus), XxxdEventEntity::getInternalStatus, internalStatus) + .set(StringUtils.isNotBlank(bssbEventId), XxxdEventEntity::getBssbEventId, bssbEventId) + .set(StringUtils.isNotBlank(internalRemark), XxxdEventEntity::getInternalRemark, internalRemark) + .set(StringUtils.isNotBlank(gridId), XxxdEventEntity::getGridId, gridId) + .set(StringUtils.isNotBlank(gridName), XxxdEventEntity::getGridName, gridName) + .set(StringUtils.isNotBlank(communityId), XxxdEventEntity::getCommunityId, communityId) + .set(StringUtils.isNotBlank(streetId), XxxdEventEntity::getStreetId, streetId); + xxxdEventDao.update(null, updateWrapper); + } + + + } + + + + } From 512b01a869d81480ba2ec0845be038146a3457a4 Mon Sep 17 00:00:00 2001 From: yinzuomei <576302893@qq.com> Date: Wed, 24 May 2023 09:40:07 +0800 Subject: [PATCH 05/14] =?UTF-8?q?=E4=BC=98=E5=8C=96submitXxxdEventToItem?= =?UTF-8?q?=E5=8F=AA=E6=9C=89=E7=94=9F=E4=BA=A7=E6=89=8D=E4=BC=9A=E6=8E=A8?= =?UTF-8?q?=E9=80=81=E5=88=B0=E5=B8=82=E5=B9=B3=E5=8F=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/XxxdEventServiceImpl.java | 13 +++- .../item/service/impl/ItemServiceImpl.java | 71 ++++++++++++------- 2 files changed, 57 insertions(+), 27 deletions(-) diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/service/impl/XxxdEventServiceImpl.java b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/service/impl/XxxdEventServiceImpl.java index bbe50592a..d6602400d 100644 --- a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/service/impl/XxxdEventServiceImpl.java +++ b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/service/impl/XxxdEventServiceImpl.java @@ -74,12 +74,23 @@ public class XxxdEventServiceImpl extends BaseServiceImpl implem dto.setHandleCategory(ItemHandleCategoryEnum.HANDLE_CLOSING_CASE_APPLY.getValue()); sendItemToDsf(dto, itemHandleProcessEntity); } - //发送到市平台 - /*try { - if (NumConstant.ZERO_STR.equals(formDto.getPeopleFlag())) { - //民生 - sendCaseLivelihood(entity); - } else if (NumConstant.ONE_STR.equals(formDto.getPeopleFlag())) { - //发展 - sendCaseDevelop(entity); - } - } catch (Exception e) { - StringBuffer str = new StringBuffer(); - switch (formDto.getPeopleFlag()) { - case NumConstant.ZERO_STR: - str.append("民生"); - break; - case NumConstant.ONE_STR: - str.append("发展"); - break; + // ！！！！！！！只有生产推送市平台 + Environment environment = SpringContextUtils.getBean(Environment.class); + String[] activeProfiles = environment.getActiveProfiles(); + if (activeProfiles.length > 0 && "prod".equals(activeProfiles[0])) { + log.info("当前运行环境：" + activeProfiles[0]); + // 发送到市平台 + try { + if (NumConstant.ZERO_STR.equals(formDto.getPeopleFlag())) { + // 民生 + sendCaseLivelihood(entity); + } else if (NumConstant.ONE_STR.equals(formDto.getPeopleFlag())) { + // 发展 + sendCaseDevelop(entity); + } + } catch (Exception e) { + StringBuffer str = new StringBuffer(); + switch (formDto.getPeopleFlag()) { + case NumConstant.ZERO_STR: + str.append("民生"); + break; + case NumConstant.ONE_STR: + str.append("发展"); + break; + } + str.append("诉求上报，发送事件数据到市中心错误，诉求项目Id->").append(entity.getId()); + log.error(str.toString()); + e.printStackTrace(); } - str.append("诉求上报，发送事件数据到市中心错误，诉求项目Id->").append(entity.getId()); - log.error(str.toString()); - e.printStackTrace(); - }*/ + } return entity.getId(); } @@ -5565,7 +5572,8 @@ public class ItemServiceImpl extends BaseServiceImpl implem Result gisGridRes = adminFeignClient.getGridByCoordinate(gisFormDTO); if (!gisGridRes.success() || null == gisGridRes.getData()) { internalRemark = "根据经纬度获取网格信息失败:" + gisGridRes.getMsg(); - // return; + log.error("submitXxxdEventToItem上传到民生诉求异常:"+internalRemark); + // return;// 测试时候注释掉，让它继续执行 }else{ gridId = String.valueOf(gisGridRes.getData().getGridId()); gridName = gisGridRes.getData().getGridName(); @@ -5576,11 +5584,22 @@ public class ItemServiceImpl extends BaseServiceImpl implem submitItemFormDTO.setGridId(gisGridRes.getData().getGridId()); submitItemFormDTO.setGrid(gisGridRes.getData().getGridName()); } - submitItemFormDTO.setGridId(1001L); - submitItemFormDTO.setGrid("test"); - + // dev开发环境临时赋值 + Environment environment = SpringContextUtils.getBean(Environment.class); + String[] activeProfiles = environment.getActiveProfiles(); + if (activeProfiles.length > 0 && "dev".equals(activeProfiles[0])) { + log.info("当前运行环境：" + activeProfiles[0]); + submitItemFormDTO.setGridId(1001L); + submitItemFormDTO.setGrid("test"); + } + // 复制了一个民生诉求提交方法submitMsFzItemResi =》submitMsFzItemResiForXxxd bssbEventId = this.submitMsFzItemResiForXxxd(submitItemFormDTO); + if(StringUtils.isNotBlank(bssbEventId)){ + //成功返回epdc_item.id，说明提交民生诉求成功，状态改为1 + internalStatus=NumConstant.ONE_STR; + log.info("submitXxxdEventToItem上传到民生诉求成功：bssbEventId："+bssbEventId); + } } catch (Exception e) { internalRemark="上传到民生诉求异常"; log.error("submitXxxdEventToItem上传到民生诉求异常",e); From 1f4ee1647a462d487028d9d81ce46198008a1417 Mon Sep 17 00:00:00 2001 From: yinzuomei <576302893@qq.com> Date: Wed, 24 May 2023 09:53:00 +0800 Subject: [PATCH 06/14] =?UTF-8?q?appealSource:=E5=8C=BA=E5=88=86=200=20?= =?UTF-8?q?=E7=BD=91=E6=A0=BC=E5=91=98=E4=B8=8A=E6=8A=A5=E8=BF=98=E6=98=AF?= =?UTF-8?q?=201=20=E5=B1=85=E6=B0=91=E4=B8=8A=E6=8A=A5;2=EF=BC=9A=E6=96=B0?= =?UTF-8?q?=E6=96=B0=E5=90=91=E5=85=9A=E9=9A=8F=E6=89=8B=E6=8B=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/elink/esua/epdc/modules/item/entity/ItemEntity.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/entity/ItemEntity.java b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/entity/ItemEntity.java index 1a2b29bf7..678e5b189 100755 --- a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/entity/ItemEntity.java +++ b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/entity/ItemEntity.java @@ -295,7 +295,7 @@ public class ItemEntity extends BaseEpdcEntity { private Integer repeatFlag; /** - * 区分 0 网格员上报还是 1居民上报 + * 区分 0 网格员上报还是 1 居民上报;2：新新向党随手拍 */ private String appealSource; From ddb9c9faba85998be17abd80c38b3bd098fe97bc Mon Sep 17 00:00:00 2001 From: yinzuomei <576302893@qq.com> Date: Wed, 24 May 2023 09:53:42 +0800 Subject: [PATCH 07/14] =?UTF-8?q?sync=E6=B7=BB=E5=8A=A0=E6=B3=A8=E9=87=8A?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../elink/esua/epdc/modules/events/entity/XxxdEventEntity.java | 1 + 1 file changed, 1 insertion(+) diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/entity/XxxdEventEntity.java b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/entity/XxxdEventEntity.java index fee644e94..58dc753e8 100644 --- a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/entity/XxxdEventEntity.java +++ b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/entity/XxxdEventEntity.java @@ -98,6 +98,7 @@ public class XxxdEventEntity extends BaseEpdcEntity { /** * 是否已同步,0：未同步;1，已同步 + * 成功上传到民生诉求后，值为1 */ private Integer sync; From 4f3ac1ac5b4baddf52773e100f680da37447ebf9 Mon Sep 17 00:00:00 2001 From: yinzuomei <576302893@qq.com> Date: Wed, 24 May 2023 09:54:09 +0800 Subject: [PATCH 08/14] =?UTF-8?q?sync=E6=B7=BB=E5=8A=A0=E6=B3=A8=E9=87=8A?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/com/elink/esua/epdc/dto/events/XxxdEventDTO.java | 1 + 1 file changed, 1 insertion(+) diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/events/XxxdEventDTO.java b/esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/events/XxxdEventDTO.java index c256d0ed6..5f6fa025c 100644 --- a/esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/events/XxxdEventDTO.java +++ b/esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/events/XxxdEventDTO.java @@ -109,6 +109,7 @@ public class XxxdEventDTO implements Serializable { /** * 是否已同步,0：未同步;1，已同步 + * 成功上传到民生诉求后，值为1 */ private Integer sync; From df412a0f464be20a11a0f77ad785a9dda05f0e2a Mon Sep 17 00:00:00 2001 From: yinzuomei <576302893@qq.com> Date: Wed, 24 May 2023 09:58:02 +0800 Subject: [PATCH 09/14] =?UTF-8?q?sync=E6=8E=A5=E6=94=B6=E9=BB=98=E8=AE=A4?= =?UTF-8?q?=E6=9C=AA=E5=90=8C=E6=AD=A5=E3=80=82=E6=88=90=E5=8A=9F=E6=8F=90?= =?UTF-8?q?=E4=BA=A4=E5=88=B0=E6=B0=91=E7=94=9F=E8=AF=89=E6=B1=82=EF=BC=8C?= =?UTF-8?q?=E7=BD=AE=E4=B8=BA=E5=B7=B2=E5=90=8C=E6=AD=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../modules/events/service/impl/XxxdEventServiceImpl.java | 2 ++ .../epdc/modules/item/service/impl/ItemServiceImpl.java | 7 ++++++- 2 files changed, 8 insertions(+), 1 deletion(-) diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/service/impl/XxxdEventServiceImpl.java b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/service/impl/XxxdEventServiceImpl.java index d6602400d..23ced4257 100644 --- a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/service/impl/XxxdEventServiceImpl.java +++ b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/service/impl/XxxdEventServiceImpl.java @@ -76,6 +76,7 @@ public class XxxdEventServiceImpl extends BaseServiceImpl implem String communityId = ""; // 街道id String streetId = ""; + // 是否已同步,0：未同步;1，已同步 + Integer sync = NumConstant.ZERO; LambdaUpdateWrapper updateWrapper = new LambdaUpdateWrapper<>(); updateWrapper.eq(XxxdEventEntity::getId, xxxdEventEntityId); try { @@ -5598,6 +5600,8 @@ public class ItemServiceImpl extends BaseServiceImpl implem if(StringUtils.isNotBlank(bssbEventId)){ //成功返回epdc_item.id，说明提交民生诉求成功，状态改为1 internalStatus=NumConstant.ONE_STR; + // 置为已同步 + sync=NumConstant.ONE; log.info("submitXxxdEventToItem上传到民生诉求成功：bssbEventId："+bssbEventId); } } catch (Exception e) { @@ -5611,7 +5615,8 @@ public class ItemServiceImpl extends BaseServiceImpl implem .set(StringUtils.isNotBlank(gridId), XxxdEventEntity::getGridId, gridId) .set(StringUtils.isNotBlank(gridName), XxxdEventEntity::getGridName, gridName) .set(StringUtils.isNotBlank(communityId), XxxdEventEntity::getCommunityId, communityId) - .set(StringUtils.isNotBlank(streetId), XxxdEventEntity::getStreetId, streetId); + .set(StringUtils.isNotBlank(streetId), XxxdEventEntity::getStreetId, streetId) + .set(null != sync, XxxdEventEntity::getSync, sync); xxxdEventDao.update(null, updateWrapper); } From 44255481ce7fc9392cc426d2096a596a09589f36 Mon Sep 17 00:00:00 2001 From: yinzuomei <576302893@qq.com> Date: Wed, 24 May 2023 09:59:51 +0800 Subject: [PATCH 10/14] =?UTF-8?q?=E6=96=B0=E6=96=B0=E5=90=91=E5=85=9A?= =?UTF-8?q?=E9=9A=8F=E6=89=8B=E6=8B=8D=E6=8F=90=E4=BA=A4=E5=88=B0=E6=B0=91?= =?UTF-8?q?=E7=94=9F=E8=AF=89=E6=B1=82=E6=97=B6=EF=BC=8C=E5=A6=82=E6=9E=9C?= =?UTF-8?q?=E6=A0=B9=E6=8D=AE=E7=BB=8F=E7=BA=AC=E5=BA=A6=E6=89=BE=E4=B8=8D?= =?UTF-8?q?=E5=88=B0=E7=BD=91=E6=A0=BC=EF=BC=8C=E8=BF=94=E5=9B=9E=E3=80=82?= =?UTF-8?q?=E8=AE=B0=E5=BD=95=E5=8E=9F=E5=9B=A0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../epdc/modules/item/service/impl/ItemServiceImpl.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/impl/ItemServiceImpl.java b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/impl/ItemServiceImpl.java index 1ed6eec84..dc1109b34 100755 --- a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/impl/ItemServiceImpl.java +++ b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/impl/ItemServiceImpl.java @@ -5574,9 +5574,9 @@ public class ItemServiceImpl extends BaseServiceImpl implem Result gisGridRes = adminFeignClient.getGridByCoordinate(gisFormDTO); if (!gisGridRes.success() || null == gisGridRes.getData()) { internalRemark = "根据经纬度获取网格信息失败:" + gisGridRes.getMsg(); - log.error("submitXxxdEventToItem上传到民生诉求异常:"+internalRemark); - // return;// 测试时候注释掉，让它继续执行 - }else{ + log.error("submitXxxdEventToItem上传到民生诉求异常:" + internalRemark); + return;// 测试时候注释掉，让它继续执行 + } else { gridId = String.valueOf(gisGridRes.getData().getGridId()); gridName = gisGridRes.getData().getGridName(); communityId = String.valueOf(gisGridRes.getData().getCommunityId()); From b45bcc0b4f181111567a5d54913d32106e4e72a0 Mon Sep 17 00:00:00 2001 From: yinzuomei <576302893@qq.com> Date: Thu, 25 May 2023 09:45:37 +0800 Subject: [PATCH 11/14] =?UTF-8?q?job=E6=B7=BB=E5=8A=A0=EF=BC=9AXxxdFeedBac?= =?UTF-8?q?kQuestionTask?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../form/XxxdFeedBackQuestionTaskFormDTO.java | 25 +++++++++++ .../esua/epdc/feign/ItemFeignClient.java | 9 ++++ .../fallback/ItemFeignClientFallback.java | 11 +++++ .../task/events/XxxdFeedBackQuestionTask.java | 18 ++++++++ .../events/XxxdFeedBackQuestionTaskImpl.java | 42 +++++++++++++++++++ 5 files changed, 105 insertions(+) create mode 100644 esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/events/form/XxxdFeedBackQuestionTaskFormDTO.java create mode 100644 esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/events/XxxdFeedBackQuestionTask.java create mode 100644 esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/events/XxxdFeedBackQuestionTaskImpl.java diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/events/form/XxxdFeedBackQuestionTaskFormDTO.java b/esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/events/form/XxxdFeedBackQuestionTaskFormDTO.java new file mode 100644 index 000000000..e951f99c8 --- /dev/null +++ b/esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/events/form/XxxdFeedBackQuestionTaskFormDTO.java @@ -0,0 +1,25 @@ +package com.elink.esua.epdc.dto.events.form; + +import lombok.Data; + +/** + * @Description 新新向党随手拍的接收数据 + * @Author yzm + * @Date 2023/5/25 9:27 + */ +@Data +public class XxxdFeedBackQuestionTaskFormDTO { + /** + * 问题标识，可唯一识别用户问题的id + */ + private String questionId; + /** + * 开始日期:yyyy-MM-dd + */ + private String startDateStr; + /** + * 结束日期:yyyy-MM-dd + */ + private String endDateStr; +} + diff --git a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/ItemFeignClient.java b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/ItemFeignClient.java index 6cb1bc129..c01f49716 100644 --- a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/ItemFeignClient.java +++ b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/ItemFeignClient.java @@ -2,6 +2,7 @@ package com.elink.esua.epdc.feign; import com.elink.esua.epdc.commons.tools.constant.ServiceConstant; import com.elink.esua.epdc.commons.tools.utils.Result; +import com.elink.esua.epdc.dto.events.form.XxxdFeedBackQuestionTaskFormDTO; import com.elink.esua.epdc.dto.item.form.GetAbnormalDataFormDTO; import com.elink.esua.epdc.dto.screen.form.DataStatisticsFormDTO; import com.elink.esua.epdc.feign.fallback.ItemFeignClientFallback; @@ -79,4 +80,12 @@ public interface ItemFeignClient { @PostMapping("events/PushToCity/getAbnormalData") Result getAbnormalData(@RequestBody GetAbnormalDataFormDTO formDTO); + /** + * 新新向党_随手拍处理反馈定时任务，job调用此方法 + * + * @return + */ + @PostMapping("events/xxxd/question/xxxdFeedBackQuestionTask") + Result xxxdFeedBackQuestionTask(@RequestBody XxxdFeedBackQuestionTaskFormDTO formDTO); + } diff --git a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/fallback/ItemFeignClientFallback.java b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/fallback/ItemFeignClientFallback.java index 939a95461..086db236c 100644 --- a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/fallback/ItemFeignClientFallback.java +++ b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/fallback/ItemFeignClientFallback.java @@ -3,6 +3,7 @@ package com.elink.esua.epdc.feign.fallback; import com.elink.esua.epdc.commons.tools.constant.ServiceConstant; import com.elink.esua.epdc.commons.tools.utils.ModuleUtils; import com.elink.esua.epdc.commons.tools.utils.Result; +import com.elink.esua.epdc.dto.events.form.XxxdFeedBackQuestionTaskFormDTO; import com.elink.esua.epdc.dto.item.form.GetAbnormalDataFormDTO; import com.elink.esua.epdc.dto.screen.form.DataStatisticsFormDTO; import com.elink.esua.epdc.feign.ItemFeignClient; @@ -68,4 +69,14 @@ public class ItemFeignClientFallback implements ItemFeignClient { return ModuleUtils.feignConError(ServiceConstant.EPDC_EVENTS_SERVER, "getAbnormalData", formDTO); } + /** + * 新新向党_随手拍处理反馈定时任务，job调用此方法 + * + * @param formDTO + * @return + */ + @Override + public Result xxxdFeedBackQuestionTask(XxxdFeedBackQuestionTaskFormDTO formDTO) { + return ModuleUtils.feignConError(ServiceConstant.EPDC_EVENTS_SERVER, "xxxdFeedBackQuestionTask", formDTO); + } } diff --git a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/events/XxxdFeedBackQuestionTask.java b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/events/XxxdFeedBackQuestionTask.java new file mode 100644 index 000000000..5297b0ade --- /dev/null +++ b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/events/XxxdFeedBackQuestionTask.java @@ -0,0 +1,18 @@ +package com.elink.esua.epdc.task.events; + +/** + * 新新向党_随手拍处理反馈定时任务 + * + * @author yzm + * @date 2023/05/25 09:19 + */ +public interface XxxdFeedBackQuestionTask { + + /** + * @param params + * @return void + * @author yzm + * @date 2023/05/25 09:19 + */ + void run(String params); +} diff --git a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/events/XxxdFeedBackQuestionTaskImpl.java b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/events/XxxdFeedBackQuestionTaskImpl.java new file mode 100644 index 000000000..bf3d4a384 --- /dev/null +++ b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/events/XxxdFeedBackQuestionTaskImpl.java @@ -0,0 +1,42 @@ +package com.elink.esua.epdc.task.events; + +import com.alibaba.fastjson.JSON; +import com.elink.esua.epdc.dto.events.form.XxxdFeedBackQuestionTaskFormDTO; +import com.elink.esua.epdc.feign.ItemFeignClient; +import org.apache.commons.lang3.StringUtils; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +/** + * @Description 新新向党_随手拍处理反馈定时任务 + * @Author yzm + * @Date 2023/5/25 9:20 + */ +@Component("XxxdFeedBackQuestionTask") +public class XxxdFeedBackQuestionTaskImpl implements XxxdFeedBackQuestionTask { + private Logger logger = LoggerFactory.getLogger(getClass()); + + @Autowired + private ItemFeignClient itemFeignClient; + + /** + * @param params + * @return void + * @author yzm + * @date 2023/05/25 09:19 + */ + @Override + public void run(String params) { + logger.debug("XxxdFeedBackQuestionTask定时任务正在执行，参数为：{}", params); + XxxdFeedBackQuestionTaskFormDTO formDTO = new XxxdFeedBackQuestionTaskFormDTO(); + if (StringUtils.isNotBlank(params)) { + formDTO = JSON.parseObject(params, XxxdFeedBackQuestionTaskFormDTO.class); + } + itemFeignClient.xxxdFeedBackQuestionTask(formDTO); + } + + +} + From 46edb9dc8697085c0170f743d145e3102488f47e Mon Sep 17 00:00:00 2001 From: yinzuomei <576302893@qq.com> Date: Thu, 25 May 2023 10:02:49 +0800 Subject: [PATCH 12/14] =?UTF-8?q?=E6=96=B0=E5=A2=9EprocessId=EF=BC=8C?= =?UTF-8?q?=E8=B0=83=E6=95=B4=E5=87=A0=E5=88=97=E6=B3=A8=E9=87=8A?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../elink/esua/epdc/dto/events/XxxdEventDTO.java | 15 ++++++++++----- .../modules/events/entity/XxxdEventEntity.java | 15 ++++++++++----- 2 files changed, 20 insertions(+), 10 deletions(-) diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/events/XxxdEventDTO.java b/esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/events/XxxdEventDTO.java index 5f6fa025c..ba8b9dbad 100644 --- a/esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/events/XxxdEventDTO.java +++ b/esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/events/XxxdEventDTO.java @@ -88,25 +88,30 @@ public class XxxdEventDTO implements Serializable { private String[] audios; /** - * 处理状态：0-未处理；1-已处理；5-不予处理 + * 反馈入参：处理状态：0-未处理；1-已处理；5-不予处理 */ private String status; /** - * 处理结果 + * 反馈入参：处理结果 */ private String processResult; /** - * 处理时间：yyyy-MM-dd HH:mm:ss + * 反馈入参：处理时间：yyyy-MM-dd HH:mm:ss */ private String processTime; /** - * 处理人 + * 处理人：北上速办处理进展对应的处理部门 */ private String processUser; + /** + * 北上速办处理进展表id + */ + private String processId; + /** * 是否已同步,0：未同步;1，已同步 * 成功上传到民生诉求后，值为1 @@ -114,7 +119,7 @@ public class XxxdEventDTO implements Serializable { private Integer sync; /** - * 0已接收；1已转北上速办事件；2已完结 + * 0已接收；1已转北上速办事件；2已反馈给新新向党 */ private String internalStatus; diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/entity/XxxdEventEntity.java b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/entity/XxxdEventEntity.java index 58dc753e8..f81aa7740 100644 --- a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/entity/XxxdEventEntity.java +++ b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/entity/XxxdEventEntity.java @@ -77,25 +77,30 @@ public class XxxdEventEntity extends BaseEpdcEntity { private String audios; /** - * 处理状态：0-未处理；1-已处理；5-不予处理 + * 反馈入参：处理状态：0-未处理；1-已处理；5-不予处理 */ private String status; /** - * 处理结果 + * 反馈入参：处理结果 */ private String processResult; /** - * 处理时间：yyyy-MM-dd HH:mm:ss + * 反馈入参：处理时间：yyyy-MM-dd HH:mm:ss */ private String processTime; /** - * 处理人 + * 处理人：北上速办处理进展对应的处理部门 */ private String processUser; + /** + * 北上速办处理进展表id + */ + private String processId; + /** * 是否已同步,0：未同步;1，已同步 * 成功上传到民生诉求后，值为1 @@ -103,7 +108,7 @@ public class XxxdEventEntity extends BaseEpdcEntity { private Integer sync; /** - * 0已接收；1已转北上速办事件；2已完结 + * 0已接收；1已转北上速办事件；2已反馈给新新向党 */ private String internalStatus; From 3f4b0b3477256f3ff6e7513c531653b18779cdc8 Mon Sep 17 00:00:00 2001 From: yinzuomei <576302893@qq.com> Date: Thu, 25 May 2023 11:02:25 +0800 Subject: [PATCH 13/14] =?UTF-8?q?"xxxdFeedBackQuestionTask"=E5=BC=80?= =?UTF-8?q?=E5=8F=91=E5=AE=8C=E6=88=90?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../esua/epdc/dto/events/XxxdEventDTO.java | 1 + .../controller/XxxdEventController.java | 23 +++--- .../epdc/modules/events/dao/XxxdEventDao.java | 17 ++++- .../events/entity/XxxdEventEntity.java | 1 + .../events/service/XxxdEventService.java | 9 +++ .../service/impl/XxxdEventServiceImpl.java | 70 ++++++++++++++++++- .../item/service/impl/ItemServiceImpl.java | 11 ++- .../resources/mapper/events/XxxdEventDao.xml | 25 ++++++- 8 files changed, 140 insertions(+), 17 deletions(-) diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/events/XxxdEventDTO.java b/esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/events/XxxdEventDTO.java index ba8b9dbad..cf2dbf276 100644 --- a/esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/events/XxxdEventDTO.java +++ b/esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/events/XxxdEventDTO.java @@ -120,6 +120,7 @@ public class XxxdEventDTO implements Serializable { /** * 0已接收；1已转北上速办事件；2已反馈给新新向党 + * -2反馈新新向党失败 */ private String internalStatus; diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/controller/XxxdEventController.java b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/controller/XxxdEventController.java index 23031b2b9..f6b38f88b 100644 --- a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/controller/XxxdEventController.java +++ b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/controller/XxxdEventController.java @@ -1,28 +1,17 @@ package com.elink.esua.epdc.modules.events.controller; -import cn.hutool.core.codec.Base64Encoder; -import cn.hutool.crypto.SecureUtil; -import cn.hutool.crypto.symmetric.AES; import com.alibaba.fastjson.JSON; -import com.alibaba.fastjson.JSONArray; -import com.alibaba.fastjson.JSONObject; import com.elink.esua.epdc.commons.tools.utils.Result; -import com.elink.esua.epdc.constant.XxxdConstant; import com.elink.esua.epdc.dto.events.XxxdEventDTO; import com.elink.esua.epdc.dto.events.form.XxxdFeedBackQuestionFormDTO; +import com.elink.esua.epdc.dto.events.form.XxxdFeedBackQuestionTaskFormDTO; import com.elink.esua.epdc.dto.events.result.XxxdFeedBackResultDTO; import com.elink.esua.epdc.modules.events.service.XxxdEventService; -import com.fasterxml.jackson.core.JsonParser; import lombok.extern.slf4j.Slf4j; import org.apache.commons.collections4.CollectionUtils; import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.http.*; import org.springframework.web.bind.annotation.*; -import org.springframework.web.client.HttpClientErrorException; -import org.springframework.web.client.RestTemplate; -import java.time.LocalDateTime; -import java.time.format.DateTimeFormatter; import java.util.HashMap; import java.util.List; import java.util.Map; @@ -103,5 +92,15 @@ public class XxxdEventController { } + /** + * 新新向党_随手拍处理反馈定时任务，job调用此方法 + * + * @return + */ + @PostMapping("xxxdFeedBackQuestionTask") + public Result xxxdFeedBackQuestionTask(@RequestBody XxxdFeedBackQuestionTaskFormDTO formDTO) { + xxxdEventService.xxxdFeedBackQuestionTask(formDTO.getQuestionId(), formDTO.getStartDateStr(), formDTO.getEndDateStr()); + return new Result(); + } } diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/dao/XxxdEventDao.java b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/dao/XxxdEventDao.java index a4f0d87d9..18acfa86f 100644 --- a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/dao/XxxdEventDao.java +++ b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/dao/XxxdEventDao.java @@ -3,6 +3,9 @@ package com.elink.esua.epdc.modules.events.dao; import com.elink.esua.epdc.commons.mybatis.dao.BaseDao; import com.elink.esua.epdc.modules.events.entity.XxxdEventEntity; import org.apache.ibatis.annotations.Mapper; +import org.apache.ibatis.annotations.Param; + +import java.util.List; /** * 新新向党随手拍的接收数据 @@ -12,5 +15,17 @@ import org.apache.ibatis.annotations.Mapper; */ @Mapper public interface XxxdEventDao extends BaseDao { - + /** + * @param questionId + * @param startDateStr yyyy-MM-dd + * @param endDateStr yyyy-MM-dd + * @param pageIndex + * @param pageSize + * @return + */ + List selectNoFeedBackData(@Param("questionId") String questionId, + @Param("startDateStr") String startDateStr, + @Param("endDateStr") String endDateStr, + @Param("pageIndex") int pageIndex, + @Param("pageSize") int pageSize); } \ No newline at end of file diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/entity/XxxdEventEntity.java b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/entity/XxxdEventEntity.java index f81aa7740..72d6a0455 100644 --- a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/entity/XxxdEventEntity.java +++ b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/entity/XxxdEventEntity.java @@ -109,6 +109,7 @@ public class XxxdEventEntity extends BaseEpdcEntity { /** * 0已接收；1已转北上速办事件；2已反馈给新新向党 + * -2反馈新新向党失败 */ private String internalStatus; diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/service/XxxdEventService.java b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/service/XxxdEventService.java index fe82d8b87..1d5c6eb33 100644 --- a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/service/XxxdEventService.java +++ b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/service/XxxdEventService.java @@ -52,4 +52,13 @@ public interface XxxdEventService extends BaseService { * @date 2023-05-22 */ void delete(List ids); + + /** + * 新新向党_随手拍处理反馈定时任务,调用 + * + * @param questionId + * @param startDateStr yyyy-MM-dd + * @param endDateStr yyyy-MM-dd + */ + void xxxdFeedBackQuestionTask(String questionId,String startDateStr, String endDateStr); } \ No newline at end of file diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/service/impl/XxxdEventServiceImpl.java b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/service/impl/XxxdEventServiceImpl.java index 23ced4257..4de326d0a 100644 --- a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/service/impl/XxxdEventServiceImpl.java +++ b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/service/impl/XxxdEventServiceImpl.java @@ -20,10 +20,10 @@ import com.elink.esua.epdc.dto.events.XxxdEventDTO; import com.elink.esua.epdc.dto.events.form.XxxdFeedBackQuestionFormDTO; import com.elink.esua.epdc.dto.events.result.XxxdFeedBackResultDTO; import com.elink.esua.epdc.dto.item.form.SubmitItemFormDTO; +import com.elink.esua.epdc.dto.item.result.ItemHandleProgressResultDTO; import com.elink.esua.epdc.modules.events.dao.XxxdEventDao; import com.elink.esua.epdc.modules.events.entity.XxxdEventEntity; import com.elink.esua.epdc.modules.events.service.XxxdEventService; -import com.elink.esua.epdc.modules.item.service.ItemService; import com.elink.esua.epdc.modules.item.service.impl.ItemServiceImpl; import lombok.extern.slf4j.Slf4j; import org.apache.commons.collections4.CollectionUtils; @@ -230,4 +230,72 @@ public class XxxdEventServiceImpl extends BaseServiceImpl list = null; + do { + int pageIndex = (pageNo - NumConstant.ONE) * pageSize; + list = baseDao.selectNoFeedBackData(questionId, startDateStr, endDateStr, pageIndex, pageSize); + //处理数据 + feedBackQuestion(list); + pageNo=pageNo+NumConstant.ONE; + } while (CollectionUtils.isNotEmpty(list) && list.size() == pageSize); + } + + + /** + * 循环每一条数据，查询最后一条处理进展反馈给新新向党 + * @param list + */ + private void feedBackQuestion(List list) { + if (CollectionUtils.isEmpty(list)) { + return; + } + for (XxxdEventEntity xxxdEventEntity : list) { + LambdaUpdateWrapper updateWrapper=new LambdaUpdateWrapper<>(); + updateWrapper.eq(XxxdEventEntity::getId,xxxdEventEntity.getId()); + try { + // 查询北上速办诉求的处理进展 + List processList = SpringContextUtils.getBean(ItemServiceImpl.class).queryItemProcess(xxxdEventEntity.getBssbEventId()); + if(CollectionUtils.isEmpty(processList)){ + throw new RenException("epdc_item_handle_process处理进展为空"); + } + ItemHandleProgressResultDTO latestProcess=processList.get(NumConstant.ZERO); + String processResult = latestProcess.getAdvice(); + String processTime = latestProcess.getCreatedTime(); + // 向新新向党反馈数据结果：status:0-未处理，1-已处理，5-不予处理 + XxxdFeedBackResultDTO resultDTO = submitFeedback(xxxdEventEntity.getQuestionId(), NumConstant.ONE_STR, processResult, processTime); + if (resultDTO.getSuccess()) { + // 反馈成功 + updateWrapper.set(XxxdEventEntity::getStatus, NumConstant.ONE_STR) + .set(XxxdEventEntity::getProcessResult, processResult) + .set(XxxdEventEntity::getProcessTime, processTime) + .set(XxxdEventEntity::getInternalStatus, NumConstant.TWO_STR) + .set(XxxdEventEntity::getProcessId, latestProcess.getId()) + .set(XxxdEventEntity::getProcessUser, latestProcess.getHandlerDept()) + .set(XxxdEventEntity::getInternalRemark, "反馈成功"); + } + } catch (RenException e) { + updateWrapper.set(XxxdEventEntity::getInternalRemark,e.getMsg()) + .set(XxxdEventEntity::getInternalStatus,"-2"); + } catch (Exception e) { + updateWrapper.set(XxxdEventEntity::getInternalRemark,"反馈异常") + .set(XxxdEventEntity::getInternalStatus,"-2"); + } finally { + baseDao.update(null, updateWrapper); + } + } + + } + + } \ No newline at end of file diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/impl/ItemServiceImpl.java b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/impl/ItemServiceImpl.java index dc1109b34..c35e63210 100755 --- a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/impl/ItemServiceImpl.java +++ b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/impl/ItemServiceImpl.java @@ -5623,7 +5623,14 @@ public class ItemServiceImpl extends BaseServiceImpl implem } - - + /** + * 获取民生诉求，处理进展 + * @param itemId + * @return + */ + public List queryItemProcess(String itemId){ + List dtoList = baseDao.selectListOfItemHandleProgressByWork(itemId); + return dtoList; + } } diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/resources/mapper/events/XxxdEventDao.xml b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/resources/mapper/events/XxxdEventDao.xml index 89770bbb2..7775c986e 100644 --- a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/resources/mapper/events/XxxdEventDao.xml +++ b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/resources/mapper/events/XxxdEventDao.xml @@ -3,6 +3,29 @@ - + + \ No newline at end of file From d83c18e3762b4c9f6c30d02f79971524b5733e85 Mon Sep 17 00:00:00 2001 From: yinzuomei <576302893@qq.com> Date: Thu, 25 May 2023 11:27:22 +0800 Subject: [PATCH 14/14] =?UTF-8?q?"xxxdFeedBackQuestionTask"=E6=96=B9?= =?UTF-8?q?=E6=B3=95=E5=AE=8C=E5=96=84?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../epdc/modules/events/service/impl/XxxdEventServiceImpl.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/service/impl/XxxdEventServiceImpl.java b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/service/impl/XxxdEventServiceImpl.java index 4de326d0a..76ed8784c 100644 --- a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/service/impl/XxxdEventServiceImpl.java +++ b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/service/impl/XxxdEventServiceImpl.java @@ -283,6 +283,9 @@ public class XxxdEventServiceImpl extends BaseServiceImpl