getnewsms.java~58~

短信网关发送接受平台。

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(Config.db_name ,Config.db_host );
    }
    public void run(){
        while(isRunning()){  //取得500条                           3天内                                   没有处理过        重法次数大于0   的数据
            String querySql = "select * from sms_submit where TO_DAYS(NOW())-TO_DAYS(create_time) <= 3 and result =1 and resend >0 limit 500";
            Vector v = new Vector();
            v = (Vector)db.execute(querySql) ;
            System.out.println("获得新插入SUBMIT包 ("+v.size() +") 个") ;
            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);
                        SendingSms(String.valueOf(submitPack.msg_id ));
                        Config.log.log("Insert One Mt to SendThreadPool : \r\n\tThe MsgId is:"+String.valueOf(submitPack.msg_id));
                }
                //submitPack
            }
            try{
                sleep(TimeConfig.TIME_ONE_SECOND*5);
            }catch(Exception e){
                System.out.println("Exception In GetNewSms.run() : "+e.toString() );
                Config.log.log("Exception In GetNewSms.run() : "+e.toString());
            }
        }
    }
    public void SendingSms(String msg_id){
        String sql = "update sms_submit set result = 2 where msg_id = "+msg_id;
        db.executeUpdate(sql) ;

    }
    public static void main(String[] args) {
        GetNewSms getNewSms1 = new GetNewSms();
        getNewSms1.run();
        System.out.println(Config.sendPool.getSize());
        while(true){}
    }
}