resendthread.java~19~

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

package mmscenter;
import java.util.*;
public class ResendThread extends Engine{
  public DBConnection db = new DBConnection(Config.db_name ,Config.db_host);
 //取得200条 没有发送成功的数据
 public String selectSql = "select * from mms_submit where  result <> 0 and result <>1 and result <>2 and resend > 0 limit 200";

  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("补发线程 ： "+"发现 "+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包进入发送队列");
        }
      }
//      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();
  }
}