fix

src/main/java/cn/com/poc/message/service/impl/OcrConsumerServiceImpl.java

@@ -59,7 +59,7 @@ public class OcrConsumerServiceImpl implements OcrConsumerService {
 
     @Override
     @Consumer(topic = OCRTopic.PARSE_PDF)
-    public void OCR(OCRMessage message)  {
+    public void OCR(OCRMessage message) {
         OCRStatusMessage ocrStatusMessage = new OCRStatusMessage();
         ocrStatusMessage.setId(message.getId());
         ocrStatusMessage.setStatus("parsing");
@@ -110,17 +110,18 @@ public class OcrConsumerServiceImpl implements OcrConsumerService {
 
     private String createFileAndUploadBos(String content, String suffix) throws IOException {
         String fileName = UUIDTool.getUUID();
-
         File tempFile = File.createTempFile(fileName, suffix);
+
         FileOutputStream fileOutputStream = new FileOutputStream(tempFile);
         fileOutputStream.write(content.getBytes());
         fileOutputStream.flush();
+        fileOutputStream.close();
 
         BufferedInputStream inputStream = FileUtil.getInputStream(tempFile);
         byte[] bytes = new byte[inputStream.available()];
         inputStream.read(bytes);
         String md5 = MD5.create().digestHex(bytes);
-        String upload = bosConfigService.upload(inputStream, suffix, null);
+        String upload = bosConfigService.uploadFileByByteArray2Oss(bytes, fileName, suffix);
 
         BizFileUploadRecordModel bizFileUploadRecordModel = new BizFileUploadRecordModel();
         bizFileUploadRecordModel.setFileName(fileName);
@@ -129,10 +130,6 @@ public class OcrConsumerServiceImpl implements OcrConsumerService {
         bizFileUploadRecordModel.setCoverSheetUrl("");
         bizFileUploadRecordService.save(bizFileUploadRecordModel);
 
-        fileOutputStream.close();
-        inputStream.close();
-        tempFile.delete();
-
         return upload;
 
     }

src/test/java/cn/com/poc/utils/FileUtilsTest.java

 package cn.com.poc.utils;
 
+import cn.com.poc.common.service.BosConfigService;
 import cn.com.poc.common.utils.DocumentLoad;
 import cn.com.poc.common.utils.FileUtils;
+import cn.com.poc.common.utils.UUIDTool;
 import cn.com.yict.framemax.core.spring.SingleContextInitializer;
+import cn.hutool.core.io.FileUtil;
+import cn.hutool.crypto.digest.MD5;
 import org.apache.pdfbox.pdmodel.PDDocument;
 import org.apache.pdfbox.text.PDFTextStripper;
 import org.junit.Test;
@@ -11,6 +15,7 @@ import org.springframework.test.context.ContextConfiguration;
 import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
 import org.springframework.test.context.web.WebAppConfiguration;
 
+import javax.annotation.Resource;
 import java.io.*;
 
 /**
@@ -21,11 +26,31 @@ import java.io.*;
 @ContextConfiguration(initializers = SingleContextInitializer.class)
 @WebAppConfiguration
 public class FileUtilsTest {
-
+    @Resource
+    private BosConfigService bosConfigService;
 
     @Test
     public void test_wordConvertPDF() throws Exception {
+        String content = "hello world";
+        String suffix = "txt";
+
+        String fileName = UUIDTool.getUUID();
+        File tempFile = File.createTempFile(fileName, suffix);
+
+        FileOutputStream fileOutputStream = new FileOutputStream(tempFile);
+        fileOutputStream.write(content.getBytes());
+        fileOutputStream.flush();
+        fileOutputStream.close();
+
+        BufferedInputStream inputStream = FileUtil.getInputStream(tempFile);
+        byte[] bytes = new byte[inputStream.available()];
+        inputStream.read(bytes);
+        String md5 = MD5.create().digestHex(bytes);
+        String upload = bosConfigService.uploadFileByByteArray2Oss(bytes, fileName, suffix);
 
+        System.out.println(md5);
+        System.out.println(upload);
+        tempFile.delete();
     }