package com.vci.server.framework.systemConfig.log;

import java.sql.SQLException;
import java.sql.Statement;
import java.text.SimpleDateFormat;
import java.util.Date;

import org.apache.commons.lang3.StringUtils;
import org.hibernate.HibernateException;
import org.hibernate.Session;

import com.vci.common.log.LogType;
import com.vci.common.objects.UserEntity;
import com.vci.common.utility.ObjectUtility;
import com.vci.corba.common.VCIError;
import com.vci.corba.common.data.VCIInvocationInfo;
import com.vci.corba.common.data.UserEntityInfo;
import com.vci.server.base.delegate.UserEntityDelegate;
import com.vci.server.base.persistence.dao.HibernateSessionFactory;

public class LogRecordUtil {
							
	
	private static LogService logSrv = new LogService();
	
	/**
	 * 日志记录
	 * @param userEntity 用户对象
	 * @param optType 操作类别
	 * @param resContent 操作结构
	 * @param logType 日志类型
	 * @throws VCIError 
	 */
	public static void writeLog(UserEntity userEntity, String optType, String result, String content, LogType logType,String dataObjId) throws VCIError{
		try {
			Log log = new Log();
			log.setId(ObjectUtility.getNewObjectID36());
			log.setDate(new Date());
			log.setUserIp(userEntity.getIp());
			
			VCIInvocationInfo invInfo = HibernateSessionFactory.getVciSessionInfo();
			String user = userEntity.getUserName();
			if (user == null) {
				user = invInfo.userName;
			}
			if (StringUtils.isEmpty(user))
				user = "loguser";
			log.setUsername(user);
			log.setResult(result);
			log.setContent(content);
			log.setType(optType);
			
			String module = userEntity.getModule();
			if (StringUtils.isEmpty(module))
				module = "log";
			
			String moduleAlias = logSrv.getModuleAlias(module);
			if(moduleAlias.equals("")){
				moduleAlias = module;
			}
			log.setModule(moduleAlias);
			log.setLogType(getLogTypeString(logType));
			log.setObjId(dataObjId);
			String roleName = "";//logSrv.getRoleName(userEntity.getModule(),userEntity.getUserName());
			log.setRoleName(roleName);
			logSrv.saveLog(log);
		} catch (Exception e) {
			e.printStackTrace();
			throw new VCIError("140109", new String[0]);
		}
	}
	
	public static String getRoleName(UserEntity userEntity) {
		String roleName = logSrv.getRoleName(userEntity.getModule(),userEntity.getUserName());
		return roleName;
	}
	
	public static String getModuleAlias(UserEntity userEntity) {
		String moduleAlias = logSrv.getModuleAlias(userEntity.getModule());
		return moduleAlias;
	}
	
	public static String getLogSql(UserEntity userEntity, String optType, String result, String content, LogType logType,String dataObjId, String roleName, String moduleAlias) {
		Date currentDAte = new Date();
		String fmtstr = "yyyy-mm-dd hh24:mi:ss";
		SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
		String dateString = formatter.format(currentDAte);
		StringBuffer sb = new StringBuffer();
		sb.append("insert into pllog (PLOID,PLUSER,PLIP,PLRESULT,PLCONTENT,PLDATE,PLTYPE,PLMODULE,PLLOGTYPE,PLOBJID,PLROLENAME) values(")
		.append("'").append(ObjectUtility.getNewObjectID36()).append("'")
		.append(",'").append(userEntity.getUserName()).append("'")
		.append(",'").append(userEntity.getIp()).append("'")
		.append(",'").append(result).append("'")
		.append(",'").append(content).append("'")
		.append(",to_date('").append(dateString).append("','").append(fmtstr).append("')")
		.append(",'").append(optType).append("'")
		.append(",'").append(moduleAlias).append("'")
		.append(",'").append(getLogTypeString(logType)).append("'")
		.append(",'").append(dataObjId).append("'")
		.append(",'").append(roleName).append("'")
		.append(")");
		return sb.toString();
	}
	
	public static void batchSaveLog(String[] sqls) throws HibernateException, SQLException {
		Session session = HibernateSessionFactory.getSession(); 
		Statement st = session.connection().createStatement();
		for (int i = 0; i < sqls.length; i++) {
			st.addBatch(sqls[i]);
			if ((i + 1) % 200 == 0) {
				st.executeBatch();
			}
		}
		if (sqls.length % 200 != 0) {
			st.executeBatch();
		}
		
		if (st != null) {
			st.close();
			st = null;
		}
	}
	/*public static void writeLog(UserEntity userEntity, String optType, String resContent, LogType logType){
		try{
			Log log = new Log();
			log.setId(ObjectUtility.getNewObjectID36());
			log.setDate(new Date());
			log.setUserIp(userEntity.getIp());
			log.setUsername(userEntity.getUserName());
			log.setResult(resContent);
			log.setType(optType);
			String moduleAlias = logSrv.getModuleAlias(userEntity.getModule());
			if(moduleAlias.equals("")){
				moduleAlias = userEntity.getModule();
			}
			log.setModule(moduleAlias);
			log.setLogType(getLogTypeString(logType));
			String roleName = logSrv.getRoleName(userEntity.getModule(),userEntity.getUserName());
			log.setRoleName(roleName);
			logSrv.saveLog(log);
		}catch (Exception e) {
			e.printStackTrace();
		}
	}*/
	/**
	 * 日志记录
	 * @param userEntity 用户对象
	 * @param optType 操作类别
	 * @param resContent 操作结构
	 * @param logType 日志类型
	 * @throws VCIError 
	 */
	public static void writeLog(UserEntityInfo userEntityInfo, String optType, String result, String content, LogType logType,String objId) throws VCIError{
		writeLog(UserEntityDelegate.changeUserEntityInfoToEntity(userEntityInfo), optType, result, content, logType,objId);
	}
	
	/**
	 * 操作类型转换：将系统传递类型转换为普通文字描述
	 * 
	 * @param logType
	 * @return
	 */
	private static String getLogTypeString(LogType logType){
		String res = "";
		if(logType == LogType.Login) {
			res = "登录";
		} else if(logType == LogType.Logout) {
			res = "登出";
		} else if(logType == LogType.GrantPrivileges) {
			res = "授权";
		} else if(logType == LogType.GeneralOperation) {
			res = "一般操作";
		} else if(logType == LogType.Integration) {
			res = "集成应用";
		} else {
			res = logType.getLabel();
		}
		return res;
	}
}