修改参数

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

@@ -23,7 +23,6 @@ public class MonitorFanIndicatorImpl implements IMonitorFanIndicator {
 
 
     @Override
-    @Async("jxiopAsyncExecutor")
     public void UpdateMonitorFanIndicator(List<IndexDto> list) {
 
         monitorFanIndicatorregionMapper.UpdateMonitorFanIndicator(list);

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

@@ -13,13 +13,14 @@ import org.influxdb.dto.QueryResult;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.scheduling.annotation.Async;
+import org.springframework.stereotype.Component;
 import org.springframework.stereotype.Service;
 
 import java.util.ArrayList;
 import java.util.List;
 
-@Service
-public class StationDataTaskImpl implements IStationDataTask {
+@Component
+public class StationDataTaskImpl {
     @Autowired
     StationBasicServiceImpl stationBasicServiceImpl;
 
@@ -41,7 +42,6 @@ public class StationDataTaskImpl implements IStationDataTask {
     @Value("${station.isok}")
     private boolean  isok;
 
-    @Override
     public List<StationTaksDto> getListStationBasic() {
         List<StationTaksDto> stationTaksDtoList = new ArrayList<>();
         List<StationBasic> stationBasicList= stationBasicServiceImpl.list();
@@ -54,7 +54,7 @@ public class StationDataTaskImpl implements IStationDataTask {
         return stationTaksDtoList;
     }
 
-    @Override
+    @Async("jxiopAsyncExecutor")
     public List<DeviceDto> getListDevice(StationTaksDto stationTaksDto) {
         List<DeviceDto> deviceDtoList =   new ArrayList<>();
         TpriDmpDatabook tpriDmpDatabook =  tpriDmpDatabookServiceImpl.getTpriDmpDatabookByDataName("风机");
@@ -71,7 +71,6 @@ public class StationDataTaskImpl implements IStationDataTask {
     }
 
     @Async("jxiopAsyncExecutor")
-    @Override
     public void getIndexDto(DeviceDto deviceDto) {
 
         //每个分机的指标数据
@@ -105,4 +104,6 @@ public class StationDataTaskImpl implements IStationDataTask {
         }
     }
 
+
+
 }

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

@@ -3,6 +3,7 @@ package com.yeejoin.amos.boot.module.jxiop.biz.tasks;
 import com.yeejoin.amos.boot.module.jxiop.api.dto.DeviceDto;
 import com.yeejoin.amos.boot.module.jxiop.api.dto.StationTaksDto;
 import com.yeejoin.amos.boot.module.jxiop.api.service.IStationDataTask;
+import com.yeejoin.amos.boot.module.jxiop.biz.service.impl.StationDataTaskImpl;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
@@ -19,7 +20,7 @@ import java.util.List;
 public class StationDataTask {
 
     @Autowired
-    IStationDataTask  stationDataTask;
+    StationDataTaskImpl stationDataTask;
 
 
     //定时获取场站指标最新数据

amos-boot-system-jxiop/amos-boot-module-jxiop-monitor-biz/src/main/resources/application.properties

@@ -66,7 +66,7 @@ privilege.fegin.name=AMOS-API-PRIVILEGE
 feign.client.config.default.connect-timeout=20000
 feign.client.config.default.read-timeout=20000
 #场站实时数据
-station.task.cron=
+station.task.cron=0 0/2 * * * ?
 #是否切片
 station.isok=true
 #风机更新数据切片量