123

2_PRODUCT_FACTORY/dz_batch_factory.js

@@ -64,10 +64,16 @@ async function processTask(){
                     }
                 }
 
+                let remove_product_list = []
+
                 for (let index = 0; index < product_list_result.data.nonExistentIds.length; index++) {
                     const product_id = product_list_result.data.nonExistentIds[index];
-                    task_queue.push({result:{data:FilterList[product_id]}})
+                    if(remove_product_list[product_id]==null){
+                        remove_product_list[product_id] = true
+                        task_queue.push({result:{data:FilterList[product_id]}})
+                    }
                 }
+
                 if(Ids.length>0){
                     console.log("Ids:",Ids)
                     await filter_data_controllers.updateFilterDataByIds({ids:Ids},{status:1})
@@ -110,8 +116,13 @@ async function processCreateTask(){
                     }
                 
                 }
-                await CMD.update_filter_data(FilterConfig,result.data)
+            }else{
+                result.data.words = product.words
+                result.data.genre = product.genre
+                result.data.book_id = product.product_id
+                result.data.book_name = product.product_name
             }
+            await CMD.update_filter_data(FilterConfig,result.data)
         }
     }catch(e){
         console.log("error::",e)

2_PRODUCT_FACTORY/fq_batch_factory.js

@@ -75,7 +75,7 @@ async function processTask(){
                 let Ids = []
                 for (let index = 0; index < product_list_result.data.nonExistentIds.length; index++) {
                     const product_id = product_list_result.data.nonExistentIds[index];
-                    Ids.push(FilterList[product_id].id)
+                    // Ids.push(FilterList[product_id].id)
                     task_queue.push({result:{data:FilterList[product_id]}})
                 }
                 if(Ids.length>0){

2_PRODUCT_FACTORY/hy_batch_factory.js

@@ -102,9 +102,14 @@ async function processTask(){
                 //找到相同数据的数据进行同步
                 // await findSameFilterData(product_list_result.data.existingRecords,FilterConfig)
 
+                let remove_product_list = []
+
                 for (let index = 0; index < product_list_result.data.nonExistentIds.length; index++) {
                     const product_id = product_list_result.data.nonExistentIds[index];
-                    task_queue.push({result:{data:FilterList[product_id]}})
+                    if(remove_product_list[product_id]==null){
+                        remove_product_list[product_id] = true
+                        task_queue.push({result:{data:FilterList[product_id]}})
+                    }
                 }
                 if(Ids.length>0){
                     await filter_data_controllers.updateFilterDataByIds({ids:Ids},{status:1})
@@ -149,8 +154,13 @@ async function processCreateTask(){
                         result.data.book_name = "没有找到这本书"
                     }
                 }
-                await CMD.update_filter_data(FilterConfig,result.data)
+            }else{
+                result.data.words = product.words
+                result.data.genre = product.genre
+                result.data.book_id = product.product_id
+                result.data.book_name = product.product_name
             }
+            await CMD.update_filter_data(FilterConfig,result.data)
         }
     }catch(e){
         console.log("processCreateTask:",e)

2_PRODUCT_FACTORY/qm_batch_factory.js

@@ -118,8 +118,13 @@ async function processCreateTask(){
                         result.data.book_name = qm_book_data.book_name
                     }
                 }
-                await CMD.update_filter_data(FilterConfig,result.data)
+            }else{
+                result.data.words = product.words
+                result.data.genre = product.genre
+                result.data.book_id = product.product_id
+                result.data.book_name = product.product_name
             }
+            await CMD.update_filter_data(FilterConfig,result.data)
         }
     }catch(e){
         console.log("error::",e)

logs/combined.log

@@ -2,3 +2,7 @@
 2024-12-20T18:52:38: > heiyan@1.0.0 start
 2024-12-20T18:52:38: > node tg_factory_main.js
 2024-12-20T18:52:38: 
+2024-12-20T19:09:18: 
+2024-12-20T19:09:18: > heiyan@1.0.0 start
+2024-12-20T19:09:18: > node tg_factory_main.js
+2024-12-20T19:09:18: 

logs/out.log

@@ -2,3 +2,7 @@
 2024-12-20T18:52:38: > heiyan@1.0.0 start
 2024-12-20T18:52:38: > node tg_factory_main.js
 2024-12-20T18:52:38: 
+2024-12-20T19:09:18: 
+2024-12-20T19:09:18: > heiyan@1.0.0 start
+2024-12-20T19:09:18: > node tg_factory_main.js
+2024-12-20T19:09:18: