白名单用户

src/main/java/com/quantgroup/asset/distribution/service/jpa/repository/IChannelRuleRepository.java

@@ -19,4 +19,5 @@ public interface IChannelRuleRepository extends JpaRepository<ChannelRuleEntity,
 
     void deleteAllByChannelIdEqualsAndEnableEquals(Long channelId,Boolean enable);
 
+    List<ChannelRuleEntity> getByChannelIdAndFundProductIdOrderByPriority(long channelId, long fundProductId);
 }

src/main/java/com/quantgroup/asset/distribution/service/newrule/CoreFilter.java

@@ -73,11 +73,19 @@ public class CoreFilter {
 
     @Transactional(rollbackFor = Exception.class)
     public void coreHandle(AuditResponce auditResponce){
-        List<ChannelRuleEntity> channelRuleEntityList = channelRuleRepository.getByChannelIdOrderByPriority(Long.parseLong(auditResponce.getBizChannel()));
+        List<ChannelRuleEntity> channelRuleEntityList;
+        UserAssociationBean associationBean = userCenterService.getUserAssociationBean(auditResponce.getUuid());
+        //白名单
+        WhiteListEntity whiteListEntity = whiteListRepository.getByPhoneEquals(associationBean.getPhoneNo());
+        if (whiteListEntity != null && whiteListEntity.getStatus().equals(Byte.valueOf("1"))) {
+            log.info("白名单用户，phoneNo:{}", associationBean.getPhoneNo());
+            channelRuleEntityList = channelRuleRepository.getByChannelIdAndFundProductIdOrderByPriority(Long.parseLong(auditResponce.getBizChannel()), whiteListEntity.getFundProductId());
+        } else {
+            channelRuleEntityList = channelRuleRepository.getByChannelIdOrderByPriority(Long.parseLong(auditResponce.getBizChannel()));
+        }
         if (CollectionUtils.isEmpty(channelRuleEntityList)){
             throw new RuntimeException("渠道配置产品集不存在，运营人员配置有问题");
         }
-        UserAssociationBean associationBean = userCenterService.getUserAssociationBean(auditResponce.getUuid());
         List<FinanceProduct> financeProducts = new ArrayList<>();
         List<RoutingRecordVO> routingRecordList = new ArrayList<>();
         for (ChannelRuleEntity channelRuleEntity : channelRuleEntityList) {