会员标签4.0

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

@@ -88,6 +88,7 @@ public class TagProcess {
                                                                 .filter(new Column("real_time").equalTo(2));
         List<TabSceneCrowd> sceneCrowdList=sceneCrowdDataset.collectAsList();
         for(TabSceneCrowd sceneCrowd:sceneCrowdList){
+            System.out.println("sceneCrowd==>"+JSONObject.toJSONString(sceneCrowd));
             LinkedList<TagConditionGroupDTO>conditionGroupDTOList=JSONObject.parseObject(sceneCrowd.getTag_Condition_Group_Info(),  new TypeReference<LinkedList<TagConditionGroupDTO>>(){});
             sceneCrowdDTOList.add(new SceneCrowdDTO(sceneCrowd,conditionGroupDTOList));
         }
@@ -114,7 +115,7 @@ public class TagProcess {
         Map<Integer, List<TagProcessEntity>> tagGroupByEnterpriseMap = new HashMap<>();
         Map<Long, TagFilter> tagIdToFilterMap = new HashMap();
         for(SceneCrowdDTO sceneCrowdDTO:sceneCrowdDTOList){
-            if(sceneCrowdDTO.getReal_Time()==1){
+            if(sceneCrowdDTO.getReal_Time()==2){
                 LinkedList<TagConditionGroupDTO> conditionGroupDTOS=sceneCrowdDTO.getConditionGroupDTOList();
                 for(int i=0;i<conditionGroupDTOS.size();i++){