添加离线养护计划功能

whyclj

2020-04-22 d72e4be99448d2c03d1409df87ad4bfa60d1b224

 src/com/dec/fbs9100/FBS9100_Task_Thread_SQL.java

@@ -1191,7 +1191,10 @@
                     + " op_cmd=" + FBS9100_ComBase.CMD_GetOffLineYHParam_ACK + ", "

                     + " MonomerTmp_High =" + param.m_FBS_DiscParamFromDev.MonomerTmp_High + ", "

                     + " OnLineVol_Low =" + param.m_FBS_DiscParamFromDev.OnLineVol_Low  + ", "

                     + " OffLineYH_Cycle=" + param.m_FBS_DiscParamFromDev.OffLineYH_Cycle 
                     + " OffLineYH_Cycle=" + param.m_FBS_DiscParamFromDev.OffLineYH_Cycle + ","

                     + " OffLineYHstarttime = '" + param.m_FBS_DiscParamFromDev.OffLineYH_Cycle + "',"

                     + " OffLineYHTimes=" + param.m_FBS_DiscParamFromDev.OffLineYH_Cycle + ","

                     + " OffLineYHOnceCycle=" + param.m_FBS_DiscParamFromDev.OffLineYH_Cycle 
                     + " where dev_id = " + param.dev_id;

         String sql_str_update = "UPDATE " + sql_str_base;

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

@@ -1420,15 +1423,69 @@
      }

   }

   

   /**

    *    读取当前设备的离线养护计划

    * @param m_ConnPool

    * @param param

    */

   public static void queryBTS61850OffLineyhPlanOnRam(MysqlConnPool m_ConnPool, FBS9100_StatAndParam param) {

      String sql_str = " SELECT * FROM " + Sql_Mysql.FBS9100_offlineyhplan + " WHERE dev_id = " + param.dev_id ;

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

      ResultSet res = sql.sqlMysqlQuery(sql_str);

      BTS61850_OffLineYHPlan plan = param.bts61850_OffLineYHPlan;

      try {

         if(res.next()) {

            plan.OffLineYH_Cycle = res.getInt("OffLineYH_Cycle");

            plan.OffLineYHOnceCycle = res.getInt("OffLineYHOnceCycle");

            plan.OffLineYHTimes = res.getInt("OffLineYHTimes");

            plan.OffLineYHstarttime = res.getTimestamp("OffLineYHstarttime");

         } else {

            String sql_str_insert = " INSERT INTO " + Sql_Mysql.FBS9100_offlineyhplan 
                  + "(dev_id,OffLineYH_Cycle,OffLineYHstarttime,OffLineYHTimes,OffLineYHOnceCycle) "

                  + "   VALUES (" + param.dev_id + ", " + plan.OffLineYH_Cycle + ", '" + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms) + "',"+ plan.OffLineYHTimes +", " + plan.OffLineYHOnceCycle +")";

            sql.sqlMysqlExecute(sql_str_insert);

         }

      } catch (SQLException e) {

         e.printStackTrace();

      } finally {

         sql.close_con();

      }

   }

	
   /**

    *        更新养护除硫参数

    * @param m_ConnPool

    * @param param

    */

   public static void updateBTS61850OffLineyhPlanOnRam(MysqlConnPool m_ConnPool, FBS9100_StatAndParam param) {

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

      BTS61850_OffLineYHPlan plan = param.bts61850_OffLineYHPlan;

      String sql_str_insert = " UPDATE TABLE  " + Sql_Mysql.FBS9100_offlineyhplan +

               " SET OffLineYH_Cycle = " + plan.OffLineYH_Cycle + ",OffLineYHstarttime='" + plan.OffLineYHstarttime + "',OffLineYHTimes="+ plan.OffLineYHTimes +",OffLineYHOnceCycle= " + plan.OffLineYHOnceCycle +

               " WHERE dev_id = " + param.dev_id;

      try {

         sql.sqlMysqlExecute(sql_str_insert);

      } catch (SQLException e) {

         e.printStackTrace();

      } finally {

         sql.close_con();

      }

   }

	
	
   public static void main(String[] args) {

      MysqlConnPool pool = new MysqlConnPool("127.0.0.1", 3360, 10);

      BTS61850_EventRecord event = new BTS61850_EventRecord(618500001, 1, 0, BTS61850_EventRecord.Event_CONNCET_Error_type);

      //BTS61850_EventRecord event = new BTS61850_EventRecord(618500001, 1, 0, BTS61850_EventRecord.Event_CONNCET_Error_type);

      

      List<BTS61850_EventRecord> events = new ArrayList<BTS61850_EventRecord>();

      events.add(event);

      //List<BTS61850_EventRecord> events = new ArrayList<BTS61850_EventRecord>();

      //events.add(event);

      //insertBTSEventRecordTable(pool, events);

      

      insertBTSEventRecordTable(pool, events);

      

      //CreateTb_BattRealDataTable(pool, 1000001);

		
      FBS9100_StatAndParam param = new FBS9100_StatAndParam("127.0.0.1", 618500001);

      queryBTS61850OffLineyhPlanOnRam(pool, param);

		
   }

}