tempthread.java~52~

短信网关发送接受平台。

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*/
                }

            }
            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){}
    }
}