123

2_PRODUCT_FACTORY/dz_batch_factory.js

@@ -94,11 +94,11 @@ async function processCreateTask(){
     try{
         if(task_queue.length>0){
             let task_queue_item = task_queue.pop()
+            result = task_queue_item.result
             let product = await video_product_controllers.getProductData({ book_id: task_queue_item.result.data.book_id });
             let FilterConfig = await redis_help.getKeyValue("FilterConfig")
             FilterConfig = JSON.parse(FilterConfig)
             if(!product.success){
-                result = task_queue_item.result
                 let tg_platform_id = result.data.tg_platform_id
                 if(tg_platform_id==config.platform_dianzhong){ //点众
                     let dz_book_data = await require('../src/api/dz/dz_search_book').search_id(result.data.book_id)

2_PRODUCT_FACTORY/hy_batch_factory.js

@@ -142,11 +142,11 @@ async function processCreateTask(){
     try{
         if(task_queue.length>0){
             let task_queue_item = task_queue.pop()
+            result = task_queue_item.result
             let product = await video_product_controllers.getProductData({ book_id: task_queue_item.result.data.book_id });
             let FilterConfig = await redis_help.getKeyValue("FilterConfig")
             FilterConfig = JSON.parse(FilterConfig)
             if(!product.success){
-                result = task_queue_item.result
                 let tg_platform_id = result.data.tg_platform_id
                 if(tg_platform_id==config.platform_heiyan){
                     let hy_book_data = await require('./collect_hy_book').runTask(result.data)