station-test-api/catch/api/controller/Api.php

<?php
namespace catchAdmin\api\controller;

use catchAdmin\api\service\dispose;
use catchAdmin\tag_history\model\Access;
use catchAdmin\tag_history\model\Dormitory;
use catchAdmin\tag_history\model\TagHistory;
use catchAdmin\worklocation\model\WorkRecord as ModelWorkRecord;
use catcher\base\CatchRequest as Request;
use catcher\CatchResponse;
use catcher\base\CatchController;
use Exception;
use think\facade\Cache;
use \think\facade\Db;


error_reporting(0);
class Api extends CatchController
{
    public function report()
    {
        $token = $_GET['token'];
        if (!$token || $token != '22723927C') {
            json_fail('缺少token或者token不对');
        }
        $param = json_decode(optimize_json(file_get_contents("php://input")), true);
        debug_log("上报数据",json_encode($param));
        if (json_last_error() != 0) {
            json_fail('解析异常', json_last_error_msg());
        }
        $mac = $param['mac'];
        if (empty($mac)) {
            json_fail('mac地址不存在');
        }
        $data = [];
        foreach ($param['list'] as $item) {
          // $onetime= TagHistory::where("mac",$mac)->where('lable',$item['label'])->order("id","desc")->value("time");
            $data[] = [
                'mac' => $mac,
                'lable' => $item['label'],
                'rssi' => $item['rssi'],
                'time' => $item['time'],
                'addTime' => time(),
                'move' => $item['move'],
                'step' => empty($item['step']) ? 0 : $item['step'],
                'temperature' => empty($item['temperature']) ? 0 : $item['temperature'],
                //告警
                'temperWarn' => empty($item['temperWarn']) ? 00 : $item['temperWarn'],
               // "interval_time"=>empty($onetime) ?0:($item['time']-$onetime)
            ];
        }
        $tage = new TagHistory();
        $tage->saveAll($data);
        json_success('上传成功');
    }
    //储存数据到redis
    public function redis_to_mysql(){
       
        $ues_redis=Cache::store('redis')->handler();
        $text=null;
        $testArray=[
            '884619516',
            '885907612',
            '3827256674',
            '885833308',
            '884019740',
            '884765612'
        ];
        while(1){
            $jsonData= $ues_redis->rpop("mqtt_data");
            debug_log("InAndOUT",'数据redis'.$jsonData);
            
            if(empty($jsonData)){
                debug_log("InAndOUT",'没有数据');
                sleep(1);
                continue;
                
            }
            // debug_log("InAndOUT",$jsonData);
            $data=json_decode($jsonData,true);
            // debug_log("InAndOUT",$data['cnt']);
            $time=$data['time'];
            $mac=$data['imei'];
            $list=[];
            $text=$text.$data['cnt'];
            
            if(strlen($text)<24){
                continue;
            }
           // $arr=['']
            while(strlen($text)>=24){
     
                $da=substr($text,0,24);

                $t1 = substr($da,8,2)=='00'||substr($da,8,2)=='10'||substr($da,8,2)=='01' ? true:false;
                $t2 =substr($da,10,6)=="FFFFFF"||substr($da,10,6)=="000000" ?true:false;
               
                if($t1&&$t2){
                    
                     $label= substr($da,0,8);
                     $rssi1= substr($da,16,2);
                     $rssi2= substr($da,18,2);
                     $rssi3= substr($da,20,2);
                     $rssi4= substr($da,22,2);
                     $DA=[
                        'mac' => $mac,
                        'label' =>$label,
                        'rssi1' => hexdec($rssi2),
                        'rssi2' => hexdec($rssi3),
                        'rssi3' => hexdec($rssi1),
                        'rssi4' => hexdec($rssi4),
                        'report_time'=>$time
                    ];
                    // if($DA['rssi1']==255){
                    //     $DA['rssi1']=100;
                    // }
                    // if($DA['rssi2']==255){
                    //     $DA['rssi2']=100;
                    // }
                   

                   // debug_log("InAndOUT","数据：".json_encode($DA,true));
                    //保存计算中
                    //分为8个桶
                    // $num=Hexdec($label);
                    // $Identification=$num%8;
                    // $key="buckets".$Identification;
                    // $ues_redis->rPush($key,json_encode($DA,true));
                    
                    $num=Hexdec($label);
                    $vs=false;
                    if($DA['rssi1']<255&&$DA['rssi2']<255){
                        $vs=true;
                    }

                 
                     if(in_array($num,$testArray)&&$vs&&(substr($da,8,2)=='01')){
                        
                        $testData=$DA;
                        $testData['num']=$num;
                        debug_log("label_log",json_encode($testData));
                        debug_log('label_log',$da);
                        try{
                            $dispose = new dispose($ues_redis);
                            $computedata=$dispose->computeData($DA);
                             //debug_log("InAndOUT","计算完成的数据：".json_encode($computedata,true));
                             $dispose->computeResout($computedata);
                            
                        }catch(Exception $e){
                            debug_log("InAndOUT","抛出异常".json_encode($DA,true));
                        }
                        

                     }
                   
                     $text=substr($text,24);
                }else{
                  $text=substr($text,1);
                }
         
             }
         
            // $tage = new Access();
           //  $tage->saveAll($list);
        }


    }
    public function redis_to_mysql_parea(){

        $ues_redis=Cache::store('redis')->handler();
        $text="";
        $dispose = new dispose($ues_redis);
        while(1){
            $jsonData= $ues_redis->rpop("mqtt_data_parea4rssi");
            debug_log("pare_InAndOUT",'数据redis'.$jsonData);
            
            if(empty($jsonData)){
                debug_log("pare_InAndOUT",'没有数据');
                sleep(1);
                continue;
                
            }
            // debug_log("InAndOUT",$jsonData);
            $data=json_decode($jsonData,true);
            // debug_log("InAndOUT",$data['cnt']);
            $time=$data['time'];
            $mac=$data['devId'];
            $text=$text.$data['cnt'];
            
            if(strlen($text)<24){
                continue;
            }
            $text = $this->handleMessage($text, $mac, $time, $ues_redis);

            // foreach ($jsonData as $k => $v) {
            //     $data = json_decode($v, true);
            //     $config = $this->selectHash("anbang_four_wire",$data['mac']);
            //     if(!$config){
            //         $config = [
            //             "front" => 70,
            //             "behind" => 70,
            //             "left" => 70,
            //             "right" => 70
            //         ];
            //     }else{
            //         $config = json_decode($config);
            //     }
            //     $field = "";
            //     $infos = $ues_redis->hget("parea_rfidinfos",$field);
            //     if(!$infos){
                    
            //     }
            //     //判断进出段
            //     //1。当前时间 - 上次时间 > 设定时间
            //     if( (time() - $v["time"]) > $setInt ){
            //         //推送离开
            //     }
            // }
            // sleep(2);

        }


    }
    // //http://47.114.185.186:8115/api/areaReport
// //{“mac”:”013560”,”data”:[{“label”:”258962f”,”time”:1682317268,”dirt”:2},{“label”:”258962f”,”time”:1682317268,”dirt”:1}]
//             }

    //消息处理
    public function handleMessage($text, $mac, $time, $ues_redis){
        $EXP_TIME = 20;
        $EFF_SIG_NUM = 10;
        while(strlen($text)>=24){
    
            $da=substr($text,0,24);
            $t1 = substr($da,8,2)=='00'||substr($da,8,2)=='10'||substr($da,8,2)=='01' ? true:false;
            $t2 =substr($da,10,6)=="FFFFFF"||substr($da,10,6)=="000000" ?true:false;
            
            if($t1&&$t2){
                // var_dump($text);
                $rfid= substr($da,0,8);
                $rssi1= hexdec(substr($da,16,2));
                $rssi2= hexdec(substr($da,18,2));
                $rssi3= hexdec(substr($da,20,2));
                $rssi4= hexdec(substr($da,22,2));
                // $rc1 = ($rssi1 == 255 ? 0 : 1);
                // $rc2 = ($rssi2 == 255 ? 0 : 1);
                // $rc3 = ($rssi3 == 255 ? 0 : 1);
                // $rc4 = ($rssi4 == 255 ? 0 : 1);
                $DA=[
                    'mac' => $mac,
                    'label' =>$rfid,
                    'rssi1' => $rssi1,
                    'rssi2' => $rssi2,
                    'rssi3' => $rssi3,
                    'rssi4' => $rssi4,
                    'report_time'=>$time
                ];
                
                $field = $mac."_".$rfid;
                $info = $ues_redis->hget("parea_rfidinfos",$field);
                debug_log("pare_InAndOUT","数据：".json_encode($DA,true));

                if($rssi1 ==255 && $rssi2 == 255 && $rssi3 == 255 && $rssi4 == 255){
                    debug_log("pare_InAndOUT","无效数据：".json_encode($DA,true));
                }else{
                    if(!$info){
                        $info = [
                            "mac" => $mac,
                            "id" => $rfid,
                            "firs_time" => $time,
                            "time" => $time,
                            "status" => 2,//2出状态，1进状态
                            "rssi" => [
                                [
                                    "front" => $rssi1,
                                    "behind" => $rssi2,
                                    "left" => $rssi3,
                                    "right" => $rssi4,
                                    "time" => $time
                                ]
                            ]
                        ];
                        $ues_redis->hset("parea_rfidinfos",$field, json_encode($info,true));
                        debug_log("parea_rfidinfos_redis_set_record","redis更新记录".json_encode($info,true));
                    }else{
                        $info = json_decode($info,true);

                        $config  = $ues_redis->hget("anbang_four_wire", $info["mac"]);
                        
                        if (!$config) {
                            # code...
                            $config = [
                                "front_in" => 65,
                                "behind_in" => 70,
                                "left_in" => 80,
                                "right_in" => 70,
                                "front_out" => 70,
                                "behind_out" => 75,
                                "left_out" => 82,
                                "right_out" => 70,
                                "expInt" => 20,
                                "effSigNum" => 10
                            ];     
                        }else{
                            $config = json_decode($config,true);
                        }
                        // var_dump("+++++++++++++++++",$config);
    
                        $info["time"] = $time;
                        $newRssi = [
                            "front" => $rssi1,
                            "behind" => $rssi2,
                            "left" => $rssi3,
                            "right" => $rssi4,
                            "time" => $time
                        ];
                        $rssisArr = $info["rssi"];
                        
                        // var_dump("+++++++++++++++++", $time, $newRssi["time"]);
                        
                        foreach ($rssisArr as $k => $v) {
                            # code...
                            if( ($time - $v["time"] ) > $config['expInt'] ){
                                unset($rssisArr[$k]);
                            }
                        }
                        // var_dump("+++++++++++++++++",$rssisArr);
                        if(count($rssisArr) == $config['effSigNum']){
                            array_shift($rssisArr);
                            array_push($rssisArr, $newRssi);
                        }else{
                            array_push($rssisArr, $newRssi);
                        }
                        
                        $rssisArr =array_values($rssisArr);
                        // var_dump("+++++++++++++++++",$rssisArr);
                        $info["rssi"] = $rssisArr;
    
                        // var_dump("------------",$info["rssi"]);
    
                        $cacCount = count($rssisArr);
                        // if($cacCount > $EFF_SIG_NUM){
                        $sum1 = 0;
                        $sum2 = 0;
                        $sum3 = 0;
                        $sum4 = 0;
                        foreach ($rssisArr as $k => $v) {
                            # code...
                            $sum1 += ($v["front"] == 255 ? 85 : $v["front"]);
                            $sum2 += ($v["behind"] == 255 ? 85 : $v["behind"]);
                            $sum3 += ($v["left"] == 255 ? 85 : $v["left"]);
                            $sum4 += ($v["right"] == 255 ? 85 : $v["right"]);
                        }
                        $info["avg"] = [
                            "front" => number_format( $sum1/$cacCount, 2 ),
                            "behind" => number_format( $sum2/$cacCount, 2 ),
                            "left" => number_format( $sum3/$cacCount, 2 ),
                            "right" => number_format( $sum4/$cacCount, 2 ),
                        ];
    
                        if ($cacCount == $EFF_SIG_NUM) {
                            # code...
                           $info = $this->compAndPush($info ,$config);
                        }
                        $ues_redis->hset("parea_rfidinfos",$field, json_encode($info,true));
                        
                        debug_log("parea_rfidinfos_redis_set_record","redis更新记录".json_encode($info,true));
                    }
                }


                $text=substr($text,24);
            }else{
                $text=substr($text,1);
            }
        }
        return $text ?$text : "";
    }
    //判断进出和推送
    public function compAndPush($info, $config ){
        //标签多，数据多时候,判断完成后放入redis，异步推送，当前暂时直接推

        // $config  = $ues_redis->hget("anbang_four_wire", $info["mac"]);
        
        //{"front_in":44,"front_out":44,"behind_in":50,"behind_out":50,"left_in":55,"left_out":55,"right_out":44,"right_out":44}

        

        $avg = $info['avg'];
        $status = $info['status'];

        $flagIn = $avg["front"] < $config["front_in"] || $avg["behind"] < $config["behind_in"] || $avg["left"] < $config["left_in"] || $avg["right"] < $config["right_in"];
        $flagOut = $avg["front"] > $config["front_out"] && $avg["behind"] > $config["behind_out"] && $avg["left"] > $config["left_out"] && $avg["right"] > $config["right_out"];

        $url="http://47.114.185.186:8115/api/areaReport";
        if($flagIn && $status == 2){
            //推送进
            $info['status'] = 1;
            $url_data = [
                "mac" => $info["mac"],
                "data" => [
                    [
                        "label" => $info["id"],
                        "time" => $info["time"],
                        "dirt" => 1
                    ]
                ]
            ];
            debug_log("pushPareaRes","进推送依赖:".json_encode($info));
            $url_res= curl_http_post(json_encode($url_data),$url,false);
            
            debug_log("pushPareaRes","远程返回结果".$url_res);
        }
        // if($info['id'] == "E2B15AD5"){
        //     var_dump($flagIn, $flagOut, $status, $avg["front"],$avg["behind"],$avg["left"], $avg["right"]);
        // }
        if($flagOut && $status == 1){
            //推送出
            $info['status'] = 2;
            $url_data = [
                "mac" => $info["mac"],
                "data" => [
                    [
                        "label" => $info["id"],
                        "time" => $info["time"],
                        "dirt" => 2
                    ]
                ]
            ];
            debug_log("pushPareaRes","出推送依赖:".json_encode($info));
            $url_res= curl_http_post(json_encode($url_data),$url,false);
            
            debug_log("pushPareaRes","远程返回结果".$url_res);
        }
        return $info;
    }

    // $url="http://47.114.185.186:8115/api/accessReport";
    // $url_res= curl_http_post(json_encode($url_data),$url,false);
    // debug_log("InAndOUT","远程返回结果".$url_res);

   
    public function test(){
        
        try{
            $ues_redis=Cache::store('redis')->handler();
            $jsonData= $ues_redis->rpop("mqtt_data");
            debug_log("InAndOUT","1212");
        }catch(Exception $e){
            var_dump($e->getMessage());
        }
    
    }
















    /**
     * 删除前1天的数据
     *
     * @return void 
     */
    public function deleteHistory()
    {
        while(true)
        {
           
            $where[] = ['addTime','<',strtotime("-1 day")];
            Db::name('tag_history')->where($where)->delete();
            sleep(60*60*24);
        }
    
    }

    

    /**
     * 检测小程序版本版本 function
     *
     * @return void
     */
    public function detectionVersion(){
        $token = $_GET['token'];
        if (!$token || $token != '444333d3') {
            json_fail('缺少token或者token不对');
        }
        $data["url"]="http://116.62.220.88:8112/static/app/蓝牙小程序/1.1.1/rl-release.apk";
        $data["version"]="1.1.1";
        json_success("查询版本成功",$data);
    }
    






}