|
@@ -1,7 +1,6 @@
|
|
|
package com.jiayue.biz.job;
|
|
|
|
|
|
|
|
|
-import ch.qos.logback.classic.spi.STEUtil;
|
|
|
import cn.hutool.core.bean.BeanUtil;
|
|
|
import cn.hutool.core.date.DateTime;
|
|
|
import cn.hutool.core.util.StrUtil;
|
|
@@ -23,10 +22,8 @@ import org.springframework.scheduling.annotation.EnableScheduling;
|
|
|
import org.springframework.scheduling.annotation.Scheduled;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
-import java.beans.IntrospectionException;
|
|
|
import java.beans.PropertyDescriptor;
|
|
|
import java.lang.reflect.Field;
|
|
|
-import java.lang.reflect.InvocationTargetException;
|
|
|
import java.lang.reflect.Method;
|
|
|
import java.math.BigDecimal;
|
|
|
import java.math.RoundingMode;
|
|
@@ -234,7 +231,7 @@ public class AirDensityJob {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- //存储杨总数据
|
|
|
+ //TODO 迁移内网后需要修改此处,使用杨总提供接口,接收下面的数据 每日更新,更新时间待确认
|
|
|
// @Scheduled(cron = "0 30 14 6 7 ?")
|
|
|
public void saveJsonY() {
|
|
|
// String s = apiHDY.jsonY(DateUtil.format(new Date(), "yyyyMMdd"));
|
|
@@ -313,13 +310,11 @@ public class AirDensityJob {
|
|
|
List<FanModelData> modelDataList = fanModelDataList.stream().filter(f -> f.getStationId().equals(stationInfo.getId())
|
|
|
&& f.getModelName().equals(modelName)).collect(Collectors.toList());
|
|
|
if (modelDataList.size() > 0) {
|
|
|
-// System.out.println("删除");
|
|
|
-// fanModelDataService.deleteFanModelData(modelDataList.get(0).getId());
|
|
|
-//
|
|
|
+ fanModelDataService.deleteFanModelData(modelDataList.get(0).getId());
|
|
|
}
|
|
|
-// System.out.println("新增");
|
|
|
-// mongoTemplate.save(fanModelData);
|
|
|
-//
|
|
|
+
|
|
|
+ mongoTemplate.save(fanModelData);
|
|
|
+
|
|
|
}
|
|
|
}
|
|
|
|