123

2_PRODUCT_FACTORY/qm_mf_batch_factory.js

@@ -7,6 +7,7 @@ const redis_help = require('../src/use_redis');
 const config = require('../etc/config.json');
 const mysql = require('mysql2/promise');
 const dbConfig = config.isDebug?config.debug_mysql:config.release_mysql
+const taskdbConfig = config.isDebug?config.debug_task_mysql:config.release_task_mysql
 const time_count = 1000;
 const task_queue = []
 
@@ -340,9 +341,9 @@ CMD.insert_product = async function(data){
 
         }else{
             let qm_iap_book_info = rows[0]
-            let iaa_book_id = await CMD.getQMMFVideoProduct(connection,qm_iap_book_info.iaa_book_id)
+            let iaa_book_id = await CMD.getQMMFVideoProduct(qm_iap_book_info.iaa_book_id)
             if(iaa_book_id==null){
-                await CMD.addQMMFVideoProduct(connection,iaa_book_id,iaa_book_id.book_id)
+                await CMD.addQMMFVideoProduct(iaa_book_id,iaa_book_id.book_id)
             }
         }
     }catch(e){
@@ -356,17 +357,30 @@ CMD.insert_product = async function(data){
 }
 
 //插入
-CMD.addQMMFVideoProduct = async function(connection,product_id,product_parent_id){
+CMD.addQMMFVideoProduct = async function(product_id,product_parent_id){
+    let connection = await mysql.createConnection({
+        ...taskdbConfig,
+        multipleStatements: true
+    });
+
     let qm_book_data = await require('../src/api/qm_mf/qm_mf_search_book').search_id(product_id)
     await connection.execute(
         `INSERT INTO video_product (product_name,product_id,book_platform,genre,words,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})`
     );
+    await connection.end();
 }
 
-CMD.getQMMFVideoProduct = async function(connection,product_id){
+CMD.getQMMFVideoProduct = async function(product_id){
+    let connection = await mysql.createConnection({
+        ...taskdbConfig,
+        multipleStatements: true
+    });
+
     const [rows] = await connection.execute(
         `SELECT * FROM video_product WHERE product_id = ${product_id} AND book_platform = ${config.platform_qmmf}  LIMIT 1`
     );
+    await connection.end();
+    
     if(rows.length<=0){
         return null
     }

logs/combined.log

@@ -31,3 +31,8 @@
 >>>>>>> 519347472191c7e9f1e859b1d2eb999bf8af34ec
 >>>>>>> 4a0b6e7cf5bcf28c250e27a6b71e0247f72854c7
 >>>>>>> 537bc45f51548aa44125f8819fa9f2f59167c2a3
+2025-03-24T15:33:56: 
+2025-03-24T15:33:56: > heiyan@1.0.0 start
+2025-03-24T15:33:56: > node tg_factory_main.js
+2025-03-24T15:33:56: 
+2025-03-24T15:34:00: Connected to Redis

logs/out.log

@@ -31,3 +31,8 @@
 >>>>>>> 519347472191c7e9f1e859b1d2eb999bf8af34ec
 >>>>>>> 4a0b6e7cf5bcf28c250e27a6b71e0247f72854c7
 >>>>>>> 537bc45f51548aa44125f8819fa9f2f59167c2a3
+2025-03-24T15:33:56: 
+2025-03-24T15:33:56: > heiyan@1.0.0 start
+2025-03-24T15:33:56: > node tg_factory_main.js
+2025-03-24T15:33:56: 
+2025-03-24T15:34:00: Connected to Redis

task_script/get_qm_mf_for_iap.js

@@ -6,6 +6,7 @@ const mysql = require('mysql2/promise');
 const tools = require("../tools");
 const video_product_controllers = require('../src/data_manager/Controllers/video_product_controllers');
 const dbConfig = config.isDebug?config.debug_mysql:config.release_mysql
+const taskdbConfig = config.isDebug?config.debug_task_mysql:config.release_task_mysql
 const CMD = {}
 let page_index = 1;
 
@@ -72,9 +73,9 @@ async function processTask(){
 
             }else{
                 let qm_iap_book_info = rows[0]
-                let iaa_book_id = await CMD.getQMMFVideoProduct(connection,qm_iap_book_info.iaa_book_id)
+                let iaa_book_id = await CMD.getQMMFVideoProduct(qm_iap_book_info.iaa_book_id)
                 if(iaa_book_id==null){
-                    await CMD.addQMMFVideoProduct(connection,iaa_book_id,iaa_book_id.book_id)
+                    await CMD.addQMMFVideoProduct(iaa_book_id,iaa_book_id.book_id)
                 }
             }
         }
@@ -93,28 +94,37 @@ async function processTask(){
 
 }
 
-//获取
-CMD.getQMMFVideoProduct = async function(connection,product_id){
+//插入
+CMD.addQMMFVideoProduct = async function(product_id,product_parent_id){
+    let connection = await mysql.createConnection({
+        ...taskdbConfig,
+        multipleStatements: true
+    });
+
+    let qm_book_data = await require('../src/api/qm_mf/qm_mf_search_book').search_id(product_id)
+    await connection.execute(
+        `INSERT INTO video_product (product_name,product_id,book_platform,genre,words,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})`
+    );
+    await connection.end();
+}
+
+CMD.getQMMFVideoProduct = async function(product_id){
+    let connection = await mysql.createConnection({
+        ...taskdbConfig,
+        multipleStatements: true
+    });
+
     const [rows] = await connection.execute(
         `SELECT * FROM video_product WHERE product_id = ${product_id} AND book_platform = ${config.platform_qmmf}  LIMIT 1`
     );
-
+    await connection.end();
+    
     if(rows.length<=0){
         return null
     }
-
     return rows[0]
 }
 
-//插入
-CMD.addQMMFVideoProduct = async function(connection,product_id,product_parent_id){
-    let qm_book_data = await require('../src/api/qm_mf/qm_mf_search_book').search_id(product_id)
-    await connection.execute(
-        `INSERT INTO video_product (product_name,product_id,book_platform,genre,words,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})`
-    );
-
-}
-
 CMD.init = async function(){
     redis_help.connect((results)=>{
         if(results){