修改

.env

@@ -19,7 +19,7 @@ DEBUG = true
 [REDIS]
 HOST = 127.0.0.1
 PORT = 6379
-PASSWORD = 'R!478gH*%23nPn'
+PASSWORD = '123456'
 SELECT = 2
 
 [LANG]

catch/api/controller/Api.php

@@ -1252,7 +1252,35 @@ class Api extends CatchController
         json_success("查询版本成功",$data);
     }
     
+    //储存数据
+    public function livestockDataToMysql(){
 
+        $ues_redis=Cache::store('redis')->handler();
+        $dispose = new dispose($ues_redis); 
+        $text=null;
+       
+      
+        // while(1){
+            $jsonData= $ues_redis->rpop("mqtt_data_livestock");
+            // if(empty($jsonData)){
+            //     sleep(1);
+            //     continue;
+            // }
+            debug_log("LiveStockData",'数据redis'.$jsonData);
+           
+            $data=json_decode($jsonData,true);
+            $url="http://127.0.0.1/api/reportMessage";
+            var_dump($data);
+            $postFields = http_build_query($data);
+            $url_res= curl_http_post($postFields,$url,false);
+            var_dump($url_res);
+          
+          
+           
+        // }
+  
+
+    }
 
 
 

catch/api/route.php

@@ -47,3 +47,5 @@ $router->get('api/redis_indoor', '\catchAdmin\api\controller\Api@redis_to_mysql_
 $router->get('api/redis_parea', '\catchAdmin\api\controller\Api@redis_to_mysql_parea');
 
 $router->get('sql/lister', '\catchAdmin\api\controller\sqlLister@lister');
+
+$router->get('api/livestock', '\catchAdmin\api\controller\Api@livestockDataToMysql');