Răsfoiți Sursa

fix: temp delete auto

ryanemax 2 săptămâni în urmă
părinte
comite
e07d2f42b9
2 a modificat fișierele cu 33 adăugiri și 19 ștergeri
  1. 20 6
      server/cloud/tbook/func-tbook-export.js
  2. 13 13
      server/lib/docs/index.js

+ 20 - 6
server/cloud/tbook/func-tbook-export.js

@@ -213,9 +213,14 @@ export async function exportProcessReportDocs(processId,bookList) {
         let now = new Date();
         let fileList = docsList?.map(item=>item?.pdfPath);
         let zipName = `申报书导出-${now.getFullYear()}${now.getMonth()+1}${now.getDate()}-${now.getHours()}${now.getMinutes()}${now.getSeconds()}.zip`
-        zipPath = await createZip(fileList,zipName)
+        zipPath = await createZip(fileList,zipName,{tempDir:null})
         if(zipPath){
             zipUrl = (await uploadFileToOSS(zipPath))?.url || null
+            fs.rmSync(zipPath)
+            fileList.forEach(tempFile=>{
+                console.log("rm",tempFile)
+                fs.rmSync(path.dirname(tempFile),{recursive:true,force:true});
+            })
         }
         docsList = docsList.map(item=>{return {code:item.code,title:item.title,url:item?.url,urlPdf:item?.urlPdf}})
     }
@@ -505,8 +510,13 @@ function renderReportDocsByTextbook(textbook){
         })
     }
 
+ 
+    let bookTempDir = path.join(tempDir,bookid)
+    if(!fs.existsSync(bookTempDir)) fs.mkdirSync(bookTempDir)
+
+
     let codePngBuffer = await toBarCode(json?.code);
-    let codePngPath = path.join(tempDir,bookid+"code.png")
+    let codePngPath = path.join(bookTempDir,bookid+"code.png")
     fs.writeFileSync(codePngPath,codePngBuffer)
     // let codeBarImg = 
     // console.log(codeBarImg)
@@ -594,8 +604,11 @@ function renderReportDocsByTextbook(textbook){
     lastPageList.push(json?.authorSignPDF?.url||docx7);
     lastPageList.push(json?.unitMaterial?.url||docx8);
     lastPageList.push(docx9);
-    let lastPageFileName = path.join(tempDir,`${bookid}_${bookData.title}_申报书及附件_789.pdf`)
-    let lastPagePdf = await docxToPdf(null,lastPageFileName,{mergeFiles:lastPageList}) // 成功用pdf,失败继续用docx
+    let lastPageFileName = path.join(bookTempDir,`${bookid}_${bookData.title}_申报书及附件_789.pdf`)
+    let lastPagePdf = await docxToPdf(null,lastPageFileName,{mergeFiles:lastPageList,tempDir:bookTempDir}) // 成功用pdf,失败继续用docx
+    docx7&&fs.rmSync(docx7)
+    docx8&&fs.rmSync(docx8)
+    docx9&&fs.rmSync(docx9)
     // mergeFiles = [...lastPageList,...mergeFiles]
     mergeFiles = [lastPagePdf,...mergeFiles]
 
@@ -610,14 +623,15 @@ function renderReportDocsByTextbook(textbook){
         }
         try{
             // DOCX模板合成 速度2-3秒
-            filePath = renderDocx(TemplateDocxPath,tempFileName,bookData)
+            filePath = renderDocx(TemplateDocxPath,tempFileName,bookData,{tempDir:bookTempDir})
             urlDocx = (await uploadFileToOSS(filePath))?.url || null
             console.log("DOCX CREATED:",filePath)
 
             // PDF文档拼接 速度10-30s 需要API支持
             pdfPath = filePath.replaceAll(".docx",".pdf")
             let options = {
-                mergeFiles:mergeFiles
+                mergeFiles:mergeFiles,
+                tempDir:bookTempDir
             }
             pdfPath = await docxToPdf(filePath,pdfPath,options) || filePath // 成功用pdf,失败继续用docx
             console.log("PDF CREATED:",filePath)

+ 13 - 13
server/lib/docs/index.js

@@ -77,11 +77,11 @@ module.exports.uploadFileToOSS = uploadFileToOSS
  * @param {Array<string>} filePathList - 要打包的文件路径数组
  * @param {string} outputZipName - 输出的zip文件名称
  */
- export function createZip(filePathList, outputZipName) {
+ export function createZip(filePathList, outputZipName,options) {
     let zipStream = new compressing.zip.Stream();
     return new Promise((resolve)=>{
         try {
-            let outputPath = path.join(tempDir,outputZipName)
+            let outputPath = path.join(options?.tempDir||tempDir,outputZipName)
             // 遍历文件路径列表,将每个文件添加到zip流中
             for (const filePath of filePathList) {
                 // 检查文件是否存在
@@ -125,13 +125,13 @@ module.exports.createZip = createZip
 
 
 const download = require('download')
-async function downloadUrl(url) {
+async function downloadUrl(url,options) {
     // console.log(url)
     if(url?.startsWith("/")) {return url};
     let md5 = crypto.createHash('md5');
     let extname = path.extname(url)?.toLocaleLowerCase();
     let filename = md5.update(url).digest('hex') + extname;
-    let filepath = path.join(tempDir,filename)
+    let filepath = path.join(options?.tempDir||tempDir,filename)
     // console.log(filename,filepath)
     try{
         // if(fs.existsSync(filepath)){fs.rmSync(filepath)} // 存在则删除
@@ -161,7 +161,7 @@ async function downloadUrl(url) {
             let filePath
             plist.push((async ()=>{
                 try{
-                    filePath = await downloadUrl(mergeFiles[index]);
+                    filePath = await downloadUrl(mergeFiles[index],options);
                 }catch(err){}
                 if(filePath){
                     mergeFileMap[index] = filePath // 按原有顺序整理
@@ -341,7 +341,7 @@ export async function mergePdfListReduce(pdfList,convertOpts){
     }
 }
 
-export function renderDocx(inputDocxPath, outputDocxName, options){
+export function renderDocx(inputDocxPath, outputDocxName, data,options){
     let imageOptions = {
         getImage(tagValue,tagName) {
             if(!fs.existsSync(tagValue)){
@@ -356,7 +356,7 @@ export function renderDocx(inputDocxPath, outputDocxName, options){
         },
     };
     
-    let outputDocxPath = path.join(tempDir,outputDocxName)
+    let outputDocxPath = path.join(options?.tempDir||tempDir,outputDocxName)
     // Load the docx file as binary content
     let content = fs.readFileSync(
         inputDocxPath,
@@ -372,12 +372,12 @@ export function renderDocx(inputDocxPath, outputDocxName, options){
     });
 
     // Render the document (Replace {first_name} by John, {last_name} by Doe, ...)
-    Object.keys(options).forEach(key=>{ // 除去空值
-        if(options[key]==undefined){
-            options[key] = ""
+    Object.keys(data).forEach(key=>{ // 除去空值
+        if(data[key]==undefined){
+            data[key] = ""
         }
     })
-    doc.render(options);
+    doc.render(data);
 
     // Get the zip document and generate it as a nodebuffer
     let buf = doc.getZip().generate({
@@ -412,13 +412,13 @@ export function replaceDocx(inputDocxPath, outputDocxPath, options,eventMap) {
     // 解压出来的临时目录
     let md5 = crypto.createHash('md5');
     let outmd5 = md5.update(outputDocxPath).digest('hex')
-    let tempDocxPath =  path.join(tempDir , outmd5)
+    let tempDocxPath =  path.join(options?.tempDir||tempDir , outmd5)
     // 要替换的xml文件位置
     let tempDocxXMLName = path.join(tempDocxPath,`word/document.xml`)
 
     // 压缩文件夹为文件
     let dir_to_docx = (inputFilePath, outputFilePath) => {
-        outputFilePath = path.join(tempDir,outputFilePath)
+        outputFilePath = path.join(options?.tempDir||tempDir,outputFilePath)
         // 创建压缩流
         let zipStream = new compressing.zip.Stream()
         // 写出流