Merge branch 'dev_lxw' of https://gitlab.com/whyclxw1/gx_tieta.git into dev...

hdw

2019-01-19 7f953d9aa0e7d4fcbe3c366c7f9f0b3f847f12bd

 gx_tieta/src/com/fgkj/dao/impl/ram/Bts_gprs_stateImpl.java

@@ -28,8 +28,9 @@
   //给gprs发送指令

   public boolean update(Object obj) {

      Bts_gprs_state gprs=(Bts_gprs_state) obj;

      String sql=" update db_ram_db.tb_bts_gprs_state set AT_cmd=? where dev_id=? ";

      boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{gprs.getAT_cmd(),gprs.getDev_id()});

      String sql=" REPLACE  into db_ram_db.tb_bts_gprs_state(AT_cmd,dev_id)  values('"+FBS9100_ComBase.CSQ+gprs.getAT_cmd()+"',?)";

      //System.out.println(sql);

      boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{gprs.getDev_id()});

      return bl;

   }



@@ -45,12 +46,12 @@
    //根据设备id读取的设备连接的gprs模块的信号值

   public List serchByCondition(Object obj) {

      Bts_gprs_state gprs=(Bts_gprs_state) obj;

      String sql=" select distinct db_ram_db.tb_bts_gprs_state.num,dev_id,op_cmd,AT_cmd,ack_inf" +

      String sql=" select distinct db_ram_db.tb_bts_gprs_state.num,dev_id,op_cmd,AT_cmd,ack_inf,bts_task_inf" +

            " ,stationName,FBSDeviceName " +

            " from db_ram_db.tb_bts_gprs_state,db_battinf.tb_battinf " +

            " where db_ram_db.tb_bts_gprs_state.dev_id=db_battinf.tb_battinf.FBSDeviceId " +

            " and dev_id=? " +

            " order by record_datetime desc";

            " and dev_id=? " ;

      //System.err.println(sql);

      List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{gprs.getDev_id()}, new CallBack() {

         

         public List getResults(ResultSet rs) {

@@ -63,6 +64,7 @@
                  g.setOp_cmd(rs.getInt("op_cmd"));

                  g.setAT_cmd(rs.getString("aT_cmd"));

                  g.setAck_inf(rs.getString("ack_inf"));

                  g.setBts_task_inf(rs.getString("bts_task_inf"));

                  g.setStationName(rs.getString("stationName"));

                  g.setFBSDeviceName(rs.getString("fBSDeviceName"));

                  list.add(g);

@@ -77,22 +79,25 @@
      return list;

   }

   //系统参数命令操作设备时的cmd和ack校验   

   public boolean sendCmdToFBS9100Dev(int cmd,int dev_id)

   public Bts_gprs_state sendCmdToFBS9100Dev(int cmd,int dev_id)

   { 

      int m_cmd = cmd;

      int m_cmd_ack = cmd;

      Bts_gprs_state gprs=new Bts_gprs_state();

      gprs.setOp_cmd(0);

      switch(m_cmd) {

         case FBS9100_ComBase.CMD_ReadGPRSCSQ: m_cmd_ack = FBS9100_ComBase.CMD_ReadGPRSCSQAck; break;

         default: return false;

         default: return gprs;

      }

      boolean res_exe = false;

      //boolean res_exe = false;

      String ack_inf="";

      String sql = "UPDATE db_ram_db.tb_bts_gprs_state  SET "

                  + " op_cmd=? " 

                  + " WHERE dev_id=? ";

      Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{m_cmd,dev_id});

      if(true == bl)

      {

         sql = "SELECT op_cmd FROM db_ram_db.tb_bts_gprs_state "+

         sql = "SELECT op_cmd,ack_inf FROM db_ram_db.tb_bts_gprs_state "+

                  " WHERE dev_id="+dev_id;

         Connection conn=DBUtil.getConn();

         PreparedStatement ps = null;

@@ -105,8 +110,10 @@
                  if(rs.next())

                  {

                     if(rs.getInt("op_cmd") == m_cmd_ack)

                     {

                        res_exe = true;

                     {  
                        gprs.setAck_inf(rs.getString("ack_inf"));

                        gprs.setOp_cmd(m_cmd_ack);

                        //res_exe = true;

                        break;

                     }

                  }

@@ -124,11 +131,20 @@
         }

         DBUtil.close(rs, ps, conn);

      }

      return res_exe;

      return gprs;

   }

   public List serchByInfo(Object obj) {

      // TODO Auto-generated method stub

      return null;

   }



   public static void main(String[] args) {

    Bts_gprs_stateImpl bimpl=new Bts_gprs_stateImpl();

    Bts_gprs_state gprs=new Bts_gprs_state();

    gprs.setDev_id(910000001);

    gprs.setAT_cmd("CSQ");

   /* boolean bl=bimpl.update(gprs);

    System.out.println(bl);*/

    List list=bimpl.serchByCondition(gprs);

    System.out.println(list);

}

}