getnewsms.java~1~

短信网关发送接受平台。

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 GetNewSms extends Engine{
    public DBConnection db = null;
    public GetNewSms() {
        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 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)v.get(0));
                submitPack.pkTotal = Integer.parseInt((String)v.get(1));
                submitPack.pkNumber = Integer.parseInt((String)v.get(2));
                submitPack.registered_deliery = Integer.parseInt((String)v.get(3));
                submitPack.msg_level = Integer.parseInt((String)v.get(4));
                submitPack.serviced_id = (String)v.get(5);
                submitPack.fee_user_type = Integer.parseInt((String)v.get(6));
                submitPack.fee_terminal_id = (String)v.get(7);
                //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();
    }
}