package com.data;
|
|
import java.sql.ResultSet;
|
import java.sql.SQLException;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
import com.base.Com;
|
import com.dev.base.data.Dynamicload_button;
|
import com.dev.base.data.Dynamicload_control;
|
import com.dev.base.data.Dynamicload_inf;
|
import com.dev.base.data.Dynamicload_state;
|
import com.modbus.data.MyModbusMaster;
|
import com.sql.MysqlConnPool;
|
import com.sql.Sql_Mysql;
|
|
public class PowerArk_Task_SQL {
|
|
|
/**
|
* ³õʼ»¯Êý¾Ý¿â±í
|
* @param pool
|
*/
|
public static void init(MysqlConnPool pool) {
|
|
createDB_ElectricSystem(pool);
|
|
createTb_Dynamicload_inf(pool);
|
|
//initTb_Dynamicload_inf(pool);
|
|
createTb_Dynamicload_Button_Rt(pool);
|
|
createTb_Dynamicload_State_rt(pool);
|
|
createTb_Dynamicload_Control(pool);
|
|
}
|
/**
|
* ´´½¨¸ºÔØÊý¾Ý¿â
|
* @param pool
|
*/
|
public static void createDB_ElectricSystem(MysqlConnPool pool) {
|
Sql_Mysql sql = new Sql_Mysql(pool.getConn());
|
try {
|
sql.sqlMysqlExecute("CREATE DATABASE IF NOT EXISTS " + Sql_Mysql.DB_DynamicSystem);
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
}
|
/**
|
* ´´½¨¸ºÔØÐÅÏ¢±í
|
* @param pool
|
*/
|
public static void createTb_Dynamicload_inf(MysqlConnPool pool) {
|
String sql_str = "CREATE TABLE IF NOT EXISTS "+Sql_Mysql.Tb_Dynamicload_inf+" (" +
|
" num bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'Ö÷¼ü'," +
|
" dev_id int(11) NOT NULL DEFAULT '1' COMMENT 'É豸id'," +
|
" dev_name varchar(126) NOT NULL DEFAULT '' COMMENT 'É豸Ãû³Æ'," +
|
" dev_type int(11) NOT NULL DEFAULT '0' COMMENT 'É豸ÀàÐÍ 1:¸ºÔØ.....'," +
|
" FZ_button_num int(11) NOT NULL DEFAULT '10' COMMENT '¸ºÔعñÉÏ°´Å¥¸öÊý',"+
|
" dev_ip varchar(126) NOT NULL DEFAULT '' COMMENT 'É豸ip'," +
|
" note varchar(255) NOT NULL DEFAULT ''," +
|
" PRIMARY KEY (num)," +
|
" UNIQUE KEY dev_id_key (dev_id)" +
|
") ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;";
|
Sql_Mysql sql = new Sql_Mysql(pool.getConn());
|
try {
|
sql.sqlMysqlExecute(sql_str);
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
}
|
/**
|
* ³õʼ»¯¸ºÔØÐÅÏ¢±í
|
* @param pool
|
*/
|
public static void initTb_Dynamicload_inf(MysqlConnPool pool) {
|
String sql_str= " replace INTO " + Sql_Mysql.Tb_Dynamicload_inf + "(dev_id,dev_name,dev_type,FZ_button_num,dev_ip) VALUES(1001,1,1,10,'127.0.0.1'),(1002,2,1,11,'127.0.0.1'),(1003,3,1,10,'127.0.0.1'),(1004,4,1,10,'127.0.0.1')";
|
|
Sql_Mysql sql = new Sql_Mysql(pool.getConn());
|
try {
|
sql.sqlMysqlExecute(sql_str);
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
}
|
/**
|
* ´´½¨°´Å¥ÊµÊ±ÐÅÏ¢
|
* @param pool
|
*/
|
public static void createTb_Dynamicload_Button_Rt(MysqlConnPool pool) {
|
String sql_str = "CREATE TABLE IF NOT EXISTS "+Sql_Mysql.Tb_Dynamicload_Button_Rt+" (" +
|
" num bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'Ö÷¼ü'," +
|
" dev_id int(11) NOT NULL DEFAULT '1' COMMENT 'É豸id'," +
|
" FZ_b1 int(11) NOT NULL DEFAULT '1' COMMENT 'FZ°´Å¥1'," +
|
" FZ_b2 int(11) NOT NULL DEFAULT '1' COMMENT 'FZ°´Å¥2'," +
|
" FZ_b3 int(11) NOT NULL DEFAULT '1' COMMENT 'FZ°´Å¥3'," +
|
" FZ_b4 int(11) NOT NULL DEFAULT '1' COMMENT 'FZ°´Å¥4'," +
|
" FZ_b5 int(11) NOT NULL DEFAULT '1' COMMENT 'FZ°´Å¥5'," +
|
" FZ_b6 int(11) NOT NULL DEFAULT '1' COMMENT 'FZ°´Å¥6'," +
|
" FZ_b7 int(11) NOT NULL DEFAULT '1' COMMENT 'FZ°´Å¥7'," +
|
" FZ_b8 int(11) NOT NULL DEFAULT '1' COMMENT 'FZ°´Å¥8'," +
|
" FZ_b9 int(11) NOT NULL DEFAULT '1' COMMENT 'FZ°´Å¥9'," +
|
" FZ_b10 int(11) NOT NULL DEFAULT '1' COMMENT 'FZ°´Å¥10'," +
|
" FZ_b11 int(11) NOT NULL DEFAULT '1' COMMENT 'FZ°´Å¥11'," +
|
" FZ_b1_power float NOT NULL DEFAULT '37.5' COMMENT 'FZ°´Å¥1¶î¶¨¹¦ÂÊ'," +
|
" FZ_b2_power float NOT NULL DEFAULT '37.5' COMMENT 'FZ°´Å¥2¶î¶¨¹¦ÂÊ'," +
|
" FZ_b3_power float NOT NULL DEFAULT '75' COMMENT 'FZ°´Å¥3¶î¶¨¹¦ÂÊ'," +
|
" FZ_b4_power float NOT NULL DEFAULT '75' COMMENT 'FZ°´Å¥4¶î¶¨¹¦ÂÊ'," +
|
" FZ_b5_power float NOT NULL DEFAULT '75' COMMENT 'FZ°´Å¥5¶î¶¨¹¦ÂÊ'," +
|
" FZ_b6_power float NOT NULL DEFAULT '75' COMMENT 'FZ°´Å¥6¶î¶¨¹¦ÂÊ'," +
|
" FZ_b7_power float NOT NULL DEFAULT '75' COMMENT 'FZ°´Å¥7¶î¶¨¹¦ÂÊ'," +
|
" FZ_b8_power float NOT NULL DEFAULT '75' COMMENT 'FZ°´Å¥8¶î¶¨¹¦ÂÊ'," +
|
" FZ_b9_power float NOT NULL DEFAULT '112.5' COMMENT 'FZ°´Å¥9¶î¶¨¹¦ÂÊ'," +
|
" FZ_b10_power float NOT NULL DEFAULT '112.5' COMMENT 'FZ°´Å¥10¶î¶¨¹¦ÂÊ'," +
|
" FZ_b11_power float NOT NULL DEFAULT '200' COMMENT 'FZ°´Å¥11¶î¶¨¹¦ÂÊ'," +
|
" FZ_fw1 int(11) NOT NULL DEFAULT '1' COMMENT 'FZ·´À¡°´Å¥1'," +
|
" FZ_fw2 int(11) NOT NULL DEFAULT '1' COMMENT 'FZ·´À¡°´Å¥2'," +
|
" FZ_fw3 int(11) NOT NULL DEFAULT '1' COMMENT 'FZ·´À¡°´Å¥3'," +
|
" FZ_fw4 int(11) NOT NULL DEFAULT '1' COMMENT 'FZ·´À¡°´Å¥4'," +
|
" FZ_fw5 int(11) NOT NULL DEFAULT '1' COMMENT 'FZ·´À¡°´Å¥5'," +
|
" FZ_fw6 int(11) NOT NULL DEFAULT '1' COMMENT 'FZ·´À¡°´Å¥6'," +
|
" FZ_fw7 int(11) NOT NULL DEFAULT '1' COMMENT 'FZ·´À¡°´Å¥7'," +
|
" FZ_fw8 int(11) NOT NULL DEFAULT '1' COMMENT 'FZ·´À¡°´Å¥8'," +
|
" FZ_fw9 int(11) NOT NULL DEFAULT '1' COMMENT 'FZ·´À¡°´Å¥9'," +
|
" FZ_fw10 int(11) NOT NULL DEFAULT '1' COMMENT 'FZ·´À¡°´Å¥10'," +
|
" FZ_fw11 int(11) NOT NULL DEFAULT '1' COMMENT 'FZ·´À¡°´Å¥11'," +
|
" FZ_ex1 int(11) NOT NULL DEFAULT '1' COMMENT 'FZÊä³ö°´Å¥1'," +
|
" FZ_ex2 int(11) NOT NULL DEFAULT '1' COMMENT 'FZÊä³ö°´Å¥2'," +
|
" FZ_ex3 int(11) NOT NULL DEFAULT '1' COMMENT 'FZÊä³ö°´Å¥3'," +
|
" FZ_ex4 int(11) NOT NULL DEFAULT '1' COMMENT 'FZÊä³ö°´Å¥4'," +
|
" FZ_ex5 int(11) NOT NULL DEFAULT '1' COMMENT 'FZÊä³ö°´Å¥5'," +
|
" FZ_ex6 int(11) NOT NULL DEFAULT '1' COMMENT 'FZÊä³ö°´Å¥6'," +
|
" FZ_ex7 int(11) NOT NULL DEFAULT '1' COMMENT 'FZÊä³ö°´Å¥7'," +
|
" FZ_ex8 int(11) NOT NULL DEFAULT '1' COMMENT 'FZÊä³ö°´Å¥8'," +
|
" FZ_ex9 int(11) NOT NULL DEFAULT '1' COMMENT 'FZÊä³ö°´Å¥9'," +
|
" FZ_ex10 int(11) NOT NULL DEFAULT '1' COMMENT 'FZÊä³ö°´Å¥10'," +
|
" FZ_ex11 int(11) NOT NULL DEFAULT '1' COMMENT 'FZÊä³ö°´Å¥11'," +
|
" note varchar(255) NOT NULL DEFAULT ''," +
|
" PRIMARY KEY (num)," +
|
" KEY dev_id_key (dev_id)" +
|
") ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;";
|
Sql_Mysql sql = new Sql_Mysql(pool.getConn());
|
try {
|
sql.sqlMysqlExecute(sql_str);
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
}
|
/**
|
* ´´½¨¸ºÔØÐÅÏ¢±í
|
* @param pool
|
*/
|
public static void createTb_Dynamicload_State_rt(MysqlConnPool pool) {
|
String sql_str = "CREATE TABLE IF NOT EXISTS "+Sql_Mysql.Tb_Dynamicload_State_rt+" (" +
|
" num int(11) NOT NULL AUTO_INCREMENT COMMENT 'Ö÷¼ü'," +
|
" dev_id int(11) NOT NULL DEFAULT '1001' COMMENT 'É豸id'," +
|
" record_time datetime NOT NULL DEFAULT '2000-01-01 00:00:00' COMMENT '¼Ç¼ʱ¼ä'," +
|
" start_auto int(11) NOT NULL DEFAULT '0' COMMENT 'Æô¶¯×Ô¶¯¼ÓÔØ'," +
|
" stop_auto int(11) NOT NULL DEFAULT '0' COMMENT 'Í£Ö¹×Ô¶¯¼ÓÔØ'," +
|
" sudden_crease int(11) NOT NULL DEFAULT '0' COMMENT 'Í»¼Óͻж'," +
|
" all_open int(11) NOT NULL DEFAULT '0' COMMENT 'È«²¿·ÖÕ¢'," +
|
" actual_set_power float NOT NULL DEFAULT '0' COMMENT 'ʵ¼ÊÉ趨¹¦ÂÊ'," +
|
" output_power float NOT NULL DEFAULT '0' COMMENT 'ÒÑÊä³ö¹¦ÂÊ'," +
|
" set_power float NOT NULL DEFAULT '0' COMMENT 'É趨¹¦ÂÊ'," +
|
" interval_time float NOT NULL DEFAULT '0' COMMENT '¼ä¸ôʱ¼äs'," +
|
" actual_curr float NOT NULL DEFAULT '0' COMMENT 'ʵ¼ÊµçÁ÷'," +
|
" actual_mov float NOT NULL DEFAULT '0' COMMENT 'ʵ¼Êµçѹ'," +
|
" switch_on int(11) NOT NULL DEFAULT '0' COMMENT 'ÊÇ·ñºÏÕ¢'," +
|
" FZ_autostate1 int(11) NOT NULL DEFAULT '0' COMMENT 'FZ×Ô¶¯×´Ì¬1'," +
|
" FZ_autostate2 int(11) NOT NULL DEFAULT '0' COMMENT 'FZ×Ô¶¯×´Ì¬2'," +
|
" FZ_autostate3 int(11) NOT NULL DEFAULT '0' COMMENT 'FZ×Ô¶¯×´Ì¬3'," +
|
" FZ_autostate4 int(11) NOT NULL DEFAULT '0' COMMENT 'FZ×Ô¶¯×´Ì¬4'," +
|
" FZ_autostate5 int(11) NOT NULL DEFAULT '0' COMMENT 'FZ×Ô¶¯×´Ì¬5'," +
|
" react_overtem int(11) NOT NULL DEFAULT '0' COMMENT 'µç¿¹³¬ÎÂ'," +
|
" water_overtem int(11) NOT NULL DEFAULT '0' COMMENT 'ÀäÈ´Ë®³¬ÎÂ'," +
|
" water_level_low int(11) NOT NULL DEFAULT '0' COMMENT 'ÀäȴˮҺλµÍ'," +
|
" water_pressure_high int(11) NOT NULL DEFAULT '0' COMMENT 'Àäȴˮѹ¸ß'," +
|
" local_control int(11) NOT NULL DEFAULT '0' COMMENT '¾ÍµØ¿ØÖÆ'," +
|
" back_control int(11) NOT NULL DEFAULT '0' COMMENT 'ºǫ́¿ØÖÆ'," +
|
" central_control int(11) NOT NULL DEFAULT '0' COMMENT 'ÖпؿØÖÆ'," +
|
" switch_state int(11) NOT NULL DEFAULT '0' COMMENT '¿ª¹Ø¹ñ״̬'," +
|
" inter_volume_M200 int(11) NOT NULL DEFAULT '0' COMMENT 'ÖмäÁ¿M200'," +
|
" fan_button int(11) NOT NULL DEFAULT '0' COMMENT '·ç»ú°´Å¥'," +
|
" fan_output int(11) NOT NULL DEFAULT '0' COMMENT '·ç»úÊä³ö'," +
|
" allow_close int(11) NOT NULL DEFAULT '0' COMMENT 'ÊÇ·ñÔÊÐíºÏÕ¢'," +
|
" note varchar(255) NOT NULL DEFAULT ''," +
|
" PRIMARY KEY (num)," +
|
" KEY dev_id_key (dev_id)" +
|
") ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;";
|
Sql_Mysql sql = new Sql_Mysql(pool.getConn());
|
ResultSet res = null;
|
try {
|
sql.sqlMysqlExecute(sql_str);
|
//Ìí¼Ó¼Ç¼ʱ¼äÁУ¬·½±ã»æÖÆʵʱÇúÏß
|
res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
+ " WHERE table_schema='db_dynamicsystem'"
|
+ " AND table_name='tb_dynamicload_state_rt'"
|
+ " AND column_name='record_time'");
|
if(false == res.next()) {
|
sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.Tb_Dynamicload_State_rt
|
+ " ADD COLUMN `record_time` datetime NOT NULL DEFAULT '2000-01-01 00:00:00' after dev_id;");
|
}
|
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
}
|
/**
|
* ´´½¨¿ØÖƱí
|
* @param pool
|
*/
|
public static void createTb_Dynamicload_Control(MysqlConnPool pool) {
|
String sql_str = "CREATE TABLE IF NOT EXISTS "+Sql_Mysql.Tb_Dynamicload_Control+" (" +
|
" num int(11) NOT NULL AUTO_INCREMENT COMMENT 'Ö÷¼ü'," +
|
" dev_id int(11) NOT NULL DEFAULT '1' COMMENT 'É豸id'," +
|
" FZ_b1 int(11) NOT NULL DEFAULT '1' COMMENT 'FZ°´Å¥1'," +
|
" FZ_b2 int(11) NOT NULL DEFAULT '1' COMMENT 'FZ°´Å¥2'," +
|
" FZ_b3 int(11) NOT NULL DEFAULT '1' COMMENT 'FZ°´Å¥3'," +
|
" FZ_b4 int(11) NOT NULL DEFAULT '1' COMMENT 'FZ°´Å¥4'," +
|
" FZ_b5 int(11) NOT NULL DEFAULT '1' COMMENT 'FZ°´Å¥5'," +
|
" FZ_b6 int(11) NOT NULL DEFAULT '1' COMMENT 'FZ°´Å¥6'," +
|
" FZ_b7 int(11) NOT NULL DEFAULT '1' COMMENT 'FZ°´Å¥7'," +
|
" FZ_b8 int(11) NOT NULL DEFAULT '1' COMMENT 'FZ°´Å¥8'," +
|
" FZ_b9 int(11) NOT NULL DEFAULT '1' COMMENT 'FZ°´Å¥9'," +
|
" FZ_b10 int(11) NOT NULL DEFAULT '1' COMMENT 'FZ°´Å¥10'," +
|
" FZ_b11 int(11) NOT NULL DEFAULT '1' COMMENT 'FZ°´Å¥11'," +
|
" start_auto int(11) NOT NULL DEFAULT '1' COMMENT 'Æô¶¯×Ô¶¯¼ÓÔØ'," +
|
" stop_auto int(11) NOT NULL DEFAULT '1' COMMENT 'Í£Ö¹×Ô¶¯¼ÓÔØ'," +
|
" sudden_crease int(11) NOT NULL DEFAULT '1' COMMENT 'Í»¼Óͻж'," +
|
" all_open int(11) NOT NULL DEFAULT '1' COMMENT 'È«²¿·ÖÕ¢'," +
|
" FZ_autostate1 int(11) NOT NULL DEFAULT '1' COMMENT 'FZ×Ô¶¯×´Ì¬1'," +
|
" FZ_autostate2 int(11) NOT NULL DEFAULT '1' COMMENT 'FZ×Ô¶¯×´Ì¬2'," +
|
" FZ_autostate3 int(11) NOT NULL DEFAULT '1' COMMENT 'FZ×Ô¶¯×´Ì¬3'," +
|
" FZ_autostate4 int(11) NOT NULL DEFAULT '1' COMMENT 'FZ×Ô¶¯×´Ì¬4'," +
|
" FZ_autostate5 int(11) NOT NULL DEFAULT '1' COMMENT 'FZ×Ô¶¯×´Ì¬5'," +
|
" local_control int(11) NOT NULL DEFAULT '1' COMMENT '¾ÍµØ¿ØÖÆ'," +
|
" back_control int(11) NOT NULL DEFAULT '1' COMMENT 'ºǫ́¿ØÖÆ'," +
|
" central_control int(11) NOT NULL DEFAULT '1' COMMENT 'ÖпؿØÖÆ'," +
|
" inter_volume_M200 int(11) NOT NULL DEFAULT '1' COMMENT 'ÖмäÁ¿M200'," +
|
" fan_button int(11) NOT NULL DEFAULT '1' COMMENT '·ç»ú°´Å¥'," +
|
" set_power float NOT NULL DEFAULT '0' COMMENT 'É趨¹¦ÂÊ'," +
|
" note varchar(255) NOT NULL DEFAULT ''," +
|
" interval_time int(11) NOT NULL DEFAULT '0'," +
|
" PRIMARY KEY (num)," +
|
" KEY dev_id_key (dev_id)" +
|
") ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;";
|
Sql_Mysql sql = new Sql_Mysql(pool.getConn());
|
try {
|
sql.sqlMysqlExecute(sql_str);
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
}
|
/**
|
* ²åÈë»ò¸üиºÔØ°´Å¥ÐÅÏ¢±í
|
* @param conn_pool
|
* @param dev_id
|
*/
|
public static void insertOrUpdateDynamicload_ButtonTable(MysqlConnPool conn_pool,Dynamicload_button dbutton,int button_num) {
|
String sql_str_sel = " SELECT * FROM " +Sql_Mysql.Tb_Dynamicload_Button_Rt+ " WHERE dev_id = " + dbutton.getDev_id();
|
String sql_str_ins10 = " INSERT INTO " + Sql_Mysql.Tb_Dynamicload_Button_Rt + "(dev_id,FZ_b1_power,FZ_b2_power,FZ_b3_power,FZ_b4_power,FZ_b5_power,FZ_b6_power,FZ_b7_power,FZ_b8_power,FZ_b9_power,FZ_b10_power,FZ_b11_power) VALUES("+dbutton.dev_id+",37.5,37.5,75,75,75,75,75,75,112.5,112.5,0)";
|
String sql_str_ins11 = " INSERT INTO " + Sql_Mysql.Tb_Dynamicload_Button_Rt + "(dev_id,FZ_b1_power,FZ_b2_power,FZ_b3_power,FZ_b4_power,FZ_b5_power,FZ_b6_power,FZ_b7_power,FZ_b8_power,FZ_b9_power,FZ_b10_power,FZ_b11_power) VALUES("+dbutton.dev_id+",5,5,10,10,20,50,50,100,100,200,200)";
|
Sql_Mysql sql = new Sql_Mysql(conn_pool.getConn());
|
ResultSet res = null;
|
try {
|
res = sql.sqlMysqlQuery(sql_str_sel);
|
if(res.next()) {
|
//¸üе±Ç°×´Ì¬
|
updateDynamicload_ButtonTable(conn_pool, new Dynamicload_button(dbutton.dev_id));
|
}else {
|
//²åÈëĬÈÏ״̬
|
if(button_num==11) {
|
sql.sqlMysqlExecute(sql_str_ins11);
|
}else {
|
sql.sqlMysqlExecute(sql_str_ins10);
|
}
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
} finally {
|
if(res != null) {
|
try {
|
res.close();
|
} catch (SQLException e) {
|
e.printStackTrace();
|
}
|
}
|
sql.close_con();
|
}
|
}
|
/**
|
* ²åÈë»ò¸üиºÔØ״̬ÐÅÏ¢±í
|
* @param conn_pool
|
* @param dev_id
|
*/
|
public static void insertOrUpdateDynamicload_StateTable(MysqlConnPool conn_pool,Dynamicload_state dstate) {
|
String sql_str_sel = " SELECT * FROM " +Sql_Mysql.Tb_Dynamicload_State_rt+ " WHERE dev_id = " + dstate.dev_id;
|
String sql_str_ins = " INSERT INTO " + Sql_Mysql.Tb_Dynamicload_State_rt + "(dev_id,record_time) VALUES("+dstate.dev_id+",'"+Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms)+"')";
|
Sql_Mysql sql = new Sql_Mysql(conn_pool.getConn());
|
ResultSet res = null;
|
try {
|
res = sql.sqlMysqlQuery(sql_str_sel);
|
if(res.next()) {
|
//¸üе±Ç°×´Ì¬
|
updateDynamicload_StateTable(conn_pool, new Dynamicload_state(dstate.dev_id,0));
|
}else {
|
//²åÈëĬÈÏ״̬
|
sql.sqlMysqlExecute(sql_str_ins);
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
} finally {
|
if(res != null) {
|
try {
|
res.close();
|
} catch (SQLException e) {
|
e.printStackTrace();
|
}
|
}
|
sql.close_con();
|
}
|
}
|
|
/**
|
* ²éѯËùÓеÄÉ豸ÐÅÏ¢
|
* @param conn_pool
|
* @return
|
*/
|
public static List<Dynamicload_inf> queryAllPowerArk(MysqlConnPool conn_pool){
|
List<Dynamicload_inf> dys = new ArrayList<Dynamicload_inf>();
|
String sql_str = " SELECT * FROM db_dynamicsystem.tb_dynamicload_inf ";
|
ResultSet res = null;
|
Sql_Mysql sql = new Sql_Mysql(conn_pool.getConn());
|
try {
|
res = sql.sqlMysqlQuery(sql_str);
|
Dynamicload_inf dyna = null;
|
while(res.next()) {
|
dyna = new Dynamicload_inf();
|
dyna.setDev_id(res.getInt("dev_id"));
|
dyna.setDev_ip(res.getString("dev_ip"));
|
dyna.setDev_name(res.getString("dev_name"));
|
dyna.setDev_type(res.getInt("dev_type"));
|
dyna.setFZ_button_num(res.getInt("fZ_button_num"));
|
dyna.setNote(res.getString("note"));
|
|
dyna.button = new Dynamicload_button(dyna.dev_id);
|
dyna.control = new Dynamicload_control(dyna.dev_id,dyna.getFZ_button_num());
|
dyna.state = new Dynamicload_state(dyna.dev_id,0);
|
dys.add(dyna);
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
} finally {
|
if(res != null) {
|
try {
|
res.close();
|
} catch (SQLException e) {
|
e.printStackTrace();
|
}
|
sql.close_con();
|
}
|
}
|
return dys;
|
}
|
|
/**
|
* ¸üÐÂÉ豸°´Å¥ÐÅÏ¢
|
* @param conn_pool
|
* @param control
|
*/
|
public static void updateDynamicload_ButtonTable(MysqlConnPool conn_pool,Dynamicload_button button) {
|
String sql_str = " UPDATE " + Sql_Mysql.Tb_Dynamicload_Button_Rt
|
+" SET "
|
+" FZ_b1=" + button.FZ_b1
|
+",FZ_b2=" + button.FZ_b2
|
+",FZ_b3=" + button.FZ_b3
|
+",FZ_b4=" + button.FZ_b4
|
+",FZ_b5=" + button.FZ_b5
|
+",FZ_b6=" + button.FZ_b6
|
+",FZ_b7=" + button.FZ_b7
|
+",FZ_b8=" + button.FZ_b8
|
+",FZ_b9=" + button.FZ_b9
|
+",FZ_b10=" + button.FZ_b10
|
+",FZ_b11=" + button.FZ_b11
|
+",FZ_fw1=" + button.FZ_fw1
|
+",FZ_fw2=" + button.FZ_fw2
|
+",FZ_fw3=" + button.FZ_fw3
|
+",FZ_fw4=" + button.FZ_fw4
|
+",FZ_fw5=" + button.FZ_fw5
|
+",FZ_fw6=" + button.FZ_fw6
|
+",FZ_fw7=" + button.FZ_fw7
|
+",FZ_fw8=" + button.FZ_fw8
|
+",FZ_fw9=" + button.FZ_fw9
|
+",FZ_fw10=" + button.FZ_fw10
|
+",FZ_fw11=" + button.FZ_fw11
|
+",FZ_ex1=" + button.FZ_ex1
|
+",FZ_ex2=" + button.FZ_ex2
|
+",FZ_ex3=" + button.FZ_ex3
|
+",FZ_ex4=" + button.FZ_ex4
|
+",FZ_ex5=" + button.FZ_ex5
|
+",FZ_ex6=" + button.FZ_ex6
|
+",FZ_ex7=" + button.FZ_ex7
|
+",FZ_ex8=" + button.FZ_ex8
|
+",FZ_ex9=" + button.FZ_ex9
|
+",FZ_ex10=" + button.FZ_ex10
|
+",FZ_ex11=" + button.FZ_ex11
|
+" WHERE dev_id = " + button.dev_id;
|
Sql_Mysql sql = new Sql_Mysql(conn_pool.getConn());
|
try {
|
sql.sqlMysqlExecute(sql_str);
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
}
|
|
|
/**
|
* ¸üÐÂÉ豸״̬ÐÅÏ¢
|
* @param conn_pool
|
* @param control
|
*/
|
public static void updateDynamicload_StateTable(MysqlConnPool conn_pool,Dynamicload_state state) {
|
String sql_str = " UPDATE " + Sql_Mysql.Tb_Dynamicload_State_rt
|
+ " SET "
|
+" record_time='" + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms)+"'"
|
+",start_auto=" + state.getStart_auto()
|
+",stop_auto=" + state.getStop_auto()
|
+",sudden_crease=" + state.getSudden_crease()
|
+",all_open=" + state.getAll_open()
|
+",actual_set_power=" + state.getActual_set_power()
|
+",output_power=" + state.getOutput_power()
|
+",set_power=" + state.getSet_power()
|
+",interval_time=" + state.getInterval_time()
|
+",actual_curr=" + state.getActual_curr()
|
+",actual_mov=" + state.getActual_mov()
|
+",switch_on=" + state.getSwitch_on()
|
+",FZ_autostate1=" + state.getFZ_autostate1()
|
+",FZ_autostate2=" + state.getFZ_autostate2()
|
+",FZ_autostate3=" + state.getFZ_autostate3()
|
+",FZ_autostate4=" + state.getFZ_autostate4()
|
+",FZ_autostate5=" + state.getFZ_autostate5()
|
+",react_overtem=" + state.getReact_overtem()
|
+",water_overtem=" + state.getWater_overtem()
|
+",water_level_low=" + state.getWater_level_low()
|
+",water_pressure_high=" + state.getWater_pressure_high()
|
+",local_control=" + state.getLocal_control()
|
+",back_control=" + state.getBack_control()
|
+",central_control=" + state.getCentral_control()
|
+",switch_state=" + state.getSwitch_state()
|
+",inter_volume_M200=" + state.getInter_volume_M200()
|
+",fan_button=" + state.getFan_button()
|
+",fan_output=" + state.getFan_output()
|
+",allow_close=" + state.allow_close
|
+ " WHERE dev_id = " + state.dev_id;
|
Sql_Mysql sql = new Sql_Mysql(conn_pool.getConn());
|
try {
|
//System.out.println(sql_str);
|
sql.sqlMysqlExecute(sql_str);
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
}
|
|
|
/**
|
* ²åÈë»ò¸üе±Ç°É豸µÄÁ¬½Ó״̬
|
* @param pool
|
* @param dev_id
|
* @param master
|
*/
|
public static void insertOrUpdateDeviceConnectState(MysqlConnPool pool,int dev_id,MyModbusMaster master) {
|
String sql_str_sel = " SELECT * FROM "+Sql_Mysql.Tb_Device_ConnectState+" WHERE dev_id = " + dev_id;
|
String sql_str_ins = " INSERT INTO "+Sql_Mysql.Tb_Device_ConnectState+"(dev_id,connect_en,record_time) values("+dev_id+","+master.getConnectState()+",'"+Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms)+"');";
|
String sql_str_upd = " UPDATE "+Sql_Mysql.Tb_Device_ConnectState+" SET connect_en = "+master.getConnectState()+",record_time='"+Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms)+"' WHERE dev_id = " + dev_id;
|
Sql_Mysql sql = new Sql_Mysql(pool.getConn());
|
ResultSet res = null;
|
try {
|
res = sql.sqlMysqlQuery(sql_str_sel);
|
if(res.next()) {
|
sql.sqlMysqlExecute(sql_str_upd);
|
}else {
|
sql.sqlMysqlExecute(sql_str_ins);
|
}
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} finally {
|
if(res != null) {
|
try {
|
res.close();
|
} catch (SQLException e) {
|
e.printStackTrace();
|
}
|
sql.close_con();
|
}
|
}
|
}
|
}
|
