diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/constant/PushToCityGridConstant.java b/esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/constant/PushToCityGridConstant.java new file mode 100644 index 000000000..b05ee38f0 --- /dev/null +++ b/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"; + + +} diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/item/result/AppealDispatchResultDto.java b/esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/item/result/AppealDispatchResultDto.java new file mode 100644 index 000000000..0016feb96 --- /dev/null +++ b/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 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; + } +} 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 452d7f23f..ba04b2580 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 @@ -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 { * @return com.elink.esua.epdc.modules.item.entity.ItemHandleProcessEntity */ ItemHandleProcessEntity selectByItemIdBestNew(@Param("itemId") String itemId); + + + /** + * 诉求派遣 + * @param state + * @return + */ + 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/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 91347f9d2..f0268891d 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 @@ -27,4 +27,10 @@ package com.elink.esua.epdc.modules.item.service; public interface PushToCityGridService { + /** + * 诉求派遣 + */ + void appealDispatch(); + + } 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 d8caa81a4..af490ed4b 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 @@ -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 list = itemHandleProcessDao.getProcessListByState("30"); + + // 组装数据 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 6808923ec..b1c5b5ecb 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,4 +20,11 @@ order by CREATED_TIME desc limit 1 +