chanmail.java

电信的网厅的整站代码

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

import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

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

public class ChanMail {
	protected static DacClient _dac = null;
	static {
		try {
			_dac = new DacClient();
		} catch (Exception rux) {
			FileLogger.getLogger().warn("连接数据库异常！");
		}
	}
	/**
	 * 
	 * @param userid
	 * @param email
	 * @return -1:异常，0：新邮箱不同于旧邮箱，1：查到和旧的邮箱一样的记录，但是已经激活，2：查到和旧的邮箱一样的记录，而且未激活
	 */
	public static String queryemail(String userid,String email){
		try {
			if(userid==null || userid.equals("")){
				return "-1";
			}
			if(email==null || email.equals("")){
				return "-1";
			}	
			StringBuffer _sql = new StringBuffer();
			_sql.append("select * from tf_custinfoweb t");
			_sql.append(" where t.userid=?");
			
			List _oParam = new ArrayList();
			if (!ExtString.isEmpty(userid)) {
				_oParam.add(userid);
			}			
			Object _ap[] = new Object[_oParam.size()];
			for (int i = 0; i < _ap.length; i++) {
				_ap[i] = _oParam.get(i);
			}
			DataTable dttmp = _dac.executeQuery(_sql.toString(), _ap);
			if(dttmp!=null){
				if(dttmp.getRows().getCount()>0){
					String oldemail = "";
					String olduserstate = "";
					for(int i=0;i<dttmp.getRows().getCount();i++){
						DataRow dr=dttmp.getRow(i);
						oldemail = dr.getString("email");
						olduserstate = dr.getString("userstate");
					}
					if(oldemail!=null && !oldemail.equals("") && oldemail.equals(email)){
						if(olduserstate!=null && olduserstate.equals("N")){
							return "2";
						}else{
							return "1";
						}
					}else{
						return "0";
					}
				}
			}
		}catch(Exception e){
			FileLogger.getLogger().info("queryemail异常：",e);
		}
		return "-1";
	}
	public static boolean checkmailchan(String userid,String email){
		try {
			if(userid==null || userid.equals("")){
				return false;
			}
			if(email==null || email.equals("")){
				return false;
			}	
			
			StringBuffer sql = new StringBuffer();
			sql.append("update tf_custinfoweb t");
			sql.append(" set t.email=? ");
			//sql.append(" ,t.userstate='N'");
			sql.append(" where t.userid=?");
			
			List oParam = new ArrayList();
			if (!ExtString.isEmpty(email)) {
				oParam.add(email);
			}	
			if (!ExtString.isEmpty(userid)) {
				oParam.add(userid);
			}			
			Object ap[] = new Object[oParam.size()];
			for (int i = 0; i < ap.length; i++) {
				ap[i] = oParam.get(i);
			}	
			int tmp = _dac.executeUpdate(sql.toString(),1000, ap);

			if(tmp>0){
				return true;
			}else{
				return false;
			}
		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			FileLogger.getLogger().info("checkmailchan异常：",e);
		}
		return false;
	}
}