会员标签4.0

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

@@ -27,6 +27,9 @@ public class TagFirstConsumptionChannelFilter extends AbstractTagConsumRecordFil
     private static TagFirstConsumptionChannelFilter instance;
 
     public static TagFirstConsumptionChannelFilter getInstance() {
+        if(null==instance){
+            instance=new TagFirstConsumptionChannelFilter();
+        }
         return instance;
     }
     private TagFirstConsumptionChannelFilter(){}
@@ -52,7 +55,6 @@ public class TagFirstConsumptionChannelFilter extends AbstractTagConsumRecordFil
 
         consumeRecordRDD=statisticsTypeHandle(orderRdd,channelRequest);
 
-        System.out.println("channelRequest==>"+ JSONObject.toJSONString(channelRequest));
         JavaRDD<Long>ecuRdd=consumeRecordRDD.filter(data-> StringUtils.isNotEmpty(data.getReceipts_time()))
                                 .mapToPair(data-> Tuple2.apply(data.getEcu_id(),data))
                                 .reduceByKey((x,y)->{
@@ -63,7 +65,6 @@ public class TagFirstConsumptionChannelFilter extends AbstractTagConsumRecordFil
                                         return y;
                                     }
                                 }).filter(data->{
-                                    System.out.println("data==>"+ JSONObject.toJSONString(data));
                                     if(channelRequest.getChannelVals().contains(data._2().getOrder_channel_code())){
                                         return true;
                                     }