好友拦截器提交

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

@@ -140,4 +140,38 @@ public class InterceptorDataFormatUtil {
 		return arrayList;
 	}
 	
+	public static List<String> userFriendsDataFormat(JSONObject jsonObj) {
+		List<String> arrayList = new ArrayList<>();
+		arrayList.add(jsonObj.getString("friend_cid"));
+		arrayList.add(jsonObj.getString("self_cid"));
+		arrayList.add(jsonObj.getString("nick"));
+		arrayList.add(jsonObj.getString("remarks"));
+		arrayList.add(jsonObj.getString("add_time"));
+		arrayList.add(jsonObj.getString("create_time"));
+		return arrayList;
+	}
+	
+	public static List<String> userGroupsDataFormat(JSONObject jsonObj) {
+		List<String> arrayList = new ArrayList<>();
+		arrayList.add(jsonObj.getString("cid"));
+		arrayList.add(jsonObj.getString("group_id"));
+		arrayList.add(jsonObj.getString("group_name"));
+		arrayList.add(jsonObj.getString("add_time"));
+		arrayList.add(jsonObj.getString("create_time"));
+		return arrayList;
+	}
+	
+	public static List<String> userInfoDataFormat(JSONObject jsonObj) {
+		List<String> arrayList = new ArrayList<>();
+		arrayList.add(jsonObj.getString("cid"));
+		arrayList.add(jsonObj.getString("country_code"));
+		arrayList.add(jsonObj.getString("phone_number"));
+		arrayList.add(jsonObj.getString("nick"));
+		arrayList.add(jsonObj.getString("uesr_create_time"));
+		arrayList.add(jsonObj.getString("user_state"));
+		arrayList.add(jsonObj.getString("user_head_url"));
+		arrayList.add(jsonObj.getString("create_time"));
+		return arrayList;
+	}
+	
 }

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

@@ -31,8 +31,12 @@ public class InterceptorSelector {
 			return dataSplit(InterceptorDataFormatUtil.sminCommunityAiClassDataFormat(jsonObj));
 		}else if(StringUtils.equals(flume_type, "sminCommunityCollect")) {
 			return dataSplit(InterceptorDataFormatUtil.sminCommunityCollectDataFormat(jsonObj));
-		}else if(StringUtils.equals(flume_type, "openApi")) {
-			return dataSplit(InterceptorDataFormatUtil.openApiDataFormat(jsonObj));
+		}else if(StringUtils.equals(flume_type, "userFriends")) {
+			return dataSplit(InterceptorDataFormatUtil.userFriendsDataFormat(jsonObj));
+		}else if(StringUtils.equals(flume_type, "userGroups")) {
+			return dataSplit(InterceptorDataFormatUtil.userGroupsDataFormat(jsonObj));
+		}else if(StringUtils.equals(flume_type, "userInfo")) {
+			return dataSplit(InterceptorDataFormatUtil.userInfoDataFormat(jsonObj));
 		}
 		return resultStr;
 	}