push

yd-csf-service/src/main/java/com/yd/csf/service/service/impl/PolicyBrokerServiceImpl.java

@@ -59,13 +59,30 @@ public class PolicyBrokerServiceImpl extends ServiceImpl<PolicyBrokerMapper, Pol
         return baseMapper.selectRelatedBrokerBizIds(clientUserId);
     }
 
+//    @Override
+//    public Map<String, PolicyBroker> queryPolicyBrokerMap(Collection<String> policyNoSet) {
+//        if (CollectionUtils.isEmpty(policyNoSet)) {
+//            return Collections.emptyMap();
+//        }
+//        List<PolicyBroker> list = this.lambdaQuery().in(PolicyBroker::getPolicyNo, policyNoSet).list();
+//        return list.stream().collect(Collectors.toMap(PolicyBroker::getPolicyNo, Function.identity(), (oldValue, newValue) -> newValue));
+//    }
+
     @Override
     public Map<String, PolicyBroker> queryPolicyBrokerMap(Collection<String> policyNoSet) {
         if (CollectionUtils.isEmpty(policyNoSet)) {
             return Collections.emptyMap();
         }
-        List<PolicyBroker> list = this.lambdaQuery().in(PolicyBroker::getPolicyNo, policyNoSet).list();
-        return list.stream().collect(Collectors.toMap(PolicyBroker::getPolicyNo, Function.identity(), (oldValue, newValue) -> newValue));
+        List<PolicyBroker> list = this.lambdaQuery()
+                .in(PolicyBroker::getPolicyNo, policyNoSet)
+                .orderByAsc(PolicyBroker::getId)
+                .list();
+
+        return list.stream().collect(Collectors.toMap(
+                PolicyBroker::getPolicyNo,
+                Function.identity(),
+                (existing, replacement) -> existing
+        ));
     }
 
     @Override