123

2_PRODUCT_FACTORY/dz_batch_factory.js

@@ -30,7 +30,6 @@ async function processTask(){
         if(result.success){
             let ProductIds = []
             let FilterList = []
-            let Ids = []
             if(result.data.length<=0){
                 throw '没有数据可处理！'
             }
@@ -59,9 +58,7 @@ async function processTask(){
                         info.book_name = product_item.product_name
                         await CMD.update_filter_data(FilterConfig,info)
                         await new Promise(resolve => setTimeout(resolve,100));
-                    } else{
-                        Ids.push(filter_item.id)
-                    }
+                    } 
                 }
 
                 let remove_product_list = []
@@ -74,11 +71,6 @@ async function processTask(){
                     }
                 }
 
-                // if(Ids.length>0){
-                //     console.log("Ids:",Ids)
-                //     await filter_data_controllers.updateFilterDataByIds({ids:Ids},{status:1})
-                // }
-              
             }
             
         }

2_PRODUCT_FACTORY/hy_batch_factory.js

@@ -55,7 +55,10 @@ async function findSameFilterData(product_list,FilterConfig) {
         }
     }
 
-    
+}
+
+async function updateSameProductId(list,product_item) {
+    await filter_data_controllers.updateFilterDataByIds({ids:list},{status:1,book_id:product_item.book_id,book_name:product_item.book_name,genre:product_item.genre,words:product_item.words})
 }
 
 async function processTask(){
@@ -71,7 +74,7 @@ async function processTask(){
         if(result.success){
             let ProductIds = []
             let FilterList = []
-            let Ids = []
+            let UpdateProductList = []
             if(result.data.length<=0){
                 throw '没有数据可处理！'
             }
@@ -79,14 +82,20 @@ async function processTask(){
                 let filter_item = result.data[index];
                 ProductIds.push(filter_item.book_id)
                 FilterList[filter_item.book_id] = filter_item
+                if(UpdateProductList[filter_item.book_id]==null){
+                    UpdateProductList[filter_item.book_id]= []
+                }
+                UpdateProductList[filter_item.book_id].push(filter_item.id)
             }
 
             let product_list_result = await video_product_controllers.findNonExistentProductIds(ProductIds);
             if(product_list_result.success){
+                let FinishProductList = []
                 for (let index = 0; index < result.data.length; index++) {
                     let filter_item = result.data[index];
-                    if(product_list_result.data.existingProductIds.has(filter_item.book_id)){
+                    if(product_list_result.data.existingProductIds.has(filter_item.book_id)&&FinishProductList[filter_item.book_id]==null){
                         let info = filter_item;
+                        FinishProductList[filter_item.book_id] = true
                         let product_item = getProductById(product_list_result.data.existingRecords,filter_item.book_id)
                         if (!info) {
                             throw `No filter info found for book_id: ${filter_item.book_id}`
@@ -99,13 +108,10 @@ async function processTask(){
                         info.book_id = product_item.product_id
                         info.book_name = product_item.product_name
                         await CMD.update_filter_data(FilterConfig,info)
+                        await updateSameProductId(UpdateProductList[info.book_id],product_item)
                         await new Promise(resolve => setTimeout(resolve,100));
-                    }else{
-                        Ids.push(filter_item.id)
                     }
                 }
-                //找到相同数据的数据进行同步
-                // await findSameFilterData(product_list_result.data.existingRecords,FilterConfig)
 
                 let remove_product_list = []
 
@@ -118,10 +124,7 @@ async function processTask(){
                         task_queue.push({result:{data:FilterList[product_id]}})
                     }
                 }
-                // console.log("remove_product_list:",remove_product_list)
-                // if(Ids.length>0){
-                //     await filter_data_controllers.updateFilterDataByIds({ids:Ids},{status:1})
-                // }
+
             }
             
         }