行政直播

slive/src/main/java/com/xhkjedu/slive/controller/xz/XzController.java

@@ -0,0 +1,109 @@
+package com.xhkjedu.slive.controller.xz;
+
+import com.github.pagehelper.PageHelper;
+import com.github.pagehelper.PageInfo;
+import com.xhkjedu.slive.model.xz.LXz;
+import com.xhkjedu.slive.service.xz.XzService;
+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;
+
+/**
+ *@Description
+ *@Author WN
+ *Date 2022/3/30 12:09
+ **/
+@RestController
+@RequestMapping("/xz")
+public class XzController {
+
+    @Resource
+    private XzService xzService;
+
+    /** 行政直播列表
+     * @Description
+     * @Param [xz]
+     * @Return com.xhkjedu.vo.ResultVo
+     * @Author wn
+     * @Date 2022/3/30 13:55
+     **/
+    @PostMapping("/list")
+    public ResultVo list(@RequestBody LXz xz){
+        N_Utils.validation(new Object[]{xz.getSchoolid(),"学校id",1});
+        PageHelper.startPage(xz.getPage(), xz.getPageSize());
+        List<Map> list = xzService.listXzs(xz.getSchoolid(),xz.getXzname());
+        PageResult pageResult = PageUtil.getPageResult(new PageInfo(list));
+        return new ResultVo(0,"获取行政直播列表成功",pageResult);
+    }
+
+
+   /**
+    * @Description 保存行政直播
+    * @Param xz
+    * @Return com.xhkjedu.vo.ResultVo
+    * @Author wn
+    * @Date 2022/3/30 13:51
+    **/
+    @PostMapping("/save")
+    public ResultVo save(@RequestBody LXz xz){
+        N_Utils.validation(new Object[]{xz.getXzname(),"名称",2,xz.getGradeid(),"年级",1,xz.getDaynum(),"课节数量",1,
+        xz.getBegindate(),"开始日期",2,xz.getEnddate(),"结束日期",2,xz.getSchoolid(),"学校id",1});
+        if ("NaN-aN-aN".equals(xz.getBegindate()) || "NaN-aN-aN".equals(xz.getEnddate())) {
+            return new ResultVo(1,"日期格式不正确");
+        }
+        Integer xzid = xzService.saveXz(xz);
+        return new ResultVo(0, "保存成功",xzid);
+    }
+
+    /**
+     * @Description 修改行政直播
+     * @Param [xz]
+     * @Return com.xhkjedu.vo.ResultVo
+     * @Author wn
+     * @Date 2022/3/30 17:05
+     **/
+    @PostMapping("/update")
+    public ResultVo update(@RequestBody LXz xz){
+        N_Utils.validation(new Object[]{xz.getXzid(),"行政直播id",1,xz.getXzname(),"名称",2});
+        xzService.updateXz(xz);
+        return new ResultVo(0, "修改成功");
+    }
+
+    /**
+     * @Description  行政直播下进行中和已结束课数量
+     * @Param [xz]
+     * @Return com.xhkjedu.vo.ResultVo
+     * @Author wn
+     * @Date 2022/3/30 15:23
+     **/
+    @PostMapping("/snum")
+    public ResultVo getXzSectionKsNum(@RequestBody LXz xz){
+        N_Utils.validation(new Object[]{xz.getXzid(),"行政直播id",1});
+        Integer num = xzService.getXzSectionKsNum(xz.getXzid());
+        return new ResultVo(0, "成功获取直播下进行中和结束课数量",num);
+    }
+
+    /**
+     * @Description 删除行政直播
+     * @Param [xz]
+     * @Return com.xhkjedu.vo.ResultVo
+     * @Author wn
+     * @Date 2022/3/30 14:29
+     **/
+    @PostMapping("/del")
+    public ResultVo delete(@RequestBody LXz xz){
+        N_Utils.validation(new Object[]{xz.getXzid(),"行政直播id",1});
+        xzService.deleteXz(xz.getXzid());
+        return new ResultVo(0, "删除成功");
+    }
+
+}

slive/src/main/java/com/xhkjedu/slive/controller/xz/XzKjController.java

@@ -0,0 +1,50 @@
+package com.xhkjedu.slive.controller.xz;
+
+import com.xhkjedu.slive.model.xz.LXzKj;
+import com.xhkjedu.slive.service.xz.XzKjService;
+import com.xhkjedu.utils.N_Utils;
+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;
+
+/**
+ * @Description 行政直播课节详情
+ * @Author WN
+ * Date 2022/3/30 15:25
+ **/
+@RestController
+@RequestMapping("/xzkj")
+public class XzKjController {
+    @Resource
+    private XzKjService xzKjService;
+
+    /**
+     * @Description 保存直播课课节信息
+     * @Param [kj]
+     * @Return com.xhkjedu.vo.ResultVo
+     * @Author wn
+     * @Date 2022/3/30 16:22
+     **/
+    @PostMapping("/save")
+    public ResultVo save(@RequestBody LXzKj kj){
+        N_Utils.validation(new Object[]{kj.getXzid(),"行政直播id",1,kj.getCreateid(),"创建人",1});
+        return xzKjService.save(kj);
+    }
+
+    /**
+     * @Description 修改直播课节信息
+     * @Param [kj]
+     * @Return com.xhkjedu.vo.ResultVo
+     * @Author wn
+     * @Date 2022/3/30 17:53
+     **/
+    @PostMapping("/update")
+    public ResultVo update(@RequestBody List<LXzKj> kjs){
+       return xzKjService.updateBatch(kjs);
+    }
+}

slive/src/main/java/com/xhkjedu/slive/mapper/xz/XzKjMapper.java

@@ -0,0 +1,24 @@
+package com.xhkjedu.slive.mapper.xz;
+
+import com.xhkjedu.slive.base.TkMapper;
+import com.xhkjedu.slive.model.xz.LXzKj;
+import org.apache.ibatis.annotations.Param;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @Description 直播课节详情
+ * @Author wn
+ * @Date 2022/3/30 12:06
+ */
+@Repository
+public interface XzKjMapper extends TkMapper<LXzKj> {
+
+    //获取行政直播课节详情
+    List<Map> listXzKjsByXzid(@Param("xzid") Integer xzid);
+
+    //批量修改行政直播课节详情
+    void updateBatchXzKj(@Param("list") List<LXzKj> list);
+}

slive/src/main/java/com/xhkjedu/slive/mapper/xz/XzMapper.java

@@ -0,0 +1,37 @@
+package com.xhkjedu.slive.mapper.xz;
+
+import com.xhkjedu.slive.base.TkMapper;
+import com.xhkjedu.slive.model.xz.LXz;
+import org.apache.ibatis.annotations.Param;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @Deprecated  直播行政概要表
+ * @Duthor wn
+ * @Date 2022/3/30 12:01
+ */
+@Repository
+public interface XzMapper extends TkMapper<LXz> {
+
+    //行政直播列表
+    List<Map> listXzs(@Param("schoolid") Integer schoolid,@Param("xzname") String xzname);
+
+    //行政直播下进行中或已结束的课节数量
+    Integer getXzSectionKsNum(@Param("xzid") Integer xzid);
+
+    //删除行政直播下所有的直播课程和直播班级
+    void deleteCourseClassByXzid(@Param("xzid") Integer xzid);
+
+    //删除行政直播和课节详情
+    void deleteXzAndKjByXzid(@Param("xzid") Integer xzid);
+
+    //删除行政直播下未开始的直播课、班级、课节详情
+    void deleteCourseClassKjByXzid(@Param("xzid") Integer xzid);
+
+    //修改行政直播删除状态
+    void updateXzDeleted(@Param("deleted") Integer deleted,@Param("xzid") Integer xzid);
+
+}

slive/src/main/java/com/xhkjedu/slive/model/xz/LXz.java

@@ -0,0 +1,49 @@
+package com.xhkjedu.slive.model.xz;
+import com.xhkjedu.slive.model.BaseBean;
+import lombok.Data;
+
+import javax.persistence.Id;
+import javax.persistence.Table;
+
+/**
+ *@Description 行政直播概要表
+ *@Author WN
+ *Date 2022/3/30 11:52
+ **/
+@Data
+@Table(name = "l_xz")
+public class LXz extends BaseBean {
+    //行政直播概要表
+    @Id
+    private Integer xzid;
+
+    //名称
+    private String xzname;
+
+    //概要
+    private String xzcomm;
+
+    //年级
+    private Integer gradeid;
+
+    //日课节数
+    private Integer daynum;
+
+    //开始日期
+    private String begindate;
+
+    //结束日期
+    private String enddate;
+
+    //是否删除1正常10已删除
+    private Integer deleted;
+
+    //创建人
+    private Integer createid;
+
+    //创建时间
+    private Integer createtime;
+
+    //学校id
+    private Integer schoolid;
+}

slive/src/main/java/com/xhkjedu/slive/model/xz/LXzKj.java

@@ -0,0 +1,49 @@
+package com.xhkjedu.slive.model.xz;
+
+import com.xhkjedu.slive.model.BaseBean;
+import lombok.Data;
+
+import javax.persistence.Table;
+import java.util.List;
+import javax.persistence.Id;
+import javax.persistence.Transient;
+
+/**
+ *@Description 行政直播课节表
+ *@Author WN
+ *Date 2022/3/30 11:52
+ **/
+@Data
+@Table(name = "l_xz_kj")
+public class LXzKj extends BaseBean {
+
+    //行政直播课节详情表
+    @Id
+    private Integer kjid;
+
+    //行政直播概要表
+    private Integer xzid;
+
+    //课节名称
+    private String kjname;
+
+    //课节排序
+    private Integer kjorder;
+
+    //开始时间
+    private String begintime;
+
+    //结束时间
+    private String endtime;
+
+    //创建人
+    private Integer createid;
+
+    //创建时间
+    private Integer createtime;
+
+    //课节集合
+    @Transient
+    private List<LXzKj> xzkjs;
+
+}

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

@@ -0,0 +1,76 @@
+package com.xhkjedu.slive.service.xz;
+
+import com.xhkjedu.slive.mapper.xz.XzKjMapper;
+import com.xhkjedu.slive.model.xz.LXzKj;
+import com.xhkjedu.utils.N_Utils;
+import com.xhkjedu.vo.ResultVo;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @Description
+ * @Author WN
+ * Date 2022/3/30 15:26
+ **/
+@Service
+public class XzKjService {
+    @Resource
+    private XzKjMapper xzKjMapper;
+
+    /**
+     * @Description 保存课节信息
+     * @Param [xzKj]
+     * @Return com.xhkjedu.vo.ResultVo
+     * @Author wn
+     * @Date 2022/3/30 16:19
+     **/
+    public ResultVo save(LXzKj xzKj) {
+        Integer timestamp = N_Utils.getSecondTimestamp();
+        List<LXzKj> kjlst = xzKj.getXzkjs();
+        if (kjlst == null || kjlst.size() == 0) {
+            return new ResultVo(1, "未设置课节信息");
+        } else {
+            for (int i = 0; i < kjlst.size(); i++) {
+                LXzKj kj = kjlst.get(i);
+                kj.setXzid(xzKj.getXzid());
+                kj.setCreateid(xzKj.getCreateid());
+                kj.setCreatetime(timestamp);
+                kj.setKjorder(i + 1);
+            }
+
+            xzKjMapper.insertList(kjlst);
+            //获取保存课节信息集合
+            List<Map> rtnlst = xzKjMapper.listXzKjsByXzid(xzKj.getXzid());
+            return new ResultVo(0, "保存成功", rtnlst);
+        }
+    }
+
+    /**
+     * @Description 修改行政直播课节信息
+     * @Param [xzKjs]
+     * @Return com.xhkjedu.vo.ResultVo
+     * @Author wn
+     * @Date 2022/3/30 21:51
+     **/
+    public ResultVo updateBatch(List<LXzKj> xzKjs) {
+        for (int i = 0; i < xzKjs.size(); i++) {
+            boolean rtn = false;
+            LXzKj kj = xzKjs.get(i);
+            if (kj.getKjid() == null || kj.getKjid() == 0) {
+                rtn = true;
+            }
+            if (N_Utils.isEmpty(kj.getKjname()) || N_Utils.isEmpty(kj.getBegintime()) || N_Utils.isEmpty(kj.getEndtime())) {
+                rtn = true;
+            }
+            if(rtn){
+                return new ResultVo(1,"课节信息不完善");
+            }
+        }
+
+        xzKjMapper.updateBatchXzKj(xzKjs);
+        return new ResultVo(0,"修改课节信息成功");
+    }
+}

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

@@ -0,0 +1,91 @@
+package com.xhkjedu.slive.service.xz;
+
+import com.xhkjedu.slive.mapper.xz.XzMapper;
+import com.xhkjedu.slive.model.xz.LXz;
+import com.xhkjedu.utils.N_Utils;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import javax.annotation.Resource;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @Description 行政直播概要
+ * @Author WN
+ * Date 2022/3/30 13:42
+ **/
+@Service
+public class XzService {
+    @Resource
+    private XzMapper xzMapper;
+
+    /**
+     * @Description 行政直播列表
+     * @Param [schoolid]
+     * @Return java.util.List<java.util.Map>
+     * @Author wn
+     * @Date 2022/3/30 14:03
+     **/
+    public List<Map> listXzs(Integer schoolid, String xzname) {
+        return xzMapper.listXzs(schoolid, xzname);
+    }
+
+    /**
+     * @Description 保存行政直播
+     * @Param [xz]
+     * @Return void
+     * @Author wn
+     * @Date 2022/3/30 14:07
+     **/
+    public Integer saveXz(LXz xz) {
+        xz.setCreatetime(N_Utils.getSecondTimestamp());
+        xz.setDeleted(1);
+        xzMapper.insertUseGeneratedKeys(xz);
+        return xz.getId();
+    }
+
+    /**
+     * @Description 修改行政直播
+     * @Param [xz]
+     * @Return void
+     * @Author wn
+     * @Date 2022/3/30 14:16
+     **/
+    public void updateXz(LXz xz) {
+        xzMapper.updateByPrimaryKeySelective(xz);
+    }
+
+    //获取行政直播课下进行中或者已结束的直播课数量
+    public Integer getXzSectionKsNum(Integer xzid) {
+        Integer num = xzMapper.getXzSectionKsNum(xzid);
+        if (num == null) {
+            num = 0;
+        }
+        return num;
+    }
+
+    /**
+     * @Description 删除行政直播
+     * @Param [xzid]
+     * @Return void
+     * @Author wn
+     * @Date 2022/3/30 15:24
+     **/
+    @Transactional
+    public void deleteXz(Integer xzid) {
+        //如果行政直播下所有的课都未开始，则可以直接删除，
+        //如果有直播课已经开始则进行逻辑删除，并删除所有未开始上的直播课
+        Integer sectionnum = xzMapper.getXzSectionKsNum(xzid);
+        if (sectionnum != null && sectionnum > 0) {
+            //说明直播下有开始或结束的课节，只能删除未开始的直播和直播班级信息
+            xzMapper.deleteCourseClassKjByXzid(xzid);
+            //修改行政直播的状态未已删除
+            xzMapper.updateXzDeleted(10, xzid);
+        } else {
+            //说明该行政直播课程可以直接删除
+            xzMapper.deleteCourseClassByXzid(xzid);
+            xzMapper.deleteXzAndKjByXzid(xzid);
+        }
+    }
+}

slive/src/main/resources/mapper/xz/XzKjMapper.xml

@@ -0,0 +1,17 @@
+<?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.xz.XzKjMapper">
+
+    <!--获取行政直播课节详情-->
+    <select id="listXzKjsByXzid" resultType="java.util.Map">
+        select * from l_xz_kj where xzid=1 order by kjorder asc
+    </select>
+
+    <!--批量修改行政直播课节详情-->
+    <update id="updateBatchXzKj" parameterType="java.util.List">
+        <foreach collection="list" item="kj" index="index" separator=";">
+            update l_xz_kj set kjname=#{kj.kjname},begintime=#{kj.begintime},endtime=#{kj.endtime}
+            where kjid=#{kj.kjid}
+        </foreach>
+    </update>
+</mapper>

slive/src/main/resources/mapper/xz/XzMapper.xml

@@ -0,0 +1,60 @@
+<?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.xz.XzMapper">
+
+    <!--行政直播列表-->
+    <select id="listXzs" resultType="java.util.Map">
+        select x.xzid,x.xzname,x.xzcomm,x.gradeid,x.daynum,x.begindate,x.enddate,x.createid,
+        x.createtime, u.username from l_xz x left join t_user u on x.createid=u.userid
+        where x.schoolid=#{schoolid} and x.deleted=1
+        <if test="xzname!='' and xzname!=null">
+            and x.xzname like '%${xzname}%'
+        </if>
+        order by x.begindate desc
+    </select>
+
+    <!--行政直播课对应的课节进行中或已结束数量-->
+    <select id="getXzSectionKsNum" resultType="java.lang.Integer">
+        select count(*)
+        from l_course_section s
+                 left join l_course c on c.courseid = s.courseid
+                 left join l_xz_kj k on c.kjid = k.kjid
+        where k.xzid = #{xzid}
+          and s.sectionstate BETWEEN 2 and 3
+    </select>
+
+    <!--删除行政直播下所有的直播课程和直播班级-->
+    <delete id="deleteCourseClassByXzid" parameterType="java.lang.Integer">
+        delete
+        c,lc from t_class as c left join l_course as lc on c.classid=lc.classid
+        left join l_xz_kj k on k.kjid=lc.kjid where k.xzid=
+        #{xzid}
+    </delete>
+    <!--删除行政直播和课节详情-->
+    <delete id="deleteXzAndKjByXzid">
+        delete
+        x,k from l_xz as x left join l_xz_kj as k on x.xzid=k.xzid where x.xzid=
+        #{xzid}
+    </delete>
+    <!--删除行政直播下未开始的直播课、班级、课节详情-->
+    <delete id="deleteCourseClassKjByXzid">
+        delete
+        c,lc,k from t_class as c left join l_course as lc on c.classid=lc.classid
+        left join l_course_section ls on ls.courseid=lc.courseid
+        left join l_xz_kj k on k.kjid=lc.kjid where k.xzid=
+        #{xzid}
+        and
+        ls
+        .
+        sectionstate
+        =
+        0
+    </delete>
+    <!--修改行政直播删除状态-->
+    <update id="updateXzDeleted">
+        update l_xz
+        set deleted=#{deleted}
+        where xzid = #{xzid}
+    </update>
+
+</mapper>