package com.huimv.admin.timer;


import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.huimv.admin.common.utils.NumberUtils;
import com.huimv.admin.entity.ProtData;
import com.huimv.admin.entity.ProtThreshold;
import com.huimv.admin.entity.ProtWarningInfo;
import com.huimv.admin.mapper.ProtDataMapper;
import com.huimv.admin.mapper.ProtThresholdMapper;
import com.huimv.admin.mapper.ProtWarningInfoMapper;
import com.huimv.admin.service.IProtDataService;
import com.huimv.admin.service.IProtThresholdService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;

import java.text.NumberFormat;
import java.util.Date;

@Configuration
@EnableScheduling
public class ProtTimer {

    @Autowired
    private ProtThresholdMapper protThresholdMapper;
    @Autowired
    private ProtDataMapper protDataMapper;
    @Autowired
    private ProtWarningInfoMapper warningInfoMapper;

    //    环保数据
    @Scheduled(cron = "0 0 */1 * * ? ")
    private void getShenChan() throws Exception {



        for (int i = 1; i < 4; i++) {

            //假设已经拿到了数据
            String num = NumberUtils.getNumFloat(5.0,6.1);//ph
            String num1 = NumberUtils.getNum(350, 381, 1);//cod
            String num2 = NumberUtils.getNum(55, 61, 1);//nh3n
            String num3 = NumberUtils.getNumFloat(5.0, 6.51);//tp
            String num4 = NumberUtils.getNum(7800, 8001, 1);//tn
            String num5 = NumberUtils.getNum(290, 301, 1);//flow


            ProtData protData = new ProtData();
            protData.setLoctionType(i);
            protData.setCreateDate(new Date());
            protData.setFarmId(21);
            protData.setCod(num1);
            protData.setPh(num);
            protData.setNh3n(num2);
            protData.setTp(num3);
            protData.setTn(num4);
            protData.setFlow(num5);
            protDataMapper.insert(protData);

            QueryWrapper<ProtThreshold> queryWrapper = new QueryWrapper<>();
            if (i == 1) {
                queryWrapper.eq("farm_id", 21).eq("prot_type", 1);
                ProtThreshold protThreshold = protThresholdMapper.selectOne(queryWrapper);//进污口
                if (Double.parseDouble(num) > Double.parseDouble(protThreshold.getPh2())) {
                    ProtWarningInfo protWarningInfo = new ProtWarningInfo();
                    protWarningInfo.setWarningContent("进污口ph值为" + num + "达到红色预警");
                    protWarningInfo.setWarningType(1);
                    protWarningInfo.setFarmId(protThreshold.getFarmId());
                    protWarningInfo.setDate(new Date());
                    protWarningInfo.setUserIds(protThreshold.getUserIds());
                    protWarningInfo.setDeviceId(i);
                    protWarningInfo.setBuildLocation("进污口");
                    warningInfoMapper.insert(protWarningInfo);
                }
                if (Double.parseDouble(num) > Double.parseDouble(protThreshold.getPh1())) {
                    ProtWarningInfo protWarningInfo = new ProtWarningInfo();
                    protWarningInfo.setWarningContent("进污口ph值为" + num + "达到橙色预警");
                    protWarningInfo.setWarningType(1);
                    protWarningInfo.setFarmId(protThreshold.getFarmId());
                    protWarningInfo.setDate(new Date());
                    protWarningInfo.setUserIds(protThreshold.getUserIds());
                    protWarningInfo.setDeviceId(i);
                    protWarningInfo.setBuildLocation("进污口");
                    warningInfoMapper.insert(protWarningInfo);
                }
                if (Double.parseDouble(num1) > Double.parseDouble(protThreshold.getCod2())) {
                    ProtWarningInfo protWarningInfo = new ProtWarningInfo();
                    protWarningInfo.setWarningContent("进污口cod值为" + num1 + "达到红色预警");
                    protWarningInfo.setWarningType(0);
                    protWarningInfo.setFarmId(protThreshold.getFarmId());
                    protWarningInfo.setDate(new Date());
                    protWarningInfo.setUserIds(protThreshold.getUserIds());
                    protWarningInfo.setDeviceId(i);
                    protWarningInfo.setBuildLocation("进污口");
                    warningInfoMapper.insert(protWarningInfo);
                }
                if (Double.parseDouble(num1) > Double.parseDouble(protThreshold.getCod1())) {
                    ProtWarningInfo protWarningInfo = new ProtWarningInfo();
                    protWarningInfo.setWarningContent("进污口cod值为" + num1 + "达到橙色预警");
                    protWarningInfo.setWarningType(0);
                    protWarningInfo.setFarmId(protThreshold.getFarmId());
                    protWarningInfo.setDate(new Date());
                    protWarningInfo.setUserIds(protThreshold.getUserIds());
                    protWarningInfo.setDeviceId(i);
                    protWarningInfo.setBuildLocation("进污口");
                    warningInfoMapper.insert(protWarningInfo);
                }
                if (Double.parseDouble(num2) > Double.parseDouble(protThreshold.getNh3n2())) {
                    ProtWarningInfo protWarningInfo = new ProtWarningInfo();
                    protWarningInfo.setWarningContent("进污口NH3N值为" + num2 + "达到红色预警");
                    protWarningInfo.setWarningType(2);
                    protWarningInfo.setFarmId(protThreshold.getFarmId());
                    protWarningInfo.setDate(new Date());
                    protWarningInfo.setUserIds(protThreshold.getUserIds());
                    protWarningInfo.setDeviceId(i);
                    protWarningInfo.setBuildLocation("进污口");
                    warningInfoMapper.insert(protWarningInfo);
                }
                if (Double.parseDouble(num2) > Double.parseDouble(protThreshold.getNh3n1())) {
                    ProtWarningInfo protWarningInfo = new ProtWarningInfo();
                    protWarningInfo.setWarningContent("进污口NH3N值为" + num2 + "达到橙色预警");
                    protWarningInfo.setWarningType(2);
                    protWarningInfo.setFarmId(protThreshold.getFarmId());
                    protWarningInfo.setDate(new Date());
                    protWarningInfo.setUserIds(protThreshold.getUserIds());
                    protWarningInfo.setDeviceId(i);
                    protWarningInfo.setBuildLocation("进污口");
                    warningInfoMapper.insert(protWarningInfo);
                }
                if (Double.parseDouble(num3) > Double.parseDouble(protThreshold.getTp2())) {
                    ProtWarningInfo protWarningInfo = new ProtWarningInfo();
                    protWarningInfo.setWarningContent("进污口TP值为" + num3 + "达到红色预警");
                    protWarningInfo.setWarningType(3);
                    protWarningInfo.setFarmId(protThreshold.getFarmId());
                    protWarningInfo.setDate(new Date());
                    protWarningInfo.setUserIds(protThreshold.getUserIds());
                    protWarningInfo.setDeviceId(i);
                    protWarningInfo.setBuildLocation("进污口");
                    warningInfoMapper.insert(protWarningInfo);
                }
                if (Double.parseDouble(num3) > Double.parseDouble(protThreshold.getTp1())) {
                    ProtWarningInfo protWarningInfo = new ProtWarningInfo();
                    protWarningInfo.setWarningContent("进污口TP值为" + num3 + "达到橙色预警");
                    protWarningInfo.setWarningType(3);
                    protWarningInfo.setFarmId(protThreshold.getFarmId());
                    protWarningInfo.setDate(new Date());
                    protWarningInfo.setUserIds(protThreshold.getUserIds());
                    protWarningInfo.setDeviceId(i);
                    protWarningInfo.setBuildLocation("进污口");
                    warningInfoMapper.insert(protWarningInfo);
                }
                if (Double.parseDouble(num4) > Double.parseDouble(protThreshold.getTn2())) {
                    ProtWarningInfo protWarningInfo = new ProtWarningInfo();
                    protWarningInfo.setWarningContent("进污口TN值为" + num4 + "达到红色预警");
                    protWarningInfo.setWarningType(4);
                    protWarningInfo.setFarmId(protThreshold.getFarmId());
                    protWarningInfo.setDate(new Date());
                    protWarningInfo.setUserIds(protThreshold.getUserIds());
                    protWarningInfo.setDeviceId(i);
                    protWarningInfo.setBuildLocation("进污口");
                    warningInfoMapper.insert(protWarningInfo);
                }
                if (Double.parseDouble(num4) > Double.parseDouble(protThreshold.getTn1())) {
                    ProtWarningInfo protWarningInfo = new ProtWarningInfo();
                    protWarningInfo.setWarningContent("进污口TN值为" + num4 + "达到橙色预警");
                    protWarningInfo.setWarningType(4);
                    protWarningInfo.setFarmId(protThreshold.getFarmId());
                    protWarningInfo.setDate(new Date());
                    protWarningInfo.setUserIds(protThreshold.getUserIds());
                    protWarningInfo.setDeviceId(i);
                    protWarningInfo.setBuildLocation("进污口");
                    warningInfoMapper.insert(protWarningInfo);
                }
                if (Double.parseDouble(num5) > Double.parseDouble(protThreshold.getFlow2())) {
                    ProtWarningInfo protWarningInfo = new ProtWarningInfo();
                    protWarningInfo.setWarningContent("进污口累计流量值为" + num5 + "达到红色预警");
                    protWarningInfo.setWarningType(5);
                    protWarningInfo.setFarmId(protThreshold.getFarmId());
                    protWarningInfo.setDate(new Date());
                    protWarningInfo.setUserIds(protThreshold.getUserIds());
                    protWarningInfo.setDeviceId(i);
                    protWarningInfo.setBuildLocation("进污口");
                    warningInfoMapper.insert(protWarningInfo);
                }
                if (Double.parseDouble(num5) > Double.parseDouble(protThreshold.getFlow1())) {
                    ProtWarningInfo protWarningInfo = new ProtWarningInfo();
                    protWarningInfo.setWarningContent("进污口累计流量值为" + num5 + "达到橙色预警");
                    protWarningInfo.setWarningType(5);
                    protWarningInfo.setFarmId(protThreshold.getFarmId());
                    protWarningInfo.setDate(new Date());
                    protWarningInfo.setUserIds(protThreshold.getUserIds());
                    protWarningInfo.setDeviceId(i);
                    protWarningInfo.setBuildLocation("进污口");
                    warningInfoMapper.insert(protWarningInfo);
                }
            }
            if (i == 2) {
                queryWrapper.eq("farm_id", 21).eq("prot_type", 2);
                ProtThreshold protThreshold = protThresholdMapper.selectOne(queryWrapper);//污口
                if (Double.parseDouble(num) > Double.parseDouble(protThreshold.getPh2())) {
                    ProtWarningInfo protWarningInfo = new ProtWarningInfo();
                    protWarningInfo.setWarningContent("处理口ph值为" + num + "达到红色预警");
                    protWarningInfo.setWarningType(1);
                    protWarningInfo.setFarmId(protThreshold.getFarmId());
                    protWarningInfo.setWarningType(i);
                    protWarningInfo.setDate(new Date());
                    protWarningInfo.setUserIds(protThreshold.getUserIds());
                    protWarningInfo.setDeviceId(i);
                    protWarningInfo.setBuildLocation("处理口");
                    warningInfoMapper.insert(protWarningInfo);
                }
                if (Double.parseDouble(num) > Double.parseDouble(protThreshold.getPh1())) {
                    ProtWarningInfo protWarningInfo = new ProtWarningInfo();
                    protWarningInfo.setWarningContent("处理口ph值为" + num + "达到橙色预警");
                    protWarningInfo.setWarningType(1);
                    protWarningInfo.setFarmId(protThreshold.getFarmId());
                    protWarningInfo.setWarningType(i);
                    protWarningInfo.setDate(new Date());
                    protWarningInfo.setUserIds(protThreshold.getUserIds());
                    protWarningInfo.setDeviceId(i);
                    protWarningInfo.setBuildLocation("处理口");
                    warningInfoMapper.insert(protWarningInfo);
                }
                if (Double.parseDouble(num1) > Double.parseDouble(protThreshold.getCod2())) {
                    ProtWarningInfo protWarningInfo = new ProtWarningInfo();
                    protWarningInfo.setWarningContent("处理口cod值为" + num1 + "达到红色预警");
                    protWarningInfo.setWarningType(0);
                    protWarningInfo.setFarmId(protThreshold.getFarmId());
                    protWarningInfo.setWarningType(i);
                    protWarningInfo.setDate(new Date());
                    protWarningInfo.setUserIds(protThreshold.getUserIds());
                    protWarningInfo.setDeviceId(i);
                    protWarningInfo.setBuildLocation("处理口");
                    warningInfoMapper.insert(protWarningInfo);
                }
                if (Double.parseDouble(num1) > Double.parseDouble(protThreshold.getCod1())) {
                    ProtWarningInfo protWarningInfo = new ProtWarningInfo();
                    protWarningInfo.setWarningContent("处理口cod值为" + num1 + "达到橙色预警");
                    protWarningInfo.setWarningType(0);
                    protWarningInfo.setFarmId(protThreshold.getFarmId());
                    protWarningInfo.setWarningType(i);
                    protWarningInfo.setDate(new Date());
                    protWarningInfo.setUserIds(protThreshold.getUserIds());
                    protWarningInfo.setDeviceId(i);
                    protWarningInfo.setBuildLocation("处理口");
                    warningInfoMapper.insert(protWarningInfo);
                }
                if (Double.parseDouble(num2) > Double.parseDouble(protThreshold.getNh3n2())) {
                    ProtWarningInfo protWarningInfo = new ProtWarningInfo();
                    protWarningInfo.setWarningContent("处理口NH3N值为" + num2 + "达到红色预警");
                    protWarningInfo.setWarningType(2);
                    protWarningInfo.setFarmId(protThreshold.getFarmId());
                    protWarningInfo.setWarningType(i);
                    protWarningInfo.setDate(new Date());
                    protWarningInfo.setUserIds(protThreshold.getUserIds());
                    protWarningInfo.setDeviceId(i);
                    protWarningInfo.setBuildLocation("处理口");
                    warningInfoMapper.insert(protWarningInfo);
                }
                if (Double.parseDouble(num2) > Double.parseDouble(protThreshold.getNh3n1())) {
                    ProtWarningInfo protWarningInfo = new ProtWarningInfo();
                    protWarningInfo.setWarningContent("处理口NH3N值为" + num2 + "达到橙色预警");
                    protWarningInfo.setWarningType(2);
                    protWarningInfo.setFarmId(protThreshold.getFarmId());
                    protWarningInfo.setWarningType(i);
                    protWarningInfo.setDate(new Date());
                    protWarningInfo.setUserIds(protThreshold.getUserIds());
                    protWarningInfo.setDeviceId(i);
                    protWarningInfo.setBuildLocation("处理口");
                    warningInfoMapper.insert(protWarningInfo);
                }
                if (Double.parseDouble(num3) > Double.parseDouble(protThreshold.getTp2())) {
                    ProtWarningInfo protWarningInfo = new ProtWarningInfo();
                    protWarningInfo.setWarningContent("处理口TP值为" + num3 + "达到红色预警");
                    protWarningInfo.setWarningType(3);
                    protWarningInfo.setFarmId(protThreshold.getFarmId());
                    protWarningInfo.setWarningType(i);
                    protWarningInfo.setDate(new Date());
                    protWarningInfo.setUserIds(protThreshold.getUserIds());
                    protWarningInfo.setDeviceId(i);
                    protWarningInfo.setBuildLocation("处理口");
                    warningInfoMapper.insert(protWarningInfo);
                }
                if (Double.parseDouble(num3) > Double.parseDouble(protThreshold.getTp1())) {
                    ProtWarningInfo protWarningInfo = new ProtWarningInfo();
                    protWarningInfo.setWarningContent("处理口TP值为" + num3 + "达到橙色预警");
                    protWarningInfo.setWarningType(3);
                    protWarningInfo.setFarmId(protThreshold.getFarmId());
                    protWarningInfo.setWarningType(i);
                    protWarningInfo.setDate(new Date());
                    protWarningInfo.setUserIds(protThreshold.getUserIds());
                    protWarningInfo.setDeviceId(i);
                    protWarningInfo.setBuildLocation("处理口");
                    warningInfoMapper.insert(protWarningInfo);
                }
                if (Double.parseDouble(num4) > Double.parseDouble(protThreshold.getTn2())) {
                    ProtWarningInfo protWarningInfo = new ProtWarningInfo();
                    protWarningInfo.setWarningContent("处理口TN值为" + num4 + "达到红色预警");
                    protWarningInfo.setWarningType(4);
                    protWarningInfo.setFarmId(protThreshold.getFarmId());
                    protWarningInfo.setWarningType(i);
                    protWarningInfo.setDate(new Date());
                    protWarningInfo.setUserIds(protThreshold.getUserIds());
                    protWarningInfo.setDeviceId(i);
                    protWarningInfo.setBuildLocation("处理口");
                    warningInfoMapper.insert(protWarningInfo);
                }
                if (Double.parseDouble(num4) > Double.parseDouble(protThreshold.getTn1())) {
                    ProtWarningInfo protWarningInfo = new ProtWarningInfo();
                    protWarningInfo.setWarningContent("处理口TN值为" + num4 + "达到橙色预警");
                    protWarningInfo.setWarningType(4);
                    protWarningInfo.setFarmId(protThreshold.getFarmId());
                    protWarningInfo.setWarningType(i);
                    protWarningInfo.setDate(new Date());
                    protWarningInfo.setUserIds(protThreshold.getUserIds());
                    protWarningInfo.setDeviceId(i);
                    protWarningInfo.setBuildLocation("处理口");
                    warningInfoMapper.insert(protWarningInfo);
                }
                if (Double.parseDouble(num5) > Double.parseDouble(protThreshold.getFlow2())) {
                    ProtWarningInfo protWarningInfo = new ProtWarningInfo();
                    protWarningInfo.setWarningContent("处理口累计流量值为" + num5 + "达到红色预警");
                    protWarningInfo.setWarningType(5);
                    protWarningInfo.setFarmId(protThreshold.getFarmId());
                    protWarningInfo.setWarningType(i);
                    protWarningInfo.setDate(new Date());
                    protWarningInfo.setUserIds(protThreshold.getUserIds());
                    protWarningInfo.setDeviceId(i);
                    protWarningInfo.setBuildLocation("处理口");
                    warningInfoMapper.insert(protWarningInfo);
                }
                if (Double.parseDouble(num5) > Double.parseDouble(protThreshold.getFlow1())) {
                    ProtWarningInfo protWarningInfo = new ProtWarningInfo();
                    protWarningInfo.setWarningContent("处理口累计流量值为" + num5 + "达到橙色预警");
                    protWarningInfo.setWarningType(5);
                    protWarningInfo.setFarmId(protThreshold.getFarmId());
                    protWarningInfo.setWarningType(i);
                    protWarningInfo.setDate(new Date());
                    protWarningInfo.setUserIds(protThreshold.getUserIds());
                    protWarningInfo.setDeviceId(i);
                    protWarningInfo.setBuildLocation("处理口");
                    warningInfoMapper.insert(protWarningInfo);
                }

            }
            if (i == 3) {
                queryWrapper.eq("farm_id", 21).eq("prot_type", 3);
                ProtThreshold protThreshold = protThresholdMapper.selectOne(queryWrapper);//进污口
                if (Double.parseDouble(num) > Double.parseDouble(protThreshold.getPh2())) {
                    ProtWarningInfo protWarningInfo = new ProtWarningInfo();
                    protWarningInfo.setWarningContent("排污口ph值为" + num + "达到红色预警");
                    protWarningInfo.setWarningType(1);
                    protWarningInfo.setFarmId(protThreshold.getFarmId());
                    protWarningInfo.setWarningType(i);
                    protWarningInfo.setDate(new Date());
                    protWarningInfo.setUserIds(protThreshold.getUserIds());
                    protWarningInfo.setDeviceId(i);
                    protWarningInfo.setBuildLocation("排污口");
                    warningInfoMapper.insert(protWarningInfo);
                }
                if (Double.parseDouble(num) > Double.parseDouble(protThreshold.getPh1())) {
                    ProtWarningInfo protWarningInfo = new ProtWarningInfo();
                    protWarningInfo.setWarningContent("排污口ph值为" + num + "达到橙色预警");
                    protWarningInfo.setWarningType(1);
                    protWarningInfo.setFarmId(protThreshold.getFarmId());
                    protWarningInfo.setWarningType(i);
                    protWarningInfo.setDate(new Date());
                    protWarningInfo.setUserIds(protThreshold.getUserIds());
                    protWarningInfo.setDeviceId(i);
                    protWarningInfo.setBuildLocation("排污口");
                    warningInfoMapper.insert(protWarningInfo);
                }
                if (Double.parseDouble(num1) > Double.parseDouble(protThreshold.getCod2())) {
                    ProtWarningInfo protWarningInfo = new ProtWarningInfo();
                    protWarningInfo.setWarningContent("排污口cod值为" + num1 + "达到红色预警");
                    protWarningInfo.setWarningType(0);
                    protWarningInfo.setFarmId(protThreshold.getFarmId());
                    protWarningInfo.setWarningType(i);
                    protWarningInfo.setDate(new Date());
                    protWarningInfo.setUserIds(protThreshold.getUserIds());
                    protWarningInfo.setDeviceId(i);
                    protWarningInfo.setBuildLocation("排污口");
                    warningInfoMapper.insert(protWarningInfo);
                }
                if (Double.parseDouble(num1) > Double.parseDouble(protThreshold.getCod1())) {
                    ProtWarningInfo protWarningInfo = new ProtWarningInfo();
                    protWarningInfo.setWarningContent("排污口cod值为" + num1 + "达到橙色预警");
                    protWarningInfo.setWarningType(0);
                    protWarningInfo.setFarmId(protThreshold.getFarmId());
                    protWarningInfo.setWarningType(i);
                    protWarningInfo.setDate(new Date());
                    protWarningInfo.setUserIds(protThreshold.getUserIds());
                    protWarningInfo.setDeviceId(i);
                    protWarningInfo.setBuildLocation("排污口");
                    warningInfoMapper.insert(protWarningInfo);
                }
                if (Double.parseDouble(num2) > Double.parseDouble(protThreshold.getNh3n2())) {
                    ProtWarningInfo protWarningInfo = new ProtWarningInfo();
                    protWarningInfo.setWarningContent("排污口NH3N值为" + num2 + "达到红色预警");
                    protWarningInfo.setWarningType(2);
                    protWarningInfo.setFarmId(protThreshold.getFarmId());
                    protWarningInfo.setWarningType(i);
                    protWarningInfo.setDate(new Date());
                    protWarningInfo.setUserIds(protThreshold.getUserIds());
                    protWarningInfo.setDeviceId(i);
                    protWarningInfo.setBuildLocation("排污口");
                    warningInfoMapper.insert(protWarningInfo);
                }
                if (Double.parseDouble(num2) > Double.parseDouble(protThreshold.getNh3n1())) {
                    ProtWarningInfo protWarningInfo = new ProtWarningInfo();
                    protWarningInfo.setWarningContent("排污口NH3N值为" + num2 + "达到橙色预警");
                    protWarningInfo.setWarningType(2);
                    protWarningInfo.setFarmId(protThreshold.getFarmId());
                    protWarningInfo.setWarningType(i);
                    protWarningInfo.setDate(new Date());
                    protWarningInfo.setUserIds(protThreshold.getUserIds());
                    protWarningInfo.setDeviceId(i);
                    protWarningInfo.setBuildLocation("排污口");
                    warningInfoMapper.insert(protWarningInfo);
                }
                if (Double.parseDouble(num3) > Double.parseDouble(protThreshold.getTp2())) {
                    ProtWarningInfo protWarningInfo = new ProtWarningInfo();
                    protWarningInfo.setWarningContent("排污口TP值为" + num3 + "达到红色预警");
                    protWarningInfo.setWarningType(3);
                    protWarningInfo.setFarmId(protThreshold.getFarmId());
                    protWarningInfo.setWarningType(i);
                    protWarningInfo.setDate(new Date());
                    protWarningInfo.setUserIds(protThreshold.getUserIds());
                    protWarningInfo.setDeviceId(i);
                    protWarningInfo.setBuildLocation("排污口");
                    warningInfoMapper.insert(protWarningInfo);
                }
                if (Double.parseDouble(num3) > Double.parseDouble(protThreshold.getTp1())) {
                    ProtWarningInfo protWarningInfo = new ProtWarningInfo();
                    protWarningInfo.setWarningContent("排污口TP值为" + num3 + "达到橙色预警");
                    protWarningInfo.setWarningType(3);
                    protWarningInfo.setFarmId(protThreshold.getFarmId());
                    protWarningInfo.setWarningType(i);
                    protWarningInfo.setDate(new Date());
                    protWarningInfo.setUserIds(protThreshold.getUserIds());
                    protWarningInfo.setDeviceId(i);
                    protWarningInfo.setBuildLocation("排污口");
                    warningInfoMapper.insert(protWarningInfo);
                }
                if (Double.parseDouble(num4) > Double.parseDouble(protThreshold.getTn2())) {
                    ProtWarningInfo protWarningInfo = new ProtWarningInfo();
                    protWarningInfo.setWarningContent("排污口TN值为" + num4 + "达到红色预警");
                    protWarningInfo.setWarningType(4);
                    protWarningInfo.setFarmId(protThreshold.getFarmId());
                    protWarningInfo.setWarningType(i);
                    protWarningInfo.setDate(new Date());
                    protWarningInfo.setUserIds(protThreshold.getUserIds());
                    protWarningInfo.setDeviceId(i);
                    protWarningInfo.setBuildLocation("排污口");
                    warningInfoMapper.insert(protWarningInfo);
                }
                if (Double.parseDouble(num4) > Double.parseDouble(protThreshold.getTn1())) {
                    ProtWarningInfo protWarningInfo = new ProtWarningInfo();
                    protWarningInfo.setWarningContent("排污口TN值为" + num4 + "达到橙色预警");
                    protWarningInfo.setWarningType(4);
                    protWarningInfo.setFarmId(protThreshold.getFarmId());
                    protWarningInfo.setWarningType(i);
                    protWarningInfo.setDate(new Date());
                    protWarningInfo.setUserIds(protThreshold.getUserIds());
                    protWarningInfo.setDeviceId(i);
                    protWarningInfo.setBuildLocation("排污口");
                    warningInfoMapper.insert(protWarningInfo);
                }
                if (Double.parseDouble(num5) > Double.parseDouble(protThreshold.getFlow2())) {
                    ProtWarningInfo protWarningInfo = new ProtWarningInfo();
                    protWarningInfo.setWarningContent("排污口累计流量值为" + num5 + "达到红色预警");
                    protWarningInfo.setWarningType(5);
                    protWarningInfo.setFarmId(protThreshold.getFarmId());
                    protWarningInfo.setWarningType(i);
                    protWarningInfo.setDate(new Date());
                    protWarningInfo.setUserIds(protThreshold.getUserIds());
                    protWarningInfo.setDeviceId(i);
                    protWarningInfo.setBuildLocation("排污口");
                    warningInfoMapper.insert(protWarningInfo);
                }
                if (Double.parseDouble(num5) > Double.parseDouble(protThreshold.getFlow1())) {
                    ProtWarningInfo protWarningInfo = new ProtWarningInfo();
                    protWarningInfo.setWarningContent("排污口累计流量值为" + num5 + "达到橙色预警");
                    protWarningInfo.setWarningType(5);
                    protWarningInfo.setFarmId(protThreshold.getFarmId());
                    protWarningInfo.setWarningType(i);
                    protWarningInfo.setDate(new Date());
                    protWarningInfo.setUserIds(protThreshold.getUserIds());
                    protWarningInfo.setDeviceId(i);
                    protWarningInfo.setBuildLocation("排污口");
                    warningInfoMapper.insert(protWarningInfo);
                }

            }
        }
    }
}