修改

catch/api/controller/Api.php

@@ -299,6 +299,46 @@ class Api extends CatchController
   
 
     }
+    public function asset_redis(){
+        $redis=Cache::store('redis')->handler();
+        $hashKey='station_access_last_data';
+        $beforeKey='station_access_before_data';
+        $list=$redis->hgetall($hashKey);
+        foreach($list as $key=>$val){
+            $data = json_decode($v, true);
+            if ( (time() - $data["time"] ) > 10 ) {
+                $before_data=json_decode($redis->hGet($beforeKey,$key),true);
+                //存在反向数据 并且连续搜到单边数据5次
+                if($before_data){
+                                //开始推送数据;
+                    $send_data=[
+                        "mac"=>$val['mac'],
+                        "label"=>$val['label'],
+                        'time'=>$val['time'],
+                    ];
+
+                    if($val['ant']>$before_data['ant']){
+                        //1->2 内到外 出
+                        $send_data['dirt']=2;
+                    }else{
+                        //2>1  外到内 进
+                        $send_data['dirt']=1;
+                    }
+                    var_dump($send_data);
+                    //推送数据
+                    $url="http://localhost:8115/api/assetReport";
+                    $postFields = http_build_query($send_data);
+                    $url_res= curl_http_post($postFields,$url,false);
+                    echo 'assetReport res'.PHP_EOL;
+                    var_dump($url_res);
+                    //推送完清除数据
+                    $redis->hDel($hashKey,$key);
+                    $redis->hDel($beforeKey,$key);
+                            
+                }
+            }
+        }
+    }
     /**
      * 清除数据
      *

catch/api/route.php

@@ -30,6 +30,8 @@ $router->get('api/test', '\catchAdmin\api\controller\Api@test');
 //推送数据
 $router->get('api/redis', '\catchAdmin\api\controller\Api@redis_to_mysql');
 $router->get('api/redis2', '\catchAdmin\api\controller\Api@redis_to_mysql2');
+$router->get('api/assetRedis', '\catchAdmin\api\controller\Api@asset_redis');
+
 $router->get('api/clear_redis', '\catchAdmin\api\controller\Api@clear_redis');
 //远程推送数据
 $router->get('api/remote_push', '\catchAdmin\api\controller\Api@remotePush');