big-model-java/slibra-quartz/src/main/java/com/slibra/quartz/task/AsyncTask.java

package com.slibra.quartz.task;

import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONObject;
import com.alibaba.fastjson2.JSONWriter;
import com.google.protobuf.ByteString;
import com.slibra.business.domain.*;
import com.slibra.business.mapper.*;
import com.slibra.business.req.ChatReq;
import com.slibra.business.req.ChatRequest;
import com.slibra.business.req.DecisionReq;
import com.slibra.business.req.PolicyReq;
import com.slibra.business.res.ShowValueCSBasic;
import com.slibra.business.res.ShowValueJSBasic;
import com.slibra.common.constant.MyConstants;
import com.slibra.common.enums.BusinessEnum;
import com.slibra.common.utils.DateUtils;
import com.slibra.common.utils.LocalDateTimeUtil;
import com.slibra.common.utils.StringUtils;
import com.slibra.common.utils.uuid.IdUtils;
import inference.InferenceAPIsServiceGrpc;
import inference.PredictionResponse;
import inference.PredictionsRequest;
import io.grpc.ManagedChannel;
import io.grpc.ManagedChannelBuilder;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;
import org.springframework.util.CollectionUtils;

import java.io.IOException;
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.util.*;

import static com.slibra.common.constant.MyConstants.*;

@Component
@Slf4j
public class AsyncTask {


    @Autowired
    private TXinyiIndustryMapper xinyiIndustryMapper;

    @Autowired
    private TXinyiNormConfigMapper xinyiNormConfigMapper;

    @Autowired
    private TXinyiWarningRecordMapper xinyiWarningRecordMapper;

    @Autowired
    private TXinyiChatRecordMapper xinyiChatRecordMapper;

    @Autowired
    private TXinyiDailyMapper xinyiDailyMapper;

    @Autowired
    private TXinyiCalculateMapper xinyiCalculateMapper;

    @Autowired
    private TXinyiRobotMapper xinyiRobotMapper;

    @Autowired
    private TXinyiForecastComparisonMapper xinyiForecastComparisonMapper;


    /**
     *
     * 异步处理告警任务
     * @param tXinyiIndustry
     */
    @Async("customizeExecutor")
    public void handleWarning(TXinyiIndustry tXinyiIndustry){
        //2024年6月18日10:45:20 额外计算一下预测的准确度
        try {
            this.updateForecastComparisonByIndustry(tXinyiIndustry);
        } catch (Exception e) {
            log.error("-------------------------------更新预测准确度的时候异常，异常信息为{}", e.getMessage());
        }
        log.info("进入了定时任务保存工业库数据并触发报警操作");
        //获取配置表
        List<TXinyiNormConfig> tXinyiNormConfigs = this.xinyiNormConfigMapper.selectTXinyiNormConfigList(null);
        if(CollectionUtils.isEmpty(tXinyiNormConfigs))
            throw new RuntimeException("未查询到配置信息");
        TXinyiNormConfig normConfig = tXinyiNormConfigs.get(0);

        //2024年6月7日15:26:44 把一些额外的计算的值，同时记录下来(xinyiCalculate对象在生化报警可能用的到)
        TXinyiCalculate xinyiCalculate = this.addCalculateByIndustry(tXinyiIndustry, normConfig);
        this.xinyiCalculateMapper.insertTXinyiCalculate(xinyiCalculate);

        //水质报警
        this.handleSZWarning(tXinyiIndustry, normConfig);

        //2024年5月28日14:14:26  下面是新增的 生化报警处理
        this.handleSHWarning(tXinyiIndustry, normConfig, xinyiCalculate);
    }

    /**
     * 额外计算一下预测的准确度
     * @param tXinyiIndustry
     */
    private void updateForecastComparisonByIndustry(TXinyiIndustry tXinyiIndustry) {
        BigDecimal csCod = tXinyiIndustry.getCsCod();
        BigDecimal csSs = tXinyiIndustry.getCsSs();
        BigDecimal csTn = tXinyiIndustry.getCsTn();
        BigDecimal csTp = tXinyiIndustry.getCsTp();
        BigDecimal csNh3 = tXinyiIndustry.getCsNh3();
        String testHour = tXinyiIndustry.getTestHour();

        //时间段1
        List<TXinyiForecastComparison> tXinyiForecastComparisons1 = this.xinyiForecastComparisonMapper.selectTXinyiForecastComparisonList(TXinyiForecastComparison.builder().forecastTimeOne(testHour).build());
        if(!CollectionUtils.isEmpty(tXinyiForecastComparisons1)){
            for (TXinyiForecastComparison tXinyiForecastComparison : tXinyiForecastComparisons1) {
                BigDecimal hsForecastOne = tXinyiForecastComparison.getHsForecastOne();
                BigDecimal yyForecastOne = tXinyiForecastComparison.getYyForecastOne();
                if("cod".equals(tXinyiForecastComparison.getCategory())){
                    tXinyiForecastComparison.setRealOne(csCod);
                    if(!Objects.isNull(csCod) && csCod.compareTo(BigDecimal.ZERO) > 0){
                        if(!Objects.isNull(hsForecastOne))
                            tXinyiForecastComparison.setHsErrorRateOne((csCod.subtract(hsForecastOne)).divide(csCod, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        if(!Objects.isNull(yyForecastOne))
                            tXinyiForecastComparison.setYyErrorRateOne((csCod.subtract(yyForecastOne)).divide(csCod, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                    }
                }
                if("ss".equals(tXinyiForecastComparison.getCategory())){
                    tXinyiForecastComparison.setRealOne(csSs);
                    if(!Objects.isNull(csSs) && csSs.compareTo(BigDecimal.ZERO) > 0){
                        if(!Objects.isNull(hsForecastOne))
                            tXinyiForecastComparison.setHsErrorRateOne((csSs.subtract(hsForecastOne)).divide(csSs, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        if(!Objects.isNull(yyForecastOne))
                            tXinyiForecastComparison.setYyErrorRateOne((csSs.subtract(yyForecastOne)).divide(csSs, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                    }
                }
                //2024年6月21日16:28:56 tn总氮的预测用xsy1和xsy2计算 并从化验库获取
                /*if("tn".equals(tXinyiForecastComparison.getCategory())){
                    tXinyiForecastComparison.setRealOne(csTn);
                    if(!Objects.isNull(csTn) && csTn.compareTo(BigDecimal.ZERO) > 0){
                        if(!Objects.isNull(hsForecastOne))
                            tXinyiForecastComparison.setHsErrorRateOne((csTn.subtract(hsForecastOne)).divide(csTn, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        if(!Objects.isNull(yyForecastOne))
                            tXinyiForecastComparison.setYyErrorRateOne((csTn.subtract(yyForecastOne)).divide(csTn, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                    }
                }*/
                //2024年6月20日11:16:55 出水总磷的真实值从化验室获取
                /*if("tp".equals(tXinyiForecastComparison.getCategory())){
                    tXinyiForecastComparison.setRealOne(csTp);
                    if(!Objects.isNull(csTp) && csTp.compareTo(BigDecimal.ZERO) > 0){
                        tXinyiForecastComparison.setHsErrorRateOne((csTp.subtract(hsForecastOne)).divide(csTp, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        tXinyiForecastComparison.setYyErrorRateOne((csTp.subtract(yyForecastOne)).divide(csTp, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                    }
                }*/
                if("nh3".equals(tXinyiForecastComparison.getCategory())){
                    tXinyiForecastComparison.setRealOne(csNh3);
                    if(!Objects.isNull(csNh3) && csNh3.compareTo(BigDecimal.ZERO) > 0){
                        if(!Objects.isNull(hsForecastOne))
                            tXinyiForecastComparison.setHsErrorRateOne((csNh3.subtract(hsForecastOne)).divide(csNh3, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        if(!Objects.isNull(yyForecastOne))
                            tXinyiForecastComparison.setYyErrorRateOne((csNh3.subtract(yyForecastOne)).divide(csNh3, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                    }
                }
                this.xinyiForecastComparisonMapper.updateTXinyiForecastComparison(tXinyiForecastComparison);
            }
        }
        //时间段2
        List<TXinyiForecastComparison> tXinyiForecastComparisons2 = this.xinyiForecastComparisonMapper.selectTXinyiForecastComparisonList(TXinyiForecastComparison.builder().forecastTimeTwo(testHour).build());
        if(!CollectionUtils.isEmpty(tXinyiForecastComparisons2)){
            for (TXinyiForecastComparison tXinyiForecastComparison : tXinyiForecastComparisons2) {
                BigDecimal hsForecastTwo = tXinyiForecastComparison.getHsForecastTwo();
                BigDecimal yyForecastTwo = tXinyiForecastComparison.getYyForecastTwo();
                if("cod".equals(tXinyiForecastComparison.getCategory())){
                    tXinyiForecastComparison.setRealTwo(csCod);
                    if(!Objects.isNull(csCod) && csCod.compareTo(BigDecimal.ZERO) > 0){
                        if(!Objects.isNull(hsForecastTwo))
                            tXinyiForecastComparison.setHsErrorRateTwo((csCod.subtract(hsForecastTwo)).divide(csCod, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        if(!Objects.isNull(yyForecastTwo))
                            tXinyiForecastComparison.setYyErrorRateTwo((csCod.subtract(yyForecastTwo)).divide(csCod, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                    }
                }
                if("ss".equals(tXinyiForecastComparison.getCategory())){
                    tXinyiForecastComparison.setRealTwo(csSs);
                    if(!Objects.isNull(csSs) && csSs.compareTo(BigDecimal.ZERO) > 0){
                        if(!Objects.isNull(hsForecastTwo))
                            tXinyiForecastComparison.setHsErrorRateTwo((csSs.subtract(hsForecastTwo)).divide(csSs, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        if(!Objects.isNull(yyForecastTwo))
                            tXinyiForecastComparison.setYyErrorRateTwo((csSs.subtract(yyForecastTwo)).divide(csSs, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                    }
                }
                /*if("tn".equals(tXinyiForecastComparison.getCategory())){
                    tXinyiForecastComparison.setRealTwo(csTn);
                    if(!Objects.isNull(csTn) && csTn.compareTo(BigDecimal.ZERO) > 0){
                        if(!Objects.isNull(hsForecastTwo))
                            tXinyiForecastComparison.setHsErrorRateTwo((csTn.subtract(hsForecastTwo)).divide(csTn, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        if(!Objects.isNull(yyForecastTwo))
                            tXinyiForecastComparison.setYyErrorRateTwo((csTn.subtract(yyForecastTwo)).divide(csTn, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                    }
                }*/
                //2024年6月20日11:16:55 出水总磷的真实值从化验室获取
                /*if("tp".equals(tXinyiForecastComparison.getCategory())){
                    tXinyiForecastComparison.setRealTwo(csTp);
                    if(!Objects.isNull(csTp) && csTp.compareTo(BigDecimal.ZERO) > 0){
                        tXinyiForecastComparison.setHsErrorRateTwo((csTp.subtract(hsForecastTwo)).divide(csTp, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        tXinyiForecastComparison.setYyErrorRateTwo((csTp.subtract(yyForecastTwo)).divide(csTp, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                    }
                }*/
                if("nh3".equals(tXinyiForecastComparison.getCategory())){
                    tXinyiForecastComparison.setRealTwo(csNh3);
                    if(!Objects.isNull(csNh3) && csNh3.compareTo(BigDecimal.ZERO) > 0){
                        if(!Objects.isNull(hsForecastTwo))
                            tXinyiForecastComparison.setHsErrorRateTwo((csNh3.subtract(hsForecastTwo)).divide(csNh3, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        if(!Objects.isNull(yyForecastTwo))
                            tXinyiForecastComparison.setYyErrorRateTwo((csNh3.subtract(yyForecastTwo)).divide(csNh3, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                    }
                }
                this.xinyiForecastComparisonMapper.updateTXinyiForecastComparison(tXinyiForecastComparison);
            }
        }
        //时间段3
        List<TXinyiForecastComparison> tXinyiForecastComparisons3 = this.xinyiForecastComparisonMapper.selectTXinyiForecastComparisonList(TXinyiForecastComparison.builder().forecastTimeThree(testHour).build());
        if(!CollectionUtils.isEmpty(tXinyiForecastComparisons3)){
            for (TXinyiForecastComparison tXinyiForecastComparison : tXinyiForecastComparisons3) {
                BigDecimal hsForecastThree = tXinyiForecastComparison.getHsForecastThree();
                BigDecimal yyForecastThree = tXinyiForecastComparison.getYyForecastThree();
                if("cod".equals(tXinyiForecastComparison.getCategory())){
                    tXinyiForecastComparison.setRealThree(csCod);
                    if(!Objects.isNull(csCod) && csCod.compareTo(BigDecimal.ZERO) > 0){
                        if(!Objects.isNull(hsForecastThree))
                            tXinyiForecastComparison.setHsErrorRateThree((csCod.subtract(hsForecastThree)).divide(csCod, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        if(!Objects.isNull(yyForecastThree))
                            tXinyiForecastComparison.setYyErrorRateThree((csCod.subtract(yyForecastThree)).divide(csCod, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                    }
                }
                if("ss".equals(tXinyiForecastComparison.getCategory())){
                    tXinyiForecastComparison.setRealThree(csSs);
                    if(!Objects.isNull(csSs) && csSs.compareTo(BigDecimal.ZERO) > 0){
                        if(!Objects.isNull(hsForecastThree))
                            tXinyiForecastComparison.setHsErrorRateThree((csSs.subtract(hsForecastThree)).divide(csSs, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        if(!Objects.isNull(yyForecastThree))
                            tXinyiForecastComparison.setYyErrorRateThree((csSs.subtract(yyForecastThree)).divide(csSs, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                    }
                }
                /*if("tn".equals(tXinyiForecastComparison.getCategory())){
                    tXinyiForecastComparison.setRealThree(csTn);
                    if(!Objects.isNull(csTn) && csTn.compareTo(BigDecimal.ZERO) > 0){
                        if(!Objects.isNull(hsForecastThree))
                            tXinyiForecastComparison.setHsErrorRateThree((csTn.subtract(hsForecastThree)).divide(csTn, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        if(!Objects.isNull(yyForecastThree))
                            tXinyiForecastComparison.setYyErrorRateThree((csTn.subtract(yyForecastThree)).divide(csTn, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                    }
                }*/
                //2024年6月20日11:16:55 出水总磷的真实值从化验室获取
                /*if("tp".equals(tXinyiForecastComparison.getCategory())){
                    tXinyiForecastComparison.setRealThree(csTp);
                    if(!Objects.isNull(csTp) && csTp.compareTo(BigDecimal.ZERO) > 0){
                        tXinyiForecastComparison.setHsErrorRateThree((csTp.subtract(hsForecastThree)).divide(csTp, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        tXinyiForecastComparison.setYyErrorRateThree((csTp.subtract(yyForecastThree)).divide(csTp, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                    }
                }*/
                if("nh3".equals(tXinyiForecastComparison.getCategory())){
                    tXinyiForecastComparison.setRealThree(csNh3);
                    if(!Objects.isNull(csNh3) && csNh3.compareTo(BigDecimal.ZERO) > 0){
                        if(!Objects.isNull(hsForecastThree))
                            tXinyiForecastComparison.setHsErrorRateThree((csNh3.subtract(hsForecastThree)).divide(csNh3, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        if(!Objects.isNull(yyForecastThree))
                            tXinyiForecastComparison.setYyErrorRateThree((csNh3.subtract(yyForecastThree)).divide(csNh3, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                    }
                }
                this.xinyiForecastComparisonMapper.updateTXinyiForecastComparison(tXinyiForecastComparison);
            }
        }
    }


    /**
     * 额外计算一下预测的准确度
     * @param tXinyiRobot
     */
    public void updateForecastComparisonByRobot(TXinyiRobot tXinyiRobot) {
        BigDecimal no3Hlj1Jqr = tXinyiRobot.getNo3Hlj1Jqr();
        BigDecimal no3Hlj2Jqr = tXinyiRobot.getNo3Hlj2Jqr();
        String testHour = tXinyiRobot.getTestHour();

        BigDecimal tpRccJqr = tXinyiRobot.getTpRccJqr();
        BigDecimal csTp = null;
        BigDecimal csTn = null;
        if(!Objects.isNull(tpRccJqr)){
            csTp = tpRccJqr.divide(ROBOT_HY_DIVIDE, NUMBER_SCALE_4, RoundingMode.HALF_UP);
            //2024年6月20日13:44:26  先不计算，结果会更准确
            //2024年6月21日14:23:14  就是要 除以0.8
//            csTp = tpRccJqr;
        }
        if(!Objects.isNull(no3Hlj1Jqr) && !Objects.isNull(no3Hlj2Jqr))
            csTn = (no3Hlj1Jqr.add(no3Hlj2Jqr)).divide(new BigDecimal(2), NUMBER_SCALE_4, RoundingMode.HALF_UP).divide(ROBOT_HY_DIVIDE, NUMBER_SCALE_4, RoundingMode.HALF_UP);

        //时间段1
        List<TXinyiForecastComparison> tXinyiForecastComparisons1 = this.xinyiForecastComparisonMapper.selectTXinyiForecastComparisonList(TXinyiForecastComparison.builder().forecastTimeOne(testHour).build());
        if(!CollectionUtils.isEmpty(tXinyiForecastComparisons1)){
            for (TXinyiForecastComparison tXinyiForecastComparison : tXinyiForecastComparisons1) {
                BigDecimal hsForecastOne = tXinyiForecastComparison.getHsForecastOne();
                BigDecimal yyForecastOne = tXinyiForecastComparison.getYyForecastOne();
                /*if("xsy1".equals(tXinyiForecastComparison.getCategory())){
                    tXinyiForecastComparison.setRealOne(no3Hlj1Jqr);
                    if(!Objects.isNull(no3Hlj1Jqr) && no3Hlj1Jqr.compareTo(BigDecimal.ZERO) > 0){
                        if(!Objects.isNull(hsForecastOne))
                            tXinyiForecastComparison.setHsErrorRateOne((no3Hlj1Jqr.subtract(hsForecastOne)).divide(no3Hlj1Jqr, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        if(!Objects.isNull(yyForecastOne))
                            tXinyiForecastComparison.setYyErrorRateOne((no3Hlj1Jqr.subtract(yyForecastOne)).divide(no3Hlj1Jqr, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                    }
                }
                if("xsy2".equals(tXinyiForecastComparison.getCategory())){
                    tXinyiForecastComparison.setRealOne(no3Hlj2Jqr);
                    if(!Objects.isNull(no3Hlj2Jqr) && no3Hlj2Jqr.compareTo(BigDecimal.ZERO) > 0){
                        if(!Objects.isNull(hsForecastOne))
                            tXinyiForecastComparison.setHsErrorRateOne((no3Hlj2Jqr.subtract(hsForecastOne)).divide(no3Hlj2Jqr, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        if(!Objects.isNull(yyForecastOne))
                            tXinyiForecastComparison.setYyErrorRateOne((no3Hlj2Jqr.subtract(yyForecastOne)).divide(no3Hlj2Jqr, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                    }
                }*/
                //2024年6月21日17:04:01  总磷的真实值也从化验室获取
                if("tn".equals(tXinyiForecastComparison.getCategory())){
                    tXinyiForecastComparison.setRealOne(csTn);
                    if(!Objects.isNull(csTn) && csTn.compareTo(BigDecimal.ZERO) > 0){
                        if(!Objects.isNull(hsForecastOne))
                            tXinyiForecastComparison.setHsErrorRateOne((csTn.subtract(hsForecastOne)).divide(csTn, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        if(!Objects.isNull(yyForecastOne))
                            tXinyiForecastComparison.setYyErrorRateOne((csTn.subtract(yyForecastOne)).divide(csTn, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                    }
                }

                //2024年6月20日11:14:42  总磷的真实值也从化验室获取
                if("tp".equals(tXinyiForecastComparison.getCategory())){
                    tXinyiForecastComparison.setRealOne(csTp);
                    if(!Objects.isNull(csTp) && csTp.compareTo(BigDecimal.ZERO) > 0){
                        if(!Objects.isNull(hsForecastOne))
                            tXinyiForecastComparison.setHsErrorRateOne((csTp.subtract(hsForecastOne)).divide(csTp, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        if(!Objects.isNull(yyForecastOne))
                            tXinyiForecastComparison.setYyErrorRateOne((csTp.subtract(yyForecastOne)).divide(csTp, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                    }
                }
                this.xinyiForecastComparisonMapper.updateTXinyiForecastComparison(tXinyiForecastComparison);
            }
        }
        //时间段2
        List<TXinyiForecastComparison> tXinyiForecastComparisons2 = this.xinyiForecastComparisonMapper.selectTXinyiForecastComparisonList(TXinyiForecastComparison.builder().forecastTimeTwo(testHour).build());
        if(!CollectionUtils.isEmpty(tXinyiForecastComparisons2)){
            for (TXinyiForecastComparison tXinyiForecastComparison : tXinyiForecastComparisons2) {
                BigDecimal hsForecastTwo = tXinyiForecastComparison.getHsForecastTwo();
                BigDecimal yyForecastTwo = tXinyiForecastComparison.getYyForecastTwo();
                /*if("xsy1".equals(tXinyiForecastComparison.getCategory())){
                    tXinyiForecastComparison.setRealTwo(no3Hlj1Jqr);
                    if(!Objects.isNull(no3Hlj1Jqr) && no3Hlj1Jqr.compareTo(BigDecimal.ZERO) > 0){
                        if(!Objects.isNull(hsForecastTwo))
                            tXinyiForecastComparison.setHsErrorRateTwo((no3Hlj1Jqr.subtract(hsForecastTwo)).divide(no3Hlj1Jqr, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        if(!Objects.isNull(yyForecastTwo))
                            tXinyiForecastComparison.setYyErrorRateTwo((no3Hlj1Jqr.subtract(yyForecastTwo)).divide(no3Hlj1Jqr, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                    }
                }
                if("xsy2".equals(tXinyiForecastComparison.getCategory())){
                    tXinyiForecastComparison.setRealTwo(no3Hlj2Jqr);
                    if(!Objects.isNull(no3Hlj2Jqr) && no3Hlj2Jqr.compareTo(BigDecimal.ZERO) > 0){
                        if(!Objects.isNull(hsForecastTwo))
                            tXinyiForecastComparison.setHsErrorRateTwo((no3Hlj2Jqr.subtract(hsForecastTwo)).divide(no3Hlj2Jqr, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        if(!Objects.isNull(yyForecastTwo))
                            tXinyiForecastComparison.setYyErrorRateTwo((no3Hlj2Jqr.subtract(yyForecastTwo)).divide(no3Hlj2Jqr, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                    }
                }*/
                //2024年6月21日17:04:01  总磷的真实值也从化验室获取
                if("tn".equals(tXinyiForecastComparison.getCategory())){
                    tXinyiForecastComparison.setRealTwo(csTn);
                    if(!Objects.isNull(csTn) && csTn.compareTo(BigDecimal.ZERO) > 0){
                        if(!Objects.isNull(hsForecastTwo))
                            tXinyiForecastComparison.setHsErrorRateTwo((csTn.subtract(hsForecastTwo)).divide(csTn, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        if(!Objects.isNull(yyForecastTwo))
                            tXinyiForecastComparison.setYyErrorRateTwo((csTn.subtract(yyForecastTwo)).divide(csTn, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                    }
                }

                //2024年6月20日11:14:42  总磷的真实值也从化验室获取
                if("tp".equals(tXinyiForecastComparison.getCategory())){
                    tXinyiForecastComparison.setRealTwo(csTp);
                    if(!Objects.isNull(csTp) && csTp.compareTo(BigDecimal.ZERO) > 0){
                        if(!Objects.isNull(hsForecastTwo))
                            tXinyiForecastComparison.setHsErrorRateTwo((csTp.subtract(hsForecastTwo)).divide(csTp, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        if(!Objects.isNull(yyForecastTwo))
                            tXinyiForecastComparison.setYyErrorRateTwo((csTp.subtract(yyForecastTwo)).divide(csTp, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                    }
                }
                this.xinyiForecastComparisonMapper.updateTXinyiForecastComparison(tXinyiForecastComparison);
            }
        }
        //时间段3
        List<TXinyiForecastComparison> tXinyiForecastComparisons3 = this.xinyiForecastComparisonMapper.selectTXinyiForecastComparisonList(TXinyiForecastComparison.builder().forecastTimeThree(testHour).build());
        if(!CollectionUtils.isEmpty(tXinyiForecastComparisons3)){
            for (TXinyiForecastComparison tXinyiForecastComparison : tXinyiForecastComparisons3) {
                BigDecimal hsForecastThree = tXinyiForecastComparison.getHsForecastThree();
                BigDecimal yyForecastThree = tXinyiForecastComparison.getYyForecastThree();
                /*if("xsy1".equals(tXinyiForecastComparison.getCategory())){
                    tXinyiForecastComparison.setRealThree(no3Hlj1Jqr);
                    if(!Objects.isNull(no3Hlj1Jqr) && no3Hlj1Jqr.compareTo(BigDecimal.ZERO) > 0){
                        if(!Objects.isNull(hsForecastThree))
                            tXinyiForecastComparison.setHsErrorRateThree((no3Hlj1Jqr.subtract(hsForecastThree)).divide(no3Hlj1Jqr, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        if(!Objects.isNull(yyForecastThree))
                            tXinyiForecastComparison.setYyErrorRateThree((no3Hlj1Jqr.subtract(yyForecastThree)).divide(no3Hlj1Jqr, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                    }
                }
                if("xsy2".equals(tXinyiForecastComparison.getCategory())){
                    tXinyiForecastComparison.setRealThree(no3Hlj2Jqr);
                    if(!Objects.isNull(no3Hlj2Jqr) && no3Hlj2Jqr.compareTo(BigDecimal.ZERO) > 0){
                        if(!Objects.isNull(hsForecastThree))
                            tXinyiForecastComparison.setHsErrorRateThree((no3Hlj2Jqr.subtract(hsForecastThree)).divide(no3Hlj2Jqr, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        if(!Objects.isNull(yyForecastThree))
                            tXinyiForecastComparison.setYyErrorRateThree((no3Hlj2Jqr.subtract(yyForecastThree)).divide(no3Hlj2Jqr, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                    }
                }*/
                //2024年6月21日17:04:01  总磷的真实值也从化验室获取
                if("tn".equals(tXinyiForecastComparison.getCategory())){
                    tXinyiForecastComparison.setRealThree(csTn);
                    if(!Objects.isNull(csTn) && csTn.compareTo(BigDecimal.ZERO) > 0){
                        if(!Objects.isNull(hsForecastThree))
                            tXinyiForecastComparison.setHsErrorRateThree((csTn.subtract(hsForecastThree)).divide(csTn, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        if(!Objects.isNull(yyForecastThree))
                            tXinyiForecastComparison.setYyErrorRateThree((csTn.subtract(yyForecastThree)).divide(csTn, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                    }
                }

                //2024年6月20日11:14:42  总磷的真实值也从化验室获取
                if("tp".equals(tXinyiForecastComparison.getCategory())){
                    tXinyiForecastComparison.setRealThree(csTp);
                    if(!Objects.isNull(csTp) && csTp.compareTo(BigDecimal.ZERO) > 0){
                        if(!Objects.isNull(hsForecastThree))
                            tXinyiForecastComparison.setHsErrorRateThree((csTp.subtract(hsForecastThree)).divide(csTp, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        if(!Objects.isNull(yyForecastThree))
                            tXinyiForecastComparison.setYyErrorRateThree((csTp.subtract(yyForecastThree)).divide(csTp, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                    }
                }
                this.xinyiForecastComparisonMapper.updateTXinyiForecastComparison(tXinyiForecastComparison);
            }
        }
    }

    private TXinyiCalculate addCalculateByIndustry(TXinyiIndustry tXinyiIndustry, TXinyiNormConfig normConfig) {
        //获取的一些配置信息
        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.selectNewestData();
        if(Objects.isNull(tXinyiDaily)){
            //理论不会出现
            log.error("没有日报数据");
            return null;
        }

        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 计算逻辑调整
            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));
            }

        }
        return tXinyiCalculate;
    }

    private void handleSHWarning(TXinyiIndustry tXinyiIndustry, TXinyiNormConfig normConfig, TXinyiCalculate xinyiCalculate) {
        //判断对应指标是否报警  然后调研大模型获取决策信息
//        BigDecimal jsSlq = tXinyiIndustry.getJsSlq();
        //内回流比报警
//        BigDecimal nhlbSjz = normConfig.getNhlbSjz();//400
//        BigDecimal nhlbnkSxz = normConfig.getNhlbnkSxz();//360
        BigDecimal nhlbnkXxz = normConfig.getNhlbnkXxz();//270
//        BigDecimal nhlbqdsl = normConfig.getNHLBQDSL();
//        BigDecimal nhlbdsjll = normConfig.getNHLBDSJLL();
//        BigDecimal nhlbgzxl = normConfig.getNHLBGZXL();
        BigDecimal nhlb = xinyiCalculate.getNHLB();
        if(!Objects.isNull(nhlb) && !Objects.isNull(nhlbnkXxz)){
//            BigDecimal divide = nhlbqdsl.multiply(nhlbdsjll).multiply(nhlbgzxl).divide(jsSlq, 4, RoundingMode.HALF_UP);
            handleXinYiWarningsSH(nhlbnkXxz, nhlb, BusinessEnum.WarningCategoryEnum.NHLB.getCode(), tXinyiIndustry, normConfig, true);
        }

        //外回流比报警
//        BigDecimal whlbqdsl = normConfig.getWHLBQDSL();
//        BigDecimal whlbdsjll = normConfig.getWHLBDSJLL();
//        BigDecimal whlbgzxl = normConfig.getWHLBGZXL();
        BigDecimal whlbnkXxz = normConfig.getWhlbnkXxz();//75
//        BigDecimal whlbSjz = normConfig.getWhlbSjz();
        BigDecimal whlb = xinyiCalculate.getWHLB();
        if(!Objects.isNull(whlb) && !Objects.isNull(whlbnkXxz)){
            handleXinYiWarningsSH(whlbnkXxz, whlb, BusinessEnum.WarningCategoryEnum.WHLB.getCode(), tXinyiIndustry, normConfig, true);
        }


        //最新的一条日报数据
        /*List<TXinyiDaily> tXinyiDailies = this.xinyiDailyMapper.selectTXinyiDailyList(null);
        if(CollectionUtils.isEmpty(tXinyiDailies))
            return;//肯定不会出现这种情况 因为有很多历史数据了
        TXinyiDaily tXinyiDaily = tXinyiDailies.get(0);*/
        TXinyiDaily tXinyiDaily = this.xinyiDailyMapper.selectNewestData();
        if(Objects.isNull(tXinyiDaily))
            return;//肯定不会出现这种情况 因为有很多历史数据了  新水厂可能会有这个问题
        log.info("生化报警获取日报的最新的一条数据为{}", JSON.toJSONString(tXinyiDaily));

        //污泥浓度报警
        BigDecimal sjscgkz = null;
        //判断是否是夏季
        if(LocalDateTimeUtil.isSummer())
            sjscgkz = normConfig.getXjwnndXxz();
        else
            sjscgkz = normConfig.getDjwnndXxz();
        //#1
        BigDecimal oneMlss = tXinyiIndustry.getOneMlss();
        if(!Objects.isNull(oneMlss) && !Objects.isNull(sjscgkz)){
            handleXinYiWarningsSH(sjscgkz, oneMlss, BusinessEnum.WarningCategoryEnum.WNND_MLSS_1.getCode(), tXinyiIndustry, normConfig, true);
        }
        //#1
        BigDecimal twoMlss = tXinyiIndustry.getTwoMlss();
        if(!Objects.isNull(twoMlss) && !Objects.isNull(sjscgkz)){
            handleXinYiWarningsSH(sjscgkz, twoMlss, BusinessEnum.WarningCategoryEnum.WNND_MLSS_2.getCode(), tXinyiIndustry, normConfig, true);
        }


        //污泥负荷(需要从日报获取数据) 计算 + 部分数据从日报获取
        //污泥负荷=[Ls]=24*（[BOD_in]-[BOD_off]）*[Q_in]/[MLSS]/（[V_hao]+[V_que]+[V_yan]）/2 kgBOD/(kgMLSS·d)
        //2024年6月27日17:18:33 直接从计算结果拿到
        BigDecimal fm = xinyiCalculate.getFM();
        //2024年6月28日17:17:03 已经配置了新的
        BigDecimal wnfhnkXxz = normConfig.getWnfhnkXxz();
        if(!Objects.isNull(fm) && !Objects.isNull(wnfhnkXxz)){
            handleXinYiWarningsSH(wnfhnkXxz, fm, BusinessEnum.WarningCategoryEnum.WNFH.getCode(), tXinyiIndustry, normConfig, true);
        }

        //万吨水产泥率（todo 没有计算规则，只能从日报获取）


        //挥发性污泥浓度占比（MLVSS/MLSS）
        //特殊：小于
        BigDecimal hfxwnndzb = xinyiCalculate.getHFXWNNDZB();
        BigDecimal hfxwnndzbSjz = normConfig.getHfxwnndzbSjz();
        if(!Objects.isNull(hfxwnndzb) && !Objects.isNull(hfxwnndzbSjz)){
            handleXinYiWarningsSH(hfxwnndzbSjz, hfxwnndzb, BusinessEnum.WarningCategoryEnum.HFXWNNDZB.getCode(), tXinyiIndustry, normConfig, false);
        }

        //进水碳氮比
        BigDecimal jsTdb = xinyiCalculate.getJsTdb();
        BigDecimal jstdbnkzXxz = normConfig.getJstdbnkzXxz();
        if(!Objects.isNull(jsTdb) && !Objects.isNull(jstdbnkzXxz)){
            handleXinYiWarningsSH(jstdbnkzXxz, jsTdb, BusinessEnum.WarningCategoryEnum.TDB.getCode(), tXinyiIndustry, normConfig, true);
        }

        //进水碳磷比
        BigDecimal jsTlb = xinyiCalculate.getJsTlb();
        BigDecimal jstlbNkz = normConfig.getJstlbNkz();
        if(!Objects.isNull(jsTlb) && !Objects.isNull(jstlbNkz)){
            handleXinYiWarningsSH(jstlbNkz, jsTlb, BusinessEnum.WarningCategoryEnum.TLB.getCode(), tXinyiIndustry, normConfig, true);
        }

        //进水BOD与COD比值(生化性)
        BigDecimal jsBodBCod = xinyiCalculate.getJsBodBCod();
        String jsbodycodbzGkz = normConfig.getJsbodycodbzGkz();
        if(!StringUtils.isBlank(jsbodycodbzGkz) && jsbodycodbzGkz.contains("-")){
            String[] split = jsbodycodbzGkz.split("-");
            sjscgkz = new BigDecimal(split[0]);
            if(!Objects.isNull(jsBodBCod)){
                handleXinYiWarningsSH(sjscgkz, jsBodBCod, BusinessEnum.WarningCategoryEnum.TLB.getCode(), tXinyiIndustry, normConfig, true);
            }
        }


        //好氧区DO（一池） 2024年5月31日14:04:37 加数据，让他一直报警
        BigDecimal shcHyOneDo = tXinyiIndustry.getOneHymdDo();
//        BigDecimal shcHyOneDo = new BigDecimal("5");
//        BigDecimal hycrjysjzSxz = normConfig.getHycrjysjzSxz();
        BigDecimal hycrjyNkz = normConfig.getHycrjyNkz();
        if(!Objects.isNull(shcHyOneDo) && !Objects.isNull(hycrjyNkz)){
            handleXinYiWarningsSH(hycrjyNkz, shcHyOneDo, BusinessEnum.WarningCategoryEnum.HYQDO_ONE.getCode(), tXinyiIndustry, normConfig, true);
        }
        //好氧区DO（二池） 2024年5月31日14:09:36 溶解氧从日报获取  工业的不准
        //2024年6月27日17:00:31  都先从工业库获取，日报没有必要再报警了
        BigDecimal shcHyTwoDo = tXinyiIndustry.getTwoHymdDo();
        if(!Objects.isNull(shcHyTwoDo) && !Objects.isNull(hycrjyNkz)){
            handleXinYiWarningsSH(hycrjyNkz, shcHyTwoDo, BusinessEnum.WarningCategoryEnum.HYQDO_TWO.getCode(), tXinyiIndustry, normConfig, true);
        }

        //气水比
        BigDecimal qsb = xinyiCalculate.getQSB();
        BigDecimal shcqbNkz = normConfig.getShcqbNkz();
        if(!Objects.isNull(qsb) && !Objects.isNull(shcqbNkz))
            handleXinYiWarningsSH(shcqbNkz, qsb, BusinessEnum.WarningCategoryEnum.QSB.getCode(), tXinyiIndustry, normConfig, true);

        //二沉池表面负荷
        BigDecimal eccBmfh = xinyiCalculate.getEccBmfh();
        BigDecimal eccbmfhznkzXxz = normConfig.getEccbmfhznkzXxz();
        if(!Objects.isNull(eccBmfh) && !Objects.isNull(eccbmfhznkzXxz)){
            handleXinYiWarningsSH(eccbmfhznkzXxz, eccBmfh, BusinessEnum.WarningCategoryEnum.ECC_BMFH.getCode(), tXinyiIndustry, normConfig, true);
        }

        //二沉池固体负荷
        BigDecimal eccGtfh = xinyiCalculate.getEccGtfh();
        BigDecimal eccgtfhnkxxz = normConfig.getECCGTFHNKXXZ();
        if(!Objects.isNull(eccGtfh) && !Objects.isNull(eccgtfhnkxxz)){
            handleXinYiWarningsSH(eccgtfhnkxxz, eccGtfh, BusinessEnum.WarningCategoryEnum.ECC_GTFH.getCode(), tXinyiIndustry, normConfig, true);
        }

        //反冲洗水量
        //2024年7月3日10:59:32 这里用反冲洗水量比例做计算
        BigDecimal fcxslBl = xinyiCalculate.getFCXSLBL();
        BigDecimal fcxslblsjzXxz = normConfig.getFcxslblsjzXxz();
        if(!Objects.isNull(fcxslBl) && !Objects.isNull(fcxslblsjzXxz))
            handleXinYiWarningsSH(fcxslblsjzXxz, fcxslBl, BusinessEnum.WarningCategoryEnum.FCXSL.getCode(), tXinyiIndustry, normConfig, true);
    }


    /**
     * 处理信义生化报警的逻辑 统一处理
     * @param sjscgkz :实际生产管控值
     * @param currentVal
     * @param category
     * @param tXinyiIndustry
     * @param normConfig
     * @param normal 是否常规判断：默认都是超过；只有这个挥发性污泥浓度占比（VSS/SS）是小于才报警
     * 2024年6月27日15:39:15 调整：生化报警只取实际生产管控指标
     *
     */
    private void handleXinYiWarningsSH(BigDecimal sjscgkz, BigDecimal currentVal, String category, TXinyiIndustry tXinyiIndustry, TXinyiNormConfig normConfig, Boolean normal) {
        TXinyiWarningRecord tXinyiWarningRecord = new TXinyiWarningRecord();
        /*String category = BusinessEnum.WarningCategoryEnum.CS_AD.getCode();*/
        tXinyiWarningRecord.setStatus(0);
        tXinyiWarningRecord.setType(1);
        tXinyiWarningRecord.setCategory(category);
        tXinyiWarningRecord.setTime(DateUtils.getNowDate());
        tXinyiWarningRecord.setWarningVal(currentVal);
        tXinyiWarningRecord.setDesignVal(sjscgkz);
        tXinyiWarningRecord.setControlVal(sjscgkz);
        tXinyiWarningRecord.setCreateBy(WARNING_DEFAULT_CREATE);
        tXinyiWarningRecord.setCreateTime(DateUtils.getNowDate());
        tXinyiWarningRecord.setRemark("1");

        //2024年6月27日17:36:25 有一个判断是反正的
        if(normal){
            //2024年5月25日17:52:33  如果工业库获取不到数据，也触发报警，但是不调用决策接口
            if (Objects.isNull(currentVal) || currentVal.compareTo(BigDecimal.ZERO) == 0) {
                tXinyiWarningRecord.setReason(category + EXCEPTION_WARNING);
                tXinyiWarningRecord.setLevel(WARNING_LEVEL_NO_DATE);
            } else if (currentVal.compareTo(sjscgkz) > 0) {//一级
                tXinyiWarningRecord.setReason(category + CHAOBIAO_WARNING);
                tXinyiWarningRecord.setLevel(WARNING_LEVEL_ONE);
            } /*else if (currentVal.compareTo(bzz) >= 0 && currentVal.compareTo(multiply) <= 0) {//二级
            tXinyiWarningRecord.setReason(category + CHAOBIAO_WARNING);
            tXinyiWarningRecord.setLevel(WARNING_LEVEL_TWO);
        } else if (!Objects.isNull(gkz) && currentVal.compareTo(gkz) > 0) {
            tXinyiWarningRecord.setReason(category + CHAOGUANKONG_WARNING);
            tXinyiWarningRecord.setLevel(WARNING_LEVEL_THREE);
        }*/ else {
                tXinyiWarningRecord = null;//这种的无需处理
            }
        }else{
            //2024年5月25日17:52:33  如果工业库获取不到数据，也触发报警，但是不调用决策接口
            if (Objects.isNull(currentVal) || currentVal.compareTo(BigDecimal.ZERO) == 0) {
                tXinyiWarningRecord.setReason(category + EXCEPTION_WARNING);
                tXinyiWarningRecord.setLevel(WARNING_LEVEL_NO_DATE);
            } else if (currentVal.compareTo(sjscgkz) < 0) {//一级
                tXinyiWarningRecord.setReason(category + CHAOBIAO_WARNING);
                tXinyiWarningRecord.setLevel(WARNING_LEVEL_ONE);
            } /*else if (currentVal.compareTo(bzz) >= 0 && currentVal.compareTo(multiply) <= 0) {//二级
            tXinyiWarningRecord.setReason(category + CHAOBIAO_WARNING);
            tXinyiWarningRecord.setLevel(WARNING_LEVEL_TWO);
        } else if (!Objects.isNull(gkz) && currentVal.compareTo(gkz) > 0) {
            tXinyiWarningRecord.setReason(category + CHAOGUANKONG_WARNING);
            tXinyiWarningRecord.setLevel(WARNING_LEVEL_THREE);
        }*/ else {
                tXinyiWarningRecord = null;//这种的无需处理
            }
        }


        //当前状态正常 需要查询历史有无正在报警的数据，如果有，将报警状态改完2(系统自动关闭)
        List<TXinyiWarningRecord> tXinyiWarningRecords = this.xinyiWarningRecordMapper.selectTXinyiWarningRecordList(TXinyiWarningRecord.builder().delFlag(0).type(1).category(category).status(0).build());
        if(Objects.isNull(tXinyiWarningRecord)){//数据正常，无告警信息
            if(!CollectionUtils.isEmpty(tXinyiWarningRecords)){
                log.info( "{}:现在恢复正常，历史报警数据为{}", category,JSON.toJSONString(tXinyiWarningRecords));
                for (TXinyiWarningRecord xinyiWarningRecord : tXinyiWarningRecords) {
                    xinyiWarningRecord.setStatus(2);
                    Date nowDate = DateUtils.getNowDate();
                    xinyiWarningRecord.setOffTime(nowDate);
                    xinyiWarningRecord.setUpdateTime(nowDate);
                    xinyiWarningRecord.setUpdateBy(WARNING_DEFAULT_CREATE);
                    this.xinyiWarningRecordMapper.updateTXinyiWarningRecord(xinyiWarningRecord);
                }
            }
        }else{//有新的告警信息
            if(CollectionUtils.isEmpty(tXinyiWarningRecords)){//之前没有告警记录
                //保存到数据库中
                this.xinyiWarningRecordMapper.insertTXinyiWarningRecord(tXinyiWarningRecord);
                if(WARNING_LEVEL_NO_DATE.equals(tXinyiWarningRecord.getLevel())){
                    //只保存一个普通的问答记录 不需要调用决策信息，但是实时数据还是要记录的
                    this.addChatRecordByWarning(tXinyiWarningRecord, tXinyiIndustry, normConfig);
                }else {
                    //继续调用决策（普通问答）
                    this.askBigModelForSHWarning(tXinyiWarningRecord, tXinyiIndustry, normConfig);
                }
            }else{
                log.info("{}:之前已经有过告警记录了，且还是继续报警，无需重复添加报警，但是决策仍然要调用", category);
                for (TXinyiWarningRecord xinyiWarningRecord : tXinyiWarningRecords) {//理论上只有一个的
                    if(WARNING_LEVEL_NO_DATE.equals(tXinyiWarningRecord.getLevel())){
                        //只保存一个普通的问答记录 不需要调用决策信息，但是实时数据还是要记录的
                        this.addChatRecordByWarning(tXinyiWarningRecord, tXinyiIndustry, normConfig);
                    }else {
                        //继续调用决策（普通问答）
                        this.askBigModelForSHWarning(xinyiWarningRecord, tXinyiIndustry, normConfig);
                    }
                }
            }
        }
    }


    private void handleSZWarning(TXinyiIndustry tXinyiIndustry, TXinyiNormConfig normConfig) {
        //出水相关
        //出水COD报警
        BigDecimal csCod = tXinyiIndustry.getCsCod();
        BigDecimal cscodBzz = normConfig.getCscodBzz();
        BigDecimal cscodGkz = normConfig.getCscodGkz();
        if(!Objects.isNull(cscodBzz)){
            handleXinYiWarningsCs(cscodBzz, csCod, cscodGkz, BusinessEnum.WarningCategoryEnum.CS_COD.getCode(), tXinyiIndustry, normConfig);
        }

        //出水总磷超标报警
        BigDecimal csTp = tXinyiIndustry.getCsTp();
        BigDecimal cszlBzz = normConfig.getCszlBzz();
        BigDecimal cszlGkz = normConfig.getCszlGkz();
        if(!Objects.isNull(cszlBzz)){
            handleXinYiWarningsCs(cszlBzz, csTp, cszlGkz, BusinessEnum.WarningCategoryEnum.CS_ZL.getCode(), tXinyiIndustry, normConfig);
        }


        //出水总氮超标报警
        BigDecimal csTn = tXinyiIndustry.getCsTn();
        BigDecimal cszzBzz = normConfig.getCszzBzz();
        BigDecimal cszzGkz = normConfig.getCszzGkz();
        if(!Objects.isNull(cszzBzz)){
            handleXinYiWarningsCs(cszzBzz, csTn, cszzGkz, BusinessEnum.WarningCategoryEnum.CS_ZD.getCode(), tXinyiIndustry, normConfig);
        }

        //出水氨氮超标报警
        BigDecimal csNh3 = tXinyiIndustry.getCsNh3();
        BigDecimal csadBzz = normConfig.getCsadBzz();
        BigDecimal csadGkz = normConfig.getCsadGkz();
        if(!Objects.isNull(csadBzz)){
            handleXinYiWarningsCs(csadBzz, csNh3, csadGkz, BusinessEnum.WarningCategoryEnum.CS_AD.getCode(), tXinyiIndustry, normConfig);
        }

        //出水SS超标报警
        BigDecimal csSS = tXinyiIndustry.getCsSs();
        BigDecimal csSSBzz = normConfig.getCsssBzz();
        BigDecimal csssGkz = normConfig.getCsssGkz();
        if(!Objects.isNull(csSSBzz)){
            handleXinYiWarningsCs(csSSBzz, csSS, csssGkz, BusinessEnum.WarningCategoryEnum.CS_SS.getCode(), tXinyiIndustry, normConfig);
        }

        //进水相关报警
        //进水总磷超标报警
        BigDecimal jsTp = tXinyiIndustry.getJsTp();
        BigDecimal jszlSjz = normConfig.getJszlSjz();
        if(!Objects.isNull(jszlSjz)){
            handleXinYiWarningRecordJS(jszlSjz, jsTp, BusinessEnum.WarningCategoryEnum.JS_ZL.getCode(), tXinyiIndustry, normConfig);
        }

        //进水COD超标报警
        BigDecimal jsCod = tXinyiIndustry.getJsCod();
        BigDecimal jscodSjz = normConfig.getJscodSjz();
        if(!Objects.isNull(jscodSjz)){
            handleXinYiWarningRecordJS(jscodSjz, jsCod, BusinessEnum.WarningCategoryEnum.JS_COD.getCode(), tXinyiIndustry, normConfig);
        }

        //进水总氮超标报警
        BigDecimal jsTn = tXinyiIndustry.getJsTn();
        BigDecimal jszdSjz = normConfig.getJszdSjz();
        if(!Objects.isNull(jszdSjz)){
            handleXinYiWarningRecordJS(jszdSjz, jsTn, BusinessEnum.WarningCategoryEnum.JS_ZD.getCode(), tXinyiIndustry, normConfig);
        }

        //进水氨氮超标报警
        BigDecimal jsNh3 = tXinyiIndustry.getJsNh3();
        BigDecimal jsadSjz = normConfig.getJsadSjz();
        if(!Objects.isNull(jsadSjz)){
            handleXinYiWarningRecordJS(jsadSjz, jsNh3, BusinessEnum.WarningCategoryEnum.JS_AD.getCode(), tXinyiIndustry, normConfig);
        }

        //进水SS超标报警
        BigDecimal jsSS = tXinyiIndustry.getJsSs();
        BigDecimal jsSSSjz = normConfig.getJsssSjz();
        if(!Objects.isNull(jsSSSjz)){
            handleXinYiWarningRecordJS(jsSSSjz, jsSS, BusinessEnum.WarningCategoryEnum.JS_SS.getCode(), tXinyiIndustry, normConfig);
        }
    }



    private void askBigModelForSHWarning(TXinyiWarningRecord xinyiWarningRecord, TXinyiIndustry tXinyiIndustry, TXinyiNormConfig normConfig) {
        log.info("进入了后台接口调⽤⼤模型获取问答结果处理");
        StringBuilder sb = new StringBuilder();
        String sessionId = IdUtils.simpleUUID();
        ChatReq chatReq = new ChatReq();
//        String ipAddr = IpUtils.getIpAddr();//获取用户的ip地址 传给大模型
        String ipAddr = "";//获取用户的ip地址 传给大模型  定时任务获取不到ip地址
        int counts = 1;//默认是第一次
        //这种问答 没有历史问答的概念 直接把问题扔进去就行 无需查询历史记录
        List<String> historyDates = new ArrayList<>();
        //构建问题(替换提示词中的占位符)
        String shWarningPrompt = SH_WARNING_PROMPT;
        shWarningPrompt =shWarningPrompt.replace("#{0}", xinyiWarningRecord.getReason());
        shWarningPrompt =shWarningPrompt.replace("#{1}", String.valueOf(xinyiWarningRecord.getDesignVal()));
        shWarningPrompt =shWarningPrompt.replace("#{2}", String.valueOf(xinyiWarningRecord.getControlVal()));
        shWarningPrompt =shWarningPrompt.replace("#{3}", String.valueOf(xinyiWarningRecord.getWarningVal()));
        historyDates.add(shWarningPrompt);
        // 获取输出流
        ManagedChannel channel = null;
        try {
            channel = ManagedChannelBuilder.forAddress("10.0.0.24", 17070)
                    .usePlaintext()
                    .build();
            InferenceAPIsServiceGrpc.InferenceAPIsServiceBlockingStub stub = InferenceAPIsServiceGrpc.newBlockingStub(channel);
//            String dataJson = "{\"bot_id\":\"721\",\"exp_id\":\"721\",\"session_id\":\"" + sessionId + "\",\"use_rag\":\"true\",\"prompt\":\"你是⼀个资深⽔务领域专家，能回答各种⽔务相关问题\",\"history_dia\":" + JSON.toJSONString(historyDates) + ",\"generate_args\":{\"max_new_tokens\":2048,\"max_length\":4096,\"num_beams\":1,\"do_sample\":true,\"top_p\":0.7,\"temperature\":0.95},\"extra\":{ \"ip_address\": \"" + ipAddr  + "\" },\"strengthen\":" + (true) + "}";
            //2024年6月27日13:29:18 优化，不再使用拼接JSON字符串
            String dataJson = buildBigModelReqForChat(sessionId, historyDates, ipAddr, false);
            log.info("请求大模型的问答参数为{}", dataJson);
            PredictionsRequest request = PredictionsRequest.newBuilder()
                    .setModelName("slibra_bot")
                    .putInput("method", ByteString.copyFrom("infer_stream", "utf-8"))//推理
                    .putInput("data", ByteString.copyFrom(dataJson, "utf-8"))
                    .buildPartial();
            Iterator<PredictionResponse> predictions = stub.streamPredictions(request);
            //将结果记录到问答表
            while (predictions.hasNext()) {
                String responseStr = predictions.next().getPrediction().toStringUtf8();
                log.info("大模型问答返回的原始结果为{}", responseStr);
                responseStr = JSON.parseObject(responseStr).getString("message");
                if("complete".equals(responseStr)){
                    log.info("结尾语句并且是非JSON，无需处理");
                }else{
                    sb.append(responseStr);
                }
            }
            //将问答更新到数据库中
            chatReq.setSessionId(sessionId);
            chatReq.setType(1);//0问答 1决策 2本地 3仿真预测
            chatReq.setModule(3);//0专家问答 1智能工单 2智能体助手 3告警 4简报
            String showVal = this.buildShowValue(xinyiWarningRecord, tXinyiIndustry, normConfig);
            chatReq.setShowVal(showVal);
            chatReq.setQuestion(shWarningPrompt);
            chatReq.setAnswer(sb.toString());
            chatReq.setWarningId(String.valueOf(xinyiWarningRecord.getId()));
            chatReq.setCounts(counts);//问答次数
            chatReq.setUserId(WARNING_DEFAULT_CREATE);
            chatReq.setCreateBy(WARNING_DEFAULT_CREATE);
            chatReq.setCreateTime(DateUtils.getNowDate());
            this.xinyiChatRecordMapper.insertTXinyiChatRecord(chatReq);
        } catch (IOException e) {
            throw new RuntimeException(e);
        } finally {
            // 关闭输出流
            channel.shutdown();
        }
    }


    private static String buildBigModelReqForChat(String sessionId, List<String> historyDates, String ipAddr, Boolean strengthen) {
        ChatRequest chatRequest = new ChatRequest();
        chatRequest.setSessionId(sessionId);
        chatRequest.setHistoryDia(historyDates);
        Map<String, Object> extra = new HashMap<>();
        extra.put("ip_address", ipAddr);
        chatRequest.setExtra(extra);
        chatRequest.setStrengthen(strengthen);
        //2024年7月3日16:21:28 明确该常见不用调工具
        chatRequest.setTools(String.valueOf(false));
        return JSON.toJSONString(chatRequest);
    }

    /**
     * 调用大模型获取决策结果 并同时记录对应信息到聊天记录表中
     *
     * @param tXinyiWarningRecord
     * @param tXinyiIndustry
     * @param normConfig
     * @param isSpecial  机器人化验库，需要把总磷和总氮的值特殊处理一下
     */
    private void handleDecision(TXinyiWarningRecord tXinyiWarningRecord, TXinyiIndustry tXinyiIndustry, TXinyiNormConfig normConfig, boolean isSpecial) {
        log.info("进入了调⽤大模型决策接口");
        ChatReq chatReq = new ChatReq();
//        StringBuilder sb = new StringBuilder();
        //大模型结果 放入一个结合中
        List<String> resultData = new ArrayList<>();
        //决策和问答不一样 没有历史的概念 所以sessionId都是新的  次数都是1
        String sessionId = IdUtils.simpleUUID();
//        String feedback = chatReq.getFeedback();
        //决策请求的业务参数
//        List<HashMap<String, Object>> list = this.xinyiIndustryMapper.selectLast10RecordsForDecision();
        //2024年5月21日15:23:07 这里不能用关联查询处理，日报要获取最新的一条而不是今日的数据。
        List<DecisionReq> decisionReqs = this.xinyiIndustryMapper.selectLast10RecordsForDecisionOnlyIndustry();
        if(!CollectionUtils.isEmpty(decisionReqs)){
            //处理日报数据
            TXinyiDaily daily = this.xinyiDailyMapper.selectNewestData();
            for (DecisionReq decisionReq : decisionReqs) {
                if(!Objects.isNull(daily)){
                    decisionReq.setT(daily.getJsSw());
                    decisionReq.setSVI(daily.getWntjzsAll());
                    decisionReq.setSV(daily.getWncjbAll());
                    decisionReq.setMlvss(daily.getHfxwnndAll());
                    //2024年7月2日17:20:12  mlss和DO_O也要从日报获取
                    decisionReq.setMlss(daily.getHycWnndAll());
                    decisionReq.setDoO(daily.getHycRjyAll());
                    decisionReq.setDoAna(daily.getYycRjyAll());
                    decisionReq.setDoQue(daily.getQycRjyAll());
                    //2024年5月26日11:59:02 干污泥量数据做了同步
                    decisionReq.setGwnl(daily.getGWNL());
                    BigDecimal jsBod5 = daily.getJsBod5();
                    decisionReq.setBodIn(jsBod5);
                    BigDecimal tpIn = decisionReq.getTpIn();
                    BigDecimal tnIn = decisionReq.getTnIn();
                    if(!Objects.isNull(jsBod5)){
                        if(!Objects.isNull(tpIn) && tpIn.compareTo(new BigDecimal("0")) >0){
                            decisionReq.setC(jsBod5.divide(tpIn, 4, RoundingMode.HALF_UP));
                        }
                        if(!Objects.isNull(tnIn) && tnIn.compareTo(new BigDecimal("0")) >0){
                            decisionReq.setB(jsBod5.divide(tnIn, 4, RoundingMode.HALF_UP));
                        }
                    }
                    //2024年6月1日08:37:09 内回流加上
                    decisionReq.setR(daily.getNhlR());
                    decisionReq.setRR(daily.getWhlR());
                }
                //如果是机器人化验室的报警，需要把总磷和总氮，获取化验室对应的数据且计算
                if(isSpecial){
                    List<TXinyiRobot> xinyiRobots = this.xinyiRobotMapper.selectTXinyiRobotList(TXinyiRobot.builder().testHour(tXinyiIndustry.getTestHour()).build());
                    if(CollectionUtils.isEmpty(xinyiRobots)){
                        log.error("{}获取化验室数据失败", tXinyiIndustry.getTestHour());
                    }else{
                        TXinyiRobot tXinyiRobot = xinyiRobots.get(0);
                        //总氮
                        BigDecimal no3Hlj1Jqr = tXinyiRobot.getNo3Hlj1Jqr();
                        BigDecimal no3Hlj2Jqr = tXinyiRobot.getNo3Hlj2Jqr();
                        if(!Objects.isNull(no3Hlj1Jqr) && !Objects.isNull(no3Hlj2Jqr)){
                            decisionReq.setTnOff((no3Hlj1Jqr.add(no3Hlj2Jqr)).divide((new BigDecimal("2").multiply(ROBOT_HY_DIVIDE)), NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        }

                        //总磷
                        BigDecimal tpRccJqr = tXinyiRobot.getTpRccJqr();
                        if(!Objects.isNull(tpRccJqr)){
                            decisionReq.setTpOff(tpRccJqr.divide(ROBOT_HY_DIVIDE, NUMBER_SCALE_4, RoundingMode.HALF_UP));
                        }
                    }
                }
            }
        }
//        String rows = JSON.toJSONString(decisionReqs, JSONWriter.Feature.WriteNulls);
        // 获取输出流
        ManagedChannel channel = null;
        String dataJson = "";
        try {
            channel = ManagedChannelBuilder.forAddress("10.0.0.24", 17070)
                    .usePlaintext()
                    .build();
            InferenceAPIsServiceGrpc.InferenceAPIsServiceBlockingStub stub = InferenceAPIsServiceGrpc.newBlockingStub(channel);
//            dataJson = "{\"bot_id\":\"b00001\",\"exp_id\":\"721\",\"norm\":\"" + tXinyiWarningRecord.getCategory() + "\",\"feedback\":" + feedback + ",\"session_id\":" + "\"" + sessionId + "\"" + ",\"generate_args\":{\"max_new_tokens\":1024,\"max_length\":4096,\"num_beams\":1,\"do_sample\":true,\"top_p\":0.7,\"temperature\":0.95},\"extra\":{\"rows\":" +  rows + "}}";
            //2024年6月24日17:59:17  优化，不再拼接JSON字符串
            PolicyReq policyReq = new PolicyReq();
            policyReq.setNorm(tXinyiWarningRecord.getCategory());
            HashMap<String, Object> hashMap = new HashMap<>();
            policyReq.setFeedback(hashMap);//不能传null
            policyReq.setSimulate(hashMap);//不能传null
            policyReq.setSessionId(sessionId);
            HashMap<String, Object> map = new HashMap<>();
            map.put("rows", decisionReqs);
            //2024年6月25日14:16:05 增加报警是管控值报警还是标准值报警
            if(WARNING_LEVEL_ONE.equals(tXinyiWarningRecord.getLevel()) || WARNING_LEVEL_TWO.equals(tXinyiWarningRecord.getLevel()))
                map.put("source", "bzz");
            else
                map.put("source", "gkz");
            policyReq.setExtra(map);
            dataJson = JSON.toJSONString(policyReq, JSONWriter.Feature.WriteNulls);
            log.info("请求大模型的决策的参数为{}", dataJson);
            PredictionsRequest request = PredictionsRequest.newBuilder()
                    .setModelName("slibra_bot")
                    .putInput("method", ByteString.copyFrom("decision_stream", "utf-8"))//推理
                    .putInput("data", ByteString.copyFrom(dataJson, "utf-8"))
                    .buildPartial();
            Iterator<PredictionResponse> predictions = stub.streamPredictions(request);
            while (predictions.hasNext()) {
                String responseStr = predictions.next().getPrediction().toStringUtf8();
                log.info("决策流式返回的结果是{}", responseStr);

                //2024年5月25日16:37:16  按照大模型返回的类型解析数据
                String biz = JSON.parseObject(responseStr).getString("biz");
                if(BusinessEnum.BigModelBizEnum.OK.getCode().equals(biz)){
                    log.info("结尾语句并且是非JSON，无需处理");
                    //结束语句也流式输出，但是并不记录下来  2024年5月24日11:15:23 也不返回前端
                    /*outputStream.write(responseStr.getBytes());
                    outputStream.flush();*/
                }else if(BusinessEnum.BigModelBizEnum.DECISION_DEBUGGER.getCode().equals(biz)){
                    log.info("中间过程，目前只打印日志，不记录数据，也不返回给前端，返回数据为{}", responseStr);
                    //结束语句也流式输出，但是并不记录下来  2024年5月24日11:15:23 也不返回前端
                    /*outputStream.write(responseStr.getBytes());
                    outputStream.flush();*/
                }else{//其他 要么错误 要么alert 要么出的报告
//                    sb.append(responseStr);
                    resultData.add(responseStr);
                }
            }
        } catch (Exception e) {
//            throw new RuntimeException(e);
            log.error("定时任务处理告警调用决策异常，异常信息为{}", JSON.toJSONString(e));
            resultData.add("{\"biz\":\"ERROR\",\"message\":\"大模型分析数据异常，请稍后再试\"}");
        } finally {
            log.info("决策最终要保存的数据是{}", JSON.toJSONString(resultData));
            //保存聊天记录
            //将问答更新到数据库中
            chatReq.setSessionId(sessionId);
            chatReq.setType(1);//0问答 1决策
            chatReq.setModule(3);
            /*String userId = SecurityUtils.getUserId().toString();
            String username = SecurityUtils.getUsername();*/
            chatReq.setUserId(WARNING_DEFAULT_CREATE);
            String showVal = this.buildShowValue(tXinyiWarningRecord, tXinyiIndustry, normConfig);
            chatReq.setShowVal(showVal);//前端展示的数据和提问的数据不一致
            chatReq.setQuestion(dataJson);
            chatReq.setAnswer(JSON.toJSONString(resultData));
            chatReq.setWarningId(String.valueOf(tXinyiWarningRecord.getId()));
            chatReq.setCounts(1);//问答次数

            chatReq.setCreateBy(WARNING_DEFAULT_CREATE);
            chatReq.setCreateTime(DateUtils.getNowDate());
            this.xinyiChatRecordMapper.insertTXinyiChatRecord(chatReq);
            // 关闭输出流
            if(!Objects.isNull(channel))
                channel.shutdown();
        }
    }

    private String buildShowValue(TXinyiWarningRecord tXinyiWarningRecord, TXinyiIndustry tXinyiIndustry, TXinyiNormConfig normConfig) {
        JSONObject result = new JSONObject();
//        JSONObject basic = new JSONObject();
        Integer status = tXinyiWarningRecord.getStatus();
        Date warningTime = tXinyiWarningRecord.getTime();
        String remark = tXinyiWarningRecord.getRemark();
        int count = DateUtils.differentHoursByMillisecond(warningTime, DateUtils.getNowDate()) + 1;
        /*basic.put("title", tXinyiWarningRecord.getReason());
        basic.put("报警时间", DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD_HH_MM ,warningTime));
        basic.put("报警值", tXinyiWarningRecord.getWarningVal());
        basic.put("标准值", tXinyiWarningRecord.getDesignVal());
        basic.put("管控值", tXinyiWarningRecord.getControlVal());
        basic.put("报警次数", Math.min(count, MAX_COUNT));
        if(tXinyiWarningRecord.getType() != 2)
            basic.put("状态", status == 0 ? "报警中" : status == 1 ? "用户关闭" : status == 2 ? "系统关闭" : "应急处理中");
        else
            basic.put("状态", status == 0 ? "预警中" : "已完成");
        //2024年5月27日14:04:22  额外返回2个字段 [管控值 和 告警级别]  返回的json没有数据是因为value没有值
//        basic.put("管控值", tXinyiWarningRecord.getControlVal());
        basic.put("告警级别", tXinyiWarningRecord.getLevel());*/
        //2024年6月25日16:00:18 进出水展示的不一样
        if(tXinyiWarningRecord.getCategory().contains("出水")){//出水的展示
            ShowValueCSBasic showValueCSBasic = new ShowValueCSBasic();
            if("0".equals(remark)){//水质报警
                showValueCSBasic.setH("在线仪表");
                showValueCSBasic.setF(tXinyiWarningRecord.getLevel());
            }else if("1".equals(remark)){//生化报警
                showValueCSBasic.setH("在线仪表");
            }else if("2".equals(remark)){//预测报警
                showValueCSBasic.setH("预测");
//                showValueCSBasic.setF(tXinyiWarningRecord.getLevel());
            }else {//机器人化验室报警（特殊的水质报警）
                showValueCSBasic.setH("化验室");
                showValueCSBasic.setF(tXinyiWarningRecord.getLevel());
            }
            //通用的
            //        showValueBasic.setA(tXinyiWarningRecord.getReason());
            showValueCSBasic.setB(DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD_HH_MM ,warningTime));
            showValueCSBasic.setC(tXinyiWarningRecord.getWarningVal());
            showValueCSBasic.setD(tXinyiWarningRecord.getControlVal());
            showValueCSBasic.setE(tXinyiWarningRecord.getDesignVal());
            showValueCSBasic.setG(Math.min(count, MAX_COUNT));
            if(tXinyiWarningRecord.getType() != 2)
                showValueCSBasic.setI(status == 0 ? "报警中" : status == 1 ? "用户关闭" : status == 2 ? "系统关闭" : "应急处理中");
            else
                showValueCSBasic.setI(status == 0 ? "预警中" : "已完成");
            result.put("basic", showValueCSBasic);
        }else{//进水的展示
            ShowValueJSBasic showValueJSBasic = new ShowValueJSBasic();
            if("0".equals(remark)){//水质报警
                showValueJSBasic.setH("在线仪表");
                showValueJSBasic.setF(tXinyiWarningRecord.getLevel());
            }else if("1".equals(remark)){//生化报警
                showValueJSBasic.setH("在线仪表");
            }else if("2".equals(remark)){//预测报警
                showValueJSBasic.setH("预测");
//                showValueCSBasic.setF(tXinyiWarningRecord.getLevel());
            }else {//机器人化验室报警（特殊的 水质报警）
                showValueJSBasic.setH("化验室");
                showValueJSBasic.setF(tXinyiWarningRecord.getLevel());
            }
            //通用的
            //        showValueBasic.setA(tXinyiWarningRecord.getReason());
            showValueJSBasic.setB(DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD_HH_MM ,warningTime));
            showValueJSBasic.setC(tXinyiWarningRecord.getWarningVal());
            showValueJSBasic.setE(tXinyiWarningRecord.getDesignVal());
            showValueJSBasic.setG(Math.min(count, MAX_COUNT));
            if(tXinyiWarningRecord.getType() != 2)
                showValueJSBasic.setI(status == 0 ? "报警中" : status == 1 ? "用户关闭" : status == 2 ? "系统关闭" : "应急处理中");
            else
                showValueJSBasic.setI(status == 0 ? "预警中" : "已完成");
            result.put("basic", showValueJSBasic);
        }
        JSONObject jsData = getJsonObject(tXinyiIndustry, normConfig);//进水数据
        result.put("jsData", jsData);
        JSONObject csData = getCsonObject(tXinyiIndustry, normConfig);//出水数据
        result.put("csData", csData);
//        return JSON.toJSONString(result, JSONWriter.Feature.WriteNulls);
        return JSON.toJSONString(result);
    }

    private static JSONObject getJsonObject(TXinyiIndustry tXinyiIndustry, TXinyiNormConfig normConfig) {
        JSONObject jsData = new JSONObject();
        HashMap<Object, Object> temp1 = new HashMap<>();
        BigDecimal jsSlq = tXinyiIndustry.getJsSlq();
        temp1.put("value", jsSlq);
        temp1.put("exceed", jsSlq.compareTo(normConfig.getJsslSjz()) >0);
        jsData.put("流量", temp1);
        HashMap<Object, Object> temp2 = new HashMap<>();
        BigDecimal jsCod = tXinyiIndustry.getJsCod();
        temp2.put("value", jsCod);
        temp2.put("exceed", jsCod.compareTo(normConfig.getJscodSjz()) > 0);
        jsData.put("COD", temp2);
        HashMap<Object, Object> temp3 = new HashMap<>();
        BigDecimal jsNh3 = tXinyiIndustry.getJsNh3();
        temp3.put("value", jsNh3);
        temp3.put("exceed", jsNh3.compareTo(normConfig.getJsadSjz()) > 0);
        jsData.put("NH3-N", temp3);
        HashMap<Object, Object> temp4 = new HashMap<>();
        BigDecimal jsTp = tXinyiIndustry.getJsTp();
        temp4.put("value", jsTp);
        temp4.put("exceed", jsTp.compareTo(normConfig.getJszlSjz()) > 0);
        jsData.put("TP", temp4);
        HashMap<Object, Object> temp5 = new HashMap<>();
        BigDecimal jsSs = tXinyiIndustry.getJsSs();
        temp5.put("value", jsSs);
        temp5.put("exceed", jsSs.compareTo(normConfig.getJsssSjz()) > 0);
        jsData.put("SS", temp5);
        HashMap<Object, Object> temp6 = new HashMap<>();
        BigDecimal jsTn = tXinyiIndustry.getJsTn();
        temp6.put("value", jsTn);
        temp6.put("exceed", jsTn.compareTo(normConfig.getJszdSjz()) > 0);
        jsData.put("TN", temp6);
        return jsData;
    }


    private static JSONObject getCsonObject(TXinyiIndustry tXinyiIndustry, TXinyiNormConfig normConfig) {
        JSONObject csData = new JSONObject();
        HashMap<Object, Object> temp1 = new HashMap<>();
        BigDecimal csSlq = tXinyiIndustry.getCsSlqc();
        temp1.put("value", csSlq);
        temp1.put("exceed", false);//出水水量没有管控值
        csData.put("流量", temp1);
        HashMap<Object, Object> temp2 = new HashMap<>();
        BigDecimal csCod = tXinyiIndustry.getCsCod();
        temp2.put("value", csCod);
        temp2.put("exceed", csCod.compareTo(normConfig.getCscodGkz()) > 0);
        csData.put("COD", temp2);
        HashMap<Object, Object> temp3 = new HashMap<>();
        BigDecimal csNh3 = tXinyiIndustry.getCsNh3();
        temp3.put("value", csNh3);
        temp3.put("exceed", csNh3.compareTo(normConfig.getCsadGkz()) > 0);
        csData.put("NH3-N", temp3);
        HashMap<Object, Object> temp4 = new HashMap<>();
        BigDecimal csTp = tXinyiIndustry.getCsTp();
        temp4.put("value", csTp);
        temp4.put("exceed", csTp.compareTo(normConfig.getCszlGkz()) > 0);
        csData.put("TP", temp4);
        HashMap<Object, Object> temp5 = new HashMap<>();
        BigDecimal csSs = tXinyiIndustry.getCsSs();
        temp5.put("value", csSs);
        temp5.put("exceed", csSs.compareTo(normConfig.getCsssGkz()) > 0);
        csData.put("SS", temp5);
        HashMap<Object, Object> temp6 = new HashMap<>();
        BigDecimal csTn = tXinyiIndustry.getCsTn();
        temp6.put("value", csTn);
        temp6.put("exceed", csTn.compareTo(normConfig.getCszzGkz()) > 0);
        csData.put("TN", temp6);
        return csData;
    }

    /**
     * 通过输入的值 生成对应类型的报警对象（出水）
     *
     * @param csBzz
     * @param currentVal
     * @param csGkz
     * @param category
     * @param tXinyiIndustry
     * @param normConfig
     * @return
     */
    private void handleXinYiWarningsCs(BigDecimal csBzz, BigDecimal currentVal, BigDecimal csGkz, String category, TXinyiIndustry tXinyiIndustry, TXinyiNormConfig normConfig) {
        BigDecimal multiply = csBzz.multiply(new BigDecimal(MyConstants.SCALE_VALUE));
        TXinyiWarningRecord tXinyiWarningRecord = new TXinyiWarningRecord();
        /*String category = BusinessEnum.WarningCategoryEnum.CS_AD.getCode();*/
        tXinyiWarningRecord.setStatus(0);
        tXinyiWarningRecord.setType(0);
        tXinyiWarningRecord.setCategory(category);
        tXinyiWarningRecord.setTime(DateUtils.getNowDate());
        tXinyiWarningRecord.setWarningVal(currentVal);
        tXinyiWarningRecord.setDesignVal(csBzz);
        tXinyiWarningRecord.setControlVal(csGkz);
        tXinyiWarningRecord.setCreateBy(WARNING_DEFAULT_CREATE);
        tXinyiWarningRecord.setCreateTime(DateUtils.getNowDate());
        tXinyiWarningRecord.setRemark("0");

        //2024年5月25日17:52:33  如果工业库获取不到数据，也触发报警，但是不调用决策接口
        if(Objects.isNull(currentVal) || currentVal.compareTo(BigDecimal.ZERO) == 0){
            tXinyiWarningRecord.setReason(category + EXCEPTION_WARNING);
            tXinyiWarningRecord.setLevel(WARNING_LEVEL_NO_DATE);
        }else if(currentVal.compareTo(multiply) > 0){//一级
            tXinyiWarningRecord.setReason(category + CHAOBIAO_WARNING);
            tXinyiWarningRecord.setLevel(WARNING_LEVEL_ONE);
        }else if(currentVal.compareTo(csBzz) >= 0 && currentVal.compareTo(multiply) <= 0){//二级
            tXinyiWarningRecord.setReason(category + CHAOBIAO_WARNING);
            tXinyiWarningRecord.setLevel(WARNING_LEVEL_TWO);
        }else if(!Objects.isNull(csGkz) && currentVal.compareTo(csGkz) > 0){
            tXinyiWarningRecord.setReason(category + CHAOGUANKONG_WARNING);
            tXinyiWarningRecord.setLevel(WARNING_LEVEL_THREE);
        }else{
            tXinyiWarningRecord = null;//这种的无需处理
        }
        //当前状态正常 需要查询历史有无正在报警的数据，如果有，将报警状态改完2(系统自动关闭)
        List<TXinyiWarningRecord> tXinyiWarningRecords = this.xinyiWarningRecordMapper.selectTXinyiWarningRecordList(TXinyiWarningRecord.builder().delFlag(0).type(0).category(category).warningStatus(0).build());
        if(Objects.isNull(tXinyiWarningRecord)){//数据正常，无告警信息
            if(!CollectionUtils.isEmpty(tXinyiWarningRecords)){
                log.info( "{}:现在恢复正常，历史报警数据为{}", category,JSON.toJSONString(tXinyiWarningRecords));
                for (TXinyiWarningRecord xinyiWarningRecord : tXinyiWarningRecords) {
                    xinyiWarningRecord.setStatus(2);
                    Date nowDate = DateUtils.getNowDate();
                    xinyiWarningRecord.setOffTime(nowDate);
                    xinyiWarningRecord.setUpdateTime(nowDate);
                    xinyiWarningRecord.setUpdateBy(WARNING_DEFAULT_CREATE);
                    this.xinyiWarningRecordMapper.updateTXinyiWarningRecord(xinyiWarningRecord);
                }
            }
        }else{//有告警信息
            if(CollectionUtils.isEmpty(tXinyiWarningRecords)){//之前没有告警记录
                //保存到数据库中
                this.xinyiWarningRecordMapper.insertTXinyiWarningRecord(tXinyiWarningRecord);
                if(WARNING_LEVEL_NO_DATE.equals(tXinyiWarningRecord.getLevel())){
                    //只保存一个普通的问答记录 不需要调用决策信息，但是实时数据还是要记录的
                    this.addChatRecordByWarning(tXinyiWarningRecord, tXinyiIndustry, normConfig);
                }else {
                    //继续调用决策
                    this.handleDecision(tXinyiWarningRecord, tXinyiIndustry, normConfig, false);
                }
            }else{
                log.info("{}:之前已经有过告警记录了，且还是继续报警，无需重复添加报警，但是决策仍然要调用", category);
                for (TXinyiWarningRecord xinyiWarningRecord : tXinyiWarningRecords) {//理论上只有一个的
                    if(WARNING_LEVEL_NO_DATE.equals(tXinyiWarningRecord.getLevel())){
                        //只保存一个普通的问答记录 不需要调用决策信息，但是实时数据还是要记录的
                        this.addChatRecordByWarning(tXinyiWarningRecord, tXinyiIndustry, normConfig);
                    }else {
                        //继续调用决策
                        this.handleDecision(xinyiWarningRecord, tXinyiIndustry, normConfig, false);
                    }
                }
            }
        }

    }


    /**
     * 通过输入的值 生成对应类型的报警对象（进水）
     *
     * @param jsBzz
     * @param currentVal
     * @param category
     * @param tXinyiIndustry
     * @param normConfig
     * @return
     */
    private void handleXinYiWarningRecordJS(BigDecimal jsBzz, BigDecimal currentVal, String category, TXinyiIndustry tXinyiIndustry, TXinyiNormConfig normConfig) {
        BigDecimal multiply = jsBzz.multiply(new BigDecimal(MyConstants.SCALE_VALUE));
        TXinyiWarningRecord tXinyiWarningRecord = new TXinyiWarningRecord();
        /*String category = BusinessEnum.WarningCategoryEnum.CS_AD.getCode();*/
        tXinyiWarningRecord.setStatus(0);
        tXinyiWarningRecord.setType(0);
        tXinyiWarningRecord.setCategory(category);
        tXinyiWarningRecord.setTime(DateUtils.getNowDate());
        tXinyiWarningRecord.setWarningVal(currentVal);
        tXinyiWarningRecord.setDesignVal(jsBzz);
//        tXinyiWarningRecord.setControlVal(csGkz);
        tXinyiWarningRecord.setCreateBy(WARNING_DEFAULT_CREATE);
        tXinyiWarningRecord.setCreateTime(DateUtils.getNowDate());
        tXinyiWarningRecord.setRemark("0");

        //2024年5月25日17:52:33  如果工业库获取不到数据，也触发报警，但是不调用决策接口
        if(Objects.isNull(currentVal) || currentVal.compareTo(BigDecimal.ZERO) == 0){
            tXinyiWarningRecord.setReason(category + EXCEPTION_WARNING);
            tXinyiWarningRecord.setLevel(WARNING_LEVEL_NO_DATE);
        }else if(currentVal.compareTo(multiply) > 0){//一级
            tXinyiWarningRecord.setReason(category + CHAOBIAO_WARNING);
            tXinyiWarningRecord.setLevel(WARNING_LEVEL_ONE);
        }else if(currentVal.compareTo(jsBzz) >= 0 && currentVal.compareTo(multiply) <= 0){//二级
            tXinyiWarningRecord.setReason(category + CHAOBIAO_WARNING);
            tXinyiWarningRecord.setLevel(WARNING_LEVEL_TWO);
        }else{
            tXinyiWarningRecord = null;//这种的无需处理
        }
        /*else if(!Objects.isNull(csGkz) && currentVal.compareTo(csGkz) > 0){
            tXinyiWarningRecord.setReason(category + CHAOGUANKONG_WARNING);
            tXinyiWarningRecord.setLevel(WARNING_LEVEL_THREE);
        }*/
        //当前状态正常 需要查询历史有无正在报警的数据，如果有，将报警状态改完2(系统自动关闭)
        List<TXinyiWarningRecord> tXinyiWarningRecords = this.xinyiWarningRecordMapper.selectTXinyiWarningRecordList(TXinyiWarningRecord.builder().delFlag(0).type(0).category(category).status(0).build());
        if(Objects.isNull(tXinyiWarningRecord)){//数据正常，无告警信息
            if(!CollectionUtils.isEmpty(tXinyiWarningRecords)){
                log.info( "{}:现在恢复正常，历史报警数据为{}", category,JSON.toJSONString(tXinyiWarningRecords));
                for (TXinyiWarningRecord xinyiWarningRecord : tXinyiWarningRecords) {
                    xinyiWarningRecord.setStatus(2);
                    Date nowDate = DateUtils.getNowDate();
                    xinyiWarningRecord.setOffTime(nowDate);
                    xinyiWarningRecord.setUpdateTime(nowDate);
                    xinyiWarningRecord.setUpdateBy(WARNING_DEFAULT_CREATE);
                    this.xinyiWarningRecordMapper.updateTXinyiWarningRecord(xinyiWarningRecord);
                }
            }
        }else{//有告警信息
            if(CollectionUtils.isEmpty(tXinyiWarningRecords)){//之前没有告警记录
                //保存到数据库中
                this.xinyiWarningRecordMapper.insertTXinyiWarningRecord(tXinyiWarningRecord);
                if(WARNING_LEVEL_NO_DATE.equals(tXinyiWarningRecord.getLevel())){
                    //只保存一个普通的问答记录 不需要调用决策信息，但是实时数据还是要记录的
                    this.addChatRecordByWarning(tXinyiWarningRecord, tXinyiIndustry, normConfig);
                }else {
                    //继续调用决策
                    this.handleDecision(tXinyiWarningRecord, tXinyiIndustry, normConfig, false);
                }
            }else{
                log.info("{}:之前已经有过告警记录了，且还是继续报警，无需重复添加报警，但是决策仍然要调用", category);
                for (TXinyiWarningRecord xinyiWarningRecord : tXinyiWarningRecords) {//理论上只有一个的
                    if(WARNING_LEVEL_NO_DATE.equals(tXinyiWarningRecord.getLevel())){
                        //只保存一个普通的问答记录 不需要调用决策信息，但是实时数据还是要记录的
                        this.addChatRecordByWarning(tXinyiWarningRecord, tXinyiIndustry, normConfig);
                    }else {
                        //继续调用决策
                        this.handleDecision(xinyiWarningRecord, tXinyiIndustry, normConfig, false);
                    }
                }
            }
        }
    }

    private void addChatRecordByWarning(TXinyiWarningRecord tXinyiWarningRecord, TXinyiIndustry tXinyiIndustry, TXinyiNormConfig normConfig) {
        ChatReq chatReq = new ChatReq();
        //保存聊天记录
        //将问答更新到数据库中
        chatReq.setSessionId(IdUtils.simpleUUID());
        chatReq.setType(1);//0问答 1决策 2本地 3仿真预测
        chatReq.setModule(3);
            /*String userId = SecurityUtils.getUserId().toString();
            String username = SecurityUtils.getUsername();*/
        chatReq.setUserId(WARNING_DEFAULT_CREATE);
        String showVal = this.buildShowValue(tXinyiWarningRecord, tXinyiIndustry, normConfig);
        chatReq.setShowVal(showVal);//前端展示的数据和提问的数据不一致
        chatReq.setQuestion(WARNING_DEFAULT_QUESTION);//本地问题
        chatReq.setAnswer(tXinyiWarningRecord.getReason() + "，请检查设备是否正常运行");
        chatReq.setWarningId(String.valueOf(tXinyiWarningRecord.getId()));
        chatReq.setCounts(1);//问答次数

        chatReq.setCreateBy(WARNING_DEFAULT_CREATE);
        chatReq.setCreateTime(DateUtils.getNowDate());
        this.xinyiChatRecordMapper.insertTXinyiChatRecord(chatReq);
    }


    public static void main(String[] args) {
        System.out.println(CCCDCHRT_LAST);
        System.out.println(GSLS_LAST);
        System.out.println(BigDecimal.valueOf(1).subtract(null));
    }

    /**
     * 处理机器人化验数据报警
     * @param uniqueList
     */
    public void handleRobotWarning(List<TXinyiRobot> uniqueList) {
        log.info("进入了定时任务判断机器人化验库是否超标及后续逻辑");
        //查询配置
        List<TXinyiNormConfig> tXinyiNormConfigs = this.xinyiNormConfigMapper.selectTXinyiNormConfigList(null);
        if(CollectionUtils.isEmpty(tXinyiNormConfigs))
            throw new RuntimeException("未查询到配置信息");
        TXinyiNormConfig normConfig = tXinyiNormConfigs.get(0);

        //查询最新的一条工业库的数据（showvalue展示使用）
        List<TXinyiIndustry> tXinyiIndustries = this.xinyiIndustryMapper.selectNIndustry(1);
        TXinyiIndustry tXinyiIndustry = CollectionUtils.isEmpty(tXinyiIndustries) ? new TXinyiIndustry() : tXinyiIndustries.get(0);

        //处理数据
        for (TXinyiRobot tXinyiRobot : uniqueList) {
            //处理总氮和总磷报警
            //总氮
            BigDecimal no3Hlj1Jqr = tXinyiRobot.getNo3Hlj1Jqr();
            BigDecimal no3Hlj2Jqr = tXinyiRobot.getNo3Hlj2Jqr();
            if(!Objects.isNull(no3Hlj1Jqr) && !Objects.isNull(no3Hlj2Jqr)){
                BigDecimal csTn = (no3Hlj1Jqr.add(no3Hlj2Jqr)).divide((new BigDecimal("2").multiply(ROBOT_HY_DIVIDE)), NUMBER_SCALE_4, RoundingMode.HALF_UP);
                BigDecimal cszzBzz = normConfig.getCszzBzz();
                BigDecimal cszzGkz = normConfig.getCszzGkz();
                if(!Objects.isNull(cszzBzz)){
                    handleXinYiWarningsRobot(cszzBzz, csTn, cszzGkz, BusinessEnum.WarningCategoryEnum.CS_ZD.getCode(), tXinyiIndustry, normConfig);
                }
            }

            //总磷
            BigDecimal tpRccJqr = tXinyiRobot.getTpRccJqr();
            if(!Objects.isNull(tpRccJqr)){
                BigDecimal csTp = tpRccJqr.divide(ROBOT_HY_DIVIDE, NUMBER_SCALE_4, RoundingMode.HALF_UP);
                BigDecimal cszlBzz = normConfig.getCszlBzz();
                BigDecimal cszlGkz = normConfig.getCszlGkz();
                if(!Objects.isNull(cszlBzz)){
                    handleXinYiWarningsRobot(cszlBzz, csTp, cszlGkz, BusinessEnum.WarningCategoryEnum.CS_ZL.getCode(), tXinyiIndustry, normConfig);
                }
            }

        }
    }




    /**
     * 通过输入的值 生成对应类型的报警对象（出水）
     *
     * @param csBzz
     * @param currentVal
     * @param csGkz
     * @param category
     * @param tXinyiIndustry
     * @param normConfig
     * @return
     */
    private void handleXinYiWarningsRobot(BigDecimal csBzz, BigDecimal currentVal, BigDecimal csGkz, String category, TXinyiIndustry tXinyiIndustry, TXinyiNormConfig normConfig) {
        BigDecimal multiply = csBzz.multiply(new BigDecimal(MyConstants.SCALE_VALUE));
        TXinyiWarningRecord tXinyiWarningRecord = new TXinyiWarningRecord();
        tXinyiWarningRecord.setStatus(0);
        tXinyiWarningRecord.setType(0);
        tXinyiWarningRecord.setCategory(category);
        tXinyiWarningRecord.setTime(DateUtils.getNowDate());
        tXinyiWarningRecord.setWarningVal(currentVal);
        tXinyiWarningRecord.setDesignVal(csBzz);
        tXinyiWarningRecord.setControlVal(csGkz);
        tXinyiWarningRecord.setCreateBy(WARNING_DEFAULT_CREATE);
        tXinyiWarningRecord.setCreateTime(DateUtils.getNowDate());
        tXinyiWarningRecord.setRemark("3");//化验室

        //2024年5月25日17:52:33  如果工业库获取不到数据，也触发报警，但是不调用决策接口
        if(Objects.isNull(currentVal)){
            tXinyiWarningRecord.setReason(category + EXCEPTION_WARNING);
            tXinyiWarningRecord.setLevel(WARNING_LEVEL_NO_DATE);
        }else if(currentVal.compareTo(multiply) > 0){//一级
            tXinyiWarningRecord.setReason(category + CHAOBIAO_WARNING);
            tXinyiWarningRecord.setLevel(WARNING_LEVEL_ONE);
        }else if(currentVal.compareTo(csBzz) >= 0 && currentVal.compareTo(multiply) <= 0){//二级
            tXinyiWarningRecord.setReason(category + CHAOBIAO_WARNING);
            tXinyiWarningRecord.setLevel(WARNING_LEVEL_TWO);
        }else if(!Objects.isNull(csGkz) && currentVal.compareTo(csGkz) > 0){
            tXinyiWarningRecord.setReason(category + CHAOGUANKONG_WARNING);
            tXinyiWarningRecord.setLevel(WARNING_LEVEL_THREE);
        }else{
            tXinyiWarningRecord = null;//这种的无需处理
        }
        //当前状态正常 需要查询历史有无正在报警的数据，如果有，将报警状态改完2(系统自动关闭)
        List<TXinyiWarningRecord> tXinyiWarningRecords = this.xinyiWarningRecordMapper.selectTXinyiWarningRecordList(TXinyiWarningRecord.builder().delFlag(0).type(0).category(category).warningStatus(0).build());
        if(Objects.isNull(tXinyiWarningRecord)){//数据正常，无告警信息
            if(!CollectionUtils.isEmpty(tXinyiWarningRecords)){
                log.info( "{}:现在恢复正常，历史报警数据为{}", category,JSON.toJSONString(tXinyiWarningRecords));
                for (TXinyiWarningRecord xinyiWarningRecord : tXinyiWarningRecords) {
                    xinyiWarningRecord.setStatus(2);
                    Date nowDate = DateUtils.getNowDate();
                    xinyiWarningRecord.setOffTime(nowDate);
                    xinyiWarningRecord.setUpdateTime(nowDate);
                    xinyiWarningRecord.setUpdateBy(WARNING_DEFAULT_CREATE);
                    this.xinyiWarningRecordMapper.updateTXinyiWarningRecord(xinyiWarningRecord);
                }
            }
        }else{//有告警信息
            if(CollectionUtils.isEmpty(tXinyiWarningRecords)){//之前没有告警记录
                //保存到数据库中
                this.xinyiWarningRecordMapper.insertTXinyiWarningRecord(tXinyiWarningRecord);
                if(WARNING_LEVEL_NO_DATE.equals(tXinyiWarningRecord.getLevel())){
                    //只保存一个普通的问答记录 不需要调用决策信息，但是实时数据还是要记录的
                    this.addChatRecordByWarning(tXinyiWarningRecord, tXinyiIndustry, normConfig);
                }else {
                    //继续调用决策
                    this.handleDecision(tXinyiWarningRecord, tXinyiIndustry, normConfig, true);
                }
            }else{
                log.info("{}:之前已经有过告警记录了，且还是继续报警，无需重复添加报警，但是决策仍然要调用", category);
                for (TXinyiWarningRecord xinyiWarningRecord : tXinyiWarningRecords) {//理论上只有一个的
                    if(WARNING_LEVEL_NO_DATE.equals(tXinyiWarningRecord.getLevel())){
                        //只保存一个普通的问答记录 不需要调用决策信息，但是实时数据还是要记录的
                        this.addChatRecordByWarning(tXinyiWarningRecord, tXinyiIndustry, normConfig);
                    }else {
                        //继续调用决策
                        this.handleDecision(xinyiWarningRecord, tXinyiIndustry, normConfig, true);
                    }
                }
            }
        }

    }
}