会员标签4.0

src/main/java/com/gic/spark/SparkTagProcessByEnterpriseOrId.java

@@ -44,6 +44,6 @@ public class SparkTagProcessByEnterpriseOrId {
         }else{
             return;
         }
-        TagProcessManager.getInstance().process(extractData);
+//        TagProcessManager.getInstance().process(extractData);
     }
 }

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

@@ -99,7 +99,6 @@ public class TagProcessManager {
             LinkedList<TagConditionGroupDTO>conditionGroupDTOList=JSONObject.parseObject(sceneCrowd.getTag_Condition_Group_Info(),  new TypeReference<LinkedList<TagConditionGroupDTO>>(){});
             sceneCrowdDTOList.add(new SceneCrowdDTO(sceneCrowd,conditionGroupDTOList));
         }
-        System.out.println("sceneCrowdDTOList==>"+JSONObject.toJSONString(sceneCrowdDTOList));
         List<TabDataActuallyPaidConfig>dataActuallyPaidConfigList=enterprise4RddManager.getPojo("tab_data_actually_paid_config",TabDataActuallyPaidConfig.class,null)
                                                                                             .filter(new Column("status").equalTo(1))
                                                                                             .collectAsList();
@@ -143,7 +142,7 @@ public class TagProcessManager {
 
                     entity.tagList=conditionGroupDTOS.get(i).getConditionInfos();
                     for(TagConditionDTO conditionDTO:entity.tagList){//将tag同filter进行映射
-                        TagFilter tagFilter=TagFilterFactory.getInstance().getTagFilter(conditionDTO.getTagEsFieldName());
+                        TagFilter tagFilter=TagFilterFactory.getInstance().getTagFilter(conditionDTO);
 
                         if(null!=tagFilter){
                             tagIdToFilterMap.put(conditionDTO.getTagId(),tagFilter);