|
@@ -0,0 +1,81 @@
|
|
|
|
+package com.ruoyi;
|
|
|
|
+
|
|
|
|
+import cn.hutool.core.collection.CollUtil;
|
|
|
|
+import cn.hutool.core.date.DateField;
|
|
|
|
+import cn.hutool.core.date.DateTime;
|
|
|
|
+import cn.hutool.core.date.DateUtil;
|
|
|
|
+import cn.hutool.core.text.StrBuilder;
|
|
|
|
+import cn.hutool.core.thread.ThreadUtil;
|
|
|
|
+import cn.hutool.core.util.NumberUtil;
|
|
|
|
+import cn.hutool.core.util.StrUtil;
|
|
|
|
+import com.alibaba.fastjson2.JSON;
|
|
|
|
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
|
+import com.ruoyi.quartz.handler.IJobHandler;
|
|
|
|
+import com.ruoyi.ucp.entity.*;
|
|
|
|
+import com.ruoyi.ucp.feign.AdapterApi;
|
|
|
|
+import com.ruoyi.ucp.service.*;
|
|
|
|
+import com.ruoyi.ucp.util.CalcCache;
|
|
|
|
+import org.apache.commons.math3.fitting.PolynomialCurveFitter;
|
|
|
|
+import org.apache.commons.math3.fitting.WeightedObservedPoints;
|
|
|
|
+import org.springframework.data.redis.core.StringRedisTemplate;
|
|
|
|
+import org.springframework.stereotype.Service;
|
|
|
|
+
|
|
|
|
+import javax.annotation.Resource;
|
|
|
|
+import java.lang.reflect.Field;
|
|
|
|
+import java.net.URI;
|
|
|
|
+import java.util.*;
|
|
|
|
+import java.util.function.Function;
|
|
|
|
+import java.util.concurrent.ConcurrentHashMap;
|
|
|
|
+import java.util.concurrent.atomic.AtomicReference;
|
|
|
|
+import java.util.stream.Collectors;
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+public class JavaFunctionJobHandler extends IJobHandler {
|
|
|
|
+
|
|
|
|
+ @Resource
|
|
|
|
+ private AdapterApi adapter;
|
|
|
|
+ @Resource
|
|
|
|
+ private IPointInfoService pointService;
|
|
|
|
+ @Resource
|
|
|
|
+ private IStationInfoHourService stationInfoHourService;
|
|
|
|
+ @Resource
|
|
|
|
+ private IStationInfoDayService stationInfoDayService;
|
|
|
|
+ @Resource
|
|
|
|
+ private ILineInfoDayService lineInfoDayService;
|
|
|
|
+ @Resource
|
|
|
|
+ private IStateAiService stateAiService;
|
|
|
|
+ @Resource
|
|
|
|
+ private StringRedisTemplate stringRedisTemplate;
|
|
|
|
+ @Resource
|
|
|
|
+ private IEquipmentModelService equipmentModelService;
|
|
|
|
+ @Resource
|
|
|
|
+ private ITurbineInfoDayService turbineInfoDayService;
|
|
|
|
+ @Resource
|
|
|
|
+ private IProEconReportIndicatorPoolService reportIndicatorPoolService;
|
|
|
|
+ @Resource
|
|
|
|
+ private ITurbineInfoMinService turbineInfoMinService;
|
|
|
|
+ @Resource
|
|
|
|
+ private IStationInfoMinService stationInfoMinService;
|
|
|
|
+ @Resource
|
|
|
|
+ private IProBasicProjectPlanService proBasicProjectPlanService;
|
|
|
|
+ @Resource
|
|
|
|
+ private IHistoryPredictService historyPredictService;
|
|
|
|
+ @Resource
|
|
|
|
+ private IPredictExaminService predictExaminService;
|
|
|
|
+
|
|
|
|
+ @Override
|
|
|
|
+ public void execute() throws Exception {
|
|
|
|
+
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ @Override
|
|
|
|
+ public IJobHandler getFunctionHandler() {
|
|
|
|
+ return null;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ @Override
|
|
|
|
+ public void setFunctionHandler(IJobHandler jobHandler) {
|
|
|
|
+
|
|
|
|
+ }
|
|
|
|
+//此处加公式
|
|
|
|
+}
|