demo30.java

pk_Total - 相同msg_Id消息总条数 pk_Number - 相同msg_Id的消息序号 registered_Delivery - 是否要求返回状态报告 msg_Level - 信

    RecvMsgSum.setBounds(new Rectangle(113, 348, 74, 22));
    jLabel21.setToolTipText("");
    jLabel21.setText("睡眠时长");
    jLabel21.setBounds(new Rectangle(320, 161, 56, 22));
    threadSleepInterval.setBorder(BorderFactory.createLineBorder(Color.black));
    threadSleepInterval.setText("0");
    threadSleepInterval.setBounds(new Rectangle(377, 161, 76, 22));
    jLabel22.setBorder(BorderFactory.createEtchedBorder());
    jLabel22.setText("运行状态 ");
    jLabel22.setBounds(new Rectangle(26, 381, 58, 22));
    myProxyState.setBorder(BorderFactory.createEtchedBorder());
    myProxyState.setEditable(false);
    myProxyState.setBounds(new Rectangle(101, 382, 484, 22));
    jLabel23.setToolTipText("");
    jLabel23.setText("登录帐号");
    jLabel23.setBounds(new Rectangle(23, 21, 66, 22));
    loginName.setBorder(BorderFactory.createLineBorder(Color.black));
    loginName.setText("d86138");
    loginName.setBounds(new Rectangle(100, 21, 131, 22));
    jLabel24.setText("登录密码");
    jLabel24.setBounds(new Rectangle(243, 21, 60, 22));
    loginPass.setBorder(BorderFactory.createLineBorder(Color.black));
    loginPass.setBounds(new Rectangle(306, 21, 131, 22));
    loginButton.setBorder(BorderFactory.createEtchedBorder());
    loginButton.setText("登录系统");
    loginButton.setBounds(new Rectangle(512, 21, 70, 22));
    loginButton.addActionListener(new java.awt.event.ActionListener() {
      public void actionPerformed(ActionEvent e) {
        loginButton_actionPerformed(e);
      }
    });
    jScrollPane1.setHorizontalScrollBarPolicy(JScrollPane.HORIZONTAL_SCROLLBAR_NEVER);
    jScrollPane1.setVerticalScrollBarPolicy(JScrollPane.VERTICAL_SCROLLBAR_ALWAYS);
    jScrollPane1.setBounds(new Rectangle(200, 253, 385, 122));
    allRecvContent.setLineWrap(true);
    jLabel1.setText("From");
    jLabel1.setBounds(new Rectangle(395, 95, 37, 20));
    jLabel18.setText("To");
    jLabel18.setBounds(new Rectangle(516, 94, 27, 19));
    calledFrom.setBorder(BorderFactory.createLineBorder(Color.black));
    calledFrom.setText("0");
    calledFrom.setBounds(new Rectangle(441, 93, 63, 22));
    calledTo.setBorder(BorderFactory.createLineBorder(Color.black));
    calledTo.setText("0");
    calledTo.setBounds(new Rectangle(547, 92, 62, 25));
    this.getContentPane().add(jLabel23, null);
    this.getContentPane().add(loginName, null);
    this.getContentPane().add(jLabel24, null);
    this.getContentPane().add(loginPass, null);
    this.getContentPane().add(service_Id, null);
    this.getContentPane().add(jLabel2, null);
    this.getContentPane().add(jLabel3, null);
    this.getContentPane().add(fee_Terminal_Id, null);
    this.getContentPane().add(msg_src, null);
    this.getContentPane().add(ThreadNum, null);
    this.getContentPane().add(jLabel8, null);
    this.getContentPane().add(jLabel9, null);
    this.getContentPane().add(threadSleepInterval, null);
    this.getContentPane().add(threadRunInterval, null);
    this.getContentPane().add(jLabel21, null);
    this.getContentPane().add(QueryDate, null);
    this.getContentPane().add(jLabel10, null);
    this.getContentPane().add(jLabel11, null);
    this.getContentPane().add(QueryCode, null);
    this.getContentPane().add(QueryType, null);
    this.getContentPane().add(jLabel12, null);
    this.getContentPane().add(CancelMsgId, null);
    this.getContentPane().add(CancelButton, null);
    this.getContentPane().add(jLabel13, null);
    this.getContentPane().add(jLabel14, null);
    this.getContentPane().add(jScrollPane1, null);
    jScrollPane1.getViewport().add(allRecvContent, null);
    this.getContentPane().add(RecvMsgSum, null);
    this.getContentPane().add(jLabel15, null);
    this.getContentPane().add(jLabel16, null);
    this.getContentPane().add(SuccessSendSum, null);
    this.getContentPane().add(SendMsgSum, null);
    this.getContentPane().add(jLabel17, null);
    this.getContentPane().add(myProxyState, null);
    this.getContentPane().add(jLabel22, null);
    this.getContentPane().add(dest_Terminal_Id, null);
    this.getContentPane().add(src_Terminal_Id, null);
    this.getContentPane().add(jLabel6, null);
    this.getContentPane().add(jLabel5, null);
    this.getContentPane().add(msg_Content, null);
    this.getContentPane().add(jLabel7, null);
    this.getContentPane().add(SendButton, null);
    this.getContentPane().add(QueryButton, null);
    this.getContentPane().add(jLabel4, null);
    this.getContentPane().add(loginButton, null);
    this.getContentPane().add(jLabel1, null);
    this.getContentPane().add(calledFrom, null);
    this.getContentPane().add(jLabel18, null);
    this.getContentPane().add(calledTo, null);
  }
  /**
   * 处理用户发送短消息的测试请求.
   */
  void SendButton_actionPerformed(ActionEvent e)
  {
     int threadNum = 0;
     int runInterval = 0;
     int sleepInterval = 0;

     //如果没有成成功登录
     if(!loginSmProxy)
     {
        showStateMsg("系统没有成功登录");
        return ;
     }

     try
     {
       threadNum= Integer.parseInt(ThreadNum.getText().trim());
       runInterval  = Integer.parseInt(threadRunInterval.getText().trim());
       sleepInterval = Integer.parseInt(threadSleepInterval.getText().trim());
       cmppSubmitFrom = Integer.parseInt(calledFrom.getText().trim());
       cmppSubmitTo = Integer.parseInt(calledTo.getText().trim());
       calledIndex = cmppSubmitFrom;
       //begin
       serviceId = service_Id.getText().trim();
       feeTerminalId = fee_Terminal_Id.getText().trim();
       msgSrc = msg_src.getText().trim();
       srcTerminalId = src_Terminal_Id.getText().trim();
       destTerminalPhone = dest_Terminal_Id.getText().trim();
       msgContent = msg_Content.getText().trim().getBytes();
       //end
     }
     catch(Exception ex)   //such as 用户没有输入线程数或者是其他非法字符的时候
     {                    //我们只发送短消息,而不启动线程
        threadNum  =0;
        runInterval = 0;
     }
     //对输入的参数做有效性判断
     if((threadNum>0)&&(runInterval>0))
     {
       //submitMsg = getSubmitMsg();
       StartSendThread(threadNum,runInterval,sleepInterval);
     }
     else
     {
        try
        {
           sendMsgSum ++;
           ProcessSubmitRep(smp.send(getSubmitMsg(0)));
        }
        catch(IllegalArgumentException ex)
        {
          //add
        }
        catch(Exception ex)
        {
          ex.printStackTrace();
        }
     }

  }

  /**
   *处理用户发送的查询短消息信息的请求
   */
  void QueryButton_actionPerformed(ActionEvent e)
  {
     //如果没有成成功登录
     if(!loginSmProxy)
     {
        showStateMsg("系统没有成功登录");
        return ;
     }

    if(smp!=null)
    {
      try
      {
        ProcessQueryRep(smp.send(getQueryMsg())) ;
      }
      catch(IllegalArgumentException ex)
      {
        ex.printStackTrace();
        showStateMsg("Query短消息请求出现异常,可能是格式错误");
      }
      catch(Exception ex)
      {
        ex.printStackTrace();
        showStateMsg("Query短消息请求出现异常");
       }
    }
  }

  /**
   * 处理用户发送的取消短消息的请求
   */
  void CancelButton_actionPerformed(ActionEvent e)
  {

     //如果没有成成功登录
     if(!loginSmProxy)
     {
        showStateMsg("系统没有成功登录");
        return ;
     }

    if(smp!=null)
    {
      try
      {
        ProcessCancelRep(smp.send(getCancelMsg()));
      }
      catch(IllegalArgumentException ex)
      {
         ex.printStackTrace();
         showStateMsg("取消短消息命令的输入参数不合法");
      }
      catch(Exception ex)
      {
        ex.printStackTrace();
        showStateMsg("取消短消息命令的处理出现异常");
      }
    }
  }
  /**
   * 处理用户的退出请求
   */
  void ExitButton_actionPerformed(ActionEvent e)
  {

     //如果没有成成功登录
     if(!loginSmProxy)
     {
        showStateMsg("系统没有成功登录");
        return ;
     }


    if(smp!=null)
    {
      try
      {
        smp.close();
      }
      catch(Exception ex)
      {
        ex.printStackTrace();
        showStateMsg("与ISMG断连出现异常");
      }
    }
  }
  /**
   * 根据用户输入的消息生成SubmitMsg
   * @return CMPPSubmitMessage 对象
   */
   private CMPP30SubmitMessage getSubmitMsg(int index)
   {
      /*
      String serviceId = service_Id.getText().trim();
      String feeTerminalId = fee_Terminal_Id.getText().trim();
      String msgSrc = msg_src.getText().trim();

      //测试中不做处理，原来C版的Demo中是空字符串
      Date valid_Time = null;//new Date();
      Date at_Time = null;//new Date();
      String srcTerminalId = src_Terminal_Id.getText().trim();
      String destTerminalId [] = new String[1];
      destTerminalId[0] = dest_Terminal_Id.getText().trim();
      byte[] msgContent = msg_Content.getText().trim().getBytes();
      */
      if(calledIndex<cmppSubmitTo)
      {
        calledIndex++;
      }
      else
      {
        calledIndex = cmppSubmitFrom;
      }
      destTerminalId[0] = destTerminalPhone+calledIndex;
      try
      {
      return new CMPP30SubmitMessage(
                                    pk_Total,
                                    pk_Number,
                                    registered_Delivery,
                                    msg_Level,
                                    serviceId,
                                    fee_UserType,
                                    feeTerminalId,
                                    1,
                                    tp_Pid,
                                    tp_Udhi,
                                    msg_Fmt,
                                    msgSrc,
                                    fee_Type,
                                    fee_Code,
                                    valid_Time,
                                    at_Time,
                                    srcTerminalId,
                                    destTerminalId,
                                    0,