修改

whyclxw

2020-09-19 a40f38549cead32b4a04c014863154f5942c44ff

 src/com/data/PowerArk_ServerSocket_Thread_SQL.java

@@ -1,257 +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()

            + ",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,11));
         }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();
      }
   }
}