123

2_PRODUCT_FACTORY/qm_batch_factory.js

@@ -410,7 +410,7 @@ CMD.addQMMFVideoProduct = async function(product_id,product_parent_id){
         multipleStatements: true
     });
 
-    let qm_book_data = await require('../src/api/qm_mf/qm_mf_search_book').search_id(product_id)
+    let qm_book_data = await require('../src/api/qm_mf/qm_mf_search_book').search_id_new(product_id)
     if(qm_book_data!=null){
         await connection.execute(
             `INSERT INTO video_product (product_name,product_id,book_platform,genre,words,product_parent_id)  VALUES ("${qm_book_data.book_name}",${product_id},${config.platform_qmmf},${qm_book_data.genre},"${qm_book_data.words}",${product_parent_id})`

2_PRODUCT_FACTORY/qm_mf_batch_factory.js

@@ -116,7 +116,7 @@ async function processCreateTask(){
             if(!product.success){
                 let tg_platform_id = result.data.tg_platform_id
                 if(tg_platform_id==config.platform_qmmf){ //七猫
-                    let qm_book_data = await require('../src/api/qm_mf/qm_mf_search_book').search_id(result.data.book_id)
+                    let qm_book_data = await require('../src/api/qm_mf/qm_mf_search_book').search_id_new(result.data.book_id)
                     if(qm_book_data==null){
                         result.data.genre = 999
                     }else{

qm_update_works.js

@@ -9,7 +9,7 @@ async function processTask(){
         console.log("result:",result)
         if(result.success){
             const product_item =  result.data;
-            let qm_book_data = await require('./src/api/qm_mf/qm_mf_search_book').search_id(product_item.product_id)
+            let qm_book_data = await require('./src/api/qm_mf/qm_mf_search_book').search_id_new(product_item.product_id)
             let words = 1
             if(qm_book_data==null){
                 

src/api/qm/qm_search_book.js

@@ -141,7 +141,7 @@ CMD.search_id_new = async function(book_id) {
     console.log("finalUrl:",finalUrl)
     try{
         let response =  await client.get(finalUrl)
-        console.log("response:",response.data)
+        // console.log("response:",response.data)
         if(response.data.code!=0){
             throw response.data
         }

src/api/qm_mf/qm_mf_search_book.js

@@ -4,6 +4,8 @@ const helper = require('../../helper');
 const mysql = require('mysql2/promise');
 const config = require("../../../etc/config.json");
 const dbConfig = config.isDebug?config.debug_mysql:config.release_mysql
+const crypto = require('crypto')
+const { format } = require('date-fns');
 const CMD = {}
 CMD.search_id = async function (bookId) {
     let connection  = null
@@ -200,4 +202,57 @@ CMD.search_350_name = async function (book_name) {
         }
     }
 }
+
+CMD.search_id_new = async function(book_id) {
+    let client = tools.getOneNewClinet()
+    let uuid = tools.generateCryptoNumericUUID()
+    let timestamp = helper.getCurrentUnixTimestamp()
+    const baseUrl = "https://new-media-iaa-mapi.qimao.com/mapi/v1/book-info";
+    const params = {
+        access_key: config.qimao_mf_config.access_key,
+        admin_account_name:"zhuoyue",
+        book_id:book_id,
+        random: uuid,
+        timestamp: timestamp,
+    };
+
+
+    const sortedParams = Object.keys(params)
+    .sort()
+    .map(key => `${key}=${params[key]}`)
+    .join('&');
+
+    const secretKey = config.qimao_mf_config.secret_key;
+
+    const sign = crypto.createHash('md5')
+            .update(sortedParams + secretKey)
+            .digest('hex');
+    const finalUrl = `${baseUrl}?${sortedParams}&sign=${sign}`;
+
+    console.log("finalUrl:",finalUrl)
+    try{
+        let response =  await client.get(finalUrl)
+        // console.log("response:",response.data)
+        if(response.data.code!=0){
+            throw response.data
+        }
+        let book_info = response.data.data.book
+        let info = {}
+        info.words =  book_info.word_count
+        info.book_name =  book_info.name
+        info.book_id =  book_info.id
+        info.genre = 999;
+        info.author = book_info.author
+        info.publish_time = format(new Date(book_info.create_time*1000), 'yyyy-MM-dd HH:mm:ss')
+        if(book_info.type==2){  //七猫只有长或者短
+            info.genre = 3;
+        }else{
+            info.genre = 1;
+        }
+        return info;
+    }catch(e){
+        console.log(e)
+        return null
+    }
+}
 module.exports = CMD;

task_script/get_qm_mf_for_iap.js

@@ -106,7 +106,7 @@ CMD.addQMMFVideoProduct = async function(product_id,product_parent_id){
         multipleStatements: true
     });
 
-    let qm_book_data = await require('../src/api/qm_mf/qm_mf_search_book').search_id(product_id)
+    let qm_book_data = await require('../src/api/qm_mf/qm_mf_search_book').search_id_new(product_id)
     console.log("qm_book_data:",qm_book_data,product_id,product_parent_id)
     if(qm_book_data!=null){
         await connection.execute(

task_script/sync_author_qm_mf.js

@@ -27,7 +27,7 @@ async function processTask(){
 
         for (let index = 0; index < rows.length; index++) {
             let video_product_info = rows[index]
-            let data = await require('../src/api/qm_mf/qm_mf_search_book').search_id(video_product_info.product_id)
+            let data = await require('../src/api/qm_mf/qm_mf_search_book').search_id_new(video_product_info.product_id)
             if(data!=null&&data!=""){
                 let author = data.author
                 await connection.execute(

task_script/sync_publish_time_qm_mf.js

@@ -26,7 +26,7 @@ async function processTask(){
         for (let index = 0; index < rows.length; index++) {
             let video_product_info = rows[index]
            
-            let data =  await require('../src/api/qm_mf/qm_mf_search_book').search_id(video_product_info.product_id)
+            let data =  await require('../src/api/qm_mf/qm_mf_search_book').search_id_new(video_product_info.product_id)
             if(data!=null){
                 let publish_time = data.publish_time
                 await connection.execute(

tg_factory_main.js

@@ -32,12 +32,12 @@ if(config.isDebug){
     redis_help.connect( async (results)=>{
         if(results){
             // await makeRequest()
-            let uuid =  tools.generateCryptoNumericUUID(5)
-            console.log("date:",uuid)
+            // let uuid =  tools.generateCryptoNumericUUID(5)
+            // console.log("date:",uuid)
             // let id = tools.getOriginVideoId("https://www.douyin.com/video/7505676062089563431")
             // console.log("id:",id)
-            let data = await require('./src/api/qm/qm_search_book').search_id_new("510151")
-            console.log("data:",data)
+            // let data = await require('./src/api/qm/qm_search_book').search_id_new("510151")
+            // console.log("data:",data)
 
 
     // let zy_token = await require('./src/api/zy/zy_login').zy_login()
@@ -138,8 +138,8 @@ if(config.isDebug){
 
             // let totalWordSize = data.rows[0].totalWordSize
             // let totalChapterNum = data.rows[0].totalChapterNum
-            // let book_info =  await require("./src/api/qm_mf/qm_mf_search_book").search_name("巧克力薄脆","爸妈地震中只救假千金，我离开后他们后悔了")
-            // console.log("book_info:",book_info)
+            let book_info =  await require("./src/api/qm_mf/qm_mf_search_book").search_id_new("1024391")
+            console.log("book_info:",book_info)
             //    await require("./5_CREATE_LINK_FACTORY/zh_create_link").makeRequest()
  
             // if(isInit){