package mmscenter;import java.util.*;public class ResendThread extends Engine{  public DBConnection db = new DBConnection(Config.db_name ,Config.db_host); //取得200條 沒(méi)有發(fā)送成功的數(shù)據(jù) public String selectSql = "select * from mms_submit where  result <> 0 and result <>1 and result <>2 and resend > 0 limit 200"; public String getServiceCode = "select service_code from mms_content where content_id =";  public ResendThread() {    super("ResendThread");    setDaemon(true);  }  public void run(){    while(true){      Vector taskV = new Vector();      taskV = (Vector)db.execute(selectSql) ;      if(taskV.size() >0){        System.out.println(":"+Utility.getTimeString()+":"+"補(bǔ)發(fā)線程 ： "+"發(fā)現(xiàn) "+taskV.size()+" 條沒(méi)有發(fā)送成功的MMS包");        Config.LogPool.push("補(bǔ)發(fā)線程 ： "+"發(fā)現(xiàn) "+taskV.size()+" 條沒(méi)有發(fā)送成功的MMS包");      }else{        System.out.println(":"+Utility.getTimeString()+":"+"補(bǔ)發(fā)線程 ： "+"發(fā)現(xiàn) "+taskV.size()+" 條沒(méi)有發(fā)送成功的MMS包");      }      for(int i = 0 ;i < taskV.size() ; i++){          Vector sV = new Vector();        MMS mms = new MMS();        mms.id = Long.parseLong(((String)(((Vector)taskV.get(i)).get(0))));        mms.content_id = Long.parseLong(((String)(((Vector)taskV.get(i)).get(1))));        mms.subject = (String )((Vector)taskV.get(i)).get(2);        mms.create_time = (String)((Vector)taskV.get(i)).get(3);        mms.dest_terminal_id = (String)((Vector)taskV.get(i)).get(5);        mms.fee_terminal_id = (String)((Vector)taskV.get(i)).get(6);        mms.fee_type = (String)((Vector)taskV.get(i)).get(7);        mms.fee_code = (String)((Vector)taskV.get(i)).get(8);        //mms.servicecode = (String)((Vector)taskV.get(i)).get(9);        sV = (Vector)db.execute(getServiceCode+mms.content_id);        String service_code = (String)((Vector)sV.get(0)).get(0);       //mms.servicecode = (String)((Vector)taskV.get(i)).get(9);        mms.servicecode = service_code;        mms.resend = (String)((Vector)taskV.get(i)).get(11);        if(Config.TaskPool.getSize()<200){//保證隊(duì)列中有<=200個(gè)MMS包          Config.TaskPool.push(mms);          System.out.println(":"+Utility.getTimeString()+":"+"補(bǔ)發(fā)線程 ： "+"ID號(hào) "+mms.id+" 的MMS包進(jìn)入發(fā)送隊(duì)列");          Config.LogPool.push("補(bǔ)發(fā)線程 ： "+"ID號(hào) "+mms.id+" 的MMS包進(jìn)入發(fā)送隊(duì)列");        }      }//      System.out.println(Config.TaskPool.getSize());//      MMS mms1 = new MMS();//      mms1 = (MMS) Config.TaskPool.pop();//      System.out.println(mms1.id);      try{        sleep(TimeConfig.TIME_ONE_MINUTE/6);      }catch(Exception e){        e.printStackTrace() ;      }    }  }  public static void main(String[] args) {    ResendThread resendThread1 = new ResendThread();  }}