package com.vci.server.framework.delegate;
|
|
import java.text.SimpleDateFormat;
|
import java.util.HashMap;
|
import java.util.HashSet;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Set;
|
|
import com.vci.common.utility.ObjectUtility;
|
import com.vci.corba.common.VCIError;
|
import com.vci.corba.framework.data.LogInfo;
|
import com.vci.corba.framework.data.LogPeriodInfo;
|
import com.vci.corba.framework.data.SystemCfgInfo;
|
import com.vci.corba.common.data.UserEntityInfo;
|
import com.vci.corba.framework.data.UserInfo;
|
import com.vci.server.base.delegate.UserEntityDelegate;
|
import com.vci.server.framework.systemConfig.SystemCfg;
|
import com.vci.server.framework.systemConfig.log.Log;
|
import com.vci.server.framework.systemConfig.log.LogPeriod;
|
import com.vci.server.framework.systemConfig.log.LogService;
|
|
public class LogManagementDelegate {
|
|
/**
|
* 在初始化日志模块时，检查是否配置了自动删除
|
* @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<Log> 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(list.get(i));
|
|
if (!userIds.contains(logInfos[i].username))
|
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;
|
}
|
|
/**
|
* 根据查询条件获取日志信息
|
* <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<Log> 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(list.get(i));
|
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(SystemCfgInfo info,UserEntityInfo userEntityInfo) throws VCIError{
|
boolean res = false;
|
String id = ObjectUtility.getNewObjectID36();
|
try {
|
LogService logSrv = new LogService();
|
info.id = id;
|
UserEntityDelegate.setUserEntityToService(logSrv, userEntityInfo);
|
res = logSrv.savePeriod(changeSysCfgInfoToObj(info));
|
} catch (Exception e) {
|
e.printStackTrace();
|
throw new VCIError("140106", new String[]{});//保存期限出错，请重试！
|
}
|
return res ;
|
}
|
|
/**
|
* 获取保存/备份期限值
|
* @param type
|
* @return
|
* @throws VCIError
|
*/
|
public int getCurPeriod(String type) throws VCIError{
|
int period = 0;
|
try {
|
LogService logSrv = new LogService();
|
period = logSrv.getCurPeriod(type);
|
} 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;
|
}
|
|
|
|
|
/**
|
* 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;
|
}
|
}
|
