getfailedsms.java~5~

短信网关发送接受平台。

package smscenter;

/**
 * <p>Title: </p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2004</p>
 * <p>Company: </p>
 * @author unascribed
 * @version 1.0
 */
import java.util.*;
import smscenter.pack.*;
public class GetFailedSms extends Engine{
    public DBConnection db = null;
    public GetFailedSms() {
        super("GetNewSms");
        setDaemon(true);
        db = new DBConnection("test",Config.db_host );
    }
    public void run(){
        while(isRunning()){  //取得500条                           3天内                        处理失败       (不是新的数据     不是正在发送     不是发送成功       重法次数大于0   的数据
            String querySql = "select * from sms_submit where TO_DAYS(create_time)-TO_DAYS(NOW()) <= 3 and result <> 1 and result <>2 and result <>0  and resend >0 limit 500";
            Vector v = new Vector();
            v = (Vector)db.execute(querySql) ;
            System.out.println(v) ;
            for(int i = 0;i<v.size() ;i++){
                SubmitPack submitPack = new SubmitPack();
                //[[1, 1, 1, 0, 0, SYSTEM, 3, 13161712520, 0, 0, 15, 1010, 01, 0, , , 1010, 1, 13161712520, test此时, , 2004-03-31, 1, 3]]
                submitPack.msg_id = Long.parseLong((String)((Vector)v.get(i)).get(0));
                submitPack.pkTotal = Integer.parseInt((String)((Vector)v.get(i)).get(1));
                submitPack.pkNumber = Integer.parseInt((String)((Vector)v.get(i)).get(2));
                submitPack.registered_deliery = Integer.parseInt((String)((Vector)v.get(i)).get(3));
                submitPack.msg_level = Integer.parseInt((String)((Vector)v.get(i)).get(4));
                submitPack.serviced_id = (String)((Vector)v.get(i)).get(5);
                submitPack.fee_user_type = Integer.parseInt((String)((Vector)v.get(i)).get(6));
                submitPack.fee_terminal_id = (String)((Vector)v.get(i)).get(7);
                submitPack.tp_pid = Integer.parseInt((String)((Vector)v.get(i)).get(8));
                submitPack.tp_udhi = Integer.parseInt((String)((Vector)v.get(i)).get(9));
                submitPack.msg_fmt = Integer.parseInt((String)((Vector)v.get(i)).get(10));
                submitPack.msg_src = (String)((Vector)v.get(i)).get(11);
                submitPack.fee_type = (String)((Vector)v.get(i)).get(12);
                submitPack.fee_code = (String)((Vector)v.get(i)).get(13);
                submitPack.valid_time = (String)((Vector)v.get(i)).get(14);
                submitPack.at_time = (String)((Vector)v.get(i)).get(15);
                submitPack.src_terminal_id = (String)((Vector)v.get(i)).get(16);
                submitPack.dest_user_t1 = Integer.parseInt((String)((Vector)v.get(i)).get(17));
                submitPack.dest_terminal_id = (String)((Vector)v.get(i)).get(18);
                submitPack.msg_content = (String)((Vector)v.get(i)).get(19);
                submitPack.reserve = (String)((Vector)v.get(i)).get(20);
                submitPack.create_time = (String)((Vector)v.get(i)).get(21);
                submitPack.result = Integer.parseInt((String)((Vector)v.get(i)).get(22));
                submitPack.resend = Integer.parseInt((String)((Vector)v.get(i)).get(23));
                if(Config.sendPool.getSize() <500){
                        Config.sendPool.push(submitPack);
                }
                //submitPack
            }
            try{
                sleep(TimeConfig.TIME_ONE_SECOND*5);
            }catch(Exception e){
                System.out.println("Exception In GetNewSms.run() : "+e.toString() );
            }
        }
    }
    public static void main(String[] args) {
        GetNewSms getNewSms1 = new GetNewSms();
        getNewSms1.run();
    }
}