scanworderthread.java

短信网关发送接受平台。

package orderapp;

/**
 * Title:
 * Description:
 *      获得由WWW上来的Mo信息，扫描www_order表
 * Copyright:    Copyright (c) 2002
 * Company:
 * @author
 * @version 1.0
 */
import utilities.*;
import data.ConnectionPool;
import java.sql.*;
import data.*;
public class scanWOrderThread extends Engine{
       public ConnectionPool database;
       public ConnectionPool dataUpdate;
       public ResultSet rs;
       public ResultSet rsUpdate;

       public ResultSet rsQuery;
       public boolean haveRs;

       public String sqlQuery,sqlUpdate;
       public getContent pushSubmit;
       public XmlString xml;
       public String WwwSql;
       public String create_date;
	public scanWOrderThread() {
	       setDaemon(true);
	       database=new ConnectionPool();
	       dataUpdate=new ConnectionPool();

	       sqlQuery="select * from mobile_www_order where process_flag = 1";
	       sqlUpdate="update mobile_www_order set process_flag = 0 where order_id =";
	       pushSubmit=new getContent();

	       //create_date=utilities.Utility.getDateString().substring(0,7);
		create_date=utilities.Utility.getDateString();
	}
	public void run(){
	       while(true){
			try{
				Thread.sleep(10);
			}catch(Exception e){
					 e.printStackTrace();
			}

		      try{
			      rs=database.executeQuery(sqlQuery);
			      while(rs.next()){
					wwwOrder.order_id=rs.getInt("order_id");
					wwwOrder.msg_id=rs.getInt("msg_id");
					wwwOrder.service_type=rs.getString("service_type");
					wwwOrder.dest_number = rs.getString("dest_number");
					wwwOrder.gateway = rs.getString("gateway");
					wwwOrder.mobile_number = rs.getString("mobile_number");
					wwwOrder.dest_number = rs.getString("dest_number");
					//更新mobile_www_order表
					sqlUpdate="update mobile_www_order set process_flag = 0 where order_id ="+wwwOrder.order_id;
					dataUpdate.executeUpdate(sqlUpdate);
					//发送
					pushSubmit.getParameter(String.valueOf(wwwOrder.msg_id),wwwOrder.service_type,"ww",wwwOrder.order_id,wwwOrder.dest_number,wwwOrder.gateway,wwwOrder.mobile_number,wwwOrder.dest_number);
					pushSubmit.insertSubmit();


					//统计Sql语句

					rsQuery=database.executeQuery("select www_order,mo_order from mobile_content_statistics where msg_id='"+wwwOrder.msg_id+"' and service_type='"+wwwOrder.service_type+"' and create_date='"+create_date+"' and www_order>0");
					try{
						haveRs=rsQuery.next();
					}
					catch(Exception e){
							e.printStackTrace();
					}
					System.out.println(haveRs);
					if(!haveRs){
						WwwSql="insert into mobile_content_statistics (msg_id,service_type,gateway,www_order,create_date)values( "+wwwOrder.msg_id+",'"+wwwOrder.service_type+"','"+wwwOrder.gateway+"',"+1+",'"+create_date+"')";
						Config.sql_queue.push(WwwSql);
					}else{
						WwwSql="update mobile_content_statistics set www_order=www_order+1 where msg_id='"+wwwOrder.msg_id+"' and service_type='"+wwwOrder.service_type+"' and create_date='"+create_date+"' and mo_order=0";
						Config.sql_queue.push(WwwSql);
					}


			      }
			      rs.close();
		      }
		      catch(Exception e){
				      e.printStackTrace();

		      }
	       }
	}
}