package mmscenter;import java.util.*;import java.lang.Long;//select * from mms_submit where TO_DAYS(create_time) <TO_DAYS( NOW())-8public class GetNewMmsToPool extends Engine{  public DBConnection db = new DBConnection(Config.db_name ,Config.db_host);  //取得200條 3天內(nèi)沒有處理過的數(shù)據(jù)  public String selectSql = "select * from mms_submit where TO_DAYS(NOW())- TO_DAYS(create_time)<= 3 and result =1 and resend >0 limit 200";  public String getServiceCode = "select service_code from mms_content where content_id =";  public GetNewMmsToPool() {    super("GetNewMmsToPool");    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()+":"+"發(fā)送線程 ： "+"發(fā)現(xiàn) "+taskV.size()+" 條還沒有處理的MMS包");        Config.LogPool .push("發(fā)送線程 ： "+"發(fā)現(xiàn) "+taskV.size()+" 條還沒有處理的MMS包");      }else{        System.out.println(":"+Utility.getTimeString()+":"+"發(fā)送線程 ： "+"發(fā)現(xiàn) "+taskV.size()+" 條還沒有處理的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);        sV = (Vector)db.execute(getServiceCode+mms.content_id);        mms.servicecode = (String)((Vector)taskV.get(i)).get(9);        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()+":"+"發(fā)送線程 ： "+"ID號(hào) "+mms.id+" 的MMS包進(jìn)入發(fā)送隊(duì)列");          Config.LogPool.push("發(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) {    GetNewMmsToPool getNewMmsToPool1 = new GetNewMmsToPool();    getNewMmsToPool1.run() ;  }}