会员标签4.0

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

@@ -23,10 +23,16 @@ public class Test {
 //    System.out.println(s);
 //        StringBuilder st=new  StringBuilder();
 
-        String str="{\"dm\":[\"7319\",\"7315\"]}";
-        Map<String,List<String>> map = JSONObject.parseObject(str,HashMap.class);
-        for(List<String> list:map.values()){
-            list.forEach(data->System.out.println("element==>"+data));
-        }
+//        String str="{\"dm\":[\"7319\",\"7315\"]}";
+//        Map<String,List<String>> map = JSONObject.parseObject(str,HashMap.class);
+//        for(List<String> list:map.values()){
+//            list.forEach(data->System.out.println("element==>"+data));
+//        }
+       /* String[] strs="timeRange.fixation".split("\\.");
+        System.out.println(strs.length);
+        System.out.println(strs[0]);*/
+        String[] strs="timeRange,fixation".split(",");
+        System.out.println(strs.length);
+        System.out.println(strs[0]);
     }
 }

src/main/java/com/gic/spark/filter/AbstractTagConsumFilter.java

 package com.gic.spark.filter;
 
+import com.alibaba.fastjson.JSONObject;
 import com.gic.spark.datasource.entity.DataSourceHive;
 import com.gic.spark.entity.bean.TrdEcuSalesLabelBean;
 import com.gic.spark.entity.request.TagConsumeRequest;
@@ -18,6 +19,7 @@ public abstract class AbstractTagConsumFilter implements BaseTagFilter {
     DataSourceHive dataSourceHive = new DataSourceHive(ConstantUtil.ADS_GIC_TRD_ECU_SALES_LABEL_D);
 
     protected static JavaRDD<TrdEcuSalesLabelBean> statisticsTypeHandle(JavaRDD<TrdEcuSalesLabelBean> consumeRDD, TagConsumeRequest consumeRequest){
+        System.out.println("request==>"+ JSONObject.toJSONString(consumeRequest));
         consumeRDD=consumeRDD.mapPartitions(data->{
                                     List<TrdEcuSalesLabelBean> result=new ArrayList();
                                     while (data.hasNext()){

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

@@ -338,7 +338,7 @@ public class TagValueParser {
     private static AbstractFilterRequest getConsumeRequest(List<TagConditionValDTO> conditionValDTOList) {
         TagConsumeRequest request=new TagConsumeRequest();
         for(TagConditionValDTO conditionValDTO:conditionValDTOList){
-
+            System.out.println("conditionValDTO==>"+JSONObject.toJSONString(conditionValDTO));
             if(Pattern.compile("flag").matcher(conditionValDTO.getKey()).find()){
                 setStatisticsTypeHandle(request,conditionValDTO.getKey(),conditionValDTO.getVal());
             }else{
@@ -352,6 +352,7 @@ public class TagValueParser {
             }
 
         }
+        System.out.println("TagConsumeRequest==>"+JSONObject.toJSONString(request));
         return request;
     }