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<ItemDao, ItemEntity> implem
     private void insertNewHandleProcess(List<EventProcessResultDto> progressList, String itemId, String itemGridPlatformId) {
 
         try {
-            for (EventProcessResultDto dto : progressList) {
+            //22.9.22 增加业务逻辑 判断项目是否已存在来自网格化平台的流程数据，存在时只把最新的流程数据放入表中，之前的不作处理 start
+            QueryWrapper<ItemHandleProcessEntity> 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<ItemHandleProcessEntity> 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("-", "");