接口数据只读redis

Modules/OpcData/Http/Controllers/Api/OPCDataTurboController.php

@@ -17,10 +17,28 @@ class OPCDataTurboController extends BaseController
             return $this->error(-1, '参数错误');
         }
 
+        $redis_key = $sys_key.'_'.$sys_name;
+
+        $redis = Redis::connection('default'); //指定连接user配置节点信息
+
+        $data = $redis->get($redis_key);
+        if (isset($data)) {
+            return $data;
+        } else {
+            return $this->error(-1, "接口数据获取错误");
+        }
+
+
+        return $data;
+
+//        $json_data = $this->get_redis_data($redis_key);
+
         $db_conf = config('database');
         $api_key = 'get';
         $api_url = 'http://'.$db_conf['python_api'][$sys_key]['url'].'/'.$api_key.'/?sys_key='.$sys_key.'&sys_name='.$sys_name;
 
+
+
         $response = $this->request_post($api_url);
 
         if (gettype($response) == 'integer') {
@@ -57,6 +75,7 @@ class OPCDataTurboController extends BaseController
         }
         $postUrl = $url;
         $curlPost = $param;
+
         $curl = curl_init();//初始化curl
         curl_setopt($curl, CURLOPT_URL,$postUrl);//抓取指定网页
         curl_setopt($curl, CURLOPT_HEADER, 0);//设置header
@@ -69,6 +88,7 @@ class OPCDataTurboController extends BaseController
         $data = curl_exec($curl);//运行curl
         $errno = curl_errno($curl);
         curl_close($curl);
+
         if ($errno > 0) return $errno;
 
         return $data;
@@ -85,8 +105,8 @@ class OPCDataTurboController extends BaseController
                 $data_value = $v['val'];
                 $data_key = $v['key'];
                 if ($data_value) {
-                    $userData = $redis->get($data_key);
-                    $data['sys_point'][$key][$k]['val'] = round($userData, 2);
+//                    $userData = $redis->get($data_key);
+                    $data['sys_point'][$key][$k]['val'] = round($data_value, 2);
                     # 数据持久化
                 }
             }
@@ -94,6 +114,17 @@ class OPCDataTurboController extends BaseController
         return $data;
     }
 
+    private  function get_redis_data($key) {
+
+        $redis = Redis::connection('default'); //指定连接user配置节点信息
+        $data = $redis->get($key);
+        if (isset($data)) {
+            return $data;
+        } else {
+            return $this->error(-1, "接口数据获取错误");
+        }
+    }
+
 
     /**
      * Display a listing of the resource.