import Utilities.*;
import java.io.*;
import java.net.*;

/**
 * <p>Title: InHand SMS platform XMLRouter</p>
 * <p>Description: InHand 短信服務平臺服務路由器</p>
 * <p>Copyright: Copyright (c) 2002</p>
 * <p>Company: 北京映翰通網絡技術有限公司</p>
 * @author 韓傳俊 shock2000@21cn.com
 * @version 1.0
 */

public class SendManager extends Engine {
        public BufferedOutputStream out;

        public SendManager(OutputStream out) {
                super("SendManager");
                this.out=new BufferedOutputStream(out);
        }

        public void run(){
                String str="";
               // while (Config.send_queue.isEmpty()){
                 //                       this.out.println("<get_gateway_status></get_gateway_status>");
                 //                       this.sleep(5000);
               // }
               String status="<get_gateway_status id=\"0\" type=\"router\"></get_gateway_status>\r\n";
               byte[] bytes=status.getBytes();
               //
               try{
                        this.out.write(status.getBytes());
                }catch(Exception e){
                        e.printStackTrace();
                        shutdown();
                }
                while(isRunning()){
                        try{

                                //this.out.write(status.getBytes());
                                if(!Config.send_queue.isEmpty()){
                                        str=(String)Config.send_queue.pop();
                                        if (str!=null){
                                                str=str+"\r\n";
                                                this.out.write(str.getBytes());
                                                if (str.startsWith("<cmpp_su")){
                                                        Config.log.log("server","Send",str);
                                                        Config.incMt();
                                                }
                                                Config.incOut();
                                        //Config.handle_recoder_number++;
                                        //System.out.println("===== Send: "+Utility.getCutString(str));

                                        }
                                        sleep(Config.sleep_time);
                                }else{
                                        this.out.write(bytes);
                                        //System.out.println("===== Sending: <get_gateway_status></get_gateway_status>");
                                        //Config.log.log("==no out put=== Sending: <get_gateway_status></get_gateway_status>");
                                        sleep(1000);
                                }
                                this.out.flush();

                        }catch(Exception e){
                                this.shutdown();
                                Config.log.log(e,"while the thread: "+this.toString()+" is writing data from socket!" );
                                System.out.println("while the thread: "+this.toString()+" is writing data from socket!");

                        }
                }
                shutdown();
        }

        public void shutdown(){
                super.shutdown();
                try{
                        this.out.close();
                }catch(Exception e){}
        }

        public static void main(String[] args) {
                //SendManager sendManager1 = new SendManager();
        }
}