完成在线培训一个会议多个班级的功能

luohairen

2024-10-30 180b752fc5857a004088edbfd505894122c40049

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

@@ -9,18 +9,17 @@
import com.ycl.jxkg.base.SystemCode;
import com.ycl.jxkg.context.WebContext;
import com.ycl.jxkg.domain.entity.Meet;
import com.ycl.jxkg.domain.entity.MeetClasses;
import com.ycl.jxkg.domain.entity.MeetStudent;
import com.ycl.jxkg.domain.entity.StudyRecord;
import com.ycl.jxkg.domain.form.MeetForm;
import com.ycl.jxkg.domain.query.MeetQuery;
import com.ycl.jxkg.domain.vo.ClassesVO;
import com.ycl.jxkg.domain.vo.MeetClassesVo;
import com.ycl.jxkg.domain.vo.MeetVO;
import com.ycl.jxkg.domain.vo.StudentSimpleVO;
import com.ycl.jxkg.enums.MeetStatusEnum;
import com.ycl.jxkg.mapper.ClassesUserMapper;
import com.ycl.jxkg.mapper.MeetMapper;
import com.ycl.jxkg.mapper.MeetStudentMapper;
import com.ycl.jxkg.mapper.StudyRecordMapper;
import com.ycl.jxkg.mapper.*;
import com.ycl.jxkg.rabbitmq.msg.MeetStatusMsg;
import com.ycl.jxkg.rabbitmq.product.Producer;
import com.ycl.jxkg.service.MeetService;
@@ -55,6 +54,7 @@
    private final Producer producer;
    private final MeetStudentMapper meetStudentMapper;
    private final StudyRecordMapper studyRecordMapper;
    private final MeetClassesMapper meetClassesMapper;
    /**
     * 添加
     * @param form
@@ -70,6 +70,13 @@
        if (baseMapper.insert(entity) > 0) {
            this.sendMQ(entity, 0);
        }
        // 向会议班级中间表中插入数据
        form.getClassesIds().stream().forEach(classId -> {
            MeetClasses meetClasses = new MeetClasses();
            meetClasses.setMeetId(entity.getId());
            meetClasses.setClassId(classId);
            meetClassesMapper.insert(meetClasses);
        });
        return Result.ok("添加成功");
    }

@@ -243,6 +250,20 @@
        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("修改成功");
    }

    /**
     * 发送mq消息
     *