123

1_FILTER_FACTORY/FILTER_FACTORY.js

@@ -3,6 +3,9 @@ const time_count = 1000;
 const redis_help = require('../src/use_redis');
 const origin_data_controllers = require('../src/data_manager/Controllers/origin_data_controllers');
 const filter_data_controllers = require('../src/data_manager/Controllers/filter_data_controllers');
+const video_product_controllers = require('../src/data_manager/Controllers/video_product_controllers');
+const get_fq_mf_book_tab_controllers = require('../src/data_manager/Controllers/get_fq_mf_book_tab_controllers');
+const get_fq_book_tab_controllers = require('../src/data_manager/Controllers/get_fq_book_tab_controllers');
 const helper = require('../src/helper');
 const config = require('../etc/config.json')
 async function createFilterData(result,FilterConfig) {
@@ -15,6 +18,41 @@ async function createFilterData(result,FilterConfig) {
     if(filter_data!=null){
         console.log("filter_data:",filter_data)
         filter_data.status = 0; //设置筛选的这个状态未定义
+        let book_name = ""
+        let genre = 0;
+        let words = 0;
+        let book_id = filter_data.book_id;
+        let status = 0;
+        if(filter_data.tg_platform_id!=config.platform_fanqie&&filter_data.tg_platform_id!=config.platform_fanqiemf){
+            let book_info =  await video_product_controllers.getProductData({book_id:filter_data.book_id})
+            if(book_info.success){
+                book_name = book_info.product_name
+                genre = book_info.genre
+                words = book_info.words
+                status = 1
+            }
+        }else{
+            if(filter_data.tg_platform_id==config.platform_fanqiemf){
+                let fq_book_result = await get_fq_mf_book_tab_controllers.getData({ book_id: filter_data.book_id });
+                if(fq_book_result.success){
+                    book_id = fq_book_result.data.book_id
+                    book_name = fq_book_result.data.info.book_name
+                    genre = fq_book_result.data.info.genre
+                    words = fq_book_result.data.info.words==undefined?0:fq_book_result.data.info.words
+                    status = 1
+                }
+            }else if(filter_data.tg_platform_id==config.platform_fanqie){
+                let fq_book_result = await get_fq_book_tab_controllers.getData({ book_id: result.data.book_id });
+                if(fq_book_result.success){//如果番茄书库里有这本书
+                    book_id = fq_book_result.data.book_id
+                    genre = fq_book_result.data.info.genre
+                    book_name = fq_book_result.data.info.book_name
+                    words = fq_book_result.data.info.words
+                    status = 1
+                }
+            }
+        }
+
         let res =  await filter_data_controllers.createFilterData({
             video_id:filter_data.video_id,
             video_link:filter_data.video_link,
@@ -25,14 +63,14 @@ async function createFilterData(result,FilterConfig) {
             like_num:filter_data.like_num,
             shared_num:filter_data.shared_num,
             is_guajian:result.data.is_guajian,
-            book_id:filter_data.book_id,
-            book_name:"",
-            genre:0,
-            words:0,
+            book_id:book_id,
+            book_name:book_name,
+            genre:genre,
+            words:words,
             guajian_link:result.data.guajian_link,
             tg_platform_id:filter_data.tg_platform_id,
             source:filter_data.source,
-            status:0,
+            status:status,
             material_sync_status:0,
             create_day: new Date(helper.getLocalDate())
         })
@@ -41,6 +79,7 @@ async function createFilterData(result,FilterConfig) {
     return filter_data
 }
 
+
 async function processTask(){
     try{
         let FilterConfig = await redis_help.getKeyValue("FilterConfig")