package com.vci.event.mpm;


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

import com.vci.common.objects.UserEntity;
import com.vci.common.qt.object.Condition;
import com.vci.common.qt.object.QueryTemplate;
import com.vci.corba.bofactory.BOFactoryServicePrx;
import com.vci.corba.common.VCIError;
import com.vci.corba.omd.data.BusinessObject;
import com.vci.corba.query.ObjectQueryServicePrx;
import com.vci.corba.query.data.BOAndLO;
import com.vci.omd.constants.BusinessConstants;
import com.vci.omd.utils.ObjectTool;
import com.vci.server.base.utility.OQueryHelper;
import com.vci.server.base.utility.ServerServiceProvider;

public class StatusListener {
	private String status =""; //要修改的状�?
	private String statusSelf =""; //父状�?
	private String creatorUser = ""; // 父创建人
	private BusinessObject bso = null;
	public void doAction(UserEntity user,String status,String[] oid,String type,String linkType) {
		if (linkType == null || linkType.equals("")) {
			linkType = "EBOM";
		}
		this.status = status;

		try {
	    	BOFactoryServicePrx bofService = ServerServiceProvider.getBOFService();
	
			BusinessObject[] bos = getBusinessObjectbyByRefTypeAndOid(oid, type);
			
			if (bos != null) {
				//只有业务对象为part，product才需要父子状态提升�?
				if (!type.equals("part") && !type.equals("product")) {
					for(int i = 0; i < bos.length; i++){
						BusinessObject businessObject = bos[i];
						ObjectTool.setBOAttributeValue(businessObject, BusinessConstants.SELECT_LCSTATUS.toLowerCase(), status);
					}
					
//		            BusinessObjectListHolder bosh = new BusinessObjectListHolder();
//		            bosh.value = bos;
					
					bofService.batchUpdateBusinessObject(bos);
				}else {
					for(int i = 0; i < bos.length; i++){
						List<BusinessObject> list = new ArrayList<BusinessObject>();
						BusinessObject businessObject = bos[i];
						statusSelf = businessObject.lcStatus;
						creatorUser = businessObject.creator;
						this.bso = businessObject;
						list = fetchAllPbomLinks(businessObject.oid, linkType.toUpperCase(), list);
						
//			            BusinessObjectListHolder bosh = new BusinessObjectListHolder();
//			            bosh.value = list.toArray(new BusinessObject[0]);

						bofService.batchUpdateBusinessObject(list.toArray(new BusinessObject[0]));
					}
				}
			}
			
		} catch (VCIError e) {
			e.printStackTrace();
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}

	}

	private List<BusinessObject> fetchAllPbomLinks(String fromOid, String linkType,
			List<BusinessObject> boList) throws Exception {
		BOAndLO[] searchLinks = searchLOAddBO(linkType, fromOid, true);
		if(searchLinks != null && searchLinks.length > 0){
			for(BOAndLO boAddLo : searchLinks){
				BusinessObject bo = boAddLo.bo;
				//父子状�?是否�?��
				boolean res = booolStatus(statusSelf,bo.lcStatus);
				//创建人是否是同一个人
				if (creatorUser.equals(bo.creator)) { 
					if (res) { //父子状�?相同, �?��提升
						ObjectTool.setBOAttributeValue(bo, BusinessConstants.SELECT_LCSTATUS.toLowerCase(), status);
						ObjectTool.setBOAttributeValue(this.bso, BusinessConstants.SELECT_LCSTATUS.toLowerCase(), status);
					}else { //提升父，不提升子
						ObjectTool.setBOAttributeValue(this.bso, BusinessConstants.SELECT_LCSTATUS.toLowerCase(), status);
					}
				}else { //创建人不�?��
					//父子状�?�?��，不提升,子大于父，提升父，不提升�?
					if (!res) {
						ObjectTool.setBOAttributeValue(this.bso, BusinessConstants.SELECT_LCSTATUS.toLowerCase(), status);
					}
				}
				
				boList.add(bo);
				//查询子节�?
				fetchAllPbomLinks(bo.oid, linkType, boList);
			}
			
		}else{
			
			ObjectTool.setBOAttributeValue(this.bso, BusinessConstants.SELECT_LCSTATUS.toLowerCase(), status);
		}
		if (!boList.contains(this.bso)) {
			boList.add(this.bso);
		}
		return boList;
	}
	
	
	/**
	 * 判断父子状�?是否�?��提升
	 * <p>Description: </p>
	 * @author heyj
	 * @time 2014-4-4
	 * @param status1 父状�?
	 * @param status2 子状�?
	 * @return
	 */
	public boolean booolStatus(String status1,String status2){
		boolean res = false;
		Map<String, Integer> map = getStatusMap();
		int a = map.get(status1.toLowerCase()); //父状�?
		int b = map.get(status2.toLowerCase()); //子状�?
		//子状态大于父状�?
		if (a < b) { 
			res = false;
			//子状态与父状态一�?
		}else if(a == b){ 
			res = true;
		}
		return res;
	}
	/**
	 * 封转状�?，用来比较大�?
	 * <p>Description: </p>
	 * @author heyj
	 * @time 2014-4-4
	 * @return
	 */
	public Map<String, Integer> getStatusMap(){
		Map<String, Integer> map = new HashMap<String, Integer>();
		map.put("working", 1);
		map.put("auditing", 2);
		map.put("release", 3);
		return map;
	}
	
	private BOAndLO[] searchLOAddBO(String lintype,String fromOrToOid ,boolean direction) throws VCIError{
		QueryTemplate qt2 = new QueryTemplate();
		qt2.setId("ltQuery");
		qt2.setLinkType(lintype);
		qt2.setType("link");
		qt2.setBtmType("part");
		List<String> clauseList = new ArrayList<String>();
		clauseList.add("*");
		qt2.setClauseList(clauseList);
		Map<String, String> conditions = new HashMap<String, String>();
		if(direction){
			qt2.setDirection("positive");
			conditions.put("f_oid", fromOrToOid);
		}else{
			qt2.setDirection("opposite");
			conditions.put("t_oid", fromOrToOid);
		}
		Condition cond = OQueryHelper.getCondition(conditions);
		qt2.setCondition(cond);
		
		//QtServiceDelegate delegate = QtServiceDelegate.getInstance();
		ObjectQueryServicePrx oqService = ServerServiceProvider.getOQService();

		BOAndLO[] loaddbo = oqService.getBOAndLOS(qt2.getId(), OQueryHelper.getQTTextByQT(qt2),"");
		return loaddbo;
	}
	/**
	 * 得到要修改的业务对象
	 * <p>Description: </p>
	 * @author heyj
	 * @time 2014-4-3
	 * @param type
	 * @param conditionMap
	 * @return
	 */
	private BusinessObject[] getBusinessObjectbyByRefTypeAndOid(final String[] oid,final String type){
		BusinessObject[] bos = null;
		try {
			QueryTemplate qt2 = new QueryTemplate();
			qt2.setId("btmQuery");
			qt2.setBtmType(type);
			qt2.setType("btm");
			qt2.setQueryChildrenFlag(true);
			List<String> clauseList = new ArrayList<String>();
			clauseList.add("*");
			qt2.setClauseList(clauseList);
			Map<String, String> conditions = new HashMap<String, String>();
			String oidStr = "";
			for (int i = 0; i < oid.length; i++) {
				oidStr +=  oid[i];
				oidStr += "\\OR";
			}
			oidStr = oidStr.substring(0, oidStr.lastIndexOf("\\OR"));
			conditions.put("oid", oidStr);
			Condition cond = OQueryHelper.getCondition(conditions);
			qt2.setCondition(cond);
			
			//QtServiceDelegate delegate = QtServiceDelegate.getInstance();
			ObjectQueryServicePrx oqService = ServerServiceProvider.getOQService();

			bos = oqService.findBTMObjects(qt2.getId(),  OQueryHelper.getQTTextByQT(qt2));
		} catch (VCIError e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (Throwable e) {
			e.printStackTrace();
		}
		if (bos == null || bos.length <0) {
			return null;
		}
		return bos;
	}
	
	
}