123

filter_qimao_dianzhong/filter_qimao_dianzhong.js

@@ -8,7 +8,8 @@ async function processTask(){
         if(tsak_list.length>0){
             let FilterConfig = await redis_help.getKeyValue("FilterConfig")
             FilterConfig = JSON.parse(FilterConfig)
-            let d =  filter_and_insert(result.data,FilterConfig)
+            let data = tsak_list.shift()
+            let d =  filter_and_insert(data,FilterConfig)
             if(d==null){
             }else{
                 if(d.channel=="七猫"){
@@ -20,7 +21,7 @@ async function processTask(){
                 }
             }
             if(isNeedDelete){
-                origin_data_controllers.updateOriginData({id:result.data.id},{
+                origin_data_controllers.updateOriginData({id:data.id},{
                     status:3
                 })
             }
@@ -29,7 +30,7 @@ async function processTask(){
     }catch(e){
 
     }finally{
-        setTimeout(processTask,1000);
+        setTimeout(processTask,300);
     }
     // const result = await origin_data_controllers.getOriginDataByStatus({status:1})
     // if(result.success){
@@ -58,7 +59,7 @@ let main = async function(){
     const result = await origin_data_controllers.findByDateRange({status:1},'create_time','2024-12-10 00:00:00','2024-12-11 00:00:00',500)
     if(result.success){
         tsak_list = result.data
-        console.log("tsak_list:",tsak_list)
+        // console.log("tsak_list:",tsak_list)
         setTimeout(processTask,1000);
     }