Sfoglia il codice sorgente

定时清除效率提升

vian 6 anni fa
parent
commit
783be85a04
1 ha cambiato i file con 3 aggiunte e 2 eliminazioni
  1. 3 2
      modules/sys_tools/models/sys_model.js

+ 3 - 2
modules/sys_tools/models/sys_model.js

@@ -9,7 +9,6 @@
  */
  */
 
 
 import mongoose from 'mongoose';
 import mongoose from 'mongoose';
-import schedule from 'node-schedule';
 import async from 'async';
 import async from 'async';
 const projectModel = mongoose.model('projects');
 const projectModel = mongoose.model('projects');
 const projSettingModel = mongoose.model('proj_setting');
 const projSettingModel = mongoose.model('proj_setting');
@@ -39,7 +38,7 @@ const contractorListModel = mongoose.model("contractor_list");
 async function clearJunkData(callback){
 async function clearJunkData(callback){
     let functions = [];
     let functions = [];
     //获取彻底删除了的项目
     //获取彻底删除了的项目
-    let junkProjs = await projectModel.find({'deleteInfo.deleted': true, 'deleteInfo.completeDeleted': true});
+    let junkProjs = await projectModel.find({'deleteInfo.deleted': true, 'deleteInfo.completeDeleted': true}, '-_id ID').lean();
     let junkProjIds = [];
     let junkProjIds = [];
     for(let jProj of junkProjs){
     for(let jProj of junkProjs){
         junkProjIds.push(jProj.ID);
         junkProjIds.push(jProj.ID);
@@ -141,6 +140,8 @@ async function clearJunkData(callback){
                 await unitPriceFileModel.remove({id: {$in: junkUFIds}});
                 await unitPriceFileModel.remove({id: {$in: junkUFIds}});
                 //清除费率文件
                 //清除费率文件
                 await feeRateFileModel.remove({feeRateID: {$in: junkFFIds}});
                 await feeRateFileModel.remove({feeRateID: {$in: junkFFIds}});
+            } else {
+                console.log(err);
             }
             }
             if(callback) callback(err);
             if(callback) callback(err);
         });
         });