SwooleCommandMeTcpController.php

<?php

namespace App\Http\Controllers\Auth;

use Illuminate\Support\Facades\DB;
use App\Laravue\Models\Users;
use Illuminate\Http\Request;
use App\Http\Controllers\Controller;
use Illuminate\Support\Facades\Redis;
use App\Http\Controllers\DevicesController;

class  SwooleCommandMeTcpController extends Controller
{
    //获取tcp链接返回数据 //进去redis
    public function swooletcplist($data = '')
    {
        if ($data != '') {
            $datadevice = $this->stringdata($data);
            Redis::set('dbtype',0);
            if(Redis::get('sbjc:' . $datadevice[0]) == ''){
                Redis::set('sbjc:' . $datadevice[0], $data);
                $this->dbdevice($this->stringdata($data));
            }else if (Redis::get('sbjc:' . $datadevice[0]) != $data){
                $this->dbdevice($this->stringdata($data));
                Redis::set('sbjc:' . $datadevice[0], $data);
            }
            Redis::lpush('police',$data);
            $this->police();
        }
        $dalen = Redis::llen('Devicesdata');//返回队列长度
        if ($dalen > 5000 ) { //当队列值达到巅峰以后切换数据库
            Redis::select(1);//使用备用数据库//释放主数据库
            Redis::set('dbtype',1);
            $this->deleteDbRedis();
        }

        if($dalen > 5000 && Redis::get('dbtype') == 1){
            Redis::select(0);
            Redis::set('dbtype',0);
            $this->deleteDb();
        }
    }

    //分割字符串
    private function stringdata($data = ''): array
    {
        if ($data != '') {
            return explode('/', $data);
        }
    }

    //查询redis所有的值
    private function devicedata(): array
    {
        $keys = Redis::keys("*");//获取所有的键
        $data = Redis::mget($keys);//获取所有的键的值
        $arrdata = [];
        foreach ($data as $key => $vel) {
            $expdata = explode('/', $vel);
            array_push($arrdata, $expdata);
        }
        return $arrdata;
    }
    //清楚指定数据库 redis
    private function deleteDbRedis (){
        Redis::select(0);
        Redis::flushdb();
        Redis::select(1);
    }

    private function deleteDb(){
        Redis::select(1);
        Redis::flushdb();
        Redis::select(0);
    }

    //查询出返回值
    private function dbdevice($data = [])
    {
        $Devices = new DevicesController();
        if ($data != []) {
            $devicedata = DB::table('device as d')
                ->where('d.devicenum', '=', $data[0])
                ->leftjoin('device_type as t', 't.tid', '=', 'd.dtype')
                ->leftjoin('gas as g', 'g.id', '=', 'd.status')
                ->leftjoin('danwei as c', 'c.id', '=', 'd.devicemonad')
                ->leftjoin('status as s', 's.id', '=', 'd.devicepolice')
                ->select('d.devicenum', 'd.username', 'd.deviceremark', 'd.devicelinkman', 'd.devicephone', 'd.deviceinfo', 't.tname', 'g.gas', 'c.danwei', 's.status_name')
                ->first();
            if($devicedata != ''){
                Redis::lPush('Devicesdata', serialize($devicedata));//进入队列进行
            }
        }
    }

    //处理报警
    private function police()
    {
        $davicedata = $this->stringdata(Redis::lpop('police'));
//        处理发送数据报警
        $isdavice = DB::table('reportpolice')
            ->where('devicenumber', '=', $davicedata[0])
            ->select('status', 'endtime')
            ->first();
        $type = json_decode(json_encode($isdavice), true);

        //设备再次报警
        if ($type['endtime'] != '' && $type['status'] == 2 && $davicedata[1] != 1){
            $up = DB::table('reportpolice')
                ->where('devicenumber', '=', $davicedata[0])
                ->update(['endtime'=>'','status' => 1,'policestatus'=> $davicedata[1],'concentration' => $davicedata[2]]);
        }
        if($type['status'] == 1 && $type['endtime'] == '' && $davicedata[1] == 1){
            $up = DB::table('reportpolice')
                ->where('devicenumber', '=', $davicedata[0])
                ->update(['endtime'=>time(),'status' => 2,'policestatus'=> $davicedata[1]]);
        }
        if ($isdavice) {
            //改成报警状态
            if ($davicedata[1] != 1 && $type['endtime'] == '') {
                $up = DB::table('reportpolice')
                    ->where('devicenumber', '=', $davicedata[0])
                    ->update(['concentration' => $davicedata[2], 'policestatus' => $davicedata[1], 'status' => 1]);
            }
        } else {
            if ($davicedata[1] != 1) {
                $add = DB::table('reportpolice')
                    ->insertGetId(['devicenumber' => $davicedata[0], 'starttime' => time(), 'concentration' => $davicedata[2], 'policestatus' => $davicedata[1], 'status' => 1]);
            }

        }
        $updavice = DB::table('device')
            ->where('devicenum', '=', $davicedata[0])
            ->update(['devicepolice' => $davicedata[1], 'nd' => $davicedata[2]]);
    }
}