在9100_state表中添加停电时长,续航时长,停电次数和流量等列

军

2018-09-29 b471d645e91846f3c54f4f1b3bcbf0a6729ed847

在9100_state表中添加停电时长,续航时长,停电次数和流量等列

 BattMonitor_DB_Builder/bin/com/dev/fbs9100/FBS9100_Task_Thread_SQL.class

Binary files differ

 BattMonitor_DB_Builder/src/com/dev/fbs9100/FBS9100_Task_Thread_SQL.java

@@ -1,197 +1,202 @@
package com.dev.fbs9100;



import java.sql.SQLException;



import com.sql.MysqlConnPool;

import com.sql.Sql_Mysql;



public class FBS9100_Task_Thread_SQL {

	
    /**

     * 创建 tb_fbs9100_state 表并且将设备id和设备hip插入到表中

     * @param con_pool

     * @param al_param

     */

    public static void createFBS9100StateTableOnRam(MysqlConnPool con_pool)

    {

        String str1 = "DROP TABLE IF EXISTS " + Sql_Mysql.FBS9100State_Table;

        String str2 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.FBS9100State_Table

                    + " ( `num` BIGINT NOT NULL AUTO_INCREMENT, "

                    + "`dev_ip` varchar(20) NOT NULL DEFAULT '127.0.0.0', "

                    + "`dev_version` varchar(20) NOT NULL DEFAULT '0', "

                    + "`dev_id` BIGINT NOT NULL DEFAULT 0, "

                    + "`op_cmd` INT NOT NULL DEFAULT 0, "

                    + "`record_datetime` varchar(20) NOT NULL DEFAULT '2015-12-02 12:10:00', "

                    + "`dev_datetime` varchar(20) NOT NULL DEFAULT '2015-12-02 12:10:00', "

                    + "`dev_testtype` INT NOT NULL DEFAULT 0, "

                    + "`dev_testgroupnum` INT NOT NULL DEFAULT 0, "

                    + "`dev_workstate` INT NOT NULL DEFAULT 0, "

                    + "`dev_alarmstate` INT NOT NULL DEFAULT 0, "

                    + "`dev_temp` float NOT NULL DEFAULT 0, "

                    + "`dev_res_test_state` INT NOT NULL DEFAULT 0, "        //内阻测试状态

                    + "`dev_onlinevollow` BOOLEAN NOT NULL DEFAULT false, "

                    + "`dev_eachgroup_battsum` INT NOT NULL DEFAULT 0, "

                    + "`dev_captest_onlinevol` float NOT NULL DEFAULT 0, "

                    + "`dev_captest_groupvol` float NOT NULL DEFAULT 0, "

                    + "`dev_captest_curr` float NOT NULL DEFAULT 0, "

                    + "`dev_captest_cap` float NOT NULL DEFAULT 0, "

                    + "`dev_captest_timelong` INT NOT NULL DEFAULT 0, "

                    + "`dev_restest_count` INT NOT NULL DEFAULT 0, "

                    + "`dev_restest_moncount` INT NOT NULL DEFAULT 0, "

                    + "`dev_restest_monindex` INT NOT NULL DEFAULT 0, "

                    + "`dev_commcount` INT NOT NULL DEFAULT 0, "

                    + "`dev_errcommcount` INT NOT NULL DEFAULT 0, "

                    + "`dev_rxnullerrcount` INT NOT NULL DEFAULT 0, "

					
                    + "`dev_last_captest_stop_type` INT NOT NULL DEFAULT 0, "

                    + "`dev_concurr`  float NOT NULL DEFAULT 0, "

                    + "`dev_condvoldp`  float NOT NULL DEFAULT 0, "

                    + "`dev_conresist`  float NOT NULL DEFAULT 0, "

                    + "`dev_condcurr`  float NOT NULL DEFAULT 0, "

                    + "`dev_61850alarms`  varchar(64) NOT NULL DEFAULT '', "					
					
                    + " UNIQUE INDEX index_dev_id_uniq (`dev_id`), "

                    + " PRIMARY KEY (`num`) ) "

                    + " ENGINE=InnoDB DEFAULT CHARSET=utf8";

        /*

        String str3 = "INSERT INTO " + Sql_Mysql.FBS9100State_Table + " (dev_ip, dev_id) ";

        str3 += " SELECT dev_ip, dev_id FROM " + Sql_Mysql.BattInf_Table;

        */

        Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());

        try {

            sql.sqlMysqlExecute(str1);

            sql.sqlMysqlExecute(str2);

            //sql.sqlMysqlExecute(str3);

        } catch (SQLException e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        } finally {

            sql.close_con();

        }

    }

	
    /**

     * 创建 tb_fbs9100s_dcdc_data 表并且将设备id和设备ip插入到表中

     * @param con_pool

     * @param al_param

     */

    public static void createFBS9100S_DCDC_DataTableOnRam(MysqlConnPool con_pool)

    {

        String str1 = "DROP TABLE IF EXISTS " + Sql_Mysql.FBS9100S_DcDcState_Table;

        String str2 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.FBS9100S_DcDcState_Table

                    + " ( `num` BIGINT NOT NULL AUTO_INCREMENT, "

                    + "`dev_id` BIGINT NOT NULL DEFAULT 0, "

                    + "`dcdc_num` BIGINT NOT NULL DEFAULT 0, "

                    + "`dcdc_Vsys` float NOT NULL DEFAULT 0, "

                    + "`dcdc_Vout` float NOT NULL DEFAULT 0, "

                    + "`dcdc_Vbat` float NOT NULL DEFAULT 0, "

                    + "`dcdc_Iout` float NOT NULL DEFAULT 0, "

                    + "`dcdc_Ibuck` float NOT NULL DEFAULT 0, "

                    + "`dcdc_Tmp_Dis` float NOT NULL DEFAULT 0, "

                    + "`dcdc_Tmp_Chr` float NOT NULL DEFAULT 0, "

                    + "`dcdc_SMR_Alarm1` INT NOT NULL DEFAULT 0, "

                    + "`dcdc_SMR_Alarm2` INT NOT NULL DEFAULT 0, "

                    + "`dcdc_version` INT NOT NULL DEFAULT 0, "

                    + "`dcdc_ModeSetComm` INT NOT NULL DEFAULT 0, "

                    + "`dcdc_RunSetComm` INT NOT NULL DEFAULT 0, "

                    + "`dcdc_BuckISet` float NOT NULL DEFAULT 0, "

                    + "`dcdc_DisVolSet` float NOT NULL DEFAULT 0, "

                    + "`dcdc_DisCurrSet` float NOT NULL DEFAULT 0, "

                    + "`dcdc_CommTxCnt` INT NOT NULL DEFAULT 0, "

                    + "`dcdc_CommRxCnt` INT NOT NULL DEFAULT 0, "

                    + " UNIQUE INDEX index_dcdc_num_uniq (`dcdc_num`), "

                    + " PRIMARY KEY (`num`) ) "

                    + " ENGINE=MEMORY DEFAULT CHARSET=utf8";

		
        Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());

        try {

            sql.sqlMysqlExecute(str1);

            sql.sqlMysqlExecute(str2);

        } catch (SQLException e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        } finally {

            sql.close_con();

        }

    }

	
    /**

     * 创建 tb_fbs9100_setparam 表，并且将设备id和设备ip插入到表中

     * @param con_pool

     * @param al_param

     */

    public static void createFBS9100SetTestParamTableOnRam(MysqlConnPool con_pool)

    {

        String str1 = "DROP TABLE IF EXISTS " + Sql_Mysql.FBS9100SetParam_Table;

        String str2 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.FBS9100SetParam_Table

                    + " ( `num` BIGINT NOT NULL AUTO_INCREMENT, "

                    + "`dev_ip` varchar(20) NOT NULL DEFAULT '127.0.0.0', "

                    + "`dev_id` BIGINT NOT NULL DEFAULT 0, "

                    + "`op_cmd` INT NOT NULL DEFAULT 0, "

                    + "`TestCmd` INT NOT NULL DEFAULT 0, "

                    + "`HourRate` INT NOT NULL DEFAULT 0, "

                    + "`DisCurr` FLOAT NOT NULL DEFAULT 0, "

                    + "`DisCap` FLOAT NOT NULL DEFAULT 0, "

                    + "`DisTime` INT NOT NULL DEFAULT 0, "

                    + "`GroupVol_LOW` FLOAT NOT NULL DEFAULT 0, "

                    + "`MonomerVol_LOW` FLOAT NOT NULL DEFAULT 0, "

                    + "`MonomerLowCount` INT NOT NULL DEFAULT 0, "

                    + "`BattGroupNum` INT NOT NULL DEFAULT 0, "

                    + "`OnlineVolLowAction` INT NOT NULL DEFAULT 0, "

                    + "`DCVolHighLimit` FLOAT NOT NULL DEFAULT 0, "

                    + "`ChargeCurrSet` FLOAT NOT NULL DEFAULT 0, "

                    + "`MonomerTmp_High` FLOAT NOT NULL DEFAULT 0, "

                    + "`AutoTestStartVol`  float NOT NULL DEFAULT 0, "            //起始电压

                    + " UNIQUE INDEX index_dev_id_uniq (`dev_id`), "

                    + " PRIMARY KEY (`num`) ) "

                    + " ENGINE=MEMORY DEFAULT CHARSET=utf8";

		
        Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());

        try {

            sql.sqlMysqlExecute(str1);

            sql.sqlMysqlExecute(str2);

        } catch (SQLException e) {

            e.printStackTrace();

        } finally {

            sql.close_con();

        }

    }

	
    /**

     * 创建 Sql_Mysql.RamDB_CMCC_POWER_Data 表并且将设备id插入到表中

     * @param con_pool

     * @param al_param

     */

    public static void createFBS9100CmccPowerDataOnRam(MysqlConnPool con_pool)

    {

        String str1 = "DROP TABLE IF EXISTS " + Sql_Mysql.RamDB_CMCC_POWER_Data;

        String str2 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.RamDB_CMCC_POWER_Data

                    + " ( `num` BIGINT NOT NULL AUTO_INCREMENT, "

                    + "`dev_id` BIGINT NOT NULL DEFAULT 0, "

                    + "`vol1` float NOT NULL DEFAULT 0, "

                    + "`vol2` float NOT NULL DEFAULT 0, "

                    + "`vol3` float NOT NULL DEFAULT 0, "

                    + "`vol4` float NOT NULL DEFAULT 0, "

                    + "`vol5` float NOT NULL DEFAULT 0, "

                    + "`curr1` float NOT NULL DEFAULT 0, "

                    + "`curr2` float NOT NULL DEFAULT 0, "

                    + "`curr3` float NOT NULL DEFAULT 0, "

                    + "`curr4` float NOT NULL DEFAULT 0, "

                    + "`curr5` float NOT NULL DEFAULT 0, "

                    + " UNIQUE INDEX index_dev_id_uniq (`dev_id`), "

                    + " PRIMARY KEY (`num`) ) "

                    + " ENGINE=InnoDB DEFAULT CHARSET=utf8";

		
        Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());

        try {

            sql.sqlMysqlExecute(str1);

            sql.sqlMysqlExecute(str2);

        } catch (SQLException e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        } finally {

            sql.close_con();

        }

    }

    /***********************************************************************************/

}

package com.dev.fbs9100;

import java.sql.SQLException;

import com.sql.MysqlConnPool;
import com.sql.Sql_Mysql;

public class FBS9100_Task_Thread_SQL {
	
    /**
     * 创建 tb_fbs9100_state 表并且将设备id和设备hip插入到表中
     * @param con_pool
     * @param al_param
     */
    public static void createFBS9100StateTableOnRam(MysqlConnPool con_pool)
    {
        String str1 = "DROP TABLE IF EXISTS " + Sql_Mysql.FBS9100State_Table;
        String str2 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.FBS9100State_Table
                    + " ( `num` BIGINT NOT NULL AUTO_INCREMENT, "
                    + "`dev_ip` varchar(20) NOT NULL DEFAULT '127.0.0.0', "
                    + "`dev_version` varchar(20) NOT NULL DEFAULT '0', "
                    + "`dev_id` BIGINT NOT NULL DEFAULT 0, "
                    + "`op_cmd` INT NOT NULL DEFAULT 0, "
                    + "`record_datetime` varchar(20) NOT NULL DEFAULT '2015-12-02 12:10:00', "
                    + "`dev_datetime` varchar(20) NOT NULL DEFAULT '2015-12-02 12:10:00', "
                    + "`dev_testtype` INT NOT NULL DEFAULT 0, "
                    + "`dev_testgroupnum` INT NOT NULL DEFAULT 0, "
                    + "`dev_workstate` INT NOT NULL DEFAULT 0, "
                    + "`dev_alarmstate` INT NOT NULL DEFAULT 0, "
                    + "`dev_temp` float NOT NULL DEFAULT 0, "
                    + "`dev_res_test_state` INT NOT NULL DEFAULT 0, "        //内阻测试状态
                    + "`dev_onlinevollow` BOOLEAN NOT NULL DEFAULT false, "
                    + "`dev_eachgroup_battsum` INT NOT NULL DEFAULT 0, "
                    + "`dev_captest_onlinevol` float NOT NULL DEFAULT 0, "
                    + "`dev_captest_groupvol` float NOT NULL DEFAULT 0, "
                    + "`dev_captest_curr` float NOT NULL DEFAULT 0, "
                    + "`dev_captest_cap` float NOT NULL DEFAULT 0, "
                    + "`dev_captest_timelong` INT NOT NULL DEFAULT 0, "
                    + "`dev_restest_count` INT NOT NULL DEFAULT 0, "
                    + "`dev_restest_moncount` INT NOT NULL DEFAULT 0, "
                    + "`dev_restest_monindex` INT NOT NULL DEFAULT 0, "
                    + "`dev_commcount` INT NOT NULL DEFAULT 0, "
                    + "`dev_errcommcount` INT NOT NULL DEFAULT 0, "
                    + "`dev_rxnullerrcount` INT NOT NULL DEFAULT 0, "
					
                    + "`dev_last_captest_stop_type` INT NOT NULL DEFAULT 0, "
                    + "`dev_concurr`  float NOT NULL DEFAULT 0, "
                    + "`dev_condvoldp`  float NOT NULL DEFAULT 0, "
                    + "`dev_conresist`  float NOT NULL DEFAULT 0, "
                    + "`dev_condcurr`  float NOT NULL DEFAULT 0, "
                    + "`dev_61850alarms`  varchar(64) NOT NULL DEFAULT '', "
					
                    + "`dev_batt_xuhang_tlong` INT NOT NULL DEFAULT 0, "                //续航时长
                    + "`dev_station_poff_tlong` INT NOT NULL DEFAULT 0, "                //停电时长
                    + "`dev_station_poff_cnt` INT NOT NULL DEFAULT 0, "                    //停电次数
                    + "`dev_data_flowsum` BIGINT NOT NULL DEFAULT 0, "                    //机房流量
					
                    + " UNIQUE INDEX index_dev_id_uniq (`dev_id`), "
                    + " PRIMARY KEY (`num`) ) "
                    + " ENGINE=InnoDB DEFAULT CHARSET=utf8";
        /*
        String str3 = "INSERT INTO " + Sql_Mysql.FBS9100State_Table + " (dev_ip, dev_id) ";
        str3 += " SELECT dev_ip, dev_id FROM " + Sql_Mysql.BattInf_Table;
        */
        Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
        try {
            sql.sqlMysqlExecute(str1);
            sql.sqlMysqlExecute(str2);
            //sql.sqlMysqlExecute(str3);
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } finally {
            sql.close_con();
        }
    }
	
    /**
     * 创建 tb_fbs9100s_dcdc_data 表并且将设备id和设备ip插入到表中
     * @param con_pool
     * @param al_param
     */
    public static void createFBS9100S_DCDC_DataTableOnRam(MysqlConnPool con_pool)
    {
        String str1 = "DROP TABLE IF EXISTS " + Sql_Mysql.FBS9100S_DcDcState_Table;
        String str2 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.FBS9100S_DcDcState_Table
                    + " ( `num` BIGINT NOT NULL AUTO_INCREMENT, "
                    + "`dev_id` BIGINT NOT NULL DEFAULT 0, "
                    + "`dcdc_num` BIGINT NOT NULL DEFAULT 0, "
                    + "`dcdc_Vsys` float NOT NULL DEFAULT 0, "
                    + "`dcdc_Vout` float NOT NULL DEFAULT 0, "
                    + "`dcdc_Vbat` float NOT NULL DEFAULT 0, "
                    + "`dcdc_Iout` float NOT NULL DEFAULT 0, "
                    + "`dcdc_Ibuck` float NOT NULL DEFAULT 0, "
                    + "`dcdc_Tmp_Dis` float NOT NULL DEFAULT 0, "
                    + "`dcdc_Tmp_Chr` float NOT NULL DEFAULT 0, "
                    + "`dcdc_SMR_Alarm1` INT NOT NULL DEFAULT 0, "
                    + "`dcdc_SMR_Alarm2` INT NOT NULL DEFAULT 0, "
                    + "`dcdc_version` INT NOT NULL DEFAULT 0, "
                    + "`dcdc_ModeSetComm` INT NOT NULL DEFAULT 0, "
                    + "`dcdc_RunSetComm` INT NOT NULL DEFAULT 0, "
                    + "`dcdc_BuckISet` float NOT NULL DEFAULT 0, "
                    + "`dcdc_DisVolSet` float NOT NULL DEFAULT 0, "
                    + "`dcdc_DisCurrSet` float NOT NULL DEFAULT 0, "
                    + "`dcdc_CommTxCnt` INT NOT NULL DEFAULT 0, "
                    + "`dcdc_CommRxCnt` INT NOT NULL DEFAULT 0, "
                    + " UNIQUE INDEX index_dcdc_num_uniq (`dcdc_num`), "
                    + " PRIMARY KEY (`num`) ) "
                    + " ENGINE=MEMORY DEFAULT CHARSET=utf8";
		
        Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
        try {
            sql.sqlMysqlExecute(str1);
            sql.sqlMysqlExecute(str2);
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } finally {
            sql.close_con();
        }
    }
	
    /**
     * 创建 tb_fbs9100_setparam 表，并且将设备id和设备ip插入到表中
     * @param con_pool
     * @param al_param
     */
    public static void createFBS9100SetTestParamTableOnRam(MysqlConnPool con_pool)
    {
        String str1 = "DROP TABLE IF EXISTS " + Sql_Mysql.FBS9100SetParam_Table;
        String str2 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.FBS9100SetParam_Table
                    + " ( `num` BIGINT NOT NULL AUTO_INCREMENT, "
                    + "`dev_ip` varchar(20) NOT NULL DEFAULT '127.0.0.0', "
                    + "`dev_id` BIGINT NOT NULL DEFAULT 0, "
                    + "`op_cmd` INT NOT NULL DEFAULT 0, "
                    + "`TestCmd` INT NOT NULL DEFAULT 0, "
                    + "`HourRate` INT NOT NULL DEFAULT 0, "
                    + "`DisCurr` FLOAT NOT NULL DEFAULT 0, "
                    + "`DisCap` FLOAT NOT NULL DEFAULT 0, "
                    + "`DisTime` INT NOT NULL DEFAULT 0, "
                    + "`GroupVol_LOW` FLOAT NOT NULL DEFAULT 0, "
                    + "`MonomerVol_LOW` FLOAT NOT NULL DEFAULT 0, "
                    + "`MonomerLowCount` INT NOT NULL DEFAULT 0, "
                    + "`BattGroupNum` INT NOT NULL DEFAULT 0, "
                    + "`OnlineVolLowAction` INT NOT NULL DEFAULT 0, "
                    + "`DCVolHighLimit` FLOAT NOT NULL DEFAULT 0, "
                    + "`ChargeCurrSet` FLOAT NOT NULL DEFAULT 0, "
                    + "`MonomerTmp_High` FLOAT NOT NULL DEFAULT 0, "
                    + "`AutoTestStartVol`  float NOT NULL DEFAULT 0, "            //起始电压
                    + " UNIQUE INDEX index_dev_id_uniq (`dev_id`), "
                    + " PRIMARY KEY (`num`) ) "
                    + " ENGINE=MEMORY DEFAULT CHARSET=utf8";
		
        Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
        try {
            sql.sqlMysqlExecute(str1);
            sql.sqlMysqlExecute(str2);
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            sql.close_con();
        }
    }
	
    /**
     * 创建 Sql_Mysql.RamDB_CMCC_POWER_Data 表并且将设备id插入到表中
     * @param con_pool
     * @param al_param
     */
    public static void createFBS9100CmccPowerDataOnRam(MysqlConnPool con_pool)
    {
        String str1 = "DROP TABLE IF EXISTS " + Sql_Mysql.RamDB_CMCC_POWER_Data;
        String str2 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.RamDB_CMCC_POWER_Data
                    + " ( `num` BIGINT NOT NULL AUTO_INCREMENT, "
                    + "`dev_id` BIGINT NOT NULL DEFAULT 0, "
                    + "`vol1` float NOT NULL DEFAULT 0, "
                    + "`vol2` float NOT NULL DEFAULT 0, "
                    + "`vol3` float NOT NULL DEFAULT 0, "
                    + "`vol4` float NOT NULL DEFAULT 0, "
                    + "`vol5` float NOT NULL DEFAULT 0, "
                    + "`curr1` float NOT NULL DEFAULT 0, "
                    + "`curr2` float NOT NULL DEFAULT 0, "
                    + "`curr3` float NOT NULL DEFAULT 0, "
                    + "`curr4` float NOT NULL DEFAULT 0, "
                    + "`curr5` float NOT NULL DEFAULT 0, "
                    + " UNIQUE INDEX index_dev_id_uniq (`dev_id`), "
                    + " PRIMARY KEY (`num`) ) "
                    + " ENGINE=InnoDB DEFAULT CHARSET=utf8";
		
        Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
        try {
            sql.sqlMysqlExecute(str1);
            sql.sqlMysqlExecute(str2);
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } finally {
            sql.close_con();
        }
    }
    /***********************************************************************************/
}