import Utilities.Engine;
import XML.*;
/**
 * <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 ProcessSMS extends Engine {

        public ProcessSMS() {
                super("ProcessSMS");
        }

        public void run(){
                String xmlStr="";
                while(isRunning()){
                        if(!Config.recv_queue.isEmpty()){
                                xmlStr=(String)Config.recv_queue.pop();
                                if (xmlStr!=null){
                                        processXMLStr(xmlStr);
                                }
                        }else{
                                nap();
                        }

                }
                this.shutdown();
                Config.log.log("Thread processSMS is shutdown!");
        }

        private void processXMLStr(String xmlStr){
                String xmlstr=xmlStr.toLowerCase();
                ParseXML xml=new ParseXML();
                xml.parse(xmlstr);import Utilities.*;
import XML.*;
/**
 * <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 ProcessSMS extends Engine {

        public ProcessSMS() {
                super("ProcessSMS");
        }

        public void run(){
                String xmlStr="";
                while(isRunning()){
                        if(!Config.recv_queue.isEmpty()){
                                xmlStr=(String)Config.recv_queue.pop();
                                if (xmlStr!=null){
                                        processXMLStr(xmlStr);
                                }
                        }else{
                                nap();
                        }

                }
                this.shutdown();
                Config.log.log("Thread processSMS is shutdown!");
        }

        private void processXMLStr(String xmlStr){
                String xmlstr=xmlStr.toLowerCase();
                ParseXML xml=new ParseXML();
                xml.parse(xmlstr);

                if (xmlstr.startsWith("<cmpp_d")){
                        //System.out.println("***** Read: "+xmlStr.substring(0,60)+" ...");
                        String msg_content=xml.getStringValue("/cmpp_deliver/msg_content");
                        String subcode=xml.getStringValue("/cmpp_deliver/destination_id");
                        String gateway=xml.getStringValue("/cmpp_deliver/source/name");
                        int registered_delivery=xml.getIntValue("/cmpp_deliver/registered_delivery");
                        String src_terminal_id=xml.getStringValue("/cmpp_deliver/src_terminal_id");
                        if (registered_delivery == 0){
                                if(msg_content !=null){
                                        if ((subcode.length()==4 && !subcode.startsWith("0")) || (subcode.length()==5 && subcode.startsWith("0"))){

                                                        while(!Config.service_id_queue.push(xmlStr))nap();

                                                        if(msg_content.startsWith("30303030") || msg_content.startsWith("0030003000300030"))
                                                                while(!Config.subcode_queue.push(xmlStr)) nap();
                                                }
                                                Config.incMo();
                                                //System.out.println("-------------in RecvManager.processXMLStr()  push deliver in service_id");
                                        }else{
                                                while(!Config.subcode_queue.push(xmlStr)) nap();
                                                Config.incMo();

                                        //System.out.println("-------------in RecvManager.processXMLStr()  push deliver in subcode");
                                        }
                                }else{
                                                       Config.send_queue.push("<cmpp_submit><destination><name>"+gateway+"</name></destination><src_terminal_id>"+subcode+"</src_terminal_id><dest_terminal_id>"+src_terminal_id+"</dest_terminal_id><pk_total>1</pk_total><pk_number>1</pk_number><service_id>tsxx</service_id><msg_fmt>15</msg_fmt><msg_content>"+Utility.toHexString(Config.no_such_service)+"</msg_content></cmpp_submit>");
                                }
                        }else{
                                while(!Config.service_id_queue.push(xmlStr))nap();
                                while(!Config.subcode_queue.push(xmlStr)) nap();
                        }
                }else {

                        while(!Config.service_id_queue.push(xmlStr)) nap();
                        while(!Config.subcode_queue.push(xmlStr)) nap();
                }
                xml.release();
        }

        public static void main(String[] args) {
                ProcessSMS processSMS1 = new ProcessSMS();
        }
}


                if (xmlstr.startsWith("<cmpp_d")){
                        //System.out.println("***** Read: "+xmlStr.substring(0,60)+" ...");
                        String msg_content=xml.getStringValue("/cmpp_deliver/msg_content");
                        String subcode=xml.getStringValue("/cmpp_deliver/destination_id");
                        int registered_delivery=xml.getIntValue("/cmpp_deliver/registered_delivery");
                        if (registered_delivery == 0){
                                if ((subcode.length()==4 && !subcode.startsWith("0")) || (subcode.length()==5 && subcode.startsWith("0"))){
                                        while(!Config.service_id_queue.push(xmlStr))nap();
                                        if(msg_content.startsWith("30303030") || msg_content.startsWith("0030003000300030"))
                                                while(!Config.subcode_queue.push(xmlStr))nap();
                                        Config.incMo();
                                        //System.out.println("-------------in RecvManager.processXMLStr()  push deliver in service_id");
                                }else{
                                        while(!Config.subcode_queue.push(xmlStr)) nap();
                                        Config.incMo();

                                //System.out.println("-------------in RecvManager.processXMLStr()  push deliver in subcode");
                                }
                        }else{
                                while(!Config.service_id_queue.push(xmlStr)) nap();
                                while(!Config.subcode_queue.push(xmlStr)) nap();
                        }
                }else {

                        while(!Config.service_id_queue.push(xmlStr)) nap();
                        while(!Config.subcode_queue.push(xmlStr)) nap();
                }
                xml.release();
        }

        public static void main(String[] args) {
                ProcessSMS processSMS1 = new ProcessSMS();
        }
}