[督导与指控 ] 督导与指控接口开发

pom.xml

@@ -273,12 +273,17 @@
         <dependency>
             <groupId>org.apache.poi</groupId>
             <artifactId>poi</artifactId>
-            <version>3.17</version>
+            <version>4.0.0</version>
         </dependency>
         <dependency>
             <groupId>org.apache.poi</groupId>
             <artifactId>poi-ooxml</artifactId>
-            <version>3.17</version>
+            <version>4.0.0</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.poi</groupId>
+            <artifactId>poi-scratchpad</artifactId>
+            <version>4.0.0</version>
         </dependency>
         <dependency>
             <groupId>xerces</groupId>

src/main/java/com/cirle/scientific/controller/miniapp/SuperviseController.java

@@ -0,0 +1,38 @@
+package com.cirle.scientific.controller.miniapp;/*
+ *24901
+ *2023/1/4
+ *9:47
+ */
+
+import com.cirle.scientific.pojo.Result;
+import com.cirle.scientific.service.SuperviseAppService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiParam;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.*;
+
+/**
+ * @author 24901
+ */
+@Controller
+@RequestMapping("/app/Supervise")
+@Api("督导与指控接口")
+public class SuperviseController {
+
+    private SuperviseAppService superviseAppService;
+
+    @Autowired
+    public void setSuperviseAppService(SuperviseAppService superviseAppService) {
+        this.superviseAppService = superviseAppService;
+    }
+
+    @GetMapping("/findSupervise")
+    @ResponseBody
+    public Result findSupervise(@ApiParam(name = "memCard", value = "用户唯一标识")   String memCard
+            , @RequestParam(name = "type") Integer type){
+        return Result.success(superviseAppService.findSuperviseResult(memCard,type));
+    }
+
+
+}

src/main/java/com/cirle/scientific/dao/QkjSuperviseAppDao.java

@@ -0,0 +1,19 @@
+package com.cirle.scientific.dao;/*
+ *24901
+ *2023/1/4
+ *9:31
+ */
+
+import com.cirle.scientific.po.QkjSuperviseApp;
+import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.PagingAndSortingRepository;
+
+import java.util.LinkedList;
+
+public interface QkjSuperviseAppDao extends PagingAndSortingRepository<QkjSuperviseApp, Long>, JpaSpecificationExecutor<QkjSuperviseApp> {
+
+    @Query(value = "select result_file from qkj_supervise_app where mem_card = ?1 and year = ?2 and type = ?3 and status = 0 group by month asc", nativeQuery = true)
+    LinkedList<String> findResultFileByYearAndTypeAndMemCard(String memCard, Integer year, Integer type);
+
+}

src/main/java/com/cirle/scientific/po/QkjSuperviseApp.java

@@ -0,0 +1,53 @@
+package com.cirle.scientific.po;/*
+ *24901
+ *2023/1/4
+ *9:23
+ */
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import org.springframework.data.annotation.CreatedDate;
+import org.springframework.data.annotation.LastModifiedDate;
+
+import javax.persistence.*;
+import java.time.LocalDateTime;
+
+@Entity
+@Table(name = "qkj_supervise_app")
+@Data
+@ApiModel
+public class QkjSuperviseApp {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    @ApiModelProperty(value = "督导表id")
+    private Long id;
+
+    @ApiModelProperty(value = "用户唯一标识")
+    private String memCard;
+
+    @ApiModelProperty(value = "上传的结果文件url")
+    private String resultFile;
+
+    @ApiModelProperty(value = "0: 线上督导结果, 1:线下督导结果, 2:质控结果")
+    private Integer type;
+
+    @ApiModelProperty(value = "上传当前的年")
+    private Integer year;
+
+    @ApiModelProperty(value = "上传的月份")
+    private Integer month;
+
+    @ApiModelProperty(value = "状态 0:未删除 1删除")
+    private Integer status;
+
+    @CreatedDate
+    @Column(nullable = false, updatable = false)
+    private LocalDateTime createTime;
+
+    @LastModifiedDate
+    @Column()
+    private LocalDateTime updateTime;
+
+}

src/main/java/com/cirle/scientific/service/SuperviseAppService.java

@@ -0,0 +1,15 @@
+package com.cirle.scientific.service;/*
+ *24901
+ *2023/1/4
+ *9:58
+ */
+
+import java.util.LinkedList;
+
+/**
+ * @author 24901
+ */
+public interface SuperviseAppService {
+
+    LinkedList<String> findSuperviseResult(String memCard , Integer type);
+}

src/main/java/com/cirle/scientific/service/impl/SuperviseAppServiceImpl.java

@@ -0,0 +1,58 @@
+package com.cirle.scientific.service.impl;/*
+ *24901
+ *2023/1/4
+ *10:01
+ */
+
+import com.cirle.scientific.dao.QkjSuperviseAppDao;
+import com.cirle.scientific.service.SuperviseAppService;
+import com.cirle.scientific.utils.ReadWordUtil;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.InputStream;
+import java.net.URI;
+import java.util.Calendar;
+import java.util.LinkedList;
+
+@Service
+@Slf4j
+public class SuperviseAppServiceImpl implements SuperviseAppService {
+
+    private QkjSuperviseAppDao qkjSuperviseAppDao;
+
+    @Autowired
+    public void setQkjSuperviseAppDao(QkjSuperviseAppDao qkjSuperviseAppDao) {
+        this.qkjSuperviseAppDao = qkjSuperviseAppDao;
+    }
+
+    @Override
+    public LinkedList<String> findSuperviseResult(String memCard, Integer type) {
+        LinkedList<String> data = new LinkedList<>();
+        Calendar instance = Calendar.getInstance();
+        //获取当前的年
+        int year = instance.get(Calendar.YEAR);
+        LinkedList<String> resultFile = qkjSuperviseAppDao.findResultFileByYearAndTypeAndMemCard(memCard, year, type);
+        for (String url : resultFile) {
+            File file = null;
+            try {
+                file = ReadWordUtil.getNetUrlHttp(url);
+                String test = ReadWordUtil.readWord(file.getPath());
+                data.add(test);
+            }catch (Exception e){
+                log.info("接口/app/Supervise/findSupervise出错 e->{}", e);
+            }finally {
+                //立即删除文件
+                if(null != file){
+                  file.delete();
+                  //在JVM退出时删除文件
+                  file.deleteOnExit();
+                }
+            }
+        }
+        return data;
+    }
+}

src/main/java/com/cirle/scientific/utils/ReadWordUtil.java

@@ -0,0 +1,125 @@
+package com.cirle.scientific.utils;/*
+ *24901
+ *2023/1/4
+ *14:00
+ */
+
+
+
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.io.FileUtils;
+import org.apache.poi.hwpf.extractor.WordExtractor;
+import org.apache.poi.xwpf.extractor.XWPFWordExtractor;
+import org.apache.poi.xwpf.usermodel.XWPFDocument;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.io.*;
+import java.net.URL;
+
+/**
+ * @author 24901
+ */
+@Slf4j
+public class ReadWordUtil {
+
+
+    //使用路径读取word文件
+    public static String readWord(String path){
+        String buffer = "";
+        try {
+            if (path.endsWith(".doc")){
+                InputStream is = new FileInputStream(new File(path));
+                WordExtractor ex = new WordExtractor(is);
+                buffer = ex.getText();
+            }else if (path.endsWith(".docx")){
+                FileInputStream fs = new FileInputStream(new File(path));
+                XWPFDocument xdoc = new XWPFDocument(fs);
+                XWPFWordExtractor extractor = new XWPFWordExtractor(xdoc);
+                buffer = extractor.getText();
+            }
+        }catch (Exception e){
+            log.info("类:ReadWordUtil 更具文件路径提取word文件内容报错 e->{}", e);
+            e.printStackTrace();
+        }
+        return buffer;
+    }
+
+    //使用MultipartFile 接收文件流
+    public static void importWord(MultipartFile file) throws IOException {
+        InputStream inputStream = file.getInputStream();
+        String fileName = file.getOriginalFilename();
+        String suff = fileName.substring(fileName.lastIndexOf(".") + 1);
+        String content = "";
+        if (suff.equals("docx")) {
+            XWPFDocument xdoc = new XWPFDocument(inputStream);
+            XWPFWordExtractor extractor = new XWPFWordExtractor(xdoc);
+            content = extractor.getText();
+            System.out.println(content);
+            extractor.close();
+        } else if (suff.equals("doc")) {
+            WordExtractor ex = new WordExtractor(inputStream);
+            content = ex.getText();
+            System.out.println(content);
+            ex.close();
+        } else {
+            System.out.println("此文件不是word文件");
+        }
+    }
+
+    public static File getNetUrlHttp(String path) throws IOException {
+        File file = null;
+        if(path.endsWith(".doc")){
+            file  = File.createTempFile("wordText",".doc");
+        }else if(path.endsWith(".docx")){
+            file  = File.createTempFile("wordText",".docx");
+        }
+        if(file != null){
+            FileUtils.touch(file);
+        }
+        URL urlfile;
+        InputStream inputStream = null;
+        OutputStream outputStream = null;
+        try{
+            //判断文件的父级目录是否存在，不存在则创建
+            assert file != null;
+            mkdirs(file.getParent());
+            //下载
+            urlfile = new URL(path);
+            inputStream = urlfile.openStream();
+            outputStream = new FileOutputStream(file);
+
+            int bytesRead = 0;
+            byte[] buffer = new byte[8192];
+            while ((bytesRead=inputStream.read(buffer,0,8192))!=-1) {
+                outputStream.write(buffer, 0, bytesRead);
+            }
+        }catch (Exception e) {
+            e.printStackTrace();
+            log.info("类:ReadWordUtil url地址转文件方法报错 e->{}", e);
+        }finally {
+            try {
+                if (null != outputStream) {
+                    outputStream.close();
+                }
+                if (null != inputStream) {
+                    inputStream.close();
+                }
+
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+        }
+        return file;
+    }
+
+    /**
+     * 1.5 当文件夹不存在时，mkdirs会自动创建多层目录，区别于mkdir。 (mkdir如果父目录不存在则会抛出异常)
+     * @param destPath  存放目录
+     */
+    public static void mkdirs(String destPath) {
+        File file = new File(destPath);
+        if (!file.exists() && !file.isDirectory()) {
+            file.mkdirs();
+        }
+    }
+}