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天內沒有處理過的數據  public String selectSql = "select * from mms_submit where TO_DAYS(create_time)-TO_DAYS(NOW()) <= 3 and result =1 and resend >0 limit 200";  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("發送線程 ： "+"發現 "+taskV.size()+" 條還沒有處理的MMS包");        Config.LogPool .push("發送線程 ： "+"發現 "+taskV.size()+" 條還沒有處理的MMS包");      }else{        System.out.println("發送線程 ： "+"發現 "+taskV.size()+" 條還沒有處理的MMS包");      }      for(int i = 0 ;i < taskV.size() ; i++){        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);        mms.resend = (String)((Vector)taskV.get(i)).get(11);        if(Config.TaskPool.getSize()<200){//保證隊列中有<=200個MMS包          Config.TaskPool.push(mms);          System.out.println("發送線程 ： "+"ID號 "+mms.id+" 的MMS包進入發送隊列");          Config.LogPool.push("發送線程 ： "+"ID號 "+mms.id+" 的MMS包進入發送隊列");        }      }//      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() ;  }}