bug

luohairen

2024-10-30 df4898d55d3aa97f2cf455b4c351c37f2b84e257

 src/main/java/com/ycl/jxkg/service/impl/MeetServiceImpl.java

@@ -29,6 +29,7 @@
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.Assert;
import org.springframework.util.CollectionUtils;
import java.util.Date;
@@ -61,6 +62,7 @@
     * @return
     */
    @Override
    @Transactional(rollbackFor = Exception.class)
    public Result add(MeetForm form) {
        Meet entity = MeetForm.getEntityByForm(form, null);
        entity.setStatus(MeetStatusEnum.Wait.getCode());
@@ -71,10 +73,10 @@
            this.sendMQ(entity, 0);
        }
        // 向会议班级中间表中插入数据
        form.getClassesIds().stream().forEach(classId -> {
        form.getClassesIds().forEach(classId -> {
            MeetClasses meetClasses = new MeetClasses();
            meetClasses.setMeetId(entity.getId());
            meetClasses.setClassId(classId);
            meetClasses.setClassesId(classId);
            meetClassesMapper.insert(meetClasses);
        });
        return Result.ok("添加成功");
@@ -91,6 +93,20 @@
        // 为空抛IllegalArgumentException，做全局异常处理
        Assert.notNull(entity, "记录不存在");
        BeanUtils.copyProperties(form, entity);

        // 先删除再新增
        new LambdaUpdateChainWrapper<>(meetClassesMapper)
                .eq(MeetClasses::getMeetId, entity.getId())
                .remove();
        // 向会议班级中间表中插入数据
        form.getClassesIds().forEach(classId -> {
            MeetClasses meetClasses = new MeetClasses();
            meetClasses.setMeetId(entity.getId());
            meetClasses.setClassesId(classId);
            meetClassesMapper.insert(meetClasses);
        });


        // 如果修改成功发送mq消息
        if (baseMapper.updateById(entity) > 0) {
            this.sendMQ(entity, entity.getUpdateVersion());
@@ -132,7 +148,11 @@
        query.setTeacherId(id);
        IPage<MeetVO> page = PageUtil.getPage(query, MeetVO.class);
        baseMapper.getPage(page, query);

        page.getRecords().forEach(vo -> {
            if (!CollectionUtils.isEmpty(vo.getTeacherNames())) {
                vo.setTeacherNamesStr(vo.getTeacherNames().stream().collect(Collectors.joining("、")));
            }
        });
        return Result.ok().data(page.getRecords()).total(page.getTotal());
    }

@@ -248,20 +268,6 @@
        Integer userId = webContext.getCurrentUser().getId();
        List<ClassesVO> classes = classesUserMapper.getClassesByUserId1(userId);
        return Result.ok().data(classes);
    }

    @Override
    public Result editMeetClasses(MeetClassesVo meetClassesVo) {
        // 删除该会议所有班级
        meetClassesMapper.deleteByMeetId(meetClassesVo.getMeetId());
        // 为该会议新增班级
        meetClassesVo.getChangeIds().forEach(id -> {
            MeetClasses meetClasses = new MeetClasses();
            meetClasses.setMeetId(meetClassesVo.getMeetId());
            meetClasses.setClassId(id);
            meetClassesMapper.insert(meetClasses);
        });
        return Result.ok("修改成功");
    }

    /**