actionmgr.java

java阿里巴巴代码

package com.saas.biz.actionMgr;

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

import com.saas.biz.dao.actionDAO.ActionInfoDAO;
import com.saas.biz.dao.actionDAO.ActionInfoExt;
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 ActionMgr{
	Logger log;

	Buffers inBuffer;

	Buffers outBuffer;

	Dbtable tradeQuery;

	ArrayList queryResult = new ArrayList();

	public ActionMgr() {
		log = new Logger(this);
		tradeQuery = new Dbtable();
		outBuffer = new Buffers();
	}

	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 addActionInfo(Buffers inbuffer) {
		log.LOG_INFO("进入addActionInfo方法...");
		this.outBuffer = inbuffer;
		this.inBuffer = inbuffer;
		int iResult = -1;
		String cust_id = inbuffer.getString("SESSION_CUST_ID");
		String own_id = inbuffer.getString("OWN_ID");
		String entity_type = inbuffer.getString("ENTITY_TYPE");
		String entity_id = inbuffer.getString("ENTITY_ID");
		String subject_tag = inbuffer.getString("SUBJECT_TAG");
		String up_info_id = inbuffer.getString("UP_INFO_ID");
		String rela_id = inbuffer.getString("RELA_ID");
		String publish_user_id = inbuffer.getString("SESSION_USER_ID");
		String attach_path = inbuffer.getString("ATTACH_PATH");
		String title = inbuffer.getString("TITLE");
		String content = inbuffer.getString("CONTENT");
		String info_date = inbuffer.getString("INFO_DATE");
		String info_state = inbuffer.getString("INFO_STATE");
		String remark = inbuffer.getString("REMARK");
		String rsrv_str10 = inbuffer.getString("RSRV_STR10");
		try {
			ActionInfoDAO actionDao = new ActionInfoDAO();
			actionDao.setOwn_id(own_id);
			actionDao.setCust_id(cust_id);
			actionDao.setEntity_type(entity_type);
			actionDao.setEntity_id(entity_id);
			actionDao.setSubject_tag(subject_tag);
			actionDao.setRela_id(rela_id);
			actionDao.setUp_info_id(up_info_id);
			actionDao.setAttach_path(attach_path);
			actionDao.setPublish_user_id(publish_user_id);
			actionDao.setTitle(title);
			actionDao.setContent(content);
			actionDao.setInfo_date(info_date);
			actionDao.setInfo_state(info_state);
			actionDao.setRemark(remark);
			actionDao.setRsrv_str10(rsrv_str10);
			iResult = addActionInfo(actionDao);
		}
		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("退出addActionInfo方法...");
	}

	public int addActionInfo(ActionInfoDAO actionDao) throws SaasApplicationException {
		ActionInfoExt actionExt = new ActionInfoExt();
		actionExt.setParam(":VOWN_ID", actionDao.getOwn_id());
		actionExt.setParam(":VCUST_ID", actionDao.getCust_id());
		actionExt.setParam(":VENTITY_TYPE", actionDao.getEntity_type());
		actionExt.setParam(":VENTITY_ID", actionDao.getEntity_id());
		actionExt.setParam(":VSUBJECT_TAG", actionDao.getSubject_tag());
		actionExt.setParam(":VRELA_ID", actionDao.getRela_id());
		actionExt.setParam(":VUP_INFO_ID", actionDao.getUp_info_id());
		actionExt.setParam(":VATTACH_PATH", actionDao.getAttach_path());
		actionExt.setParam(":VPUBLISH_USER_ID", actionDao.getPublish_user_id());
		actionExt.setParam(":VTITLE", actionDao.getTitle());
		actionExt.setParam(":VCONTENT", actionDao.getContent());
		actionExt.setParam(":VINFO_DATE", actionDao.getInfo_date());
		actionExt.setParam(":VINFO_STATE", actionDao.getInfo_state());
		actionExt.setParam(":VREMARK", actionDao.getRemark());
		actionExt.setParam(":VRSRV_STR10", actionDao.getRsrv_str10());
		tradeQuery.executeBy(actionExt.insBy("INS_BY_ALL"));
		return 0;
	}
    
	//修改动态
	public void updateActionInfo(Buffers inbuffer){
		log.LOG_INFO("进入updateActionInfo方法...");
		this.outBuffer = inbuffer;
		this.inBuffer = inbuffer;
		int iResult = -1;
		try {
			String cust_id = inbuffer.getString("SESSION_CUST_ID");
			String own_id = inbuffer.getString("OWN_ID");
			String entity_type = inbuffer.getString("ENTITY_TYPE");
			String entity_id = inbuffer.getString("ENTITY_ID");
			String subject_tag = inbuffer.getString("SUBJECT_TAG");
			String title = inbuffer.getString("TITLE");
			String content = inbuffer.getString("CONTENT");
			String info_date = inbuffer.getString("INFO_DATE");
			String remark = inbuffer.getString("REMARK");
			ActionInfoDAO actionDao = new ActionInfoDAO();
			actionDao.setCust_id(cust_id);
			actionDao.setOwn_id(own_id);
			actionDao.setEntity_id(entity_id);
			actionDao.setEntity_type(entity_type);
			actionDao.setSubject_tag(subject_tag);
			actionDao.setTitle(title);
			actionDao.setInfo_date(info_date);
			actionDao.setContent(content);
			actionDao.setRemark(remark);
			iResult=updateActionInfo(actionDao);
		} 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("退出updateActionInfo方法...");
	}
	public int updateActionInfo(ActionInfoDAO actionDao)throws SaasApplicationException{
		ActionInfoExt actionExt = new ActionInfoExt();
		actionExt.setParam(":VCUST_ID",actionDao.getCust_id());         
		actionExt.setParam(":VOWN_ID",actionDao.getOwn_id());           
		actionExt.setParam(":VENTITY_ID",actionDao.getEntity_id());     
		actionExt.setParam(":VENTITY_TYPE",actionDao.getEntity_type()); 
		actionExt.setParam(":VSUBJECT_TAG",actionDao.getSubject_tag()); 
		actionExt.setParam(":VTITLE",actionDao.getTitle());             
		actionExt.setParam(":VINFO_DATE",actionDao.getInfo_date());     
		actionExt.setParam(":VCONTENT",actionDao.getContent());         
		actionExt.setParam(":VREMARK",actionDao.getRemark());     
		tradeQuery.executeBy(actionExt.insBy("UPDAT_BY_ALL"));
		return 0;
	}
	//删除动态
	public void deleteActionInfo(Buffers inbuffer){
		log.LOG_INFO("进入deleteActionInfo方法...");
		this.outBuffer = inbuffer;
		this.inBuffer = inbuffer;
		int iResult = -1;
		try {
			String cust_id = inbuffer.getString("SESSION_CUST_ID");
			String own_id = inbuffer.getString("OWN_ID");
			String entity_type = inbuffer.getString("ENTITY_TYPE");
			String entity_id = inbuffer.getString("ENTITY_ID");
			ActionInfoDAO actionDao = new ActionInfoDAO();
			actionDao.setCust_id(cust_id);
			actionDao.setOwn_id(own_id);
			actionDao.setEntity_id(entity_id);
			actionDao.setEntity_type(entity_type);
			iResult=deleteActionInfo(actionDao);
		} 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("退出deleteActionInfo方法...");
	}
	public int deleteActionInfo(ActionInfoDAO actionDao)throws SaasApplicationException{
		ActionInfoExt actionExt = new ActionInfoExt();
		actionExt.setParam(":VCUST_ID",actionDao.getCust_id());         
		actionExt.setParam(":VOWN_ID",actionDao.getOwn_id());           
		actionExt.setParam(":VENTITY_ID",actionDao.getEntity_id());     
		actionExt.setParam(":VENTITY_TYPE",actionDao.getEntity_type()); 
		tradeQuery.executeBy(actionExt.insBy("DEL_BY_ID"));
		return 0;
	}
	//取出单条动态信息
	public ArrayList getActionByIdx(String id)throws SaasApplicationException{
		ActionInfoExt actionExt = new ActionInfoExt();
		actionExt.setParam(":VENTITY_ID", id);
		ArrayList list=actionExt.selByList("SEL_BY_ID");
		return list;
	}
	// 联系人分页查询
	public ArrayList getActionByPubId(int iStart, String cust_id, String obj_id, String publish_id) throws SaasApplicationException {
	
			iStart = iStart  * 20;
		
		ActionInfoExt actionExt = new ActionInfoExt();
		actionExt.setParam(":VCUST_ID", cust_id);
		actionExt.setParam(":VOWN_ID", obj_id);
		actionExt.setParam(":VPUBLISH_USER_ID", publish_id);
		ArrayList list = actionExt.selByList("SEL_BY_ACTION");
		return list;
	}

	// 联系人分页统计
	public int getActionByCt(String cust_id, String obj_id, String publish_id) throws SaasApplicationException {
		int size = 0;
		ActionInfoExt actionExt = new ActionInfoExt();
		actionExt.setParam(":VCUST_ID", cust_id);
		actionExt.setParam(":VOWN_ID", obj_id);
		actionExt.setParam(":VPUBLISH_USER_ID", publish_id);
		ArrayList list = actionExt.selByList("SEL_BY_ACTION_CT");
		if (list != null && list.size() > 0) {
			HashMap map = (HashMap) list.get(0);
			size = Integer.parseInt(map.get("ct").toString());
		}
		return size;
	}
	//取出竞争对手的动态视图
	public ArrayList getActionByOpp(int iStart,String cust_id,String entity_type)throws SaasApplicationException{
		
			iStart = iStart * 20;
		
		ActionInfoExt actionExt = new ActionInfoExt();
		actionExt.setParam(":VCUST_ID", cust_id);
		actionExt.setParam(":VENTITY_TYPE", entity_type);
		ArrayList list=actionExt.selByList("SEL_ACTION_BY_OPP",iStart,20);
		return list;
	}
	
	public int getActionByOpp(String cust_id,String entity_type)throws SaasApplicationException{
		int count = 0;
		ActionInfoExt actionExt = new ActionInfoExt();
		actionExt.setParam(":VCUST_ID", cust_id);
		actionExt.setParam(":VENTITY_TYPE", entity_type);
		ArrayList list=actionExt.selByList("SEL_ACTION_BY_OPP");
		if(list != null && list.size()>0){
			count = list.size();
		}
		return count;
	}
	
	public ArrayList getActionByOppOO(String cust_id,String entity_type,String own_id,String entity_id)throws SaasApplicationException{
		ActionInfoExt actionExt = new ActionInfoExt();
		actionExt.setParam(":VCUST_ID", cust_id);
		actionExt.setParam(":VENTITY_TYPE", entity_type);
		actionExt.setParam(":VENTITY_ID", entity_id);
		actionExt.setParam(":VOWN_ID", own_id);
		ArrayList list=actionExt.selByList("SEL_ACTION_BY_OPPOO");
		return list;
	}
	
	public ArrayList getNewAction(String cust_id,String entity_type)throws SaasApplicationException{
		ActionInfoExt actionExt = new ActionInfoExt();
		actionExt.setParam(":VCUST_ID", cust_id);
		actionExt.setParam(":VENTITY_TYPE", entity_type);
		ArrayList list=actionExt.selByList("SEL_NEW_ACTION_BY_ENTITY");
		return list;
	}
	
}