From e70382b9af72503681b74a427f3e7776faa04a58 Mon Sep 17 00:00:00 2001
From: zhangyuan <zhangyuan@sarnasea.com>
Date: Mon, 19 Sep 2022 10:25:14 +0800
Subject: [PATCH] =?UTF-8?q?=E5=90=B9=E5=93=A8=E9=A9=B3=E5=9B=9E?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../AppealWhistleReportRejectResultDTO.java   | 40 +++++++++++++++++++
 .../item/service/PushToCityGridService.java   |  5 +++
 .../impl/PushToCityGridServiceImpl.java       | 26 ++++++++++++
 3 files changed, 71 insertions(+)
 create mode 100644 esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/item/result/AppealWhistleReportRejectResultDTO.java

diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/item/result/AppealWhistleReportRejectResultDTO.java b/esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/item/result/AppealWhistleReportRejectResultDTO.java
new file mode 100644
index 000000000..a76264bcc
--- /dev/null
+++ b/esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/item/result/AppealWhistleReportRejectResultDTO.java
@@ -0,0 +1,40 @@
+package com.elink.esua.epdc.dto.item.result;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@NoArgsConstructor
+@Data
+public class AppealWhistleReportRejectResultDTO {
+
+    /**
+     * 唯一标识
+     */
+    @JsonProperty("sqid")
+    private String sqid;
+
+    /**
+     * 驳回人
+     */
+    @JsonProperty("bhr")
+    private String bhr;
+
+    /**
+     * 驳回人唯一标识
+     */
+    @JsonProperty("bhrId")
+    private String bhrId;
+
+    /**
+     * 驳回时间
+     */
+    @JsonProperty("bhsj")
+    private String bhsj;
+
+    /**
+     * 驳回原因
+     */
+    @JsonProperty("bhyy")
+    private String bhyy;
+}
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 c8309a96f..ba4cbe0cd 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
@@ -76,4 +76,9 @@ public interface PushToCityGridService {
      */    
     void appealWhistleReport();
 
+    /**
+     * 吹哨驳回
+     */
+    void appealWhistleReportReject();
+
 }
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 5b080eaab..e544d7d7b 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
@@ -263,5 +263,31 @@ public class PushToCityGridServiceImpl implements PushToCityGridService {
             cityGridApi.sendItemToCity(data,PushToCityGridConstant.DISP_ATCH_AUDIT,"派遣审核");
         }
     }
+    
+    @Override
+    public void appealWhistleReportReject() {
+        // 昨天
+        String date = DateUtils.format(DateUtils.addDateDays(new Date(), -1));
+        // state=吹哨驳回的流程数据
+        List<ItemHandleProcessDTO> list = itemHandleProcessDao.listProcessByStateAndDate(String.valueOf(ItemGridPlatformHandleStatusEnum.HANDLE_OTHER.getValue()), date);
+        List<AppealWhistleReportRejectResultDTO> sendData = new ArrayList<>();
+        // 拼接数据
+        list.forEach(item -> {
+            AppealWhistleReportRejectResultDTO dto = new AppealWhistleReportRejectResultDTO();
+
+            dto.setSqid(item.getItemId());
+            // todo
+            dto.setBhr("");
+            dto.setBhrId("");
+            dto.setBhsj(item.getCreatedTime().toString());
+            dto.setBhyy(item.getHandleAdvice());
+
+            sendData.add(dto);
+        });
+
+        // 逐条发送
+        sendData.forEach(item -> cityGridApi.sendItemToCity(item, PushToCityGridConstant.APPEAL_WHISTLE_REPORT_REJECT, "诉求督办"));
+
+    }
 
 }