import Utilities.*;
import java.io.*;
import XML.*;
import XML.XMLException.*;

/**
 * <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 RecvManager extends Engine {
        public DataInputStream buffer;

        public RecvManager(InputStream in) {
                super("recvManager");
                this.buffer=new DataInputStream(in);
        }

        public void run(){
                String xmlStr="";
                while(isRunning()){
                        try{
                                //while(!Config.recv_queue.isFull()){
                                        xmlStr=buffer.readLine();
                                        if (xmlStr!=null){
                                                //if(xmlStr.startsWith("<cmpp_deliver"))
                                                //System.out.println("read:"+xmlStr.substring(0,70));
                                                Config.recv_queue.push(xmlStr);
                                                Config.incIn();
                                                //processXMLStr(xmlStr);
                                                //System.out.println("***** Read: "+Utility.getCutString(xmlStr));
                                                Config.log.log("server","recieve",xmlStr);
                                        }else{
                                                nap();
                                        }
                                    //    System.out.println("          ------     ------");
                                //}
                        }catch(Exception e){
                                Config.log.log(e,"while read xmlstr from the XMLCenter in RecvManager");
                                e.printStackTrace();
                                shutdown();
                        }
                }
                try{
                        this.buffer.close();
                }catch(Exception e){
                        //e.printStackTrace();
                        shutdown();
                        Config.log.log(e,"while the thread: "+this.toString()+" is reading data from socket!" );
                        System.out.println("while the thread: "+this.toString()+" is reading data from socket!");

                }
        }
/**
        private void processXMLStr(String xmlStr){
                String xmlstr=xmlStr.toLowerCase();
                ParseXML xml=new ParseXML();
                xml.parse(xmlstr);
                String subcode="";
                if (xmlstr.startsWith("<cmpp_d")){
                        //System.out.println("***** Read: "+xmlStr.substring(0,60)+" ...");
                        subcode=xml.getStringValue("/cmpp_deliver/destination_id");
                        if ((subcode.length()==4 && !subcode.startsWith("0")) || (subcode.length()==5 && subcode.startsWith("0"))){
                                Config.service_id_queue.push(xmlStr);
                                //System.out.println("-------------in RecvManager.processXMLStr()  push deliver in service_id");
                        }else{
                                Config.subcode_queue.push(xmlStr);

                        //System.out.println("-------------in RecvManager.processXMLStr()  push deliver in subcode");
                        }
                        //Config.handle_recoder_number++;
                }else {

                        Config.service_id_queue.push(xmlStr);
                        Config.subcode_queue.push(xmlStr);
                }
                xml.release();
        }
*/
        public void shutdown(){
                super.shutdown();
                try{
                        this.buffer.close();
                }catch(Exception e){}
        }

}