数据直接请求接口

Modules/OpcData/Http/Controllers/Api/zaoquan/DcsFanEastController.php

@@ -1,276 +0,0 @@
-<?php
-
-namespace Modules\OpcData\Http\Controllers\Api\zaoquan;
-
-use App\Http\Controllers\Api\BaseController;
-use Illuminate\Contracts\Support\Renderable;
-use Illuminate\Routing\Controller;
-use Illuminate\Support\Facades\DB;
-use Illuminate\Http\Request;
-
-/**
- * 枣泉自动化——东井通风
- */
-class DcsFanEastController  extends BaseController
-{
-
-    private $list_key=[
-        '2008298770912257_2',
-        '2008298771235841_2',
-        '2008298771575809_2',
-        '2008298771760129_2',
-        '2008298770922497_2',
-        '2008298771252225_2',
-        '2008298771590145_2',
-        '2008298771774465_2',
-        '2008298771971073_1',
-        '2008298772339713_1',
-        '2008298772696065_1',
-        '2008298772747265_1',
-        '2008298770955265_2',
-        '2008298771299329_2',
-        '2008298771627009_2',
-        '2008298771809281_2',
-        '2008298771987457_1',
-        '2008298772354049_1',
-        '2008298772714497_1',
-        '2008298772763649_1',
-        '2008298772003841_1',
-        '2008298772370433_1',
-        '2008298772730881_1',
-        '2008298772780033_1',
-        '2008298772069377_1',
-        '2008298772388865_1',
-        '2008298772323329_1',
-        '2008298772677633_1',
-        '2008319841133569_2',
-        '2008319841389569_2',
-
-        '2008298772225025_1',
-        '2008298772464641_1',
-        '2008298772485121_1',
-        '2008298772503553_1',
-        '2008298772425729_1',
-        '2008298772444161_1',
-        '2008298772624385_1',
-        '2008298772642817_1',
-        '2008298772657153_1',
-        '2008298772589569_1',
-        '2008298772605953_1',
-    ];
-
-    public function getList(Request $request) {
-
-        $inCondition = "'" . implode("','", $this->list_key) . "'";
-        // 构建 SQL 查询
-        $sql_str = "select `point_id`, value from dcs_data_ventilation_east where `point_id` in ($inCondition)";
-
-        $res = $this->executeSql($sql_str);
-        $baseData=[];
-        for ($i = 0; $i < count($res); $i++) {
-            $key=$res[$i]->point_id;
-            $val=$res[$i]->value;
-            $baseData[$key]=$val;
-        }
-
-        $data['tab']=[
-            [
-                'title'=>"1#风机",
-                'state'=>$baseData['2008319841133569_2'],
-                'list'=>[
-                    [
-                        'label'=>'负压',
-                        "unit"=>"Pa",
-                        "num"=>$baseData['2008298772069377_1'],
-                    ],
-                    [
-                        "label"=>"风量",
-                        "unit"=>"m³/min",
-                        "num"=>$baseData['2008298772323329_1'],
-                    ],
-                ]
-            ],
-            [
-                'title'=>"2#风机",
-                'state'=>$baseData['2008319841389569_2'],
-                'list'=>[
-                    [
-                        'label'=>'负压',
-                        "unit"=>"Pa",
-                        "num"=>$baseData['2008298772388865_1'],
-                    ],
-                    [
-                        "label"=>"风量",
-                        "unit"=>"m³/min",
-                        "num"=>$baseData['2008298772677633_1'],
-                    ],
-                ]
-            ]
-        ];
-        $data['table_1']=[
-            "thead"=>[
-                "参数名称", "1-1", "1-2"
-            ],
-            "tbody"=>[
-                [
-                    "label"=>"电机电流（A)",
-                    "type"=>"val",
-                    "value_1"=>$baseData['2008298771987457_1'],
-                    "value_2"=>$baseData['2008298772354049_1'],
-                ],
-                [
-                    "label"=>"变频频率（HZ)",
-                    "type"=>"val",
-                    "value_1"=>$baseData['2008298772003841_1'],
-                    "value_2"=>$baseData['2008298772370433_1'],
-                ],
-                [
-                    "label"=>"设定频率（HZ)",
-                    "type"=>"val",
-                    "value_1"=>$baseData['2008298771971073_1'],
-                    "value_2"=>$baseData['2008298772339713_1'],
-                ],
-                [
-                    "label"=>"变频器状态",
-                    "type"=>"val",
-                    "value_1"=>$baseData['2008298770955265_2'],
-                    "value_2"=>$baseData['2008298771299329_2'],
-                ],
-                [
-                    "label"=>"变频器就绪",
-                    "type"=>"val",
-                    "value_1"=>$baseData['2008298770912257_2'],
-                    "value_2"=>$baseData['2008298771235841_2'],
-                ],
-                [
-                    "label"=>"变频器故障",
-                    "type"=>"val",
-                    "value_1"=>$baseData['2008298770922497_2'],
-                    "value_2"=>$baseData['2008298771252225_2'],
-                ],
-            ]
-        ];
-        $data['table_2']=[
-            "thead"=>[
-                "参数名称", "2-1", "2-2"
-            ],
-            "tbody"=>[
-                [
-                    "label"=>"电机电流（A)",
-                    "type"=>"val",
-                    "value_1"=>$baseData['2008298772714497_1'],
-                    "value_2"=>$baseData['2008298772763649_1'],
-                ],
-                [
-                    "label"=>"变频频率（HZ)",
-                    "type"=>"val",
-                    "value_1"=>$baseData['2008298772730881_1'],
-                    "value_2"=>$baseData['2008298772780033_1'],
-                ],
-                [
-                    "label"=>"设定频率（HZ)",
-                    "type"=>"val",
-                    "value_1"=>$baseData['2008298772696065_1'],
-                    "value_2"=>$baseData['2008298772747265_1'],
-                ],
-                [
-                    "label"=>"变频器状态",
-                    "type"=>"val",
-                    "value_1"=>$baseData['2008298771627009_2'],
-                    "value_2"=>$baseData['2008298771809281_2'],
-                ],
-                [
-                    "label"=>"变频器就绪",
-                    "type"=>"val",
-                    "value_1"=>$baseData['2008298771575809_2'],
-                    "value_2"=>$baseData['2008298771760129_2'],
-                ],
-                [
-                    "label"=>"变频器故障",
-                    "type"=>"val",
-                    "value_1"=>$baseData['2008298771590145_2'],
-                    "value_2"=>$baseData['2008298771774465_2'],
-                ],
-            ]
-        ];
-        $data['chartData']=[
-            'categories'=>["1-1#电机", "1-2#电机"],
-            'series'=>[
-                [
-                    "name"=>'绕组温度1',
-                    "data"=>[
-                        isset($baseData['2008298772108289_1']) ? $baseData['2008298772108289_1'] : 0,
-                        isset($baseData['2008298772239361_1']) ? $baseData['2008298772239361_1'] : 0,
-                        isset($baseData['2008298772464641_1']) ? $baseData['2008298772464641_1'] : 0,
-                        isset($baseData['2008298772624385_1']) ? $baseData['2008298772624385_1'] : 0,
-                    ],
-                ],
-                [
-                    "name"=>'绕组温度2',
-                    "data"=>[
-                        isset($baseData['2008298772118529_1']) ? $baseData['2008298772118529_1'] : 0,
-                        isset($baseData['2008298772255745_1']) ? $baseData['2008298772255745_1'] : 0,
-                        isset($baseData['2008298772485121_1']) ? $baseData['2008298772485121_1'] : 0,
-                        isset($baseData['2008298772642817_1']) ? $baseData['2008298772642817_1'] : 0,
-
-                    ],
-                ],
-                [
-                    "name"=>'绕组温度3',
-                    "data"=>[
-                        isset($baseData['2008298772132865_1']) ? $baseData['2008298772132865_1'] : 0,
-                        isset($baseData['2008298772274177_1']) ? $baseData['2008298772274177_1'] : 0,
-                        isset($baseData['2008298772503553_1']) ? $baseData['2008298772503553_1'] : 0,
-                        isset($baseData['2008298772657153_1']) ? $baseData['2008298772657153_1'] : 0,
-
-                    ],
-                ],
-                [
-                    "name"=>'轴承温度1',
-                    "data"=>[
-                        isset($baseData['2008298772089857_1']) ? $baseData['2008298772089857_1'] : 0,
-                        isset($baseData['2008298772208641_1']) ? $baseData['2008298772208641_1'] : 0,
-                        isset($baseData['2008298772425729_1']) ? $baseData['2008298772425729_1'] : 0,
-                        isset($baseData['2008298772589569_1']) ? $baseData['2008298772589569_1'] : 0,
-
-                    ],
-                ],
-                [
-                    "name"=>'轴承温度2',
-                    "data"=>[
-                        isset($baseData['2008298772098049_1']) ? $baseData['2008298772098049_1'] : 0,
-                        isset($baseData['2008298772225025_1']) ? $baseData['2008298772225025_1'] : 0,
-                        isset($baseData['2008298772444161_1']) ? $baseData['2008298772444161_1'] : 0,
-                        isset($baseData['2008298772605953_1']) ? $baseData['2008298772605953_1'] : 0,
-                    ],
-                ],
-            ]
-        ];
-        return json_encode($data);
-    }
-
-
-    public function executeSql($sqlStr, $modelname = -1, $mineCode='zaoquan') {
-
-        $conn   = 'etl_'.$mineCode;
-
-        try{
-            $opcDB =  DB::connection($conn);
-            $dbResult = $opcDB->select($sqlStr);
-            return $dbResult;
-        } catch (\Exception $e) {
-            switch ($modelname) {
-                case 1:
-                    return $this->error(-1, '统计超速数量出错！');
-                case 2:
-                    return $this->error(-1, '统计日超速出错！');
-                case 4:
-                    return $this->error(-1, '获取详细列表出错！');
-                default:
-                    return $this->error(-1, '未知错误！');
-            }
-
-        }
-    }
-
-}

Modules/OpcData/Routes/api.php

@@ -27,7 +27,6 @@ Route::namespace('Api')->group(function () {
     Route::any('apidata/getLightCurrInfoList', 'CarDownCurrLightInfoController@getList');
     Route::any('apidata/getSiteCurrInfoList', 'CarDownCurrSiteInfoController@getList');
 
-    Route::any('zaoquan/dcs/getWindEast', 'zaoquan\\DcsFanEastController@getList');
     Route::any('zaoquan/dcs/getFan', 'zaoquan\\ZQDcsFanController@getList');
 
     Route::any('zaoquan/dcs/getSupport', 'zaoquan\\ZQDcsSupportController@getList');

Modules/OpcData/Services/zaoquan/ZQDcsApiService.php

@@ -0,0 +1,82 @@
+<?php
+
+namespace Modules\OpcData\Services\zaoquan;
+
+use GuzzleHttp\Client;
+
+class ZQDcsApiService
+{
+
+    protected $client;
+
+    public function __construct()
+    {
+        $this->client = new Client();
+    }
+
+
+
+    public function getApiData($apiUrl, $queryParams)
+    {
+        // 发送 HTTP GET 请求
+        $response = $this->client->get($apiUrl, [
+            'query' => $queryParams,
+            // 可以添加其他选项，如 headers、auth 等
+        ]);
+
+        // 获取 API 响应的 JSON 数据
+        $data = json_decode($response->getBody(), true);
+
+        // 对数据进行重组，这里只是一个示例，具体根据实际需求调整
+        $transformedData = $this->transformData($data);
+
+        return $transformedData;
+    }
+
+    public function postPointRealData($apiUrl, $pointIds) {
+
+        // 发送 HTTP POST 请求
+        $response = $this->client->post($apiUrl, [
+            'PageNum'=>"-1",
+            'PointIds' => $pointIds,
+        ]);
+
+        // 获取 API 响应的 JSON 数据
+        $res = json_decode($response->getBody(), true);
+
+        $transformedData = $this->transformData($res);
+
+        return $transformedData;
+    }
+
+//    public function postApiData($apiUrl, $postData)
+//    {
+//        // 发送 HTTP POST 请求
+//        $response = $this->client->post($apiUrl, [
+//            'PageNum'=>"-1",
+//            'form_params' => $postData,
+//            // 可以添加其他选项，如 headers、auth 等
+//        ]);
+//
+//        // 获取 API 响应的 JSON 数据
+//        $data = json_decode($response->getBody(), true);
+//
+//        // 对数据进行重组，这里只是一个示例，具体根据实际需求调整
+//        $transformedData = $this->transformData($data);
+//
+//        return $transformedData;
+//    }
+
+    protected function transformData($data)
+    {
+
+        $transformedData=[];
+        for ($i = 0; $i < count($data); $i++) {
+            $dic = $data[$i];
+            $pid = $dic['ID'];
+            $val = $dic['V'];
+            $transformedData[$pid]=$val;
+        }
+        return $transformedData;
+    }
+}