操作日志

潘钊
1 parent 2987450f
Showing 15 changed files with 618 additions and 131 deletions
src/main/java/com/bsth/Application.java
src/main/java/com/bsth/ServiceStateTest.java
src/main/java/com/bsth/StartCommand.java
src/main/java/com/bsth/WebAppConfiguration.java
src/main/java/com/bsth/data/BasicData.java
src/main/java/com/bsth/oplog/Level.java
src/main/java/com/bsth/oplog/Log.java
src/main/java/com/bsth/oplog/Type.java
src/main/java/com/bsth/oplog/db/DBHelper.java
src/main/java/com/bsth/oplog/db/mysql/DBPersistence.java
src/main/java/com/bsth/oplog/db/mysql/db.sql
src/main/java/com/bsth/oplog/http/HttpOpLogInterceptor.java
src/main/java/com/bsth/oplog/http/HttpRecorder.java
src/main/java/com/bsth/oplog/normal/OpLogger.java
src/main/java/com/bsth/security/SecurityMetadataSourceService.java
@@ -16,7 +16,7 @@ import org.springframework.context.annotation.Primary;
 @SpringBootApplication
 public class Application extends SpringBootServletInitializer {
-	public static ScheduledExecutorService mainServices = Executors.newScheduledThreadPool(11);
+	public static ScheduledExecutorService mainServices = Executors.newScheduledThreadPool(12);
 	@Override
 	protected SpringApplicationBuilder configure(SpringApplicationBuilder application) {
@@ -3,8 +3,8 @@ package com.bsth;
 public class ServiceStateTest {
 	public static void main(String[] args) {
-		System.out.println("运营状态：" + getService(603979776));
-		System.out.println("上下行：" + getUpOrDown(603979776));
+		System.out.println("运营状态：" + getService(268435456));
+		System.out.println("上下行：" + getUpOrDown(268435456));
 	}
 	/**
@@ -23,37 +23,6 @@ public class StartCommand implements CommandLineRunner{
 	@Autowired
 	SecurityMetadataSourceService invocationSecurityMetadataSourceService;
-	//public static ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(8);
-	
-	/*@Autowired
-	GpsRealDataRefreshThread gpsRefreshThread;
-	@Autowired
-	GetSchedulePlanThread getSchedulePlanThread;
-	@Autowired
-	CommonRefreshThread commonRefreshThread;
-	@Autowired
-	DirectivePersistenceThread directivePersistenceThread;
-	@Autowired
-	SchedulePersistenceThread SchedulePersistenceThread;
-	@Autowired
-	ArrivalThread gpsArrivalStationThread;
-	@Autowired
-	FirstScheduleIssuedThread firstScheduleIssuedThread;
-	
-	@Autowired
-	DirectiveService directiveService;
-	@Autowired
-	DirectiveBuffer directiveBuffer;
-	@Autowired
-	CarConfigInfoRepository carConfigInfoRepository;
-	
-	@Autowired
-	GpsOfflineMonitorThread gpsOfflineMonitorThread;*/
-	
-	/*final static Long HOUR_TIME = 1000 * 60 * 60L;
-	
-	final static int HOUR_SECOND = 60 * 60;*/
-	
 	@Override
 	public void run(String... arg0){
@@ -61,91 +30,6 @@ public class StartCommand implements CommandLineRunner{
 			//启动时加载所有资源
 			invocationSecurityMetadataSourceService.loadResourceDefine();
-			/**
-			 * 车辆，设备，公司等常用的映射数据，每两小时刷新一次
-			 *//*
-			commonRefreshThread.start();
-			scheduler.scheduleWithFixedDelay(commonRefreshThread, HOUR_SECOND * 2 , HOUR_SECOND * 2, TimeUnit.SECONDS);
-			//等映射数据加载完......睡一会吧
-			Thread.sleep(4000);
-			
-			*//**
-			 * GPS实时数据更新 线程
-			 * 每8秒和网关HTTP接口同步一次
-			 *//*
-			scheduler.scheduleWithFixedDelay(gpsRefreshThread, 0, 8, TimeUnit.SECONDS);
-			
-			*//**
-			 * GPS 监控设备掉线行为
-			 * 每分钟检测一次
-			 *//*
-			scheduler.scheduleWithFixedDelay(gpsOfflineMonitorThread, 60, 60, TimeUnit.SECONDS);
-			
-			
-			*//**
-			 * 每天 凌晨 2 点 抓取当天实际排班
-			 *//*
-			//启动时先run一次
-			getSchedulePlanThread.start();
-			scheduler.scheduleAtFixedRate(getSchedulePlanThread
-					, ((DateUtils.getTimesnight2() + HOUR_TIME * 2) - System.currentTimeMillis()) / 1000
-					, 60 * 60 * 24, TimeUnit.SECONDS);
-			
-			*//**
-			 * 调度指令两分钟入库一次
-			 * 指令会缓存在内存，直到收到所有响应再入库
-			 *//*
-			//从数据库恢复初始数据
-			directiveBuffer.recovery();
-			scheduler.scheduleWithFixedDelay(directivePersistenceThread, 20, 60 * 2, TimeUnit.SECONDS);
-			
-			*//**
-			 * 每分钟将有变更的班次入库（不包括子任务）
-			 * 单纯为了提高 线调操作 的响应速度
-			 *//*
-			scheduler.scheduleWithFixedDelay(SchedulePersistenceThread, 60 * 1, 60 * 1, TimeUnit.SECONDS);
-			
-			*//**
-			 * 每15秒从数据库抓取到离站信息和班次匹配
-			 * （网关生成的到离站数据也是延迟批量入库，所以缩短该线程执行周期并不会提高 “实际到离站” 的实时性）
-			 *//*
-			scheduler.scheduleWithFixedDelay(gpsArrivalStationThread, 35, 15, TimeUnit.SECONDS);
-			
-			*//**
-			 * 首个调度指令下发（2分钟运行一次）
-			 * 每辆车的第一个调度指令由该线程下发
-			 * 后续班次由 “实际终点到达” 事件触发指令下发
-			 *//*
-			scheduler.scheduleWithFixedDelay(firstScheduleIssuedThread, 60 , 60 * 2, TimeUnit.SECONDS);
-			*/
-			
-/*			new Timer().schedule(new TimerTask() {
-				
-				@Override
-				public void run() {
-					List<CarConfigInfo> ccis = carConfigInfoRepository.findAll();
-					Cars car;
-					Line line;
-					String lineCode;
-					System.out.println("ccis size: " + ccis.size());
-					for(CarConfigInfo cci : ccis){
-						car = cci.getCl();
-						line = cci.getXl();
-						lineCode = line.getLineCode();
-						
-						String data = directiveService.createDeviceRefreshData(CommonMapped.vehicDeviceBiMap.inverse().get(car.getInsideCode())
-								, Integer.parseInt(lineCode));
-						System.out.println(data);
-						int code = HttpUtils.postJson(data);
-						System.out.println("车辆：" + car.getInsideCode() + "刷新线路：" + line.getLineCode());
-						code = directiveService.lineChange(car.getInsideCode(), Integer.parseInt(lineCode));
-						//directiveService.send60Phrase(car.getInsideCode(), "");
-						System.out.println("返回值：" + code);
-					}
-					
-				}
-			}, 1000 * 10);*/
-			
 		} catch (Exception e) {
 			e.printStackTrace();
 		}
@@ -2,18 +2,21 @@ package com.bsth;
 import javax.servlet.Filter;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.context.embedded.FilterRegistrationBean;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.ComponentScan;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.web.filter.CharacterEncodingFilter;
 import org.springframework.web.filter.HttpPutFormContentFilter;
+import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
 import org.springframework.web.servlet.config.annotation.WebMvcConfigurerAdapter;
 import org.springframework.web.socket.config.annotation.EnableWebSocket;
 import org.springframework.web.socket.config.annotation.WebSocketConfigurer;
 import org.springframework.web.socket.config.annotation.WebSocketHandlerRegistry;
 import com.bsth.filter.ResourceFilter;
+import com.bsth.oplog.http.HttpOpLogInterceptor;
 import com.bsth.websocket.WebSocketHandshakeInterceptor;
 import com.bsth.websocket.handler.RealControlSocketHandler;
@@ -22,12 +25,12 @@ import com.bsth.websocket.handler.RealControlSocketHandler;
 @ComponentScan
 public class WebAppConfiguration extends WebMvcConfigurerAdapter implements WebSocketConfigurer{
+	@Autowired
+	HttpOpLogInterceptor httpOpLogInterceptor;
+	
 	/**
-	 * 
 	 * @Title: httpPutFormContentFilter 
 	 * @Description: TODO(弥补浏览器不支持PUT/DELETE，对携带 _method 参数的请求进行转换) 
-	 * @return Filter    返回类型 
-	 * @throws
 	 */
 	@Bean
 	public Filter httpPutFormContentFilter() {
@@ -35,11 +38,8 @@ public class WebAppConfiguration extends WebMvcConfigurerAdapter implements WebS
 	}
 	/**
-	 * 
 	 * @Title: characterEncodingFilter 
 	 * @Description: TODO(编码过滤器) 
-	 * @return Filter    返回类型 
-	 * @throws
 	 */
 	@Bean
 	public Filter characterEncodingFilter(){
@@ -50,8 +50,6 @@ public class WebAppConfiguration extends WebMvcConfigurerAdapter implements WebS
 	 * 
 	 * @Title: resourceFilterRegistration 
 	 * @Description: TODO(静态资源过滤器， 只处理 /pages 目录下的片段请求 ) 
-	 * @return FilterRegistrationBean    返回类型 
-	 * @throws
 	*/
 	@Bean
 	public FilterRegistrationBean resourceFilterRegistration(){
@@ -59,8 +57,18 @@ public class WebAppConfiguration extends WebMvcConfigurerAdapter implements WebS
 		registration.setFilter(new ResourceFilter());
 		registration.addUrlPatterns("/pages/*");
 		return registration;
-	} 
-
+	}
+	
+	/**
+	 * 
+	 * @Title: addInterceptors 
+	 * @Description: TODO(HTTP结构化访问日志记录 ) 
+	
+	@Override
+	public void addInterceptors(InterceptorRegistry registry) {
+		registry.addInterceptor(httpOpLogInterceptor);
+	}*/
+	
 	@Override
 	public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
 		//线调webSocket
@@ -20,6 +20,7 @@ import com.bsth.entity.Line;
 import com.bsth.entity.Station;
 import com.bsth.entity.StationRoute;
 import com.bsth.entity.schedule.CarConfigInfo;
+import com.bsth.oplog.normal.OpLogger;
 import com.bsth.repository.CarParkRepository;
 import com.bsth.repository.CarsRepository;
 import com.bsth.repository.LineRepository;
@@ -100,6 +101,8 @@ public class BasicData implements CommandLineRunner{
 		@Autowired
 		StationRouteRepository stationRouteRepository;
+		@Autowired
+		OpLogger opLog;
 		@Override
 		public void run() {
@@ -119,6 +122,8 @@ public class BasicData implements CommandLineRunner{
 				loadStationRouteInfo();
 				logger.info("加载基础数据成功！，" );
+				
+				opLog.info("load_basic");
 			}catch(Exception e){
 				logger.error("加载基础数据时出现异常，" , e);
 			}
+package com.bsth.oplog;
+
+public enum Level {
+	
+	ERROR,WARN,INFO,ACCESS;
+}
+package com.bsth.oplog;
+
+import java.util.Date;
+
+public class Log {
+
+	private String userName;
+
+	private Long timestamp;
+
+	private String type;
+
+	private String level;
+
+	private String path;
+
+	private String serverIp;
+
+	private String clientIp;
+
+	private String httpData;
+
+	private Date month;
+
+	private String callerClass;
+
+	private String callerMethod;
+	
+	private Integer lineNumber;
+
+	public String getPath() {
+		return path;
+	}
+
+	public void setPath(String path) {
+		this.path = path;
+	}
+
+	public String getServerIp() {
+		return serverIp;
+	}
+
+	public void setServerIp(String serverIp) {
+		this.serverIp = serverIp;
+	}
+
+	public String getHttpData() {
+		return httpData;
+	}
+
+	public void setHttpData(String httpData) {
+		this.httpData = httpData;
+	}
+
+	public Date getMonth() {
+		return month;
+	}
+
+	public void setMonth(Date month) {
+		this.month = month;
+	}
+
+	public String getType() {
+		return type;
+	}
+
+	public void setType(String type) {
+		this.type = type;
+	}
+
+	public String getLevel() {
+		return level;
+	}
+
+	public void setLevel(String level) {
+		this.level = level;
+	}
+
+	public String getCallerClass() {
+		return callerClass;
+	}
+
+	public void setCallerClass(String callerClass) {
+		this.callerClass = callerClass;
+	}
+
+	public String getCallerMethod() {
+		return callerMethod;
+	}
+
+	public void setCallerMethod(String callerMethod) {
+		this.callerMethod = callerMethod;
+	}
+
+	public String getClientIp() {
+		return clientIp;
+	}
+
+	public void setClientIp(String clientIp) {
+		this.clientIp = clientIp;
+	}
+
+	public String getUserName() {
+		return userName;
+	}
+
+	public void setUserName(String userName) {
+		this.userName = userName;
+	}
+
+	public Long getTimestamp() {
+		return timestamp;
+	}
+
+	public void setTimestamp(Long timestamp) {
+		this.timestamp = timestamp;
+	}
+
+	public Integer getLineNumber() {
+		return lineNumber;
+	}
+
+	public void setLineNumber(Integer lineNumber) {
+		this.lineNumber = lineNumber;
+	}
+}
+package com.bsth.oplog;
+
+public enum Type {
+	
+	HTTP_GET,HTTP_POST,HTTP_DELETE,HTTP_PUT,NORMAL
+}
+package com.bsth.oplog.db;
+
+import java.util.LinkedList;
+import java.util.concurrent.TimeUnit;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.CommandLineRunner;
+import org.springframework.stereotype.Component;
+
+import com.bsth.Application;
+import com.bsth.oplog.Log;
+import com.bsth.oplog.db.mysql.DBPersistence;
+
+//@Component
+public class DBHelper implements CommandLineRunner{
+	
+	private final static int maxBufSize = 1000;
+	private final static int fixedMinute = 1;
+	
+	private static LinkedList<Log> buffer = new LinkedList<>();
+	
+	@Autowired
+	private FixedTimePersistenceThread fixedTimeThread;
+	
+	public void save(Log log){
+		buffer.add(log);
+		
+		if(buffer.size() >= maxBufSize)
+			fixedTimeThread.start();
+	}
+	
+	@Component
+	public static class FixedTimePersistenceThread extends Thread{
+		
+		@Autowired
+		DBPersistence persistence;
+		
+		@Override
+		public void run() {
+			persistence.batchSave(buffer);
+		}
+	}
+
+	@Override
+	public void run(String... arg0) throws Exception {
+		Application.mainServices.scheduleWithFixedDelay(fixedTimeThread, fixedMinute, fixedMinute, TimeUnit.MINUTES);
+	}
+}
+package com.bsth.oplog.db.mysql;
+
+import java.sql.Date;
+import java.sql.PreparedStatement;
+import java.sql.SQLException;
+import java.util.ArrayList;
+import java.util.LinkedList;
+import java.util.List;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.core.BatchPreparedStatementSetter;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.stereotype.Component;
+
+import com.bsth.oplog.Log;
+
+/**
+ * 
+ * @ClassName: DBPersistence 
+ * @Description: TODO(mysql 批量入库) 
+ * @author PanZhao 
+ * @date 2016年10月20日 上午9:44:00 
+ *
+ */
+@Component
+public class DBPersistence {
+	
+	@Autowired
+	JdbcTemplate jdbcTemplate;
+	
+	Logger logger = LoggerFactory.getLogger(DBPersistence.class);
+	
+	public void batchSave(LinkedList<Log> list){
+		String sql = "insert into bsth_c_sys_op_log"
+				+ "(timestamp, path, type,level, caller_class, caller_method, user_name, client_ip, server_ip, month, http_data, line_number)"
+				+ " values(?,?,?,?,?,?,?,?,?,?,?,?)";
+		
+		
+		List<Log> saveList = new ArrayList<>(list.size());
+		Log log;
+		while(true){
+			log = list.poll();
+			if(log != null)
+				saveList.add(log);
+			else
+				break;
+		}	
+		
+		Date month = new Date(System.currentTimeMillis());
+		
+		try {
+			jdbcTemplate.batchUpdate(sql, new LogBatchPreparedStatementSetter(saveList, month));
+		} catch (Exception e) {
+			logger.error("操作日志入库失败", e);
+		}
+	}
+	
+	private class LogBatchPreparedStatementSetter implements BatchPreparedStatementSetter{
+
+		List<Log> temList;  
+		Date month;
+	      
+	    public LogBatchPreparedStatementSetter(final List<Log> list, Date month){  
+	        this.temList = list; 
+	        this.month = month;
+	    }
+	    
+		@Override
+		public void setValues(PreparedStatement ps, int i) throws SQLException {
+			Log log = temList.get(i);
+			ps.setLong(1, log.getTimestamp());
+			ps.setString(2, log.getPath());
+			ps.setString(3, log.getType());
+			ps.setString(4, log.getLevel());
+			ps.setString(5, log.getCallerClass());
+			ps.setString(6, log.getCallerMethod());
+			ps.setString(7, log.getUserName());
+			ps.setString(8, log.getClientIp());
+			ps.setString(9, log.getServerIp());
+			ps.setDate(10, month);
+			ps.setString(11, log.getHttpData());
+			ps.setObject(12, log.getLineNumber());
+		}
+
+		@Override
+		public int getBatchSize() {
+			return temList.size();
+		} 
+	}
+}
+CREATE TABLE `bsth_c_sys_op_log` (
+`timestamp`  bigint(20) NOT NULL ,
+`user_name`  varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL ,
+`caller_class`  varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL ,
+`caller_method`  varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL ,
+`client_ip`  varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL ,
+`http_data`  longtext CHARACTER SET utf8 COLLATE utf8_general_ci NULL ,
+`level`  varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL ,
+`month`  date NOT NULL ,
+`path`  varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL ,
+`server_ip`  varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL ,
+`type`  varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
+`line_number`  int(11) NULL DEFAULT NULL 
+)
+ENGINE=InnoDB
+DEFAULT CHARACTER SET=utf8 COLLATE=utf8_general_ci
+ROW_FORMAT=DYNAMIC
+
+PARTITION BY RANGE(TO_DAYS (month))
+(
+PARTITION p201610 VALUES LESS THAN (TO_DAYS('2016-11-01')),
+PARTITION p201611 VALUES LESS THAN (TO_DAYS('2016-12-01')),
+PARTITION p201612 VALUES LESS THAN (TO_DAYS('2017-01-01')),
+
+PARTITION p201701 VALUES LESS THAN (TO_DAYS('2017-02-01')),
+PARTITION p201702 VALUES LESS THAN (TO_DAYS('2017-03-01')),
+PARTITION p201703 VALUES LESS THAN (TO_DAYS('2017-04-01')),
+PARTITION p201704 VALUES LESS THAN (TO_DAYS('2017-05-01')),
+PARTITION p201705 VALUES LESS THAN (TO_DAYS('2017-06-01')),
+PARTITION p201706 VALUES LESS THAN (TO_DAYS('2017-07-01')),
+PARTITION p201707 VALUES LESS THAN (TO_DAYS('2017-08-01')),
+PARTITION p201708 VALUES LESS THAN (TO_DAYS('2017-09-01')),
+PARTITION p201709 VALUES LESS THAN (TO_DAYS('2017-10-01')),
+PARTITION p201710 VALUES LESS THAN (TO_DAYS('2017-11-01')),
+PARTITION p201711 VALUES LESS THAN (TO_DAYS('2017-12-01')),
+PARTITION p201712 VALUES LESS THAN (TO_DAYS('2018-01-01')),
+
+
+PARTITION p201801 VALUES LESS THAN (TO_DAYS('2018-02-01')),
+PARTITION p201802 VALUES LESS THAN (TO_DAYS('2018-03-01')),
+PARTITION p201803 VALUES LESS THAN (TO_DAYS('2018-04-01')),
+PARTITION p201804 VALUES LESS THAN (TO_DAYS('2018-05-01')),
+PARTITION p201805 VALUES LESS THAN (TO_DAYS('2018-06-01')),
+PARTITION p201806 VALUES LESS THAN (TO_DAYS('2018-07-01')),
+PARTITION p201807 VALUES LESS THAN (TO_DAYS('2018-08-01')),
+PARTITION p201808 VALUES LESS THAN (TO_DAYS('2018-09-01')),
+PARTITION p201809 VALUES LESS THAN (TO_DAYS('2018-10-01')),
+PARTITION p201810 VALUES LESS THAN (TO_DAYS('2018-11-01')),
+PARTITION p201811 VALUES LESS THAN (TO_DAYS('2018-12-01')),
+PARTITION p201812 VALUES LESS THAN (TO_DAYS('2019-01-01')),
+
+PARTITION p201901 VALUES LESS THAN (TO_DAYS('2019-02-01')),
+PARTITION p201902 VALUES LESS THAN (TO_DAYS('2019-03-01')),
+PARTITION p201903 VALUES LESS THAN (TO_DAYS('2019-04-01')),
+PARTITION p201904 VALUES LESS THAN (TO_DAYS('2019-05-01')),
+PARTITION p201905 VALUES LESS THAN (TO_DAYS('2019-06-01')),
+PARTITION p201906 VALUES LESS THAN (TO_DAYS('2019-07-01')),
+PARTITION p201907 VALUES LESS THAN (TO_DAYS('2019-08-01')),
+PARTITION p201908 VALUES LESS THAN (TO_DAYS('2019-09-01')),
+PARTITION p201909 VALUES LESS THAN (TO_DAYS('2019-10-01')),
+PARTITION p201910 VALUES LESS THAN (TO_DAYS('2019-11-01')),
+PARTITION p201911 VALUES LESS THAN (TO_DAYS('2019-12-01')),
+PARTITION p201912 VALUES LESS THAN (TO_DAYS('2020-01-01'))
+
+
+);
+
+package com.bsth.oplog.http;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import org.springframework.util.AntPathMatcher;
+import org.springframework.util.PathMatcher;
+import org.springframework.web.method.HandlerMethod;
+import org.springframework.web.servlet.HandlerInterceptor;
+import org.springframework.web.servlet.ModelAndView;
+
+/**
+ * 
+ * @ClassName: HttpOpLogger
+ * @Description: TODO(HTTP 接口日志拦截器)
+ * @author PanZhao
+ * @date 2016年10月20日 上午12:03:11
+ *
+ */
+@Component
+public class HttpOpLogInterceptor implements HandlerInterceptor {
+
+	private final PathMatcher pathMatcher = new AntPathMatcher();
+
+	// GET 白名单
+	private String[] httpGetWhiteList = { "/user/login/**", "/user/currentUser", "/dictionary/**", "/module/findByCurrentUser" };
+
+	// POST 白名单
+	private String[] httpPostWhiteList = {
+
+	};
+	
+	@Autowired
+	HttpRecorder httpRecorder;
+
+	@Override
+	public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object arg2, Exception arg3)
+			throws Exception {
+
+	}
+
+	@Override
+	public void postHandle(HttpServletRequest request, HttpServletResponse response, Object arg2, ModelAndView arg3)
+			throws Exception {
+
+		String method = request.getMethod(), path = request.getRequestURI();
+		// white list
+		String[] whiteList = method == "GET" ? httpGetWhiteList : httpPostWhiteList;
+
+		if (!isWhiteURL(whiteList, path)) 
+			httpRecorder.record(request, (HandlerMethod)arg2);
+	}
+
+	@Override
+	public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object arg2) throws Exception {
+
+		return true;
+	}
+
+	private boolean isWhiteURL(String[] whiteList, String currentURL) {
+		for (String whiteURL : whiteList) {
+			if (pathMatcher.match(whiteURL, currentURL)) {
+				return true;
+			}
+		}
+		return false;
+	}
+}
+package com.bsth.oplog.http;
+
+import java.lang.reflect.Method;
+import java.net.InetAddress;
+import java.net.UnknownHostException;
+
+import javax.servlet.http.HttpServletRequest;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import org.springframework.web.method.HandlerMethod;
+
+import com.alibaba.fastjson.JSON;
+import com.bsth.entity.sys.SysUser;
+import com.bsth.oplog.Level;
+import com.bsth.oplog.Log;
+import com.bsth.oplog.Type;
+import com.bsth.oplog.db.DBHelper;
+import com.bsth.security.util.SecurityUtils;
+import com.bsth.util.IpUtils;
+
+/**
+ * 
+ * @ClassName: HttpRecorder 
+ * @Description: TODO(HTTP 日志记录器) 
+ * @author PanZhao 
+ * @date 2016年10月20日 下午12:56:56 
+ *
+ */
+@Component
+public class HttpRecorder {
+	
+	Logger logger = LoggerFactory.getLogger(HttpRecorder.class);
+	
+	private final static int httpDataMaxLen = 500;
+	
+	@Autowired
+	DBHelper persistenceBuff;
+	
+	public void record(HttpServletRequest request, HandlerMethod method){
+		Log log = new Log();
+		
+		Type type = null;
+		switch (request.getMethod()) {
+		case "GET":
+			type = Type.HTTP_GET;
+			break;
+		case "POST":
+			type = 	Type.HTTP_POST;
+			break;
+		case "DELETE":
+			type = 	Type.HTTP_DELETE;
+			break;
+		case "PUT":
+			type = 	Type.HTTP_PUT;
+			break;
+		}
+		log.setType(type.toString());
+		log.setLevel(Level.INFO.toString());
+		try {
+			log.setServerIp(InetAddress.getLocalHost().getHostAddress());
+		} catch (UnknownHostException e) {
+			e.printStackTrace();
+		}
+		
+		log.setPath(request.getRequestURI());
+		//Caller
+		Method refMethod = method.getMethod();
+		log.setCallerClass(refMethod.getDeclaringClass().getName());
+		log.setCallerMethod(refMethod.getName());
+		
+		//Primary Key
+		log.setTimestamp(System.currentTimeMillis());
+		
+		SysUser user = SecurityUtils.getCurrentUser();
+		if(user != null)
+			log.setUserName(user.getUserName());
+		//request
+		log.setClientIp(IpUtils.getIpAddr(request));
+		log.setHttpData(httpData(request));
+		
+		//save
+		persistenceBuff.save(log);
+	}
+	
+	private String httpData(HttpServletRequest request){
+		String rs = JSON.toJSONString(request.getParameterMap());
+		
+		if(rs.length() > httpDataMaxLen)
+			rs = rs.substring(0, httpDataMaxLen);
+		
+		return rs.replaceAll("\"", "‘");
+	}
+}
+package com.bsth.oplog.normal;
+
+import java.net.InetAddress;
+import java.net.UnknownHostException;
+
+import javax.servlet.http.HttpServletRequest;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import com.bsth.entity.sys.SysUser;
+import com.bsth.oplog.Log;
+import com.bsth.oplog.Type;
+import com.bsth.oplog.db.DBHelper;
+import com.bsth.security.util.SecurityUtils;
+import com.bsth.util.IpUtils;
+
+/**
+ * 
+ * @ClassName: OpLogger 
+ * @Description: TODO(常规的操作日志记录器) 
+ * @author PanZhao 
+ * @date 2016年10月21日 上午12:52:30 
+ *
+ */
+@Component
+public class OpLogger {
+	
+	@Autowired
+	DBHelper dbHelper;
+	
+	public void info(String path){
+		save(getInitLog(path));
+	}
+	
+	public void info(String path, HttpServletRequest request){
+		Log log = getInitLog(path);
+		
+		if(request != null){
+			SysUser user = SecurityUtils.getCurrentUser();
+			if(user != null)
+				log.setUserName(user.getUserName());
+			
+			log.setClientIp(IpUtils.getIpAddr(request));
+		}
+		
+		save(log);
+	}
+	
+	public void info(String path, HttpServletRequest request, String description){
+		
+	}
+	
+	public static Log getInitLog(String path){
+		Log log = new Log();
+		log.setTimestamp(System.currentTimeMillis());
+		log.setPath(path);
+		log.setType(Type.NORMAL.toString());
+		
+		//get caller
+		StackTraceElement[] stack = (new Throwable()).getStackTrace();
+		//注意调用链的顺序，此时2为实际调用者
+		StackTraceElement caller = stack[2];
+		
+		log.setCallerClass(caller.getClassName());
+		log.setCallerMethod(caller.getMethodName());
+		log.setLineNumber(caller.getLineNumber());
+		
+		try {
+			log.setServerIp(InetAddress.getLocalHost().getHostAddress());
+		} catch (UnknownHostException e) {
+			e.printStackTrace();
+		}
+		
+		return log;
+	}
+	
+	public void save(Log log){
+		dbHelper.save(log);
+	}
+}
@@ -66,8 +66,6 @@ public class SecurityMetadataSourceService implements
 		String method = invocation.getRequest().getMethod();
 		String url = method.toLowerCase() + "#" + invocation.getRequestUrl();
-		System.out.println(url);
-		
 		int symIndex = url.indexOf("?");
 		if(symIndex != -1){
 			url = url.substring(0, symIndex);