receiptengine.java

短信网关发送接受平台。

package orderapp;

/**
 * Title:
 * Description:收条处理线程
 * Copyright:    Copyright (c) 2002
 * Company:
 * @author
 * @version 1.0
 */
import utilities.Engine;
import xml.*;
import data.ConnectionPool;
public class receiptEngine extends Engine{
       public String receiptStr="";
       public String msg_mr="";
       public String confirmed="";
       public String status="";
       public String gateway_confirmed="";
       public getLabel GetLabel;
       public ConnectionPool data;
       public String sql="";
	public receiptEngine() {
	       setDaemon(true);
	       GetLabel=new getLabel();
	       data=new ConnectionPool();
	       status="1";
	}
	public void run(){
	       while(true){
		       if(!Config.receipt_queue.isEmpty()){
				receiptStr=(String)Config.receipt_queue.pop();
				System.out.println(receiptStr+"收条");
				msg_mr=GetLabel.getString("msg_mr",receiptStr);
				status=GetLabel.getString("status",receiptStr);
				if(status.startsWith("DELIVRD")){
					confirmed="0";
					status="0";
				}
				if(!status.equals("DELIVED") && status.length()!=0){
					confirmed="0";
					status="1";
				}
				/*
				if(status.startsWith("0")){
					confirmed="0";
					status="";
				}
				*/
				sql="update mobile_bill set gateway_confirmed = "+confirmed+" and gateway_status = "+status+"where gateway_msg_id = "+msg_mr+" and registered_delivery = 1";
				//如果有收条，没有response？？？？
				data.executeUpdate(sql);
				System.out.println(receiptStr);
				//处理收条
		       }
		       try{
				Thread.sleep(1000);
		       }
		       catch(Exception e){
				       e.printStackTrace();
		       }
	       }

	}
}