|
@@ -0,0 +1,35 @@
|
|
|
+<?php
|
|
|
+
|
|
|
+namespace Modules\OpcData\Http\Controllers\Api;
|
|
|
+
|
|
|
+use App\Http\Controllers\Api\BaseController;
|
|
|
+use Illuminate\Support\Facades\Redis;
|
|
|
+use Illuminate\Http\Request;
|
|
|
+
|
|
|
+class OpcDataRedisController extends BaseController
|
|
|
+{
|
|
|
+ public function getData(Request $request) {
|
|
|
+ $sys_key = $request->sys_key ?? $request->mine_code;
|
|
|
+ $sys_name = $request->sys_name ?? $request->system_type;
|
|
|
+ if (!isset($sys_key) || !isset($sys_name)) {
|
|
|
+ $msg="参数错误";
|
|
|
+ $code=-1;
|
|
|
+ return $this->error($code, $msg);
|
|
|
+ }
|
|
|
+
|
|
|
+ $redis_key = $sys_key.'_'.$sys_name;
|
|
|
+ $data = $this->get_redis_data($redis_key);
|
|
|
+
|
|
|
+ return $data ?? $this->error(-1, "接口数据获取错误");
|
|
|
+ }
|
|
|
+ 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, "接口数据获取错误");
|
|
|
+ }
|
|
|
+ }
|
|
|
+}
|