会员标签4.0

src/main/java/com/gic/spark/filter/TagLowestSingleConsumptionMoneyFilter.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;
@@ -40,10 +41,11 @@ public class TagLowestSingleConsumptionMoneyFilter extends AbstractTagConsumReco
     @Override
     public JavaRDD<Long> filterValidMember(Integer enterpriseId, AbstractFilterRequest request) {
         TagConsumeAmountRequest consumeAmountRequest=(TagConsumeAmountRequest)request;
+        System.out.println("consumeAmountRequest==>"+ JSONObject.toJSONString(consumeAmountRequest));
         JavaRDD<TrdVirtualOrderBean>consumeRecordRDD= MysqlRddManager.getPojoFromDataset(dataSourceHive.getDatasetByEntId(enterpriseId), TrdVirtualOrderBean.class).javaRDD();
         consumeRecordRDD=statisticsTypeHandle(consumeRecordRDD,consumeAmountRequest);
         int configStatus= CommonUtil.getConfigStatus(enterpriseId);
-
+        System.out.println("count==>"+consumeRecordRDD.count());
         JavaRDD<Long>ecuRdd=consumeRecordRDD.filter(data->{
                                     boolean result=false;
                                     if(StringUtils.isNotEmpty(data.getReceipts_time())){