Administrator
2021-12-14 2e05579d876b10f5292b3a6ee537cbe0db0470ab
Rectifier_power_4MW/src/com/data/comm/Rectifier_power_SQL.java
@@ -26,6 +26,56 @@
      CreateTB_rectifier_power_control(pool);
      
   }
   /**
    *   插入或更新设备通讯状态
    * @param pool
    * @param motor
    */
   public static void insertOrUpdateTb_Device_StateTable(MysqlConnPool pool,Motor_inf motor) {
      String sql_str_sel = " Select dev_id from " + Sql_Mysql.Tb_Device_State + " Where dev_id = " + motor.getDev_id();
      String sql_str_upd = " UPDATE " + Sql_Mysql.Tb_Device_State + " SET comm_status = " + motor.conn_state + " WHERE dev_id = " + motor.getDev_id();
      String sql_str_ins = " INSERT INTO "+Sql_Mysql.Tb_Device_State+"(dev_id,comm_status) VALUES("+motor.getDev_id()+","+motor.conn_state+");";
      ResultSet res = null;
      Sql_Mysql sql = new Sql_Mysql(pool.getConn());
      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(null != res) {
            try {
               res.close();
            } catch (SQLException e) {
               e.printStackTrace();
            }
         }
         sql.close_con();
      }
   }
   /**
    * 更新设备的通讯状态
    * @param pool
    * @param motor
    */
   public static void updateTb_Device_StateTable(MysqlConnPool pool,Motor_inf motor) {
      String sql_str = " UPDATE "+Sql_Mysql.Tb_Device_State+" SET comm_status = "+motor.conn_state+",record_time='"+Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms)+"' WHERE dev_id = "+motor.getDev_id();
      Sql_Mysql sql = new Sql_Mysql(pool.getConn());
      try {
         sql.sqlMysqlExecute(sql_str);
      } catch (SQLException e) {
         e.printStackTrace();
      } finally {
         sql.close_con();
      }
   }
   //创建4MW大功率整流电源控制表
    private static void CreateTB_rectifier_power_control(MysqlConnPool pool) {
       String sql_str = "CREATE TABLE IF NOT EXISTS "+Sql_Mysql.TB_RECTIFIER_POWER_CONTROL+" (" +