会员标签4.0

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

@@ -43,10 +43,8 @@ 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("after:count==>"+consumeRecordRDD.count());
         JavaRDD<Long>ecuRdd=consumeRecordRDD.filter(data->{
                                     boolean result=false;
                                     if(StringUtils.isNotEmpty(data.getReceipts_time())){
@@ -58,7 +56,7 @@ public class TagLowestSingleConsumptionMoneyFilter extends AbstractTagConsumReco
                                                     result=true;
                                                 break;
                                             case LATELY:
-                                                if(receiptsTime.getTime()>DateUtil.addNumForDay(new Date(),consumeAmountRequest.getTimeNum()).getTime()){
+                                                if(receiptsTime.getTime()>DateUtil.addNumForDay(new Date(),-consumeAmountRequest.getTimeNum()).getTime()){
                                                     result=true;
                                                 }
                                                 break;