📄 hqgprs.java~1~

📁 用java写编写的一个GPS源代码请大家多多指教
💻 JAVA~1~
📖 第 1 页 / 共 3 页
字号:
上一页 1 23

//      msgobj.cMsgType = SMSSENDTODEVICE;
//      msgobj.cPhoneNum = getPhoneNum(reStr[1]);
//      msgobj.cDeviceID = reStr[1];
//      msgobj.cMsg = sendStr;
//      super.addRecieveMsg(msgobj);
    }

  }

  private void FmTimingDegreeCall117(MsgObj msg) {

//添加Msg到sendQueue
//cMsgtype:1--TCPMSG,2--DEVICEUDPMSG,3--SMSMSG
//4--TCPSENDTODEVICE,5--UDPSENDTODEVICE,6--SMSSENDTODEVICE,7--TCPSENDTOTERMINAL,8--TCPRETURNTERMINAL
    String sendStr = null;
    HashObj hashobj = null;
    String strDate = CanSend.getTime();
//    String queryStr = null;
//    queryStr = super.DbServer.getUserPopedom(reStr[2]);
    //117, 设备ID，车牌号，操作员名，次数,间隔（秒, 30 ~ 65535）
    //*HQ,1381049560,D1,130305,0600,4#


//     while (reStr[5].length() < 4) {
//      reStr[5] = "0" + reStr[5];
//    }
    sendStr = new String("*HQ," + reStr[1] + ",D1," + strDate + "," + reStr[5] +
                         "," +
                         reStr[4] + "#");
//    if (super.centerMap.containsKey(reStr[1])) {
//      hashobj = (HashObj)super.centerMap.get(reStr[1]);
//      if (CanSend.CanSendMsg(hashobj.cDateTime)) {
//        msg.cMsgType = TCPSENDTODEVICE;
//      }
//    }
//    else {
    msg.cMsgType = SMSSENDTODEVICE;
//    }
    msg.cPhoneNum = getPhoneNum(reStr[1]);
    msg.cDeviceID = reStr[1];
    msg.cMsg = sendStr;
    super.addSendMsg(msg);
  }

  private void FmCompressTimingCall118(MsgObj msg) {

//添加Msg到sendQueue
//cMsgtype:1--TCPMSG,2--DEVICEUDPMSG,3--SMSMSG
//4--TCPSENDTODEVICE,5--UDPSENDTODEVICE,6--SMSSENDTODEVICE,7--TCPSENDTOTERMINAL,8--TCPRETURNTERMINAL
    String sendStr = null;
    String strDate = CanSend.getTime();
//    String queryStr = null;
//    queryStr = super.DbServer.getUserPopedom(reStr[2]);
    //118,设备ID，车牌号，间隔（秒, 30 ~ 65535）
    //*HQ,000,D1,130305,5,4#
    sendStr = ("*HQ," + reStr[1] + ",D1," + strDate + "," + reStr[3] + ",4#");
//    System.out.println(sendStr);
    msg.cMsgType = TCPSENDTODEVICE;
    msg.cPhoneNum = getPhoneNum(reStr[1]);
    msg.cDeviceID = reStr[1];
    msg.cMsg = sendStr;
    super.addSendMsg(msg);
  }

  private void FmQueryVehicleState120(MsgObj msg) {

//添加Msg到sendQueue
//cMsgtype:1--TCPMSG,2--DEVICEUDPMSG,3--SMSMSG
//4--TCPSENDTODEVICE,5--UDPSENDTODEVICE,6--SMSSENDTODEVICE,7--TCPSENDTOTERMINAL,8--TCPRETURNTERMINAL
    String sendStr1, sendStr2 = null;
    HashObj hashobj = null;
    String strDate = CanSend.getTime();
//    String queryStr = null;
//    queryStr = super.DbServer.getUserPopedom(reStr[2]);
    //120, 0000000000, 京A-1234, 张三
    //*HQ,0000000000,S26,130305#
     //*HQ,0000000000,S32,130305,1#
    sendStr1 = new String("*HQ," + reStr[1] + ",S26," + strDate + "#");
    sendStr2 = new String("*HQ," + reStr[1] + ",S32," + strDate + ",1#");
    MsgObj msgobj = new MsgObj();
    if (super.centerMap.containsKey(reStr[1])) {
      hashobj = (HashObj)super.centerMap.get(reStr[1]);
      if (hashobj.cDeviceTcpUsed) {
        if (CanSend.CanSendMsg(hashobj.cDateTime)) {
          msg.cMsgType = TCPSENDTODEVICE;
          msgobj.cMsgType = TCPSENDTODEVICE;
        }
      }
      else {
        msg.cMsgType = SMSSENDTODEVICE;
        msgobj.cMsgType = SMSSENDTODEVICE;
      }
      msg.cPhoneNum = getPhoneNum(reStr[1]);
      msg.cDeviceID = reStr[1];
      msg.cMsg = sendStr1;
      super.addSendMsg(msg);
      //---------------------------------------
      msgobj.cPhoneNum = getPhoneNum(reStr[1]);
      msgobj.cDeviceID = reStr[1];
      msgobj.cMsg = sendStr2;
      super.addSendMsg(msgobj);
    }
    else {
      msg.cMsgType = SMSSENDTODEVICE;
      msg.cPhoneNum = getPhoneNum(reStr[1]);
      msg.cDeviceID = reStr[1];
      msg.cMsg = sendStr1;
      super.addSendMsg(msg);
      //---------------------------------------
      msgobj.cPhoneNum = getPhoneNum(reStr[1]);
      msgobj.cMsgType = SMSSENDTODEVICE;
      msgobj.cDeviceID = reStr[1];
      msgobj.cMsg = sendStr2;
      super.addSendMsg(msgobj);

    }

  }

  private void FmSMSInfo121(MsgObj msg) {

//添加Msg到sendQueue
//cMsgtype:1--TCPMSG,2--DEVICEUDPMSG,3--SMSMSG
//4--TCPSENDTODEVICE,5--UDPSENDTODEVICE,6--SMSSENDTODEVICE,7--TCPSENDTOTERMINAL,8--TCPRETURNTERMINAL
    String sendStr = null;
    HashObj hashobj = null;
    String strDate = CanSend.getTime();
//    String queryStr = null;
//    queryStr = super.DbServer.getUserPopedom(reStr[2]);
    //121, 13954667441,京A-1234, 张三,5,你a好
    //*HQ,000,I1,130305,60,0,42,你好

     String infoLenth = String.valueOf(reStr[4].length() * 2);
    //String infoLenth = getStrLength(reStr[4]);

    sendStr = new String("*HQ," + reStr[1] + ",I1," + strDate + ",30,0," +
                         infoLenth + "," + reStr[4]);

    msg.cMsgType = SMSSENDTODEVICE;
    msg.cPhoneNum = getPhoneNum(reStr[1]);
    msg.cDeviceID = reStr[1];
    msg.cMsg = reStr[4];
    super.addSendMsg(msg);



/*
    if (super.centerMap.containsKey(reStr[1])) {
      hashobj = (HashObj)super.centerMap.get(reStr[1]);
      if (hashobj.cDeviceTcpUsed) {
        if (CanSend.CanSendMsg(hashobj.cDateTime)) {
          msg.cMsgType = TCPSENDTODEVICE;
          msg.cPhoneNum = getPhoneNum(reStr[1]);
          msg.cDeviceID = reStr[1];
          msg.cMsg = sendStr;
          super.addSendMsg(msg);
        }
        else {
          msg.cMsgType = SMSSENDTODEVICE;
          msg.cPhoneNum = getPhoneNum(reStr[1]);
          msg.cDeviceID = reStr[1];
          msg.cMsg = "*" + reStr[4];
          super.addSendMsg(msg);
          //----------------------------------------
          MsgObj msgobj = new MsgObj();
          msgobj.cMsg = new String("107," + reStr[1] + "," + reStr[2] + "," +
                                   reStr[3] + "," +
                                   centerIp + ":" + centerPort);
          //FmSetGPRSCenter107(msgobj);
          msgobj.cMsgType = SMSSENDTODEVICE;
          msgobj.cPhoneNum = getPhoneNum(reStr[1]);
          msgobj.cDeviceID = reStr[1];
          msgobj.cMsg = sendStr;
          super.addSendMsg(msgobj);
        }
      }
      else {
        msg.cMsgType = SMSSENDTODEVICE;
        msg.cPhoneNum = getPhoneNum(reStr[1]);
        msg.cDeviceID = reStr[1];
        msg.cMsg = "*" + reStr[4];
        super.addSendMsg(msg);
        //----------------------------------------
        MsgObj msgobj = new MsgObj();
        msgobj.cMsg = new String("107," + reStr[1] + "," + reStr[2] + "," +
                                 reStr[3] + "," +
                                 centerIp + ":" + centerPort);
        //FmSetGPRSCenter107(msgobj);
        msgobj.cMsgType = SMSSENDTODEVICE;
        msgobj.cPhoneNum = getPhoneNum(reStr[1]);
        msgobj.cDeviceID = reStr[1];
        super.addSendMsg(msgobj);

      }
    }
    else {
      msg.cMsgType = TCPRETURNTERMINAL;
      msg.cPhoneNum = getPhoneNum(reStr[1]);
      msg.cDeviceID = reStr[1];
      msg.cMsg = "*" + reStr[4];
      super.addSendMsg(msg);
      //----------------------------------------
      MsgObj msgobj = new MsgObj();
      msgobj.cMsg = new String("107," + reStr[1] + "," + reStr[2] + "," +
                               reStr[3] + "," +
                               centerIp + ":" + centerPort);
      //FmSetGPRSCenter107(msgobj);
      msgobj.cMsgType = SMSSENDTODEVICE;
      msgobj.cPhoneNum = getPhoneNum(reStr[1]);
      msgobj.cDeviceID = reStr[1];
      msgobj.cMsg = sendStr;
      super.addSendMsg(msgobj);
    }
*/



  }


  private void FmStopAlarm122(MsgObj msg) {

//添加Msg到sendQueue
//cMsgtype:1--TCPMSG,2--DEVICEUDPMSG,3--SMSMSG
//4--TCPSENDTODEVICE,5--UDPSENDTODEVICE,6--SMSSENDTODEVICE,7--TCPSENDTOTERMINAL,8--TCPRETURNTERMINAL
    String sendStr = null;
    HashObj hashobj = null;
    String strDate = CanSend.getTime();
//    String queryStr = null;
//    queryStr = super.DbServer.getUserPopedom(reStr[2]);
    //122, 13954667441, NULL, 张三, 1
    //*HQ,2020916012, A1, 050316
    sendStr = new String("*HQ," + reStr[1] + ",A1," + strDate);
    if (super.centerMap.containsKey(reStr[1])) {
      hashobj = (HashObj)super.centerMap.get(reStr[1]);
      if (hashobj.cDeviceTcpUsed) {
        if (CanSend.CanSendMsg(hashobj.cDateTime)) {
          msg.cMsgType = TCPSENDTODEVICE;
        }
      }
      else {
        msg.cMsgType = SMSSENDTODEVICE;
      }
    }
    else {
      msg.cMsgType = SMSSENDTODEVICE;
    }
    msg.cPhoneNum = getPhoneNum(reStr[1]);
    msg.cDeviceID = reStr[1];
    msg.cMsg = sendStr;
    super.addSendMsg(msg);
  }

  private void FmStopTimingCallDevice124(MsgObj msg) {
    //添加Msg到sendQueue
    //cMsgtype:1--TCPMSG,2--DEVICEUDPMSG,3--SMSMSG
    //4--TCPSENDTODEVICE,5--UDPSENDTODEVICE,6--SMSSENDTODEVICE,7--TCPSENDTOTERMINAL,8--TCPRETURNTERMINAL
    String sendStr = null;
    HashObj hashobj = null;
    String strDate = CanSend.getTime();
    //String queryStr = null;
    //queryStr = super.DbServer.getUserPopedom(reStr[2]);
    //124, 0000000000, 京A-1234, 张三
    //*HQ,0000000000,S12,130305,62#
     //*HQ,0000000000,S23,130305,0,0,0, 0,0,5#

//    if (super.centerMap.containsKey(reStr[1])) {
//      hashobj = (HashObj)super.centerMap.get(reStr[1]);
//      if (hashobj.cDeviceTcpUsed) {
//        if (CanSend.CanSendMsg(hashobj.cDateTime)) {
//          //*HQ,0000000000,S23,130305,0,0,0, 0,0,5#
//          //msg.cMsgType = TCPSENDTODEVICE;
//        //sendStr = new String("*HQ," + reStr[1] + ",S23," + strDate + ",0,0,0,0,0,5#");
//          MsgObj msgobj = new MsgObj();
//          //*HQ,0000000000,S17,130305,65534#
//          //msgobj.cMsg = new String("*HQ," + reStr[1] + ",S12," + strDate + ",62#");
//          //msgobj.cMsg = sendStr;
//
//          msgobj.cMsg = new String("*HQ," + reStr[1] + ",S17," + strDate +
//                                   ",65534,1#");//停止UDP传输
//          msgobj.cMsgType = TCPSENDTODEVICE;
//          msgobj.cPhoneNum = getPhoneNum(reStr[1]);
//          msgobj.cDeviceID = reStr[1];
//          super.addSendMsg(msgobj);
//
//        }
//      }
//    }




    sendStr = new String("*HQ," + reStr[1] + ",S23," + strDate + ",0,0,0,0,0,5#");
//    sendStr = new String("*HQ," + reStr[1] + ",S17," + strDate + ",20,1#"); //停止UDP传输
//    msg.cMsgType = TCPSENDTODEVICE;//SMSSENDTODEVICE;
    msg.cMsgType = SMSSENDTODEVICE; //SMSSENDTODEVICE;
    msg.cPhoneNum = getPhoneNum(reStr[1]);
    msg.cDeviceID = reStr[1];
    msg.cMsg = sendStr;
    super.addSendMsg(msg);

//    MsgObj msgobj = new MsgObj();
//    msgobj.cMsg = new String("*HQ," + reStr[1] + ",S12," + strDate + ",62#");
//    msgobj.cMsgType = TCPSENDTODEVICE;
//    msgobj.cPhoneNum = getPhoneNum(reStr[1]);
//    msgobj.cDeviceID = reStr[1];
//    super.addSendMsg(msgobj);

  }

  private String getPhoneNum(String deviceid) {
    String phoneNum = null;
    for (int i = 0; i < deviceIdPhone.length; i++) {
      if (deviceid.equals(deviceIdPhone[i][0])) {
        phoneNum = deviceIdPhone[i][1];
        break;
      }
    }
    return phoneNum;
  }

  private void readxml() {
    try {
      //"E:\\nk\\JBuilderWorkspace\\GPSCenter\\Expression.xml"
      File f = new File("VehicleTable.xml");
      if (f.exists()) {
        //创建工厂
        DocumentBuilderFactory factory = DocumentBuilderFactory.newInstance();
        //创建分析器实例对象
        DocumentBuilder builder = factory.newDocumentBuilder();
        //对xml文件进行解析生成Document对象
        Document doc = builder.parse(f);
        //生成节点列表
        NodeList nl = doc.getElementsByTagName("Center");
        System.out.println("nl.getLength():" + nl.getLength());
        //
        deviceIdPhone = new String[nl.getLength()][2];
        for (int i = 0; i < nl.getLength(); i++) {
          //读取电话号码
          deviceIdPhone[i][0] = new String( (doc.getElementsByTagName(
              "DeviceID").item(i).getFirstChild().getNodeValue()).trim());
          deviceIdPhone[i][1] = new String( (doc.getElementsByTagName(
              "PhoneNum").item(i).getFirstChild().getNodeValue()).trim());
        }
      }
      else {
        System.out.println("no find file：VehicleTable.xml");
        System.exit( -1);
      }
    }
    catch (Exception e) {
      e.printStackTrace();
    }

  }

}
上一页 1 23
⌨️ 快捷键说明

复制代码 Ctrl + C
搜索代码 Ctrl + F
全屏模式 F11
切换主题 Ctrl + Shift + D
显示快捷键 ?
增大字号 Ctrl + =
减小字号 Ctrl + -