123

2_PRODUCT_FACTORY/dz_factory.js

@@ -17,75 +17,85 @@ async function processTask(){
         }
         let FilterConfig = await redis_help.getKeyValue("FilterConfig")
         FilterConfig = JSON.parse(FilterConfig)
-        // result = await filter_data_controllers.getFilterDataByStatusAndLimit({ status: 0 , tg_platform_id: config.platform_dianzhong },500);
-        // if(result.success){
-        //     let ProductIds = []
-        //     let FilterList = []
-        //     for (let index = 0; index < result.data.length; index++) {
-        //         let filter_item = result.data[index];
-        //         ProductIds.push(filter_item.book_id)
-        //         FilterList[filter_item.book_id] = filter_item
-        //     }
+        result = await filter_data_controllers.getFilterDataByStatusAndLimit({ status: 0 , tg_platform_id: config.platform_dianzhong },500);
+        if(result.success){
+            let ProductIds = []
+            let FilterList = []
+            for (let index = 0; index < result.data.length; index++) {
+                let filter_item = result.data[index];
+                ProductIds.push(filter_item.book_id)
+                FilterList[filter_item.book_id] = filter_item
+            }
 
-        //     let product_list_result = await video_product_controllers.findNonExistentProductIds(ProductIds);
+            let product_list_result = await video_product_controllers.findNonExistentProductIds(ProductIds);
 
-        //     if(product_list_result.success){
+            if(product_list_result.success){
                 
-        //         for (let index = 0; index < product_list_result.data.existingRecords.length; index++) {
-        //             const product_item = product_list_result.data.existingRecords[index];
-        //             let info = FilterList[product_item.product_id]
-        //             info.words = product_item.words
-        //             info.genre =  product_item.genre
-        //             info.book_id = product_item.product_id
-        //             info.book_name = product_item.product_name
-        //             await CMD.update_filter_data(FilterConfig,info)
-        //         }
-        //         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)
-        //             task_queue.push({result:{data:FilterList[product_id]}})
-        //         }
-        //         console.log("Ids：",Ids)
-        //         if(Ids.length>0){
-        //             await filter_data_controllers.updateFilterDataByIds({ids:Ids},{status:1})
-        //         }
-              
-        //     }
-            
-        // }
-        let isInsertTask = false
-        result = await filter_data_controllers.getFilterDataByStatus({ status: 0 , tg_platform_id: config.platform_dianzhong });
-        if(result.success){
-            let tg_platform_id = result.data.tg_platform_id
-            //判断是否存在这本书
-            if(tg_platform_id==config.platform_dianzhong){ //点众
-                let dz_book_result = await video_product_controllers.getProductData({ book_id: result.data.book_id });
-                if(dz_book_result.success){
-                    result.data.words = dz_book_result.data.words
-                    result.data.genre =  dz_book_result.data.genre
-                    result.data.book_id = dz_book_result.data.product_id
-                    result.data.book_name = dz_book_result.data.product_name
-                }else{
-                    isInsertTask = true
+                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)){
+                        let info = FilterList[filter_item.book_id]
+                        info.words = product_item.words
+                        info.genre =  product_item.genre
+                        info.book_id = product_item.product_id
+                        info.book_name = product_item.product_name
+                        await CMD.update_filter_data(FilterConfig,info)
+                        await new Promise(resolve => setTimeout(resolve,100));
+                    } 
                 }
+
+                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)
+                    task_queue.push({result:{data:FilterList[product_id]}})
+                }
+                console.log("Ids：",Ids)
+                if(Ids.length>0){
+                    await filter_data_controllers.updateFilterDataByIds({ids:Ids},{status:1})
+                }
+              
             }
-            if(!isInsertTask){
-                await CMD.update_filter_data(FilterConfig,result.data)
-            }else{
-                await filter_data_controllers.updateFilterData({id:result.data.id},{status:1})
-                task_queue.push({result:result})
-            }
+            
         }
     }catch(e){
-        console.error("processTask error:",e)
-        // if(result!=null&&result!=undefined){
-        //     await filter_data_controllers.updateFilterData({id:result.data.id},{status:2})
-        // }
+
     } finally{
         global.setTimeout(processTask, 100);
     }
 
+    //     let isInsertTask = false
+    //     result = await filter_data_controllers.getFilterDataByStatus({ status: 0 , tg_platform_id: config.platform_dianzhong });
+    //     if(result.success){
+    //         let tg_platform_id = result.data.tg_platform_id
+    //         //判断是否存在这本书
+    //         if(tg_platform_id==config.platform_dianzhong){ //点众
+    //             let dz_book_result = await video_product_controllers.getProductData({ book_id: result.data.book_id });
+    //             if(dz_book_result.success){
+    //                 result.data.words = dz_book_result.data.words
+    //                 result.data.genre =  dz_book_result.data.genre
+    //                 result.data.book_id = dz_book_result.data.product_id
+    //                 result.data.book_name = dz_book_result.data.product_name
+    //             }else{
+    //                 isInsertTask = true
+    //             }
+    //         }
+    //         if(!isInsertTask){
+    //             await CMD.update_filter_data(FilterConfig,result.data)
+    //         }else{
+    //             await filter_data_controllers.updateFilterData({id:result.data.id},{status:1})
+    //             task_queue.push({result:result})
+    //         }
+    //     }
+    // }catch(e){
+    //     console.error("processTask error:",e)
+    //     // if(result!=null&&result!=undefined){
+    //     //     await filter_data_controllers.updateFilterData({id:result.data.id},{status:2})
+    //     // }
+    // } finally{
+    //     global.setTimeout(processTask, 100);
+    // }
+
 }
 
 async function processCreateTask(){

src/data_manager/Controllers/video_product_controllers.js

@@ -57,8 +57,8 @@ class video_product_controllers {
                 success: true,
                 data: {
                     total: maxIds.length,
-                    existing: existingProductIds.size,
-                    existingRecords:existingRecords,
+                    existing: existingProductIds.size, //存在
+                    existingProductIds:existingProductIds,
                     nonExistent: nonExistentProductIds.length,
                     nonExistentIds: nonExistentProductIds
                 }