mailorderstat.java

电信的网厅的整站代码

package com.doone.fj1w.fjmgr.order.mailorder;

import java.util.LinkedList;
import java.util.Map;
import java.util.Properties;

import com.doone.data.DacClient;
import com.doone.data.DataTable;
import com.doone.util.ExtString;
import com.doone.util.FileLogger;

public class MailOrderStat {
	protected static DacClient _dac = null;
	static {
		try {
			_dac = new DacClient();
		} catch (Exception rux) {
			FileLogger.getLogger().warn("连接数据库异常！");
		}
	}	
	private static FileLogger _logger = new FileLogger();
	
	static public DataTable getOrderMethod(Map _map, String statu)
	throws java.sql.SQLException, RuntimeException {
		DataTable dt=null;
		try {
			String userid = (String) _map.get("USERID");// 客户ID
			String accountid = (String) _map.get("ACCOUNTID");// 客户账号
			String name = (String) _map.get("NAME");// 客户名称
			String mailcomm = (String) _map.get("MAILCOMM");// 帐单类型
			String email = (String) _map.get("EMAIL");// email
			String sendstate = statu;// 发送状态
			String citycode = (String) _map.get("CITYCODE");// 地市编码
			String year = (String) _map.get("YEAR");// 发送月份
			String month = (String) _map.get("MONTH");// 发送月份
			String custtype = (String) _map.get("CUSTTYPE");//用户类型
			String time="";
			if(month!=null)
				if(month.length()<2)
					month="0"+month;
			if(year!=null && month!=null)
				time=year+month;
//System.out.println("time:"+time);				
			if(time.equals(""))
				return dt;
			
			StringBuffer sql = new StringBuffer();
			LinkedList _linkList = new LinkedList();
			// 基本条件
			sql.append("select count(1) as count ");
			sql.append(" FROM tl_maillog_"+time+" d,  tf_custinfoweb b,tf_andcustrela f, tf_mailorder c");
			sql.append(" where ");
			sql.append(" d.userid = b.accountid ");
			sql.append(" and b.userid=f.userid ");
			sql.append(" and f.andcustrelaid=c.andcustrelaid");
			sql.append(" and d.mailorderid=c.mailorderid ");
			sql.append(" and d.state = 'E' ");
			
			if (!ExtString.isEmpty(citycode) && !citycode.equals("0590")) {
				sql.append(" and ");	
				sql.append(" b.citycode=?");
				_linkList.add(citycode);
			}
			
			if (!ExtString.isEmpty(accountid)) {
				sql.append(" and ");	
				sql.append(" b.accountid=?");
				_linkList.add(accountid);
			}			
			
			if (!ExtString.isEmpty(mailcomm) && !mailcomm.equals("5")) {
				sql.append(" and ");	
				sql.append(" c.ordersort =?");
				_linkList.add(mailcomm);
			}
			
			if (!ExtString.isEmpty(email)) {
				sql.append(" and ");	
				sql.append(" b.email=?");
				_linkList.add(email);
			}				
			
			// "Y","N","S","F" >>>> "已发送","未发送", "发送成功","发送失败" 
			if (sendstate != null) {
				if (sendstate.equals("Y")) {
					sql.append(" and d.faultcount>'0'");
				} else if (sendstate.equals("N")) {
					sql.append(" and d.faultcount='0'");
				} else if (sendstate.equals("S")) {
					sql.append(" and d.faultcount='10'");
				} else if (sendstate.equals("F")) {
					sql.append(" and d.faultcount<'10' and d.faultcount>'0'");
				}
			}
//			sql.append(" order by t.createtime asc");
//System.out.println("sql \n:" + sql.toString());
			if (_linkList.size() == 0) {
				dt = _dac.executeQuery(sql.toString());
			} else {
				dt = _dac.executeQuery(sql.toString(), _linkList.toArray());
			}
			return dt;
		} catch (java.sql.SQLException sqlx) {
			throw sqlx;
		} catch (RuntimeException rux) {
			_logger.warn(rux.getMessage(), rux);
			throw rux;
		}catch(Exception ex){
			_logger.warn(ex.getMessage(), ex);
		}
		return null;
	}
}