会员标签4.0

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

@@ -46,7 +46,15 @@ public class TagCurrentCouponNumFilter implements BaseTagFilter {
     public JavaRDD<Long> filterValidMember(Integer enterpriseId, AbstractFilterRequest request) {
         TagCouponRequest couponRequest=(TagCouponRequest)request;
         JavaRDD<TagCouponBean> couponBeanRDD=MysqlRddManager.getPojoFromDataset(dataSourceSharding.getDatasetByEnterpriseId(enterpriseId),TagCouponBean.class).javaRDD()
-                                            .filter(data->(data.getStatus()==3||data.getStatus()==4)&&data.getEffect_End_Time().getTime()>System.currentTimeMillis());
+                                            .filter(data->{
+                                                if(null!=data.getStatus()
+                                                        &&null!=data.getEffect_End_Time()){
+
+                                                    return (data.getStatus()==3||data.getStatus()==4)
+                                                            &&data.getEffect_End_Time().getTime()>System.currentTimeMillis();
+                                                }
+                                                return false;
+                                            });
 
 
         JavaRDD<Long>ecuRDD=couponBeanRDD.mapPartitionsToPair(data->{