package com.ard.alarm.digitization.service.impl;

import com.alibaba.fastjson2.JSON;
import com.ard.alarm.digitization.model.CylbdBj;
import com.ard.alarm.digitization.model.Gkbj;
import com.ard.alarm.digitization.service.Digitization2Service;
import com.ard.utils.jdbc.Query;
import com.ard.utils.mqtt.MqttProducer;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;

import java.sql.*;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;

@Service
@Slf4j(topic = "digitization2")
public class Digitization2ServiceImpl implements Digitization2Service {

    @Value("${digitization2.enabled}")
    private Boolean digitization2Enabled;

    @Value("${digitization2.mysql.dbIP}")
    private String digitization2MysqlIP;

    @Value("${digitization2.mysql.dbPort}")
    private Integer digitization2MysqlPort;

    @Value("${digitization2.mysql.dbName}")
    private String digitization2MysqlName;

    @Value("${digitization2.mysql.dbCount}")
    private String digitization2MysqlCount;

    @Value("${digitization2.mysql.dbPassword}")
    private String digitization2MysqlPassword;

    Connection connection = null;

    Statement statement = null;

    private SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

    //public Date gkbjLastTime;
    public String gkbjLastTime;

    //public Date cylbdBjLastTime;
    public String cylbdBjLastTime;

    @Scheduled(cron = "*/5 * * * * ?")
    public void alarmHandler() {
        if(!digitization2Enabled){
            return;
        }

        Thread gkbjThread = new Thread(){
            @Override
            public void run() {
                try {
                    Class.forName("com.mysql.cj.jdbc.Driver");

                    Connection connection = DriverManager.getConnection("jdbc:mysql://" + digitization2MysqlIP + ":" + digitization2MysqlPort + "/" + digitization2MysqlName, digitization2MysqlCount, digitization2MysqlPassword);

                    Statement statement = (Statement) connection.createStatement();

                    if (gkbjLastTime == null) {
                        //初次查询，只获取10条最近数据。
                        String sql = "select * from gkbj order by fssj desc limit 0,10";
                        ResultSet resultSet = statement.executeQuery(sql);
                        while (resultSet.next()) {
                            if(resultSet.isFirst()){
                                gkbjLastTime = sdf.format(resultSet.getTimestamp("fssj"));
                            }
                            Gkbj gkbj = new Gkbj();
                            gkbj.setId(resultSet.getInt("id"));
                            gkbj.setOrgName(resultSet.getString("org_name"));
                            gkbj.setKm(resultSet.getString("km"));
                            gkbj.setDm(resultSet.getString("dm"));
                            gkbj.setDmc(resultSet.getString("dmc"));
                            gkbj.setJh(resultSet.getString("jh"));
                            gkbj.setWellCommonName(resultSet.getString("well_common_name"));
                            gkbj.setFssj(resultSet.getTimestamp("fssj"));
                            gkbj.setBdbj(resultSet.getString("bdbj"));
                            gkbj.setBjtz(resultSet.getString("bdbj"));
                            gkbj.setCyl1(resultSet.getFloat("cyl1"));
                            gkbj.setCyl2(resultSet.getFloat("cyl2"));
                            gkbj.setHsqk(resultSet.getString("hsqk"));
                            gkbj.setGxsj(resultSet.getString("gxsj"));
                            gkbj.setXqkdm(resultSet.getString("xqkdm"));
                            gkbj.setQdfs(resultSet.getString("qdfs"));
                            gkbj.setCyfs(resultSet.getString("cyfs"));
                            gkbj.setCzsj(resultSet.getString("czsj"));
                            gkbj.setCzr(resultSet.getString("czr"));
                            gkbj.setCznr(resultSet.getString("cznr"));
                            gkbj.setBz(resultSet.getString("bz"));
                            gkbj.setAlarmType("工况预警");
                            MqttProducer.publish(2, false, "digitization2", JSON.toJSONString(gkbj));
                        }
                        connection.close();
                        statement.close();
                        resultSet.close();
                    } else {
                        //查询大于上次查询最后一条数据的时间
                        String sql = "select * from gkbj where fssj >= \'" + gkbjLastTime + " \'order by fssj desc";
                        ResultSet resultSet = statement.executeQuery(sql);
                        while (resultSet.next()) {
                            if(resultSet.isFirst()){
                                gkbjLastTime = sdf.format(resultSet.getTimestamp("fssj"));
                            }
                            Gkbj gkbj = new Gkbj();
                            gkbj.setId(resultSet.getInt("id"));
                            gkbj.setOrgName(resultSet.getString("org_name"));
                            gkbj.setKm(resultSet.getString("km"));
                            gkbj.setDm(resultSet.getString("dm"));
                            gkbj.setDmc(resultSet.getString("dmc"));
                            gkbj.setJh(resultSet.getString("jh"));
                            gkbj.setWellCommonName(resultSet.getString("well_common_name"));
                            gkbj.setFssj(resultSet.getTimestamp("fssj"));
                            gkbj.setBdbj(resultSet.getString("bdbj"));
                            gkbj.setBjtz(resultSet.getString("bdbj"));
                            gkbj.setCyl1(resultSet.getFloat("cyl1"));
                            gkbj.setCyl2(resultSet.getFloat("cyl2"));
                            gkbj.setHsqk(resultSet.getString("hsqk"));
                            gkbj.setGxsj(resultSet.getString("gxsj"));
                            gkbj.setXqkdm(resultSet.getString("xqkdm"));
                            gkbj.setQdfs(resultSet.getString("qdfs"));
                            gkbj.setCyfs(resultSet.getString("cyfs"));
                            gkbj.setCzsj(resultSet.getString("czsj"));
                            gkbj.setCzr(resultSet.getString("czr"));
                            gkbj.setCznr(resultSet.getString("cznr"));
                            gkbj.setBz(resultSet.getString("bz"));
                            gkbj.setAlarmType("工况报警");
                            MqttProducer.publish(2, false, "digitization2", JSON.toJSONString(gkbj));
                        }
                        connection.close();
                        statement.close();
                        resultSet.close();
                    }
                } catch (Exception ex) {
                    ex.printStackTrace();
                    log.error("二厂数字化工况报警数据处理异常：" + ex.getMessage());
                }
            }
        };
        gkbjThread.start();

        Thread cylbdBjThread = new Thread(){
            @Override
            public void run() {
                try {
                    Class.forName("com.mysql.cj.jdbc.Driver");

                    Connection connection = DriverManager.getConnection("jdbc:mysql://" + digitization2MysqlIP + ":" + digitization2MysqlPort + "/" + digitization2MysqlName, digitization2MysqlCount, digitization2MysqlPassword);

                    Statement statement = (Statement) connection.createStatement();

                    if (cylbdBjLastTime == null) {
                        //初次查询，只获取10条最近数据。
                        String sql = "select * from cylbd_bj order by fssj desc limit 0,10";
                        ResultSet resultSet = statement.executeQuery(sql);
                        while (resultSet.next()) {
                            if(resultSet.isFirst()){
                                cylbdBjLastTime = sdf.format(resultSet.getTimestamp("fssj"));
                            }
                            CylbdBj cylbdBj = new CylbdBj();
                            cylbdBj.setId(resultSet.getInt("id"));
                            cylbdBj.setOrgName(resultSet.getString("org_name"));
                            cylbdBj.setKm(resultSet.getString("km"));
                            cylbdBj.setDm(resultSet.getString("dm"));
                            cylbdBj.setDmc(resultSet.getString("dmc"));
                            cylbdBj.setJh(resultSet.getString("jh"));
                            cylbdBj.setWellCommonName(resultSet.getString("well_common_name"));
                            cylbdBj.setFssj(resultSet.getTimestamp("fssj"));
                            cylbdBj.setBdbj(resultSet.getString("bdbj"));
                            cylbdBj.setBjtz(resultSet.getString("bdbj"));
                            cylbdBj.setCyl1(resultSet.getFloat("cyl1"));
                            cylbdBj.setCyl2(resultSet.getFloat("cyl2"));
                            cylbdBj.setHsqk(resultSet.getString("hsqk"));
                            cylbdBj.setGxsj(resultSet.getString("gxsj"));
                            cylbdBj.setXqkdm(resultSet.getString("xqkdm"));
                            cylbdBj.setQdfs(resultSet.getString("qdfs"));
                            cylbdBj.setCyfs(resultSet.getString("cyfs"));
                            cylbdBj.setCzsj(resultSet.getString("czsj"));
                            cylbdBj.setCzr(resultSet.getString("czr"));
                            cylbdBj.setCznr(resultSet.getString("cznr"));
                            cylbdBj.setBz(resultSet.getString("bz"));
                            cylbdBj.setAlarmType("停机报警");
                            MqttProducer.publish(2, false, "digitization2", JSON.toJSONString(cylbdBj));
                        }
                        connection.close();
                        statement.close();
                        resultSet.close();
                    } else {
                        //查询大于上次查询最后一条数据的时间
                        String sql = "select * from cylbd_bj where fssj >= \'" + cylbdBjLastTime + "\' order by fssj desc";
                        ResultSet resultSet = statement.executeQuery(sql);
                        while (resultSet.next()) {
                            if(resultSet.isFirst()){
                                cylbdBjLastTime = sdf.format(resultSet.getTimestamp("fssj"));
                            }
                            CylbdBj cylbdBj = new CylbdBj();
                            cylbdBj.setId(resultSet.getInt("id"));
                            cylbdBj.setOrgName(resultSet.getString("org_name"));
                            cylbdBj.setKm(resultSet.getString("km"));
                            cylbdBj.setDm(resultSet.getString("dm"));
                            cylbdBj.setDmc(resultSet.getString("dmc"));
                            cylbdBj.setJh(resultSet.getString("jh"));
                            cylbdBj.setWellCommonName(resultSet.getString("well_common_name"));
                            cylbdBj.setFssj(resultSet.getTimestamp("fssj"));
                            cylbdBj.setBdbj(resultSet.getString("bdbj"));
                            cylbdBj.setBjtz(resultSet.getString("bdbj"));
                            cylbdBj.setCyl1(resultSet.getFloat("cyl1"));
                            cylbdBj.setCyl2(resultSet.getFloat("cyl2"));
                            cylbdBj.setHsqk(resultSet.getString("hsqk"));
                            cylbdBj.setGxsj(resultSet.getString("gxsj"));
                            cylbdBj.setXqkdm(resultSet.getString("xqkdm"));
                            cylbdBj.setQdfs(resultSet.getString("qdfs"));
                            cylbdBj.setCyfs(resultSet.getString("cyfs"));
                            cylbdBj.setCzsj(resultSet.getString("czsj"));
                            cylbdBj.setCzr(resultSet.getString("czr"));
                            cylbdBj.setCznr(resultSet.getString("cznr"));
                            cylbdBj.setBz(resultSet.getString("bz"));
                            cylbdBj.setAlarmType("停机报警");
                            MqttProducer.publish(2, false, "digitization2", JSON.toJSONString(cylbdBj));
                        }
                        connection.close();
                        statement.close();
                        resultSet.close();
                    }
                } catch (Exception ex) {
                    ex.printStackTrace();
                    log.error("二厂数字化工况报警数据处理异常：" + ex.getMessage());
                }
            }
        };
        cylbdBjThread.start();
    }

    public void initMysql() throws ClassNotFoundException, SQLException {
        if(this.connection != null){
            if(!this.connection.isClosed()){
                try{
                    this.connection.close();
                    this.connection = null;
                }catch(Exception e){
                    this.connection = null;
                }
            }
        }

        if(this.statement != null){
            if(!this.statement.isClosed()){
                try{
                    this.statement.close();
                    this.statement = null;
                }catch(Exception e){
                    this.statement = null;
                }
            }
        }

        Class.forName("com.mysql.cj.jdbc.Driver");

        this.connection = DriverManager.getConnection("jdbc:mysql://" + digitization2MysqlIP + ":" + digitization2MysqlPort + "/" + digitization2MysqlName, digitization2MysqlCount, digitization2MysqlPassword);

        this.statement = (Statement) connection.createStatement();
    }

}