优先级

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

@@ -9,7 +9,7 @@ import java.util.List;
 public interface IChannelRuleRepository extends JpaRepository<ChannelRuleEntity, Long>, QueryDslPredicateExecutor<ChannelRuleEntity> {
     ChannelRuleEntity getByFundProductIdEquals(long fundProductId);
 
-    List<ChannelRuleEntity> getByChannelId(long channelId);
+    List<ChannelRuleEntity> getByChannelIdAndOrderByPriority(long channelId);
 
     List<ChannelRuleEntity> getAllByEnableEquals(Boolean enable);
 

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

@@ -73,7 +73,7 @@ public class CoreFilter {
 
     @Transactional(rollbackFor = Exception.class)
     public void coreHandle(AuditResponce auditResponce){
-        List<ChannelRuleEntity> channelRuleEntityList = channelRuleRepository.getByChannelId(Long.parseLong(auditResponce.getBizChannel()));
+        List<ChannelRuleEntity> channelRuleEntityList = channelRuleRepository.getByChannelIdAndOrderByPriority(Long.parseLong(auditResponce.getBizChannel()));
         if (CollectionUtils.isEmpty(channelRuleEntityList)){
             throw new RuntimeException("渠道配置产品集不存在，运营人员配置有问题");
         }