From c02975ee6f3fc3cc32b6b4f3664a3036b7ae13a9 Mon Sep 17 00:00:00 2001 From: sunyuchao Date: Thu, 22 Sep 2022 13:27:22 +0800 Subject: [PATCH] =?UTF-8?q?=E7=A8=8B=E5=BA=8F=E8=B0=83=E6=95=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../item/service/impl/ItemServiceImpl.java | 21 ++++++++++--------- 1 file changed, 11 insertions(+), 10 deletions(-) diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/impl/ItemServiceImpl.java b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/impl/ItemServiceImpl.java index 1b29768a8..c3eeeefd5 100755 --- a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/impl/ItemServiceImpl.java +++ b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/impl/ItemServiceImpl.java @@ -2331,21 +2331,22 @@ public class ItemServiceImpl extends BaseServiceImpl implem private void insertNewHandleProcess(List progressList, String itemId, String itemGridPlatformId) { try { - for (EventProcessResultDto dto : progressList) { + //22.9.22 增加业务逻辑 判断项目是否已存在来自网格化平台的流程数据，存在时只把最新的流程数据放入表中，之前的不作处理 start + QueryWrapper wrapper = new QueryWrapper<>(); + wrapper.eq("item_id", itemId); + wrapper.eq("created_by", "网格化平台"); + wrapper.eq("del_flag", "0"); + wrapper.orderByDesc("created_time"); + wrapper.last("limit 1"); + ItemHandleProcessEntity processEntity = itemHandleProcessDao.selectOne(wrapper); + //22.9.22 end + for (EventProcessResultDto dto : + progressList) { SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); Date insertTime = sdf.parse(dto.getCREATEDATE()); - //22.9.22 增加业务逻辑 判断项目是否已存在来自网格化平台的流程数据，存在时只把最新的流程数据放入表中，之前的不作处理 start - QueryWrapper wrapper = new QueryWrapper<>(); - wrapper.eq("item_id", itemId); - wrapper.eq("created_by", "网格化平台"); - wrapper.eq("del_flag", "0"); - wrapper.orderByDesc("created_time", Constant.CREATE_DATE); - wrapper.last("limit 1"); - ItemHandleProcessEntity processEntity = itemHandleProcessDao.selectOne(wrapper); if (null != processEntity && insertTime.compareTo(processEntity.getCreatedTime()) < NumConstant.ONE) { continue; } - //22.9.22 end // 拉取的记录增加30秒，防止出现排序问题 insertTime.setTime(insertTime.getTime() + 55000); String itemHandleProcessId = UUID.randomUUID().toString().replaceAll("-", "");