123

2_PRODUCT_FACTORY/PRODUCT_FACTORY.js

@@ -8,17 +8,16 @@ const axios = require('axios');
 const config = require('../etc/config.json');
 const HttpClient = require('../src/HttpClient');
 const helper = require('../src/helper');
-const time_count = 500;
-CMD.init = async function(){
-    redis_help.connect((results)=>{
-        if(results){
-        }
-    })
-    setInterval(async () => {
+const time_count = 2000;
+const task_queue = []
+
+async function processTask(){
+    try{
         let isPauseTask =  await redis_help.getKeyValue("isPauseTask")
         if(isPauseTask=="true"){
             return
         }
+        let isInsertTask = false
         let FilterConfig = await redis_help.getKeyValue("FilterConfig")
         FilterConfig = JSON.parse(FilterConfig)
         let result = await filter_data_controllers.getFilterDataByStatus({ status: 0 });
@@ -33,20 +32,13 @@ CMD.init = async function(){
                     result.data.book_id = hy_book_result.data.product_id
                     result.data.book_name = hy_book_result.data.product_name
                 }else{
-                    let hy_book_data = await require('./collect_hy_book').runTask(result.data)
-                    if(CMD.isGenre(FilterConfig,hy_book_data.genre)){
-                        await CMD.insert_product(hy_book_data)
-                    }
-                    result.data.words = hy_book_data.words
-                    result.data.genre = hy_book_data.genre
-                    result.data.book_id = hy_book_data.book_id
-                    result.data.book_name = hy_book_data.book_name
+                    isInsertTask = true
                 }
             }else if(tg_platform_id==2){ //番茄
                 //获取番茄书库的书
                 let fq_book_result = await get_fq_book_tab_controllers.getData({ book_id: result.data.book_id });
                 if(fq_book_result.success){//如果番茄书库里有这本书
-
+    
                     result.data.genre = CMD.getFqGenre(fq_book_result.data.info.genre)
                     result.data.book_id = fq_book_result.data.book_id
                     result.data.book_name = fq_book_result.data.info.book_name
@@ -62,36 +54,83 @@ CMD.init = async function(){
                         }
                     }
                 }else{
-                    let client =  new HttpClient()
-                    let response =  await client.proxyRequest( helper.getFqRequestOpt(result.data.book_id))
-                    let obj = response['data']
-                    let book_name =  obj['novel_data'].book_name
-                    let book_id = obj['novel_data'].book_id
-                    let genre = CMD.getFqGenre(obj['novel_data'].genre)
-                    let words = obj['novel_data'].word_number
-                    let fq_book_data = {book_name:book_name,book_id:book_id,genre:genre,words:words,info:JSON.stringify(obj['novel_data'])}
-                    let fq_book = {} 
-                    fq_book.key = result.data.book_id
-                    await CMD.add_fq_book(fq_book,fq_book_data)
-                    let product_result = await video_product_controllers.getProductData({ book_id: book_id });
-                    if(!product_result.success){ //如果书库也没有
-                        fq_book.tg_platform_id = result.data.tg_platform_id
-                        if(CMD.isGenre(FilterConfig,fq_book_data.genre)){
-                            fq_book_data.tg_platform_id = result.data.tg_platform_id
-                            await CMD.insert_product(fq_book_data)
-                        }
-                    }
-                    result.data.words = words
-                    result.data.genre = fq_book_data.genre
-                    result.data.book_id = fq_book_data.book_id
-                    result.data.book_name = fq_book_data.book_name
+                    isInsertTask = true
+              
                 }
-                
             }
+            if(!isInsertTask){
+                await CMD.update_filter_data(FilterConfig,result.data)
+            }else{
+                await filter_data_controllers.updateFilterData({id:result.data.id},{status:1})
+                task_queue.push({result:result})
+            }
+        }
+    }catch(e){
+        await filter_data_controllers.updateFilterData({id:result.data.id},{status:2})
+    } finally{
+        setTimeout(processTask, 500);
+    }
+
+}
 
+async function processCreateTask(){
+    try{
+        if(task_queue.length>0){
+            let task_queue_item = task_queue.pop()
+            let FilterConfig = await redis_help.getKeyValue("FilterConfig")
+            FilterConfig = JSON.parse(FilterConfig)
+            let result = task_queue_item.result
+            let tg_platform_id = result.data.tg_platform_id
+            if(tg_platform_id==1){
+                let hy_book_data = await require('./collect_hy_book').runTask(result.data)
+                if(CMD.isGenre(FilterConfig,hy_book_data.genre)){
+                    await CMD.insert_product(hy_book_data)
+                }
+                result.data.words = hy_book_data.words
+                result.data.genre = hy_book_data.genre
+                result.data.book_id = hy_book_data.book_id
+                result.data.book_name = hy_book_data.book_name
+            }else if(tg_platform_id==2){
+                let client =  new HttpClient()
+                let response =  await client.proxyRequest( helper.getFqRequestOpt(result.data.book_id))
+                let obj = response['data']
+                let book_name =  obj['novel_data'].book_name
+                let book_id = obj['novel_data'].book_id
+                let genre = CMD.getFqGenre(obj['novel_data'].genre)
+                let words = obj['novel_data'].word_number
+                let fq_book_data = {book_name:book_name,book_id:book_id,genre:genre,words:words,info:JSON.stringify(obj['novel_data'])}
+                let fq_book = {} 
+                fq_book.key = result.data.book_id
+                await CMD.add_fq_book(fq_book,fq_book_data)
+                let product_result = await video_product_controllers.getProductData({ book_id: fq_book_data.book_id });
+                if(!product_result.success){ //如果书库也没有
+                    fq_book.tg_platform_id = result.data.tg_platform_id
+                
+                    if(CMD.isGenre(FilterConfig,fq_book_data.genre)){
+                        fq_book_data.tg_platform_id = result.data.tg_platform_id
+                        await CMD.insert_product(fq_book_data)
+                    }
+                }
+                result.data.words = words
+                result.data.genre = fq_book_data.genre
+                result.data.book_id = fq_book_data.book_id
+                result.data.book_name = fq_book_data.book_name
+            }
             await CMD.update_filter_data(FilterConfig,result.data)
         }
-    }, time_count);
+    }catch(e){
+
+    } finally{
+        setTimeout(processCreateTask, time_count);
+    }
+}
+CMD.init = async function(){
+    redis_help.connect((results)=>{
+        if(results){
+        }
+    })
+    processTask();
+    processCreateTask();
 }
 CMD.getFqGenre = function(genre){
     if(genre=="0"){
@@ -146,8 +185,12 @@ function deepCopy3(obj) {
 
 CMD.update_filter_data = async function(FilterConfig,data) {
     if(CMD.isGenre(FilterConfig,data.genre)){
-        await CMD.video_product_material(data)
-        await filter_data_controllers.updateFilterData({id:data.id},{status:1,book_id:data.book_id,book_name:data.book_name})
+        try{
+            await CMD.video_product_material(data)
+        }catch(e){
+            console.log("video_product_material error:",e)
+        }
+        await filter_data_controllers.updateFilterData({id:data.id},{status:1,book_id:data.book_id,book_name:data.book_name,genre:data.genre,words:data.words})
         //创建一个小程序    
         let AppConfig = await redis_help.getKeyValue("AppConfig")
 
@@ -203,7 +246,7 @@ CMD.update_filter_data = async function(FilterConfig,data) {
 
     
     }else{
-        await filter_data_controllers.updateFilterData({id:data.id},{status:2,book_id:data.book_id,book_name:data.book_name})
+        await filter_data_controllers.updateFilterData({id:data.id},{status:2,book_id:data.book_id,book_name:data.book_name,genre:data.genre})
     }
 }
 
@@ -221,6 +264,7 @@ CMD.video_product_material = async function(data){
         comment_number: data.comment_num,
         forward_number: data.shared_num,
         book_platform: data.tg_platform_id,
+        title: data.title,
         yun_fabu_time:data.publish_time
     }))
     return await axios.post(url, formData, {
@@ -242,7 +286,6 @@ CMD.video_product_material = async function(data){
 }
 
 CMD.insert_product = async function(data){
-    console.log("insert_product:",data)
     return await video_product_controllers.createProductData({
         book_platform:data.tg_platform_id,
         product_name:data.book_name,
@@ -270,7 +313,6 @@ CMD.add_fq_book = async function(data,response){
     data.words = words
     data.book_name = book_name
     data.book_id = book_id
-    console.log("response:",response)
     return await get_fq_book_tab_controllers.createData( {
         book_key:data.key,
         book_id:data.book_id,

7_CHECK_AND_CREATE_URL_FACTORY/CHECK_AND_CREATE_URL_FACTORY.js

@@ -12,7 +12,7 @@ CMD.init = function(){
     setInterval(() => {
         sql_task_help.get(sql,(is_right,data)=>{
             if(is_right){
-                console.log("sql:",data)
+                // console.log("sql:",data)
                 if(data.length>0){
                     CMD.build_check_url( data[0])
                 }
@@ -48,7 +48,7 @@ CMD.update_video_applet_product = function(data){
      sql_task_help.update('UPDATE video_applet_product SET status = ?, wait_status = ?  , check_url = ?   WHERE promotion_id = ? and product_id = ?', 
         [1,2,data.check_url,data.promotion_id,data.product_id],
         ()=>{
-            console.log("update_video_applet_product:更新成功！")
+            // console.log("update_video_applet_product:更新成功！")
         })
 }
 

7_CHECK_AND_CREATE_URL_FACTORY/log/node-app.stdout.log

@@ -1,3 +1,4 @@
+<<<<<<< HEAD
 2024-11-30 11:43:17: send_data_server：sql_task_help
 2024-11-30 11:43:17: Connected to the MySQL server.
 2024-11-30 11:43:19: sql: []
@@ -163721,3 +163722,185 @@
 2024-12-04 18:48:19: sql: []
 2024-12-04 18:48:21: sql: []
 >>>>>>> dbe134510ceb02a98e645caa107bbad2dd5471d1
+=======
+2024-12-05 12:27:43: send_data_server：sql_task_help
+2024-12-05 12:27:43: Connected to the MySQL server.
+2024-12-05 12:27:45: sql: [
+2024-12-05 12:27:45:   {
+2024-12-05 12:27:45:     id: 154,
+2024-12-05 12:27:45:     product_name: '双十一我打个电话，舍友要我赔两万',
+2024-12-05 12:27:45:     product_id: '7435933042889198601',
+2024-12-05 12:27:45:     create_at: 2024-12-05T04:25:52.000Z,
+2024-12-05 12:27:45:     book_platform: 2,
+2024-12-05 12:27:45:     industry: 1,
+2024-12-05 12:27:45:     dy_small_program_start: 'pages/bookstore/index',
+2024-12-05 12:27:45:     dy_small_program_start_data: 'key=PHW9XI9LXYJ&aid=40014221&item_source=1&media_source=1&click_id=__CLICKID__&request_id=__REQUESTID__&mid1=__MID1__&mid2=__MID2__&mid3=__MID3__&mid4=__MID4__&mid5=__MID5__',
+2024-12-05 12:27:45:     dy_small_program_safety: '',
+2024-12-05 12:27:45:     dy_small_applet_app_id: 'tt46893034d9b8232301',
+2024-12-05 12:27:45:     check_url: '',
+2024-12-05 12:27:45:     status: 0,
+2024-12-05 12:27:45:     main_id: 9,
+2024-12-05 12:27:45:     promotion_id: '1817572996227115',
+2024-12-05 12:27:45:     wait_status: 1,
+2024-12-05 12:27:45:     error_info: null
+2024-12-05 12:27:45:   }
+2024-12-05 12:27:45: ]
+2024-12-05 12:27:47: sql: [
+2024-12-05 12:27:47:   {
+2024-12-05 12:27:47:     id: 154,
+2024-12-05 12:27:47:     product_name: '双十一我打个电话，舍友要我赔两万',
+2024-12-05 12:27:47:     product_id: '7435933042889198601',
+2024-12-05 12:27:47:     create_at: 2024-12-05T04:25:52.000Z,
+2024-12-05 12:27:47:     book_platform: 2,
+2024-12-05 12:27:47:     industry: 1,
+2024-12-05 12:27:47:     dy_small_program_start: 'pages/bookstore/index',
+2024-12-05 12:27:47:     dy_small_program_start_data: 'key=PHW9XI9LXYJ&aid=40014221&item_source=1&media_source=1&click_id=__CLICKID__&request_id=__REQUESTID__&mid1=__MID1__&mid2=__MID2__&mid3=__MID3__&mid4=__MID4__&mid5=__MID5__',
+2024-12-05 12:27:47:     dy_small_program_safety: '',
+2024-12-05 12:27:47:     dy_small_applet_app_id: 'tt46893034d9b8232301',
+2024-12-05 12:27:47:     check_url: '',
+2024-12-05 12:27:47:     status: 0,
+2024-12-05 12:27:47:     main_id: 9,
+2024-12-05 12:27:47:     promotion_id: '1817572996227115',
+2024-12-05 12:27:47:     wait_status: 1,
+2024-12-05 12:27:47:     error_info: null
+2024-12-05 12:27:47:   }
+2024-12-05 12:27:47: ]
+2024-12-05 12:27:49: sql: [
+2024-12-05 12:27:49:   {
+2024-12-05 12:27:49:     id: 154,
+2024-12-05 12:27:49:     product_name: '双十一我打个电话，舍友要我赔两万',
+2024-12-05 12:27:49:     product_id: '7435933042889198601',
+2024-12-05 12:27:49:     create_at: 2024-12-05T04:25:52.000Z,
+2024-12-05 12:27:49:     book_platform: 2,
+2024-12-05 12:27:49:     industry: 1,
+2024-12-05 12:27:49:     dy_small_program_start: 'pages/bookstore/index',
+2024-12-05 12:27:49:     dy_small_program_start_data: 'key=PHW9XI9LXYJ&aid=40014221&item_source=1&media_source=1&click_id=__CLICKID__&request_id=__REQUESTID__&mid1=__MID1__&mid2=__MID2__&mid3=__MID3__&mid4=__MID4__&mid5=__MID5__',
+2024-12-05 12:27:49:     dy_small_program_safety: '',
+2024-12-05 12:27:49:     dy_small_applet_app_id: 'tt46893034d9b8232301',
+2024-12-05 12:27:49:     check_url: '',
+2024-12-05 12:27:49:     status: 0,
+2024-12-05 12:27:49:     main_id: 9,
+2024-12-05 12:27:49:     promotion_id: '1817572996227115',
+2024-12-05 12:27:49:     wait_status: 1,
+2024-12-05 12:27:49:     error_info: null
+2024-12-05 12:27:49:   }
+2024-12-05 12:27:49: ]
+2024-12-05 12:27:49: update_video_applet_product:更新成功！
+2024-12-05 12:27:50: update_video_applet_product:更新成功！
+2024-12-05 12:27:51: update_video_applet_product:更新成功！
+2024-12-05 12:27:51: sql: [
+2024-12-05 12:27:51:   {
+2024-12-05 12:27:51:     id: 153,
+2024-12-05 12:27:51:     product_name: '双十一我打个电话，舍友要我赔两万',
+2024-12-05 12:27:51:     product_id: '7435933042889198601',
+2024-12-05 12:27:51:     create_at: 2024-12-05T04:25:52.000Z,
+2024-12-05 12:27:51:     book_platform: 2,
+2024-12-05 12:27:51:     industry: 1,
+2024-12-05 12:27:51:     dy_small_program_start: 'pages/bookstore/index',
+2024-12-05 12:27:51:     dy_small_program_start_data: 'key=PHW9XHXDPOR&aid=40014221&item_source=1&media_source=1&click_id=__CLICKID__&request_id=__REQUESTID__&mid1=__MID1__&mid2=__MID2__&mid3=__MID3__&mid4=__MID4__&mid5=__MID5__',
+2024-12-05 12:27:51:     dy_small_program_safety: '',
+2024-12-05 12:27:51:     dy_small_applet_app_id: 'tt46893034d9b8232301',
+2024-12-05 12:27:51:     check_url: '',
+2024-12-05 12:27:51:     status: 0,
+2024-12-05 12:27:51:     main_id: 3,
+2024-12-05 12:27:51:     promotion_id: '1817572975687755',
+2024-12-05 12:27:51:     wait_status: 1,
+2024-12-05 12:27:51:     error_info: null
+2024-12-05 12:27:51:   }
+2024-12-05 12:27:51: ]
+2024-12-05 12:27:51: update_video_applet_product:更新成功！
+2024-12-05 12:27:53: sql: [
+2024-12-05 12:27:53:   {
+2024-12-05 12:27:53:     id: 151,
+2024-12-05 12:27:53:     product_name: '嘲笑我外婆当体模，分手后他悔断肠',
+2024-12-05 12:27:53:     product_id: '7435933042796923955',
+2024-12-05 12:27:53:     create_at: 2024-12-05T04:25:49.000Z,
+2024-12-05 12:27:53:     book_platform: 2,
+2024-12-05 12:27:53:     industry: 1,
+2024-12-05 12:27:53:     dy_small_program_start: 'pages/bookstore/index',
+2024-12-05 12:27:53:     dy_small_program_start_data: 'key=PHW9XI9PW95&aid=40014221&item_source=1&media_source=1&click_id=__CLICKID__&request_id=__REQUESTID__&mid1=__MID1__&mid2=__MID2__&mid3=__MID3__&mid4=__MID4__&mid5=__MID5__',
+2024-12-05 12:27:53:     dy_small_program_safety: '',
+2024-12-05 12:27:53:     dy_small_applet_app_id: 'tt46893034d9b8232301',
+2024-12-05 12:27:53:     check_url: '',
+2024-12-05 12:27:53:     status: 0,
+2024-12-05 12:27:53:     main_id: 3,
+2024-12-05 12:27:53:     promotion_id: '1817572996411529',
+2024-12-05 12:27:53:     wait_status: 1,
+2024-12-05 12:27:53:     error_info: null
+2024-12-05 12:27:53:   }
+2024-12-05 12:27:53: ]
+2024-12-05 12:27:53: update_video_applet_product:更新成功！
+2024-12-05 12:27:55: sql: [
+2024-12-05 12:27:55:   {
+2024-12-05 12:27:55:     id: 152,
+2024-12-05 12:27:55:     product_name: '嘲笑我外婆当体模，分手后他悔断肠',
+2024-12-05 12:27:55:     product_id: '7435933042796923955',
+2024-12-05 12:27:55:     create_at: 2024-12-05T04:25:49.000Z,
+2024-12-05 12:27:55:     book_platform: 2,
+2024-12-05 12:27:55:     industry: 1,
+2024-12-05 12:27:55:     dy_small_program_start: 'pages/bookstore/index',
+2024-12-05 12:27:55:     dy_small_program_start_data: 'key=PHW9XIIGD43&aid=40014221&item_source=1&media_source=1&click_id=__CLICKID__&request_id=__REQUESTID__&mid1=__MID1__&mid2=__MID2__&mid3=__MID3__&mid4=__MID4__&mid5=__MID5__',
+2024-12-05 12:27:55:     dy_small_program_safety: '',
+2024-12-05 12:27:55:     dy_small_applet_app_id: 'tt46893034d9b8232301',
+2024-12-05 12:27:55:     check_url: '',
+2024-12-05 12:27:55:     status: 0,
+2024-12-05 12:27:55:     main_id: 9,
+2024-12-05 12:27:55:     promotion_id: '1817573011083363',
+2024-12-05 12:27:55:     wait_status: 1,
+2024-12-05 12:27:55:     error_info: null
+2024-12-05 12:27:55:   }
+2024-12-05 12:27:55: ]
+2024-12-05 12:27:55: update_video_applet_product:更新成功！
+2024-12-05 12:27:57: sql: [
+2024-12-05 12:27:57:   {
+2024-12-05 12:27:57:     id: 149,
+2024-12-05 12:27:57:     product_name: '妹妹出生后，阎王亲自订婚约',
+2024-12-05 12:27:57:     product_id: '7435933042805312522',
+2024-12-05 12:27:57:     create_at: 2024-12-05T04:25:47.000Z,
+2024-12-05 12:27:57:     book_platform: 2,
+2024-12-05 12:27:57:     industry: 1,
+2024-12-05 12:27:57:     dy_small_program_start: 'pages/bookstore/index',
+2024-12-05 12:27:57:     dy_small_program_start_data: 'key=PHW9XIJ6SDW&aid=40014221&item_source=1&media_source=1&click_id=__CLICKID__&request_id=__REQUESTID__&mid1=__MID1__&mid2=__MID2__&mid3=__MID3__&mid4=__MID4__&mid5=__MID5__',
+2024-12-05 12:27:57:     dy_small_program_safety: '',
+2024-12-05 12:27:57:     dy_small_applet_app_id: 'tt46893034d9b8232301',
+2024-12-05 12:27:57:     check_url: '',
+2024-12-05 12:27:57:     status: 0,
+2024-12-05 12:27:57:     main_id: 3,
+2024-12-05 12:27:57:     promotion_id: '1817573012316212',
+2024-12-05 12:27:57:     wait_status: 1,
+2024-12-05 12:27:57:     error_info: null
+2024-12-05 12:27:57:   }
+2024-12-05 12:27:57: ]
+2024-12-05 12:27:57: update_video_applet_product:更新成功！
+2024-12-05 12:27:59: sql: [
+2024-12-05 12:27:59:   {
+2024-12-05 12:27:59:     id: 150,
+2024-12-05 12:27:59:     product_name: '妹妹出生后，阎王亲自订婚约',
+2024-12-05 12:27:59:     product_id: '7435933042805312522',
+2024-12-05 12:27:59:     create_at: 2024-12-05T04:25:47.000Z,
+2024-12-05 12:27:59:     book_platform: 2,
+2024-12-05 12:27:59:     industry: 1,
+2024-12-05 12:27:59:     dy_small_program_start: 'pages/bookstore/index',
+2024-12-05 12:27:59:     dy_small_program_start_data: 'key=PHW9XHXDOZV&aid=40014221&item_source=1&media_source=1&click_id=__CLICKID__&request_id=__REQUESTID__&mid1=__MID1__&mid2=__MID2__&mid3=__MID3__&mid4=__MID4__&mid5=__MID5__',
+2024-12-05 12:27:59:     dy_small_program_safety: '',
+2024-12-05 12:27:59:     dy_small_applet_app_id: 'tt46893034d9b8232301',
+2024-12-05 12:27:59:     check_url: '',
+2024-12-05 12:27:59:     status: 0,
+2024-12-05 12:27:59:     main_id: 9,
+2024-12-05 12:27:59:     promotion_id: '1817572975686859',
+2024-12-05 12:27:59:     wait_status: 1,
+2024-12-05 12:27:59:     error_info: null
+2024-12-05 12:27:59:   }
+2024-12-05 12:27:59: ]
+2024-12-05 12:27:59: update_video_applet_product:更新成功！
+2024-12-05 12:28:01: sql: []
+2024-12-05 12:28:03: sql: []
+2024-12-05 12:28:05: sql: []
+2024-12-05 12:28:07: sql: []
+2024-12-05 12:28:09: sql: []
+2024-12-05 12:28:11: sql: []
+2024-12-05 12:28:13: sql: []
+2024-12-05 12:28:15: sql: []
+2024-12-05 14:27:22: send_data_server：sql_task_help
+2024-12-05 14:27:22: Connected to the MySQL server.
+>>>>>>> 806549b58fb6234e7a0f41405e1177d1d2a613a3

7_CHECK_AND_CREATE_URL_FACTORY/nohup.out

@@ -41,6 +41,7 @@
 └────┴───────────────────────────────────┴─────────────┴─────────┴─────────┴──────────┴────────┴──────┴───────────┴──────────┴──────────┴──────────┴──────────┘
 [PM2][WARN] Current process list is not synchronized with saved list. App start_novel differs. Type 'pm2 save' to synchronize.
 [PM2] cron restart at 1 0 * * *
+<<<<<<< HEAD
 [PM2][WARN] Applications 7_CHECK_AND_CREATE_URL_FACTORY not running, starting...
 [PM2][WARN] Folder does not exist: /var/log/node-app
 [PM2] Creating folder: /var/log/node-app
@@ -73,3 +74,28 @@
 │ 2  │ tg_factory                        │ default     │ N/A     │ fork    │ 0        │ 0      │ 44   │ stopped   │ 0%       │ 0b       │ root     │ disabled │
 └────┴───────────────────────────────────┴─────────────┴─────────┴─────────┴──────────┴────────┴──────┴───────────┴──────────┴──────────┴──────────┴──────────┘
 [PM2][WARN] Current process list is not synchronized with saved list. App start_data differs. Type 'pm2 save' to synchronize.
+=======
+[PM2] Applying action restartProcessId on app [7_CHECK_AND_CREATE_URL_FACTORY](ids: [ 20 ])
+[PM2] [7_CHECK_AND_CREATE_URL_FACTORY](20) ✓
+┌────┬───────────────────────────────────┬─────────────┬─────────┬─────────┬──────────┬────────┬──────┬───────────┬──────────┬──────────┬──────────┬──────────┐
+│ id │ name                              │ namespace   │ version │ mode    │ pid      │ uptime │ ↺    │ status    │ cpu      │ mem      │ user     │ watching │
+├────┼───────────────────────────────────┼─────────────┼─────────┼─────────┼──────────┼────────┼──────┼───────────┼──────────┼──────────┼──────────┼──────────┤
+│ 20 │ 7_CHECK_AND_CREATE_URL_FACTORY    │ default     │ N/A     │ fork    │ 4110     │ 0s     │ 5    │ online    │ 0%       │ 5.8mb    │ root     │ disabled │
+│ 21 │ MESSAGE_DISPATCH                  │ default     │ N/A     │ fork    │ 25114    │ 12h    │ 10   │ online    │ 0%       │ 49.4mb   │ root     │ disabled │
+│ 23 │ start                             │ default     │ 1.0.0   │ fork    │ 17580    │ 26h    │ 0    │ online    │ 0%       │ 32.4mb   │ root     │ disabled │
+│ 22 │ tg_factory                        │ default     │ N/A     │ fork    │ 3859     │ 2m     │ 592  │ online    │ 0%       │ 31.8mb   │ root     │ disabled │
+└────┴───────────────────────────────────┴─────────────┴─────────┴─────────┴──────────┴────────┴──────┴───────────┴──────────┴──────────┴──────────┴──────────┘
+[PM2][WARN] Current process list is not synchronized with saved list. App start_novel differs. Type 'pm2 save' to synchronize.
+[PM2] cron restart at 1 0 * * *
+[PM2] Applying action restartProcessId on app [7_CHECK_AND_CREATE_URL_FACTORY](ids: [ 20 ])
+[PM2] [7_CHECK_AND_CREATE_URL_FACTORY](20) ✓
+┌────┬───────────────────────────────────┬─────────────┬─────────┬─────────┬──────────┬────────┬──────┬───────────┬──────────┬──────────┬──────────┬──────────┐
+│ id │ name                              │ namespace   │ version │ mode    │ pid      │ uptime │ ↺    │ status    │ cpu      │ mem      │ user     │ watching │
+├────┼───────────────────────────────────┼─────────────┼─────────┼─────────┼──────────┼────────┼──────┼───────────┼──────────┼──────────┼──────────┼──────────┤
+│ 20 │ 7_CHECK_AND_CREATE_URL_FACTORY    │ default     │ N/A     │ fork    │ 5804     │ 0s     │ 5    │ online    │ 0%       │ 16.0mb   │ root     │ disabled │
+│ 21 │ MESSAGE_DISPATCH                  │ default     │ N/A     │ fork    │ 25114    │ 14h    │ 10   │ online    │ 0%       │ 55.0mb   │ root     │ disabled │
+│ 23 │ start                             │ default     │ 1.0.0   │ fork    │ 17580    │ 28h    │ 0    │ online    │ 0%       │ 33.0mb   │ root     │ disabled │
+│ 22 │ tg_factory                        │ default     │ N/A     │ fork    │ 0        │ 0      │ 592  │ stopped   │ 0%       │ 0b       │ root     │ disabled │
+└────┴───────────────────────────────────┴─────────────┴─────────┴─────────┴──────────┴────────┴──────┴───────────┴──────────┴──────────┴──────────┴──────────┘
+[PM2][WARN] Current process list is not synchronized with saved list. App start_novel differs. Type 'pm2 save' to synchronize.
+>>>>>>> 806549b58fb6234e7a0f41405e1177d1d2a613a3

MESSAGE_DISPATCH/log/node-app.stdout.log

@@ -1,3 +1,4 @@
+<<<<<<< HEAD
 2024-12-04 16:10:04: Received: pong
 2024-12-04 16:10:34: Received: pong
 2024-12-04 16:11:01: 登录成功
@@ -547,3 +548,311 @@
 2024-12-04 18:47:43: Received: pong
 2024-12-04 18:48:13: Received: pong
 >>>>>>> dbe134510ceb02a98e645caa107bbad2dd5471d1
+=======
+2024-12-05 12:06:08: Received: pong
+2024-12-05 12:06:38: Received: pong
+2024-12-05 12:07:08: Received: pong
+2024-12-05 12:07:38: Received: pong
+2024-12-05 12:08:08: Received: pong
+2024-12-05 12:08:38: Received: pong
+2024-12-05 12:09:08: Received: pong
+2024-12-05 12:09:38: Received: pong
+2024-12-05 12:10:08: Received: pong
+2024-12-05 12:10:38: Received: pong
+2024-12-05 12:11:08: Received: pong
+2024-12-05 12:11:38: Received: pong
+2024-12-05 12:12:08: Received: pong
+2024-12-05 12:12:38: Received: pong
+2024-12-05 12:13:08: Received: pong
+2024-12-05 12:13:38: Received: pong
+2024-12-05 12:14:08: Received: pong
+2024-12-05 12:14:38: Received: pong
+2024-12-05 12:15:08: Received: pong
+2024-12-05 12:15:38: Received: pong
+2024-12-05 12:16:08: Received: pong
+2024-12-05 12:16:38: Received: pong
+2024-12-05 12:17:08: Received: pong
+2024-12-05 12:17:38: Received: pong
+2024-12-05 12:18:08: Received: pong
+2024-12-05 12:18:38: Received: pong
+2024-12-05 12:19:08: Received: pong
+2024-12-05 12:19:38: Received: pong
+2024-12-05 12:20:08: Received: pong
+2024-12-05 12:20:38: Received: pong
+2024-12-05 12:21:08: Received: pong
+2024-12-05 12:21:38: Received: pong
+2024-12-05 12:22:08: Received: pong
+2024-12-05 12:22:38: Received: pong
+2024-12-05 12:23:08: Received: pong
+2024-12-05 12:23:38: Received: pong
+2024-12-05 12:24:08: Received: pong
+2024-12-05 12:24:38: Received: pong
+2024-12-05 12:25:08: Received: pong
+2024-12-05 12:25:38: Received: pong
+2024-12-05 12:26:08: Received: pong
+2024-12-05 12:26:38: Received: pong
+2024-12-05 12:27:08: Received: pong
+2024-12-05 12:27:38: Received: pong
+2024-12-05 12:28:08: Received: pong
+2024-12-05 12:28:38: Received: pong
+2024-12-05 12:29:08: Received: pong
+2024-12-05 12:29:38: Received: pong
+2024-12-05 12:30:08: Received: pong
+2024-12-05 12:30:38: Received: pong
+2024-12-05 12:31:08: Received: pong
+2024-12-05 12:31:38: Received: pong
+2024-12-05 12:32:08: Received: pong
+2024-12-05 12:32:38: Received: pong
+2024-12-05 12:33:08: Received: pong
+2024-12-05 12:33:38: Received: pong
+2024-12-05 12:34:08: Received: pong
+2024-12-05 12:34:38: Received: pong
+2024-12-05 12:35:08: Received: pong
+2024-12-05 12:35:38: Received: pong
+2024-12-05 12:36:08: Received: pong
+2024-12-05 12:36:38: Received: pong
+2024-12-05 12:37:08: Received: pong
+2024-12-05 12:37:38: Received: pong
+2024-12-05 12:38:08: Received: pong
+2024-12-05 12:38:38: Received: pong
+2024-12-05 12:39:08: Received: pong
+2024-12-05 12:39:38: Received: pong
+2024-12-05 12:40:08: Received: pong
+2024-12-05 12:40:38: Received: pong
+2024-12-05 12:41:08: Received: pong
+2024-12-05 12:41:38: Received: pong
+2024-12-05 12:42:08: Received: pong
+2024-12-05 12:42:38: Received: pong
+2024-12-05 12:43:08: Received: pong
+2024-12-05 12:43:38: Received: pong
+2024-12-05 12:44:08: Received: pong
+2024-12-05 12:44:38: Received: pong
+2024-12-05 12:45:08: Received: pong
+2024-12-05 12:45:38: Received: pong
+2024-12-05 12:46:08: Received: pong
+2024-12-05 12:46:38: Received: pong
+2024-12-05 12:47:08: Received: pong
+2024-12-05 12:47:38: Received: pong
+2024-12-05 12:48:08: Received: pong
+2024-12-05 12:48:38: Received: pong
+2024-12-05 12:49:08: Received: pong
+2024-12-05 12:49:38: Received: pong
+2024-12-05 12:50:08: Received: pong
+2024-12-05 12:50:38: Received: pong
+2024-12-05 12:51:08: Received: pong
+2024-12-05 12:51:38: Received: pong
+2024-12-05 12:52:08: Received: pong
+2024-12-05 12:52:38: Received: pong
+2024-12-05 12:53:08: Received: pong
+2024-12-05 12:53:38: Received: pong
+2024-12-05 12:54:08: Received: pong
+2024-12-05 12:54:38: Received: pong
+2024-12-05 12:55:08: Received: pong
+2024-12-05 12:55:38: Received: pong
+2024-12-05 12:56:08: Received: pong
+2024-12-05 12:56:38: Received: pong
+2024-12-05 12:57:08: Received: pong
+2024-12-05 12:57:38: Received: pong
+2024-12-05 12:58:08: Received: pong
+2024-12-05 12:58:38: Received: pong
+2024-12-05 12:59:08: Received: pong
+2024-12-05 12:59:38: Received: pong
+2024-12-05 13:00:08: Received: pong
+2024-12-05 13:00:38: Received: pong
+2024-12-05 13:01:08: Received: pong
+2024-12-05 13:01:38: Received: pong
+2024-12-05 13:02:08: Received: pong
+2024-12-05 13:02:38: Received: pong
+2024-12-05 13:03:08: Received: pong
+2024-12-05 13:03:39: Received: pong
+2024-12-05 13:04:08: Received: pong
+2024-12-05 13:04:38: Received: pong
+2024-12-05 13:05:08: Received: pong
+2024-12-05 13:05:38: Received: pong
+2024-12-05 13:06:08: Received: pong
+2024-12-05 13:06:38: Received: pong
+2024-12-05 13:07:08: Received: pong
+2024-12-05 13:07:38: Received: pong
+2024-12-05 13:08:08: Received: pong
+2024-12-05 13:08:38: Received: pong
+2024-12-05 13:09:08: Received: pong
+2024-12-05 13:09:38: Received: pong
+2024-12-05 13:10:08: Received: pong
+2024-12-05 13:10:38: Received: pong
+2024-12-05 13:11:08: Received: pong
+2024-12-05 13:11:38: Received: pong
+2024-12-05 13:12:08: Received: pong
+2024-12-05 13:12:38: Received: pong
+2024-12-05 13:13:08: Received: pong
+2024-12-05 13:13:38: Received: pong
+2024-12-05 13:14:08: Received: pong
+2024-12-05 13:14:38: Received: pong
+2024-12-05 13:15:08: Received: pong
+2024-12-05 13:15:38: Received: pong
+2024-12-05 13:16:08: Received: pong
+2024-12-05 13:16:38: Received: pong
+2024-12-05 13:17:08: Received: pong
+2024-12-05 13:17:39: Received: pong
+2024-12-05 13:18:09: Received: pong
+2024-12-05 13:18:39: Received: pong
+2024-12-05 13:19:09: Received: pong
+2024-12-05 13:19:39: Received: pong
+2024-12-05 13:20:09: Received: pong
+2024-12-05 13:20:39: Received: pong
+2024-12-05 13:21:09: Received: pong
+2024-12-05 13:21:39: Received: pong
+2024-12-05 13:22:09: Received: pong
+2024-12-05 13:22:39: Received: pong
+2024-12-05 13:23:09: Received: pong
+2024-12-05 13:23:39: Received: pong
+2024-12-05 13:24:09: Received: pong
+2024-12-05 13:24:39: Received: pong
+2024-12-05 13:25:09: Received: pong
+2024-12-05 13:25:39: Received: pong
+2024-12-05 13:26:09: Received: pong
+2024-12-05 13:26:39: Received: pong
+2024-12-05 13:27:09: Received: pong
+2024-12-05 13:27:39: Received: pong
+2024-12-05 13:28:09: Received: pong
+2024-12-05 13:28:39: Received: pong
+2024-12-05 13:29:09: Received: pong
+2024-12-05 13:29:39: Received: pong
+2024-12-05 13:30:09: Received: pong
+2024-12-05 13:30:39: Received: pong
+2024-12-05 13:31:09: Received: pong
+2024-12-05 13:31:39: Received: pong
+2024-12-05 13:32:09: Received: pong
+2024-12-05 13:32:39: Received: pong
+2024-12-05 13:33:09: Received: pong
+2024-12-05 13:33:39: Received: pong
+2024-12-05 13:34:09: Received: pong
+2024-12-05 13:34:39: Received: pong
+2024-12-05 13:35:09: Received: pong
+2024-12-05 13:35:39: Received: pong
+2024-12-05 13:36:09: Received: pong
+2024-12-05 13:36:39: Received: pong
+2024-12-05 13:37:09: Received: pong
+2024-12-05 13:37:39: Received: pong
+2024-12-05 13:38:09: Received: pong
+2024-12-05 13:38:39: Received: pong
+2024-12-05 13:39:09: Received: pong
+2024-12-05 13:39:39: Received: pong
+2024-12-05 13:40:09: Received: pong
+2024-12-05 13:40:39: Received: pong
+2024-12-05 13:41:09: Received: pong
+2024-12-05 13:41:39: Received: pong
+2024-12-05 13:42:09: Received: pong
+2024-12-05 13:42:39: Received: pong
+2024-12-05 13:43:09: Received: pong
+2024-12-05 13:43:39: Received: pong
+2024-12-05 13:44:09: Received: pong
+2024-12-05 13:44:39: Received: pong
+2024-12-05 13:45:09: Received: pong
+2024-12-05 13:45:39: Received: pong
+2024-12-05 13:46:09: Received: pong
+2024-12-05 13:46:39: Received: pong
+2024-12-05 13:47:09: Received: pong
+2024-12-05 13:47:39: Received: pong
+2024-12-05 13:48:09: Received: pong
+2024-12-05 13:48:39: Received: pong
+2024-12-05 13:49:09: Received: pong
+2024-12-05 13:49:39: Received: pong
+2024-12-05 13:50:09: Received: pong
+2024-12-05 13:50:39: Received: pong
+2024-12-05 13:51:09: Received: pong
+2024-12-05 13:51:39: Received: pong
+2024-12-05 13:52:09: Received: pong
+2024-12-05 13:52:39: Received: pong
+2024-12-05 13:53:09: Received: pong
+2024-12-05 13:53:39: Received: pong
+2024-12-05 13:54:09: Received: pong
+2024-12-05 13:54:39: Received: pong
+2024-12-05 13:55:09: Received: pong
+2024-12-05 13:55:39: Received: pong
+2024-12-05 13:56:09: Received: pong
+2024-12-05 13:56:39: Received: pong
+2024-12-05 13:57:09: Received: pong
+2024-12-05 13:57:39: Received: pong
+2024-12-05 13:58:09: Received: pong
+2024-12-05 13:58:39: Received: pong
+2024-12-05 13:59:09: Received: pong
+2024-12-05 13:59:39: Received: pong
+2024-12-05 14:00:09: Received: pong
+2024-12-05 14:00:39: Received: pong
+2024-12-05 14:01:09: Received: pong
+2024-12-05 14:01:39: Received: pong
+2024-12-05 14:02:09: Received: pong
+2024-12-05 14:02:39: Received: pong
+2024-12-05 14:03:09: Received: pong
+2024-12-05 14:03:39: Received: pong
+2024-12-05 14:04:09: Received: pong
+2024-12-05 14:04:39: Received: pong
+2024-12-05 14:05:09: Received: pong
+2024-12-05 14:05:39: Received: pong
+2024-12-05 14:06:09: Received: pong
+2024-12-05 14:06:39: Received: pong
+2024-12-05 14:07:09: Received: pong
+2024-12-05 14:07:39: Received: pong
+2024-12-05 14:08:09: Received: pong
+2024-12-05 14:08:39: Received: pong
+2024-12-05 14:09:09: Received: pong
+2024-12-05 14:09:39: Received: pong
+2024-12-05 14:10:09: Received: pong
+2024-12-05 14:10:39: Received: pong
+2024-12-05 14:11:09: Received: pong
+2024-12-05 14:11:39: Received: pong
+2024-12-05 14:12:09: Received: pong
+2024-12-05 14:12:39: Received: pong
+2024-12-05 14:13:09: Received: pong
+2024-12-05 14:13:39: Received: pong
+2024-12-05 14:14:09: Received: pong
+2024-12-05 14:14:39: Received: pong
+2024-12-05 14:15:09: Received: pong
+2024-12-05 14:15:39: Received: pong
+2024-12-05 14:16:09: Received: pong
+2024-12-05 14:16:39: Received: pong
+2024-12-05 14:17:09: Received: pong
+2024-12-05 14:17:39: Received: pong
+2024-12-05 14:18:09: Received: pong
+2024-12-05 14:18:39: Received: pong
+2024-12-05 14:19:09: Received: pong
+2024-12-05 14:19:39: Received: pong
+2024-12-05 14:20:09: Received: pong
+2024-12-05 14:20:39: Received: pong
+2024-12-05 14:21:09: Received: pong
+2024-12-05 14:21:39: Received: pong
+2024-12-05 14:22:09: Received: pong
+2024-12-05 14:22:39: Received: pong
+2024-12-05 14:23:09: Received: pong
+2024-12-05 14:23:39: Received: pong
+2024-12-05 14:24:09: Received: pong
+2024-12-05 14:24:39: Received: pong
+2024-12-05 14:25:09: Received: pong
+2024-12-05 14:25:39: Received: pong
+2024-12-05 14:26:09: Received: pong
+2024-12-05 14:26:39: Received: pong
+2024-12-05 14:27:09: Received: pong
+2024-12-05 14:27:39: Received: pong
+2024-12-05 14:28:09: Received: pong
+2024-12-05 14:28:39: Received: pong
+2024-12-05 14:29:09: Received: pong
+2024-12-05 14:29:39: Received: pong
+2024-12-05 14:30:09: Received: pong
+2024-12-05 14:30:39: Received: pong
+2024-12-05 14:31:09: Received: pong
+2024-12-05 14:31:39: Received: pong
+2024-12-05 14:32:09: Received: pong
+2024-12-05 14:32:39: Received: pong
+2024-12-05 14:33:09: Received: pong
+2024-12-05 14:33:39: Received: pong
+2024-12-05 14:34:09: Received: pong
+2024-12-05 14:34:39: Received: pong
+2024-12-05 14:35:09: Received: pong
+2024-12-05 14:35:39: Received: pong
+2024-12-05 14:36:09: Received: pong
+2024-12-05 14:36:39: Received: pong
+2024-12-05 14:37:09: Received: pong
+2024-12-05 14:37:39: Received: pong
+2024-12-05 14:38:09: Received: pong
+2024-12-05 14:38:39: Received: pong
+>>>>>>> 806549b58fb6234e7a0f41405e1177d1d2a613a3

etc/config.json

@@ -1,5 +1,5 @@
 {
-    "isDebug":false,
+    "isDebug":true,
     "redis_config": {
         "host": "127.0.0.1",
         "port": 6379

install_log.sh

@@ -0,0 +1,7 @@
+/home/node/node-v20.17.0-linux-x64/lib/node_modules/pm2/bin/pm2  install pm2-logrotate
+/home/node/node-v20.17.0-linux-x64/lib/node_modules/pm2/bin/pm2 set pm2-logrotate:rotateInterval '0 0 * * *'
+/home/node/node-v20.17.0-linux-x64/lib/node_modules/pm2/bin/pm2 set pm2-logrotate:dateFormat 'YYYY-MM-DD'
+/home/node/node-v20.17.0-linux-x64/lib/node_modules/pm2/bin/pm2 set pm2-logrotate:max_size '10M'
+/home/node/node-v20.17.0-linux-x64/lib/node_modules/pm2/bin/pm2 set pm2-logrotate:retain '30'
+/home/node/node-v20.17.0-linux-x64/lib/node_modules/pm2/bin/pm2 set pm2-logrotate:compress true
+/home/node/node-v20.17.0-linux-x64/lib/node_modules/pm2/bin/pm2 set pm2-logrotate:workerInterval '30'

logs/error.log

@@ -1,4 +1,5 @@
 <<<<<<< HEAD
+<<<<<<< HEAD
 2024-12-04T17:47:10: node:internal/process/promises:389
 2024-12-04T17:47:10:       new UnhandledPromiseRejection(reason);
 2024-12-04T17:47:10:       ^
@@ -3759,3 +3760,5 @@
 2024-12-04T18:41:20: 
 2024-12-04T18:41:20: Node.js v20.17.0
 >>>>>>> dbe134510ceb02a98e645caa107bbad2dd5471d1
+=======
+>>>>>>> 806549b58fb6234e7a0f41405e1177d1d2a613a3

logs/out.log

@@ -1,3 +1,4 @@
+<<<<<<< HEAD
 2024-12-04T16:12:58: 
 2024-12-04T16:12:58: > heiyan@1.0.0 start
 2024-12-04T16:12:58: > node tg_factory_main.js
@@ -10166,3 +10167,5 @@
 2024-12-04T18:47:50: jump!!!
 2024-12-04T18:47:52: jump!!!
 >>>>>>> dbe134510ceb02a98e645caa107bbad2dd5471d1
+=======
+>>>>>>> 806549b58fb6234e7a0f41405e1177d1d2a613a3

nohup.out

@@ -112,9 +112,23 @@
 │ 22 │ tg_factory                        │ default     │ N/A     │ fork    │ 0        │ 0      │ 104  │ stopped   │ 0%       │ 0b       │ root     │ disabled │
 └────┴───────────────────────────────────┴─────────────┴─────────┴─────────┴──────────┴────────┴──────┴───────────┴──────────┴──────────┴──────────┴──────────┘
 [PM2][WARN] Current process list is not synchronized with saved list. App start start_novel differs. Type 'pm2 save' to synchronize.
+<<<<<<< HEAD
 [PM2] Applying action deleteProcessId on app [0](ids: [ '0' ])
 [PM2] [start_data](0) ✓
 ┌────┬───────────┬─────────────┬─────────┬─────────┬──────────┬────────┬──────┬───────────┬──────────┬──────────┬──────────┬──────────┐
 │ id │ name      │ namespace   │ version │ mode    │ pid      │ uptime │ ↺    │ status    │ cpu      │ mem      │ user     │ watching │
 └────┴───────────┴─────────────┴─────────┴─────────┴──────────┴────────┴──────┴───────────┴──────────┴──────────┴──────────┴──────────┘
 [PM2][WARN] Current process list is not synchronized with saved list. App start_data differs. Type 'pm2 save' to synchronize.
+=======
+[PM2] Applying action deleteProcessId on app [25](ids: [ '25' ])
+[PM2] [pm2-logrotate](25) ✓
+┌────┬───────────────────────────────────┬─────────────┬─────────┬─────────┬──────────┬────────┬──────┬───────────┬──────────┬──────────┬──────────┬──────────┐
+│ id │ name                              │ namespace   │ version │ mode    │ pid      │ uptime │ ↺    │ status    │ cpu      │ mem      │ user     │ watching │
+├────┼───────────────────────────────────┼─────────────┼─────────┼─────────┼──────────┼────────┼──────┼───────────┼──────────┼──────────┼──────────┼──────────┤
+│ 20 │ 7_CHECK_AND_CREATE_URL_FACTORY    │ default     │ N/A     │ fork    │ 0        │ 0      │ 5    │ stopped   │ 0%       │ 0b       │ root     │ disabled │
+│ 21 │ MESSAGE_DISPATCH                  │ default     │ N/A     │ fork    │ 25114    │ 14h    │ 10   │ online    │ 8.3%     │ 55.1mb   │ root     │ disabled │
+│ 23 │ start                             │ default     │ 1.0.0   │ fork    │ 17580    │ 28h    │ 0    │ online    │ 0%       │ 32.8mb   │ root     │ disabled │
+│ 22 │ tg_factory                        │ default     │ N/A     │ fork    │ 0        │ 0      │ 592  │ stopped   │ 0%       │ 0b       │ root     │ disabled │
+└────┴───────────────────────────────────┴─────────────┴─────────┴─────────┴──────────┴────────┴──────┴───────────┴──────────┴──────────┴──────────┴──────────┘
+[PM2][WARN] Current process list is not synchronized with saved list. App start_novel differs. Type 'pm2 save' to synchronize.
+>>>>>>> 806549b58fb6234e7a0f41405e1177d1d2a613a3

tg_factory_main.js

@@ -1,7 +1,6 @@
 setInterval(() => {
-    console.log("jump!!!")
-}, 2000);
 
+}, 15000);
 const helper = require('./src/helper');
 const HttpClient = require('./src/HttpClient');
 const redis_help = require('./src/use_redis');
@@ -10,7 +9,6 @@ redis_help.connect( async (results)=>{
         main()
         console.log("results:",await redis_help.getKeyValue("isPauseTask"))
     }
-
 })
 
 // let test = new HttpClient()