904118851 3 meses atrás
pai
commit
8a3f37a092
5 arquivos alterados com 113 adições e 15 exclusões
  1. BIN
      dump.rdb
  2. 52 0
      logs/combined.log
  3. 52 0
      logs/out.log
  4. 1 1
      src/helper.js
  5. 8 14
      task_script/sync_publish_time_fq_mf.js

BIN
dump.rdb


+ 52 - 0
logs/combined.log

@@ -3658,3 +3658,55 @@
 2025-05-02T17:10:26: > heiyan@1.0.0 start
 2025-05-02T17:10:26: > node tg_factory_main.js
 2025-05-02T17:10:26: 
+2025-05-02T17:10:27: 
+2025-05-02T17:10:27: > heiyan@1.0.0 start
+2025-05-02T17:10:27: > node tg_factory_main.js
+2025-05-02T17:10:27: 
+2025-05-02T17:10:28: 
+2025-05-02T17:10:28: > heiyan@1.0.0 start
+2025-05-02T17:10:28: > node tg_factory_main.js
+2025-05-02T17:10:28: 
+2025-05-02T17:10:29: 
+2025-05-02T17:10:29: > heiyan@1.0.0 start
+2025-05-02T17:10:29: > node tg_factory_main.js
+2025-05-02T17:10:29: 
+2025-05-02T17:10:30: 
+2025-05-02T17:10:30: > heiyan@1.0.0 start
+2025-05-02T17:10:30: > node tg_factory_main.js
+2025-05-02T17:10:30: 
+2025-05-02T17:10:31: 
+2025-05-02T17:10:31: > heiyan@1.0.0 start
+2025-05-02T17:10:31: > node tg_factory_main.js
+2025-05-02T17:10:31: 
+2025-05-02T17:10:32: 
+2025-05-02T17:10:32: > heiyan@1.0.0 start
+2025-05-02T17:10:32: > node tg_factory_main.js
+2025-05-02T17:10:32: 
+2025-05-02T17:10:33: 
+2025-05-02T17:10:33: > heiyan@1.0.0 start
+2025-05-02T17:10:33: > node tg_factory_main.js
+2025-05-02T17:10:33: 
+2025-05-02T17:10:34: 
+2025-05-02T17:10:34: > heiyan@1.0.0 start
+2025-05-02T17:10:34: > node tg_factory_main.js
+2025-05-02T17:10:34: 
+2025-05-02T17:10:35: 
+2025-05-02T17:10:35: > heiyan@1.0.0 start
+2025-05-02T17:10:35: > node tg_factory_main.js
+2025-05-02T17:10:35: 
+2025-05-02T17:10:37: 
+2025-05-02T17:10:37: > heiyan@1.0.0 start
+2025-05-02T17:10:37: > node tg_factory_main.js
+2025-05-02T17:10:37: 
+2025-05-02T17:10:38: 
+2025-05-02T17:10:38: > heiyan@1.0.0 start
+2025-05-02T17:10:38: > node tg_factory_main.js
+2025-05-02T17:10:38: 
+2025-05-02T17:10:39: 
+2025-05-02T17:10:39: > heiyan@1.0.0 start
+2025-05-02T17:10:39: > node tg_factory_main.js
+2025-05-02T17:10:39: 
+2025-05-02T17:10:40: 
+2025-05-02T17:10:40: > heiyan@1.0.0 start
+2025-05-02T17:10:40: > node tg_factory_main.js
+2025-05-02T17:10:40: 

+ 52 - 0
logs/out.log

@@ -3658,3 +3658,55 @@
 2025-05-02T17:10:26: > heiyan@1.0.0 start
 2025-05-02T17:10:26: > node tg_factory_main.js
 2025-05-02T17:10:26: 
+2025-05-02T17:10:27: 
+2025-05-02T17:10:27: > heiyan@1.0.0 start
+2025-05-02T17:10:27: > node tg_factory_main.js
+2025-05-02T17:10:27: 
+2025-05-02T17:10:28: 
+2025-05-02T17:10:28: > heiyan@1.0.0 start
+2025-05-02T17:10:28: > node tg_factory_main.js
+2025-05-02T17:10:28: 
+2025-05-02T17:10:29: 
+2025-05-02T17:10:29: > heiyan@1.0.0 start
+2025-05-02T17:10:29: > node tg_factory_main.js
+2025-05-02T17:10:29: 
+2025-05-02T17:10:30: 
+2025-05-02T17:10:30: > heiyan@1.0.0 start
+2025-05-02T17:10:30: > node tg_factory_main.js
+2025-05-02T17:10:30: 
+2025-05-02T17:10:31: 
+2025-05-02T17:10:31: > heiyan@1.0.0 start
+2025-05-02T17:10:31: > node tg_factory_main.js
+2025-05-02T17:10:31: 
+2025-05-02T17:10:32: 
+2025-05-02T17:10:32: > heiyan@1.0.0 start
+2025-05-02T17:10:32: > node tg_factory_main.js
+2025-05-02T17:10:32: 
+2025-05-02T17:10:33: 
+2025-05-02T17:10:33: > heiyan@1.0.0 start
+2025-05-02T17:10:33: > node tg_factory_main.js
+2025-05-02T17:10:33: 
+2025-05-02T17:10:34: 
+2025-05-02T17:10:34: > heiyan@1.0.0 start
+2025-05-02T17:10:34: > node tg_factory_main.js
+2025-05-02T17:10:34: 
+2025-05-02T17:10:35: 
+2025-05-02T17:10:35: > heiyan@1.0.0 start
+2025-05-02T17:10:35: > node tg_factory_main.js
+2025-05-02T17:10:35: 
+2025-05-02T17:10:37: 
+2025-05-02T17:10:37: > heiyan@1.0.0 start
+2025-05-02T17:10:37: > node tg_factory_main.js
+2025-05-02T17:10:37: 
+2025-05-02T17:10:38: 
+2025-05-02T17:10:38: > heiyan@1.0.0 start
+2025-05-02T17:10:38: > node tg_factory_main.js
+2025-05-02T17:10:38: 
+2025-05-02T17:10:39: 
+2025-05-02T17:10:39: > heiyan@1.0.0 start
+2025-05-02T17:10:39: > node tg_factory_main.js
+2025-05-02T17:10:39: 
+2025-05-02T17:10:40: 
+2025-05-02T17:10:40: > heiyan@1.0.0 start
+2025-05-02T17:10:40: > node tg_factory_main.js
+2025-05-02T17:10:40: 

+ 1 - 1
src/helper.js

@@ -441,7 +441,7 @@ helper.getDate7DaysBefore = function(dateString, inputFormat, outputFormat) {
     }
     
     const date7DaysBefore = new Date(inputDate);
-    date7DaysBefore.setDate(date7DaysBefore.getDate() - 7);
+    date7DaysBefore.setDate(date7DaysBefore.getDate() + 7);
     
     // 简单格式化函数
     function formatDate(date, format) {

+ 8 - 14
task_script/sync_publish_time_fq_mf.js

@@ -3,6 +3,8 @@ const config = require("../etc/config.json");
 const mysql = require('mysql2/promise');
 const taskdbConfig = config.isDebug?config.debug_task_mysql:config.release_task_mysql
 const redis_help = require('../src/use_redis');
+const video_product_controllers = require('../src/data_manager/Controllers/video_product_controllers');
+const helper = require("../src/helper");
 const CMD = {}
 async function processTask(){
     let right_status = true
@@ -13,7 +15,7 @@ async function processTask(){
             multipleStatements: true
         });
         //先获取100本没有发布时间的番茄免费书籍
-        let sql = `SELECT * FROM video_product WHERE book_platform = ${config.platform_fanqiemf} AND  publish_time IS NULL  LIMIT 500`
+        let sql = `SELECT * FROM video_product WHERE book_platform = ${config.platform_fanqiemf} AND product_parent_id !="" AND  publish_time IS NULL  LIMIT 500`
         console.log("sql:",sql)
         const [rows] = await connection.execute(
             sql
@@ -25,24 +27,16 @@ async function processTask(){
 
         for (let index = 0; index < rows.length; index++) {
             let video_product_info = rows[index]
-            let data =  await require('../src/api/fq/fq_search_book').search_mf_new_id(video_product_info.product_id)
-            if(data==""){
-                console.error("接口失效")
-            }else{
-                if(data!=null){
-                    let publish_time = data.on_shelf_time
+            let book_info =  await  video_product_controllers.getProductData({book_id:video_product_info.product_parent_id})
+            if(book_info.success){
+                if(book_info.publish_time!=null){
+                    let publish_time = helper.getDate7DaysBefore(book_info.publish_time,null,'YYYY-MM-DD') 
                     await connection.execute(
                         `UPDATE video_product SET publish_time = "${publish_time}"  WHERE id = ${video_product_info.id} `
                     );
-                }else{
-                    console.error("查无此书:",video_product_info)
-                    await connection.execute(
-                        ` UPDATE video_product SET status = 0 , publish_time = '2000-01-01 01:01:01' WHERE id = ${video_product_info.id}  `
-                    );
                 }
             }
-      
-        }
+        }   
 
 
     }catch(e){