事件上报同步

epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/service/impl/EventreportPingyinServiceImpl.java

@@ -67,20 +67,12 @@ public class EventreportPingyinServiceImpl extends BaseServiceImpl<EventreportPi
         }
         List<EventInfoResultDTO> list = result.getData();
         saveEvent(list, formDTO.getInitFlag());
-        //将同步的数据保存
-        SavePyEventDataFormDTO savePyEventData = new SavePyEventDataFormDTO();
-        savePyEventData.setProjectList(ConvertUtils.sourceToTarget(list, EventreportPingyinDTO.class));
-        dataStatisticalOpenFeignClient.saveData(savePyEventData);
         //分批次循环
         while (CollectionUtils.isNotEmpty(list) && list.size() == formDTO.getPageSize()) {
             formDTO.setPageNo(formDTO.getPageNo() + NumConstant.ONE);
             result = dataStatisticalOpenFeignClient.getEventInfoV2(formDTO);
             list = result.getData();
             saveEvent(list, formDTO.getInitFlag());
-            //将同步的数据保存
-            savePyEventData = new SavePyEventDataFormDTO();
-            savePyEventData.setProjectList(ConvertUtils.sourceToTarget(list, EventreportPingyinDTO.class));
-            dataStatisticalOpenFeignClient.saveData(savePyEventData);
         }
 
 
@@ -211,7 +203,9 @@ public class EventreportPingyinServiceImpl extends BaseServiceImpl<EventreportPi
                 }
             }
         }
-
+        //将同步的数据保存
-
+        SavePyEventDataFormDTO savePyEventData = new SavePyEventDataFormDTO();
+        savePyEventData.setProjectList(ConvertUtils.sourceToTarget(entityList, EventreportPingyinDTO.class));
+        dataStatisticalOpenFeignClient.saveData(savePyEventData);
     }
 }