getnewmmstopool.java~69~

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

package mmscenter;
import java.util.*;
import java.lang.Long;
//select * from mms_submit where TO_DAYS(create_time) <TO_DAYS( NOW())-8
public 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(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()+":"+"发送线程 ： "+"发现 "+taskV.size()+" 条还没有处理的MMS包");
        Config.LogPool .push("发送线程 ： "+"发现 "+taskV.size()+" 条还没有处理的MMS包");
      }else{
        System.out.println(":"+Utility.getTimeString()+":"+"发送线程 ： "+"发现 "+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(":"+Utility.getTimeString()+":"+"发送线程 ： "+"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() ;
  }
}