sendthread.java~71~

彩信网关程序。只支持发送。

package mmscenter;
import java.util.*;
public class SendThread extends Engine{
  public DBConnection database = new DBConnection(Config.db_name ,Config.db_host);

  public String updateSql = "update mms_submit set result = ";
  public String setSql = " , resend = resend-1";
  public String whereSql = " where id = ";

  public String findXmlUrl = "select xml_url ,subject from mms_content where id = ";
  public SendThread() {
    super("SendThread");
    setDaemon(true);
  }
  public void run(){
    while(true){
      MMS mms = new MMS();
      if(Config.TaskPool.getSize()>0){//队列中如果有MMS包
        mms = (MMS)Config.TaskPool.pop();
        System.out.println("Start===>(mms.id : "+mms.id+")===>Start");
        Config.LogPool.push("Start===>(mms.id : "+mms.id+")===>Start");
        SendMMS(mms);
        System.out.println("End===>(mms.id : "+mms.id+")===>End");
        Config.LogPool.push("End===>(mms.id : "+mms.id+")===>End");
      }
      try{
        sleep(TimeConfig.TIME_ONE_SECOND);
      }catch(Exception e){
        e.printStackTrace() ;
      }
    }
  }
  public void SendMMS(MMS mms){
    //收集万维的参数
        String xmlUrl = "";
        //user;passw is in config
        String subject = "";
        //String fee_terminal_id = "13161712520";
        //String phone_num = "13161712520";
        long id = mms.id ;//submit id
        long content_id = mms.content_id ;
        subject = mms.subject ;
        String fee_terminal_id = mms.fee_terminal_id;
        String phoneNum = mms.dest_terminal_id;
        String servicecode = mms.servicecode ;
        //System.out.println(content_id);
        Vector xmlUrlV = new Vector();
        xmlUrlV = (Vector)database.execute(findXmlUrl+String.valueOf(content_id));
        xmlUrl = (String)((Vector)xmlUrlV.get(0)).get(0);
       //System.out.println("xmlUrlV : "+xmlUrlV);
        //标记submit纪录sending
        String sendingSql = updateSql+"2"+whereSql+String.valueOf(id) ;
        //System.out.println(sendingSql);
        database.executeUpdate(sendingSql) ;
        //发送//接收结果
        String MMSCUrl = Config.protocol+Config.ip+Config.subfolder+"?username="+Config.user+"&password="+Config.password+"&subject="+subject+"&fee_terminal_id="+fee_terminal_id+"&phone_num="+phoneNum+"&servicecode="+servicecode+"&xmlurl="+xmlUrl;
        System.out.println("MMSCUrl :"+MMSCUrl);
        Config.LogPool.push("MMSCUrl :"+MMSCUrl);
        String sendResult = EnterWW.GoTo(MMSCUrl);
        String resultCode = EnterWW.GetResultCode(sendResult) ;
        if(resultCode.equals("0") ){
          System.out.println("*OK_OK_OK_OK*SendResult : OK"+" MMS.ID : "+id+"");
          Config.LogPool.push("*OK_OK_OK_OK*SendResult : OK"+" MMS.ID : "+id);
        }else if(!resultCode.equals("") ){
          System.out.println("*NOTOK_NOTOK*SendResult is NotOk the resultCode is :"+resultCode+" MMS.ID : "+id);
          Config.LogPool.push("*NOTOK_NOTOK*SendResult is NotOk the resultCode is :"+resultCode+" MMS.ID : "+id);
        }else{
          resultCode = "-30";
        }
        //System.out.println(sendResult);
        //回写数据库
        String setSubmitResult = updateSql+resultCode+setSql+whereSql+String.valueOf(id) ;
        database.execute(setSubmitResult);
  }
  public static void main(String[] args) {
    SendThread sendThread1 = new SendThread();
    sendThread1.run() ;
  }
}