mom-pro2-after.git

			@@ -25,6 +25,7 @@
			import cn.iocoder.yudao.module.system.dal.dataobject.user.AdminUserDO;
			import cn.iocoder.yudao.module.system.dal.mysql.dept.UserPostMapper;
			import cn.iocoder.yudao.module.system.dal.mysql.user.AdminUserMapper;
			import cn.iocoder.yudao.module.system.mq.producer.user.AdminUserProducer;
			import cn.iocoder.yudao.module.system.service.dept.DeptService;
			import cn.iocoder.yudao.module.system.service.dept.PostService;
			import cn.iocoder.yudao.module.system.service.oauth2.OAuth2TokenService;
			@@ -88,6 +89,9 @@
			@Resource
			private ConfigApi configApi;

			@Resource
			private AdminUserProducer adminUserProducer;

			@Override
			@Transactional(rollbackFor = Exception.class)
			@LogRecord(type = SYSTEM_USER_TYPE, subType = SYSTEM_USER_CREATE_SUB_TYPE, bizNo = "{{#user.id}}",
			@@ -112,6 +116,10 @@
			if (CollectionUtil.isNotEmpty(user.getPostIds())) {
			userPostMapper.insertBatch(convertList(user.getPostIds(),
			postId -> new UserPostDO().setUserId(user.getId()).setPostId(postId)));
			}
			// 2.3 分配用户角色
			if (CollUtil.isNotEmpty(createReqVO.getRoleIds())) {
			permissionService.assignUserRole(user.getId(), createReqVO.getRoleIds());
			}

			// 3. 记录操作日志上下文
			@@ -158,6 +166,8 @@
			userMapper.updateById(updateObj);
			// 2.2 更新岗位
			updateUserPost(updateReqVO, updateObj);
			// 2.3 昵称 / 头像变化时，发送消息供下游订阅（如 IM 模块推 FRIEND_INFO_UPDATED）
			publishUserProfileUpdatedIfChanged(oldUser, updateReqVO.getNickname(), updateReqVO.getAvatar());

			// 3. 记录操作日志上下文
			LogRecordContext.putVariable(DiffParseFunction.OLD_OBJECT, BeanUtils.toBean(oldUser, UserSaveReqVO.class));
			@@ -188,12 +198,30 @@

			@Override
			public void updateUserProfile(Long id, UserProfileUpdateReqVO reqVO) {
			// 校验正确性
			validateUserExists(id);
			// 1. 校验正确性
			AdminUserDO oldUser = validateUserExists(id);
			validateEmailUnique(id, reqVO.getEmail());
			validateMobileUnique(id, reqVO.getMobile());
			// 执行更新

			// 2. 执行更新
			userMapper.updateById(BeanUtils.toBean(reqVO, AdminUserDO.class).setId(id));

			// 3. 昵称 / 头像变化时，发送消息供下游订阅（如 IM 模块推 FRIEND_INFO_UPDATED）
			publishUserProfileUpdatedIfChanged(oldUser, reqVO.getNickname(), reqVO.getAvatar());
			}

			/**
			* 仅当 nickname 或 avatar 跟旧值不一致时，发送 AdminUserProfileUpdateMessage
			*/
			private void publishUserProfileUpdatedIfChanged(AdminUserDO oldUser, String newNickname, String newAvatar) {
			boolean nicknameChanged = newNickname != null && !ObjUtil.equal(oldUser.getNickname(), newNickname);
			boolean avatarChanged = newAvatar != null && !ObjUtil.equal(oldUser.getAvatar(), newAvatar);
			if (!nicknameChanged && !avatarChanged) {
			return;
			}
			adminUserProducer.sendUserProfileUpdateMessage(oldUser.getId(),
			nicknameChanged ? newNickname : null,
			avatarChanged ? newAvatar : null);
			}

			@Override
			@@ -329,6 +357,11 @@
			}
			return userMapper.selectByIds(ids);
			}

			public List<AdminUserDO> getUserListAll() {
			return userMapper.selectList();
			}


			@Override
			public void validateUserList(Collection<Long> ids) {
			@@ -535,6 +568,11 @@
			}

			@Override
			public List<AdminUserDO> getDeptUsers(Collection<Long> deptIds) {
			return userMapper.selectListByDeptIds(deptIds);
			}

			@Override
			public boolean isPasswordMatch(String rawPassword, String encodedPassword) {
			return passwordEncoder.matches(rawPassword, encodedPassword);
			}