tempthread.java~53~

短信网关发送接受平台。

package smscenter;

/**
 * <p>Title: </p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2004</p>
 * <p>Company: </p>
 * @author unascribed
 * @version 1.0
 */
//select last_active_time from temp where DATE_ADD(last_active_time ,INTERVAL 0 SECOND)='2004-04-01 14:04:51'
import java.util.*;
public class TempThread extends Engine{
    public DBConnection db = null;
    public String getActive = "";
    public String setActive = "";
    public TempThread() {
        super("TempThread");
        setDaemon(true);
        db = new DBConnection(Config.db_name,Config.db_host);
    }
    public void run(){
        while(isRunning()){
            Vector v1 = new Vector();
            v1 = (Vector)db.execute("select active_server from sms_temp where now_run = 1") ;
            System.out.println(v1);
            String vString  = (String)((Vector)v1.get(0)).get(0);

            if(vString.equals(Config.Exe_Id)){
                Config.isActive = true;
            }else{
                Config.isActive = false;
            }
            if(Config.isActive ){
                String sql = "update sms_temp set last_active_time = '"+Utility.getDateString()+" "+Utility.getTimeString()+
                             "',now_run = 1 where active_server='"+ Config.Exe_Id +"'";

                System.out.println("发送自身状态 : Config.isActive = true");
                db.executeUpdate(sql);
            }else{
                String Exe_Id = "1";
                if(Config.Exe_Id.equals("1")){
                    Exe_Id = "2";
                }else{
                    Exe_Id = "1";
                }
                String sql = "select last_active_time from sms_temp where last_active_time >='"+
                             Utility.getDateString() +" "+Utility.getTimeString1() +"' and active_server = '"+Exe_Id+"'";
                System.out.println(sql);
                Vector v = new Vector();
                v = (Vector)db.execute(sql);
                System.out.println(v);
                if(v.size() <= 0){
                    Config.isActive = true;
                    String ChangeActive1 = "update sms_temp set now_run = 0 where active_server = '"+Exe_Id+"'";
                    String ChangeActive2 = "update sms_temp set now_run = 1 where active_server = '"+Config.Exe_Id+"'";
                    db.execute(ChangeActive1);
                    db.execute(ChangeActive2);
                    /*send Alter submit to administrator*/
                    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 = 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);
                       Config.log.log("Insert One Mt to SendThreadPool : \r\n\tThe MsgId is:"+String.valueOf(submitPack.msg_id));
                }
                }

            }
            try{
                sleep(TimeConfig.TIME_ONE_MINUTE/2);
            }catch(Exception e){
                System.out.println("Exception In TempThread : "+e.toString() );
            }
        }
    }
    public static void main(String[] args) {
        TempThread tempThread1 = new TempThread();
        tempThread1.startup() ;
        while(true){}
    }
}