V1.102 1.为兼容老版本fuguang.war平台和fg.war平台的控制功能

Administrator

2021-08-16 8c29d7514b6bc5c5c29e77a59726a51248744a0c

 BattMonitor_FBS9600S/src/com/dev/fbs9600s/FBS9600S_SocketClient_Thread_SQL.java

@@ -82,7 +82,7 @@
    * @param dev_id

    * @return

    */

   public static FBS9600S_SystemState queryFBS9600SSysCmd(MysqlConnPool pool,int dev_id) {

   public static FBS9600S_SystemState queryFBS9100SSysCmd(MysqlConnPool pool,int dev_id) {

      FBS9600S_SystemState state = new FBS9600S_SystemState("", dev_id);

      String sql_str = "SELECT * from db_ram_db.tb_fbs9100_state WHERE dev_id = "+dev_id;

      Sql_Mysql sql = new Sql_Mysql(pool.getConn());

@@ -120,6 +120,55 @@
      }

   }

   

   /**

    *    查询9600State

    * @param con_pool

    * @param sysState

    */

   public static FBS9600S_SystemState queryFbs9600StateCmdBydev_id(MysqlConnPool con_pool, int dev_id)

   {

      FBS9600S_SystemState sys = new FBS9600S_SystemState("", dev_id);

      String sql_str = " select * from " + Sql_Mysql.FBS9600State_Table + " "

                   + " where dev_id= " + dev_id;

      Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());

      ResultSet res = null;

      try {

         res = sql.sqlMysqlQuery(sql_str);

         if(res.next()) {				
            sys.op_cmd = res.getInt("op_cmd"); 
         }

      } catch (SQLException e) {

         //e.printStackTrace();

      } finally {

         if(null != res) {

             try {

               res.close();

            } catch (SQLException e) {

               e.printStackTrace();

            }

         }

         sql.close_con();

      }

      return sys;

   }

	
   public static void updateFbs9600StateCmdBydev_id(MysqlConnPool con_pool, FBS9600S_SystemState sysState)

   {

      String sql_str_base = Sql_Mysql.FBS9600State_Table + " SET "

                     + "dev_id=" + sysState.dev_id + ", "

                     + "op_cmd=" + sysState.op_cmd;

      String sql_str_update = "UPDATE " + sql_str_base + " WHERE dev_id = " + sysState.dev_id;

      //String sql_str_replace = "REPLACE INTO " + sql_str_base;

      Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());

      try {

         sql.sqlMysqlExecute(sql_str_update);

      } catch (SQLException e) {

         //e.printStackTrace();

      } finally {

         sql.close_con();

      }

   }

	
   

   /**

    * 根据获取当前设备的命令

@@ -127,7 +176,7 @@
    * @param dev_id

    * @return

    */

   public static FBS9600S_SystemState queryFBS9600SSetParam(MysqlConnPool pool,int dev_id) {

   public static FBS9600S_SystemState queryFBS9100SSetParam(MysqlConnPool pool,int dev_id) {

      FBS9600S_SystemState state = new FBS9600S_SystemState("", dev_id);

      String sql_str = "SELECT * from db_ram_db.tb_fbs9100_setparam WHERE dev_id = "+dev_id;

      Sql_Mysql sql = new Sql_Mysql(pool.getConn());