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

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

@@ -0,0 +1,89 @@
+package com.elink.esua.epdc.dto.item.result;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @Author：wgf
+ * @Date：2022/9/16 14:52
+ */
+@Data
+public class ItemHandleProcessToCityResultDTO implements Serializable {
+    private static final long serialVersionUID = 3624085359608359124L;
+
+    private String id;
+
+    /**
+     * 项目ID
+     */
+    private String itemId;
+
+    /**
+     * 状态
+     */
+    private Integer state;
+
+    /**
+     * 处理意见
+     */
+    private String handleAdvice;
+
+    /**
+     * 处理意见（外部）
+     */
+    private String outHandleAdvice;
+
+    /**
+     * 结案审批部门ID
+     */
+    private long closeCheckId;
+
+    /**
+     * 操作人部门ID
+     */
+    private long handlerDeptId;
+
+    /**
+     * 操作人部门
+     */
+    private String handlerDept;
+
+    /**
+     * 乐观锁
+     */
+    private Integer revision;
+
+    /**
+     * 创建者
+     */
+    private String createdBy;
+
+    /**
+     * 创建时间
+     */
+    private Date createdTime;
+
+    /**
+     * 修改者
+     */
+    private String updatedBy;
+
+    /**
+     * 修改时间
+     */
+    private Date updatedTime;
+
+    /**
+     * 是否已删除(0-未删除，1-已删除)
+     */
+    private String delFlag;
+
+
+    // 诉求状态
+    private String sqzt;
+    // 当前处理环节
+    private String dqclhj;
+
+}

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

@@ -19,6 +19,7 @@ package com.elink.esua.epdc.modules.item.dao;
 
 import com.elink.esua.epdc.commons.mybatis.dao.BaseDao;
 import com.elink.esua.epdc.dto.item.ItemHandleProcessDTO;
+import com.elink.esua.epdc.dto.item.result.ItemHandleProcessToCityResultDTO;
 import com.elink.esua.epdc.modules.item.entity.ItemHandleProcessEntity;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
@@ -71,5 +72,5 @@ public interface ItemHandleProcessDao extends BaseDao<ItemHandleProcessEntity> {
      * @param state
      * @return
      */
-    List<ItemHandleProcessDTO> getProcessListByState(@Param("state") String state);
+    List<ItemHandleProcessToCityResultDTO> getProcessListByState(@Param("state") String state);
 }

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

@@ -20,6 +20,7 @@ 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.dto.item.result.ItemHandleProcessToCityResultDTO;
 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.*;
@@ -53,12 +54,20 @@ public class PushToCityGridServiceImpl implements PushToCityGridService {
     @Override
     public void appealDispatch() {
 
-        List<ItemHandleProcessDTO> list = itemHandleProcessDao.getProcessListByState("30");
+        // 获取数据
+        List<ItemHandleProcessToCityResultDTO> list = itemHandleProcessDao.getProcessListByState("30");
+        for(ItemHandleProcessToCityResultDTO bdDto : list){
+            // 组装数据 todo
+            AppealDispatchResultDto data = new AppealDispatchResultDto();
+            data.setSqid(bdDto.getItemId());  // 诉求ID
+            data.setSqzt(bdDto.getSqzt());  // 诉求状态
+            data.setDqclhj(bdDto.getDqclhj()); // 当前处理环节
+
+            // 调用接口
+            cityGridApi.sendItemToCity(data, PushToCityGridConstant.APPEAL_DISPATCH,"诉求派遣");
+        }
 
-        // 组装数据 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,9 +20,13 @@
         order by CREATED_TIME desc
         limit 1
     </select>
-    <select id="getProcessListByState" resultType="com.elink.esua.epdc.dto.item.ItemHandleProcessDTO">
+    <select id="getProcessListByState" resultType="com.elink.esua.epdc.dto.item.result.ItemHandleProcessToCityResultDTO">
         select
-        p.*
+        p.ITEM_ID as sqid,
+        '01' as sqzt,
+        '07' as dqclhj
+
+
         from epdc_item_handle_process p
         where p.DEL_FLAG='0'
         and p.STATE = #{state}