groupinfo.java

java阿里巴巴代码

package com.saas.biz.groupInfoMgr;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.StringTokenizer;
import java.util.Map.Entry;

import com.saas.biz.commen.commMethodMgr;
import com.saas.biz.dao.custDAO.CustomerExt;
import com.saas.biz.dao.groupDAO.GroupInfoDAO;
import com.saas.biz.dao.groupDAO.GroupInfoExt;
import com.saas.biz.entityclassMgr.EntityClassInfo;
import com.saas.biz.relationUuMgr.RelationUUInfo;
import com.saas.biz.relationccMgr.RelationCcInfo;
import com.saas.sys.buffer.Buffers;
import com.saas.sys.dbm.Dbtable;
import com.saas.sys.exp.SaasApplicationException;
import com.saas.sys.log.Logger;
import com.saas.biz.custMgr.*;

public class GroupInfo {
	
	
	Dbtable tradeQuery;
	
	
	commMethodMgr comm;
	
	
	Logger log;
	
	
	Buffers inBuffer;
	
	
	Buffers outBuffer;
	
	
	ArrayList queryResult = new ArrayList();
	
	
	
	public GroupInfo() {

		log = new Logger(this);
		tradeQuery = new Dbtable();
		comm = new commMethodMgr();
	}
	
	
	public void setTradeQuery(Dbtable tradeQuery) {

		this.tradeQuery = tradeQuery;
	}
	
	
	public Dbtable getTradeQuery() {

		return this.tradeQuery;
	}
	
	
	public void setOutBuffer(Buffers outBuffer) {

		this.outBuffer = outBuffer;
	}
	
	
	public Buffers getOutBuffer() {

		return this.outBuffer;
	}
	
	
	public ArrayList getQueryResult() {

		return this.queryResult;
	}
	
	
	public void setQueryResult(ArrayList queryResult) {

		this.queryResult = queryResult;
	}
	
	
	
	/**
	 * 新增群组 user_id:是多个人员的id,以|分隔
	 * 
	 * @param inbuffer
	 */
	public void addGroupInfo(Buffers inbuffer) {

		log.LOG_INFO("进入addGroupInfo方法...");
		this.outBuffer = inbuffer;
		this.inBuffer = inbuffer;
		int iResult = -1;
		String cust_id = inbuffer.getString("SESSION_CUST_ID");
		String own_id = inbuffer.getString("SESSION_USER_ID");
		String group_type = inbuffer.getString("GROUP_TYPE");
		String class_id = inbuffer.getString("CLASS_ID");
		String class_name = inbuffer.getString("CLASS_NAME");
		String user_id = inbuffer.getString("USER_ID");
		String oper_user_id = inbuffer.getString("SESSION_USER_ID");
		String entity_type = inbuffer.getString("ENTITY_TYPE");
		try {
			GroupInfoDAO group = new GroupInfoDAO();
			group.setClass_id(class_id);
			group.setClass_name(class_name);
			group.setCust_id(cust_id);
			group.setOper_user_id(oper_user_id);
			group.setOwn_id(own_id);
			group.setGroup_type(group_type);
			iResult = addGroupInfo(group, user_id, entity_type);
		}
		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("退出addGroupInfo方法...");
	}
	
	
	public int addGroupInfo(GroupInfoDAO group, String user_Idx, String entity_type) throws SaasApplicationException {

		StringTokenizer st = new StringTokenizer(user_Idx, "|");
		String up_id = "", up_name = "";
		Map map = new EntityClassInfo().getUpClassIdAndName(group.getClass_id(), group.getCust_id(), entity_type);
		if (map != null && map.size() > 0) {
			Entry ent = (Entry) map.entrySet().iterator().next();
			up_id = String.valueOf(ent.getKey());
			up_name = String.valueOf(ent.getValue());
		}
		while (st.hasMoreElements()) {
			
			String user_id = String.valueOf(st.nextElement());
			if (!checkConcateExist(group.getClass_id(), group.getCust_id(), user_id, group.getOwn_id(), group.getGroup_type())) {
				GroupInfoExt groupExt = new GroupInfoExt();
				groupExt.setParam(":VCUST_ID", group.getCust_id());
				groupExt.setParam(":VOWN_ID", group.getOwn_id());
				groupExt.setParam(":VGROUP_TYPE", group.getGroup_type());
				groupExt.setParam(":VCLASS_ID", group.getClass_id());
				groupExt.setParam(":VCLASS_NAME", group.getClass_name());
				groupExt.setParam(":VCLASS_ID_GRP", up_id);
				groupExt.setParam(":VCLASS_NAME_GRP", up_name);
				groupExt.setParam(":VUSER_ID", user_id);
				groupExt.setParam(":VOPER_USER_ID", group.getOper_user_id());
				tradeQuery.executeBy(groupExt.insBy("INS_BY_ALL"));
			}
		}
		return 0;
	}
	
	
	public boolean checkConcateExist(String class_id, String cust_id, String user_id, String own_id, String group_type) throws SaasApplicationException {

		boolean exist = false;
		GroupInfoExt groupExt = new GroupInfoExt();
		groupExt.setParam(":VCLASS_ID", class_id);
		groupExt.setParam(":VCUST_ID", cust_id);
		groupExt.setParam(":VUSER_ID", user_id);
		groupExt.setParam(":VOWN_ID", own_id);
		groupExt.setParam(":VGROUP_TYPE", group_type);
		ArrayList list = groupExt.selByList("SEL_BY_CHECKS");
		if (list != null && list.size() > 0) {
			exist = true;
		}
		log.LOG_INFO("检测重复记录开始..." + exist);
		return exist;
	}
	
	
	
	// 取出组员(用户)信息
	public Map<String, String> getGroupUserByClass(String cust_id, String own_id, String class_id, String group_type) throws SaasApplicationException {

		Map<String, String> map = new HashMap<String, String>();
		GroupInfoExt groupExt = new GroupInfoExt();
		groupExt.setParam(":VCLASS_ID", class_id);
		groupExt.setParam(":VCUST_ID", cust_id);
		groupExt.setParam(":VOWN_ID", own_id);
		groupExt.setParam(":VGROUP_TYPE", group_type);
		ArrayList list = groupExt.selByList("SEL_USER_BY_CLASS");
		if (list != null && list.size() > 0) {
			for (int i = 0; i < list.size(); i++) {
				HashMap groupMap = (HashMap) list.get(i);
				String user_id = groupMap.get("user_id").toString();
				String user_name = groupMap.get("user_name").toString();
				map.put(user_id, user_name);
			}
		}
		return map;
	}
	
	
	
	// 取出组员(客户)信息
	public Map<String, String> getGroupCustByClass(String cust_id, String own_id, String class_id, String group_type) throws SaasApplicationException {

		Map<String, String> map = new HashMap<String, String>();
		GroupInfoExt groupExt = new GroupInfoExt();
		groupExt.setParam(":VCLASS_ID", class_id);
		groupExt.setParam(":VCUST_ID", cust_id);
		groupExt.setParam(":VOWN_ID", own_id);
		groupExt.setParam(":VGROUP_TYPE", group_type);
		ArrayList list = groupExt.selByList("SEL_CUST_BY_CLASS");
		if (list != null && list.size() > 0) {
			for (int i = 0; i < list.size(); i++) {
				HashMap groupMap = (HashMap) list.get(i);
				String cust_idx = groupMap.get("user_id").toString();
				String cust_name = groupMap.get("cust_name").toString();
				map.put(cust_idx, cust_name);
			}
		}
		return map;
	}
	
	
	
	// 新增客户组员列表
	public Map<String, String> getGroupMemByList(String cust_id, String own_id, String class_id, String group_type) throws SaasApplicationException {

		Map<String, String> map = new HashMap<String, String>();
		GroupInfoExt groupExt = new GroupInfoExt();
		Custinfo cust = new Custinfo();
		groupExt.setParam(":VCLASS_ID", class_id);
		groupExt.setParam(":VCUST_ID", cust_id);
		groupExt.setParam(":VOWN_ID", own_id);
		groupExt.setParam(":VGROUP_TYPE", group_type);
		ArrayList list = groupExt.selByList("SEL_CUST_BY_CLASS");
		ArrayList cust_list = new RelationCcInfo().getRelationByCustId(cust_id);
		List<String> group_List = new ArrayList<String>();
		if (list != null && list.size() > 0) {
			for (int i = 0; i < list.size(); i++) {
				HashMap groupMap = (HashMap) list.get(i);
				String cust_idx = groupMap.get("user_id").toString();
				group_List.add(cust_idx);
			}
		}
		
		if (group_List != null && group_List.size() > 0) {
			if (cust_list != null && cust_list.size() > 0) {
				for (int i = 0; i < cust_list.size(); i++) {
					HashMap cust_map = (HashMap) cust_list.get(i);
					String obj_cust_id = cust_map.get("obj_cust_id").toString();
					String obj_cust_name = cust.getCustNameById(cust_map.get("obj_cust_id").toString());// cust_map.get("cust_name").toString();
					if (!group_List.contains(obj_cust_id)) {
						map.put(obj_cust_id, obj_cust_name);
					}
				}
			}
		}
		else {
			for (int i = 0; i < cust_list.size(); i++) {
				HashMap cust_map = (HashMap) cust_list.get(i);
				String obj_cust_id = cust_map.get("obj_cust_id").toString();
				String obj_cust_name = cust.getCustNameById(cust_map.get("obj_cust_id").toString());
				map.put(obj_cust_id, obj_cust_name);
			}
		}
		return map;
	}
	
	
	public List customerByCustId(String cust_id) throws SaasApplicationException {

		List<String> list = new ArrayList<String>();
		ArrayList cust_list = new RelationCcInfo().getRelationByCustId(cust_id);
		if (cust_list != null && cust_list.size() > 0) {
			for (int i = 0; i < cust_list.size(); i++) {
				HashMap map = (HashMap) cust_list.get(i);
				String obj_cust_id = map.get("obj_cust_id").toString();
				list.add(obj_cust_id);
			}
		}
		return list;
	}
	
	
	
	// 新增联人群组列表
	public Map<String, String> getContactMemByList(String cust_id, String own_id, String class_id, String group_type) throws SaasApplicationException {

		Map<String, String> map = new HashMap<String, String>();
		GroupInfoExt groupExt = new GroupInfoExt();