Commit de54db64 by xugaojun

【11-1迭代】: 修复群发问题

parent e69406b6
......@@ -170,6 +170,6 @@ public interface ExternalClerkRelatedApiService {
* @return map:key-会员id value-导购的wxUserId
* @author: YongEn
*/
Map<String, String> listMemberStaffRel(List<String> memberIdList, List<String> clerkIdList, String enterpriseId);
Map<String, List<String>> listMemberStaffRel(List<String> memberIdList, List<String> clerkIdList, String enterpriseId);
}
......@@ -258,7 +258,7 @@ public class ExternalClerkRelatedApiServiceImpl implements ExternalClerkRelatedA
}
@Override
public Map<String, String> listMemberStaffRel(List<String> memberIdList, List<String> clerkIdList, String enterpriseId) {
public Map<String, List<String>> listMemberStaffRel(List<String> memberIdList, List<String> clerkIdList, String enterpriseId) {
if (CollectionUtils.isEmpty(memberIdList) || CollectionUtils.isEmpty(clerkIdList)) {
// 2个列表都为空查不了关系
return Collections.emptyMap();
......@@ -268,7 +268,16 @@ public class ExternalClerkRelatedApiServiceImpl implements ExternalClerkRelatedA
return Collections.emptyMap();
}
return res.stream()
.collect(Collectors.toMap(MemberStaffRelExtDO::getMemberId, MemberStaffRelExtDO::getStaffWxUserId, (s1, s2) -> s1));
.collect(Collectors.toMap(
// memberId
MemberStaffRelExtDO::getMemberId,
// 重复转集合
e -> new ArrayList<>(Collections.singletonList(e.getStaffWxUserId())),
// 集合添加
(List<String> oldList, List<String> newList) -> {
oldList.addAll(newList);
return oldList;
}));
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment