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

<?php

namespace Modules\OpcData\Http\Controllers\Api;

use App\Http\Controllers\Api\BaseController;
use Illuminate\Contracts\Support\Renderable;
use Illuminate\Http\Request;
use Illuminate\Routing\Controller;
use Illuminate\Support\Facades\DB;

class CarCurrInfoController extends BaseController
{
    public function getList(Request $request) {
        $mineCode = isset($request->mine_code) ? $request->mine_code : null;     // 矿分类
        $carList = $this->getCarInfoList($mineCode);

        $dataTotal = $this->getCarCon($mineCode);

        $data = [
            "total"=>reset($dataTotal[0]),
            "list"=>$carList
        ];
        return json_encode($data);
    }

    public function getCarCon($mineCode='zaoquan') {
        $sqlStr = /** @lang text */
            "SELECT count(1) con FROM down_car_site_status where out_time is null or out_time < in_time";

        return $this->executeSql($sqlStr, 4, $mineCode);
    }

    // 当前信息详情
    public function getCarInfoList($mineCode='zaoquan', $page=0, $perPage = 15) {

        if ($mineCode == null) return null;

        $sqlStr = /** @lang text */
            "SELECT numberplate,
                    in_time,
                    speed_avg,
                    car_type,
                    t1.task_info,
                    t2.per_name
               FROM down_car_site_status t
               left join down_task_info t1 on t.task_num = t1.task_num
               left join down_personnel_info t2 on t.per_num = t2.per_num
              where site_tag = 1";

        $dbResult = $this->executeSql($sqlStr, 4, $mineCode);

        for($i = 0; $i<count($dbResult); $i++) {
            $val = $dbResult[$i];
            $data[] = [
                'car_num' => $val->numberplate,
                'speed' => $val->speed_avg.'km/h',
                'car_type' => $val->car_type,
                'task_info' => $val->task_info,
                'per_name' => $val->per_name
            ];
        }
        return $data ?? null;

    }

    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, '未知错误！');
            }

        }
    }
}