批量分组添加的数据到分组管理数据库表

This commit is contained in:
Qi 2025-04-28 22:49:41 +08:00
parent 461705254b
commit 507546d680
4 changed files with 74 additions and 3 deletions

View File

@ -8,6 +8,8 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.jeecg.common.api.vo.Result; import org.jeecg.common.api.vo.Result;
import org.jeecg.modules.entity.CeesLocalTeacher; import org.jeecg.modules.entity.CeesLocalTeacher;
import org.jeecg.modules.entity.CeesUser; import org.jeecg.modules.entity.CeesUser;
import org.jeecg.modules.entity.dto.UpdateGroupUserDto;
import org.jeecg.modules.mapper.CeesGroupMapper;
import org.jeecg.modules.mapper.CeesLocalTeacherMapper; import org.jeecg.modules.mapper.CeesLocalTeacherMapper;
import org.jeecg.modules.mapper.CeesUserMapper; import org.jeecg.modules.mapper.CeesUserMapper;
import org.jeecg.modules.service.ICeesLocalTeacherService; import org.jeecg.modules.service.ICeesLocalTeacherService;
@ -34,6 +36,8 @@ public class CeesLocalTeacherServiceImpl extends ServiceImpl<CeesLocalTeacherMap
ICeesUserService ceesUserService; ICeesUserService ceesUserService;
@Resource @Resource
CeesLocalTeacherMapper ceesLocalTeacherMapper; CeesLocalTeacherMapper ceesLocalTeacherMapper;
@Resource
CeesGroupMapper ceesGroupMapper;
/** /**
* @param ceesLocalTeacher * @param ceesLocalTeacher
@ -113,6 +117,26 @@ public class CeesLocalTeacherServiceImpl extends ServiceImpl<CeesLocalTeacherMap
} }
} }
//插入user-group
for (String id : ids) {
try {
LambdaQueryWrapper<CeesLocalTeacher> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.eq(CeesLocalTeacher::getId, id);
CeesLocalTeacher ceesLocalTeacher = ceesLocalTeacherMapper.selectOne(queryWrapper);
String user_id = ceesLocalTeacher.getUserId();
// LambdaUpdateWrapper<CeesUser> updateWrapper = new LambdaUpdateWrapper<>();
// updateWrapper.eq(CeesUser::getUserId, user_id)
// .set(CeesUser::getGroupId, groupId);
UpdateGroupUserDto GroupUserDto = new UpdateGroupUserDto();
GroupUserDto.setGroupId(groupId);
GroupUserDto.setUserId(user_id);
// 执行更新并检查受影响行数
ceesGroupMapper.updateGroupUser(GroupUserDto);
} catch (Exception e) {
failedIds.add(id); // 记录更新失败的ID
}
}
// 构建返回结果 // 构建返回结果
JSONObject resultJson = new JSONObject(); JSONObject resultJson = new JSONObject();

View File

@ -509,7 +509,7 @@ public class CeesUserServiceImpl extends ServiceImpl<CeesUserMapper, CeesUser> i
} }
// 获取生成规则 // 获取生成规则
CeesGenerativeRules rules = getGenerativeRules(); CeesGenerativeRules rules = GetGenerativeRules();
if (rules == null) { if (rules == null) {
throw new IllegalArgumentException("找不到对应的账号生成规则"); throw new IllegalArgumentException("找不到对应的账号生成规则");
} }

View File

@ -16,8 +16,10 @@ import org.jeecg.modules.entity.CeesDormitoryInfo;
import org.jeecg.modules.entity.CeesLocalTeacher; import org.jeecg.modules.entity.CeesLocalTeacher;
import org.jeecg.modules.entity.CeesUser; import org.jeecg.modules.entity.CeesUser;
import org.jeecg.modules.entity.CeesWaiTeacher; import org.jeecg.modules.entity.CeesWaiTeacher;
import org.jeecg.modules.entity.dto.UpdateGroupUserDto;
import org.jeecg.modules.enums.MajorEnum; import org.jeecg.modules.enums.MajorEnum;
import org.jeecg.modules.mapper.CeesDormitoryInfoMapper; import org.jeecg.modules.mapper.CeesDormitoryInfoMapper;
import org.jeecg.modules.mapper.CeesGroupMapper;
import org.jeecg.modules.mapper.CeesUserMapper; import org.jeecg.modules.mapper.CeesUserMapper;
import org.jeecg.modules.mapper.CeesWaiTeacherMapper; import org.jeecg.modules.mapper.CeesWaiTeacherMapper;
import org.jeecg.modules.service.ICeesWaiTeacherService; import org.jeecg.modules.service.ICeesWaiTeacherService;
@ -44,6 +46,8 @@ public class CeesWaiTeacherServiceImpl extends ServiceImpl<CeesWaiTeacherMapper,
private final CeesDormitoryInfoMapper ceesDormitoryInfoMapper; private final CeesDormitoryInfoMapper ceesDormitoryInfoMapper;
@Resource @Resource
CeesUserMapper ceesUserMapper; CeesUserMapper ceesUserMapper;
@Resource
CeesGroupMapper ceesGroupMapper;
@Override @Override
public Result updateDormitory(String id, String dormitoryId) { public Result updateDormitory(String id, String dormitoryId) {
@ -201,8 +205,8 @@ public class CeesWaiTeacherServiceImpl extends ServiceImpl<CeesWaiTeacherMapper,
try { try {
LambdaQueryWrapper<CeesWaiTeacher> queryWrapper = new LambdaQueryWrapper<>(); LambdaQueryWrapper<CeesWaiTeacher> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.eq(CeesWaiTeacher::getId, id); queryWrapper.eq(CeesWaiTeacher::getId, id);
CeesWaiTeacher ceesLocalTeacher = ceesWaiTeacherMapper.selectOne(queryWrapper); CeesWaiTeacher ceesWaiTeacher = ceesWaiTeacherMapper.selectOne(queryWrapper);
String user_id = ceesLocalTeacher.getUserId(); String user_id = ceesWaiTeacher.getUserId();
LambdaUpdateWrapper<CeesUser> updateWrapper = new LambdaUpdateWrapper<>(); LambdaUpdateWrapper<CeesUser> updateWrapper = new LambdaUpdateWrapper<>();
updateWrapper.eq(CeesUser::getUserId, user_id) updateWrapper.eq(CeesUser::getUserId, user_id)
.set(CeesUser::getGroupId, groupId); .set(CeesUser::getGroupId, groupId);
@ -220,6 +224,26 @@ public class CeesWaiTeacherServiceImpl extends ServiceImpl<CeesWaiTeacherMapper,
} }
} }
//插入user-group
for (String id : ids) {
try {
LambdaQueryWrapper<CeesWaiTeacher> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.eq(CeesWaiTeacher::getId, id);
CeesWaiTeacher ceesWaiTeacher = ceesWaiTeacherMapper.selectOne(queryWrapper);
String user_id = ceesWaiTeacher.getUserId();
// LambdaUpdateWrapper<CeesUser> updateWrapper = new LambdaUpdateWrapper<>();
// updateWrapper.eq(CeesUser::getUserId, user_id)
// .set(CeesUser::getGroupId, groupId);
UpdateGroupUserDto GroupUserDto = new UpdateGroupUserDto();
GroupUserDto.setGroupId(groupId);
GroupUserDto.setUserId(user_id);
// 执行更新并检查受影响行数
ceesGroupMapper.updateGroupUser(GroupUserDto);
} catch (Exception e) {
failedIds.add(id); // 记录更新失败的ID
}
}
// 构建返回结果 // 构建返回结果
JSONObject resultJson = new JSONObject(); JSONObject resultJson = new JSONObject();
//update-localTeacher //update-localTeacher

View File

@ -9,6 +9,8 @@ import org.jeecg.common.api.vo.Result;
import org.jeecg.modules.entity.CeesUser; import org.jeecg.modules.entity.CeesUser;
import org.jeecg.modules.entity.CeesWaiTeacher; import org.jeecg.modules.entity.CeesWaiTeacher;
import org.jeecg.modules.entity.Student; import org.jeecg.modules.entity.Student;
import org.jeecg.modules.entity.dto.UpdateGroupUserDto;
import org.jeecg.modules.mapper.CeesGroupMapper;
import org.jeecg.modules.mapper.CeesUserMapper; import org.jeecg.modules.mapper.CeesUserMapper;
import org.jeecg.modules.mapper.StudentMapper; import org.jeecg.modules.mapper.StudentMapper;
import org.jeecg.modules.service.ICeesUserService; import org.jeecg.modules.service.ICeesUserService;
@ -34,6 +36,8 @@ public class StudentServiceImpl extends ServiceImpl<StudentMapper, Student> impl
ICeesUserService ceesUserService; ICeesUserService ceesUserService;
@Resource @Resource
StudentMapper studentMapper; StudentMapper studentMapper;
@Resource
CeesGroupMapper ceesGroupMapper;
/** /**
* @param student * @param student
* @return * @return
@ -111,7 +115,26 @@ public class StudentServiceImpl extends ServiceImpl<StudentMapper, Student> impl
} }
} }
//插入user-group
for (String id : ids) {
try {
LambdaQueryWrapper<Student> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.eq(Student::getId, id);
Student student = studentMapper.selectOne(queryWrapper);
String user_id = student.getUserId();
// LambdaUpdateWrapper<CeesUser> updateWrapper = new LambdaUpdateWrapper<>();
// updateWrapper.eq(CeesUser::getUserId, user_id)
// .set(CeesUser::getGroupId, groupId);
UpdateGroupUserDto GroupUserDto = new UpdateGroupUserDto();
GroupUserDto.setGroupId(groupId);
GroupUserDto.setUserId(user_id);
// 执行更新并检查受影响行数
ceesGroupMapper.updateGroupUser(GroupUserDto);
} catch (Exception e) {
failedIds.add(id); // 记录更新失败的ID
}
}
// 构建返回结果 // 构建返回结果
JSONObject resultJson = new JSONObject(); JSONObject resultJson = new JSONObject();
//update-localTeacher //update-localTeacher