大功率整流电源添加通讯状态更新

Administrator

2021-04-08 ca25ba854842035cf3e902190cad435148574169

大功率整流电源添加通讯状态更新

 Rectifier_power_4MW/Rectifier_power_4MW_logs/info.log

@@ -1,21 +1,7 @@
2020-12-29 15:23:13.843 [main] [INFO] main.main_Rectifier_power - main_Rectifier_power Server Started At DateTime: 2020-12-29 15:23:13     VWelcome To Use main_Rectifier_power V1.101
2020-12-29 15:23:13.975 [main] [INFO] main.main_Rectifier_power - SQLserver IP: 192.168.10.221, port: 3360
2020-12-29 15:23:13.976 [main] [INFO] main.main_Rectifier_power - IP:192.168.10.221     port:3360
2020-12-29 15:23:14.372 [main] [INFO] main.main_Rectifier_power -  开始检测数据库连接 2020-12-29 15:23:14
2020-12-29 15:23:14.614 [main] [INFO] main.main_Rectifier_power - 检测数据库连接成功
2020-12-29 15:23:14.767 [Thread-12] [INFO] com.data.comm.Rectifier_power_RealRecord_Thread -  Rectifier_power_RealRecord_Thread Start ...
2020-12-29 15:23:14.768 [Thread-11] [TRACE] com.data.comm.Rectifier_power_SocketServer_Thread -  Rectifier_power_SocketServer_Thread Start at 2020-12-29 15:23:14
2020-12-29 15:26:15.376 [main] [INFO] main.main_Rectifier_power - main_Rectifier_power Server Started At DateTime: 2020-12-29 15:26:15     VWelcome To Use main_Rectifier_power V1.101
2020-12-29 15:26:15.402 [main] [INFO] main.main_Rectifier_power - SQLserver IP: 192.168.10.221, port: 3360
2020-12-29 15:26:15.402 [main] [INFO] main.main_Rectifier_power - IP:192.168.10.221     port:3360
2020-12-29 15:26:15.627 [main] [INFO] main.main_Rectifier_power -  开始检测数据库连接 2020-12-29 15:26:15
2020-12-29 15:26:15.832 [main] [INFO] main.main_Rectifier_power - 检测数据库连接成功
2020-12-29 15:26:15.915 [Thread-12] [INFO] com.data.comm.Rectifier_power_RealRecord_Thread -  Rectifier_power_RealRecord_Thread Start ...
2020-12-29 15:26:15.915 [Thread-11] [TRACE] com.data.comm.Rectifier_power_SocketServer_Thread -  Rectifier_power_SocketServer_Thread Start at 2020-12-29 15:26:15
2020-12-29 15:28:08.602 [main] [INFO] main.main_Rectifier_power - main_Rectifier_power Server Started At DateTime: 2020-12-29 15:28:08     VWelcome To Use main_Rectifier_power V1.101
2020-12-29 15:28:08.629 [main] [INFO] main.main_Rectifier_power - SQLserver IP: 192.168.10.221, port: 3360
2020-12-29 15:28:08.629 [main] [INFO] main.main_Rectifier_power - IP:192.168.10.221     port:3360
2020-12-29 15:28:08.863 [main] [INFO] main.main_Rectifier_power -  开始检测数据库连接 2020-12-29 15:28:08
2020-12-29 15:28:09.076 [main] [INFO] main.main_Rectifier_power - 检测数据库连接成功
2020-12-29 15:28:09.158 [Thread-12] [INFO] com.data.comm.Rectifier_power_RealRecord_Thread -  Rectifier_power_RealRecord_Thread Start ...
2020-12-29 15:28:09.158 [Thread-11] [TRACE] com.data.comm.Rectifier_power_SocketServer_Thread -  Rectifier_power_SocketServer_Thread Start at 2020-12-29 15:28:09
2021-04-08 10:48:22.084 [main] [INFO] main.main_Rectifier_power - main_Rectifier_power Server Started At DateTime: 2021-04-08 10:48:22     VWelcome To Use main_Rectifier_power V1.101

2021-04-08 10:48:22.236 [main] [INFO] main.main_Rectifier_power - SQLserver IP: 192.168.10.221, port: 3360

2021-04-08 10:48:22.236 [main] [INFO] main.main_Rectifier_power - IP:192.168.10.221     port:3360

2021-04-08 10:48:23.181 [main] [INFO] main.main_Rectifier_power -  开始检测数据库连接 2021-04-08 10:48:23

2021-04-08 10:48:23.446 [main] [INFO] main.main_Rectifier_power - 检测数据库连接成功

2021-04-08 10:48:23.493 [Thread-12] [INFO] com.data.comm.Rectifier_power_RealRecord_Thread -  Rectifier_power_RealRecord_Thread Start ...

2021-04-08 10:48:23.493 [Thread-11] [TRACE] com.data.comm.Rectifier_power_SocketServer_Thread -  Rectifier_power_SocketServer_Thread Start at 2021-04-08 10:48:23


 Rectifier_power_4MW/src/com/data/comm/Rectifier_power_SQL.java

@@ -26,6 +26,56 @@
        CreateTB_rectifier_power_control(pool);
        
    }
	
    /**
     *    插入或更新设备通讯状态
     * @param pool
     * @param motor
     */
    public static void insertOrUpdateTb_Device_StateTable(MysqlConnPool pool,Motor_inf motor) {
        String sql_str_sel = " Select dev_id from " + Sql_Mysql.Tb_Device_State + " Where dev_id = " + motor.getDev_id();
        String sql_str_upd = " UPDATE " + Sql_Mysql.Tb_Device_State + " SET comm_status = " + motor.conn_state + " WHERE dev_id = " + motor.getDev_id();
        String sql_str_ins = " INSERT INTO "+Sql_Mysql.Tb_Device_State+"(dev_id,comm_status) VALUES("+motor.getDev_id()+","+motor.conn_state+");";
        ResultSet res = null;
        Sql_Mysql sql = new Sql_Mysql(pool.getConn());
        try {
            res = sql.sqlMysqlQuery(sql_str_sel);
            if(res.next()) {
                sql.sqlMysqlExecute(sql_str_upd);
            }else {
                sql.sqlMysqlExecute(sql_str_ins);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            if(null != res) {
                try {
                    res.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            sql.close_con();
        }
    }
	
    /**
     * 更新设备的通讯状态
     * @param pool
     * @param motor
     */
    public static void updateTb_Device_StateTable(MysqlConnPool pool,Motor_inf motor) {
        String sql_str = " UPDATE "+Sql_Mysql.Tb_Device_State+" SET comm_status = "+motor.conn_state+",record_time='"+Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms)+"' WHERE dev_id = "+motor.getDev_id();
        Sql_Mysql sql = new Sql_Mysql(pool.getConn());
        try {
            sql.sqlMysqlExecute(sql_str);
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            sql.close_con();
        }
    }
	
    //创建4MW大功率整流电源控制表
    private static void CreateTB_rectifier_power_control(MysqlConnPool pool) {
        String sql_str = "CREATE TABLE IF NOT EXISTS "+Sql_Mysql.TB_RECTIFIER_POWER_CONTROL+" (" + 

 Rectifier_power_4MW/src/com/data/comm/Rectifier_power_SocketClient_Thread.java

@@ -25,6 +25,7 @@
    @Override
    public void run() {
        int run_count = 0;
        Rectifier_power_SQL.insertOrUpdateTb_Device_StateTable(pool, motor);
        while(true) {
            try { 
                if(run_count % 2 == 0) {
@@ -43,6 +44,9 @@
                }
                
                motor.conn_state = master.getConnectState();
                if(run_count %5 == 0) {
                    Rectifier_power_SQL.updateTb_Device_StateTable(pool, motor);
                }
                if(run_count > 999909) {
                    run_count = 0;
                }

 Rectifier_power_4MW/src/com/sql/Sql_Mysql.java

@@ -26,6 +26,7 @@
    public final static String Tb_MW_Motor_inf = DB_MW_Motor + ".`tb_3.5mw_motor_inf`";
    public final static String TB_RECTIFIER_POWER_RT = DB_MW_Motor + ".`tb_rectifier_power_rt`";
    public final static String TB_RECTIFIER_POWER_CONTROL = DB_MW_Motor + ".`tb_rectifier_power_control`";
    public final static String Tb_Device_State = DB_MW_Motor + ".`tb_device_state`";
    //--------------------------------------------------------------------------------------------//
    public final static String Tb_RECTIFIER_POWER_RealData = DB_MW_Motor_History + ".tb_rectifier_power_";