事件感知

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;
+}

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();
+
 }

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<ItemHandleProcessDTO> 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, "事件感知");
+        });
+
+    }
 
 }