responseengine.java

短信网关发送接受平台。

package orderapp;

/**
 * Title:
 * Description:Response回应处理线程
 *              回写bill
 * Copyright:    Copyright (c) 2002
 * Company:
 * @author
 * @version 1.0
 */
import utilities.Engine;
import xml.*;
import data.response;
public class responseEngine extends Engine{
       public String respTmp="";
       public getLabel GetLabel;
       public String sql;
	public responseEngine() {
	       setDaemon(true);
	       GetLabel=new getLabel();
	}
	public void run(){
	       while(true){
			if(!Config.response_queue.isEmpty()){
				respTmp=(String)Config.response_queue.pop();
				//System.out.println(respTmp);
				response.destination_guid=GetLabel.getString("destination/guid",respTmp);
				response.result=GetLabel.getString("result",respTmp);
				response.msg_id=GetLabel.getString("msg_id",respTmp);
				//System.out.println(respTmp);
				sql="update mobile_bill set gateway_result = "+response.result+",gateway_msg_id = '"+response.msg_id+"' where row_id="+response.destination_guid;
				//System.out.print(response.msg_id+"vvvv");
				Config.sql_queue.push(sql);
			}
			try{
				Thread.sleep(50);
			}
			catch(Exception e){

			}
	       }
	}
}