From 5563293e54259b6baeb98ec9785f747aa3fbdc6a Mon Sep 17 00:00:00 2001 From: whyclxw <810412026@qq,com> Date: 星期四, 27 八月 2020 14:32:53 +0800 Subject: [PATCH] 负载部分修改提交 --- src/com/data/PowerArk_ServerSocket_Thread_SQL.java | 516 ++++++++++++++++++++++++++++---------------------------- 1 files changed, 258 insertions(+), 258 deletions(-) diff --git a/src/com/data/PowerArk_ServerSocket_Thread_SQL.java b/src/com/data/PowerArk_ServerSocket_Thread_SQL.java index eacb09f..60055d2 100644 --- a/src/com/data/PowerArk_ServerSocket_Thread_SQL.java +++ b/src/com/data/PowerArk_ServerSocket_Thread_SQL.java @@ -1,258 +1,258 @@ -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)); - }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(); - } - } -} +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(); + } + } +} -- Gitblit v1.9.1