package com.vci.client.uif.actions.client.chageowner;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.LinkedHashMap;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;

import com.vci.client.bof.ClientBusinessObject;
import com.vci.client.bof.ClientBusinessObjectOperation;
import com.vci.client.bof.ClientLinkObject;
import com.vci.client.common.objects.UserObject;
import com.vci.client.common.oq.OQTool;
import com.vci.client.oq.QTClient;
import com.vci.client.portal.constants.QueryConditionConstants;
import com.vci.client.ui.process.QANProcessBar;
import com.vci.client.ui.process.QANProcessBarFrame;
import com.vci.client.ui.swing.components.VCIJDialog.DialogResult;
import com.vci.client.uif.actions.client.AbstractBatchBusionessOperationAction;
import com.vci.client.uif.actions.client.RightCheckConstants;
import com.vci.client.uif.actions.client.UIFUtils;
import com.vci.client.uif.engine.client.UIHelper;
import com.vci.client.uif.engine.common.IDataNode;
import com.vci.common.qt.object.QueryTemplate;
import com.vci.corba.common.VCIError;
import com.vci.corba.query.data.BOAndLO;
import com.vci.mw.ClientContextVariable;

/**
 * 标准的更改业务对象的所有者action<br/>
 * 如果选择的数据是BO，则修改选择BO对象的OWNER<br/>
 * 如果选择的数据是BO，且cascade=true，此时修改选择BO对象及其子对象的OWNER。需要linkType、fromType、toType、f_oid、t_oid等参数的协同支持<br/>
 * 如果选择的数据是LO，且direction的参数值(默认按positive处理)<br/>
 * <ul>
 * <li>all:
 * <li>positive:
 * <li>opposite:
 * </ul>
 * @author xchao
 * @since 2014.06.16
 *
 */
public class ChangeOwnerAction extends AbstractBatchBusionessOperationAction {

	public static final String CASCADE_KEY = "cascade";
	public static final String CASCADE_VALUE = "true";
	public static final String DIRECTION_KEY = "direction";
	public static final String DIRECTION_POSITIVE = "positive";
	public static final String DIRECTION_OPPOSITE = "opposite";
	public static final String LINK_TYPE = QueryConditionConstants.LO_TYPE;
	public static final String FROM_TYPE = "fromType";
	public static final String TO_TYPE = "toType";
	
	@Override
	public String getKey() {
		return "changeowner";
	}

	/**
	 * 是否显示级联更改选项
	 * @return
	 */
	protected boolean isCascade(){
		boolean res = false;
		String cfgVal = getButtonParamBy(CASCADE_KEY);
		if(cfgVal != null && CASCADE_VALUE.equalsIgnoreCase(cfgVal)){
			res = true;
		}
		return res;
	}
	
	protected String getDirection(){
		return getButtonParamBy(DIRECTION_KEY);
	}
	
	protected String getLinkType(){
		return getButtonParamBy(LINK_TYPE);
	}
	
	protected String getFromType(){
		return getButtonParamBy(FROM_TYPE);
	}
	
	protected String getToType(){
		return getButtonParamBy(TO_TYPE);
	}
	
	protected String getButtonParamBy(String key){
		String configValue = getParameterValue(ValueType.ButtonConfig, key, 0);
		String res = "";
		if(configValue != null && !"".equalsIgnoreCase(configValue)){
			return configValue;
		}
		return res;
	}
	
	@Override
	public boolean checkHasRight(){
		// 按BO进行数据权限检查
		setDataRightCheckType(RightCheckConstants.RIGHT_CHECK_TYPE_B);
		return super.checkHasRight();
	}
	
	@Override
	public boolean doPost() {
		Object[] objs = getDataModel().getSelectObjects();
		// 是否显示级联
		boolean cascade = isCascade();
		ChangeOwnerDialog cod = new ChangeOwnerDialog();
		cod.setShowCascadeCheckbox(cascade);
		cod.buildDialog();
		cod.setSize(UIHelper.DIALOG_DEFAULT_WIDTH/2, UIHelper.DIALOG_DEFAULT_HEIGHT/2);
		cod.setLocationRelativeTo(ClientContextVariable.getFrame());
		cod.setVisible(true);
		DialogResult dialogResult = cod.getDialogResult();
		if(dialogResult.equals(DialogResult.CANCEL)) return false;
		// 基于选择，是否级联
		cascade = cod.isCascade();
		return doPostProcessBar(objs, cod.getNewOwner(), cascade);
	}
	
	protected boolean doPostProcessBar(final Object[] objs, final String newOwner, final boolean cascade){
		final boolean[] ress = new boolean[1];
		final QANProcessBarFrame frame = new QANProcessBarFrame();
		Thread t = new Thread() {
			public void run() {
				frame.setContent("正在执行修改所有者,请稍等......");
				try {
					ress[0] = updateObjectOwner(objs, newOwner, cascade, frame);
				} catch (Exception e) {
					UIFUtils.showErrorMessage(null, e);
					ress[0] = false;
				} finally {
					frame.setProcessBarCancel(true);
				}
			}
		};
		QANProcessBar bar = new QANProcessBar(t, frame, frame, "修改所有者", false);
		bar.setVisible(true);
		return ress[0];
	}
	/**
	 * 根据选择的数据，执行相应的判断逻辑，调用更新接口
	 * @param objs
	 * @param newOwner
	 * @param isCascade
	 * @return
	 */
	protected boolean updateObjectOwner(Object[] objs, String newOwner, boolean isCascade, QANProcessBarFrame frame){
		LinkedList<ClientBusinessObject> cboList = new LinkedList<ClientBusinessObject>();
		StringBuffer sbNames = new StringBuffer();
		HashMap<String, ClientBusinessObject> selectedCBOMap = new LinkedHashMap<String, ClientBusinessObject>();
		HashMap<String, ClientLinkObject> selectedCLOMap = new HashMap<String, ClientLinkObject>();
		for(Object obj : objs){
			if(!(obj instanceof IDataNode)) continue;
			IDataNode data = (IDataNode)obj;
			ClientBusinessObject cbo = null;
			if(data.getMaterObject() instanceof ClientBusinessObject){
				cbo = (ClientBusinessObject)(data.getMaterObject());
			} else if(data.getMaterObject() instanceof ClientLinkObject){
				// link 对象对应CBO
				ClientLinkObject clo = (ClientLinkObject)data.getMaterObject();
				cbo = data.getClientBusinessObject();
				selectedCLOMap.put(clo.getOid(), clo);
			}
			cboList.add(cbo);
			sbNames.append(cbo.getBusinessObject().name).append("\n");
			selectedCBOMap.put(cbo.getOid(), cbo);
		}
		boCascadeProcess(selectedCBOMap, isCascade, newOwner, frame);
		frame.setContent("正在设置数据的所有者");
		List<ClientBusinessObject> changeCBOList = new LinkedList<ClientBusinessObject>();
		List<UserObject> newOwnerList = new LinkedList<UserObject>();
		Iterator<String> its = selectedCBOMap.keySet().iterator();
		while(its.hasNext()){
			String oid = its.next();
			ClientBusinessObject cbo = selectedCBOMap.get(oid);
			changeCBOList.add(cbo);
			
			UserObject userObj = new UserObject();
			userObj.setUserName(newOwner);
			newOwnerList.add(userObj);
		}
		frame.setContent("正在执行修改所有者");
		boolean updateRes = executeUpdateOwner(changeCBOList, newOwnerList);
		if(updateRes){
			UIFUtils.showMessage(getParentComponent(), "uifmodel.plm.uif.actions.changeownersuccessmsg", sbNames.toString());
		}
		return updateRes;
	}
	
	protected void loCascadeProcess(HashMap<String, ClientBusinessObject> selectedCBOMap, 
			boolean isCascade, String newOwner, QANProcessBarFrame frame){
		if(!isCascade) return;
	}
	/**
	 * 级联处理选择的BO对象的子对象
	 * @param cboMap
	 * @param isCascade
	 * @param newOwner
	 */
	protected void boCascadeProcess(HashMap<String, ClientBusinessObject> selectedCBOMap, 
			boolean isCascade, String newOwner, QANProcessBarFrame frame){
		if(!isCascade) return;
		
		String direction = getDirection();
		String linkType = getLinkType();
		String fromType = getFromType();
		String toType = getToType();
		
		Iterator<String> its = selectedCBOMap.keySet().iterator();
		while(its.hasNext()){
			String oid = its.next();
			ClientBusinessObject cbo = selectedCBOMap.get(oid);
			frame.setContent("正在查询 ‘" + cbo.getName() + "’ 的子数据");
			getChildCBOS(selectedCBOMap, cbo, cbo.getOid(), direction, linkType, fromType, toType, frame);
		}
	}
	
	protected void getChildCBOS(
			HashMap<String, ClientBusinessObject> selectedCBOMap,
			ClientBusinessObject cbo, String oid, String direction, 
			String linkType, String fromType, String toType, 
			QANProcessBarFrame frame){
		QueryTemplate qt9 = new QueryTemplate();
		qt9.setId("id");
		List<String> clauseList = new ArrayList<String>();
		clauseList.add("*");
		qt9.setClauseList(clauseList);
		qt9.setLinkType(linkType);
		qt9.setBtmType(toType);
		qt9.setRightFlag(false);
		qt9.setType("link");
		// 如果参数 direction为空，则默认按正向
		if("".equals(direction)){
			direction = DIRECTION_POSITIVE;
		}
		// 设置方向
		qt9.setDirection(direction);
		// 全递归，查出全部的子
		qt9.setLevel(-1);
		Map<String, String> conditionMap = new HashMap<String, String>();
		conditionMap.put("f_oid", oid);
		qt9.setCondition(OQTool.getCondition(conditionMap));
		try {
			BOAndLO[] blos = QTClient.getService().getBOAndLOS(qt9.getId(), OQTool.qtTOXMl(qt9).asXML(), cbo.getOid());
			frame.setContent("查询到 ‘" + cbo.getName() + "’共计有 " + blos.length + " 条子件");
			filterOnwerNotEqualsCurrentUser(selectedCBOMap, cbo, blos, frame);
		} catch (VCIError e) {
			e.printStackTrace();
		}
	}

	private void filterOnwerNotEqualsCurrentUser(
			HashMap<String, ClientBusinessObject> selectedCBOMap,
			ClientBusinessObject cbo,
			BOAndLO[] blos, QANProcessBarFrame frame){
		String currentUserName = ClientContextVariable.getInvocationInfo().userName;
		frame.setContent("正在过滤 ‘" + cbo.getName() + "’的子件中与选择的数据重复、以及所有者不是当前用户‘" + currentUserName + "’的数据");
		for(BOAndLO blo : blos){
			if(selectedCBOMap.containsKey(blo.bo.oid)) continue;
			if(!currentUserName.equals(blo.bo.owner)) continue;
			ClientBusinessObject cboChild = new ClientBusinessObject();
			cboChild.setBusinessObject(blo.bo);
			selectedCBOMap.put(blo.bo.oid, cboChild);
		}
	}
	
	/**
	 * 调用接口，执行更新
	 * @param cboList
	 * @param newOwnerList
	 * @return
	 */
	protected boolean executeUpdateOwner(List<ClientBusinessObject> cboList, List<UserObject> newOwnerList){
		boolean updateRes = false;
		try {
			updateRes = new ClientBusinessObjectOperation().batchChangeBusinessObjectOwner(
					cboList.toArray(new ClientBusinessObject[]{}), newOwnerList.toArray(new UserObject[]{}));
		} catch (VCIError e) {
			UIFUtils.showErrorMessage(getParentComponent(), e);
		}
		return updateRes;
	}
}