青岛市青诉即办平台接入 --- 诉求派遣

esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/constant/PushToCityGridConstant.java

@@ -0,0 +1,16 @@
+package com.elink.esua.epdc.constant;
+
+/**
+ * 青岛市青诉即办平台接入常量类
+ * @Author wgf
+ * @Date 2022/9/16 14:07
+ */
+public interface PushToCityGridConstant {
+
+    /**
+     * 诉求派遣
+     */
+    public final static String APPEAL_DISPATCH = "http://ip:port/case/dispatch";
+
+
+}

esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/item/result/AppealDispatchResultDto.java

@@ -0,0 +1,106 @@
+package com.elink.esua.epdc.dto.item.result;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.util.Date;
+import java.util.List;
+
+/**
+ * @author wanggongfeng
+ * @date 2022/9/16 11:12
+ */
+@NoArgsConstructor
+@Data
+public class AppealDispatchResultDto {
+
+
+    // 诉求ID
+    @JsonProperty("sqid")
+    private String sqid;
+
+    //诉求状态
+    @JsonProperty("sqzt")
+    private String sqzt;
+
+    //当前处理环节
+    @JsonProperty("dqclhj")
+    private String dqclhj;
+
+    //派遣人
+    @JsonProperty("czr")
+    private CzrDTO czr;
+
+    //派遣时间
+    @JsonProperty("czsj")
+    private Date czsj;
+
+    //派遣意见
+    @JsonProperty("cznr")
+    private String cznr;
+
+    //处理期限
+    @JsonProperty("clqx")
+    private String clqx;
+
+    //派遣信息
+    @JsonProperty("pqlist")
+    private List<PqlistDTO> pqlist;
+
+    @NoArgsConstructor
+    @Data
+    public static class CzrDTO {
+        //派遣人员Id
+        @JsonProperty("id")
+        private String id;
+
+        //派遣人员
+        @JsonProperty("xm")
+        private String xm;
+
+        //所属机构Id
+        @JsonProperty("ssjgid")
+        private String ssjgid;
+
+        //所属机构
+        @JsonProperty("ssjgmc")
+        private String ssjgmc;
+
+        //所属部门Id
+        @JsonProperty("ssbmid")
+        private String ssbmid;
+
+        //所属部门
+        @JsonProperty("ssbmmc")
+        private String ssbmmc;
+    }
+
+    @NoArgsConstructor
+    @Data
+    public static class PqlistDTO {
+        //处理人姓名
+        @JsonProperty("clrxm")
+        private String clrxm;
+
+        //处理人ID
+        @JsonProperty("clrid")
+        private String clrid;
+
+        //处理部门
+        @JsonProperty("clbm")
+        private String clbm;
+
+        //处理部门ID
+        @JsonProperty("clbmid")
+        private String clbmid;
+
+        //处理机构
+        @JsonProperty("cljg")
+        private String cljg;
+
+        //处理机构ID
+        @JsonProperty("cljgid")
+        private String cljgid;
+    }
+}

esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/dao/ItemHandleProcessDao.java

@@ -23,6 +23,8 @@ import com.elink.esua.epdc.modules.item.entity.ItemHandleProcessEntity;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 
+import java.util.List;
+
 /**
  * 项目处理流程表 项目处理流程表
  *
@@ -62,4 +64,12 @@ public interface ItemHandleProcessDao extends BaseDao<ItemHandleProcessEntity> {
     * @return com.elink.esua.epdc.modules.item.entity.ItemHandleProcessEntity
     */
     ItemHandleProcessEntity selectByItemIdBestNew(@Param("itemId") String itemId);
+
+
+    /**
+     * 诉求派遣
+     * @param state
+     * @return
+     */
+    List<ItemHandleProcessDTO> getProcessListByState(@Param("state") String state);
 }

esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/PushToCityGridService.java

@@ -27,4 +27,10 @@ package com.elink.esua.epdc.modules.item.service;
 public interface PushToCityGridService {
 
 
+    /**
+     * 诉求派遣
+     */
+    void appealDispatch();
+
+
 }

esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/impl/PushToCityGridServiceImpl.java

@@ -17,12 +17,20 @@
 
 package com.elink.esua.epdc.modules.item.service.impl;
 
+import com.elink.esua.epdc.constant.PushToCityGridConstant;
+import com.elink.esua.epdc.dto.item.ItemHandleProcessDTO;
+import com.elink.esua.epdc.dto.item.result.AppealDispatchResultDto;
+import com.elink.esua.epdc.gird.city.api.CityGridApi;
+import com.elink.esua.epdc.modules.item.dao.ItemHandleProcessDao;
 import com.elink.esua.epdc.modules.item.service.*;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.util.List;
+
 /**
  * 青岛市青诉即办平台接入
  *
@@ -35,6 +43,24 @@ public class PushToCityGridServiceImpl implements PushToCityGridService {
 
     private Logger logger = LogManager.getLogger(PushToCityGridServiceImpl.class);
 
+    @Autowired
+    private ItemHandleProcessDao itemHandleProcessDao;
+
+    @Autowired
+    private CityGridApi cityGridApi;
+
+
+    @Override
+    public void appealDispatch() {
+
+        List<ItemHandleProcessDTO> list = itemHandleProcessDao.getProcessListByState("30");
+
+        // 组装数据 todo
+        AppealDispatchResultDto data = new AppealDispatchResultDto();
+
+        cityGridApi.appealDispatchToCity(data, PushToCityGridConstant.APPEAL_DISPATCH,"诉求派遣");
+
 
 
+    }
 }

esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/resources/mapper/item/ItemHandleProcessDao.xml

@@ -20,4 +20,11 @@
         order by CREATED_TIME desc
         limit 1
     </select>
+    <select id="getProcessListByState" resultType="com.elink.esua.epdc.dto.item.ItemHandleProcessDTO">
+        select
+        p.*
+        from epdc_item_handle_process p
+        where p.DEL_FLAG='0'
+        and p.STATE = #{state}
+    </select>
 </mapper>