是油润滑系统添加设备通讯状态记录

Administrator

2021-04-08 8e921ad1dfb7152a15accdb36f1be2bd8940c366

是油润滑系统添加设备通讯状态记录

 Lubrication_cooling/src/com/data/comm/Lubrication_cooling_SQL.java

@@ -26,6 +26,56 @@
        
        CreateTB_ups_comm(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();
        }
    }
	
    //创建ups通讯表
    private static void CreateTB_ups_comm(MysqlConnPool pool) {
        String sql_str = "CREATE TABLE IF NOT EXISTS "+Sql_Mysql.TB_ups_comm+" (" + 

 Lubrication_cooling/src/com/data/comm/Lubrication_cooling_SocketClient_Thread.java

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

 Lubrication_cooling/src/com/sql/Sql_Mysql.java

@@ -27,6 +27,7 @@
    public final static String TB_oil_comm = DB_MW_Motor + ".`tb_oil_comm`";
    public final static String TB_water_comm = DB_MW_Motor + ".`tb_water_comm`";
    public final static String TB_ups_comm = DB_MW_Motor + ".`tb_ups_comm`";
    public final static String Tb_Device_State = DB_MW_Motor + ".`tb_device_state`";
    
    //--------------------------------------------------------------------------------------------//
    public final static String Tb_oil_comm_RealData = DB_MW_Motor_History + ".tb_oil_comm_";