123

2_PRODUCT_FACTORY/PRODUCT_FACTORY.js

@@ -13,6 +13,7 @@ const time_count = 2000;
 const task_queue = []
 
 async function processTask(){
+    let result = null
     try{
         let isPauseTask =  await redis_help.getKeyValue("isPauseTask")
         if(isPauseTask=="true"){
@@ -21,7 +22,7 @@ async function processTask(){
         let isInsertTask = false
         let FilterConfig = await redis_help.getKeyValue("FilterConfig")
         FilterConfig = JSON.parse(FilterConfig)
-        let result = await filter_data_controllers.getFilterDataByStatus({ status: 0 });
+        result = await filter_data_controllers.getFilterDataByStatus({ status: 0 });
         if(result.success){
             let tg_platform_id = result.data.tg_platform_id
             //判断是否存在这本书
@@ -67,7 +68,10 @@ async function processTask(){
             }
         }
     }catch(e){
-        await filter_data_controllers.updateFilterData({id:result.data.id},{status:2})
+        console.log("processTask error:",e)
+        if(result!=null){
+            await filter_data_controllers.updateFilterData({id:result.data.id},{status:2})
+        }
     } finally{
         global.setTimeout(processTask, 500);
     }