Commit 2a6d7ed5 authored by chenzhao's avatar chenzhao

修改代码

parent f56ea8f2
...@@ -28,6 +28,7 @@ import com.yeejoin.amos.boot.module.jxiop.biz.service.IMonitorFanIndicator; ...@@ -28,6 +28,7 @@ import com.yeejoin.amos.boot.module.jxiop.biz.service.IMonitorFanIndicator;
import com.yeejoin.amos.component.robot.BadRequest; import com.yeejoin.amos.component.robot.BadRequest;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled; import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
...@@ -41,6 +42,7 @@ import java.util.stream.Collectors; ...@@ -41,6 +42,7 @@ import java.util.stream.Collectors;
* @createDate: 2023/7/3 * @createDate: 2023/7/3
*/ */
@Service @Service
@EnableScheduling
public class MonitorFanIndicatorImpl implements IMonitorFanIndicator { public class MonitorFanIndicatorImpl implements IMonitorFanIndicator {
@Autowired @Autowired
...@@ -55,8 +57,6 @@ public class MonitorFanIndicatorImpl implements IMonitorFanIndicator { ...@@ -55,8 +57,6 @@ public class MonitorFanIndicatorImpl implements IMonitorFanIndicator {
@Autowired @Autowired
InfluxDButils influxDButils; InfluxDButils influxDButils;
@Autowired
InfluxDButils influxDButils;
@Autowired @Autowired
TemporaryDataMapper temporaryDataMapper; TemporaryDataMapper temporaryDataMapper;
...@@ -414,9 +414,9 @@ public class MonitorFanIndicatorImpl implements IMonitorFanIndicator { ...@@ -414,9 +414,9 @@ public class MonitorFanIndicatorImpl implements IMonitorFanIndicator {
@Scheduled(cron = "0 */1 * * * ?") @Scheduled(cron = "0 */5 * * * ?")
private void schedTaskData(){ private void schedTaskData(){
log.info("定时插入数据开始");
LambdaQueryWrapper<StationBasic> wrapper = new LambdaQueryWrapper<>(); LambdaQueryWrapper<StationBasic> wrapper = new LambdaQueryWrapper<>();
wrapper.eq(BaseEntity::getIsDelete,false); wrapper.eq(BaseEntity::getIsDelete,false);
List<StationBasic> stationBasics = stationBasicMapper.selectList(wrapper); List<StationBasic> stationBasics = stationBasicMapper.selectList(wrapper);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment