processormsgthread.java

介绍短信的处理程序,从接收到短信,分类找到相应的业务处理名称,然后发送HTTP到业务来进行短信的处理.

        stmt.setInt(10, 1);
        stmt.setString(11, phone);
        stmt.setString(12, msg.substring(45));
        stmt.setInt(13, 0);
        stmt.setString(14, "02900050");
        stmt.executeUpdate();
      }
      else if (msg.length() > 90 && msg.length() <= 135) {
        stmt = conn.prepareStatement("insert into tsubmit(SubType,NeedReport,Priority,ServiceID,FeeType,FeeCode,MsgFormat,SrcTermID,ChargeTermID,DestTermIDCount,DestTermID,MsgContent,ValidTime,isdeal,spid) values(?,?,?,?,?,?,?,?,?,?,?,?,now(),?,?)");
        stmt.setInt(1, 2);
        stmt.setInt(2, 1);
        stmt.setInt(3, 0);
        stmt.setString(4, svccode);
        stmt.setString(5, "01");
        stmt.setString(6, feecode);
        stmt.setString(7, "15");
        stmt.setString(8, tophone);
        stmt.setString(9, phone);
        stmt.setInt(10, 1);
        stmt.setString(11, phone);
        stmt.setString(12, msg.substring(0, 45));
        stmt.setInt(13, 0);
        stmt.setString(14, "02900050");
        stmt.executeUpdate();

        stmt = conn.prepareStatement("insert into tsubmit(SubType,NeedReport,Priority,ServiceID,FeeType,FeeCode,MsgFormat,SrcTermID,ChargeTermID,DestTermIDCount,DestTermID,MsgContent,ValidTime,isdeal,spid) values(?,?,?,?,?,?,?,?,?,?,?,?,now(),?,?)");
        stmt.setInt(1, 2);
        stmt.setInt(2, 1);
        stmt.setInt(3, 0);
        stmt.setString(4, svccode);
        stmt.setString(5, "01");
        stmt.setString(6, feecode);
        stmt.setString(7, "15");
        stmt.setString(8, tophone);
        stmt.setString(9, phone);
        stmt.setInt(10, 1);
        stmt.setString(11, phone);
        stmt.setString(12, msg.substring(45, 90));
        stmt.setInt(13, 0);
        stmt.setString(14, "02900050");
        stmt.executeUpdate();

        stmt = conn.prepareStatement("insert into tsubmit(SubType,NeedReport,Priority,ServiceID,FeeType,FeeCode,MsgFormat,SrcTermID,ChargeTermID,DestTermIDCount,DestTermID,MsgContent,ValidTime,isdeal,spid) values(?,?,?,?,?,?,?,?,?,?,?,?,now(),?,?)");
        stmt.setInt(1, 2);
        stmt.setInt(2, 1);
        stmt.setInt(3, 0);
        stmt.setString(4, svccode);
        stmt.setString(5, "01");
        stmt.setString(6, feecode);
        stmt.setString(7, "15");
        stmt.setString(8, tophone);
        stmt.setString(9, phone);
        stmt.setInt(10, 1);
        stmt.setString(11, phone);
        stmt.setString(12, msg.substring(90));
        stmt.setInt(13, 0);
        stmt.setString(14, "02900050");
        stmt.executeUpdate();

      }
      else if (msg.length() > 135 && msg.length() <= 180) {
        stmt = conn.prepareStatement("insert into tsubmit(SubType,NeedReport,Priority,ServiceID,FeeType,FeeCode,MsgFormat,SrcTermID,ChargeTermID,DestTermIDCount,DestTermID,MsgContent,ValidTime,isdeal,spid) values(?,?,?,?,?,?,?,?,?,?,?,?,now(),?,?)");
        stmt.setInt(1, 2);
        stmt.setInt(2, 1);
        stmt.setInt(3, 0);
        stmt.setString(4, svccode);
        stmt.setString(5, "01");
        stmt.setString(6, feecode);
        stmt.setString(7, "15");
        stmt.setString(8, tophone);
        stmt.setString(9, phone);
        stmt.setInt(10, 1);
        stmt.setString(11, phone);
        stmt.setString(12, msg.substring(0, 45));
        stmt.setInt(13, 0);
        stmt.setString(14, "02900050");
        stmt.executeUpdate();

        stmt = conn.prepareStatement("insert into tsubmit(SubType,NeedReport,Priority,ServiceID,FeeType,FeeCode,MsgFormat,SrcTermID,ChargeTermID,DestTermIDCount,DestTermID,MsgContent,ValidTime,isdeal,spid) values(?,?,?,?,?,?,?,?,?,?,?,?,now(),?,?)");
        stmt.setInt(1, 2);
        stmt.setInt(2, 1);
        stmt.setInt(3, 0);
        stmt.setString(4, svccode);
        stmt.setString(5, "01");
        stmt.setString(6, feecode);
        stmt.setString(7, "15");
        stmt.setString(8, tophone);
        stmt.setString(9, phone);
        stmt.setInt(10, 1);
        stmt.setString(11, phone);
        stmt.setString(12, msg.substring(45, 90));
        stmt.setInt(13, 0);
        stmt.setString(14, "02900050");
        stmt.executeUpdate();

        stmt = conn.prepareStatement("insert into tsubmit(SubType,NeedReport,Priority,ServiceID,FeeType,FeeCode,MsgFormat,SrcTermID,ChargeTermID,DestTermIDCount,DestTermID,MsgContent,ValidTime,isdeal,spid) values(?,?,?,?,?,?,?,?,?,?,?,?,now(),?,?)");
        stmt.setInt(1, 2);
        stmt.setInt(2, 1);
        stmt.setInt(3, 0);
        stmt.setString(4, svccode);
        stmt.setString(5, "01");
        stmt.setString(6, feecode);
        stmt.setString(7, "15");
        stmt.setString(8, tophone);
        stmt.setString(9, phone);
        stmt.setInt(10, 1);
        stmt.setString(11, phone);
        stmt.setString(12, msg.substring(90, 135));
        stmt.setInt(13, 0);
        stmt.setString(14, "02900050");
        stmt.executeUpdate();

        stmt = conn.prepareStatement("insert into tsubmit(SubType,NeedReport,Priority,ServiceID,FeeType,FeeCode,MsgFormat,SrcTermID,ChargeTermID,DestTermIDCount,DestTermID,MsgContent,ValidTime,isdeal,spid) values(?,?,?,?,?,?,?,?,?,?,?,?,now(),?,?)");
        stmt.setInt(1, 2);
        stmt.setInt(2, 1);
        stmt.setInt(3, 0);
        stmt.setString(4, svccode);
        stmt.setString(5, "01");
        stmt.setString(6, feecode);
        stmt.setString(7, "15");
        stmt.setString(8, tophone);
        stmt.setString(9, phone);
        stmt.setInt(10, 1);
        stmt.setString(11, phone);
        stmt.setString(12, msg.substring(135));
        stmt.setInt(13, 0);
        stmt.setString(14, "02900050");
        stmt.executeUpdate();
      }
      else {
        stmt = conn.prepareStatement("insert into tsubmit(SubType,NeedReport,Priority,ServiceID,FeeType,FeeCode,MsgFormat,SrcTermID,ChargeTermID,DestTermIDCount,DestTermID,MsgContent,ValidTime,isdeal,spid) values(?,?,?,?,?,?,?,?,?,?,?,?,now(),?,?)");
        stmt.setInt(1, 2);
        stmt.setInt(2, 1);
        stmt.setInt(3, 0);
        stmt.setString(4, svccode);
        stmt.setString(5, "01");
        stmt.setString(6, feecode);
        stmt.setString(7, "15");
        stmt.setString(8, tophone);
        stmt.setString(9, phone);
        stmt.setInt(10, 1);
        stmt.setString(11, phone);
        stmt.setString(12, msg.substring(0, 45));
        stmt.setInt(13, 0);
        stmt.setString(14, "02900050");
        stmt.executeUpdate();

        stmt = conn.prepareStatement("insert into tsubmit(SubType,NeedReport,Priority,ServiceID,FeeType,FeeCode,MsgFormat,SrcTermID,ChargeTermID,DestTermIDCount,DestTermID,MsgContent,ValidTime,isdeal,spid) values(?,?,?,?,?,?,?,?,?,?,?,?,now(),?,?)");
        stmt.setInt(1, 2);
        stmt.setInt(2, 1);
        stmt.setInt(3, 0);
        stmt.setString(4, svccode);
        stmt.setString(5, "01");
        stmt.setString(6, feecode);
        stmt.setString(7, "15");
        stmt.setString(8, tophone);
        stmt.setString(9, phone);
        stmt.setInt(10, 1);
        stmt.setString(11, phone);
        stmt.setString(12, msg.substring(45, 90));
        stmt.setInt(13, 0);
        stmt.setString(14, "02900050");
        stmt.executeUpdate();

        stmt = conn.prepareStatement("insert into tsubmit(SubType,NeedReport,Priority,ServiceID,FeeType,FeeCode,MsgFormat,SrcTermID,ChargeTermID,DestTermIDCount,DestTermID,MsgContent,ValidTime,isdeal,spid) values(?,?,?,?,?,?,?,?,?,?,?,?,now(),?,?)");
        stmt.setInt(1, 2);
        stmt.setInt(2, 1);
        stmt.setInt(3, 0);
        stmt.setString(4, svccode);
        stmt.setString(5, "01");
        stmt.setString(6, feecode);
        stmt.setString(7, "15");
        stmt.setString(8, tophone);
        stmt.setString(9, phone);
        stmt.setInt(10, 1);
        stmt.setString(11, phone);
        stmt.setString(12, msg.substring(90, 135));
        stmt.setInt(13, 0);
        stmt.setString(14, "02900050");
        stmt.executeUpdate();

        stmt = conn.prepareStatement("insert into tsubmit(SubType,NeedReport,Priority,ServiceID,FeeType,FeeCode,MsgFormat,SrcTermID,ChargeTermID,DestTermIDCount,DestTermID,MsgContent,ValidTime,isdeal,spid) values(?,?,?,?,?,?,?,?,?,?,?,?,now(),?,?)");
        stmt.setInt(1, 2);
        stmt.setInt(2, 1);
        stmt.setInt(3, 0);
        stmt.setString(4, svccode);
        stmt.setString(5, "01");
        stmt.setString(6, feecode);
        stmt.setString(7, "15");
        stmt.setString(8, tophone);
        stmt.setString(9, phone);
        stmt.setInt(10, 1);
        stmt.setString(11, phone);
        stmt.setString(12, msg.substring(135, 180));
        stmt.setInt(13, 0);
        stmt.setString(14, "02900050");
        stmt.executeUpdate();

        stmt = conn.prepareStatement("insert into tsubmit(SubType,NeedReport,Priority,ServiceID,FeeType,FeeCode,MsgFormat,SrcTermID,ChargeTermID,DestTermIDCount,DestTermID,MsgContent,ValidTime,isdeal,spid) values(?,?,?,?,?,?,?,?,?,?,?,?,now(),?,?)");
        stmt.setInt(1, 2);
        stmt.setInt(2, 1);
        stmt.setInt(3, 0);
        stmt.setString(4, svccode);
        stmt.setString(5, "01");
        stmt.setString(6, feecode);
        stmt.setString(7, "15");
        stmt.setString(8, tophone);
        stmt.setString(9, phone);
        stmt.setInt(10, 1);
        stmt.setString(11, phone);
        stmt.setString(12, msg.substring(180));
        stmt.setInt(13, 0);
        stmt.setString(14, "02900050");
        stmt.executeUpdate();
      }
      stmt.close();
    }
    catch (Exception e) { //如果执行出错
      log.info(e.getMessage());
      return false;
    }
    finally {
      try { //关闭连接　
        if (conn != null) {
          conn.close();
        }
      }
      catch (SQLException e) {
      }
    }
    return true;
  }

  public String AnalyzeDeal(String toPhone, String command) {
    Connection conn = null;
    String str = "";
    int type = 0;
    try {
      conn = DBMgr.getCon("qqqsms");
      log.info(
          "--------------(xiao ling tong) AnalyzeDeal toPhone :" +
          toPhone);
      log.info("--------------(xiao ling tong) AnalyzeDeal command :" +
               command);

      PreparedStatement stmt = conn.prepareStatement(
          "select * from CommandName where tophone = ? and command = ?");
      stmt.setString(1, toPhone);
      stmt.setString(2, command);
      ResultSet rs = stmt.executeQuery();
      while (rs.next()) {
        str = rs.getString("servletname");
      }
      rs.close();
      stmt.close();

    }
    catch (Exception e) {
      log.info(
          "--------(xiao ling tong) system display not Analyze command");
    }
    finally {
      try {
        if (conn != null) {
          conn.close();