123

2_PRODUCT_FACTORY/dz_dj_factory.js

@@ -38,6 +38,7 @@ async function processTask(){
                         element.shelfTime = dj_info.shelfTime
                         element.tg_platform_id = tg_platform_id
                         element.seq_num = dj_info.seq_num
+                        element.gender = dj_info.gender
                         //获取商品库的商品
                         let product_result = await video_product_controllers.getProductData({ book_id: dj_info.bookId });
                         //如果商品库没有这个商品
@@ -270,6 +271,7 @@ CMD.insert_product = async function(data){
         start_chapter:10,
         publish_time:data.shelfTime,
         seq_num:data.seq_num,
+        gender:data.gender
         // status:status 
     })
 }

DZ_DJ_LIB/select_dj_and_inster.js

@@ -81,12 +81,13 @@ CMD.insterData = async function(connection,books) {
             tools.getNewBookName(item.bookName),
             item.bookType,
             item.shelfTime,
-            item.totalChapterNum
+            item.totalChapterNum,
+            item.gender
         ]);
         let table_name = "dz_dj_lib"
         const insertSQL = `
         INSERT INTO ${table_name}
-        (bookId, bookName, bookType, shelfTime,seq_num)
+        (bookId, bookName, bookType, shelfTime,seq_num,gender)
         VALUES ?
         ON DUPLICATE KEY UPDATE
             bookId = VALUES(bookId),

src/api/zy/zy_search_book.js

@@ -115,7 +115,7 @@ CMD.search_list = async function (page,size){
         if(list.length<=0){
             throw list
         }
-        console.log('掌阅书籍::响应状态:', response.status);
+        // console.log('掌阅书籍::响应状态:', response.status,list);
         let temp = []
         for (let index = 0; index < list.length; index++) {
             const book_info = list[index];

tg_factory_main.js

@@ -1,6 +1,7 @@
 setInterval(() => {
 
 }, 15000);
+const CMD = {}
 const ProcessManager = require('./ProcessManager');
 const helper = require('./src/helper');
 const HttpClient = require('./src/HttpClient');
@@ -31,6 +32,41 @@ function getMainInfoById(MainConfig,main_id){
     }
     return null
 }
+
+CMD.getDjMFList = async function(page_num){
+    try{
+        let limit = 1
+        let timestamp = helper.getCurrentUnixTimestamp()
+        let cookit = await tools.getDzMfCookit()
+        console.log("cookit:",cookit)
+        let client = tools.getOneNewClinet({   
+            "accept": "application/json, text/javascript, */*; q=0.01",
+            "content-type": "application/json",
+            "x-requested-with": "XMLHttpRequest",
+            "cookie": `${cookit}`
+        })
+        let response = await client.get(`https://admin.wqxsw.com/admin/referral/book/index?sort=idx&order=desc&offset=${page_num*limit}&limit=${limit}&filter={}&op={}&_=${timestamp}`)
+        
+        let keys = Object.keys(response.data.rows)
+        console.log("keys:",keys)
+        if(keys.length<=0){
+            throw "没有数据了"
+        }
+
+        let temp = []
+
+        for (let index = 0; index < keys.length; index++) {
+            const key = keys[index];
+            const element = response.data.rows[key];
+            temp.push(element)
+        }
+        return temp
+
+    }catch(e){
+        console.error("processTask error:",e)
+        return null
+    } 
+}
 let isInit = false
 // config.isDebug
 if(config.isDebug){
@@ -40,10 +76,15 @@ if(config.isDebug){
                 returns
             }
             isInit = true
-
-            let data = await require('./src/api/zy/zy_search_book').search_name("千金小妹要打工")
-            console.log("data:",data)
+            // require('./src/api/dz/dz_mf_login').login()
+            // await new Promise(resolve => setTimeout(resolve,1500))
+            // let temp = await CMD.getDjMFList(1)
+            // console.log("temp:",temp)
+            // let data = await require('./src/api/zy/zy_search_book').search_name("千金小妹要打工")
+            // console.log("data:",data)
             // require('./src/api/dz/dz_login').login()
+            // let data = await require('./src/api/dz/dz_new_search_book').search_id("11010292075")
+            // console.log("data:",data)
             // let info = await require("./5_CREATE_LINK_FACTORY/fq_create_link").get_tui_jian_start_chapter("7244023180658442807")
             // console.log("info:",info)
             // let response = await  require("./src/api/fq/fq_search_book").new_search_ji_jiang_xia_jia()