修改方法

amos-boot-system-jxiop/amos-boot-module-jxiop-monitor-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/service/impl/StationDataTaskImpl.java

@@ -57,17 +57,18 @@ public class StationDataTaskImpl implements IStationDataTask {
     @Async("jxiopAsyncExecutor")
     @Override
     public void getIndexDto(DeviceDto deviceDto) {
-
-
         //每个分机的指标数据
         List<IndexDto> list=null;
-        if(list!=null&&list.size()>0){}
-        //对数据切片处理
-        Lists.partition(list,100);
 
-        //每个分级信息处理
-        monitorFanIndicatorImpl.UpdateMonitorFanIndicator(list);
 
+        if(list!=null&&list.size()>0){
+            //对数据切片处理
+            List<List<IndexDto>>  listfp= Lists.partition(list,100);
+            for (List<IndexDto> indexDtos : listfp) {
+                //每个分级信息处理
+                monitorFanIndicatorImpl.UpdateMonitorFanIndicator(indexDtos);
+            }
+        }
     }
 
 

amos-boot-system-jxiop/amos-boot-module-jxiop-monitor-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/tasks/StationDataTask.java

@@ -27,18 +27,14 @@ public class StationDataTask {
     public void getStationDataTask(){
         //获取所有场站信息
         List<StationTaksDto> list=stationDataTask.getListStationBasic();
-
         for (StationTaksDto stationTaksDto : list) {
             //获取分机
             List<DeviceDto>  listDeviceDto=  stationDataTask.getListDevice(stationTaksDto);
-
-
+            if(listDeviceDto!=null&&listDeviceDto.size()>0){
+                for (DeviceDto deviceDto : listDeviceDto) {
+                    stationDataTask.getIndexDto(deviceDto);
+                }
+            }
         }
-
-
-
     }
-
-
-
 }