教育项目--课程模块--课程导入【28】

╰+攻爆jí腚メ 2023-10-05 18:38 4阅读 0赞

#### 课程模块课程导入 ####

*  1.pom中引入xml相关依赖
 *  2.实体类
 *  3.自动生成
 *  4.监听器
 *  5.service
 *  6.controller
 *  7.测试

## 1.pom中引入xml相关依赖 ##

<dependencies>
 
 <dependency>
 <groupId>com.alibaba</groupId>
 <artifactId>easyexcel</artifactId>
 <version>2.1.1</version>
 </dependency>
 
 <dependency>
 <groupId>org.apache.poi</groupId>
 <artifactId>poi</artifactId>
 <version>3.17</version>
 </dependency>
 
 <dependency>
 	 <groupId>org.apache.poi</groupId>
 	 <artifactId>poi-ooxml</artifactId>
 	 <version3.17</version>
 </dependency>
 
 </dependencies>

## 2.实体类 ##

`ExcelSubjectData`

package com.djr.eduservice.config.excel;
    
    import com.alibaba.excel.annotation.ExcelProperty;
    import lombok.Data;
    
    /**
     * @Program: science_source_education
     * @Description
     * @Author: 涛涛 * ^ *
     * @Create: 2021-01-29 12:10
     **/
    @Data
    public class ExcelSubjectData {
        
    
        @ExcelProperty(index = 0)
        private String oneSubjectName;
    
        @ExcelProperty(index = 1)
        private String twoSubjectName;
    }

`EduSubject`

package com.djr.eduservice.entity;
 
 import com.baomidou.mybatisplus.annotation.FieldFill;
 import com.baomidou.mybatisplus.annotation.IdType;
 import java.util.Date;
 
 import com.baomidou.mybatisplus.annotation.TableField;
 import com.baomidou.mybatisplus.annotation.TableId;
 import java.io.Serializable;
 import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
 import lombok.experimental.Accessors;
 
 /**
 * 
 * 课程科目
 * 
 *
 * @author taotao
 * @since 2021-01-29
 */
 @Data
 @EqualsAndHashCode(callSuper = false)
 @Accessors(chain = true)
 @ApiModel(value="EduSubject对象", description="课程科目")
 public class EduSubject implements Serializable {
 
 
 private static final long serialVersionUID = 1L;
 
 @ApiModelProperty(value = "课程类别ID")
 @TableId(value = "id", type = IdType.ID_WORKER_STR)
 private String id;
 
 @ApiModelProperty(value = "类别名称")
 private String title;
 
 @ApiModelProperty(value = "父ID")
 private String parentId;
 
 @ApiModelProperty(value = "排序字段")
 private Integer sort;
 
 @ApiModelProperty(value = "创建时间")
 @TableField(fill = FieldFill.INSERT)
 private Date gmtCreate;
 
 @ApiModelProperty(value = "更新时间")
 @TableField(fill = FieldFill.INSERT_UPDATE)
 private Date gmtModified;
 
 
 }

## 3.自动生成 ##

`EduSubjectMapper`

package com.djr.eduservice.mapper;
 
 import com.djr.eduservice.entity.EduSubject;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import org.apache.ibatis.annotations.Mapper;
 
 /**
 * 
 * 课程科目 Mapper 接口
 * 
 *
 * @author taotao
 * @since 2021-01-29
 */
 @Mapper
 public interface EduSubjectMapper extends BaseMapper<EduSubject> {
 
 
 }

## 4.监听器 ##

`SubjectExcelListener`

package com.djr.eduservice.config.excel;
 
 import com.alibaba.excel.context.AnalysisContext;
 import com.alibaba.excel.event.AnalysisEventListener;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.djr.eduservice.entity.EduSubject;
 import com.djr.eduservice.service.EduSubjectService;
 import com.djr.servicebase.exceptionhandler.MyselfException;
 
 import java.util.Map;
 
 /**
 * @Program: science_source_education
 * @Description
 * @Author: 涛涛 * ^ *
 * @Create: 2021-01-29 12:11
 **/
 public class SubjectExcelListener extends AnalysisEventListener<ExcelSubjectData> {
 
 
 /**
 * 因为监听器不能够Spring进行注入管理
 * 所以在这里直接创建一个业务上的Service
 */
 public EduSubjectService subjectService;
 
 public SubjectExcelListener() {
 
 
 }
 
 /**
 * 创建有参数构造，传递subjectService用于操作数据库
 * @param subjectService
 */
 public SubjectExcelListener(EduSubjectService subjectService) {
 
 this.subjectService = subjectService;
 }
 
 /**
 * 读取excle内容
 * @param subjectData
 * @param analysisContext
 */
 @Override
 public void invoke(ExcelSubjectData subjectData, AnalysisContext analysisContext) {
 
 
 //判断文件内是否为空
 if(subjectData == null) {
 
 throw new MyselfException(50002,"添加失败，内容为空");
 }
 //添加一级分类(第一个值为一级分类，第二个值为二级分类) 因此需要今次那个判断是否是有重复的内容
 //判断一级分类是否有重复的
 EduSubject existOneSubject = this.existOneSubject(subjectService,subjectData.getOneSubjectName());
 //没有相同的一级分类
 if(existOneSubject == null) {
 
 existOneSubject = new EduSubject();
 existOneSubject.setTitle(subjectData.getOneSubjectName());
 existOneSubject.setParentId("0");
 subjectService.save(existOneSubject);
 }
 
 //获取一级分类id值
 String pid = existOneSubject.getId();
 
 //添加二级分类
 //判断二级分类是否有重复的
 EduSubject existTwoSubject = this.existTwoSubject(subjectService,subjectData.getTwoSubjectName(), pid);
 //没有相同的二级分类
 if(existTwoSubject == null) {
 
 existTwoSubject = new EduSubject();
 existTwoSubject.setTitle(subjectData.getTwoSubjectName());
 existTwoSubject.setParentId(pid);
 subjectService.save(existTwoSubject);
 }
 }
 
 /**
 * 读取excel表头信息
 * @param headMap
 * @param context
 */
 @Override
 public void invokeHeadMap(Map<Integer, String> headMap, AnalysisContext context) {
 
 System.out.println("表头信息："+headMap);
 }
 
 /**
 * 读取完成后执行
 * @param analysisContext
 */
 @Override
 public void doAfterAllAnalysed(AnalysisContext analysisContext) {
 }
 
 /**
 * 判断一级分类是否重复
 * @param subjectService
 * @param name
 * @return
 */
 private EduSubject existOneSubject(EduSubjectService subjectService,String name) {
 
 QueryWrapper<EduSubject> wrapper = new QueryWrapper<>();
 wrapper.eq("title",name);
 wrapper.eq("parent_id","0");
 EduSubject eduSubjectIsOne = subjectService.getOne(wrapper);
 return eduSubjectIsOne;
 }
 
 /**
 * 判断二级分类是否重复
 * @param subjectService
 * @param name
 * @param pid
 * @return
 */
 private EduSubject existTwoSubject(EduSubjectService subjectService, String name, String pid) {
 
 QueryWrapper<EduSubject> wrapper = new QueryWrapper<>();
 wrapper.eq("title",name);
 wrapper.eq("parent_id",pid);
 EduSubject eduSubjectIsTwo = subjectService.getOne(wrapper);
 return eduSubjectIsTwo;
 }
 }

## 5.service ##

package com.djr.eduservice.service;
 
 import com.djr.eduservice.entity.EduSubject;
 import com.baomidou.mybatisplus.extension.service.IService;
 import org.springframework.web.multipart.MultipartFile;
 
 /**
 * 
 * 课程科目 服务类
 * 
 *
 * @author taotao
 * @since 2021-01-29
 */
 public interface EduSubjectService extends IService<EduSubject> {
 
 
 /**
 * 通过读取excel的方式进行添加课程
 */
 void saveSubject(MultipartFile file,EduSubjectService eduSubjectService);
 }

package com.djr.eduservice.service.impl;
 
 import com.alibaba.excel.EasyExcel;
 import com.djr.eduservice.config.excel.ExcelSubjectData;
 import com.djr.eduservice.config.excel.SubjectExcelListener;
 import com.djr.eduservice.entity.EduSubject;
 import com.djr.eduservice.mapper.EduSubjectMapper;
 import com.djr.eduservice.service.EduSubjectService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.djr.servicebase.exceptionhandler.MyselfException;
 import org.springframework.stereotype.Service;
 import org.springframework.web.multipart.MultipartFile;
 
 import java.io.InputStream;
 
 /**
 * 
 * 课程科目 服务实现类
 * 
 *
 * @author taotao
 * @since 2021-01-29
 */
 @Service
 public class EduSubjectServiceImpl extends ServiceImpl<EduSubjectMapper, EduSubject> implements EduSubjectService {
 
 
 /**
 * 通过读取excel的方式进行添加课程
 * 添加课程分类
 * poi读取excel内容
 * @param file
 */
 @Override
 public void saveSubject(MultipartFile file,EduSubjectService eduSubjectService) {
 
 try {
 
 //1 获取文件输入流
 InputStream inputStream = file.getInputStream();
 
 // 这里 需要指定读用哪个class去读，然后读取第一个sheet 文件流会自动关闭
 EasyExcel.read(inputStream,
 ExcelSubjectData.class,
 new SubjectExcelListener(eduSubjectService))
 .sheet()
 .doRead();
 }catch(Exception e) {
 
 e.printStackTrace();
 throw new MyselfException(50001,"添加课程分类失败");
 }
 }
 }

## 6.controller ##

package com.djr.eduservice.controller;
 
 
 import com.djr.commonutils.R;
 import com.djr.eduservice.service.EduSubjectService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.CrossOrigin;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 
 import org.springframework.web.bind.annotation.RestController;
 import org.springframework.web.multipart.MultipartFile;
 
 /**
 * 
 * 课程科目 前端控制器
 * 
 *
 * @author taotao
 * @since 2021-01-29
 */
 @Api(description = "课程模块")
 @CrossOrigin
 @RestController
 @RequestMapping("/eduservice/edu-subject")
 public class EduSubjectController {
 
 @Autowired
 EduSubjectService eduSubjectService;
 
 /**
 * 添加课程分类
 */
 @ApiOperation(value = "Excel批量导入")
 @PostMapping("/addSubject")
 public R addSubject(MultipartFile file) {
 
 
 eduSubjectService.saveSubject(file, eduSubjectService);
 
 
 return R.ok();
 }
 
 /**
 * 获取上传文件，文件内容进行读取
 */
 
 }

## 7.测试 ##

![在这里插入图片描述][20210129141045691.png]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0phdmFiYWliYWk_size_16_color_FFFFFF_t_70]

[20210129141045691.png]: https://img-blog.csdnimg.cn/20210129141045691.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0phdmFiYWliYWk_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20210129141050731.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0phdmFiYWliYWk=,size_16,color_FFFFFF,t_70