增加日志拦截flume

flume-interceptor/src/main/java/com/org/apache/flume/interceptor/interceptor/InterceptorDataFormatUtil.java

 package com.org.apache.flume.interceptor.interceptor;
 package com.org.apache.flume.interceptor.interceptor;
 
 
+import java.time.LocalDateTime;
 import java.util.ArrayList;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.List;
 
 
 import com.alibaba.fastjson.JSONObject;
 import com.alibaba.fastjson.JSONObject;
+import com.cloud.common.aop.enums.LoggingType;
+import com.cloud.common.aop.enums.RequestModel;
+import com.cloud.common.aop.tools.ServletUtil;
 
 
 /** 
 /** 
 * @author wjs 
 * @author wjs 
@@ -311,4 +315,28 @@ public class InterceptorDataFormatUtil {
 		return arrayList;
 		return arrayList;
 	}
 	}
 
 
+	public static List<String> sysLogDataFormat(JSONObject jsonObj) {
+		List<String> arrayList = new ArrayList<>();
+		arrayList.add(jsonObj.getString("id"));
+		arrayList.add(jsonObj.getString("title"));
+		arrayList.add(jsonObj.getString("method"));
+		arrayList.add(jsonObj.getString("operation_log_type"));
+		arrayList.add(jsonObj.getString("request_method"));
+		arrayList.add(jsonObj.getString("description"));
+		arrayList.add(jsonObj.getString("operate_url"));
+		arrayList.add(jsonObj.getString("operate_address"));
+		arrayList.add(jsonObj.getString("request_param"));
+		arrayList.add(jsonObj.getString("request_body"));
+		arrayList.add(jsonObj.getString("response_body"));
+		arrayList.add(jsonObj.getString("success"));
+		arrayList.add(jsonObj.getString("logging_type"));
+		arrayList.add(jsonObj.getString("error_msg"));
+		arrayList.add(jsonObj.getString("browser"));
+		arrayList.add(jsonObj.getString("system_os"));
+		arrayList.add(jsonObj.getString("create_time"));
+		arrayList.add(jsonObj.getString("operate_name"));
+		arrayList.add(jsonObj.getString("request_headers"));
+		return arrayList;
+	}
+
 }
 }

flume-interceptor/src/main/java/com/org/apache/flume/interceptor/interceptor/InterceptorSelector.java

@@ -59,6 +59,8 @@ public class InterceptorSelector {
 			return dataSplit(InterceptorDataFormatUtil.pcCollectLogDataFormat(jsonObj));
 			return dataSplit(InterceptorDataFormatUtil.pcCollectLogDataFormat(jsonObj));
 		}else if(StringUtils.equals(flume_type, "pcEventLog")) {
 		}else if(StringUtils.equals(flume_type, "pcEventLog")) {
 			return dataSplit(InterceptorDataFormatUtil.pcEventLogDataFormat(jsonObj));
 			return dataSplit(InterceptorDataFormatUtil.pcEventLogDataFormat(jsonObj));
+		}else if(StringUtils.equals(flume_type, "sysLog")) {
+			return dataSplit(InterceptorDataFormatUtil.sysLogDataFormat(jsonObj));
 		}
 		}
 		return resultStr;
 		return resultStr;
 	}
 	}