123

2_PRODUCT_FACTORY/dz_factory.js

@@ -15,7 +15,6 @@ async function processTask(){
         if(isPauseTask=="true"){
             return
         }
-        let isInsertTask = false
         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);
@@ -24,7 +23,6 @@ async function processTask(){
             let FilterList = []
             for (let index = 0; index < result.data.length; index++) {
                 let filter_item = result.data[index];
-                filter_item.isHave = false
                 ProductIds.push(filter_item.book_id)
                 FilterList[filter_item.book_id] = filter_item
             }
@@ -33,7 +31,6 @@ async function processTask(){
 
             if(product_list_result.success){
                 
-                console.log("product_list_result:",product_list_result.data)
                 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]
@@ -41,22 +38,14 @@ async function processTask(){
                     info.genre =  product_item.genre
                     info.book_id = product_item.product_id
                     info.book_name = product_item.product_name
-                    FilterList[product_item.product_id].isHave = true
                     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]}})
                 }
-                for (const key in FilterList) {
-                    if (Object.prototype.hasOwnProperty.call(FilterList, key)) {
-                        let filter_item = FilterList[key];
-                        if(filter_item.isHave!=true){
-                            Ids.push(filter_item.id)
-                        }
-                    }
-                }
                 console.log("Ids：",Ids)
                 if(Ids.length>0){
                     await filter_data_controllers.updateFilterDataByIds({ids:Ids},{status:1})