胶带运输13采区下山皮带接口

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

@@ -114,7 +114,11 @@ class OpcDataController extends Controller
         } else if ($getDataType == 'compressed_air') {
             // 压风
             $groupId = 5;
-            $result = $this->getcompressedAirData($groupId);
+            $result = $this->getCompressedAirData($groupId);
+        } else if ($getDataType == 'belt_13') {
+            // 13采区胶带运输机系统
+            $groupId = 6;
+            $result = $this->getBeltData($groupId);
         } else {
             return;
         }
@@ -141,7 +145,7 @@ class OpcDataController extends Controller
         join tb_dev_dict_list t1 on t.selItem = t1.selItem
         where t1.group_id = ".$groupId."
         and t1.is_show = 1
-        order by t1.dev_type_id, t1.row_number, t1.device_num
+        order by t1.dev_type_id, t1.row_number, t1.device_num, t1.device_name
         ";
         
         $dbResult = $this->opcDB->select($sqlStr);
@@ -197,7 +201,7 @@ class OpcDataController extends Controller
         join tb_dev_dict_list t1 on t.selItem = t1.selItem
         where t1.group_id = ".$groupId."
         and t1.is_show = 1
-        order by t1.dev_type_id, t1.row_number, t1.device_num
+        order by t1.dev_type_id, t1.row_number, t1.device_num, t1.device_name
         ";
         
         $dbResult = $this->opcDB->select($sqlStr);
@@ -276,7 +280,7 @@ class OpcDataController extends Controller
 
 
 
-    public function getcompressedAirData($groupId) {
+    public function getCompressedAirData($groupId) {
 
         $sqlStr = "
         select t1.dev_type_id,
@@ -295,7 +299,7 @@ class OpcDataController extends Controller
         join tb_dev_dict_list t1 on t.selItem = t1.selItem
         where t1.group_id = ".$groupId."
         and t1.is_show = 1
-        order by t1.dev_type_id, t1.row_number, t1.device_num
+        order by t1.dev_type_id, t1.row_number, t1.device_num, t1.device_name
         ";
         
         $dbResult = $this->opcDB->select($sqlStr);
@@ -361,4 +365,82 @@ class OpcDataController extends Controller
         }
         return $dataArr;
     }
+
+
+
+    public function getBeltData($groupId) {
+
+        $sqlStr = "
+        select t1.dev_type_id,
+                t1.dev_type_name,
+                t1.device_num,
+                t1.device_name,
+                case t.val 
+                    when 'True' then 1
+                    when 'False' then 2
+                    else t.val
+                end val,
+                t1.json_key,
+                t1.row_number,
+                t1.unit
+        from equipment t
+        join tb_dev_dict_list t1 on t.selItem = t1.selItem
+        where t1.group_id = ".$groupId."
+        and t1.is_show = 1
+        order by t1.dev_type_id, t1.row_number, t1.device_num, t1.device_name
+        ";
+        
+        $dbResult = $this->opcDB->select($sqlStr);
+        $valDict = array();
+        foreach ($dbResult as $key => $val) {
+            $devName    = $val->dev_type_name;          // 泵名
+            $rowNumber  = $val->row_number;             // 排序
+            $jsonKey    = $val->json_key;               // json键值
+            $label      = $val->device_name;            // 设备名
+            $devTypeNum = $val->dev_type_id - 1;        // 设备号
+            $devNum     = $val->device_num - 1;         // 设备号
+            $unit       = $val->unit;                   // 单位
+            $devVal     = $val->val;                    // 数值
+
+            // $valArr[$jsonKey] = $devVal;
+
+            if ($jsonKey == 'common') {
+                $valArr = [
+                    'label' => $label,      // 标题
+                    'value' => $devVal,     // 值
+                    'unit'  => $unit        // 单位
+                ];
+                $dataArr[$jsonKey][] = $valArr;
+            } else if ($jsonKey == 'state') {
+                $dataArr['state'] = $devVal;
+                $dataArr['name'] = $label;
+            }  else if ($jsonKey == 'electric_parameter' or $jsonKey == 'converter_parameter') {
+                $valArr = [
+                    'devNum' => $devNum,      // 标题
+                    'state' => $devVal,     // 值
+                    'unit'  => $unit        // 单位
+                    ,'label'  => $label        // 单位
+                ];
+                $valDict[$jsonKey][$label][] = $valArr;
+            } else {
+                $valArr = [
+                    'label' => $label,      // 标题
+                    'state' => $devVal,     // 值
+                    // 'unit'  => $unit        // 单位
+                ];
+                $dataArr[$jsonKey][] = $valArr;
+            }
+            
+        }
+        foreach ($valDict as $key => $val) {
+            $i = 0;
+            foreach ($val as $valKey => $valVal) { 
+                $dataArr[$key][$i]['label'] = $valKey;
+                $dataArr[$key][$i]['value_list'] = $valVal;
+                $i++;
+            }
+        }
+        // dd($dataArr);
+        return $dataArr;
+    }
 }