userinfo.java

java阿里巴巴代码

package com.saas.biz.userMgr;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.Map;

import net.sf.json.JSONArray;
import net.sf.json.JSONObject;

import com.saas.biz.commen.commMethodMgr;
import com.saas.biz.dao.userDAO.UserDAO;
import com.saas.biz.dao.userDAO.UserExt;
import com.saas.biz.dao.userdetailDAO.UserdetailExt;
import com.saas.sys.buffer.Buffers;
import com.saas.sys.dbm.Dbtable;
import com.saas.sys.exp.SaasApplicationException;
import com.saas.sys.log.Logger;

public class UserInfo {

	Logger log;

	Buffers inBuffer;

	Buffers outBuffer;

	Dbtable tradeQuery;

	commMethodMgr commen;

	ArrayList queryResult = new ArrayList();

	public UserInfo() {

		log = new Logger(this);
		tradeQuery = new Dbtable();
		commen = new commMethodMgr();
	}

	public void setOutBuffer(Buffers outBuffer) {

		this.outBuffer = outBuffer;
	}

	public Buffers getOutBuffer() {

		return this.outBuffer;
	}

	public void setTradeQuery(Dbtable tradeQuery) {

		this.tradeQuery = tradeQuery;
	}

	public Dbtable getTradeQuery() {

		return this.tradeQuery;
	}

	public ArrayList getQueryResult() {

		return this.queryResult;
	}

	public void setQueryResult(ArrayList queryResult) {

		this.queryResult = queryResult;
	}

	/*
	 * 添加用户
	 */
	public void addUserInfo(Buffers inbuffer) {

		this.outBuffer = inbuffer;
		this.inBuffer = inbuffer;
		log.LOG_INFO("进入addUserInfo方法...");
		int iResult = -1;
		try {
			UserDAO userDao = new UserDAO();
			userDao.setPasswd(inbuffer.getString("PASSWD"));
			userDao.setCust_id(inbuffer.getString("SESSION_CUST_ID"));
			userDao.setStaff_id(inbuffer.getString("SESSION_USER_ID"));
			userDao.setEparchy_code(inbuffer.getString("EPARCHY_CODE"));
			userDao.setCity_code(inbuffer.getString("CITY_CODE"));
			userDao.setDepart_code(inbuffer.getString("DEPART_CODE"));
			userDao.setPasswd_ques(inbuffer.getString("PASSWD_QUES"));
			userDao.setPasswd_answer(inbuffer.getString("PASSWD_ANSWER"));
			userDao.setWeb_login_tag(inbuffer.getString("WEB_LOGIN_TAG"));
			userDao.setDepart_code(inbuffer.getString("DEPART_CODE"));
			userDao.setUser_id(inbuffer.getString("USER_ID"));
			userDao.setUser_name(inbuffer.getString("USER_NAME"));
			iResult = addUserInfo(userDao);
		} catch (SaasApplicationException e) {
			log.LOG_INFO(e.getMessage());
		}
		if (iResult != 0) {
			this.outBuffer.setInt("RESULT_CODE", -1);
			this.outBuffer.setString("RESULT_INFO", "新增用户业务处理失败！");

		} else {
			this.outBuffer.setInt("RESULT_CODE", 0);
			this.outBuffer.setString("RESULT_INFO", "新增用户业务处理成功！");
		}
		log.LOG_INFO("退出addUserInfo方法...");
	}

	public int addUserInfo(UserDAO userDao) throws SaasApplicationException {

		UserExt userExt = new UserExt();
		userExt.setParam(":VPASSWD", userDao.getPasswd());
		userExt.setParam(":VCUST_ID", userDao.getCust_id());
		userExt.setParam(":VEPARCHY_CODE", userDao.getEparchy_code());
		userExt.setParam(":VCITY_CODE", userDao.getCity_code());
		userExt.setParam(":VDEPART_CODE", userDao.getDepart_code());
		userExt.setParam(":VPASSWD_QUES", userDao.getPasswd_ques());
		userExt.setParam(":VPASSWD_ANSWER", userDao.getPasswd_answer());
		userExt.setParam(":VWEB_LOGIN_TAG", userDao.getWeb_login_tag());
		userExt.setParam(":VDEPART_CODE", userDao.getDepart_code());
		userExt.setParam(":VUSER_ID", userDao.getUser_id());
		userExt.setParam(":VUSER_STATE", "0");
		userExt.setParam(":VSTAFF_ID", userDao.getStaff_id());
		userExt.setParam(":VUSER_NAME", userDao.getUser_name());
		tradeQuery.executeBy(userExt.insBy("INS_BY_ALL"));
		this.outBuffer.setString("USER_ID", userDao.getUser_id());
		this.outBuffer.setString("USER_NAME", userDao.getUser_name());
		log.LOG_INFO(" addUserInfo successful !");
		return 0;
	}

	public void addNewUserInfo(Buffers inbuffer) {

		this.outBuffer = inbuffer;
		this.inBuffer = inbuffer;
		log.LOG_INFO("进入addNewUserInfo方法...");
		int iResult = -1;
		try {
			UserDAO userDao = new UserDAO();
			userDao.setPasswd(inbuffer.getString("PASSWD"));
			userDao.setCust_id(inbuffer.getString("SESSION_CUST_ID"));
			userDao.setStaff_id(inbuffer.getString("SESSION_USER_ID"));
			userDao.setEparchy_code(inbuffer.getString("EPARCHY_CODE"));
			userDao.setCity_code(inbuffer.getString("CITY_CODE"));
			userDao.setDepart_code(inbuffer.getString("ORG_DEPART_CODE"));
			userDao.setPasswd_ques(inbuffer.getString("PASSWD_QUES"));
			userDao.setPasswd_answer(inbuffer.getString("PASSWD_ANSWER"));
			userDao.setWeb_login_tag(inbuffer.getString("WEB_LOGIN_TAG"));
			userDao.setUser_id(inbuffer.getString("USER_ID"));
			userDao.setUser_name(inbuffer.getString("USER_NAME"));
			userDao.setRsrv_str3(inbuffer.getString("ROLE_CODE"));
			iResult = addNewUserInfo(userDao);
		} catch (SaasApplicationException e) {
			log.LOG_INFO(e.getMessage());
		}
		if (iResult != 0) {
			this.outBuffer.setInt("RESULT_CODE", -1);
			this.outBuffer.setString("RESULT_INFO", "新增用户业务处理失败！");

		} else {
			this.outBuffer.setInt("RESULT_CODE", 0);
			this.outBuffer.setString("RESULT_INFO", "新增用户业务处理成功！");
		}
		log.LOG_INFO("退出addNewUserInfo方法...");
	}

	public int addNewUserInfo(UserDAO userDao) throws SaasApplicationException {

		UserExt userExt = new UserExt();
		userExt.setParam(":VPASSWD", userDao.getPasswd());
		userExt.setParam(":VCUST_ID", userDao.getCust_id());
		userExt.setParam(":VEPARCHY_CODE", userDao.getEparchy_code());
		userExt.setParam(":VCITY_CODE", userDao.getCity_code());
		userExt.setParam(":VPASSWD_QUES", userDao.getPasswd_ques());
		userExt.setParam(":VPASSWD_ANSWER", userDao.getPasswd_answer());
		userExt.setParam(":VWEB_LOGIN_TAG", userDao.getWeb_login_tag());
		userExt.setParam(":VDEPART_CODE", userDao.getDepart_code());
		userExt.setParam(":VUSER_ID", userDao.getUser_id());
		userExt.setParam(":VUSER_STATE", "0");
		userExt.setParam(":VSTAFF_ID", userDao.getStaff_id());
		userExt.setParam(":VUSER_NAME", userDao.getUser_name());
		userExt.setParam(":VRSRV_STR3", userDao.getRsrv_str3());
		tradeQuery.executeBy(userExt.insBy("INS_BY_ALL"));
		this.outBuffer.setString("USER_ID", userDao.getUser_id());
		this.outBuffer.setString("USER_NAME", userDao.getUser_name());
		log.LOG_INFO(" addUserInfo successful !");
		return 0;
	}

	// 获取会员信息列表
	public void genUserInfo(Buffers inbuffer) {

		log.LOG_INFO("进入getCustInfo方法...");
		this.outBuffer = inbuffer;
		String query_param = inbuffer.getString("QUERY_PARAM");
		try {
			log.LOG_INFO("query_param.............." + query_param);
			if (query_param.equals(""))
				this.queryResult = genUserInfo();
			else
				this.queryResult = searchUser(query_param);

		} catch (SaasApplicationException e) {
			log.LOG_INFO(e.getMessage());

		}
		log.LOG_INFO("退出getCustInfo方法...");
	}

	public ArrayList genUserInfo() throws SaasApplicationException {

		ArrayList userList = new ArrayList();
		ArrayList itemsList = new ArrayList();
		UserExt userExt = new UserExt();
		userList = userExt.selByList("SEL_BY_ALL");
		return userList;
	}

	// 查询未注销会员信息
	public void genNoFreeUserInfo(Buffers inbuffer) {

		log.LOG_INFO("进入genNoFreeUserInfo方法...");
		this.outBuffer = inbuffer;
		String query_param = inbuffer.getString("QUERY_PARAM");
		try {
			log.LOG_INFO("query_param.............." + query_param);
			if (query_param.equals(""))
				this.queryResult = genNoFreeUserInfo();
			else
				this.queryResult = searchUser(query_param);

		} catch (SaasApplicationException e) {
			log.LOG_INFO(e.getMessage());

		}
		log.LOG_INFO("退出getCustInfo方法...");
	}

	public ArrayList genNoFreeUserInfo() throws SaasApplicationException {

		ArrayList userList = new ArrayList();
		ArrayList itemsList = new ArrayList();
		UserExt userExt = new UserExt();
		userExt.setParam(":VUSER_STATE", "0");
		userList = userExt.selByList("SEL_BY_NOFREE");
		return userList;
	}

	// 获取单个会员信息
	public void genOneUserInfo(Buffers inbuffer) {

		log.LOG_INFO("进入genOneUserInfo方法...");
		this.outBuffer = inbuffer;
		String user_id = inbuffer.getString("USER_ID");
		try {
			this.queryResult = genOneUserInfo(user_id);
		} catch (SaasApplicationException e) {
			log.LOG_INFO(e.getMessage());

		}
		log.LOG_INFO("退出genOneUserInfo方法...");
	}

	public ArrayList genOneUserInfo(String strUserId) throws SaasApplicationException {

		ArrayList userList = new ArrayList();
		UserExt userExt = new UserExt();
		userExt.setParam(":VUSER_ID", strUserId);
		userList = userExt.selByList("SEL_BY_ONE");
		return userList;
	}

	// 修改会员信息
	public void updateOneUserInfo(Buffers inbuffer) {

		log.LOG_INFO("进入updateOneUserInfo方法...");
		this.outBuffer = inbuffer;
		int iResult = -1;
		try {
			UserDAO userDao = new UserDAO();
			userDao.setPasswd(inbuffer.getString("PASSWD"));
			userDao.setEparchy_code(inbuffer.getString("EPARCHY_CODE"));
			userDao.setCity_code(inbuffer.getString("CITY_CODE"));
			userDao.setDepart_code(inbuffer.getString("ORG_DEPART_CODE"));
			userDao.setPasswd_ques(inbuffer.getString("PASSWD_QUES"));
			userDao.setPasswd_answer(inbuffer.getString("PASSWD_ANSWER"));
			userDao.setWeb_login_tag(inbuffer.getString("WEB_LOGIN_TAG"));
			userDao.setUser_id(inbuffer.getString("USER_ID"));

			iResult = updateOneUserInfo(userDao);
		} catch (SaasApplicationException e) {
			log.LOG_INFO(e.getMessage());
		}
		if (iResult != 0) {
			this.outBuffer.setInt("RESULT_CODE", -1);
			this.outBuffer.setString("RESULT_INFO", "业务处理失败！");
		} else {
			this.outBuffer.setInt("RESULT_CODE", 0);
			this.outBuffer.setString("RESULT_INFO", "业务处理成功！");
		}
	}

	public int updateOneUserInfo(UserDAO userDao) throws SaasApplicationException {

		commMethodMgr comm = new commMethodMgr();
		UserExt UserExt = new UserExt();
		UserExt.setParam(":VUSER_ID", userDao.getUser_id());
		UserExt.setParam(":VPASSWD", userDao.getPasswd());
		UserExt.setParam(":VEPARCHY_CODE", userDao.getEparchy_code());
		UserExt.setParam(":VCITY_CODE", userDao.getCity_code());
		UserExt.setParam(":VDEPART_CODE", userDao.getDepart_code());
		UserExt.setParam(":VPASSWD_QUES", userDao.getPasswd_ques());
		UserExt.setParam(":VPASSWD_ANSWER", userDao.getPasswd_answer());
		UserExt.setParam(":VWEB_LOGIN_TAG", userDao.getWeb_login_tag());
		tradeQuery.executeBy(UserExt.insBy("UPDATE_BY_ONE"));
		return 0;
	}

	// 会员状态设置(0 正常 1 冻结 2 注销)
	public void invalidOneUserInfo(Buffers inbuffer) {

		log.LOG_INFO("进入updateOneUserInfo方法...");
		this.outBuffer = inbuffer;
		int iResult = -1;
		String user_id = inbuffer.getString("USER_ID");
		String user_state = inbuffer.getString("user_state");
		try {
			iResult = invaildOneUserInfo(user_id, user_state);
		} catch (SaasApplicationException e) {
			log.LOG_INFO(e.getMessage());
		}
		if (iResult != 0) {
			this.outBuffer.setInt("RESULT_CODE", -1);
			this.outBuffer.setString("RESULT_INFO", "业务处理失败！");
		} else {
			this.outBuffer.setInt("RESULT_CODE", 0);
			this.outBuffer.setString("RESULT_INFO", "业务处理成功！");
		}
	}

	public int invaildOneUserInfo(String user_id, String user_state) throws SaasApplicationException {

		UserExt UserExt = new UserExt();
		UserExt.setParam(":VUSER_ID", user_id);
		UserExt.setParam(":VUSER_STATE", user_state);
		tradeQuery.executeBy(UserExt.insBy("INVALID_BY_ONE"));
		return 0;
	}

	public ArrayList searchUser(String user_name) throws SaasApplicationException {

		ArrayList itemsList = new ArrayList();
		UserExt UserExt = new UserExt();
		UserExt.setParam(":VUSER_NAME", "%" + user_name + "%");
		itemsList = UserExt.selByList("SEL_BY_SEARCH");
		return itemsList;
	}

	// 通过cust_id获取用户列表(超级管理员)
	public void getUserinfoByCust_id(Buffers inbuffer) {

		log.LOG_INFO("进入getUserinfoByCust_id方法...");
		this.outBuffer = inbuffer;
		String cust_id = inbuffer.getString("SESSION_CUST_ID");
		String cust_name = inbuffer.getString("SESSION_USER_NAME");
		try {
			if (cust_name == "admin" || cust_name.equals("admin")) {
				this.queryResult = genUserInfo();
			} else {
				this.queryResult = getUserinfoByCust_id(cust_id);
			}
		} catch (SaasApplicationException e) {
			log.LOG_INFO(e.getMessage());

		}
		log.LOG_INFO("退出getUserinfoByCust_id方法...");
	}

	public ArrayList getUserinfoByCust_id(String cust_id) throws SaasApplicationException {

		ArrayList itemsList = new ArrayList();
		UserExt UserExt = new UserExt();
		UserExt.setParam(":VCUST_ID", cust_id);
		UserExt.setParam(":VUSER_STATE", "0");
		itemsList = UserExt.selByList("SEL_BY_CUST_ID");