|
@@ -115,23 +115,34 @@ public class AlarmUserServiceImpl extends ServiceImpl<AlarmUserMapper, AlarmUser
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
- public void getUserInfo(String code) {
|
|
|
+ public String getUserInfo(String code,String orgId) {
|
|
|
WeChatUser userInfo = PushUtil.getUserInfo(code);
|
|
|
log.info("获取用户信息……:{}", userInfo.getOpenid());
|
|
|
if(ObjectUtil.isEmpty(userInfo)) {
|
|
|
throw new CommonException("获取用户信息失败");
|
|
|
}
|
|
|
- AlarmUser alarmUser = getByOpenId(userInfo.getOpenid());
|
|
|
- if (ObjectUtil.isNotNull(alarmUser)) {
|
|
|
- this.updateById(alarmUser);
|
|
|
+ List<AlarmUser> userList = getByOpenId(userInfo.getOpenid(),orgId);
|
|
|
+ AlarmUser alarmUser = BeanUtil.copyProperties(userInfo, AlarmUser.class);
|
|
|
+ alarmUser.setOpenId(userInfo.getOpenid());
|
|
|
+ alarmUser.setUnionId(userInfo.getUnionid());
|
|
|
+ alarmUser.setNickName(userInfo.getNickname());
|
|
|
+ alarmUser.setCreateOrg(orgId);
|
|
|
+ if (!userList.isEmpty()) {
|
|
|
+ for (AlarmUser user : userList) {
|
|
|
+ alarmUser.setId(user.getId());
|
|
|
+ updateById(alarmUser);
|
|
|
+ }
|
|
|
+ return "您已绑定过该组织,已为您更新个人信息";
|
|
|
} else {
|
|
|
this.save(alarmUser);
|
|
|
+ return "绑定成功!";
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- AlarmUser getByOpenId(String openId) {
|
|
|
+ List<AlarmUser> getByOpenId(String openId,String orgId) {
|
|
|
LambdaQueryWrapper<AlarmUser> queryWrapper = new LambdaQueryWrapper<>();
|
|
|
- queryWrapper.eq(AlarmUser::getOpenId, openId).eq(AlarmUser::getDeleteFlag, CommonDeleteFlagEnum.NOT_DELETE);
|
|
|
- return getOne(queryWrapper);
|
|
|
+ queryWrapper.eq(AlarmUser::getOpenId, openId).eq(AlarmUser::getCreateOrg, orgId)
|
|
|
+ .eq(AlarmUser::getDeleteFlag, CommonDeleteFlagEnum.NOT_DELETE);
|
|
|
+ return list(queryWrapper);
|
|
|
}
|
|
|
}
|