diff --git a/src/main/java/com/yunhai/userbase/controller/oapi/GroupController.java b/src/main/java/com/yunhai/userbase/controller/oapi/GroupController.java
index 62108c9..7a07e9a 100644
--- a/src/main/java/com/yunhai/userbase/controller/oapi/GroupController.java
+++ b/src/main/java/com/yunhai/userbase/controller/oapi/GroupController.java
@@ -79,7 +79,7 @@ public class GroupController {
}
/**
- * 编辑组（不含移动，移动请走 group/move 后台接口）：返回更新后的组节点（含 id）。
+ * 编辑组（不含移动，移动请走 group/move/{schoolId} 开放接口或后台 Move）：返回更新后的组节点（含 id）。
*/
@PostMapping("edit/{id}")
public BoaGroup edit(@PathVariable Integer id,
diff --git a/src/main/java/com/yunhai/userbase/controller/oapi/UserController.java b/src/main/java/com/yunhai/userbase/controller/oapi/UserController.java
index 9623605..6a812ec 100644
--- a/src/main/java/com/yunhai/userbase/controller/oapi/UserController.java
+++ b/src/main/java/com/yunhai/userbase/controller/oapi/UserController.java
@@ -6,13 +6,16 @@ import com.yunhai.platform.utils.model.BoaGroup;
import com.yunhai.platform.utils.model.BoaModule;
import com.yunhai.platform.utils.model.BoaRoleInfo;
import com.yunhai.platform.utils.model.BoaUser;
+import com.yunhai.userbase.common.annotation.OapiLog;
import com.yunhai.userbase.common.validation.ValidationGroups;
import com.yunhai.userbase.config.Config;
import com.yunhai.userbase.entity.ApplicationInfo;
import com.yunhai.userbase.model.sysuser.SysUserGroupDeleteItem;
+import com.yunhai.userbase.model.sysuser.SysUserGroupStateRequest;
import com.yunhai.userbase.model.sysuser.SysUserMoveRequest;
import com.yunhai.userbase.model.sysuser.SysUserPasswordRequest;
import com.yunhai.userbase.model.sysuser.SysUserRequest;
+import com.yunhai.userbase.model.sysuser.SysUserTransferSchoolRequest;
import com.yunhai.userbase.repository.ApplicationInfoRepository;
import com.yunhai.userbase.service.IGroupAuthzService;
import com.yunhai.userbase.service.ISysUserService;
@@ -230,4 +233,43 @@ public class UserController {
public void password(@RequestBody @Validated SysUserPasswordRequest request) {
sysUserService.changePassword(request.getUserId(), request.getOldPassword(), request.getNewPassword());
}
+
+ /**
+ * 设置用户在指定组上的状态（转出/恢复）。
+ * state=1 转出、state=0 恢复正常；仅作关系标记，不影响成员查询、组织链与下游推送。
+ * 仅允许在同一学校（组）范围内操作——groupId 必须属于 schoolId 子树且不等于 schoolId。
+ * 鉴权由过滤器层强制签名；POST 自动记 OapiLog。
+ */
+ @PostMapping("groupState")
+ public void groupState(@RequestBody @Validated SysUserGroupStateRequest request) {
+ sysUserService.changeUserGroupState(request.getUserId(), request.getGroupId(),
+ request.getSchoolId(), request.getState());
+ }
+
+ /**
+ * 查询用户在指定组上的状态：0=正常，1=转出。
+ * 边界与设置接口一致（groupId 必须属于 schoolId 子树且不等于 schoolId）；
+ * 用户不在此组时返回业务错误（code=5）。
+ */
+ @OapiLog(value = "查询用户组状态", saveResponse = false)
+ @GetMapping("groupState")
+ public Integer groupState(@RequestParam("userId") Integer userId,
+ @RequestParam("groupId") Integer groupId,
+ @RequestParam("schoolId") Integer schoolId) {
+ return sysUserService.getUserGroupState(userId, groupId, schoolId);
+ }
+
+ /**
+ * 跨校转入（转出后迁移到其他学校）。
+ * 前置：用户已在原学校（fromSchoolId 子树内）存在至少一条「转出」状态的组关系（先经 groupState 置转出）；
+ * 操作成功后：删除原学校范围内全部组关系（其他学校保留），在目标学校建立目标组关系
+ * （主归属、状态恢复正常），并推送编辑用户订阅。
+ * 鉴权由过滤器层强制签名；POST 自动记 OapiLog。
+ */
+ @PostMapping("transferToSchool")
+ public BoaUser transferToSchool(@RequestBody @Validated SysUserTransferSchoolRequest request) {
+ sysUserService.transferUserToSchool(request.getUserId(), request.getFromSchoolId(),
+ request.getSchoolId(), request.getGroupId());
+ return userCenterService.getUserInfoWithDeptById(request.getUserId());
+ }
}
diff --git a/src/main/java/com/yunhai/userbase/entity/SysUserGroupRel.java b/src/main/java/com/yunhai/userbase/entity/SysUserGroupRel.java
index de68291..b5df70d 100644
--- a/src/main/java/com/yunhai/userbase/entity/SysUserGroupRel.java
+++ b/src/main/java/com/yunhai/userbase/entity/SysUserGroupRel.java
@@ -4,6 +4,9 @@ import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.NoArgsConstructor;
+import com.yunhai.userbase.common.converter.UserGroupRelStatusEnumConverter;
+import com.yunhai.userbase.enums.UserGroupRelStatusEnum;
+
import javax.persistence.*;
import javax.validation.constraints.NotNull;
import java.time.LocalDateTime;
@@ -36,6 +39,14 @@ public class SysUserGroupRel {
@Column(name = "sort_no")
private Integer sortNo;
+ /**
+ * 组内状态：0=正常 1=转出（存量数据 NULL 视为正常）。
+ * 转出仅作标记，不影响成员查询、组织链与下游推送；
+ * 改组/移动经 changeGroups 覆盖式重建关系行时状态随用户继承（同组照抄旧状态，新增组在转出流程中继承转出）。
+ */
+ @Convert(converter = UserGroupRelStatusEnumConverter.class)
+ private UserGroupRelStatusEnum status;
+
private LocalDateTime createTime;
// 关联用户，仅查询，不维护外键
diff --git a/src/main/java/com/yunhai/userbase/model/sysuser/SysUserVo.java b/src/main/java/com/yunhai/userbase/model/sysuser/SysUserVo.java
index 3dee203..efca624 100644
--- a/src/main/java/com/yunhai/userbase/model/sysuser/SysUserVo.java
+++ b/src/main/java/com/yunhai/userbase/model/sysuser/SysUserVo.java
@@ -29,6 +29,8 @@ public class SysUserVo {
private Integer type;
/** 当前组维度的排序号（组内 sort_no）；根节点/未选组时为 null */
private Integer sortNo;
+ /** 组内状态：UserGroupRelStatusEnum 的 key（0=正常，1=转出）；仅组上下文列表有值，根节点/未选组为 null */
+ private Integer groupStatus;
private Boolean expired;
private LocalDateTime createTime;
private LocalDateTime updateTime;
diff --git a/src/main/java/com/yunhai/userbase/repository/SysUserRepository.java b/src/main/java/com/yunhai/userbase/repository/SysUserRepository.java
index 015d584..651d4fd 100644
--- a/src/main/java/com/yunhai/userbase/repository/SysUserRepository.java
+++ b/src/main/java/com/yunhai/userbase/repository/SysUserRepository.java
@@ -35,7 +35,7 @@ public interface SysUserRepository extends JpaRepository, JpaS
* 入参 name / disabled 为可空：为空（NULL）时该过滤条件整体跳过。
*/
@Query(value =
- "SELECT u.id AS userId, MIN(r.sort_no) AS minSortNo " +
+ "SELECT u.id AS userId, MIN(r.sort_no) AS minSortNo, MAX(COALESCE(r.status, 0)) AS groupStatus " +
"FROM sys_user u " +
"INNER JOIN sys_user_group_rel r ON r.user_id = u.id " +
"WHERE r.group_id IN (:groupIds) " +
diff --git a/src/main/java/com/yunhai/userbase/service/ISysUserService.java b/src/main/java/com/yunhai/userbase/service/ISysUserService.java
index d3bb66f..da543a7 100644
--- a/src/main/java/com/yunhai/userbase/service/ISysUserService.java
+++ b/src/main/java/com/yunhai/userbase/service/ISysUserService.java
@@ -179,4 +179,42 @@ public interface ISysUserService {
* @param newPassword 新密码（弱密码规则校验后加密写入）
*/
void changePassword(Integer userId, String oldPassword, String newPassword);
+
+ /**
+ * 开放接口专用：设置用户在指定组上的状态（转出/恢复）。
+ * 仅作关系标记，不影响成员查询、组织链与下游推送；同值重复调用幂等。
+ * 边界：groupId 必须属于 schoolId 子树且不能等于 schoolId（禁止跨校/学校根组操作）。
+ *
+ * @param userId 用户ID
+ * @param groupId 组ID
+ * @param schoolId 学校组ID（限定范围）
+ * @param state 目标状态：0=恢复正常，1=转出
+ */
+ void changeUserGroupState(Integer userId, Integer groupId, Integer schoolId, Integer state);
+
+ /**
+ * 开放接口专用：查询用户在指定组上的状态（0=正常，1=转出）。
+ * 存量数据 status 为 NULL 视为正常返回 0。
+ *
+ * @param userId 用户ID
+ * @param groupId 组ID
+ * @param schoolId 学校组ID（限定范围）
+ * @return 状态值 0/1
+ */
+ Integer getUserGroupState(Integer userId, Integer groupId, Integer schoolId);
+
+ /**
+ * 开放接口专用：跨校转入（转出后迁移到其他学校）。
+ * 前置：用户已在源学校（fromSchoolId 子树内）存在至少一条「转出」状态的组关系；
+ * 操作成功后：删除源学校范围内全部组关系（其他学校保留），在目标学校建立目标组关系
+ * （主归属、状态恢复正常，转出流程结束），并推送编辑用户订阅（UPDATE_USER）。
+ * 边界：fromSchoolId 与目标 schoolId 均须为学校组且不相同；目标组须属于目标学校子树且不等于学校根组；
+ * 用户已在目标学校存在组关系时拒绝（转入语义为进入全新学校）。
+ *
+ * @param userId 待迁移用户ID
+ * @param fromSchoolId 原学校组ID（源学校）
+ * @param toSchoolId 目标学校组ID
+ * @param groupId 目标组ID（目标学校内的挂载组，迁移后的主归属）
+ */
+ void transferUserToSchool(Integer userId, Integer fromSchoolId, Integer toSchoolId, Integer groupId);
}
diff --git a/src/main/java/com/yunhai/userbase/service/impl/SysUserService.java b/src/main/java/com/yunhai/userbase/service/impl/SysUserService.java
index c9253c5..6adf2fe 100644
--- a/src/main/java/com/yunhai/userbase/service/impl/SysUserService.java
+++ b/src/main/java/com/yunhai/userbase/service/impl/SysUserService.java
@@ -7,6 +7,7 @@ import com.yunhai.userbase.entity.SysGroup;
import com.yunhai.platform.utils.enums.IEnum;
import com.yunhai.userbase.enums.StatusEnum;
import com.yunhai.userbase.enums.SysRoleEnum;
+import com.yunhai.userbase.enums.UserGroupRelStatusEnum;
import com.yunhai.userbase.enums.UserTypeEnum;
import com.yunhai.userbase.entity.SysUser;
import com.yunhai.userbase.entity.SysUserAppRoleRel;
@@ -338,6 +339,93 @@ public class SysUserService implements ISysUserService {
sysUserGroupRelRepository.save(rel);
}
+ @Override
+ @Transactional
+ public void changeUserGroupState(Integer userId, Integer groupId, Integer schoolId, Integer state) {
+ if (state == null || (state != 0 && state != 1)) {
+ throw new DException("state 仅支持 0=恢复正常、1=转出");
+ }
+ // 开放接口边界：groupId 必须属于 schoolId 子树且不能等于 schoolId（禁止跨校/学校根组）
+ assertGroupWithinSchool(groupId, schoolId);
+ if (!sysUserRepository.existsById(userId)) {
+ throw new DException("系统用户不存在");
+ }
+ // 状态按组维度存储，必须落到具体的 (userId, groupId) 关联行；同值重复调用幂等
+ SysUserGroupRel rel = sysUserGroupRelRepository.findByUserIdAndGroupId(userId, groupId)
+ .orElseThrow(() -> new DException("该用户不在此分组中"));
+ rel.setStatus(state == 1 ? UserGroupRelStatusEnum.TRANSFERRED_OUT : UserGroupRelStatusEnum.NORMAL);
+ sysUserGroupRelRepository.save(rel);
+ }
+
+ @Override
+ public Integer getUserGroupState(Integer userId, Integer groupId, Integer schoolId) {
+ assertGroupWithinSchool(groupId, schoolId);
+ SysUserGroupRel rel = sysUserGroupRelRepository.findByUserIdAndGroupId(userId, groupId)
+ .orElseThrow(() -> new DException("该用户不在此分组中"));
+ // 存量数据 status 为 NULL，按正常返回
+ return rel.getStatus() == null ? UserGroupRelStatusEnum.NORMAL.getKey() : rel.getStatus().getKey();
+ }
+
+ @Override
+ @Transactional
+ public void transferUserToSchool(Integer userId, Integer fromSchoolId, Integer toSchoolId, Integer groupId) {
+ if (userId == null) {
+ throw new DException("用户ID不能为空");
+ }
+ if (fromSchoolId == null) {
+ throw new DException("原学校ID不能为空");
+ }
+ if (toSchoolId == null) {
+ throw new DException("目标学校ID不能为空");
+ }
+ if (groupId == null) {
+ throw new DException("目标组ID不能为空");
+ }
+ // 源学校必须真实存在且为学校组（目标学校在 assertGroupWithinSchool 内一并校验）
+ sysGroupService.assertSchoolId(fromSchoolId);
+ if (fromSchoolId.equals(toSchoolId)) {
+ throw new DException("原学校与目标学校不能相同");
+ }
+ if (!sysUserRepository.existsById(userId)) {
+ throw new DException("系统用户不存在");
+ }
+ // 目标组必须属于目标学校子树且不等于学校根组（复用移动/删除的边界校验）
+ assertGroupWithinSchool(groupId, toSchoolId);
+
+ List fromScope = sysGroupService.listSelfAndDescendantIds(fromSchoolId);
+ List toScope = sysGroupService.listSelfAndDescendantIds(toSchoolId);
+ List rels = sysUserGroupRelRepository.findByUserId(userId);
+
+ // ① 前置：用户在源学校范围必须存在至少一条「转出」状态的组关系
+ boolean hasTransferOut = rels.stream().anyMatch(r ->
+ r.getStatus() == UserGroupRelStatusEnum.TRANSFERRED_OUT && fromScope.contains(r.getGroupId()));
+ if (!hasTransferOut) {
+ throw new DException("该用户在原学校不存在转出状态的组关系，禁止转入");
+ }
+ // ② 目标学校范围不得已有组关系（转入语义为进入全新学校，避免覆盖歧义）
+ boolean existsInTarget = rels.stream().anyMatch(r -> toScope.contains(r.getGroupId()));
+ if (existsInTarget) {
+ throw new DException("用户已在该学校存在组关系，禁止重复转入");
+ }
+ // ③ 删除源学校范围内全部关系行（仅源学校，其他学校保留）
+ List toDelete = rels.stream()
+ .filter(r -> fromScope.contains(r.getGroupId()))
+ .collect(Collectors.toList());
+ if (!toDelete.isEmpty()) {
+ sysUserGroupRelRepository.deleteAll(toDelete);
+ }
+ // ④ 建立目标学校关系：目标组设为主归属，状态恢复正常（转出流程结束）
+ SysUserGroupRel rel = new SysUserGroupRel();
+ rel.setUserId(userId);
+ rel.setGroupId(groupId);
+ rel.setIsMain(IS_MAIN);
+ rel.setStatus(UserGroupRelStatusEnum.NORMAL);
+ rel.setCreateTime(LocalDateTime.now());
+ sysUserGroupRelRepository.save(rel);
+ // ⑤ 推送编辑用户订阅
+ publishUserEvent(PushInterfaceType.UPDATE_USER, userId);
+ }
+
@Override
public Page list(SysUserQuery query, Pageable pageable) {
// 组上下文（选中具体组）：走原生 SQL 按「组内最小 sort_no」排序的专用分页，
@@ -348,7 +436,7 @@ public class SysUserService implements ISysUserService {
// 根节点 / 未选组：用 Specification 过滤，按主键 id 升序（聚簇索引顺序，无 filesort）。
Specification spec = buildSpecification(query);
Page page = sysUserRepository.findAll(spec, pageable);
- return page.map(u -> convertToVo(u, null));
+ return page.map(u -> convertToVo(u, null, null));
}
/**
@@ -372,15 +460,19 @@ public class SysUserService implements ISysUserService {
return new PageImpl<>(Collections.emptyList(), pageable, 0);
}
- // 保持 DB 返回的排序顺序，并记录每个用户的「组范围内最小 sort_no」
+ // 保持 DB 返回的排序顺序，并记录每个用户的「组范围内最小 sort_no」与「组内状态（任一转出即转出）」
List orderedIds = new ArrayList<>(rows.size());
Map sortNoMap = new LinkedHashMap<>();
+ Map groupStatusMap = new LinkedHashMap<>();
for (Object[] row : rows) {
Integer userId = ((Number) row[0]).intValue();
Object minObj = row[1]; // MIN(sort_no) 可能为空（该用户在组范围内均未设置排序号）
Integer sortNo = minObj == null ? null : ((Number) minObj).intValue();
+ Object statusObj = row[2]; // MAX(COALESCE(status,0))：组范围内任一条转出即视为转出
+ Integer groupStatus = statusObj == null ? null : ((Number) statusObj).intValue();
orderedIds.add(userId);
sortNoMap.put(userId, sortNo);
+ groupStatusMap.put(userId, groupStatus);
}
// 按有序 ID 取实体（findAllById 返回顺序不可靠，需按 orderedIds 重排）
@@ -392,7 +484,7 @@ public class SysUserService implements ISysUserService {
for (Integer id : orderedIds) {
SysUser u = userMap.get(id);
if (u != null) {
- voList.add(convertToVo(u, sortNoMap.get(id)));
+ voList.add(convertToVo(u, sortNoMap.get(id), groupStatusMap.get(id)));
}
}
return new PageImpl<>(voList, pageable, idPage.getTotalElements());
@@ -426,14 +518,29 @@ public class SysUserService implements ISysUserService {
LocalDateTime now = LocalDateTime.now();
for (Integer userId : userIds) {
+ // 覆盖式重建前先读旧关系，用于继承组内状态（转出标记）：
+ // 行级继承——同组照抄旧状态（管理端重设组不误改）；用户级继承——新增组在用户处于转出流程中（存在任一转出行）时继承「转出」
+ List oldRels = sysUserGroupRelRepository.findByUserId(userId);
+ Map oldStatusByGroup = new HashMap<>();
+ boolean inTransferFlow = false;
+ for (SysUserGroupRel oldRel : oldRels) {
+ oldStatusByGroup.put(oldRel.getGroupId(), oldRel.getStatus());
+ if (oldRel.getStatus() == UserGroupRelStatusEnum.TRANSFERRED_OUT) {
+ inTransferFlow = true;
+ }
+ }
sysUserGroupRelRepository.deleteByUserId(userId);
List rels = new ArrayList<>(groupIds.size());
for (int i = 0; i < groupIds.size(); i++) {
+ Integer groupId = groupIds.get(i);
SysUserGroupRel rel = new SysUserGroupRel();
rel.setUserId(userId);
- rel.setGroupId(groupIds.get(i));
+ rel.setGroupId(groupId);
rel.setIsMain(i == 0 ? IS_MAIN : 0);
rel.setCreateTime(now);
+ rel.setStatus(oldStatusByGroup.containsKey(groupId)
+ ? oldStatusByGroup.get(groupId)
+ : (inTransferFlow ? UserGroupRelStatusEnum.TRANSFERRED_OUT : UserGroupRelStatusEnum.NORMAL));
rels.add(rel);
}
sysUserGroupRelRepository.saveAll(rels);
@@ -885,18 +992,19 @@ public class SysUserService implements ISysUserService {
}
private SysUserVo convertToVo(SysUser entity) {
- return convertToVo(entity, null);
+ return convertToVo(entity, null, null);
}
- private SysUserVo convertToVo(SysUser entity, Integer sortNo) {
+ private SysUserVo convertToVo(SysUser entity, Integer sortNo, Integer groupStatus) {
SysUserVo vo = new SysUserVo();
BeanUtils.copyProperties(entity, vo);
// disabled 为枚举，需要单独映射为 key（与 GroupTypeEnum 的 type 处理一致）
vo.setDisabled(entity.getDisabled() == null ? null : entity.getDisabled().getKey());
// type 为枚举，同样映射为 key
vo.setType(entity.getType() == null ? null : entity.getType().getKey());
- // 当前组维度的排序号；根节点 / 未选组时为 null
+ // 当前组维度的排序号与组内状态；根节点 / 未选组时为 null
vo.setSortNo(sortNo);
+ vo.setGroupStatus(groupStatus);
return vo;
}