水冷将replace改成update

whyclj

2020-09-24 06eea2578a9f80002a87c90e389231e703fd2d4d

 WaterSystem_MonitorServer/src/com/watersystem/monitor/Water_Task_SQL.java

@@ -262,6 +262,40 @@
         sql.close_con();
      }
   }
	
   /**
    *    更新water_rt表
    * @param pool
    * @param wrt
    */
   public static void update_water_rt(MysqlConnPool pool,Water_rt wrt) {
      String sql_str = " update " + Sql_Mysql.Tb_water_rt +" set "
            + "water_id=" + wrt.water_id
            + ",cooling_flow=" +wrt.cooling_flow
            + ",supply_tmp=" + wrt.supply_tmp 
            + ",Supply_pre=" + wrt.Supply_pre 
            + ",back_tem=" + wrt.back_tem
            + ",back_pre=" + wrt.back_pre
            + ",Cooling_ser=" + wrt.Cooling_ser
            + ",Buffer_tank_level=" + wrt.Buffer_tank_level
            + ",Buffer_tank_pre=" + wrt.Buffer_tank_pre
            + ",Humidity_chamber=" + wrt.Humidity_chamber
            + ",Tem_chamber=" + wrt.Tem_chamber
            + ",External_tmp=" + wrt.External_tmp
            + ",External_pre=" + wrt.External_pre
            + " where water_id= " + wrt.water_id;
      Sql_Mysql sql = new Sql_Mysql(pool.getConn());
      try {
         sql.sqlMysqlExecute(sql_str);
      } catch (SQLException e) {
         e.printStackTrace();
      } finally {
         sql.close_con();
      }
   }
	
	
	
   //插入或更新水冷系统实时分支信息表
   public static void replace_water_brach(MysqlConnPool pool,Water_brach wbrach) {
      String sql_str = " replace into "+ Sql_Mysql.Tb_water_brach+"(water_id,Branch_flow_1,Branch_flow_2,Branch_flow_3,Branch_flow_4,Branch_flow_5,Branch_flow_6,Branch_flow_7,Branch_flow_8,Branch_flow_9,Branch_tmp_1,Branch_tmp_2,Branch_tmp_3,Branch_tmp_4,Branch_tmp_5,Branch_tmp_6,Branch_tmp_7,Branch_tmp_8,Branch_tmp_9,Branch_pre_1,Branch_pre_2,Branch_pre_3,Branch_pre_4,Branch_pre_5,Branch_pre_6,Branch_pre_7,Branch_pre_8,Branch_pre_9)  "
@@ -277,6 +311,57 @@
         sql.close_con();
      }
   }
	
   /**
    *    更新水冷系统实时分支信息表
    * @param pool
    * @param wbrach
    */
   public static void update_water_brach(MysqlConnPool pool,Water_brach wbrach) {
      String sql_str = " update  "+Sql_Mysql.Tb_water_brach +" "
            + " Set water_id=" + wbrach.water_id
            + ",Branch_flow_1=" + wbrach.Branch_flow_1
            + ",Branch_flow_2=" + wbrach.Branch_flow_2
            + ",Branch_flow_3=" + wbrach.Branch_flow_3
            + ",Branch_flow_4=" + wbrach.Branch_flow_4
            + ",Branch_flow_5=" + wbrach.Branch_flow_5
            + ",Branch_flow_6=" + wbrach.Branch_flow_6
            + ",Branch_flow_7=" + wbrach.Branch_flow_7
            + ",Branch_flow_8=" + wbrach.Branch_flow_8
            + ",Branch_flow_9=" + wbrach.Branch_flow_9
            + ",Branch_tmp_1=" + wbrach.Branch_tmp_1
            + ",Branch_tmp_2=" + wbrach.Branch_tmp_2
            + ",Branch_tmp_3=" + wbrach.Branch_tmp_3
            + ",Branch_tmp_4=" + wbrach.Branch_tmp_4
            + ",Branch_tmp_5=" + wbrach.Branch_tmp_5
            + ",Branch_tmp_6=" + wbrach.Branch_tmp_6
            + ",Branch_tmp_7=" + wbrach.Branch_tmp_7
            + ",Branch_tmp_8=" + wbrach.Branch_tmp_8
            + ",Branch_tmp_9=" + wbrach.Branch_tmp_9
            + ",Branch_pre_1=" + wbrach.Branch_pre_1
            + ",Branch_pre_2=" + wbrach.Branch_pre_2
            + ",Branch_pre_3=" + wbrach.Branch_pre_3
            + ",Branch_pre_4=" + wbrach.Branch_pre_4
            + ",Branch_pre_5=" + wbrach.Branch_pre_5
            + ",Branch_pre_6=" + wbrach.Branch_pre_6
            + ",Branch_pre_7=" + wbrach.Branch_pre_7
            + ",Branch_pre_8=" + wbrach.Branch_pre_8
            + ",Branch_pre_9=" + wbrach.Branch_pre_9
            + " Where water_id = " + wbrach.water_id;
		
      Sql_Mysql sql = new Sql_Mysql(pool.getConn());
      try {
         //System.out.println(sql_str);
         sql.sqlMysqlExecute(sql_str);
      } catch (SQLException e) {
         e.printStackTrace();
      } finally {
         sql.close_con();
      }
   }
	
	
	
   //插入或更新水冷系统实时信息表
   public static void replace_water_state(MysqlConnPool pool,Water_state wstate) {
      String sql_str = " replace into "+ Sql_Mysql.Tb_water_state+"(water_id,P01_main_pump,P11_replenish_pump,P12_pretest_pump,P13_replenish_pump,H01_electric_heater,H02_electric_heater,Solenoid_openflag,Solenoid_shutflag,valve_start,Exhaust_start,remote_start,remote_stop,Operation_ooled_devices,Auto_control_state,Manual_control_state,remote_control_state,Water_system_function)  "
@@ -293,6 +378,43 @@
   }
    
   /**
    *    插入或更新水冷系统实时信息表
    * @param pool
    * @param wstate
    */
   public static void update_water_state(MysqlConnPool pool,Water_state wstate) {
      String sql_str = " update " + Sql_Mysql.Tb_water_state + " "
            + " Set  water_id=" + wstate.water_id
            + ",P01_main_pump=" + wstate.P01_main_pump
            + ",P11_replenish_pump=" + wstate.P11_replenish_pump
            + ",P12_pretest_pump=" + wstate.P12_pretest_pump
            + ",P13_replenish_pump=" + wstate.P13_replenish_pump
            + ",H01_electric_heater=" + wstate.H01_electric_heater
            + ",H02_electric_heater=" + wstate.H02_electric_heater
            + ",Solenoid_openflag=" + wstate.Solenoid_openflag
            + ",Solenoid_shutflag=" + wstate.Solenoid_shutflag
            + ",valve_start=" + wstate.valve_start
            + ",Exhaust_start=" + wstate.Exhaust_start
            + ",remote_start=" + wstate.remote_start
            + ",remote_stop=" + wstate.remote_stop
            + ",Operation_ooled_devices=" + wstate.Operation_ooled_devices
            + ",Auto_control_state=" + wstate.Auto_control_state
            + ",Manual_control_state=" + wstate.Manual_control_state
            + ",remote_control_state=" + wstate.remote_control_state
            + ",Water_system_function=" + wstate.Water_system_function
            + " Where water_id = "  + wstate.water_id;
      Sql_Mysql sql = new Sql_Mysql(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