123

2_PRODUCT_FACTORY/fq_mf_factory3.js

@@ -67,6 +67,7 @@ async function processNewCreateTask(){
                     fq_book_result.data.tg_platform_id = result.data.tg_platform_id
                     await CMD.insert_product(result.data)
                 }
+                await filter_data_controllers.updateFilterData({id:result.data.id},{status:1,book_id:result.data.book_id,book_name:result.data.book_name,material_sync_status:0})
             }else{
 
                 let client =  new HttpClient()
@@ -80,6 +81,7 @@ async function processNewCreateTask(){
                     result.data.genre = 999
                     result.data.book_id = result.data.book_id
                     result.data.book_name = "没有找到这本书"
+                    await filter_data_controllers.updateFilterData({id:result.data.id},{status:1,book_id:result.data.book_id,book_name:result.data.book_name,material_sync_status:0})
                 }else{
                     let book_name =  obj['book_info'].book_name
                     let book_id = obj['book_info'].book_id
@@ -91,21 +93,24 @@ async function processNewCreateTask(){
                     // console.log("response:",obj,sid_tt)
                     await CMD.add_fq_book(fq_book,fq_book_data)
                     let product_result = await video_product_controllers.getProductData({ book_id: fq_book_data.book_id });
+                    result.data.words = words
+                    result.data.genre = fq_book_data.genre
+                    result.data.book_id = fq_book_data.book_id
+                    result.data.book_name = fq_book_data.book_name
                     if(!product_result.success){ //如果书库也没有
                         fq_book.tg_platform_id = result.data.tg_platform_id
                     
                         fq_book_data.tg_platform_id = result.data.tg_platform_id
                         await CMD.insert_product(fq_book_data)
+                        await CMD.update_filter_data(FilterConfig,result.data)
+                    }else{
+                         await filter_data_controllers.updateFilterData({id:result.data.id},{status:1,book_id:result.data.book_id,book_name:result.data.book_name,material_sync_status:0})
                     }
-                    result.data.words = words
-                    result.data.genre = fq_book_data.genre
-                    result.data.book_id = fq_book_data.book_id
-                    result.data.book_name = fq_book_data.book_name
                 }
             }
-            
+            console.log("处理完一条数据：",result.data.id)
         }
-        await CMD.update_filter_data(FilterConfig,result.data)
+
     }catch(e){
         if(e==0){
             console.log("processCreateTask:没有需要处理的任务")