video_system/Modules/Admin/Http/Controllers/Api/ApiController.php

<?php
/**
 * Created by PhpStorm.
 * User: qiuzijian
 * Date: 6/22/24
 * Time: 12:32 PM
 */

namespace Modules\Admin\Http\Controllers\Api;

use App\Enum\ApiEnum;
use App\Http\Controllers\Api\BaseController;
use App\Http\Controllers\Controller;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Input;
use Modules\Admin\Entities\User;
use Modules\Admin\Http\Requests\TokenRequest;
use Modules\Admin\Services\ApiService;
use Modules\Staff\Entities\Staff;
use Symfony\Component\HttpFoundation\Response;

class ApiController extends BaseController
{
    //整改人列表
    public function zgrList(Request $request){
        $params = $request->all();
        if(!$params['xjdw']){
            return self::errorResponse(ApiEnum::STATUS_CODE_EMPTY);
        }

        $result['status'] = true;
        $result['msg']    = ApiEnum::RETURN_SUCCESS;
        $result['data']   = [];

        $list = DB::connection('mysql_fwe10')->table('uf_zhxx_qlczgry')->where('dwmc',$params['xjdw'])->get();

        if(count($list) > 0){
            for($i=0;$i<count($list);$i++){
                $result['data'][$i] = $list[$i]->zgrxm.'|'.$list[$i]->zgrgh;
            }
        }

        return $result;
    }

    //网格化录入
    public function addConition(Request $request)
    {
        $params = Input::get();
        if (!$params) {
            return self::errorResponse(ApiEnum::STATUS_CODE_EMPTY);
        }
        $result = ApiService::addConition($params);
        return self::successResponse($result);
    }

    //网格化整改
    public function editConition(Request $request){
        $params = Input::get();
        if (!$params) {
            return self::errorResponse(ApiEnum::STATUS_CODE_EMPTY);
        }
        $result = ApiService::editConition($params);
        return self::successResponse($result);
    }

    //网格化人员轨迹查询条件
    public function getQueryConition(Request $request)
    {
        $date = Input::get('date', '');
        if (!$date) {
            return self::errorResponse(ApiEnum::STATUS_CODE_EMPTY);
        }
        $result = ApiService::getQueryConitions($date);
        return self::successResponse($result);
    }

    //网格化人员轨迹
    public function getPersonTravel(Request $request)
    {
        $person_id = Input::get('person_id', '');
        $depart = Input::get('depart', '');
        $date = Input::get('date', '');
        if (!$person_id || !$depart) {
            return self::errorResponse(ApiEnum::STATUS_CODE_EMPTY);
        }
        $result = ApiService::getPersonTravel($person_id, $depart, $date);
        return self::successResponse($result);
    }

    //网格化巡检记录查询条件
    public function getResultConition()
    {
        $result = ApiService::getResultConition();
        return self::successResponse($result);
    }

    //网格化巡检记录查询
    public function getResultRecord()
    {
        $depart = Input::get('depart', 'all');
        $date_type = Input::get('date_type', 'week');
        $result = ApiService::getResultRecord($depart, $date_type);
        return self::successResponse($result);
    }

    //网格化巡检记录列表
    public function getResultList()
    {
        $person_id = Input::get('person_id', '');
        $depart = Input::get('depart', 'all');
        $date_type = Input::get('date_type', 'week');
        if (!$person_id) {
            return self::errorResponse(ApiEnum::STATUS_CODE_EMPTY);
        }
        $result = ApiService::getResultList($person_id, $depart, $date_type);
        return self::successResponse($result);
    }

    //网格化巡检记录列表明细
    public function getResultDlist()
    {
        $person_id = Input::get('person_id', '');
        $depart = Input::get('depart', '');
        $date = Input::get('date', '');
        if (!$person_id || !$depart || !$date) {
            return self::errorResponse(ApiEnum::STATUS_CODE_EMPTY);
        }
        $result = ApiService::getResultDlist($person_id, $depart, $date);
        return self::successResponse($result);
    }

    //网格化巡检记录明细
    public function getResultDetail()
    {
        $id = Input::get('id', '');
        if (!$id) {
            return self::errorResponse(ApiEnum::STATUS_CODE_EMPTY);
        }
        $result = ApiService::getResultDetails($id);
        return self::successResponse($result);
    }

    //网格化巡检记录
    public function getFinalList()
    {
        $start_date = Input::get('start_date', '');
        $end_date = Input::get('end_date', '');
        $depart = Input::get('depart', '');
        $person = Input::get('person', '');
        if (!$start_date || !$end_date) {
            return self::errorResponse(ApiEnum::STATUS_CODE_EMPTY);
        }
        $result = ApiService::getFinalList($start_date, $end_date, $depart, $person);
        return self::successResponse($result);
    }

    //网格化巡检权限
    public function getRole(){
        $staff_num = Input::get('staff_num', '');
        if (!$staff_num) {
            return self::errorResponse(ApiEnum::STATUS_CODE_EMPTY);
        }

        $result['status'] = true;
        $result['msg']    = ApiEnum::RETURN_SUCCESS;
        $result['data']   = 2;//无权限

        $people = DB::connection('mysql_fwe10')->table('uf_zhxx_qlczgry')->where('zgrgh',$staff_num)->where('is_delete',0)->get();

        if(count($people) > 0){
            $result['data'] = 1;//有权限
        }

        return self::successResponse($result);
    }

    //设备管理添加设备单位列表
    public function sbglUnitList(){
        $result['status'] = true;
        $result['msg']    = ApiEnum::RETURN_SUCCESS;
        $result['data'] = [];

        $unit_list = DB::connection('mysql_fwe10')->table('uf_zhxx_sbgl_qygl')->where('is_delete',0)->get();

        foreach($unit_list as $k => $v){
            $result['data'][] = [
                'id'   => $v->ID,
                'qymc' => $v->qymc
            ];
        }

        return self::successResponse($result);
    }

    //设备管理添加设备负责人列表
    public function sbglPeopleList(){
        $unit_id = Input::get('unit_id', '');
        $type = Input::get('type', '');

        if (!$unit_id) {
            return self::errorResponse(ApiEnum::STATUS_CODE_EMPTY);
        }

        if($type == ''){
            $type = 0;
        }

        $result['status'] = true;
        $result['msg']    = ApiEnum::RETURN_SUCCESS;
        $result['data'] = [];

        if($type == 0){//新设备负责人
            $name = 'xsbfzr';
        }elseif($type == 2){//待修负责人
            $name = 'dxfzr';
        }elseif($type == 3){//检修负责人
            $name = 'jxfzr';
        }elseif($type == 4){//检修验收负责人
            $name = 'jxysfzr';
        }elseif($type == 5){//鉴定识别(登记核实)负责人
            $name = 'dbffzr';
        }elseif($type == 6){//固定资产鉴定负责人
            $name = 'bffzr';
        }

        $people_list = DB::connection('mysql_fwe10')->table('uf_zhxx_sbgl_rygl')->where('ssdw',$unit_id)->where($name,0)->where('is_delete',0)->get();

        foreach($people_list as $k => $v){
            $result['data'][] = [
                'id'   => $v->ID,
                'xm' => $v->xm
            ];
        }

        return self::successResponse($result);
    }

    //设备管理添加新设备
    public function sbglAdd(Request $request){
        $params = Input::get();
        if (!$params) {
            return self::errorResponse(ApiEnum::STATUS_CODE_EMPTY);
        }

        $result['status'] = true;
        $result['msg']    = ApiEnum::RETURN_SUCCESS;
        $result['data']   = [];

        $id = mt_rand(pow(10, 18), pow(10, 18) + 999999999);
        $insert = [
            'ID' => $id,
            'FORM_DATA_ID' => $id,
            'DATA_INDEX' => 0.0,
            'CREATE_TIME' => date('Y-m-d H:i:s'),
            'TENANT_KEY' => 't1zz9w8165',
            'IS_DELETE' => 0,
            'DELETE_TYPE' => 0,
            'FT_STATUS' => 0,

            'ssdw' => $params['qymc'],
            'xsbdhfzr' => $params['xsbdhfzr'],
            'sbmc' => $params['sbmc'],
            'sbzp' => $params['sbzp'],
            'rhzq' => $params['rhzq'],
            'sbbh' => $params['sbbh'],
            'ggxh' => $params['ggxh'],
            'jscs' => $params['jscs'],
            'sccj' => $params['sccj'],
            'ccrq' => $params['ccrq'],
            'dhrq' => $params['dhrq'],
            'azrq' => $params['azrq'],
            'syrq' => $params['syrq'],
            'zyfssb' => $params['zyfssb'],
            'ptjsj' => $params['ptjsj'],
            'ylohq' => $params['ylohq'],
            'ptqt' => $params['ptqt'],
            'zypj' => $params['zypj'],
            'bz' => $params['bz'],
            'sbzt' => 0,
            'sylx' => 4
        ];

        DB::connection('mysql_fwe10')->table('uf_uf_zhxx_sbgl')->insert($insert);

        return self::successResponse($result);
    }

    //设备管理设备详情
    public function sbglDetail(){
        $params = Input::get();
        if (!$params) {
            return self::errorResponse(ApiEnum::STATUS_CODE_EMPTY);
        }

        $result['status'] = true;
        $result['msg']    = ApiEnum::RETURN_SUCCESS;
        $data = DB::connection('mysql_fwe10')->table('uf_uf_zhxx_sbgl as sbgl')
            ->select('sbgl.*','qygl.qymc','qygl.wxlx','qygl.ID as qyid')
            ->leftJoin('uf_zhxx_sbgl_qygl as qygl','qygl.id','=','sbgl.ssdw')
            ->where('sbgl.ID',$params['id'])->get();

        // $sbzt = ['新设备到货验收中','完好','待修','检修中','检修验收中','鉴定识别(登记核实)中','已报废','代物资保管'];
        // $sylx = ['在用','备用','拆除','检修','闲置'];
        // $bflx = ['委外设备废品废件','废品','设备待报废'];

        foreach($data as $k=>$v){
            $v->xsbfzr_list = [];
            $v->dxfzr_list = [];
            $v->jxfzr_list = [];
            $v->dbffzr_list = [];
            $v->bffzr_list = [];

            if($v->sbzt == 0){//新设备负责人
                $people_list = DB::connection('mysql_fwe10')->table('uf_zhxx_sbgl_rygl')->where('ssdw',$v->ssdw)->where('xsbfzr',0)->where('is_delete',0)->get();
                foreach($people_list as $key => $val){
                    $v->xsbfzr_list[] = [
                        'id'   => $val->ID,
                        'xm' => $val->xm
                    ];
                }
            }elseif($v->sbzt == 2){//待修负责人
                $people_list = DB::connection('mysql_fwe10')->table('uf_zhxx_sbgl_rygl')->where('ssdw',$v->ssdw)->where('dxfzr',0)->where('is_delete',0)->get();
                foreach($people_list as $key => $val){
                    $v->dxfzr_list[] = [
                        'id'   => $val->ID,
                        'xm' => $val->xm
                    ];
                }
            }elseif($v->sbzt == 3){//检修负责人
                $people_list = DB::connection('mysql_fwe10')->table('uf_zhxx_sbgl_rygl')->where('ssdw',$v->ssdw)->where('jxfzr',0)->where('is_delete',0)->get();
                foreach($people_list as $key => $val){
                    $v->jxfzr_list[] = [
                        'id'   => $val->ID,
                        'xm' => $val->xm
                    ];
                }
            }elseif($v->sbzt == 4){//检修验收负责人
                $people_list = DB::connection('mysql_fwe10')->table('uf_zhxx_sbgl_rygl')->where('ssdw',$v->ssdw)->where('jxysfzr',0)->where('is_delete',0)->get();
                foreach($people_list as $key => $val){
                    $v->jxysfzr_list[] = [
                        'id'   => $val->ID,
                        'xm' => $val->xm
                    ];
                }
            }elseif($v->sbzt == 5){//鉴定识别(登记核实)负责人
                $people_list = DB::connection('mysql_fwe10')->table('uf_zhxx_sbgl_rygl')->where('ssdw',$v->ssdw)->where('dbffzr',0)->where('is_delete',0)->get();
                foreach($people_list as $key => $val){
                    $v->dbffzr_list[] = [
                        'id'   => $val->ID,
                        'xm' => $val->xm
                    ];
                }
            }elseif($v->sbzt == 6){//固定资产鉴定负责人
                $people_list = DB::connection('mysql_fwe10')->table('uf_zhxx_sbgl_rygl')->where('ssdw',$v->ssdw)->where('bffzr',0)->where('is_delete',0)->get();
                foreach($people_list as $key => $val){
                    $v->bffzr_list[] = [
                        'id'   => $val->ID,
                        'xm' => $val->xm
                    ];
                }
            }

            if($v->rhzq != null){
                $v->rhzq = $v->rhzq.'个月';
            }
        }

        $result['data'] = $data;

        return self::successResponse($result);
    }

    //设备管理润滑管理
    public function sbglRhList(){
        $result['status'] = true;
        $result['msg']    = ApiEnum::RETURN_SUCCESS;
        $result['data'] = [];

        $current = time();// 获取当前时间戳

        $list = DB::connection('mysql_fwe10')->table('uf_uf_zhxx_sbgl as sbgl')
            ->select('sbgl.ID','sbgl.create_time','sbgl.sbmc','sbgl.scrhsj','sbgl.rhzq','qygl.qymc')
            ->leftJoin('uf_zhxx_sbgl_qygl as qygl','qygl.id','=','sbgl.ssdw')
            ->where('sbgl.rhzq','!=','')->where('sbgl.is_delete',0)->get()->toArray();

        foreach($list as $k => $v){
            if($v->scrhsj != null){
                $scrhsj = strtotime($v->scrhsj);
                $sjc = floor(($current - $scrhsj) / (60 * 60 * 24));
                $sjc = intval(round($sjc));
                $v->sjc = ($v->rhzq*30 - $sjc);
            }else{
                $create_time = strtotime($v->create_time);
                $sjc = floor(($current - $create_time) / (60 * 60 * 24));
                $sjc = intval(round($sjc));
                $v->sjc = ($v->rhzq*30 - $sjc);
            }
        }

        usort($list, function ($a, $b) {
            return $a->sjc <=> $b->sjc;
        });

        $result['data'] = $list;

        return self::successResponse($result);
    }

    //设备管理设备调拨
    public function sbglSbdb(){
        $params = Input::get();
        if (!$params) {
            return self::errorResponse(ApiEnum::STATUS_CODE_EMPTY);
        }

        $result['status'] = true;
        $result['msg']    = ApiEnum::RETURN_SUCCESS;
        $result['data']   = [];

        $update = [
            'ssdw' => $params['unit_id'],
            'sbzt' => $params['sbzt'],
            'sylx' => $params['sylx'],
        ];
        if(isset($params['sbbh'])){
            $update['sbbh'] = $params['sbbh'];
        }
        if(isset($params['bz'])){
            $update['bz'] = $params['bz'];
        }

        if($params['sbzt'] == 0){
            $update['xsbdhfzr'] = $params['fzr_id'];
        }
        if($params['sbzt'] == 2){
            $update['dxfzr'] = $params['fzr_id'];
        }
        if($params['sbzt'] == 3){
            $update['jxfzr'] = $params['fzr_id'];
        }
        if($params['sbzt'] == 4){
            $update['jxysfzr'] = $params['fzr_id'];
        }
        if($params['sbzt'] == 5){
            $update['dbffzr'] = $params['fzr_id'];
        }
        if($params['sbzt'] == 6){
            $update['bffzr'] = $params['fzr_id'];
        }

        DB::connection('mysql_fwe10')->table('uf_uf_zhxx_sbgl')->where('ID',$params['id'])->update($update);

        return self::successResponse($result);
    }

    //设备管理设备审核
    public function sbglSbsh(){
        $params = Input::get();
        if (!$params) {
            return self::errorResponse(ApiEnum::STATUS_CODE_EMPTY);
        }

        $result['status'] = true;
        $result['msg']    = ApiEnum::RETURN_SUCCESS;
        $result['data']   = [];

        if($params['action'] == 1){//删除设备
            DB::connection('mysql_fwe10')->table('uf_uf_zhxx_sbgl')->where('ID',$params['id'])->update(['is_delete'=>1]);
            return self::successResponse($result);
        }

        $update = [
            'sbzt' => $params['sbzt'],
            'sylx' => $params['sylx']
        ];

        if(isset($params['bz'])){
            $update['bz'] = $params['bz'];
        }

        if($params['sbzt'] == 3){
            $update['jxfzr'] = $params['fzr_id'];
        }
        if($params['sbzt'] == 4){
            $update['jxysfzr'] = $params['fzr_id'];
        }
        if($params['sbzt'] == 5){
            $update['dbffzr'] = $params['fzr_id'];
        }
        if($params['sbzt'] == 6){
            $update['bffzr'] = $params['fzr_id'];
            $update['bflx'] = $params['bflx'];
        }

        DB::connection('mysql_fwe10')->table('uf_uf_zhxx_sbgl')->where('ID',$params['id'])->update($update);

        return self::successResponse($result);
    }

    //设备管理权限
    public function sbglRole(){
        $id = Input::get('id', '');
        $staff_num = Input::get('staff_num', '');
        $unit_id = Input::get('unit_id', '');
        $type = Input::get('type', '');

        if (!$unit_id) {
            return self::errorResponse(ApiEnum::STATUS_CODE_EMPTY);
        }

        if (!$staff_num) {
            return self::errorResponse(ApiEnum::STATUS_CODE_EMPTY);
        }

        if (!$type) {
            return self::errorResponse(ApiEnum::STATUS_CODE_EMPTY);
        }

        if (!$id && $type != 'sbgly') {
            return self::errorResponse(ApiEnum::STATUS_CODE_EMPTY);
        }

        $result['status'] = true;
        $result['msg']    = ApiEnum::RETURN_SUCCESS;
        $result['data']   = 2;//无权限

        if($type == 'sbgly'){
            $people_list = DB::connection('mysql_fwe10')->table('uf_zhxx_sbgl_rygl')->where('ssdw',$unit_id)->where('gh',$staff_num)->where('sbgly',0)->where('is_delete',0)->get();
            if(count($people_list) > 0){
                $result['data'] = 1;//有权限
            }
        }else{
            $sb = DB::connection('mysql_fwe10')->table('uf_uf_zhxx_sbgl')->where('id',$id)->get();
            if($type == 'xsbdhfzr'){
                $people = DB::connection('mysql_fwe10')->table('uf_zhxx_sbgl_rygl')->where('id',$sb[0]->xsbdhfzr)->get();
                if($people[0]->gh == $staff_num){
                    $result['data'] = 1;
                }
            }
            if($type == 'dxfzr'){
                $people = DB::connection('mysql_fwe10')->table('uf_zhxx_sbgl_rygl')->where('id',$sb[0]->dxfzr)->get();
                if($people[0]->gh == $staff_num){
                    $result['data'] = 1;
                }
            }
            if($type == 'jxfzr'){
                $people = DB::connection('mysql_fwe10')->table('uf_zhxx_sbgl_rygl')->where('id',$sb[0]->jxfzr)->get();
                if($people[0]->gh == $staff_num){
                    $result['data'] = 1;
                }
            }
            if($type == 'jxysfzr'){
                $people = DB::connection('mysql_fwe10')->table('uf_zhxx_sbgl_rygl')->where('id',$sb[0]->jxysfzr)->get();
                if($people[0]->gh == $staff_num){
                    $result['data'] = 1;
                }
            }
            if($type == 'dbffzr'){
                $people = DB::connection('mysql_fwe10')->table('uf_zhxx_sbgl_rygl')->where('id',$sb[0]->dbffzr)->get();
                if($people[0]->gh == $staff_num){
                    $result['data'] = 1;
                }
            }
            if($type == 'bffzr'){
                $people = DB::connection('mysql_fwe10')->table('uf_zhxx_sbgl_rygl')->where('id',$sb[0]->bffzr)->get();
                if($people[0]->gh == $staff_num){
                    $result['data'] = 1;
                }
            }
        }

        return self::successResponse($result);
    }


    //教育学习（洗选中的教育学习应用）
    // 学习效果检查统计表
    public function learningEffectCheck(Request $request)
    {
        $params = $request->all();

        if(isset($params['start_time']) && isset($params['end_time'])){
            $start_time = $params['start_time'];
            $end_time = $params['end_time'];
        }else{
            $start_time = date('Y-m-d 00:00:00');
            $end_time = date('Y-m-d 00:00:00', strtotime('+1 day'));
        }

        // 自评表数据
        $evaluate_data = DB::connection('mysql_fwe10')->table('uf_xx_zpb as t')
            ->select('t.dwmc as unitId','t.sgyy','t.sghg','t.sgcljg','t.xqjxjffcs','t.df','t1.dwmc')
            ->leftJoin('uf_xx_gxmcdw as t1', 't.dwmc', '=', 't1.id')
            ->whereBetween('t.create_time', [$start_time, $end_time])
            ->where('t.is_delete',0)
            ->where('t.delete_type',0)
            ->get();

        // 数据库查出来的数据进行处理
        $process_data = [];
        // 1. 提取所有单位id值
        $tmp = [];
        $index = 0;


        if(count($evaluate_data) > 0){
            for ($i = 0; $i < count($evaluate_data); $i++) {
                $process_data[$index]['unitId'] = $evaluate_data[$i]->unitId;
                $process_data[$index]['sgyy'] = $evaluate_data[$i]->sgyy;
                $process_data[$index]['sghg'] = $evaluate_data[$i]->sghg;
                $process_data[$index]['sgcljg'] = $evaluate_data[$i]->sgcljg;
                $process_data[$index]['xqjxjffcs'] = $evaluate_data[$i]->xqjxjffcs;
                $process_data[$index]['df'] = $evaluate_data[$i]->df;
                $process_data[$index]['dwmc'] = $evaluate_data[$i]->dwmc;
                $index++;

                $tmp[] = $evaluate_data[$i]->unitId;
            }
        }



        // 2. 去重并重置索引
        $unitId_List = array_values(array_unique($tmp));

        // 根据去重后的单位id给$evaluate_data中的数据分组
        $grouped = [];
        foreach ($process_data as $item) {
            $unitId = $item['unitId'];
            $grouped[$unitId][] = $item; // 按unitId值分组
        }
        $result = [];
        foreach ($unitId_List as $unitIdVar) {
            if (isset($grouped[$unitIdVar])) {
                $var1 = $grouped[$unitIdVar]; // 按uniqueBms顺序提取分组
                $result[] += $this->dataProcessing($var1);
            }
        }

        // 最后结果需要有个排名

        return self::successResponse($result);

    }

    // 对每组数据进行统计处理
    public function dataProcessing ($data = []): array
    {
        // 单位名称
        $unitName = '';
        // 检查人次
        $checkPeopleNum = count($data);
        // 事故原因
        $accidentCause = 0;
        // 事故后果
        $accidentConsequence = 0;
        // 事故处理结果
        $resultOfAccidentTreatment = 0;
        // 吸取教训/防范措施
        $preventiveMeasures = 0;
        // 最高分
        $theHighestScore = 0;
        // 最低分
        $theLowestScore = 0;
        // 平均分
        $averageScore = 0;

        foreach ($data as $item) {
            $accidentCause += $item['sgyy'];
            $accidentConsequence += $item['sghg'];
            $resultOfAccidentTreatment += $item['sgcljg'];
            $preventiveMeasures += $item['xqjxjffcs'];
            if ($theHighestScore < $item['df']) {
                $theHighestScore = $item['df'];
            }
            if ($theLowestScore > $item['df']) {
                 $theLowestScore = $item['df'];
            }
            $averageScore += $item['df'];
        }
        $unitName = reset($data)['dwmc'];
        $accidentCause = $accidentCause / $checkPeopleNum;
        $accidentConsequence = $accidentConsequence / $checkPeopleNum;
        $resultOfAccidentTreatment = $resultOfAccidentTreatment / $checkPeopleNum;
        $preventiveMeasures = $preventiveMeasures / $checkPeopleNum;
        $averageScore = $averageScore / $checkPeopleNum;
        $res = [
            'dwmc' => $unitName,
            'jcrc' => $checkPeopleNum,
            'sgyy' => $accidentCause,
            'sghg' => $accidentConsequence,
            'sgcljg' => $resultOfAccidentTreatment,
            'jxjxjffcs' => $preventiveMeasures,
            'zgf' => $theHighestScore,
            'zdf' => $theLowestScore,
            'pjf' => $averageScore
        ];
        return $res;

    }

}