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 msg_id = ";  public String findXmlUrl = "select xml_url ,subject from mms_content where content_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.port+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(":"+Utility.getTimeString()+":"+"     *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(":"+Utility.getTimeString()+":"+"     *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() ;  }}