likang

catch/api/controller/Api.php

@@ -146,7 +146,6 @@ class Api extends CatchController
                         }catch(Exception $e){
                             debug_log("InAndOUT","抛出异常:".$e->getMessage());
                         }
-
                      }
                    
                      $text=substr($text,24);
@@ -162,12 +161,6 @@ class Api extends CatchController
 
     }
 
-
-
-
-
-
-
     /**
      * 清除数据
      *
@@ -206,7 +199,7 @@ class Api extends CatchController
                         $a=$json_data['a'];
                         //状态
                         $status=$json_data['status'];
-                        //进出
+                        //是否形成进出考勤
                         $in_and_out=$json_data["in_and_out"];
                        
                         //总数
@@ -224,22 +217,10 @@ class Api extends CatchController
                                 debug_log("clear_label", $item.':'. "标签信号个数等于超过2个,参与计算");
                                 $frist=$a[0]['dirt'];
                                 $end=$a[$count-1]['dirt'];
+
                                 if($frist!=$end){
-                                    $data_array=[];
-                                    $data_array[]=[
-                                        "label"=>$item,
-                                        'time'=>$a[$count-1]['time'],
-                                        'dirt'=> $frist==1?1:2 //1是进 2是出
-                                    ];
-                                    $url_data=[
-                                        "mac"=>$station,
-                                        "data"=>$data_array
-                                    ];
                                     debug_log("clear_label", $item.':'. "标签信号个数等于超过2个,参与计算,得出结果:".$frist);
-
-                                    $dispose->set_time_results($station,$item,$a[$count-1]['time'],$frist==1?1:2);
-                                    $dispose->getRemoteData($url_data);
-                                    debug_log("clear_label","发送给远程".json_encode($url_data));
+                                    $dispose->network_push($station,$item,$a[$count-1]['time'],$frist==1?1:2);
                                 }else{
                                     debug_log("clear_label", $item.':'. "标签信号个数没有超过2个,全部去清除");
                                 }
@@ -274,31 +255,12 @@ class Api extends CatchController
     
                             if($status['dirt']!=$res){
                                 debug_log("clear_label", $item.':'. "最后一个信号,方向相反,得出结果,清除缓存数据");
-                                $redis->hdel($key,$item);
-                                $data_array=[];
-                                $data_array[]=[
-                                    "label"=>$item,
-                                    'time'=>$a[$count-1]['time'],
-                                    'dirt'=> $status['dirt']==1?1:2 //1是进 2是出
-                                ];
-                                $url_data=[
-                                    "mac"=>$station,
-                                    "data"=>$data_array
-                                ];
-                                //设置key
-                                $dispose->set_time_results($station,$item,$a[$count-1]['time'],$status['dirt']==1?1:2);
-                                // debug_log("InAndOUT","得出计算结果：".json_encode($arr));
-                                debug_log("clear_label","发送给远程".json_encode($url_data));
-                                //远程推送
-                               $dispose->getRemoteData($url_data);
-                           
-                             
+
+                                $dispose->network_push($station,$item,$a[$count-1]['time'],$status['dirt']==1?1:2);
+
                             }else{
                                 //上午不做二次计算
                                 if(empty($in_and_out)){
-                                    //二次生成结果
-                                    
-                                    
                                     $res=$dispose->second_create_direction($station,$item);
                                     if(!empty($res)){
                                         $res_time= $dispose->get_time_results($station,$item);
@@ -308,24 +270,26 @@ class Api extends CatchController
                                         //判断如果结果超过时间
                                         if($diff_time>10){
                                             debug_log("clear_label", $item.':'. "二次生成进出");
-                                            $data_array=[];
-                                            $data_array[]=[
-                                                "label"=>$item,
-                                                'time'=>$res['time'],
-                                                'dirt'=>$res['dirt'],
-                                            ];
-                                            $url_data=[
-                                                "mac"=>$station,
-                                                "data"=>$data_array
-                                            ];
-                                            debug_log("clear_label","二次生成发送给远程".json_encode($url_data));
-                                            //远程推送时间
-                                            $dispose->set_time_results($station,$item,$res['time'],$res['dirt']);
-                                            //远程推送
-                                            $dispose->getRemoteData($url_data);
 
+                                            $dispose->network_push($station,$item,$res['time'],$res['dirt']);
                                         }
 
+                                    }else{
+                                        //存入没有生成考勤时的初始防线
+                                        //获取朝前的最大值
+                                        //获取朝后的最大值
+                                        $frontMax=  $dispose->get_label_history(4,$station,$item);
+                                        $backMax=  $dispose->get_label_history(5,$station,$item);
+                                        $records=false;
+                                        if($status['dirt']==1){
+                                            $records=$frontMax<65;
+                                        }
+                                        if($status['dirt']==2){
+                                            $records=$backMax<65;
+                                        }
+                                        if($records){
+                                            $dispose->no_check_data($station,$item,$status['dirt'],$a[$count-1]['time'],1);
+                                        }
                                     }
 
                                 }
@@ -392,14 +356,6 @@ class Api extends CatchController
     }
 
 
-
-
-
-
-
-
-
-
     public function redis_to_mysql_parea(){
 
         $ues_redis=Cache::store('redis')->handler();
@@ -426,40 +382,41 @@ class Api extends CatchController
                 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);
+    }
 
-        }
+    public function redis_to_mysql_indoor(){
 
+        $ues_redis=Cache::store('redis')->handler();
+        $text="";
+        $dispose = new dispose($ues_redis);
+        while(1){
+            $jsonData= $ues_redis->lpop("mqtt_data_indoor4rssi");
+            debug_log("indoor_InAndOUT",'mqtt数据redis'.$jsonData);
+            
+            if(!$jsonData){
+                debug_log("indoor_InAndOUT",'mqtt没有数据');
+                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;
+            }
+            // var_dump("before",microtime());
+            $text = $this->handleMessageIndoor($text, $mac, $time, $ues_redis);
+            // var_dump("after",microtime());
+        }
 
     }
-    // //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 temporary_label_log(){
@@ -530,7 +487,7 @@ class Api extends CatchController
 //   }
 
 
-    //消息处理
+    //消息处理--重点区域
     public function handleMessage($text, $mac, $time, $ues_redis){
         while(strlen($text)>=24){
     
@@ -679,6 +636,230 @@ class Api extends CatchController
         }
         return $text ?$text : "";
     }
+    //消息处理--室内
+    public function handleMessageIndoor($text, $mac, $time, $ues_redis){
+        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));
+ 
+                $DA=[
+                    'mac' => $mac,
+                    'label' =>$rfid,
+                    'rssi1' => $rssi1,
+                    'rssi2' => $rssi2, 
+                    'rssi3' => $rssi3,
+                    'rssi4' => $rssi4,
+                    'report_time'=>$time
+                ];
+                
+                $field = $mac."_".$rfid;
+                $info = $ues_redis->hget("indoor_rfidinfos",$field);
+                debug_log("indoor_InAndOUT","数据：".json_encode($DA,true));
+
+                if($rssi1 ==255 && $rssi2 == 255 && $rssi3 == 255 && $rssi4 == 255){
+                    debug_log("indoor_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("indoor_rfidinfos",$field, json_encode($info,true));
+                        debug_log("indoor_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" => 80,
+                                "behind_in" => 80,
+                                "left_in" => 80,
+                                "right_in" => 80,
+                                "front_out" => 255,
+                                "behind_out" => 255,
+                                "left_out" => 255,
+                                "right_out" => 255,
+                                "expInt" => 12,
+                                "effSigNum" => 6
+                            ];     
+                        }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 ? 90 : $v["front"]);
+                            $sum2 += ($v["behind"] == 255 ? 90 : $v["behind"]);
+                            $sum3 += ($v["left"] == 255 ? 90 : $v["left"]);
+                            $sum4 += ($v["right"] == 255 ? 90 : $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 ),
+                        ];
+                        // var_dump($cacCount, $EFF_SIG_NUM, "dddddddd");
+                        if ($cacCount == $config['effSigNum']) {
+                            # code...
+                           $info = $this->compAndPushIndoor($info ,$config, $ues_redis);
+                        }
+                        $ues_redis->hset("indoor_rfidinfos",$field, json_encode($info,true));
+                        
+                        debug_log("indoor_rfidinfos_redis_set_record","redis更新记录".json_encode($info,true));
+                    }
+                }
+
+
+                $text=substr($text,24);
+            }else{
+                $text=substr($text,1);
+            }
+        }
+        return $text ?$text : "";
+    }
+    //判断进出和推送--室内考勤
+    public function compAndPushIndoor($info, $config, $ues_redis){
+        //标签多，数据多时候,判断完成后放入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://localhost:8115/api/api/accessClassReport";
+        // $url="http://61.175.203.188:10001/api/accessClassReport";
+        // if($flagIn && $status == 2){
+        if($flagIn){
+            if ($info["pushTime"] &&  (time()-$info['pushTime']) < 3 ) { 
+                # code...
+                return $info;
+            }
+            //推送进
+            $info['status'] = 1;
+            
+            $url_data = [
+                "mac" => $info["mac"],
+                "data" => [
+                    [
+                        "label" => $info["id"],
+                        "time" => $info["time"],
+                        "dirt" => 1,
+                        "rssi" => $info["rssi"],//数组 [{"front":72,"behind":255,"left":255,"right":255,"time":1685067709},{"front":76,"behind":255,"left":255,"right":255,"time":1685067710}]
+                        "avg" => $info["avg"] //{"front":"77.17","behind":"90.00","left":"90.00","right":"90.00"}
+                    ]
+                ]
+            ];
+            $ues_redis->lpush("indoor_inoutres_push", json_encode($url_data));
+
+            $info['pushTime'] = time();
+            // debug_log("push_indoor_res","进推送依赖:".json_encode($info));
+            // $url_res= curl_http_post(json_encode($url_data),$url,false);
+            // debug_log("push_indoor_res","远程返回结果".$url_res);
+        }
+        // if($info['id'] == "E2B15AD5"){
+        //     var_dump($flagIn, $flagOut, $status, $avg["front"],$avg["behind"],$avg["left"], $avg["right"]);
+        // }
+        if($flagOut && $status == 1){
+            if ($info["pushTime"] &&  (time()-$info['pushTime']) < 5 ) {
+                # code...
+                return $info;
+            }
+            //推送出
+            $info['status'] = 2;
+            $url_data = [
+                "mac" => $info["mac"],
+                "data" => [
+                    [
+                        "label" => $info["id"],
+                        "time" => $info["time"],
+                        "dirt" => 2,
+                        "rssi" => $info["rssi"],//数组 [{"front":72,"behind":255,"left":255,"right":255,"time":1685067709},{"front":76,"behind":255,"left":255,"right":255,"time":1685067710}]
+                        "avg" => $info["avg"] //{"front":"77.17","behind":"90.00","left":"90.00","right":"90.00"}
+                    ]
+                ]
+            ];
+            $ues_redis->lpush("indoor_inoutres_push", json_encode($url_data));
+            // debug_log("push_indoor_res","出推送依赖:".json_encode($info));
+            // $url_res= curl_http_post(json_encode($url_data),$url,false);
+            $info['pushTime'] = time();
+            
+            // debug_log("push_indoor_res","远程返回结果".$url_res);
+        }
+        return $info;
+    }
+    
     //判断进出和推送
     public function compAndPush($info, $config ){
         //标签多，数据多时候,判断完成后放入redis，异步推送，当前暂时直接推
@@ -698,7 +879,7 @@ class Api extends CatchController
         
         $url="http://localhost:8115/api/areaReport";
         if($flagIn && $status == 2){
-            if ($info["pushTime"] &&  (time()-$info['pushTime']) < 5 ) {
+            if ($info["pushTime"] &&  (time()-$info['pushTime']) < 5 ) { 
                 # code...
                 return $info;
             }
@@ -771,27 +952,6 @@ class Api extends CatchController
 
 
 
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
     /**
      * 删除前1天的数据
      *

catch/api/route.php

@@ -37,6 +37,7 @@ $router->get('api/remote_push', '\catchAdmin\api\controller\Api@remotePush');
 //打印日志
 $router->get('api/temporary_label_log', '\catchAdmin\api\controller\Api@temporary_label_log');
 $router->get('api/redis_parea', '\catchAdmin\api\controller\Api@redis_to_mysql_parea');
+$router->get('api/redis_indoor', '\catchAdmin\api\controller\Api@redis_to_mysql_indoor');
 
 //更新软件版本测试
 //$router->get('api/detectionVersion', '\catchAdmin\api\controller\Api@detectionVersion');

catch/api/service/dispose.php

@@ -140,7 +140,9 @@ class dispose
                 $status['dirt']= $res;
                 $status['time']= $resArray['time'];
                 debug_log("InAndOUT","初始化状态为：".json_encode($status));
+
             }else{
+                $this->no_check_data($data['mac'],$data['label'],$status['dirt'],$time,2);
                 //判断是否连贯
                $IS_OK=true;
                $res=0;
@@ -154,24 +156,12 @@ class dispose
             
                 //进行保存
                 if($res!=$status['dirt']&&$IS_OK){
-                            $data_array=[];
-                            $data_array[]=[
-                                "label"=>$data['label'],  
-                                'time'=>$resArray['time'],
-                                'dirt'=> $status['dirt']==1?1:2 //1是进 2是出
-                            ];
+
                             $inAndOut=$status['dirt']==1?1:2;
-                            $url_data=[
-                                "mac"=>$data['mac'],
-                                "data"=>$data_array
-                            ];
-                            //设定最后结果
-                            $this->set_time_results($data['mac'],$data['label'],$resArray['time'],$inAndOut);
-                            //推送远程数据
-                            $this->getRemoteData($url_data);
-                            //清除缓存数据
+                           //网络推送
+                            $this->network_push($data['mac'],$data['label'],$resArray['time'],$inAndOut);
+                            //清除历史记录
                             $this->get_label_history(3,$data['mac'],$data['label']);
-                            $this->temporary_label($this->redis,$data['label'],2);
                           $status['dirt']=$res;
                           $status['time']=$time;
 
@@ -196,6 +186,67 @@ class dispose
 
     }
 
+    /**
+     * 用于记录 没有生成考勤的数据信息
+     * @param $mac    基站
+     * @param $lable  标签
+     * @param $dir  1 外面  2 里面
+     * @param $type  1 存入 2获取,3 清除
+     * @param $time  时间戳
+     * @return void
+     */
+    public function no_check_data($mac,$lable,$dir=0,$time=null,$type){
+        $HASH_KEY=$mac."_no_check";
+        $KEY=$lable;
+        if($type==1){
+            debug_log("没有生成考勤",$mac." ".$lable."初始方向：$dir.时间.$time");
+            $frontMax=  $this->get_label_history(4,$mac,$lable);
+            $backMax=  $this->get_label_history(5,$mac,$lable);
+            $records=false;
+            debug_log("没有生成考勤",$mac." ".$lable."初始方向：$dir.时间.$time.前面最小值：$frontMax.里面最小值.$backMax");
+            if($dir==1){
+                $records=$frontMax<65;
+            }
+            if($dir==2){
+                $records=$backMax<65;
+            }
+            if($records){
+                debug_log("没有生成考勤",$mac." ".$lable."初始方向：$dir.时间.$time.存入redis");
+                $this->setHash( $HASH_KEY,$KEY,["time"=>$time,"dir"=>$dir]);
+            }
+
+        }
+        if($type==2){
+            $data= $this->selectHash($HASH_KEY,$KEY);
+            if(empty($data)){
+                return false;
+            }else{
+                debug_log("没有生成考勤","$mac.=======.$lable.新初始方向确定.$dir.原来方向确定.".$data["dir"] );
+
+                if($data["dir"]!=$dir){
+                    if($dir==1){
+                        $frontMax=  $this->get_label_history(4,$mac,$lable);
+                        if($frontMax<65){
+                            debug_log("没有生成考勤","$mac.=======.$lable.新初始方向确定.$dir.原来方向确定.".$data["dir"]."生成进出 2");
+                            $this->network_push($mac,$lable,$data["time"],2);
+                        }
+
+                    }else{
+                        $backMax= $this->get_label_history(5,$mac,$lable);
+                        if($backMax<65){
+                            debug_log("没有生成考勤","$mac.=======.$lable.新初始方向确定.$dir.原来方向确定.".$data["dir"]."生成进出 1");
+                            $this->network_push($mac,$lable,$data["time"],1);
+                        }
+
+                    }
+                }
+            }
+        }
+        if($type==3){
+            $this->delHash($HASH_KEY,$KEY);
+        }
+
+    }
 
 
     //获取所有基站
@@ -219,48 +270,9 @@ class dispose
         $key=$this->stations;
         $this->redis->hSet($key,$Stations,$time);
     }
-  
 
-    //排序
-    // public function sortlist($list){
-    //     $list01=[];
-    //     $list02=[];
-    //     $list03=[];
-    //     $list04=[];
-    //     debug_log("InAndOUT","排序的数据:".json_encode($list));
-    //     foreach($list as $item){
-    //        array_push($list01,$item['rssi1']);
-    //        array_push($list02,$item['rssi2']);
-    //        array_push($list03,$item['rssi3']);
-    //        array_push($list04,$item['rssi4']);
-    //     }
-
-    //     if(count($list)>=3){
-    //         sort($list01);
-    //         sort($list02);
-    //         sort($list03);
-    //         sort($list04);
-    //         array_pop($list01);
-    //         array_pop($list02);
-    //         array_pop($list03);
-    //         array_pop($list04);
-    //         array_shift($list01);
-    //         array_shift($list02);
-    //         array_shift($list03);
-    //         array_shift($list04);
-    //     }
-    //     debug_log("InAndOUT","排序后的队列:".json_encode($list01));
-    //     debug_log("InAndOUT","排序后的队列:".json_encode($list02));
-    //     debug_log("InAndOUT","排序后的队列:".json_encode($list03));
-    //     debug_log("InAndOUT","排序后的队列:".json_encode($list04));
-    //     $rssi1= array_sum($list01)/count($list01);
-    //     $rssi2= array_sum($list02)/count($list02);
-    //     $rssi3= array_sum($list03)/count($list03);
-    //     $rssi4= array_sum($list04)/count($list04);
-    //     $res=[$rssi1,$rssi2,$rssi3,$rssi4];
-    //     debug_log("InAndOUT","结算后的结果:".json_encode($res));
-    //     return $res;
-    // }
+
+
 /**
  * 获取远程推送的数据
  *
@@ -373,10 +385,45 @@ public function get_label_history($type,$mac,$label){
         return $backMax;
     }
 
+}
+
+    /**
+     * @param $mac
+     * @param $label
+     * @param $time
+     * @param $dir  1 进 ,2 出
+     * @return void
+     */
+    public function  network_push($mac,$label,$time,$dir)
+    {
+        $data_array=[];
+        $data_array[]=[
+            "label"=>$label,
+            'time'=>$time,
+            'dirt'=>$dir,
+        ];
+        $url_data=[
+            "mac"=>$mac,
+            "data"=>$data_array
+        ];
+        debug_log("clear_label","二次生成发送给远程".json_encode($url_data));
+        //远程推送时间
+        $this->set_time_results($mac,$label,$time,$dir);
+        $this->no_check_data($mac,$label,null,null,3);
+        //远程推送
+        $this->getRemoteData($url_data);
+
+    }
+
+
+
+
+
+
+
 
 
 
-}
 /**
  * 二次生成进出
  *
@@ -574,20 +621,7 @@ public function get_station_config($mac){
 
 
 
-    public function temporary_label($redis,$label,$type){
 
-        return;
-        $key="temporary_label";
-        if($type==1){
-            $res= $redis->hGet($key,$label);
-            if($res==false){
-                $redis->hSet($key,$label,1);
-            }
-        }else{
-            $redis->hSet($key,$label,2);
-        }
-
-    }
     /**
      * 解析日志
      */

task_script/INDOOR_INOUTRES_PUSH.php

@@ -0,0 +1,281 @@
+<?php
+require('../vendor/autoload.php');
+use \PhpMqtt\Client\MqttClient;
+use \PhpMqtt\Client\ConnectionSettings;
+use think\facade\Cache;
+date_default_timezone_set("PRC");
+define('HOST', '127.0.0.1');
+define('PORT', '6379');
+define('PASSWORD', 'R!478gH*%23nPn');
+// define('PASSWORD', '123456');
+define('DATABASE', 2);
+
+
+function app_redis()
+{
+    static $redis = null;
+    static $conn = false;
+    if (!$conn) {
+        connect: //定义标签
+        $redis = new Redis();
+        try {
+            //建立的Redis短连接,在请求结束后不会自动关闭,相当于持久连接.
+            $conn = $redis->connect(HOST, PORT);
+            $conn = $redis->auth(PASSWORD);
+            $conn = $redis->select(DATABASE);
+            // 连接成功,返回$redis对象,连接失败,返回false.
+            return ($conn === true) ? $redis : false;
+        } catch (Exception $e) {
+            return false;
+        }
+    } else {
+        // 这里假设PHP-FPM在处理一个请求的时间内,Redis连接都是可用的.
+        // 所以只在PHP-CLI下检查Redis连接的状态,进行断线重连.
+        if (php_sapi_name() === 'cli') {
+            try {
+                // ping用于检查当前连接的状态,成功时返回+PONG,失败时抛出一个RedisException对象.
+                // ping失败时警告:
+                // Warning: Redis::ping(): connect() failed: Connection refused
+                // var_dump('AAAAAAAAA', $redis);
+                echo 'Redis 连接状态' . $redis->ping() . PHP_EOL;
+                @$redis->ping();
+                if (!$redis->ping()) {
+                    goto connect; //跳转到标签出继续执行连接操作
+                }
+            } catch (Exception  $e) {
+                // 信息如 Connection lost 或 Redis server went away
+                echo $e->getMessage();
+                echo 'Redis 连接失败 重新连接：' . PHP_EOL;
+                // 断线重连
+                goto connect;
+            }
+        }
+        return $redis;
+    }
+}
+
+function rlog(...$args)
+{
+    if (empty($args[0])) {
+        return;
+    }
+    static $LOG_CONSOLE = false; //是否输出到控制台
+    static $LOG_NAME = "indoor_inoutres_push.log"; //值为空时 不写入文件
+    static $LOG_SIZE = 64 * 1024 * 1024; //文件最大尺寸
+
+    static $LOG_CACHE = false; //是否缓存日志内容 用于批量写入文件
+    static $CACHE_DURATION = 10; //缓存最大时间 秒
+    static $CACHE_SIZE = 1024; //缓存大小
+    static $cacheStartTime = 0;
+    static $cacheBuf = '';
+
+    static $LOG_TIMES = 10; //调用这个函数最大次数 超过次数后判断下文件大小
+    static $logCount = 0;
+
+
+    $buf = '';
+    if (count($args) == 1 && $args[0] == "\n") { //只有换行时 不写入时间戳了
+        $buf = "\n";
+    } else {
+        $pid = ''; //进程id
+        if (function_exists('posix_getpid')) {
+            $pid = ' ' . posix_getpid() . ' ';
+        }
+        $fileLine = ''; //文件名:行号
+        {
+            $debug = debug_backtrace();
+            $fileLine = ($pid == '' ? ' ' : '') . basename($debug[0]['file']) . ':' . $debug[0]['line'] . ' ';
+        }
+        $buf = date("y-m-d H:i:s") . "{$pid}{$fileLine}" . implode(' ', $args) . "\n";
+    }
+
+    $logCount++;
+    if (!empty($LOG_NAME)) {
+        if ($LOG_CACHE) {
+            $cacheBuf .= $buf;
+            //超过缓存尺寸 或者 超过缓存时长 写缓存到文件
+            if (strlen($cacheBuf) > $CACHE_SIZE || time() - $cacheStartTime > $CACHE_DURATION) {
+                $cacheStartTime = time();
+                goto write;
+            } else {
+                goto skipWrite;
+            }
+        } else {
+            $cacheBuf = $buf;
+        }
+        write: {
+            //超过尺寸后 删除旧文件 把新文件重命名为旧文件  多进程同时操作 不加锁问题不大
+            if ($logCount > $LOG_TIMES && filesize($LOG_NAME) > $LOG_SIZE) {
+                $oldLogName = $LOG_NAME . '.old';
+                if (file_exists($oldLogName)) {
+                    if (!unlink($oldLogName)) {
+                        echo "unlink err\n";
+                    }
+                }
+                if (!rename($LOG_NAME, $oldLogName)) {
+                    echo "rename err\n";
+                }
+                $logCount = 0;
+            }
+            if (!file_put_contents($LOG_NAME, $cacheBuf, FILE_APPEND)) {
+                echo "file_put_contents err\n";
+            }
+            $cacheBuf = '';
+        }
+        skipWrite: {
+        }
+    }
+    if ($LOG_CONSOLE) {
+        echo $buf;
+    }
+}
+
+function http($url, $params, $header = [], $method = 'GET', $timeout = 10)
+{
+    // POST $params 字符串形式query=abcd&abc=12345
+    //GET $params 数组['query' => 'abcd', 'abc' => 12345]
+    //  $header[] = "Content-Type: application/x-www-form-urlencoded";
+    //  $header[] = "Content-Type: application/soap+xml; charset=utf-8";
+    //  $header[] = "Content-Type: application/json; charset=utf-8";
+    //  $header[] = "Expect: ";
+    rlog("[HTTP] url:$url,method:$method" . ",header:" . json_encode($header));
+    if (strtoupper($method) == 'POST') {
+        rlog("[POST] send params " . (!is_array($params) ? $params : json_encode($params, JSON_UNESCAPED_UNICODE)));
+    } else {
+        rlog("[GET] send " . json_encode($params));
+    }
+    $header[] = "Expect: ";
+    $opts = array(
+        CURLOPT_TIMEOUT => $timeout,
+        CURLOPT_RETURNTRANSFER => 1,
+        CURLOPT_SSL_VERIFYPEER => false,
+        CURLOPT_SSL_VERIFYHOST => false,
+        CURLOPT_HTTPHEADER => $header
+    );
+
+    /* 根据请求类型设置特定参数 */
+    switch (strtoupper($method)) {
+        case 'GET':
+            $opts[CURLOPT_URL] = $url . (empty($params) ? '' : ('?' . http_build_query($params)));
+            break;
+        case 'POST':
+            //$params = http_build_query($params);
+            $opts[CURLOPT_URL] = $url;
+            $opts[CURLOPT_POST] = 1;
+            $opts[CURLOPT_POSTFIELDS] = json_encode($params);
+            break;
+        default:
+            rlog("[ERR] method " . $method);
+            return false;
+    }
+
+    global $ch; //curl长连接
+    if (empty($ch)) {
+        $ch = curl_init();
+    }
+    if (empty($ch)) {
+        rlog("[ERR] curl_init");
+        return false;
+    }
+
+    $csa = curl_setopt_array($ch, $opts);
+    if (empty($csa)) {
+        rlog("[ERR] curl_setopt_array");
+        return false;
+    }
+
+    $data = curl_exec($ch);
+    if ($data === false) {
+        rlog("[ERR] curl_exec errno:" . curl_errno($ch) . " " . curl_error($ch));
+        return false;
+    }
+    //unicode转中文
+    $data = decodeUnicode($data);
+    rlog("[HTTP] recv " . $data);
+    //curl_close($ch);
+    return $data;
+}
+function decodeUnicode($str)
+{
+    return preg_replace_callback('/\\\\u([0-9a-f]{4})/i', function ($matches) {
+        return iconv("UCS-2BE", "UTF-8", pack("H*", $matches[1]));
+    }, $str);
+}
+
+
+
+// while (true) {
+//     try {
+//         rlog('INFO', 'task start');
+
+//         $infos = app_redis()->hgetall("indoor_inoutres_push");
+//         foreach ($infos as $k => $v) {
+//             # code...
+//             $data = json_decode($v, true);
+//             if ( (time() - $data["time"] ) > $offlineInt ) {
+//                 # code...
+//                 if ($data["status"] == 1) {
+//                     # code...
+//                     // $url="http://localhost:8115/api/accessClassReport";
+//                     $url="http://61.175.203.188:10001/api/accessClassReport";
+//                     $url_data = [
+//                         "mac" => $data["mac"],
+//                         "data" => [
+//                             [
+//                                 "label" => $data["id"],
+//                                 "time" => time(),
+//                                 "dirt" => 2,
+//                                 "rssi" => $data["rssi"],
+//                                 "avg" => $data["avg"] 
+//                             ]
+//                         ]
+//                     ];
+//                     http($url, $url_data, [], 'POST');
+//                     rlog("PUSH INFO","离线推送依赖数据", $v);
+//                 }
+//                 app_redis()->hdel('indoor_rfidinfos',$k);;
+//             }
+//         }
+        
+//     } catch (\Exception $ex) {
+//         rlog("INFO", 'pushhttp',"推送 异常".$ex->getMessage());
+//     }
+//     $sleepTime = floor($offlineInt/10);
+//     if ($sleepTime < 3) {
+//         # code...
+//         $sleepTime = 3;
+//     }
+//     sleep($sleepTime); //1分钟遍历一次
+// }
+
+// 正式部分
+while (true) {
+    try {
+        
+        if (app_redis() === false) {
+            echo 'redis连接错误！' . PHP_EOL;
+            continue;
+        }
+        $data = app_redis()->lpop('indoor_inoutres_push');
+
+        if(!$data){
+            // var_dump($data);
+            echo "redis无数据!",PHP_EOL;
+            sleep(1);
+            continue;
+        }
+        echo ('取出数据' . $data." TYPE:". gettype($data) . PHP_EOL);
+
+        $url_data = json_decode($data, true);
+
+        $url="http://localhost:8115/api/api/accessClassReport";
+        
+        
+        http($url, $url_data, [], 'POST');
+        rlog("PUSH INFO","推送依赖数据", $data);
+    }catch (\Exception $ex) {
+            rlog("INFO", 'pushhttp',"推送 异常".$ex->getMessage());
+    }
+
+    // sleep(3);
+}

task_script/INDOOR_STATUS_UPDATE.php

@@ -0,0 +1,266 @@
+<?php
+require('../vendor/autoload.php');
+use \PhpMqtt\Client\MqttClient;
+use \PhpMqtt\Client\ConnectionSettings;
+use think\facade\Cache;
+date_default_timezone_set("PRC");
+define('HOST', '127.0.0.1');
+define('PORT', '6379');
+define('PASSWORD', 'R!478gH*%23nPn');
+// define('PASSWORD', '123456');
+define('DATABASE', 2);
+
+
+function app_redis()
+{
+    static $redis = null;
+    static $conn = false;
+    if (!$conn) {
+        connect: //定义标签
+        $redis = new Redis();
+        try {
+            //建立的Redis短连接,在请求结束后不会自动关闭,相当于持久连接.
+            $conn = $redis->connect(HOST, PORT);
+            $conn = $redis->auth(PASSWORD);
+            $conn = $redis->select(DATABASE);
+            // 连接成功,返回$redis对象,连接失败,返回false.
+            return ($conn === true) ? $redis : false;
+        } catch (Exception $e) {
+            return false;
+        }
+    } else {
+        // 这里假设PHP-FPM在处理一个请求的时间内,Redis连接都是可用的.
+        // 所以只在PHP-CLI下检查Redis连接的状态,进行断线重连.
+        if (php_sapi_name() === 'cli') {
+            try {
+                // ping用于检查当前连接的状态,成功时返回+PONG,失败时抛出一个RedisException对象.
+                // ping失败时警告:
+                // Warning: Redis::ping(): connect() failed: Connection refused
+                // var_dump('AAAAAAAAA', $redis);
+                echo 'Redis 连接状态' . $redis->ping() . PHP_EOL;
+                @$redis->ping();
+                if (!$redis->ping()) {
+                    goto connect; //跳转到标签出继续执行连接操作
+                }
+            } catch (Exception  $e) {
+                // 信息如 Connection lost 或 Redis server went away
+                echo $e->getMessage();
+                echo 'Redis 连接失败 重新连接：' . PHP_EOL;
+                // 断线重连
+                goto connect;
+            }
+        }
+        return $redis;
+    }
+}
+
+function rlog(...$args)
+{
+    if (empty($args[0])) {
+        return;
+    }
+    static $LOG_CONSOLE = false; //是否输出到控制台
+    static $LOG_NAME = "indoor_status_update.log"; //值为空时 不写入文件
+    static $LOG_SIZE = 64 * 1024 * 1024; //文件最大尺寸
+
+    static $LOG_CACHE = false; //是否缓存日志内容 用于批量写入文件
+    static $CACHE_DURATION = 10; //缓存最大时间 秒
+    static $CACHE_SIZE = 1024; //缓存大小
+    static $cacheStartTime = 0;
+    static $cacheBuf = '';
+
+    static $LOG_TIMES = 10; //调用这个函数最大次数 超过次数后判断下文件大小
+    static $logCount = 0;
+
+
+    $buf = '';
+    if (count($args) == 1 && $args[0] == "\n") { //只有换行时 不写入时间戳了
+        $buf = "\n";
+    } else {
+        $pid = ''; //进程id
+        if (function_exists('posix_getpid')) {
+            $pid = ' ' . posix_getpid() . ' ';
+        }
+        $fileLine = ''; //文件名:行号
+        {
+            $debug = debug_backtrace();
+            $fileLine = ($pid == '' ? ' ' : '') . basename($debug[0]['file']) . ':' . $debug[0]['line'] . ' ';
+        }
+        $buf = date("y-m-d H:i:s") . "{$pid}{$fileLine}" . implode(' ', $args) . "\n";
+    }
+
+    $logCount++;
+    if (!empty($LOG_NAME)) {
+        if ($LOG_CACHE) {
+            $cacheBuf .= $buf;
+            //超过缓存尺寸 或者 超过缓存时长 写缓存到文件
+            if (strlen($cacheBuf) > $CACHE_SIZE || time() - $cacheStartTime > $CACHE_DURATION) {
+                $cacheStartTime = time();
+                goto write;
+            } else {
+                goto skipWrite;
+            }
+        } else {
+            $cacheBuf = $buf;
+        }
+        write: {
+            //超过尺寸后 删除旧文件 把新文件重命名为旧文件  多进程同时操作 不加锁问题不大
+            if ($logCount > $LOG_TIMES && filesize($LOG_NAME) > $LOG_SIZE) {
+                $oldLogName = $LOG_NAME . '.old';
+                if (file_exists($oldLogName)) {
+                    if (!unlink($oldLogName)) {
+                        echo "unlink err\n";
+                    }
+                }
+                if (!rename($LOG_NAME, $oldLogName)) {
+                    echo "rename err\n";
+                }
+                $logCount = 0;
+            }
+            if (!file_put_contents($LOG_NAME, $cacheBuf, FILE_APPEND)) {
+                echo "file_put_contents err\n";
+            }
+            $cacheBuf = '';
+        }
+        skipWrite: {
+        }
+    }
+    if ($LOG_CONSOLE) {
+        echo $buf;
+    }
+}
+
+function http($url, $params, $header = [], $method = 'GET', $timeout = 10)
+{
+    // POST $params 字符串形式query=abcd&abc=12345
+    //GET $params 数组['query' => 'abcd', 'abc' => 12345]
+    //  $header[] = "Content-Type: application/x-www-form-urlencoded";
+    //  $header[] = "Content-Type: application/soap+xml; charset=utf-8";
+    //  $header[] = "Content-Type: application/json; charset=utf-8";
+    //  $header[] = "Expect: ";
+    rlog("[HTTP] url:$url,method:$method" . ",header:" . json_encode($header));
+    if (strtoupper($method) == 'POST') {
+        rlog("[POST] send params " . (!is_array($params) ? $params : json_encode($params, JSON_UNESCAPED_UNICODE)));
+    } else {
+        rlog("[GET] send " . json_encode($params));
+    }
+    $header[] = "Expect: ";
+    $opts = array(
+        CURLOPT_TIMEOUT => $timeout,
+        CURLOPT_RETURNTRANSFER => 1,
+        CURLOPT_SSL_VERIFYPEER => false,
+        CURLOPT_SSL_VERIFYHOST => false,
+        CURLOPT_HTTPHEADER => $header
+    );
+
+    /* 根据请求类型设置特定参数 */
+    switch (strtoupper($method)) {
+        case 'GET':
+            $opts[CURLOPT_URL] = $url . (empty($params) ? '' : ('?' . http_build_query($params)));
+            break;
+        case 'POST':
+            //$params = http_build_query($params);
+            $opts[CURLOPT_URL] = $url;
+            $opts[CURLOPT_POST] = 1;
+            $opts[CURLOPT_POSTFIELDS] = json_encode($params);
+            break;
+        default:
+            rlog("[ERR] method " . $method);
+            return false;
+    }
+
+    global $ch; //curl长连接
+    if (empty($ch)) {
+        $ch = curl_init();
+    }
+    if (empty($ch)) {
+        rlog("[ERR] curl_init");
+        return false;
+    }
+
+    $csa = curl_setopt_array($ch, $opts);
+    if (empty($csa)) {
+        rlog("[ERR] curl_setopt_array");
+        return false;
+    }
+
+    $data = curl_exec($ch);
+    if ($data === false) {
+        rlog("[ERR] curl_exec errno:" . curl_errno($ch) . " " . curl_error($ch));
+        return false;
+    }
+    //unicode转中文
+    $data = decodeUnicode($data);
+    rlog("[HTTP] recv " . $data);
+    //curl_close($ch);
+    return $data;
+}
+function decodeUnicode($str)
+{
+    return preg_replace_callback('/\\\\u([0-9a-f]{4})/i', function ($matches) {
+        return iconv("UCS-2BE", "UTF-8", pack("H*", $matches[1]));
+    }, $str);
+}
+
+
+function mqttToRedis($text){
+    
+    try{
+        app_redis()->lpush("mqtt_data_parea4rssi",$text);
+    }catch(\Exception $e){
+        rlog("INFO", 'recv',"redis 异常".$e->getMessage());
+    }
+    
+} 
+
+
+
+while (true) {
+    try {
+        rlog('INFO', 'task start');
+
+        $infos = app_redis()->hgetall("indoor_rfidinfos");
+        $offlineInt  = app_redis()->hget("anbang_four_wire", "anbang_4rssi_offint");
+        if (!$offlineInt) {
+            # code...
+            $offlineInt = 30;
+        }
+        foreach ($infos as $k => $v) {
+            # code...
+            $data = json_decode($v, true);
+            if ( (time() - $data["time"] ) > $offlineInt ) {
+                # code...
+                if ($data["status"] == 1) {
+                    # code...
+                    $url="http://localhost:8115/api/accessClassReport"; 
+                    // $url="http://61.175.203.188:10001/api/accessClassReport";
+                    $url_data = [
+                        "mac" => $data["mac"],
+                        "data" => [
+                            [
+                                "label" => $data["id"],
+                                "time" => time(),
+                                "dirt" => 2,
+                                "rssi" => $data["rssi"],
+                                "avg" => $data["avg"] 
+                            ]
+                        ]
+                    ];
+                    http($url, $url_data, [], 'POST');
+                    rlog("PUSH INFO","离线推送依赖数据", $v);
+                }
+                app_redis()->hdel('indoor_rfidinfos',$k);
+            }
+        }
+        
+    } catch (\Exception $ex) {
+        rlog("INFO", 'pushhttp',"推送 异常".$ex->getMessage());
+    }
+    $sleepTime = floor($offlineInt/10);
+    if ($sleepTime < 3) {
+        # code...
+        $sleepTime = 3;
+    }
+    sleep($sleepTime); //1分钟遍历一次
+}
+

task_script/RL4RSSI_INDOOR_MQTT.php

@@ -0,0 +1,379 @@
+<?php
+require('../vendor/autoload.php');
+use \PhpMqtt\Client\MqttClient;
+use \PhpMqtt\Client\ConnectionSettings;
+use think\facade\Cache;
+date_default_timezone_set("PRC");
+define('HOST', '127.0.0.1');
+define('PORT', '6379');
+define('PASSWORD', 'R!478gH*%23nPn');
+// define('PASSWORD', '123456');
+define('DATABASE', 2);
+
+
+function app_redis()
+{
+    static $redis = null;
+    static $conn = false;
+    if (!$conn) {
+        connect: //定义标签
+        $redis = new Redis();
+        try {
+            //建立的Redis短连接,在请求结束后不会自动关闭,相当于持久连接.
+            $conn = $redis->connect(HOST, PORT);
+            $conn = $redis->auth(PASSWORD);
+            $conn = $redis->select(DATABASE);
+            // 连接成功,返回$redis对象,连接失败,返回false.
+            return ($conn === true) ? $redis : false;
+        } catch (Exception $e) {
+            return false;
+        }
+    } else {
+        // 这里假设PHP-FPM在处理一个请求的时间内,Redis连接都是可用的.
+        // 所以只在PHP-CLI下检查Redis连接的状态,进行断线重连.
+        if (php_sapi_name() === 'cli') {
+            try {
+                // ping用于检查当前连接的状态,成功时返回+PONG,失败时抛出一个RedisException对象.
+                // ping失败时警告:
+                // Warning: Redis::ping(): connect() failed: Connection refused
+                // var_dump('AAAAAAAAA', $redis);
+                echo 'Redis 连接状态' . $redis->ping() . PHP_EOL;
+                @$redis->ping();
+                if (!$redis->ping()) {
+                    goto connect; //跳转到标签出继续执行连接操作
+                }
+            } catch (Exception  $e) {
+                // 信息如 Connection lost 或 Redis server went away
+                echo $e->getMessage();
+                echo 'Redis 连接失败 重新连接：' . PHP_EOL;
+                // 断线重连
+                goto connect;
+            }
+        }
+        return $redis;
+    }
+}
+
+function rlog(...$args)
+{
+    if (empty($args[0])) {
+        return;
+    }
+    static $LOG_CONSOLE = false; //是否输出到控制台
+    static $LOG_NAME = "rl4rssi_indoor_mqtt.log"; //值为空时 不写入文件
+    static $LOG_SIZE = 64 * 1024 * 1024; //文件最大尺寸
+
+    static $LOG_CACHE = false; //是否缓存日志内容 用于批量写入文件
+    static $CACHE_DURATION = 10; //缓存最大时间 秒
+    static $CACHE_SIZE = 1024; //缓存大小
+    static $cacheStartTime = 0;
+    static $cacheBuf = '';
+
+    static $LOG_TIMES = 10; //调用这个函数最大次数 超过次数后判断下文件大小
+    static $logCount = 0;
+
+
+    $buf = '';
+    if (count($args) == 1 && $args[0] == "\n") { //只有换行时 不写入时间戳了
+        $buf = "\n";
+    } else {
+        $pid = ''; //进程id
+        if (function_exists('posix_getpid')) {
+            $pid = ' ' . posix_getpid() . ' ';
+        }
+        $fileLine = ''; //文件名:行号
+        {
+            $debug = debug_backtrace();
+            $fileLine = ($pid == '' ? ' ' : '') . basename($debug[0]['file']) . ':' . $debug[0]['line'] . ' ';
+        }
+        $buf = date("y-m-d H:i:s") . "{$pid}{$fileLine}" . implode(' ', $args) . "\n";
+    }
+
+    $logCount++;
+    if (!empty($LOG_NAME)) {
+        if ($LOG_CACHE) {
+            $cacheBuf .= $buf;
+            //超过缓存尺寸 或者 超过缓存时长 写缓存到文件
+            if (strlen($cacheBuf) > $CACHE_SIZE || time() - $cacheStartTime > $CACHE_DURATION) {
+                $cacheStartTime = time();
+                goto write;
+            } else {
+                goto skipWrite;
+            }
+        } else {
+            $cacheBuf = $buf;
+        }
+        write: {
+            //超过尺寸后 删除旧文件 把新文件重命名为旧文件  多进程同时操作 不加锁问题不大
+            if ($logCount > $LOG_TIMES && filesize($LOG_NAME) > $LOG_SIZE) {
+                $oldLogName = $LOG_NAME . '.old';
+                if (file_exists($oldLogName)) {
+                    if (!unlink($oldLogName)) {
+                        echo "unlink err\n";
+                    }
+                }
+                if (!rename($LOG_NAME, $oldLogName)) {
+                    echo "rename err\n";
+                }
+                $logCount = 0;
+            }
+            if (!file_put_contents($LOG_NAME, $cacheBuf, FILE_APPEND)) {
+                echo "file_put_contents err\n";
+            }
+            $cacheBuf = '';
+        }
+        skipWrite: {
+        }
+    }
+    if ($LOG_CONSOLE) {
+        echo $buf;
+    }
+}
+
+function http($url, $params, $header = [], $method = 'GET', $timeout = 10)
+{
+    // POST $params 字符串形式query=abcd&abc=12345
+    //GET $params 数组['query' => 'abcd', 'abc' => 12345]
+    //  $header[] = "Content-Type: application/x-www-form-urlencoded";
+    //  $header[] = "Content-Type: application/soap+xml; charset=utf-8";
+    //  $header[] = "Content-Type: application/json; charset=utf-8";
+    //  $header[] = "Expect: ";
+    rlog("[HTTP] url:$url,method:$method" . ",header:" . json_encode($header));
+    if (strtoupper($method) == 'POST') {
+        rlog("[POST] send params " . (!is_array($params) ? $params : json_encode($params, JSON_UNESCAPED_UNICODE)));
+    } else {
+        rlog("[GET] send " . json_encode($params));
+    }
+    $header[] = "Expect: ";
+    $opts = array(
+        CURLOPT_TIMEOUT => $timeout,
+        CURLOPT_RETURNTRANSFER => 1,
+        CURLOPT_SSL_VERIFYPEER => false,
+        CURLOPT_SSL_VERIFYHOST => false,
+        CURLOPT_HTTPHEADER => $header
+    );
+
+    /* 根据请求类型设置特定参数 */
+    switch (strtoupper($method)) {
+        case 'GET':
+            $opts[CURLOPT_URL] = $url . (empty($params) ? '' : ('?' . http_build_query($params)));
+            break;
+        case 'POST':
+            //$params = http_build_query($params);
+            $opts[CURLOPT_URL] = $url;
+            $opts[CURLOPT_POST] = 1;
+            $opts[CURLOPT_POSTFIELDS] = json_encode($params);
+            break;
+        default:
+            rlog("[ERR] method " . $method);
+            return false;
+    }
+
+    global $ch; //curl长连接
+    if (empty($ch)) {
+        $ch = curl_init();
+    }
+    if (empty($ch)) {
+        rlog("[ERR] curl_init");
+        return false;
+    }
+
+    $csa = curl_setopt_array($ch, $opts);
+    if (empty($csa)) {
+        rlog("[ERR] curl_setopt_array");
+        return false;
+    }
+
+    $data = curl_exec($ch);
+    if ($data === false) {
+        rlog("[ERR] curl_exec errno:" . curl_errno($ch) . " " . curl_error($ch));
+        return false;
+    }
+    //unicode转中文
+    $data = decodeUnicode($data);
+    rlog("[HTTP] recv " . $data);
+    //curl_close($ch);
+    return $data;
+}
+function decodeUnicode($str)
+{
+    return preg_replace_callback('/\\\\u([0-9a-f]{4})/i', function ($matches) {
+        return iconv("UCS-2BE", "UTF-8", pack("H*", $matches[1]));
+    }, $str);
+}
+function devRegularInfo($topic, $msg)
+{
+    // {"CSQ":26,"REP_INT":60,"GPS":"112.14060,32.06532","IMEI":"867160049332715","IMSI":"460041872816952","CCID":"898607B8101980060659","SYS_VER":"RLSC_V0.1","Time":1676257143,"Status":0,"StatusMsg":"设备正常","Initiative":1}
+    $data = json_decode($msg, true);
+    if (empty($data)) {
+        rlog("ERR", "json_decode");
+        return;
+    }
+    rlog("[I]", $msg);
+    $url = 'http://47.114.185.186:8115/api/trackReport';
+    // $url .= http_build_query($column);
+    http($url, $data, [], 'POST');
+    $loc = explode(',', $data['GPS']);
+    $column = [
+        'csq' => $data['CSQ'] ?: '',
+        'rep_int' => $data['REP_INT'] ?: '',
+        'latitude' => isset($loc[0]) ? $loc[0] : '',
+        'longitude' => isset($loc[1]) ? $loc[1] : '',
+        'imei' => $data['IMEI'] ?: '',
+        'imsi' => $data['IMSI'] ?: '',
+        'iccid' => $data['ICCID'] ?: '',
+        'version' => $data['SYS_VER'] ?: '',
+        'time' => $data['Time'] ?: '',
+        'status' => $data['Status'] ?: '',
+        'status_msg' => $data['StatusMsg'] ?: '',
+        'initiative' => $data['Initiative'] ?: ''
+    ];
+
+    $url = 'http://47.114.185.186:8115/rlapi/busHeartbeatData';
+    // $url .= http_build_query($column);
+    http($url, $column, [], 'POST');
+}
+
+function getUpDevSysMsg($topic, $msg)
+{
+    // {
+    //     "IMEI": "867160049332715",
+    //     "Mqtt_Host": "develop.rltest.cn",
+    //     "Mqtt_Port": 1883,
+    //     "Mqtt_User": " rl517",
+    //     "Mqtt_Password": "rlian2022",
+    //     "TTS_TEXT": "某某科技欢迎您",
+    //     "GPS_EN": "0",
+    //     "Time": 1676257143
+    // }
+    $arr = json_decode($msg, true);
+    if (empty($arr)) {
+        rlog("ERR", "json_decode");
+        return;
+    }
+    $column = [
+        'imei' => $arr['IMEI'],
+        'mqtt_host' => $arr['Mqtt_Host'],
+        'mqtt_port' => $arr['Mqtt_Port'],
+        'mqtt_user' => $arr['Mqtt_User'],
+        'mqtt_password' => $arr['Mqtt_Password'],
+        'tts_text' => $arr['TTS_TEXT'],
+        'gps_en' => $arr['GPS_EN'],
+        'time' => $arr['Time']
+    ];
+    $url = 'http://47.114.185.186:8115/rlapi/busSysMsgData';
+    // $url .= http_build_query($data);
+    http($url, $column, [], 'POST');
+}
+function rcInfoMsg($topic, $msg)
+{
+
+    // {
+    //     "IMEI": "867160049332715",
+    //     "RC_Number": "867160049332715",
+    //     "RC_Type": 1,
+    //     "RC_Pres": 1,
+    //     "RC_Total": 25,
+    //     "GPS_X": "116.25"
+    //     "GPS_Y": "29.36",
+    //     "Msgid": "dkx12-15dss-ad567-1a2ss",
+    //     "Time": 1676257143
+    // }
+    $arr = json_decode($msg, true);
+    if (empty($arr)) {
+        rlog("ERR", "json_decode");
+        return;
+    }
+    $column = [
+        'imei' => $arr['IMEI'],
+        'rc_number' => $arr['RC_Number'],
+        'rc_type' => $arr['RC_Type'],
+        'rc_pres' => $arr['RC_Pres'],
+        'rc_total' => $arr['RC_Total'],
+        'gps_x' => $arr['GPS_X'],
+        'gps_y' => $arr['GPS_Y'],
+        'msgid' => $arr['Msgid'],
+        'time' => $arr['Time']
+    ];
+    $url = 'http://47.114.185.186:8115/rlapi/busRcInfoData';
+    // $url .= http_build_query($data);
+    http($url, $column, [], 'POST');
+}
+function loop()
+{
+    $server   = '127.0.0.1';
+    $port     = 1883;
+    $clientId = 'mqttx_testindoor'.rand(1234, 99999);
+    $username = 'rl0606';
+    $password = "rlian2023";
+    $clean_session = true;
+
+    $connectionSettings  = new ConnectionSettings();
+    $connectionSettings = $connectionSettings
+        ->setUsername($username)
+        ->setPassword($password)
+        ->setKeepAliveInterval(60)
+        // Last Will 设置
+        //        ->setLastWillTopic('emqx/test/last-will')
+        //        ->setLastWillMessage('client disconnect')
+        //        ->setLastWillQualityOfService(1)
+    ;
+
+    //include "RLog.php";
+    //    $mqtt = new MqttClient($server, $port, $clientId, MqttClient::MQTT_3_1, null, new RLog());
+
+    $mqtt = new MqttClient($server, $port, $clientId);
+
+    $mqtt->connect($connectionSettings, $clean_session);
+    rlog('INFO', "connect OK");
+
+    /*
+消息方向	设备->服务器 
+设备主动上报当前设备公共信息参数：ScBusTem/DevRegularInfo
+服务器获取设备系统信息后设备上传信息，即GetDevSysMsg的回应 ScBusTem/GetUpDevSysMsg 
+服务器设置设备重量信息信息 ScBusTem/RCInfoMsg
+*/
+    //订阅心跳数据
+    $mqtt->subscribe('PArea4RSSI/devOntime', function ($topic, $message) {
+        rlog("INFO", 'recv', $topic, $message);
+        var_dump($message);
+    }, 0);
+
+
+    // $mqtt->subscribe('ScBusTem/GetDevSysMsg/*', function ($topic, $message) {
+    //     rlog("INFO", 'recv', $topic, $message);
+    //     getDevSysMsg($topic, $message);
+    // }, 0);
+    //终端上报系统信息数据
+    $mqtt->subscribe('RL4RSSI/IndoorRfids', function ($topic, $message) {
+        rlog("INFO", 'recv', $topic, $message);
+        if(!empty($message)){
+            mqttToRedis($message);
+        }
+        
+    }, 0);
+    $mqtt->loop(true);
+}
+
+// FFFFFFFFFF000014FF000002200000E2B15AD501FFFFFFFF49FFFF46
+//                               5bc6f8a110FFFFFFFF474d4a49
+function mqttToRedis($text){
+    
+    try{
+        app_redis()->lpush("mqtt_data_indoor4rssi",$text);
+    }catch(\Exception $e){
+        rlog("INFO", 'recv',"redis 异常".$e->getMessage());
+    }
+    
+} 
+
+while (1) {
+    try {
+        rlog('INFO', 'connect start');
+        loop();
+    } catch (\Exception $ex) {
+        rlog("ERR", $ex->getTraceAsString());
+        rlog("ERR", $ex->getMessage());
+    }
+    sleep(3);
+}