会员标签4.0

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

@@ -43,9 +43,10 @@ public class TagLowestSingleConsumptionMoneyFilter extends AbstractTagConsumReco
         TagConsumeAmountRequest consumeAmountRequest=(TagConsumeAmountRequest)request;
         System.out.println("consumeAmountRequest==>"+ JSONObject.toJSONString(consumeAmountRequest));
         JavaRDD<TrdVirtualOrderBean>consumeRecordRDD= MysqlRddManager.getPojoFromDataset(dataSourceHive.getDatasetByEntId(enterpriseId), TrdVirtualOrderBean.class).javaRDD();
+        System.out.println("before:count==>"+consumeRecordRDD.count());
         consumeRecordRDD=statisticsTypeHandle(consumeRecordRDD,consumeAmountRequest);
         int configStatus= CommonUtil.getConfigStatus(enterpriseId);
-        System.out.println("count==>"+consumeRecordRDD.count());
+        System.out.println("after:count==>"+consumeRecordRDD.count());
         JavaRDD<Long>ecuRdd=consumeRecordRDD.filter(data->{
                                     boolean result=false;
                                     if(StringUtils.isNotEmpty(data.getReceipts_time())){