123

2_PRODUCT_FACTORY/fq_factory.js

@@ -89,9 +89,9 @@ async function processNewCreateTask(){
             multipleStatements: true
         });
 
-        // let create_day = helper.getLocalDate()
+        let create_day = helper.getLocalDate()
 
-        let sql = `SELECT * FROM filter_data WHERE tg_platform_id = ${config.platform_fanqie} AND status = 1 AND material_sync_status = 2  ORDER BY create_day DESC  LIMIT 1`
+        let sql = `SELECT * FROM filter_data WHERE tg_platform_id = ${config.platform_fanqie} AND status = 1 AND material_sync_status = 2  AND create_day = ${create_day}  LIMIT 1`
         
         const [row] = await connection.execute(sql)
 
@@ -175,7 +175,7 @@ async function processNewCreateTask(){
         if(connection!=null){
             connection.end()
         }
-        global.setTimeout(processNewCreateTask, time_count);
+        global.setTimeout(processNewCreateTask, 500);
     }
 }
 

2_PRODUCT_FACTORY/fq_mf_factory.js

@@ -86,9 +86,9 @@ async function processNewCreateTask(){
             multipleStatements: true
         });
 
-        // let create_day = helper.getLocalDate()
+        let create_day = helper.getLocalDate()
 
-        let sql = `SELECT * FROM filter_data WHERE tg_platform_id = ${config.platform_fanqiemf} AND status = 1 AND material_sync_status = 2  ORDER BY create_day DESC  LIMIT 1`
+        let sql = `SELECT * FROM filter_data WHERE tg_platform_id = ${config.platform_fanqiemf} AND status = 1 AND material_sync_status = 2  AND create_day = ${create_day}  LIMIT 1`
         
         const [row] = await connection.execute(sql)
 
@@ -173,7 +173,7 @@ async function processNewCreateTask(){
         if(connection!=null){
             connection.end()
         }
-        global.setTimeout(processNewCreateTask, time_count);
+        global.setTimeout(processNewCreateTask, 500);
     }
 }