专题直播

slive/src/main/java/com/xhkjedu/slive/controller/liveplay/CsController.java

@@ -0,0 +1,74 @@
+package com.xhkjedu.slive.controller.liveplay;
+
+import com.github.pagehelper.PageHelper;
+import com.github.pagehelper.PageInfo;
+import com.xhkjedu.slive.model.liveplay.LCourse;
+import com.xhkjedu.slive.service.liveplay.CsService;
+import com.xhkjedu.slive.vo.liveplay.CourseParams;
+import com.xhkjedu.slive.vo.liveplay.CourseVo;
+import com.xhkjedu.utils.N_Utils;
+import com.xhkjedu.utils.PageUtil;
+import com.xhkjedu.vo.PageResult;
+import com.xhkjedu.vo.ResultVo;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.annotation.Resource;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @author ywx
+ * @classname CsController
+ * @description 专题直播
+ * @date 2022/9/22 16:41
+ **/
+@RestController
+@RequestMapping("/cs")
+public class CsController {
+    @Resource
+    private CsService csService;
+
+    @PostMapping("/add")
+    public ResultVo add(@RequestBody LCourse course) {
+        N_Utils.validation(new Object[]{course.getSubjectid(), "科目id", 2});
+        if ("NaN-aN-aN".equals(course.getBegindate()) || "NaN-aN-aN".equals(course.getEnddate())) {
+            return new ResultVo(1, "日期格式不正确");
+        }
+        return csService.save(course);
+    }
+
+    @PostMapping("/list")
+    public ResultVo list(@RequestBody LCourse course) {
+        N_Utils.validation(new Object[]{course.getPage(), "显示页码", 1
+                , course.getPageSize(), "显示条数", 1, course.getCreateid(), "用户id", 1});
+        PageHelper.startPage(course.getPage(), course.getPageSize());
+        List<CourseVo> list = csService.listAll(course);
+        PageResult pageResult = PageUtil.getPageResult(new PageInfo(list));
+        return new ResultVo(0, "获取课程列表成功", pageResult);
+    }
+
+    @PostMapping("/list_class")
+    public ResultVo listClass(@RequestBody LCourse course) {
+        Integer courseid = course.getCourseid();
+        N_Utils.validation(new Object[]{courseid, "课程id", 1});
+        List<Map> list = csService.listClass(courseid);
+        return new ResultVo(0, "获取课程班级列表成功", list);
+    }
+
+    @PostMapping("/kj_mydate")
+    public ResultVo listMySectionDate(@RequestBody CourseParams params) {
+        N_Utils.validation(new Object[]{params.getTimestr(), "月份", 2, params.getTeacherid(), "用户id", 1});
+        List<Map> list = csService.listMySectionDate(params);
+        return new ResultVo(0, "获取月份下课节数量成功", list);
+    }
+
+    @PostMapping("/list_mydate")
+    public ResultVo listMyByDate(@RequestBody CourseParams params) {
+        N_Utils.validation(new Object[]{params.getTimestr(), "日期", 2, params.getTeacherid(), "用户id", 1});
+        List<Map> list = csService.listMySection(params);
+        return new ResultVo(0, "获取我的课节列表成功", list);
+    }
+}

slive/src/main/java/com/xhkjedu/slive/mapper/liveplay/CsMapper.java

@@ -0,0 +1,23 @@
+package com.xhkjedu.slive.mapper.liveplay;
+
+import com.xhkjedu.slive.model.liveplay.LCourse;
+import com.xhkjedu.slive.vo.liveplay.CourseParams;
+import com.xhkjedu.slive.vo.liveplay.CourseVo;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+import java.util.Map;
+
+public interface CsMapper {
+    //课程列表
+    List<CourseVo> listAll(@Param("course") LCourse course);
+
+    //课程班级
+    List<Map> listClass(@Param("courseid") Integer courseid);
+
+    //我的月份下日期课节数量
+    List<Map> listMySectionDate(@Param("section") CourseParams params);
+
+    //我的课程列表
+    List<Map> listMySection(@Param("section") CourseParams params);
+}

slive/src/main/java/com/xhkjedu/slive/model/liveplay/LCourse.java

@@ -78,6 +78,9 @@ public class LCourse extends BaseBean {
     //课程类别0专题直播1行政直播
     private Integer courseclass;
 
+    //直播学校0单个1多个
+    private Integer courseschool;
+
     //直播课节详情id
     private Integer kjid;
 

slive/src/main/java/com/xhkjedu/slive/service/liveplay/CourseService.java

@@ -105,6 +105,7 @@ public class CourseService {
             model.setClassid(classid);
             model.setDeleted(1);
             model.setCourseclass(0);
+            model.setCourseschool(0);
             courseMapper.insertUseGeneratedKeys(model);
             List<ClassVo> classes = new ArrayList<>();
             if (model.getCoursetype() == 1) {

slive/src/main/java/com/xhkjedu/slive/service/liveplay/CsService.java

@@ -0,0 +1,218 @@
+package com.xhkjedu.slive.service.liveplay;
+
+import com.xhkjedu.slive.mapper.gradeclass.ClassTeacherMapper;
+import com.xhkjedu.slive.mapper.gradeclass.SchoolMapper;
+import com.xhkjedu.slive.mapper.liveplay.CourseClassMapper;
+import com.xhkjedu.slive.mapper.liveplay.CourseMapper;
+import com.xhkjedu.slive.mapper.liveplay.CsMapper;
+import com.xhkjedu.slive.mapper.system.UserMapper;
+import com.xhkjedu.slive.model.gradeclass.TClass;
+import com.xhkjedu.slive.model.gradeclass.TClassTeacher;
+import com.xhkjedu.slive.model.liveplay.LCourse;
+import com.xhkjedu.slive.model.liveplay.LCourseClass;
+import com.xhkjedu.slive.model.notice.TNotice;
+import com.xhkjedu.slive.service.gradeclass.ClassService;
+import com.xhkjedu.slive.service.notice.NoticeService;
+import com.xhkjedu.slive.vo.gradeclass.ClassVo;
+import com.xhkjedu.slive.vo.liveplay.CourseParams;
+import com.xhkjedu.slive.vo.liveplay.CourseVo;
+import com.xhkjedu.utils.N_Utils;
+import com.xhkjedu.vo.ResultVo;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.BeansException;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.transaction.interceptor.TransactionAspectSupport;
+
+import javax.annotation.Resource;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @author ywx
+ * @classname CourseService
+ * @description
+ * @date 2021/1/15 12:33
+ **/
+@Service
+@Slf4j
+public class CsService {
+    @Resource
+    private CourseMapper courseMapper;
+    @Resource
+    private ClassService classService;
+    @Resource
+    private ClassTeacherMapper classTeacherMapper;
+    @Resource
+    private NoticeService noticeService;
+    @Resource
+    private SchoolMapper schoolMapper;
+    @Resource
+    private UserMapper userMapper;
+    @Resource
+    private CourseClassMapper courseClassMapper;
+    @Resource
+    private CsMapper csMapper;
+
+    //添加
+    @Transactional(rollbackFor = Exception.class)
+    public ResultVo save(LCourse model) {
+        try {
+            List<Map> users = new ArrayList<>();
+            if (model.getCoursetype() == 1) {
+                if (N_Utils.isListEmpty(model.getClassids())) {
+                    return new ResultVo(1, "班级id集合不能为空");
+                }
+                users = courseMapper.listUid(model.getClassids());//获取课程学生id集合
+                if (N_Utils.isListEmpty(users)) {
+                    return new ResultVo(1, "直播班级学生为空");
+                }
+            }
+            model.setStunum(0);
+            model.setCoursestate(0);
+            model.setCreatetime(N_Utils.getSecondTimestamp());
+            String coursename = model.getCoursename();
+            Integer createid = model.getCreateid();
+            Integer schoolid = model.getSchoolid();
+            Integer teacherid = model.getTeacherid();
+            //班级信息
+            TClass c = new TClass();
+            c.setClassname(coursename + "班");
+            c.setCreateid(createid);
+            c.setSchoolid(schoolid);
+            Integer year = schoolMapper.getYearById(schoolid);
+            c.setSchoolyear(year);
+            c.setYear(year);
+            c.setClassorder(999);
+            c.setGradeid(model.getGradeid());
+
+            if (model.getCoursetype() == 1) {
+                c.setClasstype(99);//已直播班级
+            } else {
+                c.setClasstype(3);//直播班(学生选班)
+            }
+
+            Integer classid = classService.save(c);
+            if (!N_Utils.isEmptyInteger(teacherid)) {
+                //班级教师
+                TClassTeacher teacher = new TClassTeacher();
+                teacher.setClassid(classid);
+                teacher.setTeacherid(teacherid);
+                teacher.setCreateid(createid);
+                teacher.setCreatetime(N_Utils.getSecondTimestamp());
+                teacher.setSchoolid(schoolid);
+
+                classTeacherMapper.insertSelective(teacher);
+            }
+            //课程信息
+            model.setClassid(classid);
+            model.setDeleted(1);
+            model.setCourseclass(0);
+            model.setCourseschool(1);
+            courseMapper.insertUseGeneratedKeys(model);
+            List<ClassVo> classes = new ArrayList<>();
+            if (model.getCoursetype() == 1) {
+                Integer courseid = model.getId();
+                List<Integer> studentids = new ArrayList<>();
+                users.forEach(userVo -> {
+                    studentids.add((Integer) userVo.get("userid"));
+                });
+
+                classService.batchSaveStu(createid, schoolid, classid, studentids);//批量添加报名学生
+                courseMapper.updateStuNum(courseid);//更新已报学生数量
+
+                //保存直播关联班级
+                List<LCourseClass> cclist = new ArrayList<>();
+                for(Integer cid : model.getClassids()){
+                    LCourseClass cc = new LCourseClass();
+                    cc.setCourseid(courseid);
+                    cc.setClassid(cid);
+                    cc.setCreateid(model.getCreateid());
+                    cc.setCreatetime(N_Utils.getSecondTimestamp());
+                    cclist.add(cc);
+                    //通知班级
+                    ClassVo classVo = new ClassVo();
+                    classVo.setClassid(cid);
+                    classes.add(classVo);
+                }
+                courseClassMapper.insertList(cclist);//保存原班级和直播的关联关系
+            }
+
+            //通知信息
+            StringBuffer sbcomm = new StringBuffer(); //通知消息体
+            sbcomm.append("同学你好：本次直播课程为《").append(model.getCoursename()).append("》，共有").append(model.getCoursenum());
+            sbcomm.append("节课程，每节").append(model.getDuration()).append("分钟");
+            sbcomm.append("\n开课日期：").append(model.getBegindate()).append("，");
+            sbcomm.append("上课时间：").append(model.getBegintime());
+            if (!N_Utils.isEmptyInteger(teacherid)) {
+                String teachername = userMapper.getUserNameById(model.getTeacherid());
+                sbcomm.append("，主讲教师为").append(teachername).append("。");
+            }
+            if(N_Utils.isNotEmpty(model.getComm())){
+                sbcomm.append("\n主要内容为：").append(model.getComm());
+            }
+
+            if(model.getCoursetype()==0){
+                String strtime = N_Utils.getStrtimeTimestamp(model.getStarttime(),"yyyy-MM-dd HH:mm");
+                String littime = N_Utils.getStrtimeTimestamp(model.getLimitstamp(),"yyyy-MM-dd HH:mm");
+                sbcomm.append("\n报名日期：").append(strtime).append("至").append(littime).append("  ");
+                sbcomm.append("\n请同学在规定时间内进行报名。");
+            }
+
+            TNotice n = new TNotice();
+            StringBuilder sb = new StringBuilder();
+            sb.append(coursename);
+            sb.append("(开课时间：");
+            sb.append(model.getBegindate()).append(" ").append(model.getBegintime());
+            sb.append(")");
+            n.setNoticetitle(sb.toString());
+            n.setNoticecontent(sbcomm.toString());
+            n.setNoticetxt(sbcomm.toString());
+            n.setNoticetype(1);
+
+            if(model.getCoursetype()==0){
+                //如果是学生选课，选择的有年级，则通知关联年级下所有班级
+                List<Integer> classids = classService.listClassidsByGradeid(model.getGradeid(),model.getSchoolid());
+                if(classids!=null && classids.size()>0){
+                    for(Integer cid : classids){
+                        ClassVo classVo = new ClassVo();
+                        classVo.setClassid(cid);
+                        classes.add(classVo);
+                    }
+                }
+            }
+
+            n.setClasses(classes);
+            n.setCreateid(createid);
+            n.setCreatetime(model.getCreatetime());
+            n.setSchoolid(schoolid);
+            noticeService.save(n);
+            return new ResultVo(0, "保存成功", model.getId());
+        } catch (BeansException e) {
+            log.error("添加课程失败", e.getMessage());
+            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
+            return new ResultVo(1, "保存失败");
+        }
+    }
+
+    //获取列表
+    public List<CourseVo> listAll(LCourse course) {
+        return csMapper.listAll(course);
+    }
+
+    //课程班级
+    public List<Map> listClass(Integer courseid) {
+        return csMapper.listClass(courseid);
+    }
+
+    //我的月份下日期课节数量
+    public List<Map> listMySectionDate(CourseParams params) {
+        return csMapper.listMySectionDate(params);
+    }
+
+    //我的课程列表
+    public List<Map> listMySection(CourseParams params) {
+        return csMapper.listMySection(params);
+    }
+}

slive/src/main/java/com/xhkjedu/slive/service/xz/XzService.java

@@ -7,11 +7,7 @@ import com.xhkjedu.slive.mapper.liveplay.CourseMapper;
 import com.xhkjedu.slive.mapper.liveplay.CourseSectionMapper;
 import com.xhkjedu.slive.mapper.xz.XzKjMapper;
 import com.xhkjedu.slive.mapper.xz.XzMapper;
-import com.xhkjedu.slive.model.gradeclass.TClass;
-import com.xhkjedu.slive.model.gradeclass.TClassStudent;
-import com.xhkjedu.slive.model.gradeclass.TClassTeacher;
-import com.xhkjedu.slive.model.gradeclass.TGroup;
-import com.xhkjedu.slive.model.gradeclass.TGroupStudent;
+import com.xhkjedu.slive.model.gradeclass.*;
 import com.xhkjedu.slive.model.liveplay.LCourse;
 import com.xhkjedu.slive.model.liveplay.LCourseClass;
 import com.xhkjedu.slive.model.liveplay.LCourseSection;
@@ -23,11 +19,7 @@ import com.xhkjedu.slive.utils.PoiUtils;
 import com.xhkjedu.slive.vo.gradeclass.CStudentVo;
 import com.xhkjedu.slive.vo.gradeclass.CTeacherVo;
 import com.xhkjedu.slive.vo.liveplay.CourseVo;
-import com.xhkjedu.slive.vo.xz.XzClassVo;
-import com.xhkjedu.slive.vo.xz.XzDateKjTeaVo;
-import com.xhkjedu.slive.vo.xz.XzDateKjVo;
-import com.xhkjedu.slive.vo.xz.XzDateVo;
-import com.xhkjedu.slive.vo.xz.XzKjVo;
+import com.xhkjedu.slive.vo.xz.*;
 import com.xhkjedu.utils.N_Utils;
 import com.xhkjedu.vo.ResultVo;
 import lombok.extern.slf4j.Slf4j;
@@ -414,6 +406,7 @@ public class XzService {
             classTeacherMapper.insertSelective(teacher);
 
             //保存课程信息
+            course.setCourseschool(0);
             courseMapper.insertUseGeneratedKeys(course);
             courseid = course.getId();//课程id
 

slive/src/main/resources/mapper/liveplay/CsMapper.xml

@@ -0,0 +1,102 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.xhkjedu.slive.mapper.liveplay.CsMapper">
+    <!--课程列表-->
+    <select id="listAll" resultType="com.xhkjedu.slive.vo.liveplay.CourseVo">
+        select
+        c.courseid,c.coursename,c.gradeid,c.begindate,c.enddate,c.coursenum,c.begintime,c.endtime,c.duration,c.limitstamp
+        ,c.limitstu,c.stunum,c.coursestate,c.courseselected,c.coursetype,c.comm,c.teacherid,c.classid,c.starttime,c.createid
+        ,c.subjectid,s.subjectname,ct.typename,c.ctypeid
+        ,count(distinct case when cs.sectionstate=3 then cs.sectionid else null end)sectionnum
+        ,count(distinct case when cs.sectionstate=2 then cs.sectionid else null end)insectionnum
+        ,concat('[',group_concat(distinct json_object('teachername',u.username,'headpic',u.headpic)),']')teachername
+        ,group_concat( date_format(cs.sectiondate ,'%m月%d日') separator '、')sectiondate
+        from l_course c left join l_course_section cs on cs.courseid=c.courseid
+        left join t_user u on cs.teacherid=u.userid
+        left join t_subject s on c.subjectid = s.subjectid
+        left join l_course_type ct on c.ctypeid = ct.ctypeid
+        <if test="course.classid!=null and course.classid!=0">
+            left join l_course_class cc on cc.courseid=c.courseid
+        </if>
+        where c.createid=#{course.createid} and c.deleted=1 and c.courseschool=1
+        <if test="course.subjectid!=null and course.subjectid!='0'.toString() and course.subjectid!=''">
+            and c.subjectid=#{course.subjectid}
+        </if>
+        <if test="course.coursename!=null and course.coursename!=''">
+            and c.coursename like '%${course.coursename}%'
+        </if>
+        <if test="course.coursestate!=null">
+            and c.coursestate=#{course.coursestate}
+        </if>
+        <if test="course.today!=null and course.today==1">
+            and cs.sectiondate=date_format(now(),'%Y-%m-%d')
+        </if>
+        <if test="course.coursetype!=null">
+            and c.coursetype=#{course.coursetype}
+        </if>
+        <if test="course.ctypeid!=null and course.ctypeid!=0">
+            and ct.ctypeid=#{course.ctypeid}
+        </if>
+        <if test="course.createid!=null and course.createid!=0">
+            and c.createid=#{course.createid}
+        </if>
+        <if test="course.classid!=null and course.classid!=0">
+            and cc.classid=#{course.classid}
+        </if>
+        <if test="course.teachername!=null and course.teachername!=''">
+            and u.username like '%${course.teachername}%'
+        </if>
+        group by c.courseid order by c.courseid desc
+    </select>
+    <!--课程班级-->
+    <resultMap id="classResult" type="java.util.Map">
+        <result property="schoolid" column="schoolid"></result>
+        <result property="schoolname" column="schoolname"></result>
+        <collection property="classes" ofType="java.util.Map" javaType="java.util.List">
+            <result property="classid" column="classid"></result>
+            <result property="gradeid" column="gradeid"></result>
+            <result property="classname" column="classname"></result>
+        </collection>
+    </resultMap>
+    <select id="listClass" resultMap="classResult">
+        select lcc.classid,tc.gradeid,tc.classname,ts.schoolid,ts.schoolname
+        from l_course_class lcc left join t_class tc on lcc.classid = tc.classid
+        left join t_school ts on tc.schoolid = ts.schoolid
+        where lcc.courseid=#{courseid}
+    </select>
+    <!--我的月份下日期课节数量-->
+    <select id="listMySectionDate" resultType="java.util.Map">
+        select cs.sectiondate as timestr,count(distinct cs.sectionid)as num
+        ,count(distinct case when cs.sectionstate=0 then cs.sectionid else null end)wksnum
+        ,count(distinct case when cs.sectionstate=2 then cs.sectionid else null end)jxznum
+        ,count(distinct case when cs.sectionstate=3 then cs.sectionid else null end)yjsnum
+        ,count(distinct case when cs.sectionstate=4 then cs.sectionid else null end)ygqnum
+        from l_course_section cs left join l_course c on cs.courseid = c.courseid
+        where cs.teacherid=#{section.teacherid} and c.deleted=1 and c.courseschool=1 and DATE_FORMAT(cs.sectiondate, '%Y-%m')=#{section.timestr}
+        <if test="section.cstate!=null and section.cstate!=-1">
+            and cs.sectionstate=#{section.cstate}
+        </if>
+        <if test="section.sectionname!=null and section.sectionname!=''">
+            and cs.sectionname like '%${section.sectionname}%'
+        </if>
+        group by cs.sectiondate order by cs.sectiondate asc
+    </select>
+    <!--我的课程列表-->
+    <select id="listMySection" resultType="java.util.Map">
+        select c.courseid,c.gradeid,c.stunum,c.comm,c.createid,c.classid
+        ,(select t.typename from l_course_type t where t.ctypeid=c.ctypeid)typename
+        ,cs.sectionid,cs.sectionname,cs.sectiondate,cs.teacherid,cs.stunum cynum
+        ,cs.planbegintime,cs.planendtime,cs.begintime,cs.endtime,cs.sectionstate
+        ,(UNIX_TIMESTAMP(CONCAT(cs.sectiondate,' ',cs.planendtime))-UNIX_TIMESTAMP(CONCAT(cs.sectiondate,' ',cs.planbegintime))) totaltime
+        ,(select count(*) from l_course_section_playback p where p.sectionid=cs.sectionid and p.pb is not null)playnum
+        from l_course_section cs left join l_course c on cs.courseid = c.courseid
+        where cs.teacherid=#{section.teacherid} and c.deleted=1 and c.courseschool=1 and cs.sectiondate=#{section.timestr}
+        <if test="section.cstate!=null and section.cstate!=-1">
+            and cs.sectionstate=#{section.cstate}
+        </if>
+        <if test="section.sectionname!=null and section.sectionname!=''">
+            and cs.sectionname like '%${section.sectionname}%'
+        </if>
+        order by cs.sectionstate,abs(UNIX_TIMESTAMP(concat(cs.sectiondate,' ',cs.planbegintime))-UNIX_TIMESTAMP(now())),cs.sectionid
+    </select>
+</mapper>