会员标签4.0

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

 package com.gic.spark.filter;
 
+import com.alibaba.fastjson.JSONObject;
 import com.gic.spark.datasource.entity.DataSourceEntity;
 import com.gic.spark.datasource.mysql.MysqlRddManager;
 import com.gic.spark.entity.bean.TrdVirtualOrderBean;
@@ -50,6 +51,8 @@ public class TagOnlineConsumptionStoreFilter extends AbstractTagConsumRecordFilt
                                                                                 .map(data->data._2());
 
         consumeRecordRDD=statisticsTypeHandle(orderRdd,storeRequest);
+        System.out.println("consumeRecordRDD==>"+consumeRecordRDD.count());
+        System.out.println("TagConsumeStoreRequest==>"+ JSONObject.toJSONString(storeRequest));
         JavaRDD<Long>ecuRdd=consumeRecordRDD.filter(data->data.getOrder_channel_code()!=1
                                                 && StringUtils.isNotEmpty(data.getReceipts_time())
                                                 && null!=data.getShop_id())