add inoutIntFilter

task_script/PAREA_INOUTRES_PUSH.php

@@ -273,19 +273,19 @@ while (true) {
         
         http($url, $url_data, [], 'POST');
 
-        if($url_data["data"][0]["dirt"] == 1){
-            $camData = [
-                "station" => $url_data["mac"],
-                "list" => [
-                    [
-                        "label" =>$url_data["data"][0]["label"],
-                        "time" => $url_data["data"][0]["time"]
-                    ]
-                ]
-            ];
-            $resp = http("http://localhost:8115/api/areaLabelReport", $camData, [], 'POST');
-            // rlog("CAM api RESP",$resp);
-        }
+        // if($url_data["data"][0]["dirt"] == 1){
+        //     $camData = [
+        //         "station" => $url_data["mac"],
+        //         "list" => [
+        //             [
+        //                 "label" =>$url_data["data"][0]["label"],
+        //                 "time" => $url_data["data"][0]["time"]
+        //             ]
+        //         ]
+        //     ];
+        //     $resp = http("http://localhost:8115/api/areaLabelReport", $camData, [], 'POST');
+        //     // rlog("CAM api RESP",$resp);
+        // }
 
         rlog("PUSH INFO","推送依赖数据", $data);
     }catch (\Exception $ex) {

task_script/PAREA_STATUS_UPDATE.php

@@ -214,12 +214,17 @@ function mqttToRedis($text){
 
 
 
+$rfidPushRecArr = [];
 while (true) {
     try {
         rlog('INFO', 'task start');
 
         $infos = app_redis()->hgetall("parea_rfidinfos");
         $offlineInt  = app_redis()->hget("anbang_four_wire", "anbang_4rssi_offint");
+        $inoutIntFilter = app_redis()->hget("anbang_four_wire", "anbang_4rssi_intFilter");
+        if(!$inoutIntFilter){
+            $inoutIntFilter = 300;
+        }
         if (!$offlineInt) {
             # code...
             $offlineInt = 30;
@@ -227,6 +232,36 @@ while (true) {
         foreach ($infos as $k => $v) {
             # code...
             $data = json_decode($v, true);
+            
+
+            if($data["status"] == 1){
+                if ( (time() - $data["pushTime"] ) > $inoutIntFilter ) {
+                    $camData = [
+                        "station" => $data["mac"],
+                        "list" => [
+                            [
+                                "label" =>$data["id"],
+                                "time" => $data["time"]
+                            ]
+                        ]
+                    ];
+                    
+                    if(!$rfidPushRecArr[$data["id"]]){
+                        $rfidPushRecArr[$data["id"]] = 1;
+                        $resp = http("http://localhost:8115/api/areaLabelReport", $camData, [], 'POST');
+                    }else{
+                        if($rfidPushRecArr[$data["id"]] == 1){
+                            $rfidPushRecArr[$data["id"]] == 2;
+                            $resp = http("http://localhost:8115/api/areaLabelReport", $camData, [], 'POST');
+                        }
+                    }
+
+                    $logrecData = ['anbang_4rssi_intFilter' => $inoutIntFilter, 'time' => $data["time"], 'os_time' => time(), 'push_count' => $rfidPushRecArr[$data["id"]]];
+                    rlog("CAM PUSH INFO","推送摄像关联接口", json_encode($logrecData) );
+                    
+                }
+            }
+
             if ( (time() - $data["time"] ) > $offlineInt ) {
                 # code...
                 if ($data["status"] == 1) {
@@ -247,7 +282,10 @@ while (true) {
                     http($url, $url_data, [], 'POST');
                     rlog("PUSH INFO","离线推送依赖数据", $v);
                 }
-                app_redis()->hdel('parea_rfidinfos',$k);;
+                app_redis()->hdel('parea_rfidinfos',$k);
+                if($rfidPushRecArr[$data["id"]]){
+                    unset($rfidPushRecArr[$data["id"]]);
+                }
             }
         }