big-model-java/slibra-admin/src/main/java/com/slibra/web/controller/business/HandleDataController.java

package com.slibra.web.controller.business;

import cn.hutool.core.date.DateUtil;
import cn.hutool.http.HttpRequest;
import cn.hutool.http.HttpUtil;
import cn.hutool.poi.excel.ExcelReader;
import cn.hutool.poi.excel.ExcelUtil;
import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONArray;
import com.alibaba.fastjson2.JSONObject;
import com.slibra.business.domain.*;
import com.slibra.business.mapper.*;
import com.slibra.business.res.ChartBasic;
import com.slibra.business.service.ITXinyiForecastComparisonService;
import com.slibra.common.DecimalUtils;
import com.slibra.common.core.domain.TXinyiDaily;
import com.slibra.common.core.controller.BaseController;
import com.slibra.common.enums.BusinessEnum;
import com.slibra.common.utils.DateUtils;
import com.slibra.common.utils.StringUtils;
import com.slibra.quartz.task.AsyncTask;
import com.slibra.quartz.task.RyTask;
import lombok.extern.slf4j.Slf4j;
import org.apache.ibatis.session.ExecutorType;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.util.CollectionUtils;
import org.springframework.web.bind.annotation.*;

import java.io.File;
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.*;

import static com.slibra.common.constant.MyConstants.*;
import static com.slibra.common.constant.MyConstants.BigDecimal_100;
import static com.slibra.common.enums.BusinessEnum.WarningCategoryEnum.CS_TP_YC;

/**
 * 参数配置 信息操作处理
 * 
 *
 */
@Slf4j
@RestController
@RequestMapping("/test")
public class HandleDataController extends BaseController
{
    @Autowired
    private TXinyiIndustryMapper xinyiIndustryMapper;

    @Autowired
    private TXinyiDailyMapper xinyiDailyMapper;

    @Autowired
    private TXinyiLaboratoryMapper xinyiLaboratoryMapper;

    @Autowired
    private TXinyiRobotMapper xinyiRobotMapper;

    @Autowired
    private TXinyiNormConfigMapper xinyiNormConfigMapper;

    @Autowired
    private TXinyiCalculateMapper xinyiCalculateMapper;

    @Autowired
    private TXinyiBigTableHourMapper tXinyiBigTableHourMapper;

    @Autowired
    private TXinyiBigTableDayMapper tXinyiBigTableDayMapper;

    @Autowired
    private  TXinyiBigTableMonthMapper tXinyiBigTableMonthMapper;

    @Autowired
    private SqlSessionFactory sqlSessionFactory;

    @Autowired
    private RyTask ryTask;

    @Autowired
    private AsyncTask asyncTask;

    @Autowired
    private ITXinyiForecastComparisonService xinyiForecastComparisonService;


    public static final String[] queryTags = {"信义污水厂JS_COD_Value","信义污水厂JS_PH_Value","信义污水厂JS_SS_Value","信义污水厂JS_ZL_Value","信义污水厂JS_ZA_Value","信义污水厂JS_AD_Value","信义污水厂JS_T_Value","信义污水厂进水泵房液位","信义污水厂出水瞬时流量","信义污水厂升级出水COD","信义污水厂升级出水PH","信义污水厂升级出水SS","信义污水厂升级出水TN","信义污水厂升级出水TP","信义污水厂升级出水氨氮","信义污水厂AIT202_Value","信义污水厂AIT203_Value","信义污水厂AIT207_Value","信义污水厂AIT206_Value","信义污水厂AIT209_Value","信义污水厂AIT210_Value","信义污水厂进水TDS","信义污水厂FT101_Value","信义污水厂SWCHHYHLB1_R_Value","信义污水厂SWCHHYHLB2_R_Value","信义污水厂SWCHHYHLB3_R_Value","信义污水厂SWCHHYHLB4_R_Value","信义污水厂SWCHHYHLB5_R_Value","信义污水厂SWCHHYHLB6_R_Value","信义污水厂SWCWNHLB1_R_Value","信义污水厂SWCWNHLB2_R_Value","信义污水厂SWCWNHLB3_R_Value","信义污水厂SWCWNHLB4_R_Value","信义污水厂SWCWNHLB5_R_Value","信义污水厂GFJ1_R_Value","信义污水厂GFJ2_R_Value","信义污水厂GFJ3_R_Value","信义污水厂GFJ4_R_Value","信义污水厂GFJ5_R_Value","信义污水厂GFJ6_R_Value","信义污水厂GFJ1_KQLL_Value","信义污水厂GFJ2_KQLL_Value","信义污水厂GFJ3_KQLL_Value","信义污水厂GFJ4_KQLL_Value","信义污水厂GFJ5_KQLL_Value","信义污水厂GFJ6_KQLL_Value"};

//    public static final String[] predictorArr = {"出水COD", "出水SS", "出水总磷", "出水氨氮", "xsy1", "xsy2"};
    public static final String[] predictorArr = {"cs_cod", "cs_ss", "cs_tp", "cs_andan", "xsy1", "xsy2", "qyxsy1", "qyxsy2", "缺氧出水氨氮1", "缺氧出水氨氮2"};

    /**
     *手动处理水质报警
     */
   @GetMapping("/waterWarning")
   public String waterWarning(){
       log.info("进入了 手动触发水质报警的 操作");
       //获取配置表
       List<TXinyiNormConfig> tXinyiNormConfigs = this.xinyiNormConfigMapper.selectTXinyiNormConfigList(null);
       if(CollectionUtils.isEmpty(tXinyiNormConfigs))
           throw new RuntimeException("未查询到配置信息");
       TXinyiNormConfig normConfig = tXinyiNormConfigs.get(0);
       TXinyiIndustry tXinyiIndustry = this.xinyiIndustryMapper.selectTXinyiIndustryNewest();
       if(Objects.isNull(tXinyiIndustry))
           throw new RuntimeException("未查询到工业库信息");
       asyncTask.handleSZWarning(tXinyiIndustry, normConfig);
       return "success";
   }


    /**
     *手动处理生化报警
     */
    @GetMapping("/shWarning")
    public String shWarning(){
        log.info("进入了 手动处理生化报警 操作");
        //获取配置表
        List<TXinyiNormConfig> tXinyiNormConfigs = this.xinyiNormConfigMapper.selectTXinyiNormConfigList(null);
        if(CollectionUtils.isEmpty(tXinyiNormConfigs))
            throw new RuntimeException("未查询到配置信息");
        TXinyiNormConfig normConfig = tXinyiNormConfigs.get(0);
        TXinyiIndustry tXinyiIndustry = this.xinyiIndustryMapper.selectTXinyiIndustryNewest();
        if(Objects.isNull(tXinyiIndustry))
            throw new RuntimeException("未查询到工业库信息");
        List<TXinyiCalculate> tXinyiCalculates = xinyiCalculateMapper.selectTXinyiCalculateList(TXinyiCalculate.builder().testHour(tXinyiIndustry.getTestHour()).build());
        if (!CollectionUtils.isEmpty(tXinyiCalculates)) {
            TXinyiCalculate tXinyiCalculate = tXinyiCalculates.get(0);
            asyncTask.handleSHWarning(tXinyiIndustry, normConfig, tXinyiCalculate);
        }
        return "success";
    }


    /**
     *手动处理化验室报警
     */
    @GetMapping("/robotWarning")
    public String robotWarning(){
        log.info("进入了 手动触发化验室报警的 操作");
        asyncTask.handleRobotWarning(this.xinyiRobotMapper.selectNRobot(1));
        return "success";
    }


    /**
     *手动处理预测报警
     */
    @GetMapping("/forecastWarning")
    public String forecastWarning(){
        log.info("进入了 手动触发预测报警的 操作");
        //获取最新的6条工业科数据
        List<TXinyiIndustry> tXinyiIndustries6 = this.xinyiIndustryMapper.selectNIndustry(INT_6);
        List<TXinyiRobot> tXinyiRobots6 = this.xinyiRobotMapper.selectNRobot(INT_6);
        //2024年7月18日10:31:18  加个校验，只有从来没有数据的水厂才会进入下面的判断
        if(CollectionUtils.isEmpty(tXinyiIndustries6) || tXinyiIndustries6.size() < INT_6
                || CollectionUtils.isEmpty(tXinyiRobots6) || tXinyiRobots6.size() <INT_6){
            log.error("预测的时候，获取最新的6条工业数据或者化验数据不满足，任务终止，工业数据为{}\n化验数据为{}", JSON.toJSONString(tXinyiIndustries6), JSON.toJSONString(tXinyiRobots6));
            return "预测的时候，获取最新的6条工业数据或者化验数据不满足，任务终止";
        }
        //先处理xsy1 和 xsy2 合并成一个数据
//        this.predictorSpecial(tXinyiIndustries6, tXinyiRobots6);
        //2024年7月11日16:55:27  xsy1 和 xsy2 又不合并了。。。 再次分开处理
        for (int i = 0; i < predictorArr.length; i++) {
            String result = ryTask.getPredictor(predictorArr[i]);
            if(StringUtils.isBlank(result) || "error".equals(result)){
                log.info("预测数据返回结果不符合解析条件，返回结果为{}", result);
                continue;
            }
            JSONObject jsonObject = null;
            try {
                jsonObject = JSON.parseObject(result);
            } catch (Exception e) {
                log.error("[转JSON的时候]预测数据返回结果不符合解析条件，返回结果为{}", result);
                continue;
            }
            log.info("^^^^^^^^^^^^^预测接口转弯JSON对象后，原内容是{}", JSON.toJSONString(jsonObject));
            //2024年7月8日15:25:51 加个校验 因为各种奇葩返回。。 比如返回的结果是 "null"
            if(Objects.isNull(jsonObject)){
                log.error("[转JSON的时候]预测数据返回结果是null，不处里");
                continue;
            }
            String task = jsonObject.getString("task");
            String hour = jsonObject.getString("hour");
            String pred = jsonObject.getString("pred");
            String date = jsonObject.getString("date");
            if(StringUtils.isNotBlank(pred) && pred.contains(",")){
                String[] split = pred.split(",");
                if(split.length != 3){
                    log.error("预测数据返回结果为{},长度不是3，无法正常解析", result);
                    //因为部分预测还不支持  所以不需要
//                    ryTask.handleXinYiWarningsYC(cscodBzz, split, cscodGkz, BusinessEnum.WarningCategoryEnum.CS_COD_YC.getCode(), hour, normConfig);
                    continue;
                }
                //解析数据 处理报警 调研prompt 保存等
                this.handlePredictorWarning(split, hour, task, tXinyiIndustries6, tXinyiRobots6, date);
            }else {
                log.error("预测数据返回结果为{},无法正常解析", result);
            }
        }
        return "success";
    }

    @GetMapping("/dateAdd")
    public String dateAdd() {


        // 给定时间段的起始时间和结束时间
        LocalDateTime startTime = LocalDateTime.parse("2024-04-13T16:00:00");
        LocalDateTime endTime = LocalDateTime.parse("2024-04-13T17:00:00");


        /*LocalDateTime startTime = LocalDateTime.parse("2024-02-26T00:00:00");
        LocalDateTime endTime = LocalDateTime.parse("2024-02-27T00:00:00");*/

        // 每个小时的时间格式
        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");

        // 循环按小时分割
        LocalDateTime currentHour = startTime;
        while (currentHour.isBefore(endTime)) {
            String begin = currentHour.format(formatter);
            String end = currentHour.plusMinutes(10).format(formatter);
            // 输出当前小时的起始时间和结束时间
            System.out.println("起始时间：" + begin);
            System.out.println("结束时间：" + end);

            // 当前小时加一小时，作为下一个小时的起始时间
            currentHour = currentHour.plusMinutes(10);

            //每个小时查询一次数据
            String url = "http://10.0.0.27:4568/api/v1/khquerydata";
            HashMap<String, Object> req = new HashMap<>();
            req.put("tagNames", queryTags);
            req.put("startTime", begin);
            req.put("endTime", end);
            req.put("recordNumbers", 100000);
            String body = HttpRequest.post(url).header("Authorization", "c2E6c2E=").header("clientName", "hongshan").body(JSON.toJSONString(req)).execute().body();
//            System.out.println("body = " + body);
            List<HashMap<String, String>> list = new ArrayList<>();

            //行转列数据处理
            for (String queryTag : queryTags) {
                JSONArray array = JSON.parseObject(body).getJSONArray(queryTag);
                //特殊数据处理一
                if(Objects.isNull(array) || array.isEmpty()){
                    System.out.println(queryTag + "查询到了空的数据，跳过本次循环");
                    continue;
                }
                int size = array.size();
                //特殊数据处理二
                if("0".equals(array.get(1) + "")){
                    System.out.println(queryTag + "查询到了数据，但是数据集合只有一条，且都是0");
                    continue;
                }
                //结合至少62个数据才满足条件(有可能获取不到)
                /*if(size < 62){
                    System.out.println(queryTag + "查询到了不符合条件的数据，跳过本次循环");
                    continue;
                }*/

                //存放的数据集
                //利用map去重
                HashMap<String, String> map = new LinkedHashMap<>();
                for (int i = 2; i < size; i++) {
//            System.out.println(i + "" + array.get(i));
                    JSONArray oneRecord = JSON.parseArray(JSON.toJSONString(array.get(i)));
                    //处理为空或者为0的数据
                    Object timeStampValue = oneRecord.get(2);
                    if(Objects.isNull(timeStampValue) || "0".equals(timeStampValue + ""))
                        continue;
                    BigDecimal value = Objects.isNull(oneRecord.get(0)) ? null : new BigDecimal(oneRecord.get(0) + "");
                    long timestamp = (long) timeStampValue;
                    String format = DateUtil.format(new Date(timestamp), DateUtils.YYYYMMDDHH_TS);
                    map.put(format, queryTag + "-" + value);
                }
                list.add(map);
            }
//        System.out.println("list = " + list);
            //先构造对象（list中任意一个map遍历的key个数）  因为合并完并不是1分钟60条，参考上面筛选区间，有时候会有几个值获取不到
            /*HashMap<String, String> oneRow = list.get(0);
            Set<String> set = oneRow.keySet();
            List<Industry> result = new ArrayList<>(set.size());
            set.forEach(s -> {
                Industry industry = new Industry();
                industry.setTestTime(s);
                result.add(industry);
            });*/
            Set<String> recordTimeSet = new HashSet<>();
            Map<String, TXinyiIndustry> recordMap = new HashMap<>();
            for (int i = 0; i < list.size(); i++) {
                HashMap<String, String> map = list.get(i);
                int finalJ = i;
                map.forEach((k, v) ->{
                    TXinyiIndustry industry = null;
                    if(!recordTimeSet.contains(k)){//第一次
                        industry = new TXinyiIndustry();
                        recordTimeSet.add(k);
                        recordMap.put(k, industry);
                    }else{
                        industry = recordMap.get(k);
                    }
                    industry.setTestTime(k);
                    //2024年4月15日11:19:52  额外增加2个字段
                    industry.setTestDate(k.substring(0,10));
                    industry.setTestHour(k.substring(0,13));
                    //解析值
                    String[] split = v.split("-");
                    String type = split[0];
                    BigDecimal value = new BigDecimal(split[1]);
                    if ("信义污水厂JS_COD_Value".equals(type)) {
                        industry.setJsCod(value);
                    } else if ("信义污水厂JS_PH_Value".equals(type)) {
                        industry.setJsPh(value);
                    } else if ("信义污水厂JS_SS_Value".equals(type)) {
                        industry.setJsSs(value);
                    } else if ("信义污水厂JS_ZL_Value".equals(type)) {
                        industry.setJsTp(value);
                    } else if ("信义污水厂JS_ZA_Value".equals(type)) {
                        industry.setJsTn(value);
                    } else if ("信义污水厂JS_AD_Value".equals(type)) {
                        industry.setJsNh3(value);
                    } else if ("信义污水厂JS_T_Value".equals(type)) {
                        industry.setJsSwPh(value);
                    } else if ("信义污水厂进水泵房液位".equals(type)) {
                        industry.setJsBfyw(value);
                    } else if ("信义污水厂出水瞬时流量".equals(type)) {
                        industry.setCsSlqc(value);
                    } else if ("信义污水厂升级出水COD".equals(type)) {
                        industry.setCsCod(value);
                    } else if ("信义污水厂升级出水PH".equals(type)) {
                        industry.setCsPh(value);
                    } else if ("信义污水厂升级出水SS".equals(type)) {
                        industry.setCsSs(value);
                    } else if ("信义污水厂升级出水TN".equals(type)) {
                        industry.setCsTn(value);
                    } else if ("信义污水厂升级出水TP".equals(type)) {
                        industry.setCsTp(value);
                    } else if ("信义污水厂升级出水氨氮".equals(type)) {
                        industry.setCsNh3(value);
                    } else if ("信义污水厂AIT202_Value".equals(type)) {
                        industry.setOneHyzdDo(value);
                    } else if ("信义污水厂AIT203_Value".equals(type)) {
                        industry.setOneHymdDo(value);
                    } else if ("信义污水厂AIT207_Value".equals(type)) {
                        industry.setTwoHyzdDo(value);
                    } else if ("信义污水厂AIT206_Value".equals(type)) {
                        industry.setTwoHymdDo(value);
                    } else if ("信义污水厂AIT209_Value".equals(type)) {
                        industry.setOneMlss(value);
                    } else if ("信义污水厂AIT210_Value".equals(type)) {
                        industry.setTwoMlss(value);
                    } else if ("信义污水厂进水TDS".equals(type)) {
                        industry.setJsTds(value);
                    } else if ("信义污水厂FT101_Value".equals(type)) {
                        industry.setJsSlq(value);
                    } else if ("信义污水厂SWCHHYHLB1_R_Value".equals(type)) {
                        industry.setNHlbOneGp(value);
                    } else if ("信义污水厂SWCHHYHLB2_R_Value".equals(type)) {
                        industry.setNHlbTwoGp(value);
                    } else if ("信义污水厂SWCHHYHLB3_R_Value".equals(type)) {
                        industry.setNHlbThreeGp(value);
                    } else if ("信义污水厂SWCHHYHLB4_R_Value".equals(type)) {
                        industry.setNHlbFourGp(value);
                    } else if ("信义污水厂SWCHHYHLB5_R_Value".equals(type)) {
                        industry.setNhlBFiveGp(value);
                    } else if ("信义污水厂SWCHHYHLB6_R_Value".equals(type)) {
                        industry.setNHlbSixGp(value);
                    } else if ("信义污水厂SWCWNHLB1_R_Value".equals(type)) {
                        industry.setWHlbOneGp(value);
                    } else if ("信义污水厂SWCWNHLB2_R_Value".equals(type)) {
                        industry.setWHlbTwoGp(value);
                    } else if ("信义污水厂SWCWNHLB3_R_Value".equals(type)) {
                        industry.setWHlbThreeGp(value);
                    } else if ("信义污水厂SWCWNHLB4_R_Value".equals(type)) {
                        industry.setWHlbFourGp(value);
                    } else if ("信义污水厂SWCWNHLB5_R_Value".equals(type)) {
                        industry.setWHlbFiveGp(value);
                    } else if ("信义污水厂GFJ1_R_Value".equals(type)) {
                        industry.setFjOne(value);
                    } else if ("信义污水厂GFJ2_R_Value".equals(type)) {
                        industry.setFjTwo(value);
                    } else if ("信义污水厂GFJ3_R_Value".equals(type)) {
                        industry.setFjThree(value);
                    } else if ("信义污水厂GFJ4_R_Value".equals(type)) {
                        industry.setFjFour(value);
                    } else if ("信义污水厂GFJ5_R_Value".equals(type)) {
                        industry.setFjFive(value);
                    } else if ("信义污水厂GFJ6_R_Value".equals(type)) {
                        industry.setFjSix(value);
                    } else if ("信义污水厂GFJ1_KQLL_Value".equals(type)) {
                        industry.setKqllOne(value);
                    } else if ("信义污水厂GFJ2_KQLL_Value".equals(type)) {
                        industry.setKqllTwo(value);
                    } else if ("信义污水厂GFJ3_KQLL_Value".equals(type)) {
                        industry.setKqllThree(value);
                    } else if ("信义污水厂GFJ4_KQLL_Value".equals(type)) {
                        industry.setKqllFour(value);
                    } else if ("信义污水厂GFJ5_KQLL_Value".equals(type)) {
                        industry.setKqllFive(value);
                    } else if ("信义污水厂GFJ6_KQLL_Value".equals(type)) {
                        industry.setKqllSix(value);
                    }else if ("信义污水厂实际碳源加药量".equals(type)) {
                        industry.setSJTYJLY(value);
                    }else if ("信义污水厂除磷加药瞬时流量".equals(type)) {
                        industry.setCLJYSSLL(value);
                    }
                    //只有最后一次才执行数据库添加
                    if(finalJ == list.size()-1){
                        //插入数据库
                        xinyiIndustryMapper.insertTXinyiIndustry(industry);
                    }
                });




            }

        }
        return "ok";
    }

//    @GetMapping("/dateUpdateCL")
//    public String dateUpdateCL() {
//        String fileName = "除磷加药瞬时流量";
//        //输入目录
//        ExcelReader reader = ExcelUtil.getReader("C:\\Users\\10109\\Desktop\\新程序\\" + fileName + ".xls");
//        //解析数据
//        List<List<Object>> readAll = reader.read();
//        if(!CollectionUtils.isEmpty(readAll)){
//            for (List<Object> objects : readAll) {
//                String time = "20" + objects.get(0) + " " + objects.get(1).toString().substring(0, 5);
//                System.out.println("time = " + time);
//                TXinyiIndustry uniqueTXinyiIndustry = this.xinyiIndustryMapper.getUniqueTXinyiIndustry(time);
//                if(!Objects.isNull(uniqueTXinyiIndustry)){
//                    System.out.println(objects.get(2));
//                    BigDecimal CLJYSSLL = Objects.isNull(objects.get(2)) ? null : new BigDecimal(String.valueOf(objects.get(2)));
//                    uniqueTXinyiIndustry.setCLJYSSLL(CLJYSSLL);
//                    this.xinyiIndustryMapper.updateTXinyiIndustry(uniqueTXinyiIndustry);
//                }
//            }
//        }
//        return "ok";
//    }
//
//
//    @GetMapping("/dateUpdateSJTY")
//    public String dateUpdateSJTY() {
//        String fileName = "信义污水厂实际碳源加药量";
//        //输入目录
//        ExcelReader reader = ExcelUtil.getReader("C:\\Users\\10109\\Desktop\\新程序\\" + fileName + ".xls");
//        //解析数据
//        List<List<Object>> readAll = reader.read();
//        if(!CollectionUtils.isEmpty(readAll)){
//            int i = 0;
//            for (List<Object> objects : readAll) {
//                String format = "";
//                if(objects.get(0) instanceof String){
//                    System.out.println("----------是字符串类型的");
//                    String time = ((String) objects.get(0));
//                    System.out.println("time = " + time);
//                    format =  time.replaceAll("-", "/").substring(0, 16);
//                }else if (objects.get(0) instanceof cn.hutool.core.date.DateTime){
//                    System.out.println("++++++++++是日期类型的");
//                    cn.hutool.core.date.DateTime time = (DateTime) objects.get(0);
//                    System.out.println("time = " + time);
//                    format = DateUtil.format(time, DateUtils.YYYYMMDDHHMM_TS);
//                    System.out.println("format = " + format);
//                }else {
//                    System.out.println(JSON.toJSONString(objects));
//                    format = "";
//                    i++;
//                }
//                TXinyiIndustry uniqueTXinyiIndustry = this.xinyiIndustryMapper.getUniqueTXinyiIndustry(format);
//                if(!Objects.isNull(uniqueTXinyiIndustry)){
//                    BigDecimal SJTYJLY = Objects.isNull(objects.get(1)) ? null : new BigDecimal(String.valueOf(objects.get(1)));
//                    uniqueTXinyiIndustry.setSJTYJLY(SJTYJLY);
//                    this.xinyiIndustryMapper.updateTXinyiIndustry(uniqueTXinyiIndustry);
//                }
//            }
//            System.out.println("i =" + i);
//        }
//        return "ok";
//    }
//
//    //下面是新的 将一个小时的数据 更新到一个小时之内的所有的数据中
//    @GetMapping("/dateUpdateCLMinute")
//    public String dateUpdateCLMinute() {
//        String fileName = "除磷加药瞬时流量";
//        //输入目录
//        ExcelReader reader = ExcelUtil.getReader("C:\\Users\\10109\\Desktop\\新程序\\" + fileName + ".xls");
//        //解析数据
//        List<List<Object>> readAll = reader.read();
//        int i = 0;
//        if(!CollectionUtils.isEmpty(readAll)){
//            for (List<Object> objects : readAll) {
//                if(!Objects.isNull(objects.get(0)) && !Objects.isNull(objects.get(1))){
//                    String beginTime = "20" + objects.get(0) + " " + objects.get(1).toString().substring(0, 5);
//                    System.out.println("beginTime = " + beginTime);
//                    String endTime = "20" + objects.get(0) + " " + objects.get(1).toString().substring(0, 3) + "59";
//                    System.out.println("endTime = " + endTime);
//                    //更新数据
//                    System.out.println(objects.get(2));
//                    //有特殊情况
//                    if(Objects.isNull(objects.get(2)) || objects.get(2).toString().contains("-")){
//                        System.out.println("存在特殊的情况，值包含-,不做更新");
//                        i++;
//                    }else{
//                    this.xinyiIndustryMapper.updateTXinyiIndustryCLByBetweenTime(beginTime, endTime, new BigDecimal(String.valueOf(objects.get(2))));
//                    }
//                }
//            }
//        }
//        System.out.println("i = " + i);
//        return "ok";
//    }
//
//
//    @GetMapping("/dateUpdateSJTYMinute")
//    public String dateUpdateSJTYMinute() {
//        String fileName = "信义污水厂实际碳源加药量";
//        //输入目录
//        ExcelReader reader = ExcelUtil.getReader("C:\\Users\\10109\\Desktop\\新程序\\" + fileName + ".xls");
//        //解析数据
//        List<List<Object>> readAll = reader.read();
//        if(!CollectionUtils.isEmpty(readAll)){
//            int i = 0;
//            for (List<Object> objects : readAll) {
//                String beginTime = "";
//                if(objects.get(0) instanceof String){
//                    System.out.println("----------是字符串类型的");
//                    String time = ((String) objects.get(0));
////                    System.out.println("time = " + time);
//                    beginTime = time.replaceAll("-", "/").substring(0, 16);
//                }else if (objects.get(0) instanceof cn.hutool.core.date.DateTime){
//                    System.out.println("++++++++++是日期类型的");
//                    cn.hutool.core.date.DateTime time = (DateTime) objects.get(0);
////                    System.out.println("time = " + time);
//                    beginTime = DateUtil.format(time, DateUtils.YYYYMMDDHHMM_TS);
//                    System.out.println("beginTime = " + beginTime);
//                }else {
//                    System.out.println(JSON.toJSONString(objects));
//                    beginTime = "";
//                    i++;
//                }
//                //endTime
//                String endTime = beginTime.substring(0, 14) + "59";
//                System.out.println("endTime = " + endTime);
//                //更新数据
//                BigDecimal sjtyjly = Objects.isNull(objects.get(1)) ? null : new BigDecimal(String.valueOf(objects.get(1)));
//                this.xinyiIndustryMapper.updateTXinyiIndustrySJByBetweenTime(beginTime, endTime, sjtyjly);
//            }
//            System.out.println("i =" + i);
//        }
//        return "ok";
//    }





//    @GetMapping("/dateUpdateSJTYMinute")
//    public String dateUpdateSJTYMinute() {
//        log.info("进入了手动处理两个值的操作~~~~~~~~");
//        File file = new File("/home/slibra/历史数据");
//        if(file.isDirectory()){
//            for (File listFile : file.listFiles()) {
//                //        输入目录
//                ExcelReader reader = ExcelUtil.getReader(listFile);
//                List<List<Object>> readAll = reader.read();
//                if(!CollectionUtils.isEmpty(readAll)){
//                    for (int i = 3; i < readAll.size(); i++) {
//                        //解析数据
//                        List<Object> objects = readAll.get(i);
//                        String time = "20" + objects.get(0).toString().replaceAll(" ", "") + " " + objects.get(1).toString().replaceAll(" ", "").substring(0, 5);
////                        System.out.println("time = " + time);
//                        TXinyiIndustry uniqueTXinyiIndustry = this.xinyiIndustryMapper.getUniqueTXinyiIndustry(time);
//                        if(!Objects.isNull(uniqueTXinyiIndustry)){
//                            TXinyiIndustry updateBean = new TXinyiIndustry();
//                            updateBean.setID(uniqueTXinyiIndustry.getID());
//                            BigDecimal CLJYSSLL = Objects.isNull(objects.get(2)) || String.valueOf(objects.get(2)).contains("-") ? null : new BigDecimal(String.valueOf(objects.get(2)));
//                            updateBean.setCLJYSSLL(CLJYSSLL);
//                            BigDecimal SJTYJLY = Objects.isNull(objects.get(3)) || String.valueOf(objects.get(3)).contains("-") ? null : new BigDecimal(String.valueOf(objects.get(3)));
//                            updateBean.setSJTYJLY(SJTYJLY);
//                            //如果两个都不为空再更新
//                            if(!Objects.isNull(CLJYSSLL) || !Objects.isNull(SJTYJLY)){
//                                this.xinyiIndustryMapper.updateTXinyiIndustry(updateBean);
//                            }else{
//                                log.error("要更新的两个字段全部为空--------");
//                            }
//                        }
//                    }
//                }
//                }
//            }
//        return "ok";
//    }


    /**
     *
     * 从Excel读取数据 将新增的列数据更新到新的日报字段中
     * @return
     */
    @GetMapping("/dailyAddDataByExcel")
    public String dailyAddDataByExcel() {
        log.info("从Excel读取数据 将新增的列数据更新到新的日报字段中~~~~~~~~");
        File file = new File("/home/slibra/绝干泥量.xlsx");
//        File file = new File("C:\\Users\\10109\\Documents\\WeChat Files\\mz1010995810\\FileStorage\\File\\2024-05\\绝干泥量.xlsx");
        //        输入目录
        ExcelReader reader = ExcelUtil.getReader(file);
        List<List<Object>> readAll = reader.read();
//        log.info("Excel解析的结果为{}", JSON.toJSONString(readAll));
        if(!CollectionUtils.isEmpty(readAll)){
            for (int i = 1; i < readAll.size(); i++) {
                //解析数据
                List<Object> objects = readAll.get(i);
                String date = (String) objects.get(0);
                date = date.replaceAll("\\.", "/");
                date = handleDate(date);

                //用时间去查询 如果存在就更新，否则跳过
                List<TXinyiDaily> tXinyiDailies = this.xinyiDailyMapper.selectTXinyiDailyList(TXinyiDaily.builder().testDate(date).build());
                if(CollectionUtils.isEmpty(tXinyiDailies)){
                    log.error("没有查询到对应的历史数据，跳过~~~~~~{}", date);
                    continue;
                }

                //目前集合就一个对象  以后可能会多个
                TXinyiDaily tXinyiDaily = tXinyiDailies.get(0);

                //出泥量
                Object o1 = objects.get(1);
                BigDecimal CHUNILIANG = null;
                if(o1 instanceof String){
                    log.error("数据异常，解析为null");
                    CHUNILIANG = null;
                }else  if(o1 instanceof Double){
                    CHUNILIANG = new BigDecimal((Double) o1);
                }else {
                    log.error("错误的类型，不用解析了");
                    CHUNILIANG = null;
                }

                //出泥含水率
                BigDecimal CNHSL = null;
                Object o2 = objects.get(2);
                if(o2 instanceof String){
                    log.error("数据异常，解析为null");
                    CNHSL = null;
                }else  if(o2 instanceof Double){
                    CNHSL = new BigDecimal((Double) o2);
                }else {
                    log.error("错误的类型，不用解析了");
                    CNHSL = null;
                }

                //干污泥量
                Object o3 = objects.get(3);
                BigDecimal GWNL = null;
                if(o3 instanceof String){
                    log.error("数据异常，解析为null");
                    GWNL = null;
                }else  if(o3 instanceof Double){
                    GWNL = new BigDecimal((Double) o3);
                }else {
                    log.error("错误的类型，不用解析了");
                    GWNL = null;
                }

                //更新数据
                tXinyiDaily.setCHUNILIANG(CHUNILIANG);
                tXinyiDaily.setCNHSL(CNHSL);
                tXinyiDaily.setGWNL(GWNL);
                this.xinyiDailyMapper.updateTXinyiDaily(tXinyiDaily);

            }
        }
        return "ok";
    }


    /**
     * 手动处理日报数据 增加两个字段 时间和小时
     * @return
     */
    @GetMapping("/dateUpdateDaily")
    public String dateUpdateDaily() {
        //获取全部数据
        List<TXinyiDaily> tXinyiDailies = this.xinyiDailyMapper.selectTXinyiDailyList(null);
        if(!CollectionUtils.isEmpty(tXinyiDailies)){
            for (TXinyiDaily tXinyiDaily : tXinyiDailies) {
                String handleTime = handleDate(tXinyiDaily.getTestTime());
                tXinyiDaily.setTestTime(handleTime);
                tXinyiDaily.setTestDate(handleTime);
                //更新
                this.xinyiDailyMapper.updateTXinyiDaily(tXinyiDaily);
            }
        }
        return "ok";
    }


    /**
     * 手动处理化验数据 增加两个字段 时间和小时
     * @return
     */
    @GetMapping("/dateUpdateHuaYan")
    public String dateUpdateHuaYan() {
        //获取全部数据
        List<TXinyiLaboratory> tXinyiLaboratories = this.xinyiLaboratoryMapper.selectTXinyiLaboratoryList(null);
        if(!CollectionUtils.isEmpty(tXinyiLaboratories)){
            for (TXinyiLaboratory tXinyiLaboratory : tXinyiLaboratories) {
                String handleTime = handleDate(tXinyiLaboratory.getTestTime());
                tXinyiLaboratory.setTestTime(handleTime);//到分为止
                tXinyiLaboratory.setTestDate(handleTime.substring(0, 10));
                tXinyiLaboratory.setTestHour(handleTime.substring(0, 13));
                //更新
                this.xinyiLaboratoryMapper.updateTXinyiLaboratory(tXinyiLaboratory);
            }
        }
        return "ok";
    }



    /**
     * 手动处理 工业库的 某个值，将历史数据全部都更新
     * @return
     */
    @GetMapping("/updateGYKSomeFields")
    public String updateGYKSomeFields() {
        //更新的某个指标
        String[] queryTags = {"信义污水厂_除磷P04预测值_"};
        //找到对应的数据，然后更新它
        // 给定时间段的起始时间和结束时间
        LocalDateTime startTime = LocalDateTime.parse("2022-07-01T00:00:00");
        LocalDateTime endTime = LocalDateTime.parse("2024-04-25T09:00:01");

        // 每个小时的时间格式
        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");

        // 循环按小时分割
        LocalDateTime currentHour = startTime;
        while (currentHour.isBefore(endTime)) {
            String begin = currentHour.format(formatter);
            String end = currentHour.plusDays(1).format(formatter);
            // 输出当前小时的起始时间和结束时间
            System.out.println("起始时间：" + begin);
            System.out.println("结束时间：" + end);

            // 当前小时加一小时，作为下一个小时的起始时间
            currentHour = currentHour.plusDays(1);

            //每个小时查询一次数据
            String url = "http://10.0.0.27:4568/api/v1/khquerydata";
            HashMap<String, Object> req = new HashMap<>();
            req.put("tagNames", queryTags);
            req.put("startTime", begin);
            req.put("endTime", end);
            req.put("recordNumbers", 100000);
            String body = HttpRequest.post(url).header("Authorization", "c2E6c2E=").header("clientName", "hongshan").body(JSON.toJSONString(req)).execute().body();
//            System.out.println("body = " + body);
            List<HashMap<String, String>> list = new ArrayList<>();

            //行转列数据处理
            for (String queryTag : queryTags) {
                JSONArray array = JSON.parseObject(body).getJSONArray(queryTag);
                //特殊数据处理一
                if(Objects.isNull(array) || array.isEmpty()){
                    System.out.println(queryTag + "查询到了空的数据，跳过本次循环");
                    continue;
                }
                int size = array.size();
                //特殊数据处理二
                if("0".equals(array.get(1) + "")){
                    System.out.println(queryTag + "查询到了数据，但是数据集合只有一条，且都是0");
                    continue;
                }

                //存放的数据集
                //利用map去重
                HashMap<String, String> map = new LinkedHashMap<>();
                for (int i = 2; i < size; i++) {
//            System.out.println(i + "" + array.get(i));
                    JSONArray oneRecord = JSON.parseArray(JSON.toJSONString(array.get(i)));
                    //处理为空或者为0的数据
                    Object timeStampValue = oneRecord.get(2);
                    if(Objects.isNull(timeStampValue) || "0".equals(timeStampValue + ""))
                        continue;
                    BigDecimal value = Objects.isNull(oneRecord.get(0)) ? null : new BigDecimal(oneRecord.get(0) + "");
                    long timestamp = (long) timeStampValue;
                    String format = DateUtil.format(new Date(timestamp), DateUtils.YYYYMMDDHH_TS);
                    map.put(format, queryTag + "-" + value);
                }
                list.add(map);
            }
            Set<String> recordTimeSet = new HashSet<>();
            Map<String, TXinyiIndustry> recordMap = new HashMap<>();
            for (int i = 0; i < list.size(); i++) {
                HashMap<String, String> map = list.get(i);
                int finalJ = i;
                map.forEach((k, v) ->{
                    TXinyiIndustry industry = null;
                    if(!recordTimeSet.contains(k)){//第一次
                        industry = new TXinyiIndustry();
                        recordTimeSet.add(k);
                        recordMap.put(k, industry);
                    }else{
                        industry = recordMap.get(k);
                    }
                    industry.setTestTime(k);
                    //解析值
                    String[] split = v.split("-");
                    String type = split[0];
                    BigDecimal value = new BigDecimal(split[1]);
                    if ("信义污水厂_除磷P04预测值_".equals(type)) {
                        industry.setCLP04YCZ(value);//目前值更新此字段
                    }
                    /*else if ("信义污水厂除磷加药瞬时流量".equals(type)) {
                        industry.setCLJYSSLL(value);
                    }*/

                    //只有最后一次才执行数据库添加
                    if(finalJ == list.size()-1){
                        //先去查询数据库
                        TXinyiIndustry uniqueTXinyiIndustry = this.xinyiIndustryMapper.getUniqueTXinyiIndustry(industry.getTestTime());
                        if(Objects.isNull(uniqueTXinyiIndustry))
                            log.error("查询到的工业库数据为null，化验时间为{}", industry.getTestTime());
                        else {
                            //防止其他信息被更新，新建对象
                            TXinyiIndustry updateTXinyiIndustry = new TXinyiIndustry();
                            //赋值
                            updateTXinyiIndustry.setID(uniqueTXinyiIndustry.getID());
                            updateTXinyiIndustry.setCLP04YCZ(industry.getCLP04YCZ());
                            //更新数据库
                            xinyiIndustryMapper.updateTXinyiIndustry(updateTXinyiIndustry);
                        }
                    }
                });

            }
        }
        return "ok";
    }


    /**
     * 手动处理 计算相关的数据，处理历史数据
     * @return
     */
    @GetMapping("/handleCalculateHistoryDates")
    public String handleCalculateHistoryDates() {
        log.info("进入了 手动处理-重置计算表历史数据");
        long begin = System.currentTimeMillis();

        List<TXinyiNormConfig> tXinyiNormConfigs = xinyiNormConfigMapper.selectTXinyiNormConfigList(null);
        if(CollectionUtils.isEmpty(tXinyiNormConfigs)) {
            log.error( "未查询到配置信息");
            return null;
        }

        TXinyiNormConfig normConfig = tXinyiNormConfigs.get(0);

        int size = 500;
        int count = xinyiIndustryMapper.getCount();

        int num = ( count / size ) + 1;

        for (int i = 0; i < num; i++) {
            List<TXinyiIndustry> tXinyiIndustries = xinyiIndustryMapper.selectTXinyiIndustryListByPage(i * size, size);
            List<TXinyiCalculate> tempInsertData = new ArrayList<>();
            if (!CollectionUtils.isEmpty( tXinyiIndustries )) {
                for (int j = 0; j < tXinyiIndustries.size(); j++) {

                    TXinyiIndustry tXinyiIndustry = tXinyiIndustries.get(j);

                    //获取的一些配置信息
                    BigDecimal nhlbqdsl = normConfig.getNHLBQDSL();
                    BigDecimal nhlbdsjll = normConfig.getNHLBDSJLL();
                    BigDecimal nhlbgzxl = normConfig.getNHLBGZXL();
                    BigDecimal whlbqdsl = normConfig.getWHLBQDSL();
                    BigDecimal whlbdsjll = normConfig.getWHLBDSJLL();
                    BigDecimal whlbgzxl = normConfig.getWHLBGZXL();
                    BigDecimal gfjgzts = normConfig.getGFJGZTS();
                    BigDecimal gfjckll = normConfig.getGFJCKLL();
                    BigDecimal fcxbsjll = normConfig.getFCXBSJLL();
                    BigDecimal fclbsl = normConfig.getFCLBSL();
                    BigDecimal fcxbgzxl = normConfig.getFCXBGZXL();

                    //结算结果
                    TXinyiCalculate tXinyiCalculate = new TXinyiCalculate();
                    //时间相关
                    tXinyiCalculate.setTestDate(tXinyiIndustry.getTestDate());
                    tXinyiCalculate.setTestHour(tXinyiIndustry.getTestHour());
                    tXinyiCalculate.setTestTime(tXinyiIndustry.getTestTime());

                    //获取最新的一条日报信息
                    TXinyiDaily tXinyiDaily = this.xinyiDailyMapper.getDetailByDay(tXinyiIndustry.getTestDate());
                    if(Objects.isNull(tXinyiDaily)){
                        //理论不会出现
                        log.error("没有日报数据，取最新的");
                        tXinyiDaily = this.xinyiDailyMapper.selectNewestData();
                    }

                    BigDecimal jsBod5 = tXinyiDaily.getJsBod5();
                    BigDecimal csBod5 = tXinyiDaily.getCsBod5();
                    BigDecimal whlR = tXinyiDaily.getWhlR();
                    BigDecimal oneMlvss = tXinyiDaily.getShcHyOneMlvss();
                    BigDecimal twoMlvss = tXinyiDaily.getShcHyTwoMlvss();
                    BigDecimal avgMlvss = null;
                    if(!Objects.isNull(oneMlvss) && !Objects.isNull(twoMlvss))
                        avgMlvss = ((oneMlvss.add(twoMlvss)).divide(new BigDecimal(2),4, RoundingMode.HALF_UP));
                    BigDecimal oneMlss = tXinyiDaily.getShcHyOneMlss();
                    BigDecimal twoMlss = tXinyiDaily.getShcHyTwoMlss();
                    BigDecimal avgMlss = null;
                    if(!Objects.isNull(oneMlss) && !Objects.isNull(twoMlss))
                        avgMlss = ((oneMlss.add(twoMlss)).divide(new BigDecimal(NUMBER_2),NUMBER_SCALE_4, RoundingMode.HALF_UP));

                    //工业库的指标
                    BigDecimal jsTn = tXinyiIndustry.getJsTn();
                    BigDecimal jsTp = tXinyiIndustry.getJsTp();
                    BigDecimal jsCod = tXinyiIndustry.getJsCod();
                    BigDecimal jsSlq = tXinyiIndustry.getJsSlq();
                    //计算
                    if(!Objects.isNull(jsBod5)){
                        if(!Objects.isNull(jsTn) && jsTn.compareTo(BigDecimal.ZERO) > 0)
                            tXinyiCalculate.setJsTdb(jsBod5.divide(jsTn, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        if(!Objects.isNull(jsTp) && jsTp.compareTo(BigDecimal.ZERO) > 0)
                            tXinyiCalculate.setJsTlb(jsBod5.divide(jsTp, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        if(!Objects.isNull(jsCod) && jsCod.compareTo(BigDecimal.ZERO) > 0)
                            tXinyiCalculate.setJsBodBCod(jsBod5.divide(jsCod, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        if(!Objects.isNull(csBod5) && !Objects.isNull(avgMlss) && avgMlss.compareTo(BigDecimal.ZERO) > 0 && !Objects.isNull(jsSlq) && jsSlq.compareTo(BigDecimal.ZERO) > 0)
                            tXinyiCalculate.setFM(new BigDecimal(ONE_DAY_HOURS).multiply((jsBod5.subtract(csBod5))).multiply(jsSlq).divide(avgMlss, NUMBER_SCALE_4, RoundingMode.HALF_UP).divide(new BigDecimal(F_M_LAST), NUMBER_SCALE_4, RoundingMode.HALF_UP));
                    }
                    if(!Objects.isNull(avgMlss) && avgMlss.compareTo(BigDecimal.ZERO) > 0 && !Objects.isNull(avgMlvss) && avgMlvss.compareTo(BigDecimal.ZERO) > 0)
                        tXinyiCalculate.setHFXWNNDZB(avgMlvss.divide(avgMlss, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                    if(!Objects.isNull(jsSlq) && jsSlq.compareTo(BigDecimal.ZERO) > 0){
                        tXinyiCalculate.setYyqHrt(new BigDecimal(YYQ_TLSJ_FIRST).divide(jsSlq, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        tXinyiCalculate.setQyqHrt(new BigDecimal(QYQ_TLSJ_FIRST).divide(jsSlq, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        tXinyiCalculate.setHyqHrt(new BigDecimal(HYQ_TLSJ_FIRST).divide(jsSlq, NUMBER_SCALE_4, RoundingMode.HALF_UP));
//            tXinyiCalculate.setGSLS(jsSlq.divide(new BigDecimal(NUMBER_3600), NUMBER_SCALE_4, RoundingMode.HALF_UP).multiply(new BigDecimal(NUMBER_4)).divide((new BigDecimal(Math.PI).multiply(new BigDecimal(NUMBER_0_0_0_3)).multiply(new BigDecimal(NUMBER_0_0_0_3)).multiply(new BigDecimal(NUMBER_4)).multiply(new BigDecimal(NUMBER_4)).multiply(new BigDecimal(NUMBER_97119))) , NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        tXinyiCalculate.setGSLS(jsSlq.divide(GSLS_LAST, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        tXinyiCalculate.setGslsOne(jsSlq.divide(new BigDecimal(NUMBER_3600), NUMBER_SCALE_4, RoundingMode.HALF_UP).multiply(new BigDecimal(Math.sqrt(Math.sin(Math.toRadians(DOUBLE_75))))).divide(GSLSONE_LAST, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        tXinyiCalculate.setGslsTwo(jsSlq.divide(new BigDecimal(NUMBER_3600), NUMBER_SCALE_4, RoundingMode.HALF_UP).multiply(new BigDecimal(Math.sqrt(Math.sin(Math.toRadians(DOUBLE_75))))).divide(GSLSTWO_LAST, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        tXinyiCalculate.setXgsGsls(jsSlq.divide(new BigDecimal(NUMBER_3600), NUMBER_SCALE_4, RoundingMode.HALF_UP).multiply(new BigDecimal(NUMBER_4)).divide((GSLS_XGS_LAST) , NUMBER_SCALE_4, RoundingMode.HALF_UP));

                        tXinyiCalculate.setXlcscBmfh(jsSlq.divide(XLCSCBMFH_LAST, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        tXinyiCalculate.setXlcscHrt(XLCSCHRT_LAST.divide(jsSlq, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        tXinyiCalculate.setCccdcBmfh(jsSlq.divide(CCCDCBMFH_LAST, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        tXinyiCalculate.setCccdcHrt(CCCDCHRT_LAST.divide(jsSlq, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        tXinyiCalculate.setEccBmfh(jsSlq.divide(ECCBMFH_LAST, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        tXinyiCalculate.setEccHrt(ECCHRT_LAST.divide(jsSlq, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        //2024年7月1日17:16:16 计算逻辑调整
                        if(!Objects.isNull(whlR) && avgMlss != null && jsSlq != null) {
                            tXinyiCalculate.setEccGtfh((new BigDecimal(1).add(whlR.divide(BigDecimal_100, NUMBER_SCALE_4, RoundingMode.HALF_UP))).multiply(jsSlq).multiply(new BigDecimal(NUMBER_24)).multiply(avgMlss).divide(ECCGTFH_LAST, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        }
                        tXinyiCalculate.setClsnJcsj(CLSNJCSJ_LAST.divide(jsSlq, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        tXinyiCalculate.setXgcdcQsqSsls(jsSlq.multiply(XGCDCQSQSSLS_LAST));
                        //2024年6月29日15:18:01 增加几个新的计算指标
                        if(!Objects.isNull(nhlbqdsl) && !Objects.isNull(nhlbdsjll) && !Objects.isNull(nhlbgzxl))
                            tXinyiCalculate.setNHLB(nhlbqdsl.multiply(nhlbdsjll).multiply(nhlbgzxl).multiply(BigDecimal_100).divide(jsSlq, 4, RoundingMode.HALF_UP));
                        if(!Objects.isNull(whlbqdsl) && !Objects.isNull(whlbdsjll) && !Objects.isNull(whlbgzxl))
                            tXinyiCalculate.setWHLB(whlbqdsl.multiply(whlbdsjll).multiply(whlbgzxl).multiply(BigDecimal_100).divide(jsSlq, 4, RoundingMode.HALF_UP));
                        if(!Objects.isNull(gfjgzts) && !Objects.isNull(gfjckll))
                            tXinyiCalculate.setQSB(gfjgzts.multiply(gfjckll).divide(jsSlq, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        if(!Objects.isNull(fcxbsjll) && !Objects.isNull(fclbsl) && !Objects.isNull(fcxbgzxl)){
                            BigDecimal fcxsl = fcxbsjll.multiply(fclbsl).multiply(fcxbgzxl);
                            tXinyiCalculate.setFCXSL(fcxsl);
                            //2024年7月3日10:54:28 额外再增加一个字段
                            tXinyiCalculate.setFCXSLBL(fcxsl.divide(jsSlq, NUMBER_SCALE_4, RoundingMode.HALF_UP).multiply(BigDecimal_100));
                        }
                        //2024年7月11日15:43:47  之前给的外回流比计算不准确，额外一个字段记录新的外回流比
                        BigDecimal divide = jsSlq.divide(DECIMAL_2, NUMBER_SCALE_4, RoundingMode.HALF_UP);
                        if(divide.compareTo(DECIMAL_1500) < 0)
                            tXinyiCalculate.setWhlRN(DECIMAL_1200.divide(divide, NUMBER_SCALE_4, RoundingMode.HALF_UP).multiply(BigDecimal_100));
                        else
                            tXinyiCalculate.setWhlRN(DECIMAL_1620.divide(divide, NUMBER_SCALE_4, RoundingMode.HALF_UP).multiply(BigDecimal_100));
                    }

                    tempInsertData.add(tXinyiCalculate);
                    xinyiCalculateMapper.insertTXinyiCalculate(tXinyiCalculate);
                }

                // xinyiCalculateMapper.insertBatchData(tempInsertData);
                // return tXinyiCalculate;
            }
        }

        long end = System.currentTimeMillis();
        return "ok;耗时：" + (end - begin) /1000 + "秒。";
    }

    public void main(String[] args) {

        // handleBigTableDayHistoryData();

        // HandleDataController handleDataController = new HandleDataController();
        //
        // handleDataController.handleBigTableDayHistoryData();

//        File file = new File("C:\\Users\\10109\\Desktop\\新程序\\历史数据");
//        if(file.isDirectory()){
//            for (File listFile : file.listFiles()) {
////                System.out.println(listFile.getName());
//                ExcelReader reader = ExcelUtil.getReader(listFile);
//                List<List<Object>> readAll = reader.read();
//                for (int i = 3; i < 10; i++) {
//                    System.out.println(readAll.get(i));
//                }
//                System.out.println("------------------");
//            }
//        }


        String str = "2022/07/11 19:00";
//        String str = "2022/7/1";
//        String str = "0:0:1";
//        String newStr = handleDate(str);
//        System.out.println(newStr);
//        System.out.println(str.substring(0, 12));
//        System.out.println(str.substring(0, 9));

//        System.out.println(handleDate("2024-3-9"));
        System.out.println(handleDate("2023/12/26 02:00"));
        System.out.println(handleDate("2023/12/26 02:00").substring(0, 10));
        System.out.println(handleDate("2023/12/26 02:00").substring(0, 13));

    }

    public static String handleDate(String str){
        StringBuilder sb = new StringBuilder();
        if(str.contains(" ")){//包含空格 就是年月日时分秒了
            String[] split = str.split(" ");
            addBeforeZero(sb, split[0], "/");
            sb.append(" ");
            addBeforeZero(sb, split[1], ":");
        }else{
            if(str.contains("/")){//年月日
                addBeforeZero(sb, str, "/");
            }else if(str.contains(":")){//时分秒
                addBeforeZero(sb, str, ":");
            }else if(str.contains("-")){//只有年月日
                addBeforeZero(sb, str, "-");
            }else {
                sb.append(str);
            }
       }
        return sb.toString();
    }

    public static StringBuilder addBeforeZero(StringBuilder sb, String str, String tag){
        String[] split = str.split(tag);
        int length = split.length;
        for (int i = 0; i < length; i++) {
            String value = split[i];
            Integer intValue = Integer.parseInt(value);
            if(intValue < 10 && value.length() == 1){////防止有正确的情况 额外再补充字符串
                sb.append(0).append(value);
            }else{
                sb.append(value);
            }
            if(i < length-1){
                sb.append(tag);
            }
        }
        return sb;
    }

    public BigDecimal getListAvg (Collection<BigDecimal> bigDecimals) {
        if (bigDecimals.isEmpty()) {
            return null;
        }

        BigDecimal sum = bigDecimals.stream()
                .reduce(BigDecimal.ZERO, BigDecimal::add);

        int size = bigDecimals.size();
        return sum.divide(new BigDecimal(size), 6, RoundingMode.HALF_UP);
    }

    public String formatList(List<BigDecimal> list) {
        if (CollectionUtils.isEmpty(list)) {
            return null;
        }

        boolean isNullList = list.stream().allMatch(x -> x == null);

        return isNullList ? null : list.toString();
    }


    /**
     * 处理big_table_month历史数据
     * @return
     */
    @GetMapping("/handleBigTableMonthHistoryData")
    public String handleBigTableMonthHistoryData() {
        log.info("进入了处理big_table_month历史数据");
        long begin = System.currentTimeMillis();

        List<TXinyiBigTableMonth> tXinyiBigTableDayList = tXinyiBigTableDayMapper.selectTXinyiBigTableDayByMonthAvg();

        if ( !CollectionUtils.isEmpty(tXinyiBigTableDayList)  ) {

            for (int i = 0; i < tXinyiBigTableDayList.size(); i++) {
                TXinyiBigTableMonth tableMonth = tXinyiBigTableDayList.get(i);


                ArrayList<BigDecimal> gyHycRjyAll = new ArrayList<>();
                ArrayList<BigDecimal> gyHycRjyZdAll = new ArrayList<>();
                ArrayList<BigDecimal> gyHycWnndAll = new ArrayList<>();

                ArrayList<BigDecimal> rbHycRjyAll = new ArrayList<>();
                ArrayList<BigDecimal> rbHycWnndAll = new ArrayList<>();
                ArrayList<BigDecimal> rbYycRjyAll = new ArrayList<>();
                ArrayList<BigDecimal> rbQycRjyAll = new ArrayList<>();
                ArrayList<BigDecimal> rbWncjbAll = new ArrayList<>();
                ArrayList<BigDecimal> rbWntjzsAll = new ArrayList<>();
                ArrayList<BigDecimal> rbHfxwnndAll = new ArrayList<>();

                ArrayList<BigDecimal> hyHycxsyAll = new ArrayList<>();
                ArrayList<BigDecimal> hyQyanAll = new ArrayList<>();
                ArrayList<BigDecimal> hyQyckxsyAll = new ArrayList<>();
                ArrayList<BigDecimal> hyHyzlsyAll = new ArrayList<>();

                gyHycRjyAll.add(tableMonth.getGyOneHymdDo());
                gyHycRjyAll.add(tableMonth.getGyTwoHymdDo());
                gyHycRjyZdAll.add(tableMonth.getGyOneHyzdDo());
                gyHycRjyZdAll.add(tableMonth.getGyTwoHyzdDo());
                gyHycWnndAll.add(tableMonth.getGyOneMlss());
                gyHycWnndAll.add(tableMonth.getGyTwoMlss());

                rbHycRjyAll.add(tableMonth.getRbShcHyOneDo());
                rbHycRjyAll.add(tableMonth.getRbShcHyTwoDo());
                rbHycWnndAll.add(tableMonth.getRbShcHyOneMlss());
                rbHycWnndAll.add(tableMonth.getRbShcHyTwoMlss());
                rbYycRjyAll.add(tableMonth.getRbShcYyOneDo());
                rbYycRjyAll.add(tableMonth.getRbShcYyTwoDo());
                rbQycRjyAll.add(tableMonth.getRbShcQyOneDo());
                rbQycRjyAll.add(tableMonth.getRbShcQyTwoDo());
                rbWncjbAll.add(tableMonth.getRbShcHyOneSv());
                rbWncjbAll.add(tableMonth.getRbShcHyTwoSv());
                rbWntjzsAll.add(tableMonth.getRbShcHyOneSvi());
                rbWntjzsAll.add(tableMonth.getRbShcHyTwoSvi());
                rbHfxwnndAll.add(tableMonth.getRbShcHyOneMlvss());
                rbHfxwnndAll.add(tableMonth.getRbShcHyTwoMlvss());

                hyHycxsyAll.add(tableMonth.getHyNo3Hlj1Jqr());
                hyHycxsyAll.add(tableMonth.getHyNo3Hlj2Jqr());
                hyQyanAll.add(tableMonth.getHyNh31Jqr());
                hyQyanAll.add(tableMonth.getHyNh32Jqr());
                hyQyckxsyAll.add(tableMonth.getHyNo3Qyc1Jqr());
                hyQyckxsyAll.add(tableMonth.getHyNo3Qyc2Jqr());
                hyHyzlsyAll.add(tableMonth.getHyTpHl1Jqr());
                hyHyzlsyAll.add(tableMonth.getHyTpHl2Jqr());

                tableMonth.setGyHycRjyAll(formatList(gyHycRjyAll));
                tableMonth.setGyHycRjyZdAll(formatList(gyHycRjyZdAll));
                tableMonth.setGyHycWnndAll(formatList(gyHycWnndAll));
                tableMonth.setRbHycRjyAll(formatList(rbHycRjyAll));
                tableMonth.setRbHycWnndAll(formatList(rbHycWnndAll));
                tableMonth.setRbYycRjyAll(formatList(rbYycRjyAll));
                tableMonth.setRbQycRjyAll(formatList(rbQycRjyAll));
                tableMonth.setRbWncjbAll(formatList(rbWncjbAll));
                tableMonth.setRbWntjzsAll(formatList(rbWntjzsAll));
                tableMonth.setRbHfxwnndAll(formatList(rbHfxwnndAll));
                tableMonth.setHyHycxsyAll(formatList(hyHycxsyAll));
                tableMonth.setHyQyanAll(formatList(hyQyanAll));
                tableMonth.setHyQyckxsyAll(formatList(hyQyckxsyAll));
                tableMonth.setHyHyzlsyAll(formatList(hyHyzlsyAll));


                tXinyiBigTableMonthMapper.insertTXinyiBigTableMonth(tableMonth);
            }
        }

        long end = System.currentTimeMillis();
        return "ok;耗时：" + (end - begin) / 1000 + "秒。";
    }


    /**
     * 处理big_table_day历史数据
     * @return
     */
    @GetMapping("/handleBigTableDayHistoryData")
    public String handleBigTableDayHistoryData() {
        log.info("进入了 处理big_table_day历史数据");
        long begin = System.currentTimeMillis();

        List<TXinyiBigTableHour> tXinyiBigTableHours = tXinyiBigTableHourMapper.selectTXinyiBigTableHourByTestDate();
        if ( !CollectionUtils.isEmpty(tXinyiBigTableHours) ) {

            List<TXinyiBigTableDay> bigTableDayList = new ArrayList<>();

            for (int i = 0; i < tXinyiBigTableHours.size(); i++) {
                TXinyiBigTableHour tXinyiBigTableHour = tXinyiBigTableHours.get(i);
                String testDate = tXinyiBigTableHour.getTestDate();

                TXinyiBigTableDay tableDay = tXinyiBigTableDayMapper.selectTXinyiBigTableHourAvg(testDate);
                if (!Objects.isNull(tableDay)) {

                    ArrayList<BigDecimal> gyHycRjyAll = new ArrayList<>();
                    ArrayList<BigDecimal> gyHycRjyZdAll = new ArrayList<>();
                    ArrayList<BigDecimal> gyHycWnndAll = new ArrayList<>();

                    ArrayList<BigDecimal> rbHycRjyAll = new ArrayList<>();
                    ArrayList<BigDecimal> rbHycWnndAll = new ArrayList<>();
                    ArrayList<BigDecimal> rbYycRjyAll = new ArrayList<>();
                    ArrayList<BigDecimal> rbQycRjyAll = new ArrayList<>();
                    ArrayList<BigDecimal> rbWncjbAll = new ArrayList<>();
                    ArrayList<BigDecimal> rbWntjzsAll = new ArrayList<>();
                    ArrayList<BigDecimal> rbHfxwnndAll = new ArrayList<>();

                    ArrayList<BigDecimal> hyHycxsyAll = new ArrayList<>();
                    ArrayList<BigDecimal> hyQyanAll = new ArrayList<>();
                    ArrayList<BigDecimal> hyQyckxsyAll = new ArrayList<>();
                    ArrayList<BigDecimal> hyHyzlsyAll = new ArrayList<>();

                    gyHycRjyAll.add(tableDay.getGyOneHymdDo());
                    gyHycRjyAll.add(tableDay.getGyTwoHymdDo());
                    gyHycRjyZdAll.add(tableDay.getGyOneHyzdDo());
                    gyHycRjyZdAll.add(tableDay.getGyTwoHyzdDo());
                    gyHycWnndAll.add(tableDay.getGyOneMlss());
                    gyHycWnndAll.add(tableDay.getGyTwoMlss());

                    rbHycRjyAll.add(tableDay.getRbShcHyOneDo());
                    rbHycRjyAll.add(tableDay.getRbShcHyTwoDo());
                    rbHycWnndAll.add(tableDay.getRbShcHyOneMlss());
                    rbHycWnndAll.add(tableDay.getRbShcHyTwoMlss());
                    rbYycRjyAll.add(tableDay.getRbShcYyOneDo());
                    rbYycRjyAll.add(tableDay.getRbShcYyTwoDo());
                    rbQycRjyAll.add(tableDay.getRbShcQyOneDo());
                    rbQycRjyAll.add(tableDay.getRbShcQyTwoDo());
                    rbWncjbAll.add(tableDay.getRbShcHyOneSv());
                    rbWncjbAll.add(tableDay.getRbShcHyTwoSv());
                    rbWntjzsAll.add(tableDay.getRbShcHyOneSvi());
                    rbWntjzsAll.add(tableDay.getRbShcHyTwoSvi());
                    rbHfxwnndAll.add(tableDay.getRbShcHyOneMlvss());
                    rbHfxwnndAll.add(tableDay.getRbShcHyTwoMlvss());

                    hyHycxsyAll.add(tableDay.getHyNo3Hlj1Jqr());
                    hyHycxsyAll.add(tableDay.getHyNo3Hlj2Jqr());
                    hyQyanAll.add(tableDay.getHyNh31Jqr());
                    hyQyanAll.add(tableDay.getHyNh32Jqr());
                    hyQyckxsyAll.add(tableDay.getHyNo3Qyc1Jqr());
                    hyQyckxsyAll.add(tableDay.getHyNo3Qyc2Jqr());
                    hyHyzlsyAll.add(tableDay.getHyTpHl1Jqr());
                    hyHyzlsyAll.add(tableDay.getHyTpHl2Jqr());

                    tableDay.setGyHycRjyAll(formatList(gyHycRjyAll));
                    tableDay.setGyHycRjyZdAll(formatList(gyHycRjyZdAll));
                    tableDay.setGyHycWnndAll(formatList(gyHycWnndAll));
                    tableDay.setRbHycRjyAll(formatList(rbHycRjyAll));
                    tableDay.setRbHycWnndAll(formatList(rbHycWnndAll));
                    tableDay.setRbYycRjyAll(formatList(rbYycRjyAll));
                    tableDay.setRbQycRjyAll(formatList(rbQycRjyAll));
                    tableDay.setRbWncjbAll(formatList(rbWncjbAll));
                    tableDay.setRbWntjzsAll(formatList(rbWntjzsAll));
                    tableDay.setRbHfxwnndAll(formatList(rbHfxwnndAll));
                    tableDay.setHyHycxsyAll(formatList(hyHycxsyAll));
                    tableDay.setHyQyanAll(formatList(hyQyanAll));
                    tableDay.setHyQyckxsyAll(formatList(hyQyckxsyAll));
                    tableDay.setHyHyzlsyAll(formatList(hyHyzlsyAll));

                    tableDay.setTestDate(testDate);

                    bigTableDayList.add(tableDay);
                }
            }

            if (!CollectionUtils.isEmpty(bigTableDayList)) {
                SqlSession sqlSession = sqlSessionFactory.openSession(ExecutorType.BATCH, false);
                TXinyiBigTableDayMapper sqlSessionMapper =  sqlSession.getMapper(TXinyiBigTableDayMapper.class);
                bigTableDayList.forEach(sqlSessionMapper::insertTXinyiBigTableDay);
                sqlSession.commit();
                sqlSession.close();
            }
        }
        long end = System.currentTimeMillis();
        return "ok;耗时：" + (end - begin) / 1000 + "秒。";
    }


    /**
     * 处理big_table_hour历史数据
     * @return
     */
    @GetMapping("/handleBigTableHourHistoryData")
    public String handleBigTableHourHistoryData () {
        log.info("进入了 处理big_table_hour历史数据");
        long begin = System.currentTimeMillis();

        int size = 500;
        int count = xinyiIndustryMapper.getCount();

        int num = ( count / size ) + 1;

        for (int i = 0; i < num; i++) {
            List<TXinyiIndustry> tXinyiIndustries = xinyiIndustryMapper.selectTXinyiIndustryListByPage(i * size, size);
            if ( !CollectionUtils.isEmpty(tXinyiIndustries) ) {

                List<TXinyiBigTableHour> tXinyiBigTableHourList = new ArrayList();

                for (int j = 0; j < tXinyiIndustries.size(); j++) {
                    TXinyiBigTableHour xinyiBigTableHour = new TXinyiBigTableHour();
                    TXinyiIndustry tXinyiIndustry = tXinyiIndustries.get(j);

                    String testHour = tXinyiIndustry.getTestHour();
                    String testDate = tXinyiIndustry.getTestDate();

                    // 处理工业库
                    handleIndustryData(xinyiBigTableHour, tXinyiIndustry);

                    // 处理计算表
                    List<TXinyiCalculate> tXinyiCalculates = xinyiCalculateMapper.selectTXinyiCalculateList(TXinyiCalculate.builder().testHour(testHour).build());
                    if ( !CollectionUtils.isEmpty(tXinyiCalculates) ) {
                        TXinyiCalculate tXinyiCalculate = tXinyiCalculates.get(0);
                        handleCalculateData(xinyiBigTableHour, tXinyiCalculate);
                    }

                    // 处理日报表
                    List<TXinyiDaily> tXinyiDailies = xinyiDailyMapper.selectTXinyiDailyList(TXinyiDaily.builder().testDate(testDate).build());
                    if ( !CollectionUtils.isEmpty(tXinyiDailies) ) {
                        TXinyiDaily tXinyiDaily = tXinyiDailies.get(0);
                        handleDailyData(xinyiBigTableHour, tXinyiDaily);
                    }

                    // 处理化验室
                    List<TXinyiRobot> tXinyiRobots = xinyiRobotMapper.selectTXinyiRobotList(TXinyiRobot.builder().testHour(testHour).build());
                    if (!CollectionUtils.isEmpty(tXinyiRobots)) {
                        TXinyiRobot tXinyiRobot = tXinyiRobots.get(0);
                        handleRobotData(xinyiBigTableHour, tXinyiRobot);
                    }
                    // TXinyiRobot tXinyiRobot = xinyiRobotMapper.selectTXinyiRobotByAvg(TXinyiRobot.builder().testHour(testHour).build());
                    // if ( !Objects.isNull(tXinyiRobot) ) {
                    //     handleRobotData(xinyiBigTableHour, tXinyiRobot);
                    // }

                    tXinyiBigTableHourList.add(xinyiBigTableHour);
                }

                if (!CollectionUtils.isEmpty(tXinyiBigTableHourList)) {
                    SqlSession sqlSession = sqlSessionFactory.openSession(ExecutorType.BATCH,false);
                    TXinyiBigTableHourMapper sqlSessionMapper = sqlSession.getMapper(TXinyiBigTableHourMapper.class);
                    tXinyiBigTableHourList.stream().forEach(item -> sqlSessionMapper.insertTXinyiBigTableHour(item));
                    sqlSession.commit();
                    sqlSession.close();
                }
            }
        }

        long end = System.currentTimeMillis();
        return "ok;耗时：" + (end - begin) /1000 + "秒。";
    }

    // 处理工业库
    private void handleIndustryData(TXinyiBigTableHour xinyiBigTableHour, TXinyiIndustry tXinyiIndustry) {
        xinyiBigTableHour.setTestDate(tXinyiIndustry.getTestDate());
        xinyiBigTableHour.setTestHour(tXinyiIndustry.getTestHour());
        xinyiBigTableHour.setGyJsCod(tXinyiIndustry.getJsCod());
        xinyiBigTableHour.setGyJsPh(tXinyiIndustry.getJsPh());
        xinyiBigTableHour.setGyJsSs(tXinyiIndustry.getJsSs());
        xinyiBigTableHour.setGyJsTp(tXinyiIndustry.getJsTp());
        xinyiBigTableHour.setGyJsTn(tXinyiIndustry.getJsTn());
        xinyiBigTableHour.setGyJsNh3(tXinyiIndustry.getJsNh3());
        xinyiBigTableHour.setGyJsSwPh(tXinyiIndustry.getJsSwPh());
        xinyiBigTableHour.setGyJsBfyw(tXinyiIndustry.getJsBfyw());
        xinyiBigTableHour.setGyCsSlqc(tXinyiIndustry.getCsSlqc());
        xinyiBigTableHour.setGyCsCod(tXinyiIndustry.getCsCod());
        xinyiBigTableHour.setGyCsPh(tXinyiIndustry.getCsPh());
        xinyiBigTableHour.setGyCsSs(tXinyiIndustry.getCsSs());
        xinyiBigTableHour.setGyCsTn(tXinyiIndustry.getCsTn());
        xinyiBigTableHour.setGyCsTp(tXinyiIndustry.getCsTp());
        xinyiBigTableHour.setGyCsNh3(tXinyiIndustry.getCsNh3());
        xinyiBigTableHour.setGyOneHyzdDo(tXinyiIndustry.getOneHyzdDo());
        xinyiBigTableHour.setGyOneHymdDo(tXinyiIndustry.getOneHymdDo());
        xinyiBigTableHour.setGyTwoHyzdDo(tXinyiIndustry.getTwoHyzdDo());
        xinyiBigTableHour.setGyTwoHymdDo(tXinyiIndustry.getTwoHymdDo());
        xinyiBigTableHour.setGyOneMlss(tXinyiIndustry.getOneMlss());
        xinyiBigTableHour.setGyTwoMlss(tXinyiIndustry.getTwoMlss());
        xinyiBigTableHour.setGyJsTds(tXinyiIndustry.getJsTds());
        xinyiBigTableHour.setGyJsSlq(tXinyiIndustry.getJsSlq());
        xinyiBigTableHour.setGyNHlbOneGp(tXinyiIndustry.getNHlbOneGp());
        xinyiBigTableHour.setGyNHlbTwoGp(tXinyiIndustry.getNHlbTwoGp());
        xinyiBigTableHour.setGyNHlbThreeGp(tXinyiIndustry.getNHlbThreeGp());
        xinyiBigTableHour.setGyNHlbFourGp(tXinyiIndustry.getNHlbFourGp());
        xinyiBigTableHour.setGyNhlBFiveGp(tXinyiIndustry.getNhlBFiveGp());
        xinyiBigTableHour.setGyNHlbSixGp(tXinyiIndustry.getNHlbSixGp());
        xinyiBigTableHour.setGyWHlbOneGp(tXinyiIndustry.getWHlbOneGp());
        xinyiBigTableHour.setGyWHlbTwoGp(tXinyiIndustry.getWHlbTwoGp());
        xinyiBigTableHour.setGyWHlbThreeGp(tXinyiIndustry.getWHlbThreeGp());
        xinyiBigTableHour.setGyWHlbFourGp(tXinyiIndustry.getWHlbFourGp());
        xinyiBigTableHour.setGyWHlbFiveGp(tXinyiIndustry.getWHlbFiveGp());
        xinyiBigTableHour.setGyFjOne(tXinyiIndustry.getFjOne());
        xinyiBigTableHour.setGyFjTwo(tXinyiIndustry.getFjTwo());
        xinyiBigTableHour.setGyFjThree(tXinyiIndustry.getFjThree());
        xinyiBigTableHour.setGyFjFour(tXinyiIndustry.getFjFour());
        xinyiBigTableHour.setGyFjFive(tXinyiIndustry.getFjFive());
        xinyiBigTableHour.setGyFjSix(tXinyiIndustry.getFjSix());
        xinyiBigTableHour.setGyKqllOne(tXinyiIndustry.getKqllOne());
        xinyiBigTableHour.setGyKqllTwo(tXinyiIndustry.getKqllTwo());
        xinyiBigTableHour.setGyKqllThree(tXinyiIndustry.getKqllThree());
        xinyiBigTableHour.setGyKqllFour(tXinyiIndustry.getKqllFour());
        xinyiBigTableHour.setGyKqllFive(tXinyiIndustry.getKqllFive());
        xinyiBigTableHour.setGyKqllSix(tXinyiIndustry.getKqllSix());
        xinyiBigTableHour.setGySjtyjly(tXinyiIndustry.getSJTYJLY());
        xinyiBigTableHour.setGyCljyssll(tXinyiIndustry.getCLJYSSLL());
        xinyiBigTableHour.setGyHycRjyAll(tXinyiIndustry.getHycRjyAll());
        xinyiBigTableHour.setGyHycRjyZdAll(tXinyiIndustry.getHycRjyZdAll());
        xinyiBigTableHour.setGyHycWnndAll(tXinyiIndustry.getHycWnndAll());
        xinyiBigTableHour.setGyClP04Ycz(tXinyiIndustry.getCLP04YCZ());
    }

    // 处理计算表
    private void handleCalculateData(TXinyiBigTableHour xinyiBigTableHour, TXinyiCalculate xinyiCalculate) {
        xinyiBigTableHour.setJsJsTdb(xinyiCalculate.getJsTdb());
        xinyiBigTableHour.setJsJsTlb(xinyiCalculate.getJsTlb());
        xinyiBigTableHour.setJsJsBodBCod(xinyiCalculate.getJsBodBCod());
        xinyiBigTableHour.setJsYyqHrt(xinyiCalculate.getYyqHrt());
        xinyiBigTableHour.setJsQyqHrt(xinyiCalculate.getQyqHrt());
        xinyiBigTableHour.setJsHyqHrt(xinyiCalculate.getHyqHrt());
        xinyiBigTableHour.setJsHfxwnndzb(xinyiCalculate.getHFXWNNDZB());
        xinyiBigTableHour.setJsFM(xinyiCalculate.getFM());
        xinyiBigTableHour.setJsGsls(xinyiCalculate.getGSLS());
        xinyiBigTableHour.setJsGslsOne(xinyiCalculate.getGslsOne());
        xinyiBigTableHour.setJsGslsTwo(xinyiCalculate.getGslsTwo());
        xinyiBigTableHour.setJsXgsGsls(xinyiCalculate.getXgsGsls());
        xinyiBigTableHour.setJsXlcscBmfh(xinyiCalculate.getXlcscBmfh());
        xinyiBigTableHour.setJsXlcscHrt(xinyiCalculate.getXlcscHrt());
        xinyiBigTableHour.setJsCccdcBmfh(xinyiCalculate.getCccdcBmfh());
        xinyiBigTableHour.setJsCccdcHrt(xinyiCalculate.getCccdcHrt());
        xinyiBigTableHour.setJsEccBmfh(xinyiCalculate.getEccBmfh());
        xinyiBigTableHour.setJsEccHrt(xinyiCalculate.getEccHrt());
        xinyiBigTableHour.setJsEccGtfh(xinyiCalculate.getEccGtfh());
        xinyiBigTableHour.setJsClsnJcsj(xinyiCalculate.getClsnJcsj());
        xinyiBigTableHour.setJsXgcdcQsqSsls(xinyiCalculate.getXgcdcQsqSsls());
        xinyiBigTableHour.setJsWhlb(xinyiCalculate.getWHLB());
        xinyiBigTableHour.setJsNhlb(xinyiCalculate.getNHLB());
        xinyiBigTableHour.setJsWdscnl(xinyiCalculate.getWDSCNL());
        xinyiBigTableHour.setJsQsb(xinyiCalculate.getQSB());
        xinyiBigTableHour.setJsFcxsl(xinyiCalculate.getFCXSL());
        xinyiBigTableHour.setJsFcxslbl(xinyiCalculate.getFCXSLBL());
        xinyiBigTableHour.setJsWhlbRN(xinyiCalculate.getWhlRN());
    }

    // 处理日报
    private void handleDailyData(TXinyiBigTableHour tXinyiBigTableHour, TXinyiDaily tXinyiDaily) {
        tXinyiBigTableHour.setRbJsCod(tXinyiDaily.getJsCod());
        tXinyiBigTableHour.setRbJsPh(tXinyiDaily.getJsPh());
        tXinyiBigTableHour.setRbJsBod5(tXinyiDaily.getJsBod5());
        tXinyiBigTableHour.setRbJsSs(tXinyiDaily.getJsSs());
        tXinyiBigTableHour.setRbJsNh3(tXinyiDaily.getJsNh3());
        tXinyiBigTableHour.setRbJsTn(tXinyiDaily.getJsTn());
        tXinyiBigTableHour.setRbJsTp(tXinyiDaily.getJsTp());
        tXinyiBigTableHour.setRbJsDcgj(tXinyiDaily.getJsDcgj());
        tXinyiBigTableHour.setRbCsCod(tXinyiDaily.getCsCod());
        tXinyiBigTableHour.setRbCsPh(tXinyiDaily.getCsPh());
        tXinyiBigTableHour.setRbCsBod5(tXinyiDaily.getCsBod5());
        tXinyiBigTableHour.setRbCsSs(tXinyiDaily.getCsSs());
        tXinyiBigTableHour.setRbCsNh3(tXinyiDaily.getCsNh3());
        tXinyiBigTableHour.setRbCsTn(tXinyiDaily.getCsTn());
        tXinyiBigTableHour.setRbCsTp(tXinyiDaily.getCsTp());
        tXinyiBigTableHour.setRbCsDcgj(tXinyiDaily.getCsDcgj());
        tXinyiBigTableHour.setRbJsSw(tXinyiDaily.getJsSw());
        tXinyiBigTableHour.setRbCsSw(tXinyiDaily.getCsSw());
        tXinyiBigTableHour.setRbShcOnePh(tXinyiDaily.getShcOnePh());
        tXinyiBigTableHour.setRbShcTwoPh(tXinyiDaily.getShcTwoPh());
        tXinyiBigTableHour.setRbShcHyOneSv(tXinyiDaily.getShcHyOneSv());
        tXinyiBigTableHour.setRbShcHyTwoSv(tXinyiDaily.getShcHyTwoSv());
        tXinyiBigTableHour.setRbShcHyOneSvi(tXinyiDaily.getShcHyOneSvi());
        tXinyiBigTableHour.setRbShcHyTwoSvi(tXinyiDaily.getShcHyTwoSvi());
        tXinyiBigTableHour.setRbShcHyOneMlss(tXinyiDaily.getShcHyOneMlss());
        tXinyiBigTableHour.setRbShcHyTwoMlss(tXinyiDaily.getShcHyTwoMlss());
        tXinyiBigTableHour.setRbShcHyOneMlvss(tXinyiDaily.getShcHyOneMlvss());
        tXinyiBigTableHour.setRbShcHyTwoMlvss(tXinyiDaily.getShcHyTwoMlvss());
        tXinyiBigTableHour.setRbShcYyOneDo(tXinyiDaily.getShcYyOneDo());
        tXinyiBigTableHour.setRbShcYyTwoDo(tXinyiDaily.getShcYyTwoDo());
        tXinyiBigTableHour.setRbShcQyOneDo(tXinyiDaily.getShcQyOneDo());
        tXinyiBigTableHour.setRbShcQyTwoDo(tXinyiDaily.getShcQyTwoDo());
        tXinyiBigTableHour.setRbShcHyOneDo(tXinyiDaily.getShcHyOneDo());
        tXinyiBigTableHour.setRbShcHyTwoDo(tXinyiDaily.getShcHyTwoDo());
        tXinyiBigTableHour.setRbJsl(tXinyiDaily.getJSL());
        tXinyiBigTableHour.setRbCsl(tXinyiDaily.getCSL());
        tXinyiBigTableHour.setRbSdclcxsl(tXinyiDaily.getSDCLCXSL());
        tXinyiBigTableHour.setRbQsb(tXinyiDaily.getQSB());
        tXinyiBigTableHour.setRbFM(tXinyiDaily.getFM());
        tXinyiBigTableHour.setRbYyHrt(tXinyiDaily.getYyHrt());
        tXinyiBigTableHour.setRbHyHrt(tXinyiDaily.getHyHrt());
        tXinyiBigTableHour.setRbQyHrt(tXinyiDaily.getQyHrt());
        tXinyiBigTableHour.setRbNhlR(tXinyiDaily.getNhlR());
        tXinyiBigTableHour.setRbWhlR(tXinyiDaily.getWhlR());
        tXinyiBigTableHour.setRbSrt(tXinyiDaily.getSRT());
        tXinyiBigTableHour.setRbCnl(tXinyiDaily.getCNL());
        tXinyiBigTableHour.setRbTyqBod5Tn(tXinyiDaily.getTyqBod5Tn());
        tXinyiBigTableHour.setRbTyhBod5Tn(tXinyiDaily.getTyhBod5Tn());
        tXinyiBigTableHour.setRbHycRjyAll(tXinyiDaily.getHycRjyAll());
        tXinyiBigTableHour.setRbHycWnndAll(tXinyiDaily.getHycWnndAll());
        tXinyiBigTableHour.setRbYycRjyAll(tXinyiDaily.getYycRjyAll());
        tXinyiBigTableHour.setRbQycRjyAll(tXinyiDaily.getQycRjyAll());
        tXinyiBigTableHour.setRbWncjbAll(tXinyiDaily.getWncjbAll());
        tXinyiBigTableHour.setRbWntjzsAll(tXinyiDaily.getWntjzsAll());
        tXinyiBigTableHour.setRbHfxwnndAll(tXinyiDaily.getHfxwnndAll());
        tXinyiBigTableHour.setRbChuniliang(tXinyiDaily.getCHUNILIANG());
        tXinyiBigTableHour.setRbCnhsl(tXinyiDaily.getCNHSL());
        tXinyiBigTableHour.setRbGwnl(tXinyiDaily.getGWNL());
        tXinyiBigTableHour.setRbDf(tXinyiDaily.getDF());
        tXinyiBigTableHour.setRbXnjf(tXinyiDaily.getXNJF());
        tXinyiBigTableHour.setRbClf(tXinyiDaily.getCLF());
        tXinyiBigTableHour.setRbTyf(tXinyiDaily.getTYF());
        tXinyiBigTableHour.setRbXdjf(tXinyiDaily.getXDJF());
        tXinyiBigTableHour.setRbQtyjf(tXinyiDaily.getQTYJF());
        tXinyiBigTableHour.setRbCnf(tXinyiDaily.getCNF());
        tXinyiBigTableHour.setRbZlsf(tXinyiDaily.getZLSF());
        tXinyiBigTableHour.setRbZjcb(tXinyiDaily.getZJCB());
        tXinyiBigTableHour.setRbDwcb(tXinyiDaily.getDWCB());
    }

    // 处理化验室
    private void handleRobotData(TXinyiBigTableHour tXinyiBigTableHour, TXinyiRobot tXinyiRobot) {
        tXinyiBigTableHour.setHyCodYb(tXinyiRobot.getCodYb());
        tXinyiBigTableHour.setHyCodJqr(tXinyiRobot.getCodJqr());
        tXinyiBigTableHour.setHyCodYz(tXinyiRobot.getCodYz());
        tXinyiBigTableHour.setHyTpHl1Jqr(tXinyiRobot.getTpHl1Jqr());
        tXinyiBigTableHour.setHyTpHl2Jqr(tXinyiRobot.getTpHl2Jqr());
        tXinyiBigTableHour.setHyTpRccJqr(tXinyiRobot.getTpRccJqr());
        tXinyiBigTableHour.setHyTp1Yz(tXinyiRobot.getTp1Yz());
        tXinyiBigTableHour.setHyTp2Yz(tXinyiRobot.getTp2Yz());
        tXinyiBigTableHour.setHyTpRccYz(tXinyiRobot.getTpRccYz());
        tXinyiBigTableHour.setHyNh31Jqr(tXinyiRobot.getNh31Jqr());
        tXinyiBigTableHour.setHyNh32Jqr(tXinyiRobot.getNh32Jqr());
        tXinyiBigTableHour.setHyNh31Yz(tXinyiRobot.getNh31Yz());
        tXinyiBigTableHour.setHyNo3Hlc1Yz(tXinyiRobot.getNo3Hlc1Yz());
        tXinyiBigTableHour.setHyNh32Yz(tXinyiRobot.getNh32Yz());
        tXinyiBigTableHour.setHyNo3Hlc2Yz(tXinyiRobot.getNo3Hlc2Yz());
        tXinyiBigTableHour.setHyNo3Hlj1Jqr(tXinyiRobot.getNo3Hlj1Jqr());
        tXinyiBigTableHour.setHyNo3Hlj2Jqr(tXinyiRobot.getNo3Hlj2Jqr());
        tXinyiBigTableHour.setHyTyll(tXinyiRobot.getTYLL());
        tXinyiBigTableHour.setHyNo3Qyc1Jqr(tXinyiRobot.getNo3Qyc1Jqr());
        tXinyiBigTableHour.setHyNo3Qyc2Jqr(tXinyiRobot.getNo3Qyc2Jqr());
        tXinyiBigTableHour.setHyNo3Qyc1Yz(tXinyiRobot.getNo3Qyc1Yz());
        tXinyiBigTableHour.setHyNo3Qyc2Yz(tXinyiRobot.getNo3Qyc2Yz());
        tXinyiBigTableHour.setHyJsll(tXinyiRobot.getJSLL());
        tXinyiBigTableHour.setHyHycxsyAll(tXinyiRobot.getHycxsyAll());
        tXinyiBigTableHour.setHyQyanAll(tXinyiRobot.getQyanAll());
        tXinyiBigTableHour.setHyQyckxsyAll(tXinyiRobot.getQyckxsyAll());
        tXinyiBigTableHour.setHyHyzlsyAll(tXinyiRobot.getHyzlsyAll());
    }


    private void handlePredictorWarning(String[] split, String hour, String task, List<TXinyiIndustry> tXinyiIndustries6, List<TXinyiRobot> tXinyiRobots6, String date) {

        String[] hours = hour.split(",");
        //2024年6月23日18:28:55 因为存在跨天问题  所以日期也是逗号拼接的
        String[] dates = date.split(",");
        //2024年6月18日13:41:10 统一格式，否则查询不到结果
        //2024年6月18日10:36:49 增加预测记录，预测准确度计算等
        TXinyiForecastComparison tXinyiForecastComparison = new TXinyiForecastComparison();
        //2024年7月11日17:04:11 TP改为zlsy
        tXinyiForecastComparison.setCategory(BusinessEnum.BigModelForecastEnum.TP.getCode().equalsIgnoreCase(task) ? BusinessEnum.BigModelForecastEnum.ZLSY.getCode() : task);
        tXinyiForecastComparison.setForecastTimeOne(dates[0].replaceAll("-", "/") + " " + hours[0]);
        tXinyiForecastComparison.setForecastTimeTwo(dates[1].replaceAll("-", "/") + " " + hours[1]);
        tXinyiForecastComparison.setForecastTimeThree(dates[2].replaceAll("-", "/") + " " + hours[2]);
        tXinyiForecastComparison.setHsForecastOne(new BigDecimal(split[0]));
        tXinyiForecastComparison.setHsForecastTwo(new BigDecimal(split[1]));
        tXinyiForecastComparison.setHsForecastThree(new BigDecimal(split[2]));
        //2024年6月20日14:28:31  增加字段，方便查询
        tXinyiForecastComparison.setRemark(DateUtil.format(DateUtils.getNowDate(), DateUtils.YYYYMMDDHH_TS));

        //防止工业库挂掉以后持续预测同一数据
        //2024年6月20日14:59:23 因为预测bug(以工业库为准，假如工业库挂了，获取的全是挂了时间段后的三小时) 判断是否生成过了否则不生成
        TXinyiForecastComparison tXinyiForecastComparisonReq = new TXinyiForecastComparison();
        //2024年08月20日16:24:56  因为remark存放的是当前时间，也就是每个小时的，所以都是不一样的，修复此bug
//        tXinyiForecastComparisonReq.setRemark(tXinyiForecastComparison.getRemark());
        tXinyiForecastComparisonReq.setCategory(tXinyiForecastComparison.getCategory());
        //2024年7月18日15:04:37 如果工业库挂掉以后，不管什么时刻，调用预测返回的未来三小时时间都是一样的，再增加一个查询条件
        tXinyiForecastComparisonReq.setForecastTimeOne(tXinyiForecastComparison.getForecastTimeOne());//一个时刻就可以了 没必要再比较第二和第三时刻了。
        List<TXinyiForecastComparison> tXinyiForecastComparisons = this.xinyiForecastComparisonService.selectTXinyiForecastComparisonList(tXinyiForecastComparisonReq);
        if(!CollectionUtils.isEmpty(tXinyiForecastComparisons)){
            log.error("预测已经进行过了，无需重复运行~~~~~~~~~~~@@@@@@@，要保存的预测数据为{}", JSON.toJSONString(tXinyiForecastComparison));
            return;
        }

        //获取配置表
        List<TXinyiNormConfig> tXinyiNormConfigs = this.xinyiNormConfigMapper.selectTXinyiNormConfigList(null);
        if(CollectionUtils.isEmpty(tXinyiNormConfigs)) {
            log.error( "未查询到配置信息");
            return;
        }
        TXinyiNormConfig normConfig = tXinyiNormConfigs.get(0);
        //获取最新的工业库的数据
//        TXinyiIndustry tXinyiIndustry = this.xinyiIndustryMapper.selectTXinyiIndustryNewest();
        //2024年7月18日10:29:44  因为获取了最新的六条数据，所以无需再查询最新的数据了
        TXinyiIndustry tXinyiIndustry = tXinyiIndustries6.get(0);
        TXinyiRobot tXinyiRobot = tXinyiRobots6.get(0);
        List<ChartBasic> chartsDataList = new ArrayList<>(9);
        if(BusinessEnum.BigModelForecastEnum.COD.getCode().equals(task)){
            //同时调用跃渊的预测接口 保存记录值
            try {
                String result = HttpUtil.get("http://10.0.3.52:10003/system/forecast?type=2&time=" + DateUtil.format(DateUtils.getNowDate(), DateUtils.YYYY_MM_DD_HH), INT_10000);
                if(!StringUtils.isBlank(result)){
                    JSONArray array = JSON.parseArray(result);
                    tXinyiForecastComparison.setYyForecastOne(array.getBigDecimal(6));
                    tXinyiForecastComparison.setYyForecastTwo(array.getBigDecimal(7));
                    tXinyiForecastComparison.setYyForecastThree(array.getBigDecimal(8));
                }
            } catch (Exception e) {
                log.error("调用跃渊的预测接口出现异常，异常信息为{}", e.getMessage());
            }
            // this.xinyiForecastComparisonService.insertTXinyiForecastComparison(tXinyiForecastComparison);
            BigDecimal cscodBzz = normConfig.getCscodBzz();
            BigDecimal cscodGkz = normConfig.getCscodGkz();
            //处理展示数据
            for (int i = 0; i < tXinyiIndustries6.size(); i++) {
                TXinyiIndustry tXinyiIndustryTemp = tXinyiIndustries6.get(5 - i);
                ChartBasic chartBasic = new ChartBasic();
                chartBasic.setTime(tXinyiIndustryTemp.getTestHour().substring(11));
                chartBasic.setVal(DecimalUtils.getAbsAndScale(tXinyiIndustryTemp.getCsCod(), INT_2));
                chartsDataList.add(chartBasic);
            }
            for (int i = 0; i < split.length; i++) {
                String val = split[i];
                ChartBasic chartBasic = new ChartBasic();
                chartBasic.setTime(hours[i]);
                chartBasic.setVal(DecimalUtils.getAbsAndScale(new BigDecimal(val), INT_2));
                chartsDataList.add(chartBasic);
            }
            ryTask.handleXinYiWarningsYC(cscodBzz, split, cscodGkz, BusinessEnum.WarningCategoryEnum.CS_COD_YC.getCode(), hour, normConfig, tXinyiIndustry.getCsCod(), tXinyiIndustry, chartsDataList, date);
        }else if(BusinessEnum.BigModelForecastEnum.SS.getCode().equals(task)){
            //同时调用跃渊的预测接口 保存记录值
            try {
                String result = HttpUtil.get("http://10.0.3.52:10003/system/forecast?type=5&time=" + DateUtil.format(DateUtils.getNowDate(), DateUtils.YYYY_MM_DD_HH), INT_10000);
                if(!StringUtils.isBlank(result)){
                    JSONArray array = JSON.parseArray(result);
                    tXinyiForecastComparison.setYyForecastOne(array.getBigDecimal(6));
                    tXinyiForecastComparison.setYyForecastTwo(array.getBigDecimal(7));
                    tXinyiForecastComparison.setYyForecastThree(array.getBigDecimal(8));
                }
            } catch (Exception e) {
                log.error("调用跃渊的预测接口出现异常，异常信息为{}", e.getMessage());
            }
            // this.xinyiForecastComparisonService.insertTXinyiForecastComparison(tXinyiForecastComparison);
            BigDecimal csSSBzz = normConfig.getCsssBzz();
            BigDecimal csssGkz = normConfig.getCsssGkz();
            //处理展示数据
            for (int i = 0; i < tXinyiIndustries6.size(); i++) {
                TXinyiIndustry tXinyiIndustryTemp = tXinyiIndustries6.get(5 - i);
                ChartBasic chartBasic = new ChartBasic();
                chartBasic.setTime(tXinyiIndustryTemp.getTestHour().substring(11));
                chartBasic.setVal(DecimalUtils.getAbsAndScale(tXinyiIndustryTemp.getCsSs(), INT_2));
                chartsDataList.add(chartBasic);
            }
            for (int i = 0; i < split.length; i++) {
                String val = split[i];
                ChartBasic chartBasic = new ChartBasic();
                chartBasic.setTime(hours[i]);
                chartBasic.setVal(DecimalUtils.getAbsAndScale(new BigDecimal(val), INT_2));
                chartsDataList.add(chartBasic);
            }
            ryTask.handleXinYiWarningsYC(csSSBzz, split, csssGkz, BusinessEnum.WarningCategoryEnum.CS_SS_YC.getCode(), hour, normConfig, tXinyiIndustry.getCsSs(), tXinyiIndustry, chartsDataList, date);
        }/*else if(BusinessEnum.BigModelForecastEnum.TN.getCode().equals(task)){
            //同时调用跃渊的预测接口 保存记录值
            try {
                String result = HttpUtil.get("http://10.0.3.52:10003/system/forecast?type=3&time=" + DateUtil.format(DateUtils.getNowDate(), DateUtils.YYYY_MM_DD_HH), INT_10);
                if(!StringUtils.isBlank(result)){
                    JSONArray array = JSON.parseArray(result);
                    tXinyiForecastComparison.setYyForecastOne(array.getBigDecimal(6));
                    tXinyiForecastComparison.setYyForecastTwo(array.getBigDecimal(7));
                    tXinyiForecastComparison.setYyForecastThree(array.getBigDecimal(8));
                }
            } catch (Exception e) {
                log.error("调用跃渊的预测接口出现异常，异常信息为{}", e.getMessage());
            }
            // this.xinyiForecastComparisonService.insertTXinyiForecastComparison(tXinyiForecastComparison);
            BigDecimal cszzBzz = normConfig.getCszzBzz();
            BigDecimal cszzGkz = normConfig.getCszzGkz();
            //处理展示数据
            for (int i = 0; i < tXinyiIndustries6.size(); i++) {
                TXinyiIndustry tXinyiIndustryTemp = tXinyiIndustries6.get(5 - i);
                ChartBasic chartBasic = new ChartBasic();
                chartBasic.setTime(tXinyiIndustryTemp.getTestHour().substring(11));
                chartBasic.setVal(DecimalUtils.getAbsAndScale(tXinyiIndustryTemp.getCsTn(), INT_2));
                chartsDataList.add(chartBasic);
            }
            for (int i = 0; i < split.length; i++) {
                String val = split[i];
                ChartBasic chartBasic = new ChartBasic();
                chartBasic.setTime(hours[i]);
                chartBasic.setVal(DecimalUtils.getAbsAndScale(new BigDecimal(val), INT_2));
                chartsDataList.add(chartBasic);
            }
            handleXinYiWarningsYC(cszzBzz, split, cszzGkz, BusinessEnum.WarningCategoryEnum.CS_TN_YC.getCode(), hour, normConfig,tXinyiIndustry.getCsCod(), tXinyiIndustry, chartsDataList, date);
        }*/else if(BusinessEnum.BigModelForecastEnum.TP.getCode().equals(task)){
            //同时调用跃渊的预测接口 保存记录值
            try {
                String result = HttpUtil.get("http://10.0.3.52:10003/system/forecast?type=1&time=" + DateUtil.format(DateUtils.getNowDate(), DateUtils.YYYY_MM_DD_HH), INT_10000);
                if(!StringUtils.isBlank(result)){
                    JSONArray array = JSON.parseArray(result);
                    tXinyiForecastComparison.setYyForecastOne(array.getBigDecimal(6));
                    tXinyiForecastComparison.setYyForecastTwo(array.getBigDecimal(7));
                    tXinyiForecastComparison.setYyForecastThree(array.getBigDecimal(8));
                }
            } catch (Exception e) {
                log.error("调用跃渊的预测接口出现异常，异常信息为{}", e.getMessage());
            }
            // this.xinyiForecastComparisonService.insertTXinyiForecastComparison(tXinyiForecastComparison);
            BigDecimal cszlBzz = normConfig.getCszlBzz();
            BigDecimal cszlGkz = normConfig.getCszlGkz();
            //处理展示数据
            for (int i = 0; i < tXinyiRobots6.size(); i++) {
                TXinyiRobot tXinyiRobotTemp = tXinyiRobots6.get(5 - i);
                ChartBasic chartBasic = new ChartBasic();
                chartBasic.setTime(tXinyiRobotTemp.getTestHour().substring(11));
                chartBasic.setVal(DecimalUtils.getAbsAndScale(tXinyiRobotTemp.getTpRccJqr(), INT_2));
                chartsDataList.add(chartBasic);
            }
            for (int i = 0; i < split.length; i++) {
                String val = split[i];
                ChartBasic chartBasic = new ChartBasic();
                chartBasic.setTime(hours[i]);
                chartBasic.setVal(DecimalUtils.getAbsAndScale(new BigDecimal(val), INT_2));
                chartsDataList.add(chartBasic);
            }
            ryTask.handleXinYiWarningsYC(cszlBzz, split, cszlGkz, CS_TP_YC.getCode(), hour, normConfig, tXinyiRobot.getTpRccJqr(), tXinyiIndustry, chartsDataList, date);
        }else if(BusinessEnum.BigModelForecastEnum.NH3.getCode().equals(task)){
            //同时调用跃渊的预测接口 保存记录值
            try {
                String result = HttpUtil.get("http://10.0.3.52:10003/system/forecast?type=4&time=" + DateUtil.format(DateUtils.getNowDate(), DateUtils.YYYY_MM_DD_HH), INT_10000);
                if(!StringUtils.isBlank(result)){
                    JSONArray array = JSON.parseArray(result);
                    tXinyiForecastComparison.setYyForecastOne(array.getBigDecimal(6));
                    tXinyiForecastComparison.setYyForecastTwo(array.getBigDecimal(7));
                    tXinyiForecastComparison.setYyForecastThree(array.getBigDecimal(8));
                }
            } catch (Exception e) {
                log.error("调用跃渊的预测接口出现异常，异常信息为{}", e.getMessage());
            }
            // this.xinyiForecastComparisonService.insertTXinyiForecastComparison(tXinyiForecastComparison);
            BigDecimal csadBzz = normConfig.getCsadBzz();
            BigDecimal csadGkz = normConfig.getCsadGkz();
            //处理展示数据
            for (int i = 0; i < tXinyiIndustries6.size(); i++) {
                TXinyiIndustry tXinyiIndustryTemp = tXinyiIndustries6.get(5 - i);
                ChartBasic chartBasic = new ChartBasic();
                chartBasic.setTime(tXinyiIndustryTemp.getTestHour().substring(11));
                chartBasic.setVal(DecimalUtils.getAbsAndScale(tXinyiIndustryTemp.getCsNh3(), INT_2));
                chartsDataList.add(chartBasic);
            }
            for (int i = 0; i < split.length; i++) {
                String val = split[i];
                ChartBasic chartBasic = new ChartBasic();
                chartBasic.setTime(hours[i]);
                chartBasic.setVal(DecimalUtils.getAbsAndScale(new BigDecimal(val), INT_2));
                chartsDataList.add(chartBasic);
            }
            ryTask.handleXinYiWarningsYC(csadBzz, split, csadGkz, BusinessEnum.WarningCategoryEnum.CS_AD_YC.getCode(), hour, normConfig, tXinyiIndustry.getCsNh3(), tXinyiIndustry, chartsDataList, date);
        }else if(BusinessEnum.BigModelForecastEnum.XSY1.getCode().equals(task)){
            //2024年6月21日14:57:02 红杉的出水总氮预测改成 不用工业库的，用化验科的两个xsy 相关指标
            //同时调用跃渊的预测接口 保存记录值
            try {
                String result = HttpUtil.get("http://10.0.3.52:10003/system/forecast?type=6&time=" + DateUtil.format(DateUtils.getNowDate(), DateUtils.YYYY_MM_DD_HH), INT_10000);
                if(!StringUtils.isBlank(result)){
                    JSONArray array = JSON.parseArray(result);
                    tXinyiForecastComparison.setYyForecastOne(array.getBigDecimal(6));
                    tXinyiForecastComparison.setYyForecastTwo(array.getBigDecimal(7));
                    tXinyiForecastComparison.setYyForecastThree(array.getBigDecimal(8));
                }
            } catch (Exception e) {
                log.error("调用跃渊的预测接口出现异常，异常信息为{}", e.getMessage());
            }
            // this.xinyiForecastComparisonService.insertTXinyiForecastComparison(tXinyiForecastComparison);
            /*BigDecimal cscodBzz = new BigDecimal(XIAOSUANYAN_BZK);
            BigDecimal cscodGkz = new BigDecimal(XIAOSUANYAN_GKZ);*/
            //2024年7月11日17:19:47  1#好氧硝酸盐、2#好氧硝酸盐使用总氮标准值和管控值来预警
            BigDecimal cszzBzz = normConfig.getCszzBzz();
            BigDecimal cszzGkz = normConfig.getCszzGkz();
            //处理展示数据
            for (int i = 0; i < tXinyiRobots6.size(); i++) {
                TXinyiRobot tXinyiRobotTemp = tXinyiRobots6.get(5 - i);
                ChartBasic chartBasic = new ChartBasic();
                chartBasic.setTime(tXinyiRobotTemp.getTestHour().substring(11));
                chartBasic.setVal(DecimalUtils.getAbsAndScale(tXinyiRobotTemp.getNo3Hlj1Jqr(), INT_2));
                chartsDataList.add(chartBasic);
            }
            for (int i = 0; i < split.length; i++) {
                String val = split[i];
                ChartBasic chartBasic = new ChartBasic();
                chartBasic.setTime(hours[i]);
                chartBasic.setVal(DecimalUtils.getAbsAndScale(new BigDecimal(val), INT_2));
                chartsDataList.add(chartBasic);
            }
            ryTask.handleXinYiWarningsYC(cszzBzz, split, cszzGkz, BusinessEnum.WarningCategoryEnum.CS_XSY_1_YC.getCode(), hour, normConfig, tXinyiRobot.getNo3Hlj1Jqr(), tXinyiIndustry, chartsDataList, date);
        }else if(BusinessEnum.BigModelForecastEnum.XSY2.getCode().equals(task)){
            //同时调用跃渊的预测接口 保存记录值
            try {
                String result = HttpUtil.get("http://10.0.3.52:10003/system/forecast?type=7&time=" + DateUtil.format(DateUtils.getNowDate(), DateUtils.YYYY_MM_DD_HH), INT_10000);
                if(!StringUtils.isBlank(result)){
                    JSONArray array = JSON.parseArray(result);
                    tXinyiForecastComparison.setYyForecastOne(array.getBigDecimal(6));
                    tXinyiForecastComparison.setYyForecastTwo(array.getBigDecimal(7));
                    tXinyiForecastComparison.setYyForecastThree(array.getBigDecimal(8));
                }
            } catch (Exception e) {
                log.error("调用跃渊的预测接口出现异常，异常信息为{}", e.getMessage());
            }
            // this.xinyiForecastComparisonService.insertTXinyiForecastComparison(tXinyiForecastComparison);
            /*BigDecimal cscodBzz = new BigDecimal(XIAOSUANYAN_BZK);
            BigDecimal cscodGkz = new BigDecimal(XIAOSUANYAN_GKZ);*/
            //2024年7月11日17:19:47  1#好氧硝酸盐、2#好氧硝酸盐使用总氮标准值和管控值来预警
            BigDecimal cszzBzz = normConfig.getCszzBzz();
            BigDecimal cszzGkz = normConfig.getCszzGkz();
            //处理展示数据
            for (int i = 0; i < tXinyiRobots6.size(); i++) {
                TXinyiRobot tXinyiRobotTemp = tXinyiRobots6.get(5 - i);
                ChartBasic chartBasic = new ChartBasic();
                chartBasic.setTime(tXinyiRobotTemp.getTestHour().substring(11));
                chartBasic.setVal(DecimalUtils.getAbsAndScale(tXinyiRobotTemp.getNo3Hlj2Jqr(), INT_2));
                chartsDataList.add(chartBasic);
            }
            for (int i = 0; i < split.length; i++) {
                String val = split[i];
                ChartBasic chartBasic = new ChartBasic();
                chartBasic.setTime(hours[i]);
                chartBasic.setVal(DecimalUtils.getAbsAndScale(new BigDecimal(val), INT_2));
                chartsDataList.add(chartBasic);
            }
            ryTask.handleXinYiWarningsYC(cszzBzz, split, cszzGkz, BusinessEnum.WarningCategoryEnum.CS_XSY_2_YC.getCode(), hour, normConfig, tXinyiRobot.getNo3Hlj2Jqr(), tXinyiIndustry, chartsDataList, date);
        }else if(BusinessEnum.BigModelForecastEnum.QYXSY1.getCode().equals(task)){
            //同时调用跃渊的预测接口 保存记录值
            /*try {
                String result = HttpUtil.get("http://10.0.3.52:10003/system/forecast?type=7&time=" + DateUtil.format(DateUtils.getNowDate(), DateUtils.YYYY_MM_DD_HH), INT_10000);
                if(!StringUtils.isBlank(result)){
                    JSONArray array = JSON.parseArray(result);
                    tXinyiForecastComparison.setYyForecastOne(array.getBigDecimal(6));
                    tXinyiForecastComparison.setYyForecastTwo(array.getBigDecimal(7));
                    tXinyiForecastComparison.setYyForecastThree(array.getBigDecimal(8));
                }
            } catch (Exception e) {
                log.error("调用跃渊的预测接口出现异常，异常信息为{}", e.getMessage());
            }*/
            // this.xinyiForecastComparisonService.insertTXinyiForecastComparison(tXinyiForecastComparison);
            /*BigDecimal cscodBzz = new BigDecimal(XIAOSUANYAN_BZK);
            BigDecimal cscodGkz = new BigDecimal(XIAOSUANYAN_GKZ);*/
            //2024年7月11日17:19:47  1#好氧硝酸盐、2#好氧硝酸盐使用总氮标准值和管控值来预警
            BigDecimal cszzBzz = normConfig.getCszzBzz();
            BigDecimal cszzGkz = normConfig.getCszzGkz();
            //处理展示数据
            for (int i = 0; i < tXinyiRobots6.size(); i++) {
                TXinyiRobot tXinyiRobotTemp = tXinyiRobots6.get(5 - i);
                ChartBasic chartBasic = new ChartBasic();
                chartBasic.setTime(tXinyiRobotTemp.getTestHour().substring(11));
                chartBasic.setVal(DecimalUtils.getAbsAndScale(tXinyiRobotTemp.getNo3Qyc1Jqr(), INT_2));
                chartsDataList.add(chartBasic);
            }
            for (int i = 0; i < split.length; i++) {
                String val = split[i];
                ChartBasic chartBasic = new ChartBasic();
                chartBasic.setTime(hours[i]);
                chartBasic.setVal(DecimalUtils.getAbsAndScale(new BigDecimal(val), INT_2));
                chartsDataList.add(chartBasic);
            }
//            ryTask.handleXinYiWarningsYC(cszzBzz, split, cszzGkz, BusinessEnum.WarningCategoryEnum.QYCXSY_1.getCode(), hour, normConfig, tXinyiRobot.getNo3Hlj2Jqr(), tXinyiIndustry, chartsDataList, date);
        }else if(BusinessEnum.BigModelForecastEnum.QYXSY2.getCode().equals(task)){
            //同时调用跃渊的预测接口 保存记录值
            /*try {
                String result = HttpUtil.get("http://10.0.3.52:10003/system/forecast?type=7&time=" + DateUtil.format(DateUtils.getNowDate(), DateUtils.YYYY_MM_DD_HH), INT_10000);
                if(!StringUtils.isBlank(result)){
                    JSONArray array = JSON.parseArray(result);
                    tXinyiForecastComparison.setYyForecastOne(array.getBigDecimal(6));
                    tXinyiForecastComparison.setYyForecastTwo(array.getBigDecimal(7));
                    tXinyiForecastComparison.setYyForecastThree(array.getBigDecimal(8));
                }
            } catch (Exception e) {
                log.error("调用跃渊的预测接口出现异常，异常信息为{}", e.getMessage());
            }*/
            // this.xinyiForecastComparisonService.insertTXinyiForecastComparison(tXinyiForecastComparison);
            /*BigDecimal cscodBzz = new BigDecimal(XIAOSUANYAN_BZK);
            BigDecimal cscodGkz = new BigDecimal(XIAOSUANYAN_GKZ);*/
            //2024年7月11日17:19:47  1#好氧硝酸盐、2#好氧硝酸盐使用总氮标准值和管控值来预警
            BigDecimal cszzBzz = normConfig.getCszzBzz();
            BigDecimal cszzGkz = normConfig.getCszzGkz();
            //处理展示数据
            for (int i = 0; i < tXinyiRobots6.size(); i++) {
                TXinyiRobot tXinyiRobotTemp = tXinyiRobots6.get(5 - i);
                ChartBasic chartBasic = new ChartBasic();
                chartBasic.setTime(tXinyiRobotTemp.getTestHour().substring(11));
                chartBasic.setVal(DecimalUtils.getAbsAndScale(tXinyiRobotTemp.getNo3Qyc2Jqr(), INT_2));
                chartsDataList.add(chartBasic);
            }
            for (int i = 0; i < split.length; i++) {
                String val = split[i];
                ChartBasic chartBasic = new ChartBasic();
                chartBasic.setTime(hours[i]);
                chartBasic.setVal(DecimalUtils.getAbsAndScale(new BigDecimal(val), INT_2));
                chartsDataList.add(chartBasic);
            }
//            ryTask.handleXinYiWarningsYC(cszzBzz, split, cszzGkz, BusinessEnum.WarningCategoryEnum.QYCXSY_2.getCode(), hour, normConfig, tXinyiRobot.getNo3Hlj2Jqr(), tXinyiIndustry, chartsDataList, date);
        }else if(BusinessEnum.BigModelForecastEnum.QYNH31.getCode().equals(task)){
            //同时调用跃渊的预测接口 保存记录值
            /*try {
                String result = HttpUtil.get("http://10.0.3.52:10003/system/forecast?type=7&time=" + DateUtil.format(DateUtils.getNowDate(), DateUtils.YYYY_MM_DD_HH), INT_10000);
                if(!StringUtils.isBlank(result)){
                    JSONArray array = JSON.parseArray(result);
                    tXinyiForecastComparison.setYyForecastOne(array.getBigDecimal(6));
                    tXinyiForecastComparison.setYyForecastTwo(array.getBigDecimal(7));
                    tXinyiForecastComparison.setYyForecastThree(array.getBigDecimal(8));
                }
            } catch (Exception e) {
                log.error("调用跃渊的预测接口出现异常，异常信息为{}", e.getMessage());
            }*/
            // this.xinyiForecastComparisonService.insertTXinyiForecastComparison(tXinyiForecastComparison);
            /*BigDecimal cscodBzz = new BigDecimal(XIAOSUANYAN_BZK);
            BigDecimal cscodGkz = new BigDecimal(XIAOSUANYAN_GKZ);*/
            //2024年09月08日11:21:25 采用出水氨氮的标准值和管控值
            BigDecimal csadBzz = normConfig.getCsadBzz();
            BigDecimal csadGkz = normConfig.getCsadGkz();
            //处理展示数据
            for (int i = 0; i < tXinyiRobots6.size(); i++) {
                TXinyiRobot tXinyiRobotTemp = tXinyiRobots6.get(5 - i);
                ChartBasic chartBasic = new ChartBasic();
                chartBasic.setTime(tXinyiRobotTemp.getTestHour().substring(11));
                chartBasic.setVal(DecimalUtils.getAbsAndScale(tXinyiRobotTemp.getNh31Jqr(), INT_2));
                chartsDataList.add(chartBasic);
            }
            for (int i = 0; i < split.length; i++) {
                String val = split[i];
                ChartBasic chartBasic = new ChartBasic();
                chartBasic.setTime(hours[i]);
                chartBasic.setVal(DecimalUtils.getAbsAndScale(new BigDecimal(val), INT_2));
                chartsDataList.add(chartBasic);
            }
//            ryTask.handleXinYiWarningsYC(csadBzz, split, csadGkz, BusinessEnum.WarningCategoryEnum.QYAD_1.getCode(), hour, normConfig, tXinyiRobot.getNo3Hlj2Jqr(), tXinyiIndustry, chartsDataList, date);
        }else if(BusinessEnum.BigModelForecastEnum.QYNH32.getCode().equals(task)){
            //同时调用跃渊的预测接口 保存记录值
            /*try {
                String result = HttpUtil.get("http://10.0.3.52:10003/system/forecast?type=7&time=" + DateUtil.format(DateUtils.getNowDate(), DateUtils.YYYY_MM_DD_HH), INT_10000);
                if(!StringUtils.isBlank(result)){
                    JSONArray array = JSON.parseArray(result);
                    tXinyiForecastComparison.setYyForecastOne(array.getBigDecimal(6));
                    tXinyiForecastComparison.setYyForecastTwo(array.getBigDecimal(7));
                    tXinyiForecastComparison.setYyForecastThree(array.getBigDecimal(8));
                }
            } catch (Exception e) {
                log.error("调用跃渊的预测接口出现异常，异常信息为{}", e.getMessage());
            }*/
            // this.xinyiForecastComparisonService.insertTXinyiForecastComparison(tXinyiForecastComparison);
            /*BigDecimal cscodBzz = new BigDecimal(XIAOSUANYAN_BZK);
            BigDecimal cscodGkz = new BigDecimal(XIAOSUANYAN_GKZ);*/
            //2024年09月08日11:21:25 采用出水氨氮的标准值和管控值
            BigDecimal csadBzz = normConfig.getCsadBzz();
            BigDecimal csadGkz = normConfig.getCsadGkz();
            //处理展示数据
            for (int i = 0; i < tXinyiRobots6.size(); i++) {
                TXinyiRobot tXinyiRobotTemp = tXinyiRobots6.get(5 - i);
                ChartBasic chartBasic = new ChartBasic();
                chartBasic.setTime(tXinyiRobotTemp.getTestHour().substring(11));
                chartBasic.setVal(DecimalUtils.getAbsAndScale(tXinyiRobotTemp.getNh32Jqr(), INT_2));
                chartsDataList.add(chartBasic);
            }
            for (int i = 0; i < split.length; i++) {
                String val = split[i];
                ChartBasic chartBasic = new ChartBasic();
                chartBasic.setTime(hours[i]);
                chartBasic.setVal(DecimalUtils.getAbsAndScale(new BigDecimal(val), INT_2));
                chartsDataList.add(chartBasic);
            }
//            ryTask.handleXinYiWarningsYC(csadBzz, split, csadGkz, BusinessEnum.WarningCategoryEnum.QYAD_2.getCode(), hour, normConfig, tXinyiRobot.getNo3Hlj2Jqr(), tXinyiIndustry, chartsDataList, date);
        }else {
            log.error("暂未支持的类型{}", task);
        }
        //插入到数据库
        //2024年6月21日14:18:55  如果红杉预测和跃渊预测都有数据再保存
        //2024年7月8日15:15:46 逻辑调整：只要红杉的数据不为空就保存
        if(Objects.isNull(tXinyiForecastComparison.getHsForecastOne()) || Objects.isNull(tXinyiForecastComparison.getHsForecastTwo()) ||Objects.isNull(tXinyiForecastComparison.getHsForecastThree())){
//            || Objects.isNull(tXinyiForecastComparison.getYyForecastOne()) || Objects.isNull(tXinyiForecastComparison.getYyForecastTwo()) || Objects.isNull(tXinyiForecastComparison.getYyForecastThree())){
            log.error("保存预测对比数据时，有存在不满足条件的数据，不再保存数据，数据为{}", JSON.toJSONString(tXinyiForecastComparison));
        }else
            xinyiForecastComparisonService.insertTXinyiForecastComparison(tXinyiForecastComparison);
    }
}