From 84b5b256cc0147cc99cfa61b2525b376e928d6e1 Mon Sep 17 00:00:00 2001 From: wanggongfeng <1305282856@qq.com> Date: Fri, 16 Sep 2022 15:52:00 +0800 Subject: [PATCH] =?UTF-8?q?=E9=9D=92=E5=B2=9B=E5=B8=82=E9=9D=92=E8=AF=89?= =?UTF-8?q?=E5=8D=B3=E5=8A=9E=E5=B9=B3=E5=8F=B0=E6=8E=A5=E5=85=A5=20---=20?= =?UTF-8?q?=E8=AF=89=E6=B1=82=E6=B4=BE=E9=81=A3--=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ItemHandleProcessToCityResultDTO.java | 89 +++++++++++++++++++ .../item/dao/ItemHandleProcessDao.java | 3 +- .../impl/PushToCityGridServiceImpl.java | 17 +++- .../mapper/item/ItemHandleProcessDao.xml | 8 +- 4 files changed, 110 insertions(+), 7 deletions(-) create mode 100644 esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/item/result/ItemHandleProcessToCityResultDTO.java diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/item/result/ItemHandleProcessToCityResultDTO.java b/esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/item/result/ItemHandleProcessToCityResultDTO.java new file mode 100644 index 000000000..869f9c174 --- /dev/null +++ b/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; + +} diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/dao/ItemHandleProcessDao.java b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/dao/ItemHandleProcessDao.java index ba04b2580..655fad0e4 100644 --- a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/dao/ItemHandleProcessDao.java +++ b/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 { * @param state * @return */ - List getProcessListByState(@Param("state") String state); + List getProcessListByState(@Param("state") String state); } 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 af490ed4b..4e1b05424 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 @@ -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 list = itemHandleProcessDao.getProcessListByState("30"); + // 获取数据 + List 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,"诉求派遣"); diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/resources/mapper/item/ItemHandleProcessDao.xml b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/resources/mapper/item/ItemHandleProcessDao.xml index b1c5b5ecb..82c5ea233 100644 --- a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/resources/mapper/item/ItemHandleProcessDao.xml +++ b/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 - 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}