人员同步重复,bug修复

master
zhaoxiaolin 12 months ago
parent 1706f6be9b
commit 36bf1e057a

@ -592,14 +592,14 @@ public class SysUserServiceImpl implements ISysUserService {
int n = 0;
//sap返回的供应商编码
List<String> codes = dtos.stream().map(HRInfo::getUserCode).collect(Collectors.toList());
List<String> codes = dtos.stream().map(HRInfo::getUserName).collect(Collectors.toList());
//sap返回的工作中心编码-本地已存在
List<String> exsitCodes = userMapper.getExsitCodes(codes);
//sap返回的工作中心编码-本地不存在// 差集 (list2 - list1)
List<String> noExsitCodes = codes.stream().filter(item -> !exsitCodes.contains(item)).collect(Collectors.toList());
List<HRInfo> updates = dtos.stream()
.filter(item -> exsitCodes.contains(item.getUserCode()))
.filter(item -> exsitCodes.contains(item.getUserName()))
.collect(Collectors.toList());
if(!CollectionUtils.isEmpty(updates)){
@ -621,7 +621,7 @@ public class SysUserServiceImpl implements ISysUserService {
System.out.println("人员更新成功条数:"+m);
}
List<HRInfo> adds = dtos.stream()
.filter(item -> noExsitCodes.contains(item.getUserCode()))
.filter(item -> noExsitCodes.contains(item.getUserName()))
.collect(Collectors.toList());
if(!CollectionUtils.isEmpty(adds)){

@ -241,9 +241,9 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
sex = #{item.sex},
del_flag = #{item.delFlag},
update_by = #{item.updateBy},
update_time = #{updateTime}
update_time = #{item.updateTime}
where
user_name = #{item.userCode}
user_name = #{item.userName}
</foreach>
</update>

Loading…
Cancel
Save