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\Routing\Controller;
use Illuminate\Support\Facades\DB;
use Modules\OpcData\Entities\OpcDataDict;

class OpcDataController extends Controller
{
    /**
     * 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)
    {
        //
    }

    private $opcDictArr = array();
    private $dictTableName = 'tb_fan_dict_list';
    private $dataTableName = 'equipment';

    public function getData(Request $request)
    {
        // dd($request->all());
        // $model = new OpcDataDict();
        // $dictData = OpcDataDict::where();
        // dd($dictData);
        $db = DB::connection('mysql_opc_jinjiaqu');
        $sqlStr = "
         select t1.fan_type_id,
                t1.fan_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_fan_dict_list t1 on t.selItem = t1.selItem
         where t1.group_id = 1
           and t1.is_show = 1
         order by t1.fan_type_id, t1.row_number, t1.device_num
        ";
        
        $dbResult = $db->select($sqlStr);
        $dataArr = array();
        foreach ($dbResult as $key => $val) {
            $fanNum     = $val->fan_type_id - 1;        // 风机号
            $label      = $val->device_name;            // 设备名
            $devVal     = $val->val;                    // 数值
            $jsonKey   = $val->json_key;               // json键值
            $unit       = $val->unit;                   // 单位
            $dataArr[$fanNum]['title'] = $val->fan_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 response()->json($dataArr);
    }
}