123

0_RECEIVE_FACTORY/RECEIVE_FACTORY.js

@@ -341,6 +341,11 @@ CMD.get_yw_recharge_template = async function(res,yw_id) {
     res.end(JSON.stringify({ message:"成功！",data:data,code:10000}));
 }
 
+CMD.test_open_sessid = async function(res,book_id) {
+    let yw_book_data = await require('../src/api/yw/yw_search_book').search_test_id(book_id)
+    res.writeHead(200, {'Content-Type': 'application/json'});
+    res.end(JSON.stringify({ message:"成功！",data:yw_book_data,code:10000}));
+}
 CMD.get_yw_open_sessid_status = async function(res) {
     let OPENSESSID = await redis_help.getKeyValue("OPENSESSID")
     console.log('get_yw_open_sessid_status:', OPENSESSID);
@@ -461,6 +466,9 @@ var server = http.createServer(function(req,res){
                     }else if(jsonData['fun']=="get_yw_recharge_template"&&jsonData['cmd']=="yw_link"){
                         let yw_id = jsonData['data']['yw_id']
                         CMD.get_yw_recharge_template(res,yw_id) 
+                    }else if(jsonData['fun']=="test_open_sessid"&&jsonData['cmd']=="yw_link"){
+                        let book_id = jsonData['data']['book_id']
+                        CMD.test_open_sessid(res,book_id) 
                     }else if(jsonData['fun']=="get_yw_open_sessid_status"&&jsonData['cmd']=="yw_link"){
                         CMD.get_yw_open_sessid_status(res) 
                     } else if(jsonData['fun']=="get_zh_recharge_template"&&jsonData['cmd']=="zh_link"){

check_yw_info.js

@@ -0,0 +1,39 @@
+const video_product_controllers = require('./src/data_manager/Controllers/video_product_controllers');
+const config = require("./etc/config.json")
+const redis_help = require('./src/use_redis');
+const CMD = {}
+
+async function processTask(){
+    try{
+        const result = await video_product_controllers.getDataByBookPlatform({book_platform:config.platform_yuewen})
+        console.log("result:",result)
+        if(result.success){
+            for (let index = 0; index < result.data.length; index++) {
+                const product_item =  result.data[index];
+                let yw_book_data = await require('./src/api/yw/yw_search_book').search_id(product_item.product_id)
+                if(yw_book_data!=null){
+                    await video_product_controllers.updateData({id:product_item.id},{
+                                genre:yw_book_data.genre
+                    })
+                }
+                await new Promise(resolve => setTimeout(resolve,100));
+            }
+        }
+    }catch(e){
+        console.error("processTask error:",e)
+    } finally{
+        console.log("finish all!!!!!")
+    }
+
+}
+
+CMD.init = async function(){
+    redis_help.connect((results)=>{
+        if(results){
+            processTask();
+        }
+    })
+
+}
+
+CMD.init()

logs/combined.log

@@ -1,16 +1,20 @@
-<<<<<<< HEAD
-2025-02-12T16:20:24: 
-2025-02-12T16:20:24: > heiyan@1.0.0 start
-2025-02-12T16:20:24: > node tg_factory_main.js
-2025-02-12T16:20:24: 
-2025-02-12T16:22:08: 
-2025-02-12T16:22:08: > heiyan@1.0.0 start
-2025-02-12T16:22:08: > node tg_factory_main.js
-2025-02-12T16:22:08: 
-2025-02-12T16:22:11: Connected to Redis
-=======
-2025-02-12T16:20:12: 
-2025-02-12T16:20:12: > heiyan@1.0.0 start
-2025-02-12T16:20:12: > node tg_factory_main.js
-2025-02-12T16:20:12: 
->>>>>>> 26855451fce82442b1677946e1316048f1d9ad13
+2025-02-13T11:47:12: 
+2025-02-13T11:47:12: > heiyan@1.0.0 start
+2025-02-13T11:47:12: > node tg_factory_main.js
+2025-02-13T11:47:12: 
+2025-02-13T11:47:15: Connected to Redis
+2025-02-13T11:49:04: 
+2025-02-13T11:49:04: > heiyan@1.0.0 start
+2025-02-13T11:49:04: > node tg_factory_main.js
+2025-02-13T11:49:04: 
+2025-02-13T11:49:08: Connected to Redis
+2025-02-13T12:02:31: 
+2025-02-13T12:02:31: > heiyan@1.0.0 start
+2025-02-13T12:02:31: > node tg_factory_main.js
+2025-02-13T12:02:31: 
+2025-02-13T12:02:35: Connected to Redis
+2025-02-13T12:05:39: 
+2025-02-13T12:05:39: > heiyan@1.0.0 start
+2025-02-13T12:05:39: > node tg_factory_main.js
+2025-02-13T12:05:39: 
+2025-02-13T12:05:42: Connected to Redis

logs/out.log

@@ -1,16 +1,20 @@
-<<<<<<< HEAD
-2025-02-12T16:20:24: 
-2025-02-12T16:20:24: > heiyan@1.0.0 start
-2025-02-12T16:20:24: > node tg_factory_main.js
-2025-02-12T16:20:24: 
-2025-02-12T16:22:08: 
-2025-02-12T16:22:08: > heiyan@1.0.0 start
-2025-02-12T16:22:08: > node tg_factory_main.js
-2025-02-12T16:22:08: 
-2025-02-12T16:22:11: Connected to Redis
-=======
-2025-02-12T16:20:12: 
-2025-02-12T16:20:12: > heiyan@1.0.0 start
-2025-02-12T16:20:12: > node tg_factory_main.js
-2025-02-12T16:20:12: 
->>>>>>> 26855451fce82442b1677946e1316048f1d9ad13
+2025-02-13T11:47:12: 
+2025-02-13T11:47:12: > heiyan@1.0.0 start
+2025-02-13T11:47:12: > node tg_factory_main.js
+2025-02-13T11:47:12: 
+2025-02-13T11:47:15: Connected to Redis
+2025-02-13T11:49:04: 
+2025-02-13T11:49:04: > heiyan@1.0.0 start
+2025-02-13T11:49:04: > node tg_factory_main.js
+2025-02-13T11:49:04: 
+2025-02-13T11:49:08: Connected to Redis
+2025-02-13T12:02:31: 
+2025-02-13T12:02:31: > heiyan@1.0.0 start
+2025-02-13T12:02:31: > node tg_factory_main.js
+2025-02-13T12:02:31: 
+2025-02-13T12:02:35: Connected to Redis
+2025-02-13T12:05:39: 
+2025-02-13T12:05:39: > heiyan@1.0.0 start
+2025-02-13T12:05:39: > node tg_factory_main.js
+2025-02-13T12:05:39: 
+2025-02-13T12:05:42: Connected to Redis

src/api/yw/yw_search_book.js

@@ -3,6 +3,47 @@ const tools = require('../../../tools');
 const helper = require('../../helper');
 const redis_help = require('../../use_redis');
 const CMD = {}
+
+CMD.search_test_id = async function (bookId) {
+    try {
+        let OPENSESSID = await redis_help.getKeyValue("OPENSESSID")
+        let time = helper.getCurrentUnixTimestamp()
+        const response = await fetch(`https://open.yuewen.com/api/wechatspread/bookSpread?cbid=${bookId}&page=1&version=2&order_field=allwords&order_type=0&content_type=1&category1=-1&allwords=-1&category2=-1&isfinish=-1&level=-1`, {
+            "headers": {
+              "accept": "application/json, text/plain, */*",
+              "accept-language": "zh-CN,zh;q=0.9,en;q=0.8,en-GB;q=0.7,en-US;q=0.6",
+              "priority": "u=1, i",
+              "sec-ch-ua": "\"Microsoft Edge\";v=\"131\", \"Chromium\";v=\"131\", \"Not_A Brand\";v=\"24\"",
+              "sec-ch-ua-mobile": "?0",
+              "sec-ch-ua-platform": "\"Windows\"",
+              "sec-fetch-dest": "empty",
+              "sec-fetch-mode": "cors",
+              "sec-fetch-site": "same-origin",
+              "cookie": `Hm_lvt_990f9ab9737a266517417cc2949bb3f4=${time}; csrfToken=9EeGTClKZ3EJFZjIQDcVozZj; OPENSESSID=${OPENSESSID}; yw_open_token=6784835e6c51a; is_read_notice=6784835e6c51a; sidebarStatus=0`,
+              "Referer": "https://open.yuewen.com/new/library",
+              "Referrer-Policy": "strict-origin-when-cross-origin"
+            },
+            "body": null,
+            "method": "GET"
+        });
+
+        const data = await response.json();
+        console.log('data:', data);
+        if(data.code!=0){
+            throw data
+        }
+        console.log('响应状态:', response.status);
+        if(data.data.list.length<=0){
+            return null
+        }
+        console.log('响应数据:', data.data.list[0]);
+        let book_info = data.data.list[0]
+        return book_info;
+    } catch (error) {
+        return null
+    }
+}
+
 CMD.search_id = async function (bookId) {
     try {
         let OPENSESSID = await redis_help.getKeyValue("OPENSESSID")
@@ -27,6 +68,7 @@ CMD.search_id = async function (bookId) {
         });
 
         const data = await response.json();
+        console.log('data:', data);
         if(data.code!=0){
             throw data
         }
@@ -40,8 +82,14 @@ CMD.search_id = async function (bookId) {
         info.words =  book_info.WordsCntShow
         info.book_name =  book_info.BookName
         info.book_id =  book_info.cbid
+
+        if(book_info.WordsCnt<100000){
+            info.genre = 3;
+        }else{
+            info.genre = 1;
+        }
         // info.genre = 999;
-        info.genre = 3;
+       
         // if(book_info.CategoryName=="短篇"){  
         //     info.genre = 3;
         // }else{

src/data_manager/Controllers/video_product_controllers.js

@@ -171,6 +171,32 @@ class video_product_controllers {
         }
     }
 
+    async getDataByBookPlatform(params) {
+        try {
+            // 参数验证
+            if (!params?.book_platform) {
+                throw  'getDataByBookPlatform:book_platform  is required:'+params;
+            }
+
+            const filterData = await video_product_model.findDataByLimit({ book_platform:params.book_platform },1000);
+
+            if (!filterData) {
+                return {
+                    success: false,
+                    data: null
+                };
+            }
+
+            return {
+                success: true,
+                data: filterData
+            };
+        } catch (error) {
+
+            throw error;
+        }
+    }
+
 }
 
 module.exports =  new video_product_controllers();