| | |
|---|
| | | boolean needUpdateWx = false; |
|---|
| | | if (currentWxOpenid != null && !currentWxOpenid.trim().isEmpty()) { |
|---|
| | | if (user.getWxOpenid() == null || !currentWxOpenid.equals(user.getWxOpenid())) { |
|---|
| | | // 检查这个openid是否已经被其他用户使用 |
|---|
| | | Optional<User> existingUserWithOpenid = userRepository.findByWxOpenid(currentWxOpenid); |
|---|
| | | if (existingUserWithOpenid.isEmpty() || existingUserWithOpenid.get().getId().equals(user.getId())) { |
|---|
| | | user.setWxOpenid(currentWxOpenid); |
|---|
| | | needUpdateWx = true; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | if (currentWxUnionid != null && !currentWxUnionid.trim().isEmpty()) { |
|---|
| | | if (user.getWxUnionid() == null || !currentWxUnionid.equals(user.getWxUnionid())) { |
|---|
| | | // 检查这个unionid是否已经被其他用户使用 |
|---|
| | | Optional<User> existingUserWithUnionid = userRepository.findByWxUnionid(currentWxUnionid); |
|---|
| | | if (existingUserWithUnionid.isEmpty() || existingUserWithUnionid.get().getId().equals(user.getId())) { |
|---|
| | | user.setWxUnionid(currentWxUnionid); |
|---|
| | | needUpdateWx = true; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | if (needUpdateWx) { |
|---|
| | | logger.info("覆盖用户(wx)标识：phone匹配的用户ID={}, 使用当前登录用户ID={} 的 openid/unionid 覆盖", user.getId(), currentUserId); |
|---|
| | | } |
|---|
