diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/item/result/AppealMsgResultDTO.java b/esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/item/result/AppealMsgResultDTO.java new file mode 100644 index 000000000..c6dd23210 --- /dev/null +++ b/esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/item/result/AppealMsgResultDTO.java @@ -0,0 +1,46 @@ +package com.elink.esua.epdc.dto.item.result; + +import com.fasterxml.jackson.annotation.JsonProperty; +import lombok.Data; +import lombok.NoArgsConstructor; + +@NoArgsConstructor +@Data +public class AppealMsgResultDTO { + + /** + * 唯一标识 + */ + @JsonProperty("sqid") + private String sqid; + + /** + * 接收人 + */ + @JsonProperty("jsr") + private String jsr; + + /** + * 发送时间 + */ + @JsonProperty("fssj") + private String fssj; + + /** + * 手机号码 + */ + @JsonProperty("sjhm") + private String sjhm; + + /** + * 信息内容 + */ + @JsonProperty("xxnr") + private String xxnr; + + /** + * 类型 0:短信;1:微信 + */ + @JsonProperty("lx") + private String lx; +} diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/PushToCityGridService.java b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/PushToCityGridService.java index 6459edd83..5a988da1b 100644 --- a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/PushToCityGridService.java +++ b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/PushToCityGridService.java @@ -106,4 +106,14 @@ public interface PushToCityGridService { */ void AppealReporting(); + /** + * 事件感知 + * + * @param + * @return void + * @author zhy + * @date 2022/9/19 10:33 + */ + void appealMsg(); + } diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/impl/PushToCityGridServiceImpl.java b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/impl/PushToCityGridServiceImpl.java index fc41619f0..cc91ddbe9 100644 --- a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/impl/PushToCityGridServiceImpl.java +++ b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/impl/PushToCityGridServiceImpl.java @@ -339,6 +339,27 @@ public class PushToCityGridServiceImpl implements PushToCityGridService { } } + @Override + public void appealMsg() { + // 昨天 + String date = DateUtils.format(DateUtils.addDateDays(new Date(), -1)); + // 我们没有发送短信??? + List list = itemHandleProcessDao.listProcessByStateAndDate(String.valueOf(ItemGridPlatformHandleStatusEnum.HANDLE_OTHER.getValue()), date); + // 拼接数据 + list.forEach(item -> { + AppealMsgResultDTO dto = new AppealMsgResultDTO(); + dto.setSqid(item.getItemId()); + // todo + dto.setJsr(""); + dto.setFssj(""); + dto.setSjhm(""); + dto.setXxnr(""); + dto.setLx(""); + // 组装好直接推送 + cityGridApi.sendItemToCity(dto, PushToCityGridConstant.APPEAL_MSG, "事件感知"); + }); + + } }