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

<?php

namespace Modules\OpcData\Http\Controllers\Api;

use Illuminate\Contracts\Support\Renderable;
use Illuminate\Http\Request;
use Illuminate\Http\Response;
use Illuminate\Routing\Controller;
use Illuminate\Support\Facades\DB;
use Modules\OpcData\Entities\OpcDataDict;

class OpcDataController extends Controller
{
    protected $opcDB;
    // private $opcDictArr = array();
    protected $opcConnectName   = 'mysql_opc_jinjiaqu';
    // private $dictTableName      = 'tb_dev_dict_list';
    // private $dataTableName      = 'equipment';
    
    public function __construct() {
        $this->opcDB =  DB::connection($this->opcConnectName);
    }

    /**
     * Display a listing of the resource.
     * @return Renderable
     */
    public function index()
    {
        return view('opcdata::index');
    }

    /**
     * Show the form for creating a new resource.
     * @return Renderable
     */
    public function create()
    {
        return view('opcdata::create');
    }

    /**
     * Store a newly created resource in storage.
     * @param Request $request
     * @return Renderable
     */
    public function store(Request $request)
    {
        //
    }

    /**
     * Show the specified resource.
     * @param int $id
     * @return Renderable
     */
    public function show($id)
    {
        return view('opcdata::show');
    }

    /**
     * Show the form for editing the specified resource.
     * @param int $id
     * @return Renderable
     */
    public function edit($id)
    {
        return view('opcdata::edit');
    }

    /**
     * Update the specified resource in storage.
     * @param Request $request
     * @param int $id
     * @return Renderable
     */
    public function update(Request $request, $id)
    {
        //
    }

    /**
     * Remove the specified resource from storage.
     * @param int $id
     * @return Renderable
     */
    public function destroy($id)
    {
        //
    }

    public function getData(Request $request)
    {
        $getDataType = $request->system_type;   // 获取需要的数据
        $dataArr = array();                     // 返回数据数组
        $result;
        if ($getDataType == 'ventilation_zb'){
            // 中部风机
            $groupId = 1;
            $result = $this->getFanData($groupId);
        } else if ($getDataType == 'ventilation_bb') {
            // 北部风机
            $groupId = 2;
            $result = $this->getFanData($groupId);
        } else if ($getDataType == 'pump_zy') {
            // 中央水泵
            $groupId = 3;
            $result = $this->getPumpData($groupId);
        } else if ($getDataType == 'pump_690') {
            // 609水泵
            $groupId = 4;
            $result = $this->getPumpData($groupId);
        } else if ($getDataType == 'compressed_air') {
            // 压风
            $groupId = 5;
            $result = $this->getCompressedAirData($groupId);
        } else if ($getDataType == 'belt_13') {
            // 13采区胶带运输机系统
            $groupId = 6;
            $result = $this->getBeltData($groupId);
        } else {
            return;
        }
        return response()->json($result);
    }

    // 水泵
    public function getFanData($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);
        // dd($dbResult);
        foreach ($dbResult as $key => $val) {
            $fanNum     = $val->dev_type_id - 1;        // 风机号
            $label      = $val->device_name;            // 设备名
            $devVal     = $val->val;                    // 数值
            $jsonKey   = $val->json_key;                // json键值
            $unit       = $val->unit;                   // 单位
            $dataArr[$fanNum]['title'] = $val->dev_type_name; // 风机名
            $valArr = [
                'label' => $label,      // 标题
                'unit'  => $unit        // 单位
            ];
            // 状态与value
            if($jsonKey == 'state_list') {
                $valArr['state'] = $devVal;
            } else {
                $valArr['value'] = $devVal;
            }
            // 根据风量判断风机开关
            if($label == '风量') {
                if ($devVal <= 0 ) {
                    $dataArr[$fanNum]['state'] = 2;
                } else {
                    $dataArr[$fanNum]['state'] = 1;
                }
            }
            $dataArr[$fanNum][$jsonKey][] = $valArr;
            
        }
        return $dataArr;
    }


    public function getPumpData($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);
        $timeArr = array();     // 用于拼接时分秒
        $timeJsonKey;           // 记录time字段key名
        // dd($dbResult);
        foreach ($dbResult as $key => $val) {
            $devName    = $val->dev_type_name;          // 泵名
            $rowNumber  = $val->row_number;             // 排序
            $jsonKey    = $val->json_key;               // json键值
            $label      = $val->device_name;            // 设备名
            $devNum     = $val->dev_type_id - 1;        // 设备号
            $unit       = $val->unit;                   // 单位
            $devVal     = $val->val;                    // 数值

            if ($rowNumber <= 4) {

                $valArr = [
                    'label' => $label,      // 标题
                    'value' => $devVal,     // 值
                    'unit'  => $unit        // 单位
                ];
                $dataArr[$jsonKey][] = $valArr;

            } else if ($rowNumber == 5) {
                if ($groupId == 4) {
                    // 609水泵房单独处理状态
                    $dataArr['water_pump'][$devNum]['name'] = $devName;
                    if (array_key_exists($jsonKey, $dataArr['water_pump'][$devNum])) {
                        $state = $dataArr['water_pump'][$devNum][$jsonKey];
                        $dataArr['water_pump'][$devNum][$jsonKey] = max($devVal, $state);
                    } else {
                        $dataArr['water_pump'][$devNum][$jsonKey] = $devVal;
                    }
                } else {
                    // 中央水泵房电机开启状态处理
                    $valArr = [
                        'label' => $devName,      // 标题
                        'state' => $devVal      // 值
                    ];
                    $dataArr[$jsonKey][] = $valArr;
                }

            } else if ($rowNumber == 10 or $rowNumber == 11) {

                $timeArr[$label][$devNum][$unit] = $devVal;
                $timeJsonKey = $jsonKey;

            } else if ($rowNumber > 5) {

                $valArr = [
                    'label' => $label,      // 标题
                    'value' => $devVal,     // 值
                    'unit'  => $unit        // 单位
                ];

                $dataArr['water_pump'][$devNum][$jsonKey][] = $valArr;

            }
            
        }

        foreach ($timeArr as $key => $value) {
            for ($i=0; $i < count($value); $i++) {
                $timeFormatStr = $value[$i]['HH'].'时'.$value[$i]['MM'].'分'.$value[$i]['SS'].'秒';
                $valArr = [
                    'label' => $key,                // 标题
                    'value' => $timeFormatStr,      // 值
                    'unit'  => ''                   // 单位
                ];
                $dataArr['water_pump'][$i][$timeJsonKey][] = $valArr;
            }
        }
        return $dataArr;
    }



    public function getCompressedAirData($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);
        $timeArr = array();     // 用于拼接时分秒
        $timeJsonKey;           // 记录time字段key名
        // dd($dbResult);
        foreach ($dbResult as $key => $val) {
            $devName    = $val->dev_type_name;          // 泵名
            $rowNumber  = $val->row_number;             // 排序
            $jsonKey    = $val->json_key;               // json键值
            $label      = $val->device_name;            // 设备名
            $devNum     = $val->dev_type_id - 1;        // 设备号
            $unit       = $val->unit;                   // 单位
            $devVal     = $val->val;                    // 数值

            // $valArr[$jsonKey] = $devVal;

            
            if ($jsonKey == 'run_parameter') {
                $dataArr['compressed_air'][$devNum]['name'] = $devName;
                $dataArr['compressed_air'][$devNum]['state'] = $devVal;

                $valArr = [
                    'label' => $label,      // 标题
                    'state' => $devVal,     // 值
                    'unit'  => $unit        // 单位
                    // ,'json' => $jsonKey
                ];
                $dataArr['compressed_air'][$devNum][$jsonKey][] = $valArr;
                
            } else if ($jsonKey == 'common') {
                $valArr = [
                    'label' => $label,      // 标题
                    'value' => $devVal,     // 值
                    'unit'  => $unit        // 单位
                ];
                $dataArr[$jsonKey][] = $valArr;
            } else if ($jsonKey == 'drain_value_state') {
                // 开关状态单独处理
                $dataArr['compressed_air'][$devNum][$jsonKey] = $devVal;
                if (array_key_exists($jsonKey, $dataArr['compressed_air'][$devNum])) {
                    $state = $dataArr['compressed_air'][$devNum][$jsonKey];
                    $dataArr['compressed_air'][$devNum][$jsonKey] = max($devVal, $state);
                } else {
                    $dataArr['compressed_air'][$devNum][$jsonKey] = $devVal;
                }
            }  else if ($jsonKey == 'compressed_air') {
                $valArr = [
                    'label' => $label,      // 标题
                    'value' => $devVal,     // 值
                    'unit'  => $unit        // 单位
                ];
                $dataArr['compressed_air'][$devNum][$jsonKey][] = $valArr;
            } else if ($jsonKey == 'warn_state') {
                $valArr = [
                    'label' => $label,      // 标题
                    'state' => $devVal,     // 值
                    'unit'  => $unit        // 单位
                ];
                $dataArr['compressed_air'][$devNum][$jsonKey][] = $valArr;
            }
            
        }
        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;
    }
}