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 index 174b4f813..e73450931 100644 --- 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 @@ -107,5 +107,26 @@ public interface PushToCityGridConstant { */ public final static String DELAY_AUDIT = "http://ip:port/case/delayAudit"; + /** + * 2.12 诉求评价 + */ + public final static String EVALUATION = "http://ip:port/case/evaluation"; + + /** + * 2.13 初验申请 + */ + public final static String EARLY_INSPECTION_APPLY = "http://ip:port/case/earlyInspectionApply"; + + /** + * 2.14 诉求初验 + */ + public final static String EARLY_INSPECTION = "http://ip:port/case/earlyInspection"; + + /** + * 2.15 诉求终验 + */ + public final static String END_INSPECTION = "http://ip:port/case/endInspection"; + + } 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 b1d55739f..5234416a8 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 @@ -586,7 +586,30 @@ public class PushToCityGridServiceImpl implements PushToCityGridService { */ @Override public void evaluation() { + // 昨天 + String date = DateUtils.format(DateUtils.addDateDays(new Date(), -1)); + // state=作废的流程数据 + List list = itemHandleProcessDao.listProcessByStateAndDate(String.valueOf(ItemGridPlatformHandleStatusEnum.HANDLE_CL.getValue()), date); + // 拼接数据 + list.forEach(item -> { + EvaluationResultDTO dto = new EvaluationResultDTO(); + dto.setSqid(getSqid(item.getItemId())); + dto.setSqzt(CityPushStateEnum.DPJ.getCode()); + dto.setDqclhj(CityPushLinkEnum.SQ_PJ.getCode()); + //评价结果 + dto.setCzjg(""); + //评价时间 + dto.setCzsj(item.getCreatedTime()); + //评价意见 + dto.setCzyj(item.getOutHandleAdvice()); + //申请人员 + EvaluationResultDTO.CzrBean czr = new EvaluationResultDTO.CzrBean(); + // TODO + dto.setCzr(czr); + // 组装好直接推送 + cityGridApi.sendItemToCity(dto, PushToCityGridConstant.EVALUATION, "诉求评价"); + }); } /** @@ -599,7 +622,28 @@ public class PushToCityGridServiceImpl implements PushToCityGridService { */ @Override public void earlyInspectionApply() { + // 昨天 + String date = DateUtils.format(DateUtils.addDateDays(new Date(), -1)); + // state=作废的流程数据 + List list = itemHandleProcessDao.listProcessByStateAndDate(String.valueOf(ItemGridPlatformHandleStatusEnum.HANDLE_CL.getValue()), date); + // 拼接数据 + list.forEach(item -> { + EarlyInspectionApplyResultDTO dto = new EarlyInspectionApplyResultDTO(); + dto.setSqid(getSqid(item.getItemId())); + dto.setSqzt(CityPushStateEnum.DYS.getCode()); + dto.setDqclhj(CityPushLinkEnum.SQCY.getCode()); + //申请内容 + dto.setSqnr(item.getOutHandleAdvice()); + //申请时间 + dto.setSqsj(item.getCreatedTime()); + //申请人员 + EarlyInspectionApplyResultDTO.SqrBean sqr = new EarlyInspectionApplyResultDTO.SqrBean(); + // TODO + dto.setSqr(sqr); + // 组装好直接推送 + cityGridApi.sendItemToCity(dto, PushToCityGridConstant.EARLY_INSPECTION_APPLY, "初验申请"); + }); } /** @@ -612,7 +656,30 @@ public class PushToCityGridServiceImpl implements PushToCityGridService { */ @Override public void earlyInspection() { + // 昨天 + String date = DateUtils.format(DateUtils.addDateDays(new Date(), -1)); + // state=作废的流程数据 + List list = itemHandleProcessDao.listProcessByStateAndDate(String.valueOf(ItemGridPlatformHandleStatusEnum.HANDLE_CL.getValue()), date); + // 拼接数据 + list.forEach(item -> { + EarlyInspectionResultDTO dto = new EarlyInspectionResultDTO(); + dto.setSqid(getSqid(item.getItemId())); + dto.setSqzt(CityPushStateEnum.DYS.getCode()); + dto.setDqclhj(CityPushLinkEnum.SQ_CY.getCode()); + //评价结果 + dto.setCzjg(""); + //评价时间 + dto.setCzsj(item.getCreatedTime()); + //评价意见 + dto.setCzyj(item.getOutHandleAdvice()); + //申请人员 + EarlyInspectionResultDTO.CzrBean czr = new EarlyInspectionResultDTO.CzrBean(); + // TODO + dto.setCzr(czr); + // 组装好直接推送 + cityGridApi.sendItemToCity(dto, PushToCityGridConstant.EARLY_INSPECTION, "诉求初验"); + }); } /** @@ -625,7 +692,30 @@ public class PushToCityGridServiceImpl implements PushToCityGridService { */ @Override public void endInspection() { + // 昨天 + String date = DateUtils.format(DateUtils.addDateDays(new Date(), -1)); + // state=作废的流程数据 + List list = itemHandleProcessDao.listProcessByStateAndDate(String.valueOf(ItemGridPlatformHandleStatusEnum.HANDLE_CL.getValue()), date); + // 拼接数据 + list.forEach(item -> { + EndInspectionResultDTO dto = new EndInspectionResultDTO(); + dto.setSqid(getSqid(item.getItemId())); + dto.setSqzt(CityPushStateEnum.DYS.getCode()); + dto.setDqclhj(CityPushLinkEnum.SQ_ZY.getCode()); + //评价结果 + dto.setCzjg(""); + //评价时间 + dto.setCzsj(item.getCreatedTime()); + //评价意见 + dto.setCzyj(item.getOutHandleAdvice()); + //申请人员 + EndInspectionResultDTO.CzrBean czr = new EndInspectionResultDTO.CzrBean(); + // TODO + dto.setCzr(czr); + // 组装好直接推送 + cityGridApi.sendItemToCity(dto, PushToCityGridConstant.END_INSPECTION, "诉求终验"); + }); } }