prochangeuinfo.java

java阿里巴巴代码

package com.saas.biz.propertyuMgr;

import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;

import com.saas.biz.commen.ParamethodMgr;
import com.saas.biz.commen.commMethodMgr;
import com.saas.biz.dao.prochangeuDAO.ProchangeuDAO;
import com.saas.biz.dao.prochangeuDAO.ProchangeuExt;
import com.saas.sys.buffer.Buffers;
import com.saas.sys.dbm.Dbtable;
import com.saas.sys.exp.SaasApplicationException;
import com.saas.sys.log.Logger;

/**
 * 会员财产异动记录表
 * 
 * @author Liuy
 */
public class ProchangeuInfo {
	
	
	Logger log;
	
	
	Buffers inBuffer;
	
	
	Buffers outBuffer;
	
	
	Dbtable tradeQuery;
	
	
	commMethodMgr comm;
	
	
	ParamethodMgr param;
	
	
	ArrayList queryResult = new ArrayList();
	
	
	
	public ProchangeuInfo() {

		log = new Logger(this);
		comm = new commMethodMgr();
		outBuffer = new Buffers();
		tradeQuery = new Dbtable();
		param = new ParamethodMgr();
	}
	
	
	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;
	}
	
	
	
	/**
	 * 初始化生财产异动信息
	 * 
	 * @param inbuffer
	 */
	public void addDefaultProchange(Buffers inbuffer) {

		log.LOG_INFO("进入addDefaultProchange方法...");
		this.outBuffer = inbuffer;
		this.inBuffer = inbuffer;
		int iResult = -1;
		String user_id = inbuffer.getString("USER_ID");
		String property_type = inbuffer.getString("PROPERTY_TYPE");
		String property_value = inbuffer.getString("PROPERTY_VALUE");
		String change_value = inbuffer.getString("PROPERTY_VALUE");
		String change_date = comm.GenSysdate("1");
		String old_value = "0";
		String change_reason = "";
		String change_user_id = "system";// 新会员注册时，默认为系统管理员
		String oper_date = change_date;
		String rsrv_str1 = "";
		String rsrv_str2 = "";
		String rsrv_str3 = "";
		String rsrv_str7 = "";
		String rsrv_str8 = "";
		String rsrv_str9 = "";
		String rsrv_str10 = "";
		String remark = inbuffer.getString("REMARK");
		try {
			ProchangeuDAO prochangeuDAO = new ProchangeuDAO();
			prochangeuDAO.setUser_id(user_id);
			prochangeuDAO.setProperty_type(property_type);
			prochangeuDAO.setProperty_value(property_value);
			prochangeuDAO.setChange_date(change_date);
			prochangeuDAO.setChange_value(change_value);
			prochangeuDAO.setRemark(remark);
			prochangeuDAO.setOld_value(old_value);
			prochangeuDAO.setChange_reason(change_reason);
			prochangeuDAO.setRsrv_str10(rsrv_str10);
			prochangeuDAO.setChange_user_id(change_user_id);
			prochangeuDAO.setOper_date(oper_date);
			prochangeuDAO.setRsrv_str1(rsrv_str1);
			prochangeuDAO.setRsrv_str2(rsrv_str2);
			prochangeuDAO.setRsrv_str3(rsrv_str3);
			prochangeuDAO.setRsrv_str7(rsrv_str7);
			prochangeuDAO.setRsrv_str8(rsrv_str8);
			prochangeuDAO.setRsrv_str9(rsrv_str9);
			iResult = addDefaultProchange(prochangeuDAO);
		}
		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("退出addDefaultProchange方法...");
	}
	
	
	
	// 财产异动修改
	public int addDefaultProchange(ProchangeuDAO prochangeuDAO) throws SaasApplicationException {

		ProchangeuExt prochangeuext = new ProchangeuExt();
		prochangeuext.setParam(":VUSER_ID", prochangeuDAO.getUser_id());
		prochangeuext.setParam(":VPROPERTY_TYPE", prochangeuDAO.getProperty_type());
		prochangeuext.setParam(":VPROPERTY_VALUE", prochangeuDAO.getProperty_value());
		prochangeuext.setParam(":VCHANGE_DATE", prochangeuDAO.getChange_date());
		prochangeuext.setParam(":VCHANGE_VALUE", prochangeuDAO.getChange_value());
		prochangeuext.setParam(":VREMARK", prochangeuDAO.getRemark());
		prochangeuext.setParam(":VOLD_VALUE", prochangeuDAO.getOld_value());
		prochangeuext.setParam(":VCHANGE_REASON", prochangeuDAO.getChange_reason());
		prochangeuext.setParam(":VRSRV_STR10", prochangeuDAO.getRsrv_str10());
		prochangeuext.setParam(":VCHANGE_USER_ID", prochangeuDAO.getChange_user_id());
		prochangeuext.setParam(":VOPER_DATE", prochangeuDAO.getOper_date());
		prochangeuext.setParam(":VRSRV_STR1", prochangeuDAO.getRsrv_str1());
		prochangeuext.setParam(":VRSRV_STR2", prochangeuDAO.getRsrv_str2());
		prochangeuext.setParam(":VRSRV_STR3", prochangeuDAO.getRsrv_str3());
		prochangeuext.setParam(":VRSRV_STR7", prochangeuDAO.getRsrv_str7());
		prochangeuext.setParam(":VRSRV_STR8", prochangeuDAO.getRsrv_str8());
		prochangeuext.setParam(":VRSRV_STR9", prochangeuDAO.getRsrv_str9());
		tradeQuery.executeBy(prochangeuext.insBy("INS_BY_ALL"));
		return 0;
	}
	
	
	
	/**
	 * 修改会员财产 @ property_value=change_value+old_value
	 * @会员登录时赠送黄金
	 * @param inbuffer
	 * @throws SaasApplicationException
	 */
	public void updateProchange(Buffers inbuffer) throws SaasApplicationException {

		log.LOG_INFO("进入updateProchange方法...");
		this.outBuffer = inbuffer;
		this.inBuffer = inbuffer;
		int iResult = -1;
		String login = inbuffer.getString("LOGIN");// 如果会员已登录过
		try {
			if (login == "0" || login.equals("0")) {
				String user_id = inbuffer.getString("SESSION_USER_ID");
				String property_type = inbuffer.getString("PROPERTY_TYPE");
				String property_value = inbuffer.getString("PROPERTY_VALUE");
				String change_value = inbuffer.getString("PROPERTY_VALUE");
				String change_date = comm.GenSysdate("1");
				String old_value = "0";
				HashMap map = getUserOldProperty(user_id, property_type);
				if (map.get("property_value") != null) {
					old_value = map.get("property_value").toString();
				}
				String change_reason = "6";
				String change_user_id = "loading";
				String oper_date = change_date;
				String rsrv_str1 = "";
				String rsrv_str2 = "";
				String rsrv_str3 = "";
				String rsrv_str7 = "";
				String rsrv_str8 = "";
				String rsrv_str9 = "";
				String rsrv_str10 = "";
				String remark = inbuffer.getString("REMARK");
				ProchangeuDAO prochangeuDAO = new ProchangeuDAO();
				prochangeuDAO.setUser_id(user_id);
				prochangeuDAO.setProperty_type(property_type);
				prochangeuDAO.setProperty_value(property_value);
				prochangeuDAO.setChange_date(change_date);
				prochangeuDAO.setChange_value(change_value);
				prochangeuDAO.setRemark(remark);
				prochangeuDAO.setOld_value(old_value);
				prochangeuDAO.setChange_reason(change_reason);
				prochangeuDAO.setRsrv_str10(rsrv_str10);
				prochangeuDAO.setChange_user_id(change_user_id);
				prochangeuDAO.setOper_date(oper_date);
				prochangeuDAO.setRsrv_str1(rsrv_str1);
				prochangeuDAO.setRsrv_str2(rsrv_str2);
				prochangeuDAO.setRsrv_str3(rsrv_str3);
				prochangeuDAO.setRsrv_str7(rsrv_str7);
				prochangeuDAO.setRsrv_str8(rsrv_str8);
				prochangeuDAO.setRsrv_str9(rsrv_str9);
				iResult = addDefaultProchange(prochangeuDAO);
			}
			else {
				iResult = 0;
			}
		}
		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("退出addDefaultProchange方法...");
	}
	
	
	
	/**
	 * 发布信息时增加会员财富
	 * 
	 * @param inbuffer
	 * @throws SaasApplicationException
	 */
	public void updateProchangeByPublish(Buffers inbuffer) throws SaasApplicationException {

		log.LOG_INFO("进入updateProchangeByPublish方法...");
		this.outBuffer = inbuffer;
		this.inBuffer = inbuffer;
		int iResult = -1;
		String info_type = inbuffer.getString("INFO_TYPE");
		String info_state = inbuffer.getString("INFO_STATE");
		try {
			boolean audit = new PropertyuInfo().getValidityInfo("106", info_type);
			if (audit) {
				if (info_state == "1" || info_state.equals("1")) {
					String user_id = inbuffer.getString("PUBLISH_USER_ID");
					String property_type = inbuffer.getString("PROPERTY_TYPE");
					String property_value = inbuffer.getString("PROPERTY_VALUE");
					String change_value = inbuffer.getString("PROPERTY_VALUE");
					String change_date = comm.GenSysdate("1");
					String old_value = "0";
					HashMap map = getUserOldProperty(user_id, property_type);
					if (map.get("property_value") != null) {
						old_value = map.get("property_value").toString();
					}
					String change_reason = "1";
					String change_user_id = "validity";
					String oper_date = change_date;
					String rsrv_str1 = "";
					String rsrv_str2 = "";
					String rsrv_str3 = "";
					String rsrv_str7 = "";
					String rsrv_str8 = "";
					String rsrv_str9 = "";
					String rsrv_str10 = "";
					String remark = inbuffer.getString("REMARK");
					ProchangeuDAO prochangeuDAO = new ProchangeuDAO();
					prochangeuDAO.setUser_id(user_id);
					prochangeuDAO.setProperty_type(property_type);
					prochangeuDAO.setProperty_value(property_value);
					prochangeuDAO.setChange_date(change_date);
					prochangeuDAO.setChange_value(change_value);
					prochangeuDAO.setRemark(remark);
					prochangeuDAO.setOld_value(old_value);
					prochangeuDAO.setChange_reason(change_reason);
					prochangeuDAO.setRsrv_str10(rsrv_str10);
					prochangeuDAO.setChange_user_id(change_user_id);
					prochangeuDAO.setOper_date(oper_date);
					prochangeuDAO.setRsrv_str1(rsrv_str1);
					prochangeuDAO.setRsrv_str2(rsrv_str2);
					prochangeuDAO.setRsrv_str3(rsrv_str3);
					prochangeuDAO.setRsrv_str7(rsrv_str7);
					prochangeuDAO.setRsrv_str8(rsrv_str8);
					prochangeuDAO.setRsrv_str9(rsrv_str9);
					iResult = addDefaultProchange(prochangeuDAO);
				}
				else {
					iResult = 0;
				}
			}
			else {
				iResult = 0;
			}
		}
		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("退出updateProchangeByPublish方法...");
	}
	
	
	
	/**
	 * 赠送黄金 change_reason:会员是否登录
	 * 
	 * @判断用户是否是第一次登录
	 */
	public void checkUserLoading(Buffers inbuffer) {

		log.LOG_INFO("进入checkUserLoading方法...");
		this.outBuffer = inbuffer;
		this.inBuffer = inbuffer;
		int iResult = -1;
		String user_id = inbuffer.getString("SESSION_USER_ID");
		String change_reason = "6";
		try {
			iResult = checkUserLoading(user_id, change_reason);
		}
		catch (Exception 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("退出checkUserLoading方法...");
	}
	
	
	public int checkUserLoading(String user_id, String change_reason) throws SaasApplicationException {

		ProchangeuExt prochangeuext = new ProchangeuExt();
		prochangeuext.setParam(":VUSER_ID", user_id);
		prochangeuext.setParam(":VOPER_DATE", new SimpleDateFormat("yyyy-MM-dd").format(new Date()));
		prochangeuext.setParam(":VCHANGE_REASON", change_reason);
		ArrayList list = prochangeuext.selByList("SEL_BY_DATE");
		if (list != null && list.size() > 0) {
			this.outBuffer.setString("LOGIN", "1");
		}
		else {
			this.outBuffer.setString("LOGIN", "0");
		}
		return 0;
	}
	
	
	
	/**
	 * @param user_id
	 * @param property_type
	 * @return 取出会员上次财产
	 * @throws SaasApplicationException
	 */
	public HashMap getUserOldProperty(String user_id, String property_type) throws SaasApplicationException {

		HashMap map = new HashMap();
		ProchangeuExt prochangeuext = new ProchangeuExt();
		prochangeuext.setParam(":VUSER_ID", user_id);
		prochangeuext.setParam(":VPROPERTY_TYPE", property_type);
		ArrayList list = prochangeuext.selByList("SEL_BY_MAX");
		if (list != null && list.size() > 0) {
			map = (HashMap) list.get(0);
		}
		return map;
	}
}