add: 同步用户信息;
This commit is contained in:
@@ -41,11 +41,6 @@ public class OnlineUserDto {
|
|||||||
*/
|
*/
|
||||||
private String nickName;
|
private String nickName;
|
||||||
|
|
||||||
/**
|
|
||||||
* 用户姓名
|
|
||||||
*/
|
|
||||||
private String person_name;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 岗位
|
* 岗位
|
||||||
*/
|
*/
|
||||||
|
|||||||
@@ -84,12 +84,12 @@ public class EasBillSchedule {
|
|||||||
//@Scheduled(cron = "0/120 * * * * *")
|
//@Scheduled(cron = "0/120 * * * * *")
|
||||||
public void insertUsers(List<SysUser> existingUsers, List<SysUser> newUsers) {
|
public void insertUsers(List<SysUser> existingUsers, List<SysUser> newUsers) {
|
||||||
Set<String> ids = existingUsers.stream().map(SysUser::getUsername).collect(Collectors.toSet());
|
Set<String> ids = existingUsers.stream().map(SysUser::getUsername).collect(Collectors.toSet());
|
||||||
// 过滤出需要插入的新用户,并设置默认属性
|
|
||||||
List<SysUser> insertUsers = newUsers.stream()
|
List<SysUser> insertUsers = newUsers.stream()
|
||||||
.filter(user -> !ids.contains(user.getUsername()))
|
.filter(user -> !ids.contains(user.getUsername()))
|
||||||
.peek(user -> {
|
.peek(user -> {
|
||||||
user.setIs_used(true); // 设置默认启用
|
//默认启用
|
||||||
user.setCreate_time(new Date()); // 设置创建时间
|
user.setIs_used(true);
|
||||||
|
user.setCreate_time(new Date());
|
||||||
})
|
})
|
||||||
.collect(Collectors.toList());
|
.collect(Collectors.toList());
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user