register.java

电信的网厅的整站代码

package com.doone.fj1w.fjmgr.sysmgr;

import java.util.Date;
import java.util.LinkedList;
import java.util.Map;

import com.doone.data.DacClient;
import com.doone.data.DataTable;
import com.doone.fj1w.common.TF_CustTypeImpl;
import com.doone.fj1w.fj1w.account.AccountImpl;
import com.doone.fj1w.fj1w.account.interfaceset.Account;
import com.doone.fj1w.fjmgr.order.DAO;
import com.doone.util.FileLogger;
import com.doone.uurm.UserFactory;

public class Register extends DAO {

	private static FileLogger _logger = new FileLogger();
	
	/**
	 * <code>
	 *  统计注册用户的所有状态，如：激活
	 * </code>
	 * 
	 * @param _map
	 * @param statu
	 * @return
	 * @throws java.sql.SQLException
	 * @throws RuntimeException
	 */
	static public DataTable getOrderMethod(Map _map, String statu)
			throws java.sql.SQLException, RuntimeException {

		try {
			String userid = (String) _map.get("USERID");// 客户账号
			String name   = (String) _map.get("NAME");// 客户名称
			String email  = (String) _map.get("EMAIL");// email
			String ordernbr  = (String) _map.get("ORDERNBR");
			String userState = statu;// 账号状态
			String areaCode  = (String) _map.get("AREA");// 地域编码
			String cityCode  = (String) _map.get("CITY");// 地市编码
			String custtype  = (String) _map.get("CUSTTYPE");
			String starttime = (String) _map.get("STARTTIME");// 开始时间
			String endtime   = (String) _map.get("ENDTIME");// 结束时间

			StringBuffer sql = new StringBuffer();
			LinkedList _linkList = new LinkedList();
			// 基本条件
			sql.append("SELECT count(t.userid) as count FROM tf_custinfoweb t ");
			sql.append(" where t.userid > 0 AND");
			if (custtype == null || custtype.equals("")) {
				custtype = "2";
			}
			sql.append(" t.custtypeid=?");
			_linkList.add(custtype);
			// 权限值
			if (cityCode != null && !cityCode.equals("")
					&& !cityCode.equals("0590")) {
				sql.append(" and t.citycode=?");
				_linkList.add(cityCode);
				// 地区
				if (areaCode != null && !areaCode.equals("")) {
					sql.append(" and decode(t.areacode,null,t.citycode||'00',t.areacode)=?");
					_linkList.add(areaCode);
				}
			}

			if (userid != null && !userid.equals("")) {
				sql.append(" and t.accountid like ?");
				_linkList.add("%" + userid.trim() + "%");
			}

			if (name != null && !name.equals("")) {
				sql.append(" and t.name like ?");
				_linkList.add("%" + name.trim() + "%");
			}

			if (email != null && !email.equals("")) {
				sql.append(" and t.email like ?");
				_linkList.add("%" + email.trim() + "%");
			}

			if (ordernbr != null && !ordernbr.equals("")) {
				sql.append(" and t.userid in(");
				sql.append("select a.userid from tf_andcustrela a ");
				sql.append("where a.state='E' and a.phonenum like ?)");
				_linkList.add("%" + ordernbr.trim() + "%");
			}
			
			// "A","N","L","D" >>>> "激活","待激活", "过期","注销"
			if (userState != null) {

				if (userState.equals("A")) {
					sql.append(" and t.state='E' and t.userstate='A'");
				} else if (userState.equals("N")) {
					sql.append(" and t.state='E' and t.userstate='N'");
				} else if (userState.equals("L")) {
					sql.append(" and t.state='D' and t.userstate='L'");
				} else if (userState.equals("D")) {
					sql.append(" and t.state='D' and t.userstate not in('L')");
				}
			}

			// 开始时间
			if (starttime != null && !starttime.equals("")) {
				sql.append(" and t.createtime >= to_date(?,'YYYY-MM-DD HH24:MI:SS')");
				_linkList.add(starttime);
			}
			// 结束时间
			if (endtime != null && !endtime.equals("")) {
				sql.append(" and t.createtime <= to_date(?,'YYYY-MM-DD HH24:MI:SS')");
				_linkList.add(endtime);
			}

			sql.append(" order by t.createtime asc");
			//System.out.println("sql \n:" + sql.toString());
			if (_linkList.size() == 0) {
				return _dac.executeQuery(sql.toString());
			} else {
				return _dac.executeQuery(sql.toString(), _linkList.toArray());
			}
		} catch (java.sql.SQLException sqlx) {
			throw sqlx;
		} catch (RuntimeException rux) {
			_logger.warn(rux.getMessage(), rux);
			throw rux;
		}
	}

	/**
	 * 获取当前某一状态的总数
	 * 
	 * @param _map
	 * @param statu
	 * @return
	 * @throws java.sql.SQLException
	 * @throws RuntimeException
	 */
	static public int getOrderListCount(Map _map, String statu)
			throws java.sql.SQLException, RuntimeException {

		try {
			DataTable _dt = getOrderMethod(_map, statu);
			return _dt.getRow(0).getInt("count");

		} catch (java.sql.SQLException sqlx) {
			throw sqlx;
		} catch (RuntimeException rux) {
			_logger.warn(rux.getMessage(), rux);
			throw rux;
		}
	}

	static public DataTable getOrderList(java.util.Map _map, int startrecord,
			int recordnum) throws java.sql.SQLException, RuntimeException {
		int endrecord = recordnum;
		if (startrecord < 0)
			startrecord = 0;
		if (endrecord > 0 && startrecord > 0)
			endrecord = startrecord + recordnum;
		try {
			String userid = (String) _map.get("USERID");// 客户账号
			String name = (String) _map.get("NAME");// 客户名称
			String email = (String) _map.get("EMAIL");// email
			String ordernbr = (String) _map.get("ORDERNBR");
			String userState = (String) _map.get("ACTION");// 账号状态
			String areaCode = (String) _map.get("AREA");// 地域编码
			String cityCode = (String) _map.get("CITY");// 地市编码
			String custtype = (String) _map.get("CUSTTYPE");
			String starttime = (String) _map.get("STARTTIME");// 开始时间
			String endtime = (String) _map.get("ENDTIME");// 结束时间

			StringBuffer sql = new StringBuffer();
			LinkedList _linkList = new LinkedList();
			// 基本条件 帐号 姓名 地市编码 注册时间 证件号 邮件地址 状态
			//添加显示字段USERID、AREACODE，便于以后用实体对此表进行操作。 2007-03-05 qiuzb  add   t.USERID、t.AREACODE
			sql.append("SELECT t.USERID,t.ACCOUNTID,t.NAME,t.CITYCODE,t.CREATETIME,");
			sql.append("t.EMAIL,t.USERSTATE,t.STATE,t.AREACODE FROM tf_custinfoweb t ");
			sql.append(" where t.userid > 0 AND");
			if (custtype == null || custtype.equals("")) {
				custtype = "2";
			}
			sql.append(" t.custtypeid=?");
			_linkList.add(custtype);
			// 权限值
			if (cityCode != null && !cityCode.equals("")
					&& !cityCode.equals("0590")) {
				sql.append(" and t.citycode=?");
				_linkList.add(cityCode);
				// 地区
				if (areaCode != null && !areaCode.equals("")) {
					sql
							.append(" and decode(t.areacode,null,t.citycode||'00',t.areacode)=?");
					_linkList.add(areaCode);
				}
			}

			if (userid != null && !userid.equals("")) {
				sql.append(" and t.accountid like ?");
				_linkList.add("%" + userid.trim() + "%");
			}

			if (name != null && !name.equals("")) {
				sql.append(" and t.name like ?");
				_linkList.add("%" + name.trim() + "%");
			}

			if (email != null && !email.equals("")) {
				sql.append(" and t.email like ?");
				_linkList.add("%" + email.trim() + "%");
			}
			
			if (ordernbr != null && !ordernbr.equals("")) {
				sql.append(" and t.userid in(");
				sql.append("select userid from tf_andcustrela a ");
				sql.append("where a.state='E' and a.phonenum like ?)");
				_linkList.add("%" + ordernbr.trim() + "%");
			}

			// "A","N","L","D" >>>> "激活","待激活", "过期","注销"
			if (userState != null) {

				if (userState.equals("A")) {
					sql.append(" and t.state='E' and t.userstate='A'");
				} else if (userState.equals("N")) {
					sql.append(" and t.state='E' and t.userstate='N'");
				} else if (userState.equals("L")) {
					sql.append(" and t.state='D' and t.userstate='L'");
				} else if (userState.equals("D")) {
					sql.append(" and t.state='D' and t.userstate not in('L')");
				}
			}

			// 开始时间
			if (starttime != null && !starttime.equals("")) {
				sql.append(" and t.createtime >= to_date(?,'YYYY-MM-DD HH24:MI:SS')");
				_linkList.add(starttime);
			}
			// 结束时间
			if (endtime != null && !endtime.equals("")) {
				sql.append(" and t.createtime <= to_date(?,'YYYY-MM-DD HH24:MI:SS')");
				_linkList.add(endtime);
			}

			if(userState != null && userState.equals("A")){
				sql.append(" order by t.createtime DESC");
			}else{
			    sql.append(" order by t.createtime asc");
			}
			
			return executePageList(startrecord, endrecord, sql.toString(),
					_linkList.toArray());

		} catch (java.sql.SQLException sqlx) {
			throw sqlx;
		} catch (RuntimeException rux) {
			_logger.warn(rux.getMessage(), rux);
			throw rux;
		}
	}

	private static DataTable executePageList(int start, int end, String sql,
			Object[] _param) throws java.sql.SQLException {
		StringBuffer _sb = new StringBuffer();
		_sb.append("SELECT * FROM ( SELECT row_.*, rownum rownum_ FROM(");
		_sb.append(sql);
		_sb.append(")row_ WHERE rownum <=");
		_sb.append(end);
		_sb.append(") WHERE rownum_ >");
		_sb.append(start);

		// System.out.println("分页内容： \n"+_sb.toString());
		if (_param == null || _param.length == 0) {
			return _dac.executeQuery(_sb.toString());
		} else {
			return _dac.executeQuery(_sb.toString(), _param);
		}
	}

	/**
	 * <code>查询过期账号</code>
	 * 
	 * @param _map
	 */
	public static DataTable selectOverDueAccount(java.util.Map _map)
			throws java.sql.SQLException {
		try {
			String userid = (String) _map.get("USERID");// 客户账号
			String name = (String) _map.get("NAME");// 客户名称
			String email = (String) _map.get("EMAIL");// email
			String areaCode = (String) _map.get("AREA");// 地域编码
			String cityCode = (String) _map.get("CITY");// 地市编码
			String starttime = (String) _map.get("STARTTIME");// 开始时间
			String endtime = (String) _map.get("ENDTIME");// 结束时间

			StringBuffer sql = new StringBuffer();
			LinkedList _linkList = new LinkedList();

			sql.append("SELECT ACCOUNTID,PWD,EMAIL FROM tf_custinfoweb t ");
			sql.append("WHERE t.state='D' AND t.custtypeid='2' AND t.userstate='L'");

			if (cityCode != null && !cityCode.equals("")
					&& !cityCode.equals("0590")) {
				sql.append(" and t.citycode=?");
				_linkList.add(cityCode);
				// 地区
				if (areaCode != null && !areaCode.equals("")) {
					sql.append(" and decode(t.areacode,null,t.citycode||'00',t.areacode)=?");
					_linkList.add(areaCode);
				}
			}

			if (userid != null && !userid.equals("")) {
				sql.append(" and t.accountid like ?");
				_linkList.add("%" + userid.trim() + "%");