package com.dev.fgcd.comm;
|
|
import java.sql.ResultSet;
|
import java.sql.SQLException;
|
import java.util.ArrayList;
|
import java.util.Date;
|
|
import com.battmonitor.base.Com;
|
import com.battmonitor.data.BattData_RT;
|
import com.battmonitor.sql.MysqlConnPool;
|
import com.battmonitor.sql.Sql_Mysql;
|
import com.dev.btse.comm.FBS9100S_SocketClient2;
|
import com.dev.btse.data.FBS9100S_NT_DCDC_Data;
|
import com.dev.btse.data.FBS9100S_NT_DCDC_State;
|
import com.dev.btse.data.FBS9100S_NiBian_Data;
|
import com.dev.btse.data.FBS9100_CMCC_Power;
|
import com.dev.btse.data.FBS9100_ComBase;
|
import com.dev.btse.data.FBS9100_ParamBatt;
|
import com.dev.btse.data.FBS9100_ParamDischarge;
|
import com.dev.btse.data.FBS9100_ParamSystem;
|
import com.dev.btse.data.FBS9100_StatAndParam;
|
import com.dev.btse.data.FBS9100_VCData;
|
import com.dev.fgcd.data.FGCD_BattTestParam;
|
import com.dev.fgcd.data.FGCD_StateAndParam;
|
import com.dev.fgcd.data.FGCD_TestFBOFile;
|
import com.dev.fgcd.data.FGCD_TestFBOFile.FBOFile;
|
|
public class FGCD_SocketClient_Thread_SQL {
|
|
/**
|
* ´´½¨ tb_fbs9100_state ±í²¢ÇÒ½«É豸idºÍÉ豸ip²åÈëµ½±íÖÐ
|
* @param con_pool
|
* @param al_param
|
*/
|
public static void createFBS9100StateTableOnRam(MysqlConnPool con_pool, ArrayList<FBS9100_StatAndParam> al_param)
|
{
|
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 = "";
|
if(al_param.size() > 0) {
|
str3 = "INSERT INTO " + Sql_Mysql.FBS9100State_Table
|
+ " (dev_ip, dev_id) VALUES";
|
}
|
for(int n=0; n<al_param.size(); n++)
|
{
|
if(n > 0) {
|
str3 += ", ";
|
}
|
str3 += " ('" + al_param.get(n).dev_ipaddr + "'," + al_param.get(n).dev_id + ")";
|
}
|
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
try {
|
sql.sqlMysqlExecute(str1);
|
sql.sqlMysqlExecute(str2);
|
if(str3.length() > 0) {
|
sql.sqlMysqlExecute(str3);
|
}
|
} catch (SQLException e) {
|
sql.logger.error("FBS9100_Task_Thread_SQL.createFBS9100StateTableOnRam():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
}
|
|
/**
|
* ²åÈë»ò¸üе±Ç°É豸״̬
|
* @param con_pool
|
* @param dev_id
|
*/
|
public static void insertFBS9100StateTableOnRam(MysqlConnPool con_pool,int dev_id) {
|
String sql_str_que = "Select * from "+ Sql_Mysql.FBS9100State_Table + " Where dev_id = " + dev_id;
|
String sql_str_ins = " INSERT INTO " + Sql_Mysql.FBS9100State_Table +
|
" (dev_id) VALUES("+dev_id+")";
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
ResultSet res = null;
|
|
try {
|
res = sql.sqlMysqlQuery(sql_str_que);
|
if(!res.next()) {
|
sql.sqlMysqlExecute(sql_str_ins);
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
} finally {
|
if(null != res) {
|
try {
|
res.close();
|
} catch (SQLException e) {
|
e.printStackTrace();
|
}
|
}
|
sql.close_con();
|
}
|
}
|
|
/**
|
* ²åÈ뵱ǰÉ豸ĬÈÏÊý¾Ý
|
* @param pool
|
* @param dev_id
|
*/
|
public static void insertTb_Fgcd_Filedownload_Table(MysqlConnPool pool,int dev_id) {
|
String sql_str = " SELECT * FROM " + Sql_Mysql.Tb_Fgcd_Filedownload_Table +
|
" WHERE dev_id = " + dev_id;
|
Sql_Mysql sql = new Sql_Mysql(pool);
|
ResultSet res = null;
|
try {
|
res = sql.sqlMysqlQuery(sql_str);
|
if(!res.next()) {
|
sql.sqlMysqlExecute(" insert into " + Sql_Mysql.Tb_Fgcd_Filedownload_Table +"(dev_id) values("+dev_id+")" );
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
} finally {
|
if(null != res) {
|
try {
|
res.close();
|
} catch (SQLException e) {
|
e.printStackTrace();
|
}
|
}
|
sql.close_con();
|
}
|
}
|
|
/**
|
* ²åÈ뵱ǰÉ豸ĬÈÏÊý¾Ý
|
* @param pool
|
* @param dev_id
|
*/
|
public static void updateTb_Fgcd_Filedownload_Table(MysqlConnPool pool,FGCD_TestFBOFile fbo) {
|
String sql_str = " UPDATE " + Sql_Mysql.Tb_Fgcd_Filedownload_Table +
|
" SET op_cmd = "+fbo.op_cmd +
|
" ,file_count = " + fbo.file_count +
|
" ,file_total = " + fbo.file_total;
|
if(fbo.files.length > 0) {
|
//µ±Ç°ÎļþÊý´óÓÚ0
|
for(int i=0;i<fbo.files.length;i++) {
|
FBOFile file = fbo.files[i];
|
sql_str += ",file_name"+(i+1)+"='"+file.filename+"'"
|
+ ",file_index"+(i+1)+"="+file.file_index
|
+ ",test_timelong"+(i+1)+"="+file.test_timelong
|
+ ",data_type"+(i+1)+"="+file.data_type
|
+ ",test_curr"+(i+1)+"="+file.test_curr
|
+ ",test_cap"+(i+1)+"="+file.test_cap
|
+ ",cap_std"+(i+1)+"="+file.cap_std
|
+ ",mon_count"+(i+1)+"="+file.mon_count
|
+ ",mon_vol"+(i+1)+"="+file.monvol_type
|
+ ",download_flag"+(i+1)+"="+file.download_flag
|
+ ",download_state"+(i+1)+"="+file.download_state
|
+ ",now_data_block"+(i+1)+"="+file.now_data_block
|
+ ",total_data_block"+(i+1)+"="+file.total_data_block
|
+ ",stop_type"+(i+1)+"="+file.teststop_reason;
|
}
|
}
|
sql_str += " where dev_id = " + fbo.dev_id;
|
Sql_Mysql sql = null;
|
try {
|
sql = new Sql_Mysql(pool);
|
sql.sqlMysqlExecute(sql_str);
|
} catch (Exception e) {
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
}
|
|
/**
|
* ¶ÁÈ¡µ±Ç°É豸״̬
|
* @param pool
|
* @param file
|
*/
|
public static void queryTb_Fgcd_Filedownload_Table(MysqlConnPool pool,FGCD_TestFBOFile file) {
|
String sql_str = " SELECT * FROM " + Sql_Mysql.Tb_Fgcd_Filedownload_Table +
|
" WHERE dev_id = " + file.dev_id;
|
Sql_Mysql sql = new Sql_Mysql(pool);
|
ResultSet res = null;
|
try {
|
res = sql.sqlMysqlQuery(sql_str);
|
if(res.next()) {
|
file.battgroupid = res.getInt("BattGroupId");
|
file.file_index = res.getInt("file_index");
|
file.op_cmd = res.getInt("op_cmd");
|
for(int i=0;i<file.files.length;i++) {
|
file.files[i].setDownload_flag(res.getInt("download_flag"+(i+1)));;
|
}
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
} finally {
|
if(null != res) {
|
try {
|
res.close();
|
} catch (SQLException e) {
|
e.printStackTrace();
|
}
|
}
|
sql.close_con();
|
}
|
}
|
|
/**
|
* ¸üе±Ç°ÏÂÔØ״̬,ÒÔ¼°Òì³£½áÊøÔÒò
|
* @param pool
|
* @param file
|
*/
|
public static void updateFgcd_Filedownload_TableCmdByDevId(MysqlConnPool pool,FGCD_TestFBOFile file) {
|
String sql_str = " UPDATE " + Sql_Mysql.Tb_Fgcd_Filedownload_Table +
|
" SET op_cmd = " + file.op_cmd +
|
" ,stop_reason = " + file.getStop_reason() +
|
" WHERE dev_id = " + file.dev_id;
|
Sql_Mysql sql = new Sql_Mysql(pool);
|
try {
|
sql.sqlMysqlExecute(sql_str);
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
}
|
|
|
/**
|
* ´´½¨ 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(64) 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, " //»ú·¿Á÷Á¿
|
+ "`batt_online_state` INT NOT NULL DEFAULT 0, " //µç³Ø״̬(0:±ÕºÏ,1£º¶Ï¿ª)
|
|
+ " 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());
|
ResultSet res = null;
|
try {
|
sql.sqlMysqlExecute(str2);
|
//ÐÞ¸´É豸É豸°æ±¾ºÅ¹ý³¤bug
|
res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
+ " WHERE table_schema='db_ram_db'"
|
+ " AND table_name='tb_fbs9100_state'"
|
+ " AND column_name='dev_version'");
|
if(true == res.next()) {
|
sql.sqlMysqlExecute("ALTER TABLE " +Sql_Mysql.FBS9100State_Table + " MODIFY COLUMN dev_version varchar(64) NOT NULL DEFAULT '';");
|
}
|
|
//Ìí¼ÓÉ豸ζÈÁÐ
|
res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
+ " WHERE table_schema='db_ram_db'"
|
+ " AND table_name='tb_fbs9100_state'"
|
+ " AND column_name='dev_temp'");
|
if(false == res.next()) {
|
sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.FBS9100State_Table
|
+ " ADD COLUMN `dev_temp` float NOT NULL DEFAULT 0;");
|
}
|
//Ìí¼ÓÄÚ×è²âÊÔ״̬ÁÐ
|
res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
+ " WHERE table_schema='db_ram_db'"
|
+ " AND table_name='tb_fbs9100_state'"
|
+ " AND column_name='dev_res_test_state'");
|
if(false == res.next()) {
|
sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.FBS9100State_Table
|
+ " ADD COLUMN `dev_res_test_state` INT NOT NULL DEFAULT 0;");
|
}
|
//Ìí¼Ódev_restest_count
|
res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
+ " WHERE table_schema='db_ram_db'"
|
+ " AND table_name='tb_fbs9100_state'"
|
+ " AND column_name='dev_restest_count'");
|
if(false == res.next()) {
|
sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.FBS9100State_Table
|
+ " ADD COLUMN `dev_restest_count` INT NOT NULL DEFAULT 0;");
|
}
|
//Ìí¼Ódev_last_captest_stop_type
|
res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
+ " WHERE table_schema='db_ram_db'"
|
+ " AND table_name='tb_fbs9100_state'"
|
+ " AND column_name='dev_last_captest_stop_type'");
|
if(false == res.next()) {
|
sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.FBS9100State_Table
|
+ " ADD COLUMN `dev_last_captest_stop_type` INT NOT NULL DEFAULT 0;");
|
}
|
|
//Ìí¼Ódev_concurr
|
res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
+ " WHERE table_schema='db_ram_db'"
|
+ " AND table_name='tb_fbs9100_state'"
|
+ " AND column_name='dev_concurr'");
|
if(false == res.next()) {
|
sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.FBS9100State_Table
|
+ " ADD COLUMN `dev_concurr` float NOT NULL DEFAULT 0;");
|
}
|
|
//Ìí¼Ódev_condvoldp ×é1µ¼Í¨Ñ¹½µ
|
res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
+ " WHERE table_schema='db_ram_db'"
|
+ " AND table_name='tb_fbs9100_state'"
|
+ " AND column_name='dev_condvoldp'");
|
if(false == res.next()) {
|
sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.FBS9100State_Table
|
+ " ADD COLUMN `dev_condvoldp` float NOT NULL DEFAULT 0;");
|
}
|
//Ìí¼Ódev_condvoldp1 ×é2µ¼Í¨Ñ¹½µ
|
res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
+ " WHERE table_schema='db_ram_db'"
|
+ " AND table_name='tb_fbs9100_state'"
|
+ " AND column_name='dev_condvoldp1'");
|
if(false == res.next()) {
|
sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.FBS9100State_Table
|
+ " ADD COLUMN `dev_condvoldp1` float NOT NULL DEFAULT 0;");
|
}
|
//Ìí¼Ódev_conresist ×é1½Ó´¥Æ÷µ¼Í¨×迹
|
res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
+ " WHERE table_schema='db_ram_db'"
|
+ " AND table_name='tb_fbs9100_state'"
|
+ " AND column_name='dev_conresist'");
|
if(false == res.next()) {
|
sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.FBS9100State_Table
|
+ " ADD COLUMN `dev_conresist` float NOT NULL DEFAULT 0;");
|
}
|
//Ìí¼Ódev_conresist ×é2½Ó´¥Æ÷µ¼Í¨×迹
|
res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
+ " WHERE table_schema='db_ram_db'"
|
+ " AND table_name='tb_fbs9100_state'"
|
+ " AND column_name='dev_conresist1'");
|
if(false == res.next()) {
|
sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.FBS9100State_Table
|
+ " ADD COLUMN `dev_conresist1` float NOT NULL DEFAULT 0 after dev_conresist;");
|
}
|
//Ìí¼Ódev_condcurr
|
res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
+ " WHERE table_schema='db_ram_db'"
|
+ " AND table_name='tb_fbs9100_state'"
|
+ " AND column_name='dev_condcurr'");
|
if(false == res.next()) {
|
sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.FBS9100State_Table
|
+ " ADD COLUMN `dev_condcurr` float NOT NULL DEFAULT 0;");
|
}
|
|
//Ìí¼Ódev_61850alarms
|
res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
+ " WHERE table_schema='db_ram_db'"
|
+ " AND table_name='tb_fbs9100_state'"
|
+ " AND column_name='dev_61850alarms'");
|
if(false == res.next()) {
|
sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.FBS9100State_Table
|
+ " ADD COLUMN `dev_61850alarms` varchar(64) NOT NULL DEFAULT '';");
|
}
|
//Ìí¼Ódev_batt_xuhang_tlong
|
res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
+ " WHERE table_schema='db_ram_db'"
|
+ " AND table_name='tb_fbs9100_state'"
|
+ " AND column_name='dev_batt_xuhang_tlong'");
|
if(false == res.next()) {
|
sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.FBS9100State_Table
|
+ " ADD COLUMN `dev_batt_xuhang_tlong` INT NOT NULL DEFAULT 0;");
|
}
|
|
//Ìí¼Ódev_station_poff_tlong
|
res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
+ " WHERE table_schema='db_ram_db'"
|
+ " AND table_name='tb_fbs9100_state'"
|
+ " AND column_name='dev_station_poff_tlong'");
|
if(false == res.next()) {
|
sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.FBS9100State_Table
|
+ " ADD COLUMN `dev_station_poff_tlong` INT NOT NULL DEFAULT 0;");
|
}
|
|
//Ìí¼Ódev_station_poff_cnt(Í£µç´ÎÊý)
|
res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
+ " WHERE table_schema='db_ram_db'"
|
+ " AND table_name='tb_fbs9100_state'"
|
+ " AND column_name='dev_station_poff_cnt'");
|
if(false == res.next()) {
|
sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.FBS9100State_Table
|
+ " ADD COLUMN `dev_station_poff_cnt` INT NOT NULL DEFAULT 0;");
|
}
|
|
|
//Ìí¼Ódev_data_flowsum(Á÷Á¿Í³¼Æ)
|
res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
+ " WHERE table_schema='db_ram_db'"
|
+ " AND table_name='tb_fbs9100_state'"
|
+ " AND column_name='dev_data_flowsum'");
|
if(false == res.next()) {
|
sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.FBS9100State_Table
|
+ " ADD COLUMN `dev_data_flowsum` BIGINT NOT NULL DEFAULT 0;");
|
}
|
//Ìí¼Óbatt_online_state(µç³Ø¿ª¹Ø״̬)
|
res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
+ " WHERE table_schema='db_ram_db'"
|
+ " AND table_name='tb_fbs9100_state'"
|
+ " AND column_name='batt_online_state'");
|
if(false == res.next()) {
|
sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.FBS9100State_Table
|
+ " ADD COLUMN `batt_online_state` INT NOT NULL DEFAULT 0;");
|
}
|
|
|
|
//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, ArrayList<FBS9100_StatAndParam> al_param)
|
{
|
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";
|
|
String str3 = "";
|
if(al_param.size() > 0) {
|
str3 = "INSERT INTO " + Sql_Mysql.FBS9100S_DcDcState_Table
|
+ " (dev_id) VALUES";
|
}
|
for(int n=0; n<al_param.size(); n++)
|
{
|
if(n > 0) {
|
str3 += ", ";
|
}
|
str3 += " (" + al_param.get(n).dev_id + ")";
|
}
|
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
try {
|
sql.sqlMysqlExecute(str1);
|
sql.sqlMysqlExecute(str2);
|
if(str3.length() > 0) {
|
sql.sqlMysqlExecute(str3);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
sql.logger.error("FBS9100_Task_Thread_SQL.createFBS9100S_DCDC_DataTableOnRam():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
}
|
|
/**
|
* ½«É豸idºÍÉ豸ip²åÈë»òÕ߸üе½±íÖÐ
|
* @param con_pool
|
* @param al_param
|
*/
|
/*
|
public static void insertorupdateFBS9100StateTableOnRam(MysqlConnPool con_pool, FBS9100_StatAndParam param)
|
{
|
String str1 = "";
|
String str2 = "";
|
String str3 = "";
|
if(param != null) {
|
str1 = "SELECT num,dev_id,dev_errcommcount,dev_commcount from " +Sql_Mysql.FBS9100State_Table+ " where dev_id = " + param.dev_id;
|
str2 = "INSERT INTO " + Sql_Mysql.FBS9100State_Table
|
+ " (dev_ip, dev_id) VALUES";
|
str2 += " ('" + param.dev_ipaddr + "'," + param.dev_id + ")";
|
|
str3 = "UPDATE " +Sql_Mysql.FBS9100State_Table+ " SET dev_ip = '"+param.dev_ipaddr+"' where dev_id = " + param.dev_id;
|
}
|
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
try {
|
if(param != null){
|
ResultSet rs = sql.sqlMysqlQuery(str1);
|
if(rs.next()){
|
param.m_FBS_VCData.m_SysState.ErrCommCount = rs.getInt("dev_errcommcount");
|
param.m_FBS_VCData.m_SysState.CommCount = rs.getInt("dev_commcount");
|
sql.sqlMysqlExecute(str3);
|
}else{
|
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, ArrayList<FBS9100_StatAndParam> al_param)
|
{
|
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, "
|
+ " UNIQUE INDEX index_dev_id_uniq (`dev_id`), "
|
+ " PRIMARY KEY (`num`) ) "
|
+ " ENGINE=MEMORY DEFAULT CHARSET=utf8";
|
|
String str3 = "";
|
if(al_param.size() > 0) {
|
str3 = "INSERT INTO " + Sql_Mysql.FBS9100SetParam_Table
|
+ " (dev_ip, dev_id) VALUES";
|
}
|
for(int n=0; n<al_param.size(); n++)
|
{
|
if(n > 0) {
|
str3 += ", ";
|
}
|
str3 += " ('" + al_param.get(n).dev_ipaddr + "'," + al_param.get(n).dev_id + ")";
|
}
|
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
try {
|
sql.sqlMysqlExecute(str1);
|
sql.sqlMysqlExecute(str2);
|
if(str3.length() > 0) {
|
sql.sqlMysqlExecute(str3);
|
}
|
} catch (SQLException e) {
|
sql.logger.error("FBS9100_Task_Thread_SQL.createFBS9100SetTestParamTableOnRam():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
}
|
|
/**
|
* ´´½¨ tb_fbs9100_system_param ±í£¬²¢ÇÒ½«É豸idºÍÉ豸ip²åÈëµ½±íÖÐ
|
* @param con_pool
|
* @param al_param
|
*/
|
public static void createFBS9100SystemParamTableOnRam(MysqlConnPool con_pool, ArrayList<FBS9100_StatAndParam> al_param)
|
{
|
String str1 = "DROP TABLE IF EXISTS " + Sql_Mysql.FBS9100SysParam_Table;
|
String str2 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.FBS9100SysParam_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, "
|
+ "`IPADDR` varchar(20) NOT NULL DEFAULT '127.0.0.0', "
|
+ "`SubIPADDR` varchar(20) NOT NULL DEFAULT '127.0.0.0', "
|
+ "`NetGateADDR` varchar(20) NOT NULL DEFAULT '127.0.0.0', "
|
+ "`GroupVolRange` INT NOT NULL DEFAULT 0, "
|
+ "`GroupVolSorce` INT NOT NULL DEFAULT 0, "
|
+ "`CurrentRange` INT NOT NULL DEFAULT 0, "
|
+ "`CurrentTyte` INT NOT NULL DEFAULT 0, "
|
+ "`MonomerOrder` INT NOT NULL DEFAULT 0, "
|
+ "`BackLightTime` INT NOT NULL DEFAULT 0, "
|
+ "`MACADDR` varchar(30) NOT NULL DEFAULT '0.0.0.0.0.0', "
|
+ "`LoaderCount` INT NOT NULL DEFAULT 0, "
|
+ "`DtCardCount` INT NOT NULL DEFAULT 0, "
|
+ "`PowerBreakChargeCurr` FLOAT NOT NULL DEFAULT 0, "
|
+ "`MajorBattGroupNum` INT NOT NULL DEFAULT 0, "
|
+ "`POF_BG_Boost_Cnt` INT NOT NULL DEFAULT 0, "
|
+ "`POF_BG_Boost_VolStop` FLOAT NOT NULL DEFAULT 0, "
|
+ "`POF_BG_Boost_VolStart` FLOAT NOT NULL DEFAULT 0, "
|
+ " UNIQUE INDEX index_dev_id_uniq (`dev_id`), "
|
+ " PRIMARY KEY (`num`) ) "
|
+ " ENGINE=MEMORY DEFAULT CHARSET=utf8";
|
|
String str3 = "";
|
if(al_param.size() > 0) {
|
str3 = "INSERT INTO " + Sql_Mysql.FBS9100SysParam_Table
|
+ " (dev_ip, dev_id) VALUES";
|
}
|
for(int n=0; n<al_param.size(); n++)
|
{
|
if(n > 0) {
|
str3 += ", ";
|
}
|
str3 += " ('" + al_param.get(n).dev_ipaddr + "'," + al_param.get(n).dev_id + ")";
|
}
|
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
try {
|
sql.sqlMysqlExecute(str1);
|
sql.sqlMysqlExecute(str2);
|
if(str3.length() > 0) {
|
sql.sqlMysqlExecute(str3);
|
}
|
} catch (SQLException e) {
|
sql.logger.error("FBS9100_Task_Thread_SQL.createFBS9100SystemParamTableOnRam():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
}
|
|
/**
|
* ½«É豸idºÍÉ豸ip²åÈë»òÕ߸üе½±íÖÐ
|
* @param con_pool
|
* @param al_param
|
*/
|
/*
|
public static void insertorupdateFBS9100SetTestParamTableOnRam(MysqlConnPool con_pool, FBS9100_StatAndParam param)
|
{
|
String str1 = "";
|
String str2 = "";
|
String str3 = "";
|
if(param != null) {
|
str1 = "SELECT num,dev_id from " +Sql_Mysql.FBS9100SetParam_Table+ " where dev_id = " + param.dev_id;
|
|
str2 = "INSERT INTO " + Sql_Mysql.FBS9100SetParam_Table
|
+ " (dev_ip, dev_id) VALUES";
|
|
str2 += " ('" + param.dev_ipaddr + "'," + param.dev_id + ")";
|
|
str3 = "UPDATE " +Sql_Mysql.FBS9100SetParam_Table+ " SET dev_ip = '"+param.dev_ipaddr+"' where dev_id = " + param.dev_id;
|
}
|
|
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
try {
|
if(param != null){
|
ResultSet rs = sql.sqlMysqlQuery(str1);
|
if(rs.next()){
|
sql.sqlMysqlExecute(str3);
|
}else{
|
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, ArrayList<FBS9100_StatAndParam> al_param)
|
{
|
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";
|
|
String str3 = "";
|
if(al_param.size() > 0) {
|
str3 = "INSERT INTO " + Sql_Mysql.RamDB_CMCC_POWER_Data
|
+ " (dev_id) VALUES";
|
}
|
for(int n=0; n<al_param.size(); n++)
|
{
|
if(n > 0) {
|
str3 += ", ";
|
}
|
str3 += " (" + al_param.get(n).dev_id + ")";
|
}
|
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
try {
|
sql.sqlMysqlExecute(str1);
|
sql.sqlMysqlExecute(str2);
|
if(str3.length() > 0) {
|
sql.sqlMysqlExecute(str3);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
sql.logger.error("FBS9100_Task_Thread_SQL.createFBS9100CmccPowerDataOnRam():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
}
|
|
/**
|
* ½«É豸idºÍÉ豸ip²åÈë»òÕ߸üе½±íÖÐ
|
* @param con_pool
|
* @param al_param
|
*/
|
/*
|
public static void insertorupdateFBS9100CmccPowerDataTableOnRam(MysqlConnPool con_pool, FBS9100_StatAndParam param)
|
{
|
String str1 = "";
|
String str2 = "";
|
if(param != null) {
|
str1 = "SELECT num,dev_id from " +Sql_Mysql.RamDB_CMCC_POWER_Data+ " where dev_id = " + param.dev_id;
|
str2 = "INSERT INTO " + Sql_Mysql.RamDB_CMCC_POWER_Data
|
+ " (dev_id) VALUES";
|
str2 += " (" + param.dev_id + ")";
|
}
|
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
try {
|
if(param != null) {
|
ResultSet rs = sql.sqlMysqlQuery(str1);
|
if(false == rs.next()) {
|
sql.sqlMysqlExecute(str2);
|
}
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
}
|
*/
|
/***********************************************************************************/
|
/**
|
* ´´½¨ Sql_Mysql.AppDevCommTask_Table ±í²¢ÇÒ½«É豸id²åÈëµ½±íÖÐ
|
* @param con_pool
|
* @param al_param
|
*/
|
public static void createBTSCommTaskStateTable(MysqlConnPool con_pool)
|
{
|
String str1 = "DROP TABLE IF EXISTS " + Sql_Mysql.AppDevCommTask_Table;
|
String str2 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.AppDevCommTask_Table
|
+ " ( `num` BIGINT NOT NULL AUTO_INCREMENT, "
|
+ "`thread_id` BIGINT NOT NULL DEFAULT 0, "
|
+ "`dev_id` BIGINT NOT NULL DEFAULT 0, "
|
+ "`dev_mcu_uid` varchar(48) NOT NULL DEFAULT 'null',"
|
+ "`battgroup_cnt` INT NOT NULL DEFAULT 0, "
|
+ "`battgroup_id1` INT NOT NULL DEFAULT 0, "
|
+ "`battgroup_index1` INT NOT NULL DEFAULT 0, "
|
+ "`battgroup_id2` INT NOT NULL DEFAULT 0, "
|
+ "`battgroup_index2` INT NOT NULL DEFAULT 0, "
|
+ "`battgroup_id3` INT NOT NULL DEFAULT 0, "
|
+ "`battgroup_index3` INT NOT NULL DEFAULT 0, "
|
+ "`battgroup_id4` INT NOT NULL DEFAULT 0, "
|
+ "`battgroup_index4` INT NOT NULL DEFAULT 0, "
|
+ "`connet_time` varchar(20) NOT NULL DEFAULT '1980-01-01 01:01:00', "
|
+ "`dev_comm_runtime` varchar(20) NOT NULL DEFAULT '1980-01-01 01:01:00', "
|
+ "`break_type` INT NOT NULL DEFAULT 0, "
|
+ " 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
|
sql.logger.error("FBS9100_Task_Thread_SQL.createBTSCommTaskStateTable():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
}
|
/***********************************************************************************/
|
/***********************************************************************************/
|
/**
|
* ´´½¨ Sql_Mysql.AppDevBattGroup_Table ±í²¢ÇÒ½«É豸id²åÈëµ½±íÖÐ
|
* @param con_pool
|
* @param al_param
|
*/
|
public static void createBTS_BattGroupState_Table(MysqlConnPool con_pool)
|
{
|
String str1 = "DROP TABLE IF EXISTS " + Sql_Mysql.AppDevBattGroup_Table;
|
String str2 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.AppDevBattGroup_Table
|
+ " ( `num` BIGINT NOT NULL AUTO_INCREMENT, "
|
+ "`dev_id` BIGINT NOT NULL DEFAULT 0, "
|
+ "`battgroup_id` INT NOT NULL DEFAULT 0, "
|
+ "`battgroup_index` INT NOT NULL DEFAULT -1, "
|
+ "`battgroup_mon_cnt` INT NOT NULL DEFAULT 0, "
|
+ "`battgroup_float_vol` float NOT NULL DEFAULT 0, "
|
+ "`battgroup_float_curr` float NOT NULL DEFAULT 0, "
|
+ "`battgroup_register_code` varchar(48) NOT NULL DEFAULT 'null', "
|
+ " 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
|
sql.logger.error("FBS9100_Task_Thread_SQL.createBTS_BattGroupState_Table():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
}
|
/***********************************************************************************/
|
/**
|
* ¸ù¾ÝÉ豸id¸üРtb_bts_battgoup_inf ±í
|
* @param con_pool
|
* @param dev_id
|
*/
|
public static void insert_BTS_BattGroupState_Table(MysqlConnPool con_pool, int dev_id, int bg_id,
|
int bg_index, int mon_cnt, float f_vol, float f_curr,
|
String reg_code)
|
{
|
String sql_str_insert = "INSERT INTO " + Sql_Mysql.AppDevBattGroup_Table
|
+ " ( "
|
+ "dev_id,"
|
+ "battgroup_id,"
|
+ "battgroup_index,"
|
+ "battgroup_mon_cnt,"
|
+ "battgroup_float_vol,"
|
+ "battgroup_float_curr,"
|
+ "battgroup_register_code"
|
+ " ) "
|
+ " VALUES "
|
+ " ( "
|
+ dev_id + ", "
|
+ bg_id + ", "
|
+ bg_index + ", "
|
+ mon_cnt + ", "
|
+ f_vol + ", "
|
+ f_curr + ", "
|
+ "'" + reg_code + "'"
|
+ " ) ";
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
try {
|
//sql.logger.debug(sql_str_insert);
|
sql.sqlMysqlExecute(sql_str_insert);
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
sql.logger.error("FBS9100_Task_Thread_SQL.insert_BTS_BattGroupState_Table():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
}
|
/***********************************************************************************/
|
/***********************************************************************************/
|
/**
|
* ¸ù¾ÝÉ豸id¸üРtb_bts_battgoup_inf ±í
|
* @param con_pool
|
* @param dev_id
|
*/
|
public static void update_BTS_BattGroupState_Table(MysqlConnPool con_pool, int dev_id, int bg_id,
|
int bg_index, int mon_cnt, float f_vol, float f_curr,
|
String reg_code)
|
{
|
String sql_str_insert = "UPDATE " + Sql_Mysql.AppDevBattGroup_Table
|
+ " SET "
|
+ "battgroup_index=" + bg_index + ","
|
+ "battgroup_mon_cnt=" + mon_cnt + ","
|
+ "battgroup_float_vol=" + f_vol + ","
|
+ "battgroup_float_curr=" + f_curr + ","
|
+ "battgroup_register_code='" + reg_code + "'"
|
+ " WHERE "
|
+ " dev_id=" + dev_id + " AND battgroup_id=" + bg_id;
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
try {
|
//sql.logger.debug(sql_str_insert);
|
sql.sqlMysqlExecute(sql_str_insert);
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
}
|
/***********************************************************************************/
|
/**
|
* ¸ù¾ÝÉ豸id¸üРtb_bts_commtask_state ±í
|
* @param con_pool
|
* @param dev_id
|
*/
|
public static void insertBTSCommTaskStateByDev_Id(MysqlConnPool con_pool, long thread_id, int dev_id, String mcu_uid,
|
int bg_cnt, int bg_id_1, int bg_id_2, int bg_id_3, int bg_id_4,
|
int bg_index1, int bg_index2, int bg_index3, int bg_index4,
|
String connet_time, String dev_comm_runtime,
|
int break_type)
|
{
|
String sql_str_insert = "INSERT INTO " + Sql_Mysql.AppDevCommTask_Table
|
+ " ( "
|
+ "thread_id,"
|
+ "dev_id,"
|
+ "dev_mcu_uid,"
|
+ "battgroup_cnt,"
|
+ "battgroup_id1,"
|
+ "battgroup_index1,"
|
+ "battgroup_id2,"
|
+ "battgroup_index2,"
|
+ "battgroup_id3,"
|
+ "battgroup_index3,"
|
+ "battgroup_id4,"
|
+ "battgroup_index4,"
|
+ "connet_time,"
|
+ "dev_comm_runtime,"
|
+ "break_type"
|
+ " ) "
|
+ " VALUES "
|
+ " ( "
|
+ thread_id + ", "
|
+ dev_id + ", "
|
+ "'" + mcu_uid + "', "
|
+ bg_cnt + ", "
|
+ bg_id_1 + ", "
|
+ bg_index1 + ", "
|
+ bg_id_2 + ", "
|
+ bg_index2 + ", "
|
+ bg_id_3 + ", "
|
+ bg_index3 + ", "
|
+ bg_id_4 + ", "
|
+ bg_index4 + ", "
|
+ "'" + connet_time + "', "
|
+ "'" + dev_comm_runtime + "', "
|
+ break_type
|
+ " ) ";
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
try {
|
//sql.logger.debug(sql_str);
|
sql.sqlMysqlExecute(sql_str_insert);
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
sql.logger.error("FBS9100_Task_Thread_SQL.insertBTSCommTaskStateByDev_Id():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
}
|
/***********************************************************************************/
|
/**
|
* ¸ù¾ÝÉ豸id¸üРtb_bts_commtask_state ±í
|
* @param con_pool
|
* @param dev_id
|
*/
|
public static void updateBTSCommTaskStateRunTimeByThread_Id(MysqlConnPool con_pool, long thread_id)
|
{
|
String sql_str_update = "UPDATE " + Sql_Mysql.AppDevCommTask_Table
|
+ " SET dev_comm_runtime='" + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms) + "' "
|
+ " WHERE thread_id=" + thread_id;
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
try {
|
//sql.logger.debug(sql_str);
|
sql.sqlMysqlExecute(sql_str_update);
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
sql.logger.error("FBS9100_Task_Thread_SQL.updateBTSCommTaskStateRunTimeByThread_Id():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
}
|
/***********************************************************************************/
|
/**
|
* ¸ù¾ÝÉ豸id¸üРtb_bts_commtask_state ±í
|
* @param con_pool
|
* @param dev_id
|
*/
|
public static void deleteBTSCommTaskStateByThread_Id(MysqlConnPool con_pool, long thread_id)
|
{
|
String sql_str_del = "DELETE FROM " + Sql_Mysql.AppDevCommTask_Table + " WHERE thread_id=" + thread_id;
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
try {
|
//sql.logger.debug(sql_str);
|
sql.sqlMysqlExecute(sql_str_del);
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
sql.logger.error("FBS9100_Task_Thread_SQL.deleteBTSCommTaskStateByThread_Id():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
}
|
/***********************************************************************************/
|
public static void deleteBTSCommTaskStateByDev_Id(MysqlConnPool con_pool, FBS9100_StatAndParam param)
|
{
|
String sql_str_del = "DELETE FROM " + Sql_Mysql.AppDevCommTask_Table
|
+ " WHERE "
|
+ " dev_id=" + param.dev_id
|
+ " AND "
|
+ " dev_mcu_uid='" + param.dev_reg_code.trim() + "'";
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
try {
|
//sql.logger.debug(sql_str);
|
sql.sqlMysqlExecute(sql_str_del);
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
sql.logger.error("FBS9100_Task_Thread_SQL.deleteBTSCommTaskStateByDev_Id():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
}
|
/***********************************************************************************/
|
/**
|
* ¸ù¾ÝÉ豸id¸üРtb_cmcc_power_data ±í
|
* @param con_pool
|
* @param v_data
|
* @param dev_id
|
*/
|
public static void updateFbs9100CmccPowerDataByDev_Id(MysqlConnPool con_pool, FBS9100_CMCC_Power cmcc_data, int dev_id)
|
{
|
String sql_str_base = Sql_Mysql.RamDB_CMCC_POWER_Data
|
+ " SET "
|
+ "dev_id=" + dev_id + ", "
|
+ "vol1=" + cmcc_data.Vol[0] + ", "
|
+ "vol2=" + cmcc_data.Vol[1] + ", "
|
+ "vol3=" + cmcc_data.Vol[2] + ", "
|
+ "vol4=" + cmcc_data.Vol[3] + ", "
|
+ "vol5=" + cmcc_data.Vol[4] + ", "
|
+ "curr1=" + cmcc_data.Curr[0] + ", "
|
+ "curr2=" + cmcc_data.Curr[1] + ", "
|
+ "curr3=" + cmcc_data.Curr[2] + ", "
|
+ "curr4=" + cmcc_data.Curr[3] + ", "
|
+ "curr5=" + cmcc_data.Curr[4];
|
//+ " WHERE dev_id=" + dev_id;
|
//String sql_str_update = "UPDATE " + sql_str_base;
|
String sql_str_replace = "REPLACE INTO " + sql_str_base;
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
try {
|
//sql.logger.debug(sql_str);
|
sql.sqlMysqlExecute(sql_str_replace);
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
sql.logger.error("FBS9100_Task_Thread_SQL.updateFbs9100CmccPowerDataByDev_Id():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
}
|
/***********************************************************************************/
|
public static int getFbs9100StationState_ById(MysqlConnPool con_pool, FBS9100_StatAndParam m_pm)
|
{
|
String sql_str_base = "SELECT station_stat FROM " + Sql_Mysql.BTSStationState_Table
|
+ " WHERE dev_id=" + m_pm.dev_id;
|
int state_t = 0;
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
try {
|
//sql.logger.debug(sql_str);
|
ResultSet res = sql.sqlMysqlQuery(sql_str_base);
|
if(res.next()) {
|
state_t = res.getInt("station_stat");
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
sql.logger.error("FBS9100_Task_Thread_SQL.getFbs9100StationState_ById():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
|
return state_t;
|
}
|
/***********************************************************************************/
|
public static long getFbs9100DataCommFlowSum_ById(MysqlConnPool con_pool, FGCD_StateAndParam m_pm)
|
{
|
String sql_str_base = "SELECT dev_data_flowsum FROM " + Sql_Mysql.FBS9100State_Table
|
+ " WHERE dev_id=" + m_pm.dev_id;
|
long flow_sum = 0;
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
try {
|
//sql.logger.debug(sql_str);
|
ResultSet res = sql.sqlMysqlQuery(sql_str_base);
|
if(res.next()) {
|
flow_sum = res.getLong("dev_data_flowsum");
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
sql.logger.error("FGCD_SocketClient_Thread_SQL.getFbs9100DataCommFlowSum_ById():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
|
return flow_sum;
|
}
|
/***********************************************************************************/
|
public static void updateFbs9100StateOnlyByDev_Id(MysqlConnPool con_pool, FGCD_StateAndParam m_pm)
|
{
|
String sql_str_sel = "SELECT dev_res_test_state,dev_alarmstate " +
|
" FROM " + Sql_Mysql.FBS9100State_Table +
|
" WHERE dev_id = " + m_pm.dev_id;
|
|
ResultSet res = null;
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
int dev_alarm_state = 0;
|
try {
|
//sql.logger.debug(sql_str);
|
res = sql.sqlMysqlQuery(sql_str_sel); //²éѯµ±Ç°É豸µÄËø¶¨×´Ì¬
|
if(res.next()) {
|
m_pm.sysState.tmp_alm_lock = res.getInt("dev_res_test_state");
|
dev_alarm_state = res.getInt("dev_alarmstate");
|
}
|
m_pm.sysState.checkTmpAlmState(dev_alarm_state);
|
String sql_str_base = Sql_Mysql.FBS9100State_Table
|
+ " SET "
|
+ "dev_id=" + m_pm.dev_id + ", "
|
+ "dev_ip='" + m_pm.dev_ipaddr + "', "
|
+ "dev_version='" + m_pm.m_DevVersion + "', "
|
+ "record_datetime="
|
+ "'" + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms) + "',"
|
+ "dev_datetime='" + m_pm.sysState.chageDate+ "', "
|
+ "dev_testtype=" + m_pm.sysState.btnState+ ", "
|
+ "dev_captest_onlinevol=" + m_pm.sysState.on_online_vol+ ", "
|
+ "dev_captest_groupvol=" + m_pm.sysState.on_group_vol+ ", "
|
+ "batt_online_state=" + m_pm.sysState.diode_state+ ", "
|
+ "dev_temp=" + m_pm.sysState.devtmp + ", "
|
+ "dev_res_test_state=" + m_pm.sysState.tmp_alm_lock + ", "
|
+ "dev_workstate=" + m_pm.sysState.dev_workstate + ", "
|
+ "dev_captest_curr=" + m_pm.sysState.chargeCurr + ", "
|
|
+ "dev_restest_monindex=" + m_pm.sysState.hhProgress + ", " //»î»¯½ø¶È
|
+ "dev_restest_moncount=" + m_pm.sysState.hhCount + ", " //»î»¯´ÎÊý
|
+ "dev_batt_xuhang_tlong=" + m_pm.sysState.hhstate + ", " //»î»¯×´Ì¬
|
+ "dev_captest_timelong=" + m_pm.sysState.test_timelong + ", " //ÏÔʾÆÁ²âÊÔʱ³¤
|
+ "dev_eachgroup_battsum=" + m_pm.sysState.char_phase + ", " //³äµç½×¶ÎÊý
|
|
+ "dev_last_captest_stop_type=" + m_pm.sysState.dev_captest_stop_type + ", "
|
+ "dev_captest_cap=" + m_pm.sysState.testCap + ", "
|
|
/***
|
* 2022-01-17ÐÂÔöÔÚÏßÄ£¿éÐÅÏ¢[Çл»µç³Ø×éºóÐèÁ¢¼´¶ÁÈ¡µ±Ç°×´Ì¬]
|
*/
|
//+ "dev_conresist=" + m_pm.onlineInfo.batt1_vol + ", " //µç³Ø×é1µçѹ
|
//+ "dev_conresist1=" + m_pm.onlineInfo.batt2_vol + ", " //µç³Ø×é2µçѹ
|
//+ "dev_onlinevollow=" + m_pm.onlineInfo.currBattNum + ", " //µ±Ç°µç³Ø×éºÅ 0->δÉèÖÃ;1->µç³Ø×é1;2->µç³Ø×é2
|
//+ "dev_station_poff_cnt=" + m_pm.onlineInfo.endoscopeState + ", " //ÄÚ¿ú¾µ×´Ì¬ 0->Í£Ö¹ÏÔʾ 1->¿ªÊ¼ÏÔʾ
|
|
+ "dev_data_flowsum=" + m_pm.sysState.dev_data_flowsum+ ", "
|
+ "dev_commcount=" + m_pm.sysState.dev_commcount+ ", "
|
+ "dev_errcommcount=" + m_pm.sysState.dev_errcommcount;
|
if((m_pm.sysState.dev_captest_stop_type>=0) && (m_pm.sysState.dev_captest_stop_type<50)) {
|
sql_str_base += ", ";
|
sql_str_base += "dev_last_captest_stop_type=" + m_pm.sysState.dev_captest_stop_type;
|
}
|
if(m_pm.sysState.dev_alarm == 1) {
|
//¸üе±Ç°×´Ì¬
|
sql.sqlMysqlExecute(" update " + Sql_Mysql.FBS9100State_Table +" Set dev_alarmstate = "+m_pm.sysState.dev_alarm+" where dev_id = "+m_pm.dev_id+" AND dev_alarmstate != 2" );
|
}else {
|
//¸üе±Ç°¸æ¾¯×´Ì¬
|
sql.sqlMysqlExecute(" update " + Sql_Mysql.FBS9100State_Table +" Set dev_alarmstate = "+m_pm.sysState.dev_alarm+" where dev_id = "+m_pm.dev_id);
|
}
|
|
String sql_str_update = "UPDATE " + sql_str_base + " WHERE dev_id=" + m_pm.dev_id;
|
sql.sqlMysqlExecute(sql_str_update);
|
} catch (SQLException e) {
|
sql.logger.error("FGCD_SocketClient_Thread_SQL.updateFbs9100StateOnlyByDev_Id():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
}
|
|
/**
|
* ¸üÐÂÔÚÏßÄ£¿éÐÅÏ¢
|
* @param con_pool
|
* @param m_pm
|
*/
|
public static void updateFbs9100StateOnlineMode(MysqlConnPool con_pool, FGCD_StateAndParam m_pm)
|
{
|
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
try {
|
String sql_str_base = Sql_Mysql.FBS9100State_Table
|
+ " SET "
|
/***
|
* 2022-01-17ÐÂÔöÔÚÏßÄ£¿éÐÅÏ¢
|
*/
|
+ "dev_conresist=" + m_pm.onlineInfo.batt1_vol + ", " //µç³Ø×é1µçѹ
|
+ "dev_conresist1=" + m_pm.onlineInfo.batt2_vol + ", " //µç³Ø×é2µçѹ
|
+ "dev_onlinevollow=" + m_pm.onlineInfo.currBattNum + ", " //µ±Ç°µç³Ø×éºÅ 0->δÉèÖÃ;1->µç³Ø×é1;2->µç³Ø×é2
|
+ "dev_station_poff_cnt=" + m_pm.onlineInfo.endoscopeState + " "; //ÄÚ¿ú¾µ×´Ì¬ 0->Í£Ö¹ÏÔʾ 1->¿ªÊ¼ÏÔʾ
|
|
String sql_str_update = "UPDATE " + sql_str_base + " WHERE dev_id=" + m_pm.dev_id;
|
sql.sqlMysqlExecute(sql_str_update);
|
} catch (SQLException e) {
|
sql.logger.error("FGCD_SocketClient_Thread_SQL.updateFbs9100StateOnlineMode():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
}
|
/***********************************************************************************/
|
/**
|
* ¸ù¾ÝÉ豸id¸üРtb_fbs9100_state ±í
|
* @param con_pool
|
* @param v_data
|
* @param dev_id
|
*/
|
public static void updateFbs9100StateByDev_Id(MysqlConnPool con_pool, FBS9100_VCData vc_data, FBS9100_StatAndParam m_pm)
|
{
|
int TestGroup_index = m_pm.m_SysState.TestGroupNum;
|
if(TestGroup_index > 0) {
|
TestGroup_index -= 1;
|
}
|
if((TestGroup_index>=FBS9100_ComBase.BattGroupCountMax) || (TestGroup_index<0)) {
|
TestGroup_index = 0;
|
}
|
|
int batt_online_state = 0;
|
if(true == m_pm.m_SysState.BG_1_IsOFFLine) {
|
batt_online_state |= (1<<1);
|
}
|
if(true == m_pm.m_SysState.BG_2_IsOFFLine) {
|
batt_online_state |= (1<<2);
|
}
|
if(true == m_pm.m_SysState.SD_Card_Err) {
|
batt_online_state |= (1<<5);
|
}
|
|
String sql_str_base = Sql_Mysql.FBS9100State_Table
|
+ " SET "
|
+ "dev_id=" + m_pm.dev_id + ", "
|
+ "dev_ip='" + m_pm.dev_ipaddr + "', "
|
+ "dev_version='" + m_pm.m_DevVersion + "', "
|
+ "record_datetime="
|
+ "'" + Com.getDateTimeFormat(m_pm.m_SysState.Record_DateTime, Com.DTF_YMDhms) + "',"
|
+ "dev_datetime='" + m_pm.m_SysState.DTime.year + "-"
|
+ m_pm.m_SysState.DTime.month + "-"
|
+ m_pm.m_SysState.DTime.day + " "
|
+ m_pm.m_SysState.DTime.hour + ":"
|
+ m_pm.m_SysState.DTime.minute + ":"
|
+ m_pm.m_SysState.DTime.second + "', "
|
+ "dev_testtype=" + m_pm.m_SysState.TestType+ ", "
|
+ "dev_testgroupnum=" + m_pm.m_SysState.TestGroupNum + ", "
|
+ "dev_workstate=" + m_pm.m_SysState.WorkState + ", "
|
+ "dev_alarmstate=" + m_pm.m_SysState.AlarmState + ", "
|
+ "dev_temp=" + vc_data.batttemp[0] + ", "
|
+ "dev_res_test_state=" + m_pm.m_SysState.ResTestState + ", "
|
+ "dev_onlinevollow=" + (1==m_pm.m_SysState.OnlineVolLow) + ", "
|
+ "dev_captest_onlinevol=" + vc_data.onlinevol[TestGroup_index] + ", "
|
+ "dev_captest_groupvol=" + vc_data.groupvol[TestGroup_index] + ", "
|
+ "dev_captest_curr=" + vc_data.battcurr[TestGroup_index] + ", "
|
+ "dev_captest_cap=" + vc_data.battcap[TestGroup_index] + ", "
|
+ "dev_conresist=" + vc_data.conresist + ", "
|
+ "dev_conresist1=" + vc_data.conresist1 + ", "
|
+ "dev_condvoldp=" + vc_data.condvoldp + ", "
|
+ "dev_condvoldp1=" + vc_data.condvoldp1 + ", "
|
+ "dev_captest_timelong=" + vc_data.testTime.getSecondCount() + ", "
|
+ "dev_restest_count=" + m_pm.m_SysState.ResTestCnt + ", "
|
+ "dev_restest_monindex=" + m_pm.m_SysState.ResBattIndex + ", "
|
+ "dev_restest_moncount=" + m_pm.m_SysState.ResBattIndexMax + ", "
|
+ "dev_data_flowsum=" + m_pm.dev_comm_data_flowsum + ", "
|
+ "batt_online_state=" + batt_online_state + ", "
|
+ "dev_commcount=" + m_pm.m_SysState.CommCount + ", "
|
+ "dev_errcommcount=" + m_pm.m_SysState.ErrCommCount + ", "
|
+ "dev_rxnullerrcount=" + m_pm.m_SysState.RxNullErrCount;
|
if((m_pm.m_SysState.CapTestStopType>=0) && (m_pm.m_SysState.CapTestStopType<50)) {
|
sql_str_base += ", ";
|
sql_str_base += "dev_last_captest_stop_type=" + m_pm.m_SysState.CapTestStopType;
|
}
|
|
String sql_str_replace = "REPLACE INTO " + sql_str_base;
|
//String sql_str_update = "UPDATE " + Sql_Mysql.FBS9100State_Table + " SET dev_data_flowsum=dev_data_flowsum+"
|
// + v_data.dev_comm_data_flowsum + " WHERE dev_id=" + m_pm.dev_id;
|
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
try {
|
//sql.logger.debug(sql_str);
|
sql.sqlMysqlExecute(sql_str_replace);
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
sql.logger.error("FBS9100_Task_Thread_SQL.updateFbs9100StateByDev_Id():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
}
|
/***********************************************************************************/
|
/*
|
public static void updateFbs9100State_ResTestCNT_ByDev_Id(MysqlConnPool con_pool, FBS9100_StatAndParam m_pm)
|
{
|
String sql_str = "UPDATE " + Sql_Mysql.FBS9100State_Table
|
+ " SET "
|
+ "record_datetime="
|
+ "'" + Com.getDateTimeFormat(m_pm.m_FBS_VCData.m_SysState.Record_DateTime, Com.DTF_YMDhms) + "', "
|
+ "dev_restest_count=" + m_pm.m_FBS_VCData.m_SysState.ResTestCnt
|
+ " WHERE dev_id=" + m_pm.dev_id;
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
try {
|
System.out.println(sql_str);
|
sql.sqlMysqlExecute(sql_str);
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
}
|
*/
|
/***********************************************************************************/
|
public static int queryBTS_DCDC_AlarmStat(MysqlConnPool con_pool, int dev_id, FBS9100S_NT_DCDC_State[] dcdc_stat)
|
{
|
String sql_str = "SELECT dcdc_SMR_Alarm1,dcdc_ModeSetComm,dcdc_RunSetComm "
|
+ " FROM " + Sql_Mysql.FBS9100S_DcDcState_Table + " WHERE dev_id=" + dev_id;
|
int test_cnt = 0;
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
ResultSet res = sql.sqlMysqlQuery(sql_str);
|
try {
|
int index_t = 0;
|
while(res.next()) {
|
if(index_t < dcdc_stat.length) {
|
dcdc_stat[index_t].SMR_Alarm1 = res.getInt("dcdc_SMR_Alarm1");
|
dcdc_stat[index_t].ModeSetComm = res.getInt("dcdc_ModeSetComm");
|
dcdc_stat[index_t].RunSetComm = res.getInt("dcdc_RunSetComm");
|
index_t += 1;
|
}
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
sql.logger.error("FBS9100_Task_Thread_SQL.queryBTS_DCDC_AlarmStat():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
|
return test_cnt;
|
}
|
/**
|
* ¸ù¾ÝÉ豸id¸üРtb_fbs9100s_dcdc_data ±í
|
* @param con_pool
|
* @param v_data
|
* @param dev_id
|
*/
|
public static void updateFbs9100S_DCDC_Data_ByDev_Id(MysqlConnPool con_pool,
|
FBS9100S_NT_DCDC_Data[] dcdc_data, int dev_id)
|
{
|
for(int n=0; n<dcdc_data.length; n++) {
|
if(0 == dcdc_data[n].Version) {
|
continue;
|
}
|
|
String sql_str_base = Sql_Mysql.FBS9100S_DcDcState_Table
|
+ " SET "
|
+ "dev_id=" + dev_id + ", "
|
+ "dcdc_num=" + ((dev_id%1000000)*10 + (n+1)) + ", "
|
+ "dcdc_Vsys=" + dcdc_data[n].Vsys + ", "
|
+ "dcdc_Vout=" + dcdc_data[n].Vout + ", "
|
+ "dcdc_Vbat=" + dcdc_data[n].Vbat + ", "
|
+ "dcdc_Iout=" + dcdc_data[n].Iout + ", "
|
+ "dcdc_Ibuck=" + dcdc_data[n].Ibuck + ", "
|
+ "dcdc_Tmp_Dis=" + dcdc_data[n].Tmp_Dis + ", "
|
+ "dcdc_Tmp_Chr=" + dcdc_data[n].Tmp_Chr + ", "
|
+ "dcdc_SMR_Alarm1=" + dcdc_data[n].SMR_Alarm1 + ", "
|
+ "dcdc_SMR_Alarm2=" + dcdc_data[n].SMR_Alarm2 + ", "
|
+ "dcdc_version=" + dcdc_data[n].Version + ", "
|
+ "dcdc_ModeSetComm=" + dcdc_data[n].ModeSetComm + ", "
|
+ "dcdc_RunSetComm=" + dcdc_data[n].RunSetComm + ", "
|
+ "dcdc_BuckISet=" + dcdc_data[n].SetBuckI + ", "
|
+ "dcdc_DisVolSet=" + dcdc_data[n].SetDisVol + ", "
|
+ "dcdc_DisCurrSet=" + dcdc_data[n].SetDisCurr + ", "
|
+ "dcdc_CommTxCnt=" + dcdc_data[n].CommTxCnt + ", "
|
+ "dcdc_CommRxCnt=" + dcdc_data[n].CommRxCnt;
|
|
String sql_str_replace = "REPLACE INTO " + sql_str_base;
|
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
try {
|
//sql.logger.debug(sql_str);
|
sql.sqlMysqlExecute(sql_str_replace);
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
sql.logger.error("FBS9100_Task_Thread_SQL.updateFbs9100S_DCDC_Data_ByDev_Id():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
}
|
}
|
/***********************************************************************************/
|
/**
|
* ¸ù¾ÝÉ豸id¸üРtb_fbs9100s_dcdc_data ±í
|
* @param con_pool
|
* @param v_data
|
* @param dev_id
|
*/
|
public static void resetFbs9100S_DCDC_Data_ByDev_Id(MysqlConnPool con_pool, int dev_id)
|
{
|
String sql_str_base = Sql_Mysql.FBS9100S_DcDcState_Table
|
+ " SET "
|
+ "dcdc_ModeSetComm=" + 0 + ", "
|
+ "dcdc_RunSetComm=" + 0;
|
|
String sql_str_update = "UPDATE " + sql_str_base + " WHERE dev_id=" + dev_id;
|
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
try {
|
//sql.logger.debug(sql_str);
|
sql.sqlMysqlExecute(sql_str_update);
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
sql.logger.error("FBS9100_Task_Thread_SQL.resetFbs9100S_DCDC_Data_ByDev_Id():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
}
|
/***********************************************************************************/
|
/***********************************************************************************/
|
public static int queryFBS9100_ResTestCnt(MysqlConnPool con_pool, int dev_id)
|
{
|
String sql_str = "SELECT dev_restest_count FROM " + Sql_Mysql.FBS9100State_Table + " WHERE dev_id=" + dev_id;
|
int test_cnt = 0;
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
ResultSet res = sql.sqlMysqlQuery(sql_str);
|
try {
|
if(res.next()) {
|
test_cnt = res.getInt("dev_restest_count");
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
sql.logger.error("FBS9100_Task_Thread_SQL.queryFBS9100_ResTestCnt():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
|
return test_cnt;
|
}
|
|
/**
|
* ¸ù¾Ýtb_fbs9100_setparam±í¸üÐÂal_paramÊý×é
|
* @param con_pool
|
* @param al_param
|
*/
|
/*
|
public static void queryFbs9100SetParam(MysqlConnPool con_pool, ArrayList<FBS9100_StatAndParam> al_param)
|
{
|
String sql_str = "SELECT * FROM " + Sql_Mysql.FBS9100SetParam_Table;
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
ResultSet res = sql.sqlMysqlQuery(sql_str);
|
try {
|
while(res.next())
|
{
|
FBS9100_StatAndParam param = null;
|
int devid = res.getInt("dev_id");
|
|
for(int n=0; n<al_param.size(); n++) {
|
param = al_param.get(n);
|
if(devid == param.dev_id) {
|
break;
|
}
|
}
|
|
if(null != param) {
|
param.m_FBS_DiscParam.op_cmd = res.getInt("op_cmd");
|
param.m_FBS_DiscParam.BattGroupNum = res.getInt("BattGroupNum");
|
param.m_FBS_DiscParam.test_cmd = res.getInt("TestCmd");
|
param.m_FBS_DiscParam.HourRate = res.getInt("HourRate");
|
param.m_FBS_DiscParam.DisCurr = res.getFloat("DisCurr");
|
param.m_FBS_DiscParam.DisCap = res.getFloat("DisCap");
|
param.m_FBS_DiscParam.DisTime = res.getInt("DisTime");
|
param.m_FBS_DiscParam.GroupVol_LOW = res.getFloat("GroupVol_LOW");
|
param.m_FBS_DiscParam.MonomerVol_LOW = res.getFloat("MonomerVol_LOW");
|
param.m_FBS_DiscParam.MonomerLowCount = res.getInt("MonomerLowCount");
|
param.m_FBS_DiscParam.OnlineVolLowAction = res.getInt("OnlineVolLowAction");
|
param.m_FBS_DiscParam.DCVolHighLimit = res.getFloat("DCVolHighLimit");
|
param.m_FBS_DiscParam.ChargeCurrSet = res.getFloat("ChargeCurrSet");
|
param.m_FBS_DiscParam.MonomerTmp_High = res.getFloat("MonomerTmp_High");
|
}
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
//e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
}
|
*/
|
/**
|
* ¸ù¾Ýtb_fbs9100_setparam±í¸üÐÂal_paramÊý×é
|
* @param con_pool
|
* @param al_param
|
*/
|
public static void queryFbs9100SetParamCmdBydev_id(MysqlConnPool con_pool, FGCD_StateAndParam param)
|
{
|
String sql_str = "SELECT op_cmd FROM " + Sql_Mysql.FBS9100SetParam_Table + " where dev_id = " + param.dev_id;
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
ResultSet res = sql.sqlMysqlQuery(sql_str);
|
try {
|
if(res.next()) {
|
if(null != param) {
|
param.op_cmd = res.getInt("op_cmd");
|
}
|
}
|
} catch (SQLException e) {
|
sql.logger.error("FGCD_SocketClient_Thread_SQL.queryFbs9100SetParamCmdBydev_id():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
}
|
/***********************************************************************************/
|
|
/**
|
* ¸ù¾Ýtb_fbs9100_setparam±í¸üÐÂal_paramÊý×é
|
* @param con_pool
|
* @param al_param
|
*/
|
public static void queryFbs9100SetParamBydev_id(MysqlConnPool con_pool, FGCD_StateAndParam param, FGCD_BattTestParam dis_pm)
|
{
|
String sql_str = "SELECT * FROM " + Sql_Mysql.FBS9100SetParam_Table + " where dev_id = " + param.dev_id;
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
ResultSet res = sql.sqlMysqlQuery(sql_str);
|
try {
|
if(res.next())
|
{
|
if(null != param) {
|
|
dis_pm.op_cmd = res.getInt("op_cmd");
|
dis_pm.test_cmd = res.getInt("TestCmd");
|
dis_pm.hourState = res.getInt("HourRate");
|
dis_pm.disChargeCurr = res.getDouble("DisCurr");
|
dis_pm.disChargeCap = res.getInt("DisCap");
|
dis_pm.disTime = res.getInt("DisTime");
|
dis_pm.groupVolLow = res.getDouble("GroupVol_LOW");
|
dis_pm.monVolLow = res.getDouble("MonomerVol_LOW");
|
dis_pm.monVolLowCount = res.getInt("MonomerLowCount");
|
dis_pm.groupCount = res.getInt("BattGroupNum");
|
dis_pm.testType = res.getInt("OnlineVolLowAction");
|
dis_pm.groupHighVol = res.getDouble("DCVolHighLimit");
|
dis_pm.chargeCurr = res.getDouble("ChargeCurrSet");
|
dis_pm.dischargeHighTmp = res.getInt("MonomerTmp_High");
|
dis_pm.floatVol = res.getDouble("AutoTestStartVol");
|
dis_pm.chargeVol = res.getDouble("OnLineVol_Low");
|
dis_pm.battStdCap = res.getInt("OffLineYH_Cycle");
|
dis_pm.cycleTimes = res.getInt("OffLineYHTimes");
|
dis_pm.cycleStart = res.getInt("OffLineYHOnceCycle");
|
dis_pm.monCount = res.getInt("MonCount");
|
dis_pm.mon_vol = res.getDouble("MonVol");
|
dis_pm.dischargePower = res.getDouble("DisPower");
|
dis_pm.disPreRes = res.getDouble("DisPreRes");
|
dis_pm.chargeCap = res.getInt("CharCap");
|
dis_pm.chargeTime = res.getInt("CharTimeLong");
|
dis_pm.floatTime = res.getInt("FloatCharTimeLong");
|
dis_pm.chargeStopCurr = res.getDouble("CharSotpCurr");
|
dis_pm.monHighVol = res.getDouble("MonVolHightLimit");
|
dis_pm.monHighVolCount = res.getInt("MonVolHightLimitCount");
|
dis_pm.chargeHighTmp = res.getInt("CharHighTmp");
|
dis_pm.waitdisTime = res.getInt("DisWaitTime");
|
dis_pm.waitchrTime = res.getInt("CharWaitTime");
|
|
dis_pm.FlowOver_Count = res.getInt("FlowOver_Count");
|
dis_pm.FlowOver_CharCurr[0] = res.getFloat("FlowOver_CharCurr_1");
|
dis_pm.FlowOver_CharCurr[1] = res.getFloat("FlowOver_CharCurr_2");
|
dis_pm.FlowOver_CharCurr[2] = res.getFloat("FlowOver_CharCurr_3");
|
dis_pm.FlowOver_CharTime[0] = res.getInt("FlowOver_CharTime_1");
|
dis_pm.FlowOver_CharTime[1] = res.getInt("FlowOver_CharTime_2");
|
dis_pm.FlowOver_CharTime[2] = res.getInt("FlowOver_CharTime_3");
|
|
|
}
|
}
|
} catch (SQLException e) {
|
sql.logger.error("FGCD_SocketClient_Thread_SQL.queryFbs9100SetParamBydev_id():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
}
|
/***********************************************************************************/
|
/**
|
* ¸ù¾ÝÖ¸¶¨µÄÉ豸id Ð޸ıí tb_fbs9100_setparam ÖеÄop_cmdÖµ
|
*/
|
/*
|
public static void updateFbs9100SetParamCmd(MysqlConnPool con_pool, ArrayList<FBS9100_StatAndParam> al_param)
|
{
|
for(int n=0; n<al_param.size(); n++) {
|
FBS9100_StatAndParam param = al_param.get(n);
|
if((param.op_cmd_ack == FBS9100_ComBase.CMD_StartAck)
|
|| (param.op_cmd_ack == FBS9100_ComBase.CMD_StopAck)
|
|| (param.op_cmd_ack == FBS9100_ComBase.CMD_SetDischargeParmAck))
|
{
|
String sql_str_base = Sql_Mysql.FBS9100SetParam_Table + " SET "
|
+ "op_cmd=" + param.op_cmd_ack;
|
String sql_str_update = "UPDATE " + sql_str_base + " WHERE dev_id=" + param.dev_id;
|
//String sql_str_replace = "REPLACE INTO " + sql_str_base;
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
try {
|
sql.sqlMysqlExecute(sql_str_update);
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
//e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
|
//param.m_FBS_DiscParam.op_cmd = param.op_cmd_ack;
|
param.op_cmd_ack = FBS9100_ComBase.CMD_NULL;
|
}
|
}
|
}
|
*/
|
|
/**
|
* ¸ù¾ÝÖ¸¶¨µÄÉ豸id Ð޸ıí tb_fbs9100_setparam ÖеÄop_cmdÖµ
|
*/
|
public static void updateFbs9100SetParamCmdAckBydev_id(MysqlConnPool con_pool, FBS9100_StatAndParam param)
|
{
|
if((param.op_cmd_ack == FBS9100_ComBase.CMD_StartAck)
|
|| (param.op_cmd_ack == FBS9100_ComBase.CMD_StopAck)
|
|| (param.op_cmd_ack == FBS9100_ComBase.CMD_SetDischargeParmAck)
|
|| (param.op_cmd_ack == FBS9100_ComBase.CMD_ResetSystemAck)
|
|| (param.op_cmd_ack == FBS9100_ComBase.CMD_GetDeviceTaskInfAck))
|
{
|
String sql_str_base = Sql_Mysql.FBS9100SetParam_Table + " SET "
|
+ "op_cmd=" + param.op_cmd_ack;
|
String sql_str_update = "UPDATE " + sql_str_base + " WHERE dev_id=" + param.dev_id;
|
//String sql_str_replace = "REPLACE INTO " + sql_str_base;
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
try {
|
sql.sqlMysqlExecute(sql_str_update);
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
sql.logger.error("FGCD_SocketClient_Thread_SQL.updateFbs9100SetParamCmdAckBydev_id():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
|
//param.m_FBS_DiscParam.op_cmd = param.op_cmd_ack;
|
param.op_cmd_ack = FBS9100_ComBase.CMD_NULL;
|
}
|
}
|
|
/**
|
* ¸ù¾ÝÖ¸¶¨µÄÉ豸id Ð޸ıí tb_fbs9100_setparam ÖеÄop_cmdÖµ
|
*/
|
public static void updateFbs9100SetParamCmdAckBydev_id(MysqlConnPool con_pool, FGCD_StateAndParam param)
|
{
|
if(null != param)
|
{
|
String sql_str_base = Sql_Mysql.FBS9100SetParam_Table + " SET "
|
+ "op_cmd=" + param.op_cmd_ack;
|
String sql_str_update = "UPDATE " + sql_str_base + " WHERE dev_id=" + param.dev_id;
|
//String sql_str_replace = "REPLACE INTO " + sql_str_base;
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
try {
|
sql.sqlMysqlExecute(sql_str_update);
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
sql.logger.error("FGCD_SocketClient_Thread_SQL.updateFbs9100SetParamCmdAckBydev_id():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
|
//param.m_FBS_DiscParam.op_cmd = param.op_cmd_ack;
|
param.op_cmd_ack = FBS9100_ComBase.CMD_NULL;
|
}
|
}
|
|
/***********************************************************************************/
|
/**
|
* ¸ù¾Ý Êý×éÖеÄÖµÐÞ¸Ätb_fbs9100_setparam±íÖÐÖ¸¶¨É豸µÄÐÅÏ¢
|
* @param con_pool
|
* @param al_param
|
*/
|
/*
|
public static void updateFbs9100SetParam(MysqlConnPool con_pool, ArrayList<FBS9100_StatAndParam> al_param)
|
{
|
for(int n=0; n<al_param.size(); n++)
|
{
|
FBS9100_StatAndParam param = al_param.get(n);
|
if(param.op_cmd_ack == FBS9100_ComBase.CMD_GetDischargeParmAck)
|
{
|
String sql_str_base = Sql_Mysql.FBS9100SetParam_Table
|
+ " SET "
|
+ "dev_id=" + param.dev_id + ", "
|
+ "op_cmd=" + FBS9100_ComBase.CMD_GetDischargeParmAck + ", "
|
+ "TestCmd=" + param.m_FBS_DiscParam.test_cmd + ", "
|
+ "HourRate=" + param.m_FBS_DiscParamFromDev.HourRate + ", "
|
+ "DisCurr=" + param.m_FBS_DiscParamFromDev.DisCurr + ", "
|
+ "DisCap=" + param.m_FBS_DiscParamFromDev.DisCap + ", "
|
+ "DisTime=" + param.m_FBS_DiscParamFromDev.DisTime + ", "
|
+ "GroupVol_LOW=" + param.m_FBS_DiscParamFromDev.GroupVol_LOW + ", "
|
+ "MonomerVol_LOW=" + param.m_FBS_DiscParamFromDev.MonomerVol_LOW + ", "
|
+ "MonomerLowCount=" + param.m_FBS_DiscParamFromDev.MonomerLowCount + ", "
|
+ "BattGroupNum=" + param.m_FBS_DiscParamFromDev.BattGroupNum + ", "
|
+ "OnlineVolLowAction=" + param.m_FBS_DiscParamFromDev.OnlineVolLowAction + ", "
|
+ "DCVolHighLimit=" + param.m_FBS_DiscParamFromDev.DCVolHighLimit + ", "
|
+ "ChargeCurrSet=" + param.m_FBS_DiscParamFromDev.ChargeCurrSet + ", "
|
+ "MonomerTmp_High=" + param.m_FBS_DiscParamFromDev.MonomerTmp_High;
|
//+ " WHERE dev_id=" + param.dev_id;
|
//String sql_str_update = "UPDATE " + sql_str_base;
|
String sql_str_replace = "REPLACE INTO " + sql_str_base;
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
try {
|
//System.out.println(sql_str_replace);
|
sql.sqlMysqlExecute(sql_str_replace);
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
//e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
|
param.m_FBS_DiscParam.op_cmd = param.op_cmd_ack;
|
param.op_cmd_ack = FBS9100_ComBase.CMD_NULL;
|
}
|
}
|
}
|
*/
|
|
/**
|
* ¸ù¾Ý Ö¸¶¨¶ÔÏóµÄÉ豸idÐÞ¸Ätb_fbs9100_setparam±íÖÐÖ¸¶¨É豸µÄÐÅÏ¢
|
* @param con_pool
|
* @param al_param
|
*/
|
public static void insertFbs9100SetParamBydev_id(MysqlConnPool con_pool, int dev_id)
|
{
|
{
|
String sql_str_base = Sql_Mysql.FBS9100SetParam_Table
|
+ " SET "
|
+ "dev_id=" + dev_id ;
|
|
String sql_str_replace = "REPLACE INTO " + sql_str_base;
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
try {
|
sql.sqlMysqlExecute(sql_str_replace);
|
} catch (SQLException e) {
|
sql.logger.error("FGCD_SocketClient_Thread_SQL.insertFbs9100SetParamBydev_id():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
}
|
}
|
|
/**
|
* ²åÈë»ò¸üе±Ç°²ÎÊý
|
* @param con_pool
|
* @param dev_id
|
*/
|
public static void insertOrUpdateFbs9100SetParamBydev_id(MysqlConnPool con_pool, int dev_id) {
|
String sql_str_sel = " Select * from "+Sql_Mysql.FBS9100SetParam_Table+" where dev_id= "+dev_id ;
|
String sql_str_ins = " insert into "+Sql_Mysql.FBS9100SetParam_Table+"(dev_id) values("+dev_id+")";
|
String sql_str_upd = " update "+Sql_Mysql.FBS9100SetParam_Table+" set op_cmd = 0";
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
ResultSet res = null;
|
try {
|
res = sql.sqlMysqlQuery(sql_str_sel);
|
if(!res.next()) {
|
sql.sqlMysqlExecute(sql_str_ins);
|
}else {
|
//Çå¿ÕͨÐÅ֮ǰµÄ¿ØÖÆÃüÁî
|
sql.sqlMysqlExecute(sql_str_upd);
|
}
|
} catch (SQLException e) {
|
sql.logger.error("FGCD_SocketClient_Thread_SQL.insertOrUpdateFbs9100SetParamBydev_id():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
}
|
|
/**
|
* ¸ù¾Ý Ö¸¶¨¶ÔÏóµÄÉ豸idÐÞ¸Ätb_fbs9100_setparam±íÖÐÖ¸¶¨É豸µÄÐÅÏ¢
|
* @param con_pool
|
* @param al_param
|
*/
|
public static void updateFbs9100SetParamBydev_id(MysqlConnPool con_pool, FGCD_StateAndParam param, FGCD_BattTestParam dis_pm)
|
{
|
if(param.op_cmd_ack == FBS9100_ComBase.CMD_GetDischargeParmAck)
|
{
|
String sql_str_base = Sql_Mysql.FBS9100SetParam_Table
|
+ " SET "
|
+ "dev_id=" + param.dev_id + ", "
|
+ "op_cmd=" + param.op_cmd_ack + ", "
|
+ "TestCmd=" + dis_pm.test_cmd + ", "
|
+ "HourRate=" + dis_pm.hourState +","
|
+ "DisCurr=" + dis_pm.disChargeCurr +","
|
+ "DisCap=" + dis_pm.disChargeCap +","
|
+ "DisTime=" + dis_pm.disTime +","
|
+ "GroupVol_LOW=" + dis_pm.groupVolLow +","
|
+ "MonomerVol_LOW=" + dis_pm.monVolLow +","
|
+ "MonomerLowCount=" + dis_pm.monVolLowCount +","
|
+ "BattGroupNum=" + dis_pm.groupCount +","
|
+ "OnlineVolLowAction=" + dis_pm.testType +","
|
+ "DCVolHighLimit=" + dis_pm.groupHighVol +","
|
+ "ChargeCurrSet=" + dis_pm.chargeCurr +","
|
+ "MonomerTmp_High=" + dis_pm.dischargeHighTmp +","
|
+ "AutoTestStartVol=" + dis_pm.floatVol +","
|
+ "OnLineVol_Low=" + dis_pm.chargeVol +","
|
+ "OffLineYH_Cycle=" + dis_pm.battStdCap +","
|
+ "OffLineYHTimes=" + dis_pm.cycleTimes +","
|
+ "OffLineYHOnceCycle=" + dis_pm.cycleStart +","
|
+ "MonCount=" + dis_pm.monCount +","
|
+ "MonVol=" + dis_pm.mon_vol +","
|
+ "DisPower=" + dis_pm.dischargePower +","
|
+ "DisPreRes=" + dis_pm.disPreRes +","
|
+ "CharCap=" + dis_pm.chargeCap +","
|
+ "CharTimeLong=" + dis_pm.chargeTime +","
|
+ "FloatCharTimeLong=" + dis_pm.floatTime +","
|
+ "CharSotpCurr=" + dis_pm.chargeStopCurr +","
|
+ "MonVolHightLimit=" + dis_pm.monHighVol +","
|
+ "MonVolHightLimitCount=" + dis_pm.monHighVolCount +","
|
+ "CharHighTmp=" + dis_pm.chargeHighTmp +","
|
+ "DisWaitTime=" + dis_pm.waitdisTime +","
|
+ "CharWaitTime=" + dis_pm.waitchrTime +","
|
+ "FlowOver_Count=" + dis_pm.FlowOver_Count +","
|
+ "FlowOver_CharCurr_1=" + dis_pm.FlowOver_CharCurr[0] +","
|
+ "FlowOver_CharCurr_2=" + dis_pm.FlowOver_CharCurr[1] +","
|
+ "FlowOver_CharCurr_3=" + dis_pm.FlowOver_CharCurr[2] +","
|
+ "FlowOver_CharTime_1=" + dis_pm.FlowOver_CharTime[0] +","
|
+ "FlowOver_CharTime_2=" + dis_pm.FlowOver_CharTime[1] +","
|
+ "FlowOver_CharTime_3=" + dis_pm.FlowOver_CharTime[2];
|
String sql_str_update = "UPDATE " + sql_str_base + " WHERE dev_id = " + param.dev_id;
|
//String sql_str_replace = "REPLACE INTO " + sql_str_base;
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
try {
|
//sql.logger.info(sql_str_update);
|
sql.sqlMysqlExecute(sql_str_update);
|
} catch (SQLException e) {
|
sql.logger.error("FGCD_SocketClient_Thread_SQL.updateFbs9100SetParamBydev_id():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
param.op_cmd_ack = FBS9100_ComBase.CMD_NULL;
|
}
|
}
|
/***********************************************************************************/
|
/**
|
* ¸ù¾Ýtb_fbs9100_setparam±í¸üÐÂal_paramÊý×é
|
* @param con_pool
|
* @param al_param
|
*/
|
public static void queryFbs9100SysParamCmdBydev_id(MysqlConnPool con_pool, FBS9100_StatAndParam param)
|
{
|
String sql_str = "SELECT op_cmd FROM " + Sql_Mysql.FBS9100SysParam_Table + " where dev_id = " + param.dev_id;
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
ResultSet res = sql.sqlMysqlQuery(sql_str);
|
try {
|
if(res.next()) {
|
if(null != param) {
|
param.op_cmd = res.getInt("op_cmd");
|
}
|
}
|
} catch (SQLException e) {
|
sql.logger.error("FGCD_SocketClient_Thread_SQL.queryFbs9100SysParamCmdBydev_id():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
}
|
/***********************************************************************************/
|
/**
|
* ¸ù¾Ý Ö¸¶¨¶ÔÏóµÄÉ豸idÐÞ¸Ätb_fbs9100_sysparam±íÖÐÖ¸¶¨É豸µÄÐÅÏ¢
|
* @param con_pool
|
* @param al_param
|
*/
|
public static void updateFbs9100SysParamCmdAckBydev_id(MysqlConnPool con_pool, FBS9100_StatAndParam param)
|
{
|
if(param.op_cmd_ack == FBS9100_ComBase.CMD_SetSYSSetParamAck)
|
{
|
String sql_str_base = Sql_Mysql.FBS9100SysParam_Table
|
+ " SET "
|
+ "op_cmd=" + param.op_cmd_ack;
|
String sql_str_update = "UPDATE " + sql_str_base + " WHERE dev_id=" + param.dev_id;
|
//String sql_str_replace = "REPLACE INTO " + sql_str_base;
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
try {
|
//sql.logger.debug(sql_str_replace);
|
sql.sqlMysqlExecute(sql_str_update);
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
sql.logger.error("FGCD_SocketClient_Thread_SQL.updateFbs9100SysParamCmdAckBydev_id():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
|
//param.m_FBS_SystemParam.op_cmd = param.op_cmd_ack;
|
param.op_cmd_ack = FBS9100_ComBase.CMD_NULL;
|
}
|
}
|
/***********************************************************************************/
|
/**
|
* ¸ù¾Ýtb_fbs9100_setparam±í¸üÐÂal_paramÊý×é
|
* @param con_pool
|
* @param al_param
|
*/
|
public static void queryFbs9100SysParamBydev_id(MysqlConnPool con_pool, FBS9100_StatAndParam param, FBS9100_ParamSystem sys_param)
|
{
|
String sql_str = "SELECT * FROM " + Sql_Mysql.FBS9100SysParam_Table + " where dev_id = " + param.dev_id;
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
ResultSet res = sql.sqlMysqlQuery(sql_str);
|
try {
|
if(res.next()) {
|
if(null != param) {
|
//param.m_FBS_SystemParam.op_cmd = res.getInt("op_cmd");
|
sys_param.GroupVolRange = res.getInt("GroupVolRange");
|
sys_param.GroupVolSorce = res.getInt("GroupVolSorce");
|
sys_param.CurrentRange = res.getInt("CurrentRange");
|
sys_param.CurrentType = res.getInt("CurrentTyte");
|
sys_param.MonomerOrder = res.getInt("MonomerOrder");
|
|
sys_param.BackLightTime = res.getInt("BackLightTime");
|
sys_param.LoaderCount = res.getInt("LoaderCount");
|
sys_param.DtCardCount = res.getInt("DtCardCount");
|
sys_param.PowerBreakChargeCurr = res.getFloat("PowerBreakChargeCurr");
|
sys_param.MajorBattGroupNum = res.getInt("MajorBattGroupNum");
|
sys_param.POF_BG_Boost_Cnt = res.getInt("POF_BG_Boost_Cnt");
|
sys_param.POF_BG_Boost_VolStop = res.getFloat("POF_BG_Boost_VolStop");
|
sys_param.POF_BG_Boost_VolStart = res.getFloat("POF_BG_Boost_VolStart");
|
}
|
}
|
} catch (SQLException e) {
|
sql.logger.error("FGCD_SocketClient_Thread_SQL.queryFbs9100SysParamBydev_id():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
}
|
/***********************************************************************************/
|
/**
|
* ¸ù¾Ý Ö¸¶¨¶ÔÏóµÄÉ豸idÐÞ¸Ätb_fbs9100_sysparam±íÖÐÖ¸¶¨É豸µÄÐÅÏ¢
|
* @param con_pool
|
* @param al_param
|
*/
|
public static void updateFbs9100SysParamBydev_id(MysqlConnPool con_pool, FBS9100_StatAndParam param, FBS9100_ParamSystem sys_param)
|
{
|
if(param.op_cmd_ack == FBS9100_ComBase.CMD_GetSYSSetParamAck)
|
{
|
String sql_str_base = Sql_Mysql.FBS9100SysParam_Table
|
+ " SET "
|
+ "dev_id=" + param.dev_id + ", "
|
+ "op_cmd=" + param.op_cmd_ack + ", "
|
+ "GroupVolRange=" + sys_param.GroupVolRange + ", "
|
+ "GroupVolSorce=" + sys_param.GroupVolSorce + ", "
|
+ "CurrentRange=" + sys_param.CurrentRange + ", "
|
+ "CurrentTyte=" + sys_param.CurrentType + ", "
|
+ "MonomerOrder=" + sys_param.MonomerOrder + ", "
|
+ "BackLightTime=" + sys_param.BackLightTime + ", "
|
+ "LoaderCount=" + sys_param.LoaderCount + ", "
|
+ "DtCardCount=" + sys_param.DtCardCount + ", "
|
+ "PowerBreakChargeCurr=" + sys_param.PowerBreakChargeCurr + ", "
|
+ "MajorBattGroupNum=" + sys_param.MajorBattGroupNum + ", "
|
+ "POF_BG_Boost_Cnt=" + sys_param.POF_BG_Boost_Cnt + ", "
|
+ "POF_BG_Boost_VolStop=" + sys_param.POF_BG_Boost_VolStop + ", "
|
+ "POF_BG_Boost_VolStart=" + sys_param.POF_BG_Boost_VolStart;
|
//String sql_str_update = "UPDATE " + sql_str_base;
|
String sql_str_replace = "REPLACE INTO " + sql_str_base;
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
try {
|
//sql.logger.debug(sql_str_replace);
|
sql.sqlMysqlExecute(sql_str_replace);
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
sql.logger.error("FGCD_SocketClient_Thread_SQL.updateFbs9100SysParamBydev_id():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
|
//param.m_FBS_SystemParam.op_cmd = param.op_cmd_ack;
|
param.op_cmd_ack = FBS9100_ComBase.CMD_NULL;
|
}
|
}
|
/***********************************************************************************/
|
/**
|
* ¸ù¾Ýtb_fbs9100_battparam±í¸üÐÂal_paramÊý×é
|
* @param con_pool
|
* @param al_param
|
*/
|
public static void queryFbs9100BattParamCmdBydev_id(MysqlConnPool con_pool, FBS9100_StatAndParam param)
|
{
|
String sql_str = "SELECT op_cmd FROM " + Sql_Mysql.FBS9100BattParam_Table + " where dev_id = " + param.dev_id;
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
ResultSet res = sql.sqlMysqlQuery(sql_str);
|
try {
|
if(res.next()) {
|
if(null != param) {
|
param.op_cmd = res.getInt("op_cmd");
|
}
|
}
|
} catch (SQLException e) {
|
sql.logger.error("FGCD_SocketClient_Thread_SQL.queryFbs9100BattParamCmdBydev_id():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
}
|
/***********************************************************************************/
|
/**
|
* ¸ù¾Ý Ö¸¶¨¶ÔÏóµÄÉ豸idÐÞ¸Ätb_fbs9100_battparam±íÖÐÖ¸¶¨É豸µÄÐÅÏ¢
|
* @param con_pool
|
* @param al_param
|
*/
|
public static void updateFbs9100BattParamCmdAckBydev_id(MysqlConnPool con_pool, FBS9100_StatAndParam param)
|
{
|
if(param.op_cmd_ack == FBS9100_ComBase.CMD_SetBattParamACK)
|
{
|
String sql_str_base = Sql_Mysql.FBS9100BattParam_Table
|
+ " SET "
|
+ "op_cmd=" + param.op_cmd_ack;
|
String sql_str_update = "UPDATE " + sql_str_base + " WHERE dev_id=" + param.dev_id;
|
//String sql_str_replace = "REPLACE INTO " + sql_str_base;
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
try {
|
//sql.logger.debug(sql_str_replace);
|
sql.sqlMysqlExecute(sql_str_update);
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
sql.logger.error("FGCD_SocketClient_Thread_SQL.updateFbs9100BattParamCmdAckBydev_id():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
|
//param.m_FBS_BattParam.op_cmd = param.op_cmd_ack;
|
param.op_cmd_ack = FBS9100_ComBase.CMD_NULL;
|
}
|
}
|
/***********************************************************************************/
|
/**
|
* ¸ù¾Ýtb_fbs9100_battparam±í²éѯ²ÎÊý
|
* @param con_pool
|
* @param al_param
|
*/
|
public static void queryFbs9100BattParamBydev_id(MysqlConnPool con_pool, FBS9100_StatAndParam param, FBS9100_ParamBatt batt_pm)
|
{
|
String sql_str = "SELECT * FROM " + Sql_Mysql.FBS9100BattParam_Table + " where dev_id = " + param.dev_id;
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
ResultSet res = sql.sqlMysqlQuery(sql_str);
|
try {
|
if(res.next()) {
|
if(null != param) {
|
batt_pm.STD_CAP = res.getInt("STD_CAP");
|
batt_pm.STD_RES = res.getInt("STD_RES");
|
batt_pm.BattGroupCount = res.getInt("BattGroupCount");
|
batt_pm.EachGroupBattCount = res.getInt("EachGroupBattCount");
|
|
batt_pm.MonomerVol = res.getFloat("MonomerVol");
|
batt_pm.GroupVol = res.getFloat("GroupVol");
|
batt_pm.BattTemp = res.getFloat("BattTemp");
|
batt_pm.FloatChargeVol = res.getFloat("FloatChargeVol");
|
batt_pm.FloatChargeCurr = res.getFloat("FloatChargeCurr");
|
batt_pm.OnlineVolLow = res.getFloat("OnlineVolLow");
|
batt_pm.GroupConnType = res.getInt("GroupConnType");
|
}
|
}
|
} catch (SQLException e) {
|
sql.logger.error("FGCD_SocketClient_Thread_SQL.queryFbs9100BattParamBydev_id():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
}
|
/***********************************************************************************/
|
/**
|
* ¸ù¾Ý Ö¸¶¨¶ÔÏóµÄÉ豸idÐÞ¸Ätb_fbs9100_sysparam±íÖÐÖ¸¶¨É豸µÄÐÅÏ¢
|
* @param con_pool
|
* @param al_param
|
*/
|
public static void updateFbs9100BattParamBydev_id(MysqlConnPool con_pool, FBS9100_StatAndParam param, FBS9100_ParamBatt batt_pm)
|
{
|
if(param.op_cmd_ack == FBS9100_ComBase.CMD_GetBattParamACK)
|
{
|
String sql_str_base = Sql_Mysql.FBS9100BattParam_Table
|
+ " SET "
|
+ "dev_id=" + param.dev_id + ", "
|
+ "op_cmd=" + param.op_cmd_ack + ", "
|
+ "STD_CAP=" + batt_pm.STD_CAP + ", "
|
+ "STD_RES=" + batt_pm.STD_RES + ", "
|
+ "BattGroupCount=" + batt_pm.BattGroupCount + ", "
|
+ "EachGroupBattCount=" + batt_pm.EachGroupBattCount + ", "
|
+ "MonomerVol=" + batt_pm.MonomerVol + ", "
|
+ "GroupVol=" + batt_pm.GroupVol + ", "
|
+ "BattTemp=" + batt_pm.BattTemp + ", "
|
+ "FloatChargeVol=" + batt_pm.FloatChargeVol + ", "
|
+ "FloatChargeCurr=" + batt_pm.FloatChargeCurr + ", "
|
+ "OnlineVolLow=" + batt_pm.OnlineVolLow + ", "
|
+ "GroupConnType=" + batt_pm.GroupConnType;
|
//String sql_str_update = "UPDATE " + sql_str_base;
|
String sql_str_replace = "REPLACE INTO " + sql_str_base;
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
try {
|
//sql.logger.debug(sql_str_replace);
|
sql.sqlMysqlExecute(sql_str_replace);
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
sql.logger.error("FGCD_SocketClient_Thread_SQL.updateFbs9100BattParamBydev_id():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
|
//param.m_FBS_BattParam.op_cmd = param.op_cmd_ack;
|
param.op_cmd_ack = FBS9100_ComBase.CMD_NULL;
|
}
|
}
|
/***********************************************************************************/
|
/***********************************************************************************/
|
/**
|
* ¸ù¾Ýtb_bts_gprs_state±í¸üÐÂal_paramÊý×é
|
* @param con_pool
|
* @param al_param
|
*/
|
public static int queryBTSGPRSCmdBydev_id(MysqlConnPool con_pool, FBS9100_StatAndParam param)
|
{
|
int cmd_t = 0;
|
String sql_str = "SELECT op_cmd FROM " + Sql_Mysql.BTSGPRSState_Table + " where dev_id = " + param.dev_id;
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
ResultSet res = sql.sqlMysqlQuery(sql_str);
|
try {
|
if(res.next()) {
|
if(null != param) {
|
cmd_t = res.getInt("op_cmd");
|
}
|
}
|
} catch (SQLException e) {
|
sql.logger.error("FGCD_SocketClient_Thread_SQL.queryBTSGPRSCmdBydev_id():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
|
return cmd_t;
|
}
|
/***********************************************************************************/
|
public static String queryBTSGPRS_ATCmd_Bydev_id(MysqlConnPool con_pool, FBS9100_StatAndParam param)
|
{
|
String cmd_at = "";
|
String sql_str = "SELECT AT_cmd FROM " + Sql_Mysql.BTSGPRSState_Table + " where dev_id = " + param.dev_id;
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
ResultSet res = sql.sqlMysqlQuery(sql_str);
|
try {
|
if(res.next()) {
|
if(null != param) {
|
cmd_at = res.getString("AT_cmd").trim();
|
}
|
}
|
} catch (SQLException e) {
|
sql.logger.error("FGCD_SocketClient_Thread_SQL.queryBTSGPRS_ATCmd_Bydev_id():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
|
return cmd_at;
|
}
|
/***********************************************************************************/
|
/**
|
* ¸ù¾Ý Ö¸¶¨¶ÔÏóµÄÉ豸idÐÞ¸Ätb_bts_gprs_state±íÖÐÖ¸¶¨É豸µÄÐÅÏ¢
|
* @param con_pool
|
* @param al_param
|
*/
|
public static void updateBTSGPRSSateBydev_id(MysqlConnPool con_pool, FBS9100_StatAndParam param,
|
String at_cmd, String val)
|
{
|
if(param.op_cmd_ack == FBS9100_ComBase.CMD_ReadGPRSCSQAck)
|
{
|
String tmp_val = "null";
|
if(null != val) {
|
if((val.length() > 6) && (val.contains("usr.cn"))) {
|
tmp_val = val;
|
}
|
}
|
String sql_str_base = Sql_Mysql.BTSGPRSState_Table
|
+ " SET "
|
+ "dev_id=" + param.dev_id + ", "
|
+ "op_cmd=" + param.op_cmd_ack + ", "
|
+ "AT_cmd='" + at_cmd + "', "
|
+ "ack_inf='" + tmp_val + "'";
|
//String sql_str_update = "UPDATE " + sql_str_base;
|
String sql_str_replace = "REPLACE INTO " + sql_str_base;
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
try {
|
//sql.logger.debug(sql_str_replace);
|
sql.sqlMysqlExecute(sql_str_replace);
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
sql.logger.error("FGCD_SocketClient_Thread_SQL.updateBTSGPRSSateBydev_id():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
|
param.op_cmd_ack = FBS9100_ComBase.CMD_NULL;
|
}
|
}
|
/***********************************************************************************/
|
public static void updateBTS_TaskInf_To_GPRSTableBydev_id(MysqlConnPool con_pool, FBS9100_StatAndParam param, String val)
|
{
|
if(param.op_cmd_ack == FBS9100_ComBase.CMD_GetDeviceTaskInfAck)
|
{
|
String sql_str_base = Sql_Mysql.BTSGPRSState_Table
|
+ " SET "
|
+ "dev_id=" + param.dev_id + ", "
|
+ "bts_task_inf='" + val + "'";
|
String sql_str_update = "REPLACE INTO " + sql_str_base;
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
try {
|
//sql.logger.debug(sql_str_update);
|
sql.sqlMysqlExecute(sql_str_update);
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
sql.logger.error("FGCD_SocketClient_Thread_SQL.updateBTS_TaskInf_To_GPRSTableBydev_id():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
|
param.op_cmd_ack = FBS9100_ComBase.CMD_NULL;
|
}
|
}
|
/***********************************************************************************/
|
public static void updateBattState_RT_RamDB_Table(MysqlConnPool conn_pool, ArrayList<BattData_RT> bd_al)
|
{
|
Sql_Mysql sql = new Sql_Mysql(conn_pool.getConn());
|
try
|
{
|
String sql_str = "UPDATE " + Sql_Mysql.BattRtState_Table
|
+ " SET "
|
+ " rec_datetime='" + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms) + "',";
|
|
sql_str += " batt_count = CASE BattGroupId ";
|
for(int n=0; n<bd_al.size(); n++) {
|
BattData_RT brt = bd_al.get(n);
|
sql_str += " WHEN " + brt.BattGroupId + " THEN " + brt.MonCount;
|
}
|
|
sql_str += " END, " + " online_vol = CASE BattGroupId ";
|
for(int n=0; n<bd_al.size(); n++) {
|
BattData_RT brt = bd_al.get(n);
|
sql_str += " WHEN " + brt.BattGroupId + " THEN " + brt.getOnlineVol();
|
}
|
|
sql_str += " END, " + " group_vol = CASE BattGroupId ";
|
for(int n=0; n<bd_al.size(); n++) {
|
BattData_RT brt = bd_al.get(n);
|
sql_str += " WHEN " + brt.BattGroupId + " THEN " + brt.getGroupVol();
|
}
|
|
sql_str += " END, " + " group_tmp = CASE BattGroupId ";
|
for(int n=0; n<bd_al.size(); n++) {
|
BattData_RT brt = bd_al.get(n);
|
sql_str += " WHEN " + brt.BattGroupId + " THEN " + brt.getGroupTmp();
|
}
|
|
sql_str += " END, " + " group_curr = CASE BattGroupId ";
|
for(int n=0; n<bd_al.size(); n++) {
|
BattData_RT brt = bd_al.get(n);
|
sql_str += " WHEN " + brt.BattGroupId + " THEN " + brt.getTestCurr();
|
}
|
|
sql_str += " END, " + " batt_state = CASE BattGroupId ";
|
for(int n=0; n<bd_al.size(); n++) {
|
BattData_RT brt = bd_al.get(n);
|
sql_str += " WHEN " + brt.BattGroupId + " THEN " + brt.getBattState();
|
}
|
|
sql_str += " END, " + " batt_test_type = CASE BattGroupId ";
|
for(int n=0; n<bd_al.size(); n++) {
|
BattData_RT brt = bd_al.get(n);
|
sql_str += " WHEN " + brt.BattGroupId + " THEN " + brt.getBattTestType();
|
}
|
|
sql_str += " END, " + " batt_test_starttime = CASE BattGroupId ";
|
Date dt = new Date();
|
for(int n=0; n<bd_al.size(); n++) {
|
BattData_RT brt = bd_al.get(n);
|
dt.setTime(brt.getTestStartTime());
|
sql_str += " WHEN " + brt.BattGroupId + " THEN '" + Com.getDateTimeFormat(dt, Com.DTF_YMDhms) + "'";
|
}
|
|
sql_str += " END, " + " batt_test_recordtime = CASE BattGroupId ";
|
for(int n=0; n<bd_al.size(); n++) {
|
BattData_RT brt = bd_al.get(n);
|
dt.setTime(brt.getTestRecordTime());
|
sql_str += " WHEN " + brt.BattGroupId + " THEN '" + Com.getDateTimeFormat(dt, Com.DTF_YMDhms) + "'";
|
}
|
|
sql_str += " END, " + " batt_test_tlong = CASE BattGroupId ";
|
for(int n=0; n<bd_al.size(); n++) {
|
BattData_RT brt = bd_al.get(n);
|
sql_str += " WHEN " + brt.BattGroupId + " THEN " + brt.getTestTimeLong();
|
}
|
|
sql_str += " END, " + " batt_test_cap = CASE BattGroupId ";
|
for(int n=0; n<bd_al.size(); n++) {
|
BattData_RT brt = bd_al.get(n);
|
sql_str += " WHEN " + brt.BattGroupId + " THEN " + brt.getTestCap();
|
}
|
|
sql_str += " END, " + " batt_real_cap = CASE BattGroupId ";
|
for(int n=0; n<bd_al.size(); n++) {
|
BattData_RT brt = bd_al.get(n);
|
sql_str += " WHEN " + brt.BattGroupId + " THEN " + brt.getBattRealCap();
|
}
|
|
sql_str += " END, " + " batt_rest_cap = CASE BattGroupId ";
|
for(int n=0; n<bd_al.size(); n++) {
|
BattData_RT brt = bd_al.get(n);
|
sql_str += " WHEN " + brt.BattGroupId + " THEN " + brt.getBattRestCap();
|
}
|
|
sql_str += " END, " + " batt_rest_power1_time = CASE BattGroupId ";
|
for(int n=0; n<bd_al.size(); n++) {
|
BattData_RT brt = bd_al.get(n);
|
sql_str += " WHEN " + brt.BattGroupId + " THEN " + brt.getBattRestTime();
|
}
|
|
sql_str += " END WHERE BattGroupId IN (";
|
for(int n=0; n<bd_al.size(); n++) {
|
BattData_RT brt = bd_al.get(n);
|
if(n > 0) {
|
sql_str += ",";
|
}
|
sql_str += brt.BattGroupId;
|
}
|
sql_str += ")";
|
//sql.logger.debug(sql_str);
|
sql.sqlMysqlExecute(sql_str);
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
sql.logger.error("FGCD_SocketClient_Thread_SQL.updateBattState_RT_RamDB_Table():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
}
|
/************************************************************************************************/
|
public static void UpdateBTS_Station_Stat(MysqlConnPool conn_pool, FBS9100_StatAndParam m_pm, int start_stat) {
|
String sql_str = "UPDATE " + Sql_Mysql.BTSStationState_Table + " SET "
|
+ "record_datetime='" + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms) + "',"
|
+ "station_stat=" + m_pm.m_SysState.Station_State;
|
|
if((start_stat & (1<<FBS9100S_SocketClient2.EveType_StationPOFF)) > 0) {
|
sql_str += ", station_poff_start_time='" + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms) + "'";
|
}
|
|
if((start_stat & (1<<FBS9100S_SocketClient2.EveType_StationXuHang)) > 0) {
|
sql_str += ", station_xuhang_start_time='" + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms) + "'";
|
sql_str += ", station_xuhang_end_time='1980-01-01 00:00:00'";
|
} else {
|
if((start_stat & (1<<FBS9100S_SocketClient2.EveType_StationXuHangEnd)) > 0) {
|
sql_str += ", station_xuhang_end_time='" + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms) + "'";
|
}
|
}
|
|
if((start_stat & (1<<FBS9100S_SocketClient2.EveType_StationDiaoZhan)) > 0) {
|
sql_str += ", station_diaozhan_start_time='" + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms) + "'";
|
}
|
|
sql_str += " WHERE dev_id=" + m_pm.dev_id;
|
|
Sql_Mysql sql = new Sql_Mysql(conn_pool.getConn());
|
try {
|
//System.out.println(sql_str);
|
sql.sqlMysqlExecute(sql_str);
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
sql.logger.error("FGCD_SocketClient_Thread_SQL.UpdateBTS_Station_Stat():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
}
|
/***********************************************************************************/
|
public static void insertBTS_Station_Event_IntoDB(MysqlConnPool conn_pool, FBS9100_StatAndParam m_pm,
|
int eve_type, int eve_trig, String dt_str) {
|
String sql_str = "INSERT INTO " + Sql_Mysql.BTSStationEvent_Table
|
+ "( station_id, dev_id, record_datetime, station_event_type, station_event_trig )"
|
+ " VALUES "
|
+ "(" + m_pm.dev_station_id + ","
|
+ m_pm.dev_id + ","
|
+ "'" + dt_str + "',"
|
+ eve_type + ","
|
+ eve_trig + ")";
|
|
Sql_Mysql sql = new Sql_Mysql(conn_pool.getConn());
|
try {
|
//System.out.println(sql_str);
|
sql.sqlMysqlExecute(sql_str);
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
sql.logger.error("FGCD_SocketClient_Thread_SQL.insertBTS_Station_Event_IntoDB():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
}
|
/***********************************************************************************/
|
public static void insertFBS_EventToTable(MysqlConnPool conn_pool, int fbsdev_id,
|
int eve_type, int module_num,
|
int last_stat, int now_stat, int stat_change_reason)
|
{
|
Sql_Mysql sql = new Sql_Mysql(conn_pool.getConn());
|
try {
|
String sql_str = "INSERT INTO " + Sql_Mysql.FBSDevStateChangeInf_Table
|
+ " (dev_id,rec_time,eve_type,module_num,last_stat,now_stat,state_change_reason) "
|
+ " VALUES (" +
|
+ fbsdev_id + ","
|
+ "'" + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms) + "',"
|
+ eve_type + ","
|
+ module_num + ","
|
+ last_stat + ","
|
+ now_stat + ","
|
+ stat_change_reason + ")";
|
|
//System.out.println(sql_str);
|
sql.sqlMysqlExecute(sql_str);
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
sql.logger.error("FGCD_SocketClient_Thread_SQL.insertFBS_EventToTable():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
}
|
|
/**
|
* ´´½¨Äæ±äÐÅϢ״̬±í
|
*/
|
public static void createFBS_NiBianTable(MysqlConnPool conn_pool){
|
String sql_str = "CREATE TABLE IF NOT EXISTS "+ Sql_Mysql.FBS9100s_NiBian_stateTable +" ("
|
+ " `num` bigint(20) NOT NULL AUTO_INCREMENT,"
|
+ " `dev_id` bigint(11) NOT NULL DEFAULT '0',"
|
+ " `nb_num` bigint(11) NOT NULL DEFAULT '0',"
|
+ " `record_time` datetime NOT NULL DEFAULT '2000-01-01 00:00:00',"
|
+ " `AC_ASimVol` float NOT NULL DEFAULT '0',"
|
+ " `AC_ASimCur` float NOT NULL DEFAULT '0',"
|
+ " `AC_BSimVol` float NOT NULL DEFAULT '0',"
|
+ " `AC_BSimCur` float NOT NULL DEFAULT '0',"
|
+ " `AC_CSimVol` float NOT NULL DEFAULT '0',"
|
+ " `AC_CSimCur` float NOT NULL DEFAULT '0',"
|
+ " `A_HZ` float NOT NULL DEFAULT '0',"
|
+ " `B_HZ` float NOT NULL DEFAULT '0',"
|
+ " `C_HZ` float NOT NULL DEFAULT '0',"
|
+ " `Power_Pa` float NOT NULL DEFAULT '0',"
|
+ " `Power_Pb` float NOT NULL DEFAULT '0',"
|
+ " `Power_Pc` float NOT NULL DEFAULT '0',"
|
+ " `Power_Sa` float NOT NULL DEFAULT '0',"
|
+ " `Power_Sb` float NOT NULL DEFAULT '0',"
|
+ " `Power_Sc` float NOT NULL DEFAULT '0',"
|
+ " `Temp1` float NOT NULL DEFAULT '0',"
|
+ " `Temp2` float NOT NULL DEFAULT '0',"
|
+ " `RunState` float NOT NULL DEFAULT '0',"
|
+ " `DcACState` int(11) NOT NULL DEFAULT '0',"
|
+ " `InsulaTionRes1` int(11) NOT NULL DEFAULT '0',"
|
+ " `InsulaTionRes2` int(11) NOT NULL DEFAULT '0',"
|
+ " `DCInputVol` float NOT NULL DEFAULT '0',"
|
+ " `DCInputCur` float NOT NULL DEFAULT '0',"
|
+ " `SetRun_Stop` int(11) NOT NULL DEFAULT '0',"
|
+ " `SetDischargeCur` float NOT NULL DEFAULT '0',"
|
+ " `CommTxCnt` int(11) NOT NULL DEFAULT '0',"
|
+ " `CommRxCnt` int(11) NOT NULL DEFAULT '0',"
|
+ " PRIMARY KEY (`num`),"
|
+ " UNIQUE KEY `nb_num_index` (`nb_num`) USING HASH"
|
+ ") ENGINE=InnoDB DEFAULT CHARSET=utf8;";
|
Sql_Mysql sql = new Sql_Mysql(conn_pool.getConn());
|
try {
|
sql.sqlMysqlExecute(sql_str);
|
} catch (SQLException e) {
|
sql.logger.error("FGCD_SocketClient_Thread_SQL.createFBS_NiBianTable():" + e.toString(), e);
|
} finally{
|
sql.close_con();
|
}
|
|
}
|
|
/**
|
* ¸üÐÂÄæ±ä״̬ÐÅÏ¢
|
* @param conn_pool
|
* @param nibiandata
|
* @param dev_id
|
*/
|
public static void updateFBS9100S_NiBianStateTable(MysqlConnPool conn_pool,FBS9100S_NiBian_Data[] nibiandata,int dev_id ){
|
for(int n=0; n<nibiandata.length; n++) {
|
|
String sql_str_base = Sql_Mysql.FBS9100s_NiBian_stateTable
|
+ " SET "
|
+ "dev_id=" + dev_id + ","
|
+ "nb_num=" + ((dev_id%1000000)*10 + (n+1)) + ", "
|
+ "record_time='"+ Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms) + "', "
|
+ "AC_ASimVol=" + nibiandata[n].AC_ASimVol + ", "
|
+ "AC_ASimCur=" + nibiandata[n].AC_ASimCur + ", "
|
+ "AC_BSimVol=" + nibiandata[n].AC_BSimVol + ", "
|
+ "AC_BSimCur=" + nibiandata[n].AC_BSimCur + ", "
|
+ "AC_CSimVol=" + nibiandata[n].AC_CSimVol + ", "
|
+ "AC_CSimCur=" + nibiandata[n].AC_CSimCur + ", "
|
+ "A_HZ=" + nibiandata[n].A_HZ + ", "
|
+ "B_HZ=" + nibiandata[n].B_HZ + ", "
|
+ "C_HZ=" + nibiandata[n].C_HZ + ", "
|
+ "Power_Pa=" + nibiandata[n].Power_Pa + ", "
|
+ "Power_Pb=" + nibiandata[n].Power_Pb + ", "
|
+ "Power_Pc=" + nibiandata[n].Power_Pc + ", "
|
+ "Power_Sa=" + nibiandata[n].Power_Sa + ", "
|
+ "Power_Sb=" + nibiandata[n].Power_Sb + ", "
|
+ "Power_Sc=" + nibiandata[n].Power_Sc + ", "
|
+ "Temp1=" + nibiandata[n].Temp1 + ", "
|
+ "Temp2=" + nibiandata[n].Temp2 + ", "
|
+ "RunState=" + nibiandata[n].RunState + ", "
|
+ "DcACState=" + nibiandata[n].DcACState + ", "
|
+ "InsulaTionRes1=" + nibiandata[n].InsulaTionRes1 + ", "
|
+ "InsulaTionRes2=" + nibiandata[n].InsulaTionRes2 + ", "
|
+ "DCInputVol=" + nibiandata[n].DCInputVol + ", "
|
+ "DCInputCur=" + nibiandata[n].DCInputCur + ", "
|
+ "SetRun_Stop=" + nibiandata[n].SetRun_Stop + ", "
|
+ "SetDischargeCur=" + nibiandata[n].SetDischargeCur + ", "
|
+ "CommTxCnt=" + nibiandata[n].CommTxCnt + ", "
|
+ "CommRxCnt=" + nibiandata[n].CommRxCnt ;
|
|
String sql_str_replace = "REPLACE INTO " + sql_str_base;
|
String sql_str_update = " UPDATE " + sql_str_base + " where dev_id = "+dev_id + " AND nb_num = "+((dev_id%1000000)*10 + (n+1)) ;
|
ResultSet res = null;
|
Sql_Mysql sql = new Sql_Mysql(conn_pool.getConn());
|
try {
|
res = sql.sqlMysqlQuery(" select * from "+Sql_Mysql.FBS9100s_NiBian_stateTable + " where dev_id = "+dev_id + " AND nb_num = "+((dev_id%1000000)*10 + (n+1)));
|
if(res.next()){
|
sql.sqlMysqlExecute(sql_str_update);
|
}else{
|
sql.sqlMysqlExecute(sql_str_replace);
|
}
|
//System.out.println(sql_str_replace);
|
} catch (SQLException e) {
|
sql.logger.error("FGCD_SocketClient_Thread_SQL.updateFBS9100S_NiBianStateTable():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
}
|
}
|
|
/**
|
* ´´½¨Ö¸¶¨µÄµç³Ø×éÀúÊ·Êý¾Ý¼Ç¼±í
|
* @param pool
|
* @param BattGroupId
|
*/
|
public static void CreateTb_BattRealDataTable(MysqlConnPool pool,int BattGroupId) {
|
String sql_str = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.Tb_Batt_RealData+BattGroupId + " (" +
|
" `num` bigint(20) NOT NULL AUTO_INCREMENT," +
|
" `BattGroupId` int(11) NOT NULL DEFAULT '1'," +
|
" `recrod_time` datetime NOT NULL DEFAULT '2000-01-01 00:00:00'," +
|
" `group_vol` float NOT NULL DEFAULT '0'," +
|
" `online_vol` float NOT NULL DEFAULT '0'," +
|
" `group_curr` float NOT NULL DEFAULT '0'," +
|
" `group_tmp` float NOT NULL DEFAULT '0'," +
|
" `batt_state` int(11) NOT NULL DEFAULT '0'," +
|
" `batt_test_type` int(11) NOT NULL DEFAULT '0'," +
|
" `batt_test_starttime` datetime NOT NULL DEFAULT '2000-01-01 00:00:00'," +
|
" `batt_test_tlong` int(11) NOT NULL DEFAULT '0'," +
|
" `batt_test_cap` float NOT NULL DEFAULT '0'," +
|
" `mon_num` int(11) NOT NULL DEFAULT '1'," +
|
" `mon_vol` float NOT NULL DEFAULT '0'," +
|
" `mon_tmp` float NOT NULL DEFAULT '0'," +
|
" `mon_res` float NOT NULL DEFAULT '0'," +
|
" `mon_ser` float NOT NULL DEFAULT '0'," +
|
" `mon_conn_res` float NOT NULL DEFAULT '0'," +
|
" `mon_cap` float NOT NULL DEFAULT '0'," +
|
" `mon_JH_curr` float NOT NULL DEFAULT '0'," +
|
" `note` varchar(255) NOT NULL DEFAULT ''," +
|
" PRIMARY KEY (`num`),"
|
+ "KEY `index_battgroupid` (`BattGroupId`) USING BTREE" +
|
") ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8;";
|
Sql_Mysql sql = new Sql_Mysql(pool.getConn());
|
try {
|
sql.sqlMysqlExecute(sql_str);
|
} catch (SQLException e) {
|
sql.logger.error("FGCD_SocketClient_Thread_SQL.CreateTb_BattRealDataTable():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
}
|
|
|
/**
|
* ´´½¨Ö¸¶¨µÄµç³Ø×éÀúÊ·Êý¾Ý¼Ç¼±í
|
* @param pool
|
* @param BattGroupId µç³Ø×éid
|
* @param time ¼Ç¼ʱ¼ä
|
*/
|
public static void CreateTb_BattRealDataTable(MysqlConnPool pool,int BattGroupId,Date time) {
|
String sql_str = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.Tb_Batt_RealData+BattGroupId+"_"+Com.getDateTimeFormat(time, Com.DTF_YM) + " (" +
|
" `num` bigint(20) NOT NULL AUTO_INCREMENT," +
|
" `BattGroupId` int(11) NOT NULL DEFAULT '1'," +
|
" `recrod_time` datetime NOT NULL DEFAULT '2000-01-01 00:00:00'," +
|
" `group_vol` float NOT NULL DEFAULT '0'," +
|
" `online_vol` float NOT NULL DEFAULT '0'," +
|
" `group_curr` float NOT NULL DEFAULT '0'," +
|
" `group_tmp` float NOT NULL DEFAULT '0'," +
|
" `batt_state` int(11) NOT NULL DEFAULT '0'," +
|
" `batt_test_type` int(11) NOT NULL DEFAULT '0'," +
|
" `batt_test_starttime` datetime NOT NULL DEFAULT '2000-01-01 00:00:00'," +
|
" `batt_test_tlong` int(11) NOT NULL DEFAULT '0'," +
|
" `batt_test_cap` float NOT NULL DEFAULT '0'," +
|
" `mon_num` int(11) NOT NULL DEFAULT '1'," +
|
" `mon_vol` float NOT NULL DEFAULT '0'," +
|
" `mon_tmp` float NOT NULL DEFAULT '0'," +
|
" `mon_res` float NOT NULL DEFAULT '0'," +
|
" `mon_ser` float NOT NULL DEFAULT '0'," +
|
" `mon_conn_res` float NOT NULL DEFAULT '0'," +
|
" `mon_cap` float NOT NULL DEFAULT '0'," +
|
" `mon_JH_curr` float NOT NULL DEFAULT '0'," +
|
" `note` varchar(255) NOT NULL DEFAULT ''," +
|
" PRIMARY KEY (`num`)," +
|
" KEY `index_battgroupid` (`BattGroupId`) USING BTREE," +
|
" KEY `index_record_time` (`recrod_time`) USING BTREE" +
|
") ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8;";
|
Sql_Mysql sql = new Sql_Mysql(pool.getConn());
|
try {
|
sql.sqlMysqlExecute(sql_str);
|
} catch (SQLException e) {
|
sql.logger.error("CreateTb_BattRealDataTable():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
}
|
|
/**
|
* ɾ³ý±í´´½¨Ê±¼ä³¬Ê±µÄÀúÊ·Êý¾Ý±í[ûÓÐÐÞ¸Äʱ¼äµÄ±í²»»áÓÐÓ¦Ó°Ïì]
|
*/
|
public static void deleteHistoryData(MysqlConnPool conn_pool,Date deldate) {
|
String sql_select_strs = " select TABLE_NAME,UPDATE_TIME " +
|
" from information_schema.tables " +
|
" where table_schema='db_batt_history' " +
|
" AND TABLE_NAME like 'tb_batt_realdata_%' " +
|
" AND CREATE_TIME <= '"+Com.getDateTimeFormat(deldate, Com.DTF_YMDhms)+"';" ;
|
String sql_delete_strs = " DROP TABLE IF EXISTS ";
|
Sql_Mysql sql = new Sql_Mysql(conn_pool.getConn());
|
ResultSet res = null;
|
int count = 0;
|
res = sql.sqlMysqlQuery(sql_select_strs);
|
try {
|
while(res.next()) {
|
if(count > 0) {
|
sql_delete_strs += ",";
|
}
|
|
sql_delete_strs += "db_batt_history." + res.getString("TABLE_NAME");
|
System.out.println("ɾ³ý£º"+res.getString("TABLE_NAME")+"\t at "+Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms));
|
count++;
|
}
|
if(count >0) {
|
sql.sqlMysqlExecute(sql_delete_strs);
|
}
|
res.close();
|
} catch (SQLException e) {
|
sql.logger.error("FGCD_SocketClient_Thread_SQL.deleteHistoryData():" + e.toString(), e);
|
} finally {
|
sql.close_con();
|
}
|
}
|
|
/**
|
* ²éѯϵͳ²ÎÊýÖеÄÇå³ý¸æ¾¯¹¦ÄÜ
|
* @param conn_pool
|
* @param param
|
* @return
|
*/
|
public static int queryClearAlarmState(MysqlConnPool conn_pool,FGCD_StateAndParam param) {
|
int op_cmd = 0;
|
String sql_str = " SELECT * " +
|
" FROM " + Sql_Mysql.FBS9100SysParam_Table +
|
" WHERE dev_id = " + param.dev_id;
|
Sql_Mysql sql = null;
|
ResultSet res = null;
|
try {
|
sql = new Sql_Mysql(conn_pool);
|
res = sql.sqlMysqlQuery(sql_str);
|
if(res.next()) {
|
op_cmd = res.getInt("op_cmd");
|
}
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} finally {
|
if(null != res) {
|
try {
|
res.close();
|
} catch (SQLException e) {
|
e.printStackTrace();
|
}
|
}
|
sql.close_con();
|
}
|
return op_cmd;
|
}
|
|
/**
|
* ²éѯϵͳ²ÎÊýÖеÄÇå³ý¸æ¾¯¹¦ÄÜ
|
* @param conn_pool
|
* @param param
|
* @return
|
*/
|
public static int updateClearAlarmState(MysqlConnPool conn_pool,FGCD_StateAndParam param,int op_cmd_ack) {
|
int op_cmd = 0;
|
String sql_str = " update " + Sql_Mysql.FBS9100SysParam_Table +
|
" Set op_cmd = " + op_cmd_ack +
|
" WHERE dev_id = " + param.dev_id;
|
Sql_Mysql sql = null;
|
try {
|
sql = new Sql_Mysql(conn_pool);
|
sql.sqlMysqlExecute(sql_str);
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
return op_cmd;
|
}
|
|
public static void insertFBS9100_SysParamDefaultData(MysqlConnPool conn_pool,FGCD_StateAndParam param) {
|
String sql_str_sel = " Select * from "+Sql_Mysql.FBS9100SysParam_Table +" Where dev_id = "+param.dev_id;
|
String sql_str_ins = " insert into " + Sql_Mysql.FBS9100SysParam_Table+"(dev_id) values("+param.dev_id+")";
|
String sql_str_upd = " update " + Sql_Mysql.FBS9100SysParam_Table+" set op_cmd = 0";
|
ResultSet res = null;
|
Sql_Mysql sql = null;
|
try {
|
sql = new Sql_Mysql(conn_pool);
|
res = sql.sqlMysqlQuery(sql_str_sel);
|
if(!res.next()) {
|
sql.sqlMysqlExecute(sql_str_ins);
|
}else {
|
//Çå¿ÕͨÐÅ֮ǰµÄ¿ØÖÆÃüÁî
|
sql.sqlMysqlExecute(sql_str_upd);
|
}
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} finally {
|
if(null != res) {
|
try {
|
res.close();
|
} catch (SQLException e) {
|
e.printStackTrace();
|
}
|
}
|
sql.close_con();
|
}
|
}
|
|
|
//¸üгä·ÅµçÒ»Ìå»úÏ̵߳ÄÆô¶¯Ê±¼äºÍ°æ±¾ºÃ
|
public static void updateServerStartInf_StartTime(MysqlConnPool conn_pool,double version){
|
Sql_Mysql sql = new Sql_Mysql(conn_pool.getConn());
|
try {
|
sql.sqlMysqlUseDB(Sql_Mysql.WEB_Site);
|
String sql_str = "UPDATE tb_process_survey "
|
+ "SET Process_starttime = '"+Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms)+"'"
|
+ ",ProcessTime = '"+Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms)+"'"
|
+ ",ProcessVersion = 'V"+version+"'"
|
+ " WHERE processid = 11018 ";
|
//System.out.println(sql_str);
|
sql.sqlMysqlExecute(sql_str);
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
}
|
|
//¸üеç³Ø×鸺ÔØÏ̵߳Äʱ¼ä´Á
|
public static void updateServerStartInf_Time(MysqlConnPool conn_pool){
|
Sql_Mysql sql = new Sql_Mysql(conn_pool.getConn());
|
try {
|
sql.sqlMysqlUseDB(Sql_Mysql.WEB_Site);
|
String sql_str = "UPDATE tb_process_survey SET ProcessTime = '"+Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms)
|
+ "' WHERE processid = 11018";
|
sql.sqlMysqlExecute(sql_str);
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
}
|
}
|
