package com.vci.server.base.utility;

import org.apache.commons.lang3.StringUtils;

import com.vci.common.objects.UserEntity;
import com.vci.corba.common.VCIError;
import com.vci.corba.log.LogServicePrx;
import com.vci.corba.log.data.LogType;
import com.vci.corba.log.data.RefObj;
import com.vci.corba.omd.data.BusinessObject;
import com.vci.corba.common.data.UserEntityInfo;
import com.vci.corba.common.data.VCIInvocationInfo;
import com.vci.server.base.delegate.UserEntityDelegate;
import com.vci.server.base.persistence.dao.HibernateSessionFactory;

public class LogRecordUtil {

	public static void saveLoginLog(boolean success, String content, UserEntityInfo userEnt) throws VCIError{
		
		if (userEnt == null)
			userEnt = getUserEntity();
		
		LogServicePrx logService = ServerServiceProvider.getLogService();
		
		logService.saveLoginLog(success, content, userEnt);
	}
	
	public static void saveLogoutLog(String content, UserEntityInfo userEnt) throws VCIError{
		if (userEnt == null)
			userEnt = getUserEntity();
		
		LogServicePrx logService = ServerServiceProvider.getLogService();
		
		logService.saveLogoutLog(content, userEnt);
	}
	
	/**
	 * 日志记录
	 * @param userEntity 用户对象
	 * @param optType 操作类别
	 * @param resContent 操作结构
	 * @param logType 日志类型
	 * @throws VCIError 
	 */
	public static void writeLog(UserEntity userEnt, String optType, String result, String content, LogType logType,String dataObjId) throws VCIError{
		
		LogServicePrx logService = ServerServiceProvider.getLogService();
		
		logService.saveLog(result, content, optType, logType, dataObjId, UserEntityDelegate.changeUserEntityToInfo(userEnt));
	}
	
	/**
	 * 日志记录
	 * @param optType
	 * @param result
	 * @param content
	 * @param logType
	 * @param dataObjId
	 * @throws VCIError
	 */
	public static void writeGeneralSuccessLog(BusinessObject bo, String optType) throws VCIError{
		writeGeneralLog(bo, optType, "操作成功");
	}
	
	public static void writeGeneralFailLog(BusinessObject bo, String optType) throws VCIError{
		writeGeneralLog(bo, optType, "操作失败");
	}
	
	public static void writeGeneralLog(BusinessObject bo, String optType, String result) throws VCIError{
		
		UserEntityInfo userEnt = getUserEntity();
		
		LogServicePrx logService = ServerServiceProvider.getLogService();
		
		String logInfo = StringUtils.isNotBlank(bo.name)?bo.name:(StringUtils.isNotBlank(bo.id)?bo.id:bo.oid);
		
		logService.saveLog(result, logInfo, optType, LogType.General, bo.id, userEnt);
	}

	private static UserEntityInfo getUserEntity() {
		//日志记录
		VCIInvocationInfo viinfo = HibernateSessionFactory.getVciSessionInfo();
		String ip = "127.0.0.1";
		if(viinfo!=null){
			ip = viinfo.clientIPInfo == null||"".equals(viinfo.clientIPInfo) ? "127.0.0.1" : viinfo.clientIPInfo;
		}
		
		UserEntityInfo userEnt = new UserEntityInfo();
		userEnt.userName = viinfo.userName;
		userEnt.ip = ip;
		return userEnt;
	}
	
	/**
	 * 日志记录
	 * @param userEnt
	 * @param optType
	 * @param result
	 * @param content
	 * @param logType
	 * @param dataObjId
	 * @throws VCIError
	 */
	public static void writeLog(UserEntityInfo userEnt, String optType, String result, String content, LogType logType,String dataObjId) throws VCIError{
		
		LogServicePrx logService = ServerServiceProvider.getLogService();
		
		logService.saveLog(result, content, optType, logType, dataObjId, userEnt);
	}
	
//	protected void recordLog(String user, String module, String ip, String operation, String type, String objName, String oid) throws VCIError {
//		userEntity.userName = user;
//		if(module.equalsIgnoreCase(type)){
//			userEntity.modules = getBtmShowName(module);
//		}else{
//			userEntity.modules = module;
//		}
//		userEntity.ip = ip;
//	
//		String con = "操作的数据是->" + getBtmShowName(type) + ":" + objName;
//		//记录日志
//		
//		ServerServiceProvider.getFrameService().savelogGeneralOperation("操作成功", con, userEntity, oid, type);
//		//LogRecordUtil.writeLog(userEntity, operation, "操作成功", "操作的数据是->" + getBtmShowName(type) + ":" + objName, LogType.GeneralOperation, oid);
//	}

	/**
	 * 批量存储对象操作日志
	 * @param userEnt
	 * @param bos
	 * @param operation
	 * @param result
	 * @throws VCIError
	 */
	public static void batchWriteLog(UserEntityInfo userEnt, BusinessObject[] bos, String operation, String result) throws VCIError{
		if (bos == null || bos.length < 1) {
			return;
		}
		
		LogServicePrx logService = ServerServiceProvider.getLogService();

		userEnt.modules = "bo";
		
		RefObj[] ros = new RefObj[bos.length];
		for (int i = 0; i < bos.length; i++) {
			BusinessObject bo = bos[i];
			
			RefObj ro = new RefObj();
			ro.oid = bo.oid;
			ro.btName = bo.btName;
			ro.name = bo.name;
			ro.id = bo.id;
			
			ros[i] = ro;
		}
			
		try {
			logService.batchSaveObjLog(ros, operation, result, userEnt);
		} catch (VCIError e) {
			e.printStackTrace();
		}
	}
	
	/**
	 * 批量保存对象操作日志
	 * @param bos
	 * @param operation
	 * @param result
	 * @throws VCIError
	 */
	public static void batchWriteLog(BusinessObject[] bos, String operation) throws VCIError{
		batchWriteLog(bos, operation, "操作成功");
	}
	
	public static void batchWriteLog(BusinessObject[] bos, String operation, String result) throws VCIError{
		if (bos == null || bos.length < 1) {
			return;
		}
		
		//日志记录
		VCIInvocationInfo viinfo = HibernateSessionFactory.getVciSessionInfo();
		String ip = "127.0.0.1";
		if(viinfo!=null){
			ip = viinfo.clientIPInfo == null||"".equals(viinfo.clientIPInfo) ?"127.0.0.1":viinfo.clientIPInfo;
		}
		
		UserEntityInfo userEnt = new UserEntityInfo();
		userEnt.userName = viinfo.userName;
		userEnt.ip = ip;
		
		LogServicePrx logService = ServerServiceProvider.getLogService();
		
		userEnt.modules = "bo";
		
		RefObj[] ros = new RefObj[bos.length];
		for (int i = 0; i < bos.length; i++) {
			RefObj ro = new RefObj();
			
			BusinessObject bo = bos[i];
			
			ro.oid = bo.oid;
			ro.btName = bo.btName;
			ro.name = bo.name;
			ro.id = bo.id;
			
			ros[i] = ro;
		}
		
		try {
			logService.batchSaveObjLog(ros, operation, result, userEnt);
		} catch (VCIError e) {
			e.printStackTrace();
		}
	}
	
}