package com.vci.server.workflow.server.delegate;

import java.util.Date;
import java.util.Iterator;
import java.util.LinkedHashMap;
import java.util.List;

import org.omg.CORBA.LongHolder;

import com.vci.common.objects.QueryParam;
import com.vci.common.objects.QueryResult;
import com.vci.common.utility.ObjectUtility;
import com.vci.corba.common.VCIError;
import com.vci.corba.workflow.data.QueryParamInfo;
import com.vci.corba.common.data.UserEntityInfo;
import com.vci.corba.workflow.data.FlowApproveContentInfo;
import com.vci.server.base.delegate.BaseDelegate;
import com.vci.server.workflow.objects.FlowApproveContent;
import com.vci.server.workflow.server.task.approve.FlowApproveContentService;

/**
 * FlowApproveContent Delegate Server
 *
 */
public class FlowApproveContentDelegate extends BaseDelegate {
	FlowApproveContentService service = null;

	public FlowApproveContentDelegate(UserEntityInfo userEntityInfo) {
		super(userEntityInfo);
		service = new FlowApproveContentService(this.getUserEntity());
	}

	/**
	 * 添加、保存 FlowApproveContent 对象
	 * 
	 * @param info FlowApproveContentInfo 对象
	 */
	public boolean saveFlowApproveContent(FlowApproveContentInfo info) throws VCIError {
		boolean res = false;
		String id = ObjectUtility.getNewObjectID36();
		info.id = id;
		try {
			FlowApproveContent obj = this.convertFlowApproveContentInfoToFlowApproveContent(info);
			res = service.saveFlowApproveContent(obj);
//				LogRecordUtil.writeLog(userEntity, "添加", obj.getLogInfo(), LogType.GeneralOperation, obj.getId());
		} catch (Exception ex) {
			throw new VCIError("410801", new String[] { ex.getMessage() });
		}
		return res;
	}

	/**
	 * 修改、更新 FlowApproveContent 对象
	 * 
	 * @param info FlowApproveContentInfo 对象
	 */
	public boolean updateFlowApproveContent(FlowApproveContentInfo info) throws VCIError {
		boolean res = false;
		try {
			FlowApproveContent obj = this.convertFlowApproveContentInfoToFlowApproveContent(info);
			FlowApproveContent objBefore = service.getFlowApproveContentById(info.id);
			StringBuffer sbLog = new StringBuffer();
			sbLog.append("更新前：" + objBefore.getLogInfo());
			sbLog.append("更新后：" + obj.getLogInfo());
			res = service.updateFlowApproveContent(obj);
//				LogRecordUtil.writeLog(userEntity, "更新", sbLog.toString(), LogType.GeneralOperation, obj.getId());
		} catch (Exception ex) {
			throw new VCIError("410802", new String[] { ex.getMessage() });
		}
		return res;
	}

	/**
	 * 根据 ID 删除 FlowApproveContent 对象（批量）
	 * 
	 * @param ids FlowApproveContent 对象的 ID 列表
	 */
	public boolean deleteFlowApproveContent(String[] ids) throws VCIError {
		boolean res = false;
		LinkedHashMap<String, String> delLogMap = new LinkedHashMap<String, String>();
		try {
			for (String id : ids) {
				delLogMap.put(id, service.getFlowApproveContentById(id).getLogInfo());
			}
			res = service.deleteFlowApproveContent(ids);
			Iterator<String> keys = delLogMap.keySet().iterator();
			while (keys.hasNext()) {
				String id = keys.next();
				String logInfo = delLogMap.get(id);
//					LogRecordUtil.writeLog(userEntity, "删除", logInfo, LogType.GeneralOperation, id);
			}
		} catch (Exception ex) {
			throw new VCIError("410803", new String[] { ex.getMessage() });
		}
		return res;
	}

	/**
	 * 返回全部的 FlowApproveContent 对象
	 */
	public FlowApproveContentInfo[] getFlowApproveContents() throws VCIError {
		FlowApproveContentInfo[] infos = new FlowApproveContentInfo[0];
		try {
			List<FlowApproveContent> list = service.getFlowApproveContents();
			FlowApproveContent[] objects = list.toArray(new FlowApproveContent[] {});
			infos = this.convertFlowApproveContentsToFlowApproveContentInfos(objects);
		} catch (Exception ex) {
			throw new VCIError("410804", new String[] { ex.getMessage() });
		}
		return infos;
	}

	/**
	 * 根据分页参数 返回 FlowApproveContent 对象
	 * <p>
	 * Description:
	 * </p>
	 * 
	 * @param total          输出参数，数据总数
	 * @param queryParamInfo 查询参数
	 * @return 对象集合
	 * @throws VCIError
	 */
	public FlowApproveContentInfo[] getFlowApproveContentByPageing(LongHolder total, QueryParamInfo queryParamInfo)
			throws VCIError {
		FlowApproveContentInfo[] infos = new FlowApproveContentInfo[0];
		try {
			QueryParam queryParam = convertQueryParamInfo(queryParamInfo);
			QueryResult<FlowApproveContent> res = service.getFlowApproveContentByPageing(queryParam);
			total.value = res.getTotal();
			FlowApproveContent[] objects = res.getDatas();
			infos = this.convertFlowApproveContentsToFlowApproveContentInfos(objects);
		} catch (Exception ex) {
			throw new VCIError("410804", new String[] { ex.getMessage() });
		}
		return infos;
	}

	/**
	 * 根据 ID 返回 FlowApproveContent 对象
	 * 
	 * @param id FlowApproveContent
	 */
	public FlowApproveContentInfo getFlowApproveContentById(String id) throws VCIError {
		FlowApproveContentInfo info = new FlowApproveContentInfo();
		try {
			FlowApproveContent object = service.getFlowApproveContentById(id);
			info = this.convertFlowApproveContentToFlowApproveContentInfo(object);
		} catch (Exception ex) {
			throw new VCIError("410804", new String[] { ex.getMessage() });
		}
		return info;
	}

	/************************* CORBA & HIBERNATE CONVERT **************************/
	/**
	 * 对象转换(批量)，从 Hibernate 对象转换到 Corba 对象
	 * 
	 * @param objects
	 */
	public FlowApproveContentInfo[] convertFlowApproveContentsToFlowApproveContentInfos(FlowApproveContent[] objects) {
		FlowApproveContentInfo[] infos = new FlowApproveContentInfo[objects.length];
		int i = 0;
		for (FlowApproveContent obj : objects) {
			infos[i++] = this.convertFlowApproveContentToFlowApproveContentInfo(obj);
		}
		return infos;
	}

	/**
	 * 对象转换，从 Hibernate 对象转换到 Corba 对象
	 * 
	 * @param object
	 * @return
	 */
	public FlowApproveContentInfo convertFlowApproveContentToFlowApproveContentInfo(FlowApproveContent object) {
		FlowApproveContentInfo info = new FlowApproveContentInfo();
		info.id = object.getId() == null ? "" : object.getId();
		info.userId = object.getUserId() == null ? "" : object.getUserId();
		info.approveContent = object.getApproveContent() == null ? "" : object.getApproveContent();
		info.seq = object.getSeq();
		info.createTime = object.getCreateTime().getTime();
		info.createUser = object.getCreateUser() == null ? "" : object.getCreateUser();
		info.createRole = object.getCreateRole() == null ? "" : object.getCreateRole();
		info.createOrg = object.getCreateOrg() == null ? "" : object.getCreateOrg();
		info.modifyTime = object.getModifyTime().getTime();
		info.modifyUser = object.getModifyUser() == null ? "" : object.getModifyUser();
		info.modifyRole = object.getModifyRole() == null ? "" : object.getModifyRole();
		info.modifyOrg = object.getModifyOrg() == null ? "" : object.getModifyOrg();
		info.licensors = object.getLicensors() == null ? "" : object.getLicensors();
		return info;
	}

	/**
	 * 对象转换(批量)，从 Corba 对象转换到 Hibernate 对象
	 * 
	 * @param infos
	 * @return
	 */
	public FlowApproveContent[] convertFlowApproveContentInfosToFlowApproveContents(FlowApproveContentInfo[] infos) {
		FlowApproveContent[] objects = new FlowApproveContent[infos.length];
		int i = 0;
		for (FlowApproveContentInfo info : infos) {
			objects[i++] = this.convertFlowApproveContentInfoToFlowApproveContent(info);
		}
		return objects;
	}

	/**
	 * 对象转换，从 Corba 对象转换到 Hibernate 对象
	 * 
	 * @param info
	 * @return
	 */
	public FlowApproveContent convertFlowApproveContentInfoToFlowApproveContent(FlowApproveContentInfo info) {
		FlowApproveContent object = new FlowApproveContent();
		object.setId(info.id);
		object.setUserId(info.userId);
		object.setApproveContent(info.approveContent);
		object.setSeq(info.seq);
		object.setCreateTime(new Date(info.createTime));
		object.setCreateUser(info.createUser);
		object.setCreateRole(info.createRole);
		object.setCreateOrg(info.createOrg);
		object.setModifyTime(new Date(info.modifyTime));
		object.setModifyUser(info.modifyUser);
		object.setModifyRole(info.modifyRole);
		object.setModifyOrg(info.modifyOrg);
		object.setLicensors(info.licensors);
		return object;
	}

	protected QueryParam convertQueryParamInfo(QueryParamInfo info) {
		QueryParam obj = new QueryParam();
		obj.setCustomQueryString(info.customQueryString);
		obj.setPageIndex(info.pageIndex);
		obj.setPageSize(info.pageSize);
		return obj;
	}
}