会员标签4.0

src/main/java/com/gic/spark/tag/TagProcess.java

@@ -126,8 +126,12 @@ public class TagProcess {
                     entity.tagList=conditionGroupDTOS.get(i).getConditionInfos();
                     for(TagConditionDTO conditionDTO:entity.tagList){//将tag同filter进行映射
                         TagFilter tagFilter=TagFilterFactory.getInstance().getTagFilter(conditionDTO.getTagEsFieldName());
+
                         if(null!=tagFilter){
                             tagIdToFilterMap.put(conditionDTO.getTagId(),tagFilter);
+                            for(DataSourceEntity sourceEntity:tagFilter.necessarySourceList()){
+                                System.out.println("tagEsFieldName==>"+conditionDTO.getTagEsFieldName()+" ,SourceKey==>"+sourceEntity.getSourceKey()+" ,HiveTableName==>"+sourceEntity.getHiveTableName());
+                            }
                         }
                     }
 
@@ -145,9 +149,9 @@ public class TagProcess {
                 for (TagConditionDTO conditionDTO : processEntity.tagList) {
                     if (tagIdToFilterMap.containsKey(conditionDTO.getTagId())) {
                         for (DataSourceEntity sourceEntity : tagIdToFilterMap.get(conditionDTO.getTagId()).necessarySourceList()) {
-                            System.out.println("enterpriseId==>"+enterpriseTagEntry.getKey());
-                            System.out.println("SourceKey==>"+sourceEntity.getSourceKey());
-                            System.out.println("HiveTableName==>"+sourceEntity.getHiveTableName());
+//                            System.out.println("enterpriseId==>"+enterpriseTagEntry.getKey());
+//                            System.out.println("SourceKey==>"+sourceEntity.getSourceKey());
+//                            System.out.println("HiveTableName==>"+sourceEntity.getHiveTableName());
                             DataSourceManager.getInstance().addSourceEntity(sourceEntity, enterpriseTagEntry.getKey().intValue());
                         }
                     }