package com.data;
|
|
import java.sql.ResultSet;
|
import java.sql.SQLException;
|
import java.util.Date;
|
|
import com.base.Com;
|
import com.dev.base.data.Dynamicload_button;
|
import com.dev.base.data.Dynamicload_control;
|
import com.dev.base.data.Dynamicload_state;
|
import com.sql.MysqlConnPool;
|
import com.sql.Sql_Mysql;
|
|
public class PowerArk_ServerSocket_Thread_SQL {
|
|
public static void insertOrUpdateDynamicload_ButtonTable(MysqlConnPool conn_pool,int dev_id) {
|
String sql_str_sel = " SELECT * FROM " +Sql_Mysql.Tb_Dynamicload_Button_Rt+ " WHERE dev_id = " + dev_id;
|
String sql_str_ins = " INSERT INTO " + Sql_Mysql.Tb_Dynamicload_Button_Rt + "(dev_id,FZ_b1,FZ_b2,FZ_b3,FZ_b4,FZ_b5,FZ_b6,FZ_b7,FZ_b8,FZ_b9,FZ_b10,FZ_b11,start_auto,stop_auto,sudden_crease,all_open,FZ_autostate1,FZ_autostate2,FZ_autostate3,FZ_autostate4,FZ_autostate5,local_control,back_control,central_control,inter_volume_M200,fan_button) "
|
+ " values("+dev_id+",0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0); ";
|
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(dev_id));
|
}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
|
* @param dev_id
|
*/
|
public static void insertOrUpdateDynamicload_ControlTable(MysqlConnPool conn_pool,int dev_id) {
|
String sql_str_sel = " SELECT * FROM " +Sql_Mysql.Tb_Dynamicload_Control+ " WHERE dev_id = " + dev_id;
|
String sql_str_ins = " INSERT INTO " + Sql_Mysql.Tb_Dynamicload_Control + "(dev_id,FZ_b1,FZ_b2,FZ_b3,FZ_b4,FZ_b5,FZ_b6,FZ_b7,FZ_b8,FZ_b9,FZ_b10,FZ_b11,start_auto,stop_auto,sudden_crease,all_open,FZ_autostate1,FZ_autostate2,FZ_autostate3,FZ_autostate4,FZ_autostate5,local_control,back_control,central_control,inter_volume_M200,fan_button,set_power) VALUES("+dev_id+",0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0)";
|
Sql_Mysql sql = new Sql_Mysql(conn_pool.getConn());
|
ResultSet res = null;
|
try {
|
res = sql.sqlMysqlQuery(sql_str_sel);
|
if(res.next()) {
|
//¸üе±Ç°×´Ì¬
|
updateDynamicload_ControlTable(conn_pool, new Dynamicload_control(dev_id));
|
}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
|
* @param dev_id
|
*/
|
public static void insertOrUpdateDynamicload_StateTable(MysqlConnPool conn_pool,int dev_id) {
|
String sql_str_sel = " SELECT * FROM " +Sql_Mysql.Tb_Dynamicload_State_rt+ " WHERE dev_id = " + dev_id;
|
String sql_str_ins = " INSERT INTO " + Sql_Mysql.Tb_Dynamicload_State_rt + "(dev_id,record_time,start_auto,stop_auto,sudden_crease,all_open,actual_set_power,output_power,set_power,interval_time,actual_curr,actual_mov,switch_on,FZ_autostate1,FZ_autostate2,FZ_autostate3,FZ_autostate4,FZ_autostate5,react_overtem,water_overtem,water_level_low,water_pressure_high,local_control,back_control,central_control,switch_state,inter_volume_M200,fan_button,fan_output,allow_close) VALUES("+dev_id+",'"+Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms)+"',0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0)";
|
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(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
|
* @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_ControlTable(MysqlConnPool conn_pool,Dynamicload_control control) {
|
String sql_str = " UPDATE " + Sql_Mysql.Tb_Dynamicload_Control
|
+ " SET FZ_b1= " + control.getFZ_b1()
|
+ ",FZ_b2 = " + control.getFZ_b2()
|
+ ",FZ_b3 = " + control.getFZ_b3()
|
+ ",FZ_b4 = " + control.getFZ_b4()
|
+ ",FZ_b5 = " + control.getFZ_b5()
|
+ ",FZ_b6 = " + control.getFZ_b6()
|
+ ",FZ_b7 = " + control.getFZ_b7()
|
+ ",FZ_b8 = " + control.getFZ_b8()
|
+ ",FZ_b9 = " + control.getFZ_b9()
|
+ ",FZ_b10 = " + control.getFZ_b10()
|
+ ",FZ_b11 = " + control.getFZ_b11()
|
+ ",start_auto = " + control.getStart_auto()
|
+ ",stop_auto = " + control.getStop_auto()
|
+ ",sudden_crease = " + control.getSudden_crease()
|
+ ",all_open = " + control.getAll_open()
|
+ ",FZ_autostate1 = " + control.getFZ_autostate1()
|
+ ",FZ_autostate2 = " + control.getFZ_autostate2()
|
+ ",FZ_autostate3 = " + control.getFZ_autostate3()
|
+ ",FZ_autostate4 = " + control.getFZ_autostate4()
|
+ ",FZ_autostate5 = " + control.getFZ_autostate5()
|
+ ",local_control = " + control.getLocal_control()
|
+ ",back_control = " + control.getBack_control()
|
+ ",central_control = " + control.getCentral_control()
|
+ ",inter_volume_M200 = " + control.getInter_volume_M200()
|
+ ",fan_button = " + control.getFan_button()
|
+ ",interval_time = " + control.interval_time
|
+ ",set_power = " + control.set_power
|
+ " WHERE dev_id = " + control.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 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 "
|
+" 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();
|
}
|
}
|
}
|
