会员标签4.0

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

@@ -41,7 +41,6 @@ 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);
@@ -90,7 +89,6 @@ public class TagLowestSingleConsumptionMoneyFilter extends AbstractTagConsumReco
                                         });
 
                                         for(TrdVirtualOrderBean amountBean:effectiveOrderMap.values()){
-                                            System.out.println("configStatus==>"+configStatus+"paid_amt==>"+amountBean.getPaid_amt()+"pay_amt==>"+amountBean.getPay_amt());
 
                                             if(1==configStatus){
                                                 topConsumAmount=null==topConsumAmount?amountBean.getPaid_amt():(amountBean.getPaid_amt()<topConsumAmount?amountBean.getPaid_amt():topConsumAmount);
@@ -102,7 +100,6 @@ public class TagLowestSingleConsumptionMoneyFilter extends AbstractTagConsumReco
                                         }
                                         topConsumAmount=null==topConsumAmount?0:topConsumAmount;
 
-                                        System.out.println("topConsumAmount==>"+topConsumAmount);
                                         switch (consumeAmountRequest.getNumberType()){
                                             case between:
                                                 if(topConsumAmount>=consumeAmountRequest.getBeginNum()
@@ -138,11 +135,8 @@ public class TagLowestSingleConsumptionMoneyFilter extends AbstractTagConsumReco
                                             default:break;
                                         }
                                     }
-                                    System.out.println("result==>"+result.size());
                                     return result.iterator();
                                 });
-        System.out.println("ecuRdd.count==>"+ecuRdd.count());
-        ecuRdd.foreach(data->System.out.println("ecuId==>"+data));
         return ecuRdd;
     }
 }