station-test-api/catch/map/controller/RouteMap.php

<?php

namespace catchAdmin\map\controller;

use catcher\base\CatchRequest as Request;
use catcher\CatchResponse;
use catcher\base\CatchController;
use Aliyun\OTS\OTSClient;


use catchAdmin\hydraulic\model\Hydraulic as deviceModel;
use catchAdmin\fences\model\Fences as fencesModel;
use think\facade\Db;
use think\facade\Env;
class RouteMap extends CatchController
{
    protected $deviceModel;
    protected $fencesModel;
    protected $filterTrack=false;
    public function __construct(deviceModel $deviceModel,fencesModel $fencesModel)
    {
        $this->deviceModel = $deviceModel;
        $this->fencesModel = $fencesModel;
    }
    
    /**
     * 列表
     * @time 2021年05月18日 10:15
     * @param Request $request 
     */
    public function queryDeviceList(Request $request) : \think\Response
    {
        $list =$this->deviceModel->getList();

        return CatchResponse::paginate($list);
    }
     /**
     * 列表
     * @time 2021年05月18日 10:15
     * @param Request $request 
     */
    public function  queryDeviceRealTimeInfo(Request $request) : \think\Response
    {
        $params=$request->param();
        if(!isset($params['imeis'])){
            return CatchResponse::success([]);
        }
        // var_dump($params);   
        $imeis=$params['imeis'];
        
        $list=$this->deviceModel->whereIn('imei',$imeis)->select();
        foreach ($list as &$value) {
            $value['status_icon']='run';
            $value['status']='在线';
         }
        // var_dump($list);
        return CatchResponse::success($list);
    }
    
    /**
     *
     * @time  2021年05月24日
     * @return \think\response\Json
     */
    public function queryLocationList(Request $request): \think\Response
    {
        return CatchResponse::success($this->deviceModel->queryLocationList());
    }
    
    
    
    
    /**
     *
     * @time  2021年05月24日
     * @return \think\response\Json
     */
    public function queryFenceList(Request $request): \think\Response
    {
        $list=DB::table('fences')->where('fence_type',0)->select()->toArray();
        foreach($list as &$val){
            $user_depart=Db::table('users')->where('id',$val['creator_id'])->value('department_id');
            $creator_level=Db::table('departments')->where('id',$user_depart)->value('level');
            if(!$creator_level){
                $val['level']=1;
            }else{
                $level_arr=explode('-',$creator_level);
                $val['level']=count($level_arr)+1;
            }
        }
        return CatchResponse::success($list);
    }

    /**
     * 查询当前定位
     * @time 2021年05月18日 10:15
     * 
     */
    public function queryDeviceCurLocation(Request $request) : \think\Response
    {
        $params=$request->param();

        $device_number=$params['device_number'];
        if (!$device_number) {
            return CatchResponse::fail("获取设备号失败");
        }
        $device_info=$this->deviceModel->where('imei',$device_number)->find()->toArray();
        // var_dump($device_info);
        if($device_info['online_time']<$device_info['wifi_online_time']){
            $device_info['online_time']=$device_info['wifi_online_time'];
            $device_info['longitude']=$device_info['wifi_longitude'];
            $device_info['latitude']=$device_info['wifi_latitude'];
        }
        return CatchResponse::success($device_info);
    }
    /**
     * 查询学生轨迹RFid
     * @time 2021年05月18日 10:15
     * 
     */
    public function queryStudentRouteRfid(Request $request) : \think\Response
    {
      
        $params=$request->param();

        $active_rfid=$params['active_rfid'];
        if (!$active_rfid) {
            return CatchResponse::fail("获取设备号失败");
        }
        $start_time = strtotime(date('Y-m-d 00:00:00'));
        $end_time = strtotime(date('Y-m-d 23:59:59'));
        if(isset($params['time_range']) && $params['time_range'] != ''){
            $start_time=strtotime($params['time_range'][0]);
            $end_time=strtotime($params['time_range'][1]);
        }

        // 判断设备是否为第三方的，如果是则调用第三方接口获取
        $isThirdParty = \catchAdmin\student\model\ThirdPartyDevices::isThirdPartyDevice($active_rfid);
        // var_dump('isThirdParty', $isThirdParty);
        if ($isThirdParty) {
            $options = [
                'startTime' => $start_time,
                'endTime' => $end_time,
                // 'positionTypes' => 1, //1,2
            ];
           $api_routes = \thirdapi\ThirdDeviceApi2::getHistoryLocations($active_rfid, $options);
           if (!$api_routes) {
             return CatchResponse::fail("查询轨迹失败");
           }
           $routes = [];
            if (isset($api_routes['content']) && !empty($api_routes['content'])) {
                foreach ($api_routes['content'] as $info) {
                    $routes[] = [
                        'AlarmType' => 0,
                        'Altitude' => '',
                        'DeviceNumber' => $info['imei'],
                        'Latitude' => $info['lat'],
                        'Longitude' => $info['lon'],
                        'PassTime' => $info['receiveAt'],
                        'Battery' => $info['battery'],
                        'CollectDt' => $info['collectDt'],
                        'PositionType' => $info['positionType'],
                        'IsOnline' => $info['isOnline'],
                    ];
                }
            }
           return CatchResponse::success($routes, "查询轨迹成功");
        }

        // 非第三方设备从表格存储获取
        // $otsClient = new OTSClient (array (
        //     'EndPoint' => 'https://rlfd.cn-hangzhou.ots.aliyuncs.com',
        //     'AccessKeyID' => 'LTAI4FecTAyMPdhAdkUwhAGA',
        //     'AccessKeySecret' => 'Ih0knSSfcje3OUi1YrdjeXQZYIfmTK',
        //     'InstanceName' => 'rlfd',
        // ));
        $table_config=Db::table('sys_config')->where('type','table_store')->column('fieldValue','field');
        if(!isset($table_config['EndPoint']) || !isset($table_config['AccessKeyID']) || !isset($table_config['AccessKeySecret']) || !isset($table_config['InstanceName'])){
            return CatchResponse::fail("请先配置表格存储");
        }
        $otsClient = new OTSClient (array (
            'EndPoint' => $table_config['EndPoint'],
            'AccessKeyID' => $table_config['AccessKeyID'],
            'AccessKeySecret' => $table_config['AccessKeySecret'],
            'InstanceName' =>  $table_config['InstanceName'],
        ));
        $otsClient->getClientConfig()->debugLogHandler = null;
        $otsClient->getClientConfig()->errorLogHandler = null;
        // var_dump($otsClient);
        ini_set('memory_limit', '512M');

        $startPK = array (
            array('DeviceNumber',$active_rfid),
            array('Timestamp', $start_time)
            // array('Timestamp', 1620885120)
        );
        $endPK = array (
            array('DeviceNumber', $active_rfid),
            array('Timestamp', $end_time)
            // array('Timestamp', 1620885441)
        );

        $limit = 5500; 

       
        $rows=[];
        while (! empty ($startPK) && $limit > 0) {

            $request = array (
                'table_name' => 'wxt_route_rfid',
                'max_versions' => 1,
                'direction' => 'BACKWARD', // 方向可以为 FORWARD 或者 BACKWARD
                'inclusive_start_primary_key' => $endPK, // 开始主键
                'exclusive_end_primary_key' => $startPK, // 结束主键
                'limit' => $limit
            );
            
            
            $response = [];
            try {
                $response = $otsClient->getRange($request);
            } catch (\Exception $e) {
            //    var_dump($e);
            }
            
            if (!isset($response['rows'])){
                return CatchResponse::success([]);
            }
            
            foreach ($response['rows'] as $rowData) {
                    // $str=($limit-4000)/2000;
                    $item=[];
                    foreach($rowData['primary_key'] as $keyItem){
                        $item[$keyItem[0]]=$keyItem[1];
                    }
                    foreach($rowData['attribute_columns'] as $colItem){
                        $item[$colItem[0]]=$colItem[1];
                    }
                    $station_info=Db::table('station')->where('station_code',$item['StationCode'])->find();
                    if($station_info['station_type']==3){
                        $school_name=Db::table('departments')->where('id',$station_info['school_id'])->cache(60)->value('department_name');
                        $build_name=Db::table('kq_building')->where('id',$station_info['building_id'])->cache(60)->value('name');
                        $floor_name=Db::table('kq_floor')->where('id',$station_info['floor_id'])->cache(60)->value('name');
                        $station_address=$school_name.' '.$build_name.' '.$floor_name.' '.$station_info['room_no'].'房间';
                        $item['Address']=$station_address;
                    }else{
                        $item['Address']=$station_info['address'];
                    }

                    
                    $item['PassTime']=date('Y-m-d H:i:s',$item['Timestamp']);
                    // $item['Longitude']+=$str;
                    // $item['Latitude']+=$str;
                    $rows[]=$item;
                    $limit --;

              // 处理每一行数据
            }
          
              $startPK = $response['next_start_primary_key'];
              // 如果 next_start_primary_key 不为空并且 limit > 0 则循环继续
        }
        // var_dump($rows);
        return CatchResponse::success($rows);
        
    }


    /**
     * 查询学生轨迹GPS
     * @time 2021年05月18日 10:15
     * 
     */
    public function queryDeviceRouteGps(Request $request) : \think\Response
    {
        
        $params=$request->param();
        // var_dump($params);
        // var_dump(strtotime($params['aData']));
        $device_number = $params['imei'];

        if (!$device_number) {
            return CatchResponse::fail("获取设备号失败");
        }
        if($params['time']==0 && isset($params['time_range']) && $params['time_range'] != ''){
            $start_time=strtotime($params['time_range'][0]);
            $end_time=strtotime($params['time_range'][1]);
           
        }else{
            $start_time = time()-$params['time'];
            $end_time=time();
        }
        


        $options=array(
            'device_number'=>$device_number,
            'start_time'=>$start_time,
            'end_time'=>$end_time,
            'table_name'=>'wxt_route_gps'
        );
        $res = queryTableStoreGpsRoute($options);
        if($res['success']){
            $data=$res['data'];
            $battery_level=Db::table('devices')->where('imei',$device_number)->value('battery_level');
            foreach($data as &$val){
                $val['Longitude']=round($val['Longitude'],6);
                $val['Latitude']=round($val['Latitude'],6);
                $val['SignalType']='GPS';
                $val['BatteryLevel']=$battery_level;
    
            }
            return CatchResponse::success($data);
        }else{
            return CatchResponse::fail($res['message']);
        }
        
       

        
        
    }

    
    /**
     * 查询相关建筑信息
     * @time 2021年05月18日 10:15
     * @param Request $request 
     */
    public function queryBuildingInfo(Request $request) : \think\Response
    {
        $params=$request->param();
      
        $building_id=Db::table('station')->where('station_mac',$params['station_mac'])->value('building_id');
        $build_info=Db::table('kq_building')->where('id',$building_id)->find();
        $student_info=Db::table('users')->where('active_rfid',$params['active_rfid'])->find();
        $res=array('build_info'=>$build_info,'student_info'=>$student_info);
        return CatchResponse::success($res);
    }

     /**
     * 查询告警相关围栏信息
     * @time 2021年05月18日 10:15
     * @param Request $request 
     */
    public function queryAlarmFenceList(Request $request) : \think\Response
    {
        $params=$request->param();
        $record=$params['record'];
        $fence_list=array();
        $alarm_list=$record['alarm_reason_list'];
        foreach($alarm_list as $val){
            $fence_id=Db::table('alarm_report')
                ->where('device_number',$record['imei'])
                ->where('alarm_type',$val['value'])
                ->order('id', 'desc')
                ->value('fence_id');

            if($fence_id){
                $fence_info=$this->fencesModel->where('id',$fence_id)->append(['type_name','in_fence_time_area_text','out_fence_time_area_text','department_name','level'])->find();
                if($fence_info){
                    //$fence_info['department_name']=Db::table('departments')->where('id',$fence_info['departments'])->value('department_name');
                    $fence_list[]=$fence_info;
                }
                
            }
        }

        return CatchResponse::success($fence_list);
    }
 
 
}