package com.vci.server.framework.systemConfig.log;
|
|
import java.io.File;
|
import java.text.SimpleDateFormat;
|
import java.util.ArrayList;
|
import java.util.Calendar;
|
import java.util.Date;
|
import java.util.GregorianCalendar;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Timer;
|
import java.util.TimerTask;
|
|
import org.apache.commons.lang3.StringUtils;
|
import org.hibernate.Transaction;
|
|
import com.vci.client.common.excel.SheetDataSet;
|
import com.vci.common.log.ServerWithLog4j;
|
import com.vci.common.resource.CommonProperties;
|
import com.vci.corba.framework.data.UserInfo;
|
import com.vci.server.base.persistence.dao.HibernateSessionFactory;
|
import com.vci.server.framework.delegate.RightManagementDelegate;
|
|
public class LogAutoControlUtil {
|
|
private Timer timer = null;
|
private TimerTask timerTask = null;
|
private final String AUTO_DELETE_RATE = "log.autoDelete.rate";//自动删除执行频率
|
private final String AUTO_DELETE_TIME = "log.autoDelete.time";//每天启动自动任务的时间
|
private final String LOG_SAVE_PERIOD = "logSavePeriod";//日志保存期限
|
private final String AUTO_DELETE_BACK_PATH = "log.autoDelete.backPath";//备份的文件夹
|
private Calendar cal = Calendar.getInstance();
|
private long period = 24*60*60*1000;//执行周期，配置文件里配置，这里初始化为1天
|
private static LogAutoControlUtil instance = null;
|
|
public synchronized static LogAutoControlUtil getInstance(){
|
if(instance == null){
|
instance = new LogAutoControlUtil();
|
}
|
return instance;
|
}
|
|
/**
|
* 自动任务的入口
|
*/
|
public void startLogDeleteMonitoring(){
|
timer = new Timer();
|
timerTask = new TimerTask(){
|
@Override
|
public void run() {
|
autoDeleteTask();//执行自动删除
|
}
|
|
};
|
period = this.getPeriod() == 0 ? period : this.getPeriod();//如果无配置，则使用默认值
|
int year = cal.get(Calendar.YEAR);//年
|
int month = cal.get(Calendar.MONTH);//月
|
int day = cal.get(Calendar.DAY_OF_MONTH);//日
|
int times[] = this.getTimeOfDay();//时分秒为手动配置的
|
int hour = times[0];//时
|
int minute = times[1];//分
|
int seconds = times[2];//秒
|
Calendar calendar = new GregorianCalendar(year,month,day,hour,minute,seconds);
|
timer.scheduleAtFixedRate(timerTask, calendar.getTime(), period);
|
}
|
|
/**
|
* 获取用户配置的执行起始时间
|
* @return
|
*/
|
private int[] getTimeOfDay(){
|
String times = "";
|
int time[] = new int[3];
|
times = CommonProperties.getStringProperty(AUTO_DELETE_TIME);
|
String temp[] = times.split("::");
|
if(temp.length >=3){
|
time[0] = Integer.parseInt(temp[0]);
|
time[1] = Integer.parseInt(temp[1]);
|
time[2] = Integer.parseInt(temp[2]);
|
}
|
return time;
|
}
|
|
/**
|
* 取得配置的自动任务执行周期
|
* @return
|
*/
|
private long getPeriod(){
|
String days = "";
|
long res = 0;
|
days = CommonProperties.getStringProperty(AUTO_DELETE_RATE);
|
if(!days.equals("")&&days != null){
|
res = Long.valueOf(days);
|
}
|
return res*24*60*60*1000;//转化成毫秒
|
}
|
|
/**
|
* 自动任务执行的核心方法
|
*/
|
private void autoDeleteTask(){
|
ServerWithLog4j.logger.info("日志删除自动任务启动...................");
|
LogService logSrv = new LogService();
|
int curPeriod = logSrv.getCurPeriod(LOG_SAVE_PERIOD);//获取当前设置期限
|
if(curPeriod<1){
|
return ;
|
}
|
StringBuffer whereSql = new StringBuffer();
|
boolean flag = false;
|
whereSql.append(" trunc(PLDATE) < add_months(trunc(sysdate),"+(-curPeriod)+")");
|
//导出excel
|
//先查询出来的数据
|
List<Log> logList = logSrv.getLogListBySql(whereSql.toString());
|
long logCount = logList.size();//查找出超出期限的日志
|
ServerWithLog4j.logger.info("需要删除的日志条数为："+logCount);
|
|
List<List<Log>> logCollection = switchListForOracleIn(logList,60000);
|
String excelFilePrefix = "自动备份日志" + (new SimpleDateFormat("yyyyMMddHHmmss").format(new Date()));
|
if(logCount != 0){
|
for(int i = 0 ; i < logCollection.size() ; i++){
|
List<Log> logs = logCollection.get(i);
|
try{
|
writeLog2Excel(logs,excelFilePrefix,i);
|
}catch(Exception e){
|
e.printStackTrace();
|
ServerWithLog4j.logger.error("备份日志文件出错",e);
|
}
|
}
|
Transaction t = HibernateSessionFactory.getSession().beginTransaction();
|
|
String sql = "delete from pllog where pltype<>'删除日志' and "+whereSql.toString();
|
flag = logSrv.deleteLogBySql(sql, curPeriod);
|
t.commit();
|
ServerWithLog4j.logger.info("删除日志"+(flag == true?"成功！":"失败！"));
|
}
|
ServerWithLog4j.logger.info("日志删除自动任务退出...................");
|
}
|
|
private void writeLog2Excel(List<Log> logs,String excelFilePrefix,int sub) throws Exception{
|
String excel = excelFilePrefix + "_" + sub + ".xls";
|
|
//转换为二维数组
|
List<String[]> lstData = new ArrayList<String[]>();
|
String[][] data = new String[logs.size()+1][8];
|
//data[0] = new String[]{"用户名","姓名","用户IP","模块","操作","时间","操作结果","描述"};
|
lstData.add(new String[]{"用户名","姓名","用户IP","模块","操作","时间","操作结果","描述"});
|
//需要查询用户的信息
|
List<String> userIdList = new ArrayList<String>();
|
for(Log log : logs){
|
String userName = log.getUsername();
|
if(!userIdList.contains(userName)){
|
userIdList.add(userName);
|
}
|
};
|
List<List<String>> userIdCollection = switchListForOracleIn(userIdList,500);
|
Map<String,String> userInfoMap = new HashMap<String,String>();
|
for(List<String> userIds :userIdCollection ){
|
UserInfo[] userInfos = new RightManagementDelegate().fetchUserInfoByNames(userIds.toArray(new String[0]));
|
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 < logs.size(); i++){
|
Log log = logs.get(i);
|
String[] row = new String[8];
|
row[0] = log.getUsername();
|
row[1] = userInfoMap.containsKey(log.getUsername())?userInfoMap.get(log.getUsername()):"";
|
row[2] = log.getUserIp();
|
row[3] = log.getModule();
|
row[4] = log.getType();
|
row[5] = date2Str(log.getDate(),"yyyy-MM-dd HH:mm:ss");//时间
|
String result = "操作成功";
|
String memo = log.getResult();
|
if(StringUtils.isNotBlank(memo)){
|
boolean hasResult =false;
|
if(memo.startsWith("操作") && memo.length()>4){
|
result = memo.substring(0,4);
|
hasResult = true;
|
}
|
if((memo.startsWith("登入") || memo.startsWith("登出"))&& memo.length()>4){
|
result = memo.substring(0,4);
|
hasResult = true;
|
}
|
if(memo.length()>5 && hasResult){
|
memo = memo.substring(5);
|
}else{
|
//memo = "";
|
}
|
}
|
row[6]=result;//结果
|
row[7]=memo;//描述
|
//data[i+1] = row;
|
lstData.add(row);
|
}
|
//处理文件
|
String tempFolderPath = CommonProperties.getStringProperty(AUTO_DELETE_BACK_PATH);
|
if(StringUtils.isBlank(tempFolderPath)){
|
tempFolderPath = this.getClass().getResource("/").getPath() + File.separator + "logsBack";
|
}
|
File folder = new File(tempFolderPath);
|
if(!folder.exists()){
|
folder.mkdirs();
|
}
|
File excelFile = new File(tempFolderPath+ File.separator +excel);
|
excelFile.createNewFile();
|
|
SheetDataSet ds = new SheetDataSet();
|
ds.setDataSet(lstData);
|
ds.setSheet("日志备份");
|
|
//ExcelDocumentUtils.writeExcelDocument(excelFile.getPath(), "日志备份", ds);
|
|
ServerWithLog4j.logger.info("导出" + logs.size() + "条日志到excel文件:" +excelFile.getAbsolutePath() );
|
}
|
|
/**
|
* 时间转换
|
* @param d
|
* @param formate
|
* @return
|
*/
|
private String date2Str(Date d,String formate){
|
SimpleDateFormat sdf = new SimpleDateFormat(formate);
|
return sdf.format(d);
|
}
|
|
/**
|
* oracle in 查询不能超过1000，转换一下集合
|
* 由于SQL语句1000个可能很长，超过oracle10g，所以牺牲性能分配为500个数组
|
* @param list 需要转换的列表内容
|
* @return 分组后的list
|
*/
|
private <T> List<List<T>> switchListForOracleIn(List<T> list,int size) {
|
List<List<T>> listHasList = new ArrayList<List<T>>();
|
if(list == null){
|
return listHasList;
|
}
|
List<T> newList = new ArrayList<T>();
|
for(Object obj : list){
|
//为了让list还可以添加内容，因为使用sublist后，list不能再Add了
|
newList.add((T)obj);
|
}
|
int muti = 1;
|
if(newList.size() >size){
|
int balance = newList.size()%size;
|
muti = (newList.size() - balance)/size + (balance == 0?0:1);
|
}
|
for(int i = 0 ; i < muti; i ++){
|
int start = i*size;
|
int end = start + size;
|
if(i == muti-1 || end >newList.size() ){
|
end = newList.size();
|
}
|
List subList = newList.subList(start,end);
|
listHasList.add(subList);
|
}
|
return listHasList;
|
}
|
|
|
public static void main(String[] args){
|
|
// Thread t1 = new Thread(){
|
// public void run(){
|
// LogAutoControlUtil.getInstance().startLogDeleteMonitoring();
|
// System.err.println("Thread1..........................");
|
// }
|
// };
|
//
|
// Thread t2 = new Thread(){
|
// Timer time = new Timer();
|
// public void run(){
|
// System.err.println("Thread2..........................");
|
// time.schedule(new TimerTask(){
|
// int i = 0;
|
// @Override
|
// public void run() {
|
// System.err.println("i="+i++);
|
// }
|
//
|
// }, 1000,1000);
|
// }
|
// };
|
// t1.start();
|
// t2.start();
|
}
|
//
|
}
|
