sgipconnection.java

WAP PUSH后台源码,WAP PUSH后台源码

//          while(true){
//               if(m_is.available()>0){
//                    smsunbindresp.read(m_is);
//                    break;
//               }else{
//                    if(System.currentTimeMillis()-beginTime>=30000L){
//                         throw new SgipException();
//                    }
//               }
//          }
          SMSUnBindResp smsunbindresp=(SMSUnBindResp) m_Reader.blockRead(CommandID.SGIP_UNBIND_RESP,
                    smsunbind.seqAddr,smsunbind.seqDate,smsunbind.sequence);
     }


     /**
      * 在已经建立的发送通道上发送一个短消息。
      */
     public String submit(String chargeNumber,String userNumber,String messageContent,String spNumber,String corpID,
                        String serviceType,int feeType,String feeValue,String givenValue,
                        int morelatetoMTFlag,int reportFlag,int messageCoding,String expireTime,String scheduleTime) throws SgipException,IOException {
          SMSSubmit smssubmit=new SMSSubmit();
          smssubmit.getValue(corpID);

          smssubmit.setChargeNumber(chargeNumber);
          smssubmit.setUserNumber(userNumber);
          smssubmit.setMessageContent(messageContent);
          if(spNumber!=null&&!spNumber.equals("")){
               smssubmit.setSpNumber(spNumber);
          }
          smssubmit.setCorpId(corpID);
          smssubmit.setServiceType(serviceType);
          smssubmit.setFeeType(feeType);
          smssubmit.setFeeValue(feeValue);
          smssubmit.setGivenValue(givenValue);
          smssubmit.setMorelatetoMTFlag(morelatetoMTFlag);
          smssubmit.setReportFlag(reportFlag);
          smssubmit.setMessageCoding(messageCoding);
          smssubmit.setExpireTime(expireTime);
          smssubmit.setScheduleTime(scheduleTime);

          smssubmit.write(m_os);
//          System.out.println(smssubmit.seqAddr);
//          System.out.println(smssubmit.seqDate);
//          System.out.println(smssubmit.sequence);

//          String resp=CommandID.SGIP_SUBMIT_RESP + "," + smssubmit.seqAddr + "," + smssubmit.seqDate + "," + smssubmit.sequence;
//          return resp;

//          SMSSubmitResp smssubmitresp=new SMSSubmitResp();
//          long beginTime=System.currentTimeMillis();
//          while(true){
//               if(m_is.available()>0){
//                    smssubmitresp.read(m_is);
//                    break;
//               }else{
//                    if(System.currentTimeMillis()-beginTime>=30000L){
//                         throw new SgipException();
//                    }
//               }
//          }
          SMSSubmitResp smssubmitresp=(SMSSubmitResp) m_Reader.blockRead(CommandID.SGIP_SUBMIT_RESP,
                    smssubmit.seqAddr,smssubmit.seqDate,smssubmit.sequence);
//
          System.out.println("返回结果值：" + smssubmitresp.getResult());
          if(smssubmitresp.getResult()!=0){
               throw new SgipException();
          }

//          return smssubmit;
          String resp=smssubmit.seqAddr + ";" + smssubmit.seqDate + ";" + smssubmit.sequence;
          return resp;
     }

     public String submit(String chargeNumber,String userNumber,byte[] messageContent,String spNumber,String corpID,
                        String serviceType,int feeType,String feeValue,String givenValue,
                        int morelatetoMTFlag,int reportFlag,int messageCoding,String expireTime,String scheduleTime) throws SgipException,IOException {
          SMSSubmit smssubmit=new SMSSubmit();
          smssubmit.getValue(corpID);

          smssubmit.setChargeNumber(chargeNumber);
          smssubmit.setUserNumber(userNumber);
          smssubmit.setBinaryMessageContent(messageContent);
          if(spNumber!=null&&!spNumber.equals("")){
               smssubmit.setSpNumber(spNumber);
          }
          smssubmit.setCorpId(corpID);
          smssubmit.setServiceType(serviceType);
          smssubmit.setFeeType(feeType);
          smssubmit.setFeeValue(feeValue);
          smssubmit.setGivenValue(givenValue);
          smssubmit.setMorelatetoMTFlag(morelatetoMTFlag);
          smssubmit.setReportFlag(reportFlag);
          smssubmit.setMessageCoding(messageCoding);
          smssubmit.setExpireTime(expireTime);
          smssubmit.setScheduleTime(scheduleTime);

          smssubmit.writeBinary(m_os);

//          SMSSubmitResp smssubmitresp=new SMSSubmitResp();
//          long beginTime=System.currentTimeMillis();
//          while(true){
//               if(m_is.available()>0){
//                    smssubmitresp.read(m_is);
//                    break;
//               }else{
//                    if(System.currentTimeMillis()-beginTime>=30000L){
//                         throw new SgipException();
//                    }
//               }
//          }
          SMSSubmitResp smssubmitresp=(SMSSubmitResp) m_Reader.blockRead(CommandID.SGIP_SUBMIT_RESP,
                    smssubmit.seqAddr,smssubmit.seqDate,smssubmit.sequence);
//
          if(smssubmitresp.getResult()!=0){
               throw new SgipException();
          }
//          return smssubmit;
          String resp=smssubmit.seqAddr + ";" + smssubmit.seqDate + ";" + smssubmit.sequence;
          return resp;
     }

     /**
      * 在已经建立的发送通道上发送多个短消息。
      */
     public String submitMulti(String chargeNumber,String[] userNumber,String messageContent,String spNumber,String corpID,
                        String serviceType,int feeType,String feeValue,String givenValue,
                        int morelatetoMTFlag,int reportFlag,int messageCoding,String expireTime,String scheduleTime) throws SgipException,IOException {
          SMSSubmitMulti smssubmitmulti=new SMSSubmitMulti();
          smssubmitmulti.getValue(corpID);

          smssubmitmulti.setChargeNumber(chargeNumber);
          smssubmitmulti.setUserNumber(userNumber);
          smssubmitmulti.setMessageContent(messageContent);
          if(spNumber!=null&&!spNumber.equals("")){
               smssubmitmulti.setSpNumber(spNumber);
          }
          smssubmitmulti.setCorpId(corpID);
          smssubmitmulti.setServiceType(serviceType);
          smssubmitmulti.setFeeType(feeType);
          smssubmitmulti.setFeeValue(feeValue);
          smssubmitmulti.setGivenValue(givenValue);
          smssubmitmulti.setMorelatetoMTFlag(morelatetoMTFlag);
          smssubmitmulti.setReportFlag(reportFlag);
          smssubmitmulti.setMessageCoding(messageCoding);
          smssubmitmulti.setExpireTime(expireTime);
          smssubmitmulti.setScheduleTime(scheduleTime);

          smssubmitmulti.write(m_os);

//          SMSSubmitMultiResp smssubmitmultiresp=new SMSSubmitMultiResp();
//          long beginTime=System.currentTimeMillis();
//          while(true){
//               if(m_is.available()>0){
//                    smssubmitmultiresp.read(m_is);
//                    break;
//               }else{
//                    if(System.currentTimeMillis()-beginTime>=30000L){
//                         throw new SgipException();
//                    }
//               }
//          }
//          if(smssubmitmultiresp.getResult()!=0){
//               throw new SgipException();
//          }
          SMSSubmitResp smssubmitresp=(SMSSubmitResp) m_Reader.blockRead(CommandID.SGIP_SUBMIT_RESP,
                    smssubmitmulti.seqAddr,smssubmitmulti.seqDate,smssubmitmulti.sequence);
//          return smssubmitmulti;
          String resp=smssubmitmulti.seqAddr + ";" + smssubmitmulti.seqDate + ";" + smssubmitmulti.sequence;
          return resp;
     }


     public SMSDeliver deliver(String userNumber,String messageContent,String corpID,String spNumber) throws SgipException,IOException {
          SMSDeliver smsdeliver=new SMSDeliver();
          smsdeliver.getValue(corpID);
          smsdeliver.setUserNumber(userNumber);
          smsdeliver.setSpNumber(spNumber);
          smsdeliver.setMessageContent(messageContent);
          smsdeliver.write(m_os);
//          SMSDeliverResp smsdeliverresp=new SMSDeliverResp();
          SMSDeliverResp smsdeliverresp=(SMSDeliverResp) m_Reader.blockRead(CommandID.SGIP_DELIVER_RESP,
                    smsdeliver.seqAddr,smsdeliver.seqDate,smsdeliver.sequence);
//          smsdeliverresp.read(m_is);
          if(smsdeliverresp.getResult()!=0){
               throw new SgipException();
          }
          return smsdeliver;
     }
     /**
      * 保持连接线程。SgipConnection类的使用者不应直接访问这个方法。
      */
     public void run() {
//          while (m_thdKeepAlive == Thread.currentThread() && isConnected()) {
//               try {
//                    Thread.sleep(m_iKeepAliveTimeGap);
//               } catch (InterruptedException e) {
//               }
//
//          }
//
//          m_thdKeepAlive = null;
     }
}