新增超声病理心电初审不拦截

新增检验外送报告解析
5/17

src/main/java/com/ann/service/impl/QueueService.java

@@ -72,10 +72,32 @@ public class QueueService {
                                     }
                                     /**2021-1-26 等lis程序升级 去掉*/
 
+                                    /**2021-4-25 等超声补传完 去掉*/
+                                    if (Objects.equals(messageDto.getType(), AliasName.ULTRASONIC_REPORT) && archiveMaster.getArchiveState().equals("已归档")){
+                                        messageSubordinate.setStatus(3);
+                                        messageSubordinateService.save(messageSubordinate);
+                                        continue;
+                                    }
+                                    /**2021-4-25 等超声补传完 去掉*/
+
+                                    /**2021-4-25 等心电图补传完 去掉*/
+                                    if (Objects.equals(messageDto.getType(), AliasName.EKG_REPORT) && archiveMaster.getArchiveState().equals("已归档")){
+                                        messageSubordinate.setStatus(3);
+                                        messageSubordinateService.save(messageSubordinate);
+                                        continue;
+                                    }
+                                    /**2021-4-25 等心电图补传完 去掉*/
+
                                     if ( !Objects.equals(messageDto.getType(), AliasName.PATHOLOGY_REPORT)
                                             /**2021-1-26 等lis程序升级 去掉*/
                                             && !Objects.equals(messageDto.getType(), AliasName.INSPECTION_REPORT)
                                             /**2021-1-26 等lis程序升级 去掉*/
+                                            /**2021-4-25 等超声补传完 去掉*/
+                                            && !Objects.equals(messageDto.getType(), AliasName.ULTRASONIC_REPORT)
+                                            /**2021-4-25 等超声补传完 去掉*/
+                                            /**2021-4-25 等心电图补传完 去掉*/
+                                            && !Objects.equals(messageDto.getType(), AliasName.EKG_REPORT)
+                                            /**2021-4-25 等心电图补传完 去掉*/
                                             && (archiveMaster.getArchiveState().equals("初审") || archiveMaster.getArchiveState().equals("已归档"))
                                     ){
                                         messageSubordinate.setStatus(3);
@@ -224,6 +246,12 @@ public class QueueService {
                                                         pdfPath = PdfUtils.imagesToPdf(imageFile, pdfFile);
                                                     }
                                                 }
+
+                                                //金域外送报告解析 2021-05-06
+                                                if (Objects.equals(messageDto.getType(), AliasName.INSPECTION_REPORT)){
+                                                    PdfUtils.base64StringToPDF(address,pdfFile.getAbsolutePath());
+                                                    pdfPath=pdfFile.getAbsolutePath();
+                                                }
                                             }
                                         }
                                         //存入pdf地址

src/main/java/com/ann/utils/PdfUtils.java

@@ -9,11 +9,10 @@ import com.itextpdf.text.pdf.PdfWriter;
 import org.apache.commons.net.ftp.FTPClient;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import sun.misc.BASE64Decoder;
 import sun.net.ftp.FtpClient;
 
-import java.io.File;
-import java.io.FileOutputStream;
-import java.io.IOException;
+import java.io.*;
 import java.time.LocalDate;
 
 /**
@@ -115,5 +114,51 @@ public class PdfUtils {
         return fileName;
     }
 
+    /**
+     *  将base64编码转换成PDF
+     *  @param base64String
+     *  1.使用BASE64Decoder对编码的字符串解码成字节数组
+     *  2.使用底层输入流ByteArrayInputStream对象从字节数组中获取数据；
+     *  3.建立从底层输入流中读取数据的BufferedInputStream缓冲输出流对象；
+     *  4.使用BufferedOutputStream和FileOutputSteam输出数据到指定的文件中
+     */
+    public static void base64StringToPDF(String base64String, String pdfPath/*File file*/){
+        File file = new File(pdfPath);// 将原来参数修改为字符串
+        BASE64Decoder decoder = new BASE64Decoder();
+        BufferedInputStream bin = null;
+        FileOutputStream fout = null;
+        BufferedOutputStream bout = null;
+        try {
+            //将base64编码的字符串解码成字节数组
+            byte[] bytes = decoder.decodeBuffer(base64String);
+            //创建一个将bytes作为其缓冲区的ByteArrayInputStream对象
+            ByteArrayInputStream bais = new ByteArrayInputStream(bytes);
+            //创建从底层输入流中读取数据的缓冲输入流对象
+            bin = new BufferedInputStream(bais);
+            //创建到指定文件的输出流
+            fout  = new FileOutputStream(file);
+            //为文件输出流对接缓冲输出流对象
+            bout = new BufferedOutputStream(fout);
+
+            byte[] buffers = new byte[1024];
+            int len = bin.read(buffers);
+            while(len != -1){
+                bout.write(buffers, 0, len);
+                len = bin.read(buffers);
+            }
+            //刷新此输出流并强制写出所有缓冲的输出字节，必须这行代码，否则有可能有问题
+            bout.flush();
+        } catch (IOException e) {
+            e.printStackTrace();
+        } finally {
+            try {
+                bout.close();
+                fout.close();
+                bin.close();
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+    }
 
 }