BandingTaskServiceImpl.java 28 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572
  1. package com.xjrsoft.module.banding.service.impl;
  2. import cn.dev33.satoken.secure.BCrypt;
  3. import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
  4. import com.baomidou.mybatisplus.core.toolkit.Wrappers;
  5. import com.github.yulichang.base.MPJBaseServiceImpl;
  6. import com.github.yulichang.wrapper.MPJLambdaWrapper;
  7. import com.xjrsoft.common.enums.ArchivesStatusEnum;
  8. import com.xjrsoft.common.enums.DeleteMark;
  9. import com.xjrsoft.common.enums.EnabledMark;
  10. import com.xjrsoft.common.enums.GenderDictionaryEnum;
  11. import com.xjrsoft.common.enums.RoleEnum;
  12. import com.xjrsoft.common.exception.MyException;
  13. import com.xjrsoft.common.utils.VoToColumnUtil;
  14. import com.xjrsoft.config.CommonPropertiesConfig;
  15. import com.xjrsoft.module.banding.dto.AutomaticBandingTaskDto;
  16. import com.xjrsoft.module.banding.dto.BandingTaskClassStudentPageDto;
  17. import com.xjrsoft.module.banding.dto.SureBandingTaskDto;
  18. import com.xjrsoft.module.banding.entity.BandingRule;
  19. import com.xjrsoft.module.banding.entity.BandingTask;
  20. import com.xjrsoft.module.banding.entity.BandingTaskClass;
  21. import com.xjrsoft.module.banding.entity.BandingTaskClassStudent;
  22. import com.xjrsoft.module.banding.entity.BandingTaskMajorCondition;
  23. import com.xjrsoft.module.banding.entity.BandingTaskRule;
  24. import com.xjrsoft.module.banding.mapper.BandingRuleMapper;
  25. import com.xjrsoft.module.banding.mapper.BandingTaskClassMapper;
  26. import com.xjrsoft.module.banding.mapper.BandingTaskMapper;
  27. import com.xjrsoft.module.banding.mapper.BandingTaskRuleMapper;
  28. import com.xjrsoft.module.banding.service.IBandingTaskClassStudentService;
  29. import com.xjrsoft.module.banding.service.IBandingTaskMajorConditionService;
  30. import com.xjrsoft.module.banding.service.IBandingTaskService;
  31. import com.xjrsoft.module.banding.vo.BandingTaskClassSureListVo;
  32. import com.xjrsoft.module.base.entity.BaseClass;
  33. import com.xjrsoft.module.base.entity.BaseMajorSet;
  34. import com.xjrsoft.module.base.mapper.BaseMajorSetMapper;
  35. import com.xjrsoft.module.base.service.IBaseClassService;
  36. import com.xjrsoft.module.organization.entity.User;
  37. import com.xjrsoft.module.organization.entity.UserRoleRelation;
  38. import com.xjrsoft.module.organization.service.IUserRoleRelationService;
  39. import com.xjrsoft.module.organization.service.IUserService;
  40. import com.xjrsoft.module.outint.vo.IdCountVo;
  41. import com.xjrsoft.module.student.entity.BaseClassMajorSet;
  42. import com.xjrsoft.module.student.entity.BaseNewStudent;
  43. import com.xjrsoft.module.student.entity.BaseStudent;
  44. import com.xjrsoft.module.student.entity.BaseStudentFamily;
  45. import com.xjrsoft.module.student.entity.BaseStudentSchoolRoll;
  46. import com.xjrsoft.module.student.entity.EnrollmentPlan;
  47. import com.xjrsoft.module.student.mapper.BaseClassMajorSetMapper;
  48. import com.xjrsoft.module.student.service.IBaseNewStudentService;
  49. import com.xjrsoft.module.student.service.IBaseStudentFamilyService;
  50. import com.xjrsoft.module.student.service.IBaseStudentSchoolRollService;
  51. import com.xjrsoft.module.student.service.IBaseStudentService;
  52. import lombok.AllArgsConstructor;
  53. import org.springframework.stereotype.Service;
  54. import org.springframework.transaction.annotation.Transactional;
  55. import java.math.BigDecimal;
  56. import java.time.LocalDate;
  57. import java.time.LocalDateTime;
  58. import java.time.format.DateTimeFormatter;
  59. import java.util.ArrayList;
  60. import java.util.Collections;
  61. import java.util.Date;
  62. import java.util.HashMap;
  63. import java.util.List;
  64. import java.util.Map;
  65. import java.util.Objects;
  66. import java.util.Random;
  67. import java.util.stream.Collectors;
  68. /**
  69. * @title: 新生分班任务
  70. * @Author dzx
  71. * @Date: 2024-07-01
  72. * @Version 1.0
  73. */
  74. @Service
  75. @AllArgsConstructor
  76. public class BandingTaskServiceImpl extends MPJBaseServiceImpl<BandingTaskMapper, BandingTask> implements IBandingTaskService {
  77. private final BandingTaskMapper bandingTaskMapper;
  78. private final BandingRuleMapper ruleMapper;
  79. private final BandingTaskRuleMapper taskRuleMapper;
  80. private final BandingTaskClassMapper taskClassMapper;
  81. private final IBaseNewStudentService newStudentService;
  82. private final IBandingTaskClassStudentService classStudentService;
  83. private final IBandingTaskMajorConditionService conditionService;
  84. private final IBaseClassService classService;
  85. private final BaseClassMajorSetMapper classMajorSetMapper;
  86. private final CommonPropertiesConfig propertiesConfig;
  87. private final IUserService userService;
  88. private final IUserRoleRelationService roleRelationService;
  89. private final IBaseStudentSchoolRollService schoolRollService;
  90. private final IBaseStudentService studentService;
  91. private final IBaseStudentFamilyService familyService;
  92. private final BaseMajorSetMapper majorSetMapper;
  93. @Override
  94. @Transactional(rollbackFor = Exception.class)
  95. public Boolean add(BandingTask bandingTask) {
  96. bandingTask.setCreateDate(new Date());
  97. bandingTaskMapper.insert(bandingTask);
  98. return true;
  99. }
  100. @Override
  101. @Transactional(rollbackFor = Exception.class)
  102. public Boolean update(BandingTask bandingTask) {
  103. bandingTask.setModifyDate(new Date());
  104. bandingTaskMapper.updateById(bandingTask);
  105. return true;
  106. }
  107. @Override
  108. @Transactional(rollbackFor = Exception.class)
  109. public Boolean delete(List<Long> ids) {
  110. bandingTaskMapper.deleteBatchIds(ids);
  111. taskRuleMapper.delete(Wrappers.lambdaQuery(BandingTaskRule.class).in(BandingTaskRule::getBandingTaskId, ids));
  112. taskClassMapper.delete(Wrappers.lambdaQuery(BandingTaskClass.class).in(BandingTaskClass::getBandingTaskId, ids));
  113. return true;
  114. }
  115. /**
  116. * 自动分班
  117. * 1、根据分班任务的信息,查询出来需要分班的学生
  118. * 2、查询该任务下的班级信息
  119. * 3、查询该任务使用的规则
  120. * 4、执行自动分班
  121. * 5、完成后,将分好班的信息存到banding_task_class_student表中
  122. */
  123. @Override
  124. public Boolean automaticBanding(AutomaticBandingTaskDto dto) {
  125. BandingTask bandingTask = this.getById(dto.getBandingTaskId());
  126. if(bandingTask == null){
  127. throw new MyException("未能查询到该任务,无法自动分班");
  128. }
  129. //1、查询需要分班的学生信息
  130. List<String> orderColumn = new ArrayList();
  131. orderColumn.add("height");orderColumn.add("score");
  132. List<BaseNewStudent> baseNewStudents = newStudentService.selectJoinList(BaseNewStudent.class,
  133. new MPJLambdaWrapper<BaseNewStudent>()
  134. .select(BaseNewStudent::getId)
  135. .select(BaseNewStudent.class, x -> VoToColumnUtil.fieldsToColumns(BaseNewStudent.class).contains(x.getProperty()))
  136. .leftJoin(EnrollmentPlan.class, EnrollmentPlan::getId, BaseNewStudent::getEnrollmentPlanId)
  137. .eq(EnrollmentPlan::getGradeId, bandingTask.getGradeId())
  138. .eq(EnrollmentPlan::getEnrollType, bandingTask.getEnrollType())
  139. .eq(BaseNewStudent::getStatus, 0)
  140. .orderByDescStr(orderColumn)
  141. );
  142. //2、查询所有班级信息
  143. List<BandingTaskClass> classList = taskClassMapper.getListOrderByAsc(bandingTask.getId());
  144. if(!classList.isEmpty()){
  145. //清除数据
  146. List<Long> classIds = classList.stream().map(BandingTaskClass::getId).collect(Collectors.toList());
  147. classStudentService.remove(
  148. new QueryWrapper<BandingTaskClassStudent>().lambda()
  149. .in(BandingTaskClassStudent::getBandingTaskClassId, classIds)
  150. );
  151. }
  152. //3、查询所用到的规则
  153. List<BandingRule> ruleList = ruleMapper.selectJoinList(BandingRule.class,
  154. new MPJLambdaWrapper<BandingRule>()
  155. .select(BandingRule::getId)
  156. .select(BandingRule.class, x -> VoToColumnUtil.fieldsToColumns(BandingRule.class).contains(x.getProperty()))
  157. .innerJoin(BandingTaskRule.class, BandingTaskRule::getBandingRuleId, BandingRule::getId)
  158. .eq(BandingTaskRule::getBandingTaskId, bandingTask.getId())
  159. );
  160. List<String> ruleCodes = ruleList.stream().map(BandingRule::getCode).collect(Collectors.toList());
  161. //包含下面个条件,则需要计算每个班级应该分配的人数
  162. Map<Long, Integer> classLimitMap = new HashMap<>();
  163. if(ruleCodes.contains("BR0004")){
  164. //查询每个专业下面有多少个班级
  165. List<IdCountVo> majorClassCountList = taskClassMapper.getMajorClassCount(bandingTask.getId());
  166. Map<Long, Integer> majorClassCount = majorClassCountList.stream().collect(Collectors.toMap(IdCountVo::getId, IdCountVo::getCount));
  167. //查询每个专业下面的班级人数
  168. Map<Long, Integer> majorClassStudentCount = taskClassMapper.getMajorClassStudentCount(bandingTask.getId())
  169. .stream().collect(Collectors.toMap(IdCountVo::getId, IdCountVo::getCount));
  170. //查询每个专业人数
  171. Map<Long, Integer> majorStudentCount = newStudentService.getMajorStudentCount()
  172. .stream().collect(Collectors.toMap(IdCountVo::getId, IdCountVo::getCount));
  173. Map<Long, Integer> majorLimitMap = new HashMap<>();
  174. for (Long majorSetId : majorClassStudentCount.keySet()) {
  175. int majorClassNumber = 0;
  176. if(majorClassStudentCount.get(majorSetId) != null){
  177. majorClassNumber = majorClassStudentCount.get(majorSetId);
  178. }
  179. int majorStudentNumber = 0;
  180. if(majorStudentCount.get(majorSetId) != null){
  181. majorStudentNumber = majorStudentCount.get(majorSetId);
  182. }
  183. Integer classCount = majorClassCount.get(majorSetId);
  184. if(majorStudentNumber < majorClassNumber){//报名人数小于班级人数
  185. Integer classLimtCount = majorStudentNumber / classCount;
  186. majorLimitMap.put(majorSetId, classLimtCount);
  187. }else{
  188. Integer classLimtCount = majorClassNumber / classCount;
  189. majorLimitMap.put(majorSetId, classLimtCount);
  190. }
  191. }
  192. for (BandingTaskClass bandingTaskClass : classList) {
  193. classLimitMap.put(bandingTaskClass.getId(), majorLimitMap.get(bandingTaskClass.getMajorSetId()));
  194. }
  195. }
  196. //查询每个专业的限制条件
  197. List<BandingTaskMajorCondition> list = conditionService.list(
  198. new QueryWrapper<BandingTaskMajorCondition>().lambda()
  199. .eq(BandingTaskMajorCondition::getBandingTaskId, dto.getBandingTaskId())
  200. );
  201. Map<Long, BandingTaskMajorCondition> classConditionMap = new HashMap<>();
  202. for (BandingTaskMajorCondition conditionDto : list) {
  203. classConditionMap.put(conditionDto.getMajorSetId(), conditionDto);
  204. }
  205. Map<Long, List<BaseNewStudent>> classStudentMap = new HashMap<>();
  206. if(ruleCodes.contains("BR0002")){
  207. classStudentMap.putAll(divideStudentByScore(classConditionMap, baseNewStudents, classList));
  208. }
  209. //存班级和学生的关系
  210. Map<Long, Long> studentClassMap = new HashMap<>();
  211. //4、开始分班
  212. for (BandingTaskClass taskClass : classList) {
  213. Integer number = taskClass.getNumber();//班级总人数
  214. if(classLimitMap.get(taskClass.getId()) != null){
  215. if(number > classLimitMap.get(taskClass.getId())){
  216. number = classLimitMap.get(taskClass.getId());
  217. }
  218. }
  219. Integer maleCount = 0, femaleCount = 0;
  220. if(ruleCodes.contains("BR0001")){
  221. maleCount = number / 2;
  222. femaleCount = number / 2;
  223. //如果班级人数是奇数,随机分配一个名额
  224. if(number % 2 != 0){
  225. Random random = new Random();
  226. int randomIndex = random.nextInt(GenderDictionaryEnum.getCodes().length);
  227. String randomGender = GenderDictionaryEnum.getCodes()[randomIndex];
  228. if(GenderDictionaryEnum.MALE.getCode().equals(randomGender)){
  229. maleCount ++;
  230. }else if(GenderDictionaryEnum.FEMALE.getCode().equals(randomGender)){
  231. femaleCount ++ ;
  232. }
  233. }
  234. }
  235. List<String> nameList = new ArrayList<>();
  236. List<BaseNewStudent> maleList = new ArrayList();
  237. List<BaseNewStudent> femaleList = new ArrayList();
  238. List<BaseNewStudent> studentList = new ArrayList<>();
  239. studentList.addAll(baseNewStudents);
  240. if(ruleCodes.contains("BR0002") && classStudentMap.get(taskClass.getMajorSetId()) != null && !classStudentMap.get(taskClass.getMajorSetId()).isEmpty()){
  241. studentList.clear();
  242. studentList.addAll(classStudentMap.get(taskClass.getMajorSetId()));
  243. }
  244. for (BaseNewStudent newStudent : studentList) {
  245. //人数已满,进行下一个班级的的循环
  246. if(nameList.size() == number){
  247. break;
  248. }
  249. //该学生已被分配
  250. if(studentClassMap.containsKey(newStudent.getId())){
  251. continue;
  252. }
  253. if(ruleCodes.contains("BR0003") && nameList.contains(newStudent.getName())){
  254. continue;
  255. }
  256. //专业不匹配,直接跳过
  257. if(!Objects.equals(taskClass.getMajorSetId(), newStudent.getFirstAmbitionId()) && !Objects.equals(taskClass.getMajorSetId(), newStudent.getSecondAmbitionId())){
  258. continue;
  259. }
  260. //判断该班性别是否已满
  261. if(ruleCodes.contains("BR0001")){
  262. if(GenderDictionaryEnum.MALE.getCode().equals(newStudent.getGender()) && maleList.size() == maleCount){
  263. continue;
  264. }else if(GenderDictionaryEnum.FEMALE.getCode().equals(newStudent.getGender()) && femaleList.size() == femaleCount){
  265. continue;
  266. }
  267. }
  268. if(taskClass.getSortCode() == null && !Objects.equals(taskClass.getMajorSetId(), newStudent.getFirstAmbitionId())){//如果未给班级设置优先级,只匹配一志愿的学生
  269. continue;
  270. }
  271. List<Boolean> conditionList = new ArrayList<>();
  272. BandingTaskMajorCondition condition = classConditionMap.get(taskClass.getMajorSetId());
  273. if(condition.getHeight() !=null && newStudent.getHeight() != null && newStudent.getHeight().compareTo(condition.getHeight()) >= 0 ){
  274. conditionList.add(true);
  275. }else if(condition.getHeight() !=null && newStudent.getHeight() != null && newStudent.getHeight().compareTo(condition.getHeight()) < 0){
  276. conditionList.add(false);
  277. }else if(condition.getHeight() !=null && newStudent.getHeight() == null){
  278. conditionList.add(false);
  279. }
  280. if(condition.getScore() !=null && newStudent.getScore() != null && newStudent.getScore().compareTo(condition.getScore()) >= 0 ){
  281. conditionList.add(true);
  282. }else if(condition.getScore() !=null && newStudent.getScore() != null && newStudent.getScore().compareTo(condition.getScore()) < 0){
  283. conditionList.add(false);
  284. }else if(condition.getScore() !=null && newStudent.getScore() == null){
  285. conditionList.add(false);
  286. }
  287. //如果包含false,则表明不符合条件,这个学生跳过
  288. if(conditionList.contains(false)){
  289. continue;
  290. }
  291. studentClassMap.put(newStudent.getId(), taskClass.getId());
  292. if(GenderDictionaryEnum.MALE.getCode().equals(newStudent.getGender())){
  293. maleList.add(newStudent);
  294. }else if(GenderDictionaryEnum.FEMALE.getCode().equals(newStudent.getGender())){
  295. femaleList.add(newStudent);
  296. }
  297. nameList.add(newStudent.getName());
  298. }
  299. }
  300. List<BandingTaskClassStudent> dataList = new ArrayList<>();
  301. Date createDate = new Date();
  302. for (Long studentId : studentClassMap.keySet()) {
  303. dataList.add(
  304. new BandingTaskClassStudent(){{
  305. setBandingTaskClassId(studentClassMap.get(studentId));
  306. setNewStudentId(studentId);
  307. setStatus(0);
  308. setCreateDate(createDate);
  309. }}
  310. );
  311. }
  312. if(!dataList.isEmpty()){
  313. classStudentService.saveBatch(dataList);
  314. }
  315. return true;
  316. }
  317. /**
  318. * 按照成绩均衡划分学生
  319. * @return 班级id和学生
  320. */
  321. Map<Long, List<BaseNewStudent>> divideStudentByScore(Map<Long, BandingTaskMajorCondition> classConditionMap, List<BaseNewStudent> baseNewStudents,
  322. List<BandingTaskClass> classList){
  323. Map<Long, List<BaseNewStudent>> classStudentMap = new HashMap<>();
  324. for (Long majorSetId : classConditionMap.keySet()) {
  325. // 1、先把每个专业匹配的学生分组存一起,并按照分数高低排序
  326. List<BaseNewStudent> stuList = new ArrayList<>();
  327. for (BaseNewStudent newStudent : baseNewStudents) {
  328. if(!Objects.equals(majorSetId, newStudent.getFirstAmbitionId()) && !Objects.equals(majorSetId, newStudent.getSecondAmbitionId())){
  329. continue;
  330. }
  331. List<Boolean> conditionList = new ArrayList<>();
  332. BandingTaskMajorCondition condition = classConditionMap.get(majorSetId);
  333. if(condition.getHeight() !=null && newStudent.getHeight() != null && newStudent.getHeight().compareTo(condition.getHeight()) >= 0 ){
  334. conditionList.add(true);
  335. }else if(condition.getHeight() !=null && newStudent.getHeight() != null && newStudent.getHeight().compareTo(condition.getHeight()) < 0){
  336. conditionList.add(false);
  337. }else if(condition.getHeight() !=null && newStudent.getHeight() == null){
  338. conditionList.add(false);
  339. }
  340. if(condition.getScore() !=null && newStudent.getScore() != null && newStudent.getScore().compareTo(condition.getScore()) >= 0 ){
  341. conditionList.add(true);
  342. }else if(condition.getScore() !=null && newStudent.getScore() != null && newStudent.getScore().compareTo(condition.getScore()) < 0){
  343. conditionList.add(false);
  344. }else if(condition.getScore() !=null && newStudent.getScore() == null){
  345. conditionList.add(false);
  346. }
  347. //如果包含false,则表明不符合条件,这个学生跳过
  348. if(conditionList.contains(false)){
  349. continue;
  350. }
  351. stuList.add(newStudent);
  352. }
  353. if(!stuList.isEmpty()){
  354. for (BaseNewStudent student : stuList) {
  355. if(student.getScore() == null){
  356. student.setScore(BigDecimal.ZERO);
  357. }
  358. }
  359. Collections.sort(stuList, (s1, s2) -> (int) (s2.getScore().doubleValue() - s1.getScore().doubleValue())); //按照成绩降序排序
  360. }
  361. //查询该专业下面有几个班级,把这部分学生按照成绩均匀分组
  362. List<List<BaseNewStudent>> result = new ArrayList<>();
  363. for (int i = 0; i < classList.size(); i++) {
  364. result.add(new ArrayList<>());
  365. }
  366. for (int i = 0; i < stuList.size(); i++) {
  367. BaseNewStudent currentStudent = stuList.get(i);
  368. int classIndex = i % classList.size(); //分配班级
  369. result.get(classIndex).add(currentStudent);
  370. }
  371. for (int i = 0; i < result.size(); i ++){
  372. classStudentMap.put(classList.get(i).getId(), result.get(i));
  373. }
  374. }
  375. return classStudentMap;
  376. }
  377. @Override
  378. public Boolean sure(SureBandingTaskDto dto) {
  379. List<BandingTaskClassStudent> classStudents = classStudentService.selectJoinList(BandingTaskClassStudent.class,
  380. new MPJLambdaWrapper<BandingTaskClassStudent>()
  381. .select(BandingTaskClassStudent::getId)
  382. .select(BandingTaskClassStudent.class, x -> VoToColumnUtil.fieldsToColumns(BandingTaskClassStudent.class).contains(x.getProperty()))
  383. .leftJoin(BandingTaskClass.class, BandingTaskClass::getId, BandingTaskClassStudent::getBandingTaskClassId)
  384. .eq(BandingTaskClass::getBandingTaskId, dto.getId())
  385. .eq(BandingTaskClassStudent::getStatus, 0)
  386. );
  387. List<Long> studentIds = classStudents.stream().map(BandingTaskClassStudent::getNewStudentId).collect(Collectors.toList());
  388. if(studentIds.isEmpty()){
  389. throw new MyException("未能查询到学生,无法确认");
  390. }
  391. List<BaseNewStudent> list = newStudentService.list(
  392. new QueryWrapper<BaseNewStudent>().lambda()
  393. .in(BaseNewStudent::getId, studentIds)
  394. );
  395. List<BaseNewStudent> updateList = new ArrayList<>();
  396. for (BaseNewStudent student : list) {
  397. student.setStatus(1);
  398. updateList.add(student);
  399. }
  400. if(!updateList.isEmpty()){
  401. newStudentService.updateBatchById(updateList);
  402. }
  403. //形成学生数据
  404. createStudentData(dto.getId(), classStudents, updateList);
  405. BandingTask bandingTask = this.getById(dto.getId());
  406. bandingTask.setStatus(1);
  407. bandingTask.setModifyDate(new Date());
  408. Boolean isSuccess = this.update(bandingTask);
  409. return isSuccess;
  410. }
  411. void createStudentData(Long badingTaskId,List<BandingTaskClassStudent> classStudents, List<BaseNewStudent> updateList){
  412. Date createDate = new Date();
  413. BandingTask bandingTask = this.getById(badingTaskId);
  414. List<BandingTaskClassSureListVo> classSure = taskClassMapper.getClassSure(new BandingTaskClassStudentPageDto() {{
  415. setBandingTaskId(badingTaskId);
  416. }});
  417. Map<Long, Integer> classTotal = classSure.stream().collect(Collectors.toMap(BandingTaskClassSureListVo::getId, BandingTaskClassSureListVo::getNumber));
  418. Map<Long, Integer> classBoy = classSure.stream().collect(Collectors.toMap(BandingTaskClassSureListVo::getId, BandingTaskClassSureListVo::getMaleCount));
  419. Map<Long, Integer> classGirl = classSure.stream().collect(Collectors.toMap(BandingTaskClassSureListVo::getId, BandingTaskClassSureListVo::getFemaleCount));
  420. //生成班级数据
  421. Map<Long, Long> classMap = new HashMap<>();
  422. Map<Long, Long> taskClassMajorMap = new HashMap<>();
  423. //查询出需要新增的班级信息
  424. List<Long> classIds = classStudents.stream().map(BandingTaskClassStudent::getBandingTaskClassId).collect(Collectors.toList());
  425. List<BandingTaskClass> classList = taskClassMapper.selectList(new QueryWrapper<BandingTaskClass>().lambda().in(BandingTaskClass::getId, classIds));
  426. Map<Long, Long> majorDeptMap = majorSetMapper.selectList(new QueryWrapper<BaseMajorSet>()).stream().collect(Collectors.toMap(BaseMajorSet::getId, BaseMajorSet::getDepartmentId));
  427. for (BandingTaskClass taskClass : classList) {
  428. BaseClass baseClass = new BaseClass() {{
  429. setName(taskClass.getName());
  430. setClassroomId(taskClass.getClassroomId());
  431. setTeacherId(taskClass.getTeacherId());
  432. setIsGraduate(1);
  433. setIsOrderClass(taskClass.getIsOrderClass()==null?0:taskClass.getIsOrderClass().intValue());
  434. setGradeId(bandingTask.getGradeId());
  435. setDeleteMark(DeleteMark.NODELETE.getCode());
  436. setEnrollType(bandingTask.getEnrollType());
  437. setOrgId(majorDeptMap.get(taskClass.getMajorSetId()));
  438. }};
  439. classService.save(baseClass);
  440. BaseClassMajorSet majorSet = new BaseClassMajorSet() {{
  441. setCreateDate(createDate);
  442. setMajorSetId(taskClass.getMajorSetId());
  443. setClassId(baseClass.getId());
  444. setPlanTotalStudent(taskClass.getNumber());
  445. setTotalStudent(classTotal.get(taskClass.getId()));
  446. setBoyNum(classBoy.get(taskClass.getId()));
  447. setGirlNum(classGirl.get(taskClass.getId()));
  448. }};
  449. classMajorSetMapper.insert(majorSet);
  450. classMap.put(taskClass.getId(), baseClass.getId());
  451. taskClassMajorMap.put(taskClass.getId(), taskClass.getMajorSetId());
  452. }
  453. /**
  454. * 新增学生数据
  455. * 1、新增用户xjr_user
  456. * 2、新增用户与角色的关系xjr_user_role_relation
  457. * 3、新增学生基本信息base_student
  458. * 4、新增学籍信息表base_student_school_roll
  459. * 5、新增家庭信息表base_student_family
  460. */
  461. LocalDateTime now = LocalDateTime.now();
  462. Map<Long, Long> studentClassRelation = classStudents.stream().collect(Collectors.toMap(BandingTaskClassStudent::getNewStudentId, BandingTaskClassStudent::getBandingTaskClassId));
  463. for (BaseNewStudent student : updateList) {
  464. LocalDate birthDate = getBirthDate(student.getCredentialNumber());
  465. User xjrUser = new User() {{
  466. setCreateDate(now);
  467. setPassword(BCrypt.hashpw(propertiesConfig.getDefaultPassword(), BCrypt.gensalt()));
  468. setName(student.getName());
  469. setUserName(student.getCredentialNumber());
  470. setCredentialNumber(student.getCredentialNumber());
  471. setCredentialType("ZZLS10007");
  472. setMobile(student.getMobile());
  473. setEnabledMark(EnabledMark.DISABLED.getCode());
  474. setGender(student.getGender());
  475. setIsChangePassword(1);
  476. setBirthDate(birthDate.atStartOfDay());
  477. }};
  478. userService.save(xjrUser);
  479. UserRoleRelation userRoleRelation = new UserRoleRelation() {{
  480. setRoleId(RoleEnum.STUDENT.getCode());
  481. setUserId(xjrUser.getId());
  482. }};
  483. roleRelationService.save(userRoleRelation);
  484. BaseStudent baseStudent = new BaseStudent() {{
  485. setUserId(xjrUser.getId());
  486. setCreateDate(now);
  487. setStudentId(student.getCredentialNumber());
  488. setHeight(student.getHeight().doubleValue());
  489. setWeight(student.getWeight().doubleValue());
  490. }};
  491. studentService.save(baseStudent);
  492. BaseStudentSchoolRoll schoolRoll = new BaseStudentSchoolRoll() {{
  493. setUserId(xjrUser.getId());
  494. setGraduatedScore(student.getScore().doubleValue());
  495. setGraduatedUniversity(student.getGraduateSchool());
  496. setClassId(classMap.get(studentClassRelation.get(student.getId())));
  497. setMajorSetId(taskClassMajorMap.get(studentClassRelation.get(student.getId())));
  498. setStduyStatus(student.getStduyStatus());
  499. setEnrollType(bandingTask.getEnrollType());
  500. setStudentSource(student.getSource());
  501. setGradeId(bandingTask.getGradeId());
  502. setArchivesStatus(ArchivesStatusEnum.FB2901.getCode());
  503. setCreateDate(now);
  504. }};
  505. schoolRollService.save(schoolRoll);
  506. BaseStudentFamily studentFamily = new BaseStudentFamily() {{
  507. setCreateDate(now);
  508. setUserId(xjrUser.getId());
  509. setTelephone(student.getFamilyMobile());
  510. setAddress(student.getFamilyAddress());
  511. }};
  512. familyService.save(studentFamily);
  513. }
  514. }
  515. LocalDate getBirthDate(String idCardNumber){
  516. // 获取出生日期前6位,即yyyyMM
  517. String birthdayString = idCardNumber.substring(6, 14);
  518. // 将字符串解析为LocalDate对象
  519. DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyyMMdd");
  520. return LocalDate.parse(birthdayString, formatter);
  521. }
  522. }