package com.vci.server.log.delegate;

import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
import org.apache.commons.lang3.StringUtils;

import com.vci.common.utility.ObjectUtility;
import com.vci.corba.common.VCIError;
import com.vci.corba.log.data.LogInfo;
import com.vci.corba.log.data.LogPeriodInfo;
import com.vci.corba.log.data.LogType;
import com.vci.corba.log.data.RefObj;
import com.vci.corba.omd.btm.BtmItem;
import com.vci.corba.common.data.UserEntityInfo;
import com.vci.corba.framework.data.UserInfo;
import com.vci.server.cache.OMCacheProvider;
import com.vci.server.cache.OrgCacheProvider;
import com.vci.server.log.objects.Log;
import com.vci.server.log.objects.LogPeriod;
import com.vci.server.log.utils.LogTypeUtil;
import com.vci.server.log.dao.LogService;

public class LogManagementDelegate {
	private final String LOG_SAVE_PERIOD = "logSavePeriod";//日志保存期限
	private static LogService logSrv = new LogService();
	
	/**
	 * 在初始化日志模块时，检查是否配置了自动删除
	 * @return true表示设置了自动删除
	 * @throws VCIError
	 */
	public boolean getIsAutoDelete() throws VCIError {
		boolean res = false;
		try {
			LogService logSrv = new LogService();
			res = logSrv.getIsAutoDelete();
		} catch (Exception e) {
			e.printStackTrace();
			throw new VCIError("140101", new String[]{});//获取日志删除配置出错，请重试！
		}
		return res ;
	}
	
	/**
	 * 初始化日志模块时，获取保存期限和备份期限下拉框列表
	 * @return 配置好的期限值的集合
	 * @throws VCIError
	 */
	public LogPeriodInfo[] getPeriods() throws VCIError {
		LogPeriod[] periods = null;
		LogPeriodInfo[] infos = null;
		try {
			LogService logSrv = new LogService();
			periods = logSrv.getPeriods();
			if(periods!=null) {
				infos = new LogPeriodInfo[periods.length];
				for(int i=0;i<periods.length;i++) {
					infos[i] = changePeriodObjToInfo(periods[i]);
				}
			} else {
				infos = new LogPeriodInfo[0];
			}
		} catch (Exception e) {
			e.printStackTrace();
			throw new VCIError("140102", new String[]{});//获取日志配置期限出错，请重试！
		}
		return  infos;
	}
	
	/**
	 * 获取日志页面显示条数
	 * @return
	 * @throws VCIError
	 */
	public int getPageSize() throws VCIError {
		int pageSize = 0;
		try {
			LogService logSrv = new LogService();
			pageSize = logSrv.getPageSize();
		} catch (Exception e) {
			e.printStackTrace();
			throw new VCIError("140103", new String[]{});//获取日志页面显示条数出错，请重试！
		}
		return pageSize;
	}
	
	/**
	 * 获取当前查询日志总数
	 * @param sql 带条件的查询语句
	 * @return
	 * @throws VCIError
	 */
	public long getSumLogRows(String sql) throws VCIError {
		long sumRows = 0;
		try {
			LogService logSrv = new LogService();
			sumRows = logSrv.getSumLogRows(sql);
		}catch (Exception e) {
			e.printStackTrace();
			throw new VCIError("140104", new String[]{});//获取本次查询日志总数出错，请重试！
		}
		return sumRows ;
	}
	
	/**
	 * 获取全部日志信息
	 * @return
	 */
	public LogInfo[] fetchLogInfo(int pageNo,int pageSize,String sql) throws VCIError{
		LogInfo[] logInfos = null;
		try {
			LogService logSrv = new LogService();
			List<?> list = logSrv.getLogList(pageNo, pageSize,sql);
			logInfos = new LogInfo[list.size()];
			//Set<String> userIds = new HashSet<String>();
			for(int i = 0;i < list.size();i++){
				logInfos[i] = this.changeLogToLogInfo((Log)list.get(i));
				
				UserInfo user = OrgCacheProvider.getUser(logInfos[i].username);
				if (user != null)
					logInfos[i].truename = user.trueName;
			}
			
//			if(userIds.size()>0){
//				UserInfo[] userInfos = new RightManagementDelegate().fetchUserInfoByNames(userIds.toArray(new String[0]));
//				Map<String,String> userInfoMap = new HashMap<String,String>();
//				if(userInfos.length > 0 ){
//					for(int i = 0 ; i < userInfos.length; i ++){
//						UserInfo user = userInfos[i];
//						userInfoMap.put(user.userName, user.trueName);
//					}
//				}
//				for(int i = 0 ; i < logInfos.length ; i ++){
//					String userId  = logInfos[i].username;
//					if(userInfoMap.containsKey(userId)){
//						logInfos[i].truename = userInfoMap.get(userId);
//					}
//				}
//			}
		} catch (Exception e) {
			e.printStackTrace();
			throw new VCIError("140105", new String[]{});//查询日志出错，请重试！
		}
		return logInfos;
	}
	
	/**
	 * 根据查询条件获取日志信息
	 * <p>Description: </p>
	 * 
	 * @author Administrator
	 * @time 2013-1-2
	 * @param pageNo
	 * @param pageSize
	 * @param sql
	 * @return
	 * @throws VCIError
	 */
	public LogInfo[] getLogListByContion(int pageNo,int pageSize,String sql) throws VCIError{
		LogInfo[] logInfos = null;
		try {
			LogService logSrv = new LogService();
			List<?> list = logSrv.getLogListByContion(pageNo, pageSize,sql);
			logInfos = new LogInfo[list.size()];
			//Set<String> userIds = new HashSet<String>();
			for(int i = 0;i < list.size();i++){
				logInfos[i] = this.changeLogToLogInfo((Log)list.get(i));
				
				UserInfo user = OrgCacheProvider.getUser(logInfos[i].username);
				if (user != null)
					logInfos[i].truename = user.trueName;
				//userIds.add(logInfos[i].username);
			}
//			if(userIds.size()>0){
//				UserInfo[] userInfos = new RightManagementDelegate().fetchUserInfoByNames(userIds.toArray(new String[0]));
//				Map<String,String> userInfoMap = new HashMap<String,String>();
//				if(userInfos.length > 0 ){
//					for(int i = 0 ; i < userInfos.length; i ++){
//						UserInfo user = userInfos[i];
//						userInfoMap.put(user.userName, user.trueName);
//					}
//				}
//				for(int i = 0 ; i < logInfos.length ; i ++){
//					String userId  = logInfos[i].username;
//					if(userInfoMap.containsKey(userId)){
//						logInfos[i].truename = userInfoMap.get(userId);
//					}
//				}
//			}
		} catch (Exception e) {
			e.printStackTrace();
			throw new VCIError("140105", new String[]{});//查询日志出错，请重试！
		}
		return logInfos;
	}
	
	/**
	 * 保存日志保存/备份期限
	 * @param info 系统配置表的对象
	 * @return
	 */
	public boolean savePeriod(String period, UserEntityInfo userEnt) throws VCIError{
		boolean res = false;
		String id = ObjectUtility.getNewObjectID36();
		try {
			LogService logSrv = new LogService();
			//info.id = id;
			//UserEntityDelegate.setUserEntityToService(logSrv, userEnt);
			res = logSrv.savePeriod(LOG_SAVE_PERIOD, period);
			return res ;
		} catch (Exception e) {
			e.printStackTrace();
			throw new VCIError("140106", new String[]{});//保存期限出错，请重试！
		}
	}
	
	/**
	 * 获取保存/备份期限值
	 * @param type
	 * @return
	 * @throws VCIError
	 */
	public int getCurPeriod() throws VCIError{
		int period = 0;
		try {
			LogService logSrv = new LogService();
			period = logSrv.getCurPeriod(LOG_SAVE_PERIOD);
		} catch (Exception e) {
			e.printStackTrace();
			throw new VCIError("140107", new String[]{});//获取期限数值出错，请重试！
		}
		return period;
	}
	
	public boolean deleteLog(String deleteDate) throws VCIError {
		boolean res = false;
		try {
			LogService logSrv = new LogService();
			res = logSrv.deleteLog(deleteDate);
		} catch (Exception e) {
			e.printStackTrace();
			throw new VCIError("140108", new String[]{});//删除日志出错，请重试！
		}
		return res;
	}
	
	
	/**
	 * 简单记录系统登入、登出日�?
	 * <p>
	 * Description:
	 * </p>
	 * 
	 * @author wangxl
	 * @time 2012-12-27
	 * @param message
	 * @param userEntityInfo
	 * @throws VCIError
	 */
	public void saveLoginLog(boolean success, String message, UserEntityInfo userEntityInfo) throws VCIError {
		userEntityInfo.modules = "登录模块";// add by liujw
		
		UserInfo user = OrgCacheProvider.getUser(userEntityInfo.userName);
		
		if (user == null)
			return;
		
		String result = success ? "登录成功" : "登录失败";
		writeLog(userEntityInfo, "登录", message, result, LogType.Login, user.id);
	}


	public void saveLogoutLog(String message, UserEntityInfo userEntityInfo) throws VCIError {
		userEntityInfo.modules = "登录模块";

		UserInfo user = OrgCacheProvider.getUser(userEntityInfo.userName);
		if (user == null)
			return;
		
		writeLog(userEntityInfo, "登出", "登录成功", message, LogType.Logout, user.id);
	}
	
	/**
	 * 记录日志
	 * @param result
	 * @param message
	 * @param type
	 * @param logTypeIntVal
	 * @param dataObjOid
	 * @param userEntityInfo
	 * @throws VCIError
	 */
	public void saveLogV2(String result, String message, String type, LogType logType, String dataObjOid,
			UserEntityInfo userEntityInfo) throws VCIError {
		
		//LogType logType = LogType.getByIntVal(logTypeIntVal);
		
		writeLog(userEntityInfo, type, result, message, logType, dataObjOid);
	}
	

	public void saveObjLog(RefObj obj, String opType, String result, LogType logType, UserEntityInfo userEnt) {

		String info = StringUtils.isNotBlank(obj.name) ? obj.name : (StringUtils.isNotBlank(obj.id) ? obj.id : obj.oid);
		String btLabel = getBtmLabel(obj.btName);
		userEnt.modules = btLabel;
		
		writeLog(userEnt, opType, result,  "操作的数据为->"+ btLabel + ":" + info, logType, obj.oid);
	}
	

	public void batchSaveObjLog(RefObj[] objs, String opType, String result, UserEntityInfo userEnt) {
		if (objs == null || objs.length < 1) {
			return;
		}
		
		for (int i = 0; i < objs.length; i++) {
			RefObj ro = objs[i];
			String info = StringUtils.isNotBlank(ro.name) ? ro.name : (StringUtils.isNotBlank(ro.id) ? ro.id : ro.oid);
			String btLabel = getBtmLabel(ro.btName);
			userEnt.modules = btLabel;
			
			writeLog(userEnt, opType, result,  "操作的数据为->"+ btLabel + ":" + info, LogType.General, ro.oid);
		}
	}

//	private void writeLog(UserEntity userEntity, String optType, String result, String content, LogType logType, String dataObjId) {
//		try {
//			Log log = new Log();
//			log.setId(ObjectUtility.getNewObjectID36());
//			log.setDate(new Date());
//			log.setUserIp(userEntity.getIp());
//			
//			log.setUsername(userEntity.getUserName());
//			log.setResult(result);
//			log.setContent(content);
//			log.setType(optType);
//			
//			String module = userEntity.getModule();
//			if (StringUtils.isEmpty(module))
//				module = "log";
//			
//			log.setModule(module);
//			log.setLogType(logType.getLabel());
//			log.setObjId(dataObjId);
//			String roleName = "";//logSrv.getRoleName(userEntity.getModule(),userEntity.getUserName());
//			log.setRoleName(roleName);
//			
//			logSrv.saveLog(log);
//			
//		} catch (Exception e) {
//			e.printStackTrace();
//		}
//	}
	
	private void writeLog(UserEntityInfo userInfo, String optType, String result, String content, LogType logType, String dataObjId) {
		try {
			Log log = new Log();
			log.setId(ObjectUtility.getNewObjectID36());
			log.setDate(new Date());
			log.setUserIp(userInfo.ip);
			
			log.setUsername(userInfo.userName);
			log.setResult(result);
			log.setContent(content);
			log.setType(optType);
			
			String module = userInfo.modules;
			if (StringUtils.isEmpty(module))
				module = "log";
			
			log.setModule(module);
			log.setLogType(LogTypeUtil.getLabel(logType));
			log.setObjId(dataObjId);
			String roleName = "";//logSrv.getRoleName(userEntity.getModule(),userEntity.getUserName());
			log.setRoleName(roleName);
			
			logSrv.saveLog(log);
			
		} catch (Exception e) {
			e.printStackTrace();
		}
	}


	// 简单记录用户被锁定的日志
	public void saveLockUserLog(String userId, UserEntityInfo userEntityInfo) throws VCIError {
		UserInfo user = OrgCacheProvider.getUserByID(userId);
		if (user == null)
			return;
		
		writeLog(userEntityInfo, LogTypeUtil.getLabel(LogType.LockUser), "用户锁定", 
				user.userName + "[" + user.trueName + "]" + "在连续输入多次密码错误后导致账户被锁定", LogType.LockUser, userId);
	}
	
	/**
	 * period
	 * 服务器端对象转成CORBA对象
	 * @param obj
	 * @return
	 */
	private LogPeriodInfo changePeriodObjToInfo(LogPeriod obj) {
		LogPeriodInfo info = new LogPeriodInfo();
		info.code = obj.getCode()==null?"":obj.getCode();
		info.value = obj.getValue()==null?"":obj.getValue();
		return info;
	}
	
	/**
	 * 系统配置
	 * CORBA对象转成服务器端对象
	 * @param info
	 * @return
	 */
//	private SystemCfg changeSysCfgInfoToObj(SystemCfgInfo info) {
//		SystemCfg sys = new SystemCfg();
//		sys.setId(info.id);
//		sys.setName(info.name);
//		sys.setValue(info.value);
//		return sys;
//	}
	
	/**
	 * Log
	 * 服务器端对象转成CORBA对象
	 * @param obj
	 * @return
	 */
	public LogInfo changeLogToLogInfo(Log obj){
		LogInfo info = new LogInfo();
		info.puid = obj.getId() == null?"":obj.getId();
		info.type = obj.getType() == null?"":obj.getType();
		info.date = obj.getDate() == null?"":new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(obj.getDate());
		info.username = obj.getUsername() == null?"":obj.getUsername();
		info.userIp = obj.getUserIp() == null?"":obj.getUserIp();
		info.entityDesc = obj.getEntityDesc() == null?"":obj.getEntityDesc();
		info.property = obj.getProperty() == null?"":obj.getProperty();
		info.previousVal = obj.getPreviousVal() == null?"":obj.getPreviousVal();
		info.newVal = obj.getNewVal() == null?"":obj.getNewVal();
		info.result = obj.getResult() == null?"":obj.getResult();
		info.moduleName = obj.getModule() == null?"":obj.getModule();
		info.logType = obj.getLogType() == null ? "" : obj.getLogType();
		return info;
	}
	
	/**
	 * 获取类型Label
	 * @param btName
	 * @return
	 */
	private String getBtmLabel(String btName) {
		BtmItem bt = OMCacheProvider.getBizType(btName);
		if (bt != null)
			return bt.label;
		
		return btName;
	}

}