Api.php 31 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858
  1. <?php
  2. namespace catchAdmin\api\controller;
  3. use catchAdmin\api\service\dispose;
  4. use catchAdmin\tag_history\model\Access;
  5. use catchAdmin\tag_history\model\Dormitory;
  6. use catchAdmin\tag_history\model\TagHistory;
  7. use catchAdmin\worklocation\model\WorkRecord as ModelWorkRecord;
  8. use catcher\base\CatchRequest as Request;
  9. use catcher\CatchResponse;
  10. use catcher\base\CatchController;
  11. use Exception;
  12. use think\facade\Cache;
  13. use \think\facade\Db;
  14. error_reporting(0);
  15. class Api extends CatchController
  16. {
  17. public function report()
  18. {
  19. $token = $_GET['token'];
  20. if (!$token || $token != '22723927C') {
  21. json_fail('缺少token或者token不对');
  22. }
  23. $param = json_decode(optimize_json(file_get_contents("php://input")), true);
  24. debug_log("上报数据",json_encode($param));
  25. if (json_last_error() != 0) {
  26. json_fail('解析异常', json_last_error_msg());
  27. }
  28. $mac = $param['mac'];
  29. if (empty($mac)) {
  30. json_fail('mac地址不存在');
  31. }
  32. $data = [];
  33. foreach ($param['list'] as $item) {
  34. // $onetime= TagHistory::where("mac",$mac)->where('lable',$item['label'])->order("id","desc")->value("time");
  35. $data[] = [
  36. 'mac' => $mac,
  37. 'lable' => $item['label'],
  38. 'rssi' => $item['rssi'],
  39. 'time' => $item['time'],
  40. 'addTime' => time(),
  41. 'move' => $item['move'],
  42. 'step' => empty($item['step']) ? 0 : $item['step'],
  43. 'temperature' => empty($item['temperature']) ? 0 : $item['temperature'],
  44. //告警
  45. 'temperWarn' => empty($item['temperWarn']) ? 00 : $item['temperWarn'],
  46. // "interval_time"=>empty($onetime) ?0:($item['time']-$onetime)
  47. ];
  48. }
  49. $tage = new TagHistory();
  50. $tage->saveAll($data);
  51. json_success('上传成功');
  52. }
  53. //储存数据到redis
  54. public function redis_to_mysql(){
  55. $ues_redis=Cache::store('redis')->handler();
  56. $text=null;
  57. while(1){
  58. $jsonData= $ues_redis->rpop("mqtt_data");
  59. debug_log("InAndOUT",'数据redis'.$jsonData);
  60. if(empty($jsonData)){
  61. debug_log("InAndOUT",'没有数据');
  62. sleep(1);
  63. continue;
  64. }
  65. $data=json_decode($jsonData,true);
  66. $time=$data['time'];
  67. $mac=$data['devId'];
  68. $list=[];
  69. $text=$text.$data['cnt'];
  70. if(strlen($text)<24){
  71. continue;
  72. }
  73. while(strlen($text)>=24){
  74. $da=substr($text,0,24);
  75. $t1 = substr($da,8,2)=='00'||substr($da,8,2)=='10'||substr($da,8,2)=='01' ? true:false;
  76. $t2 =substr($da,10,6)=="FFFFFF"||substr($da,10,6)=="000000" ?true:false;
  77. if($t1&&$t2){
  78. $label= substr($da,0,8);
  79. $rssi1= substr($da,16,2);
  80. $rssi2= substr($da,18,2);
  81. $rssi3= substr($da,20,2);
  82. $rssi4= substr($da,22,2);
  83. $DA=[
  84. 'mac' => $mac,
  85. 'label' =>$label,
  86. 'rssi1' => hexdec($rssi1),
  87. 'rssi2' => hexdec($rssi2),
  88. 'rssi3' => hexdec($rssi3),
  89. 'rssi4' => hexdec($rssi4),
  90. 'report_time'=>$time
  91. ];
  92. // $num=dechex($label);
  93. $vs=false;
  94. $history_status=false;
  95. // $DA['num']=$num;
  96. $DA['other_time']=date("Y-m-d H:i:s",$time);
  97. if($DA['rssi1']<=85||$DA['rssi2']<=85||$DA['rssi3']<=85||$DA['rssi4']<=85){
  98. $history_status=true;
  99. }else{
  100. debug_log("label_log","cache_del:".json_encode($DA));
  101. }
  102. debug_log("label_log","cssh: ".json_encode($DA));
  103. if($DA['rssi1']<=72||$DA['rssi2']<=72||$DA['rssi3']<=72||$DA['rssi4']<=72){
  104. $vs=true;
  105. }else{
  106. debug_log("label_log","delete:".json_encode($DA));
  107. }
  108. $DA['rssi1']=$DA['rssi1']==255?100:$DA['rssi1'];
  109. $DA['rssi2']=$DA['rssi2']==255?100:$DA['rssi2'];
  110. $DA['rssi3']=$DA['rssi3']==255?100:$DA['rssi3'];
  111. $DA['rssi4']=$DA['rssi4']==255?100:$DA['rssi4'];
  112. $DA["rssi1"]=$DA["rssi1"]<=$DA["rssi3"]?$DA["rssi1"]:$DA["rssi3"];
  113. $DA["rssi2"]=$DA["rssi2"]<=$DA["rssi4"]?$DA["rssi2"]:$DA["rssi4"];
  114. /**
  115. * 缓存到redis历史数据
  116. */
  117. if(substr($da,8,2)=='01'&&$history_status&&$DA["rssi1"]!=$DA["rssi2"]){
  118. debug_log("label_log","cache: ".json_encode($DA));
  119. $diff= $DA["rssi1"]-$DA["rssi2"];
  120. if(abs($diff)>2){
  121. $dispose = new dispose($ues_redis);
  122. $dispose->set_label_history($DA);
  123. }
  124. debug_log("label_log","cache_diff: ".$diff);
  125. }
  126. $this->temporary_label($ues_redis,$label,1);
  127. if($vs&&(substr($da,8,2)=='01')){
  128. try{
  129. $dispose = new dispose($ues_redis);
  130. $DA= $dispose->check_data($DA);
  131. debug_log("label_log","xsj:".json_encode($DA));
  132. $dispose->computeResout($DA);
  133. }catch(Exception $e){
  134. debug_log("InAndOUT","抛出异常".json_encode($DA,true));
  135. }
  136. }
  137. $text=substr($text,24);
  138. }else{
  139. $text=substr($text,1);
  140. }
  141. }
  142. }
  143. }
  144. /**
  145. * 清除数据
  146. *
  147. * @return void
  148. */
  149. public function clear_redis(){
  150. while(1){
  151. sleep(1);
  152. $redis=Cache::store('redis')->handler();
  153. $dispose = new dispose($redis);
  154. $keylist= $dispose->getStations();
  155. debug_log("clear_label","查询数据".json_encode($keylist));
  156. if(empty($keylist)){
  157. continue;
  158. }
  159. foreach($keylist as $station){
  160. //结果key值
  161. $key="res".$station;
  162. //存取旧的数据的reids数据
  163. $catchkey=$station."station";
  164. //获取该基站的所有key
  165. $keys= $redis->hKeys($key);
  166. if(empty($keys)){
  167. continue;
  168. }
  169. foreach($keys as $item){
  170. if( $json_data=$redis->hget($key,$item)){
  171. debug_log("clear_label",'基站'.$station);
  172. debug_log("clear_label",'标签'.$item);
  173. debug_log("clear_label",'获取的数据'.$json_data);
  174. $json_data=json_decode($json_data,true);
  175. //列表
  176. $a=$json_data['a'];
  177. //状态
  178. $status=$json_data['status'];
  179. //进出
  180. $in_and_out=$json_data["in_and_out"];
  181. //总数
  182. $count= count($a);
  183. if((time()-$json_data["time"])<=7){
  184. debug_log("clear_label", $item.':'. "标签上报间隔没有超过7秒进行跳过");
  185. continue;
  186. }
  187. if($count<5){
  188. if($count>2){
  189. debug_log("clear_label", $item.':'. "标签信号个数等于超过2个,参与计算");
  190. $frist=$a[0]['dirt'];
  191. $end=$a[$count-1]['dirt'];
  192. if($frist!=$end){
  193. $data_array=[];
  194. $data_array[]=[
  195. "label"=>$item,
  196. 'time'=>$a[$count-1]['time'],
  197. 'dirt'=> $frist==1?1:2 //1是进 2是出
  198. ];
  199. $url_data=[
  200. "mac"=>$station,
  201. "data"=>$data_array
  202. ];
  203. debug_log("clear_label", $item.':'. "标签信号个数等于超过2个,参与计算,得出结果:".$frist);
  204. //设置key
  205. $dispose->set_time_results($station,$item,$a[$count-1]['time'],$frist==1?1:2);
  206. $dispose->getRemoteData($url_data);
  207. // debug_log("InAndOUT","得出计算结果:".json_encode($arr));
  208. debug_log("clear_label","发送给远程".json_encode($url_data));
  209. }else{
  210. debug_log("clear_label", $item.':'. "标签信号个数没有超过4个,全部去清除");
  211. }
  212. }
  213. }else{
  214. $front=0;
  215. $back=0;
  216. $res=0;
  217. if($a[$count-3]['dirt']==1){
  218. $front+=1;
  219. }else{
  220. $back+=1;
  221. }
  222. if($a[$count-2]['dirt']==1){
  223. $front+=1;
  224. }else{
  225. $back+=1;
  226. }
  227. if($a[$count-1]['dirt']==1){
  228. $front+=1;
  229. }else{
  230. $back+=1;
  231. }
  232. if($front>$back){
  233. $res=1;
  234. }else{
  235. $res=2;
  236. }
  237. if($status['dirt']!=$res){
  238. debug_log("clear_label", $item.':'. "最后一个信号,方向相反,得出结果,清除缓存数据");
  239. $redis->hdel($key,$item);
  240. $data_array=[];
  241. $data_array[]=[
  242. "label"=>$item,
  243. 'time'=>$a[$count-1]['time'],
  244. 'dirt'=> $status['dirt']==1?1:2 //1是进 2是出
  245. ];
  246. $url_data=[
  247. "mac"=>$station,
  248. "data"=>$data_array
  249. ];
  250. //设置key
  251. $dispose->set_time_results($station,$item,$a[$count-1]['time'],$status['dirt']==1?1:2);
  252. // debug_log("InAndOUT","得出计算结果:".json_encode($arr));
  253. debug_log("clear_label","发送给远程".json_encode($url_data));
  254. //远程推送
  255. $dispose->getRemoteData($url_data);
  256. //清除缓存数据
  257. $this->temporary_label($redis,$item,2);
  258. }else{
  259. //上午不做二次计算
  260. if(empty($in_and_out)){
  261. //二次生成结果
  262. $res=$dispose->second_create_direction($station,$item);
  263. if(!empty($res)){
  264. $res_time= $dispose->get_time_results($station,$item);
  265. $res_time= empty($res_time)?0:$res_time;
  266. $diff_time=$res['time']-$res_time;
  267. debug_log("clear_label", $item.':'. "间隔时间".$diff_time);
  268. //判断如果结果超过时间
  269. if($diff_time>10){
  270. debug_log("clear_label", $item.':'. "二次生成进出");
  271. $data_array=[];
  272. $data_array[]=[
  273. "label"=>$item,
  274. 'time'=>$res['time'],
  275. 'dirt'=>$res['dirt'],
  276. ];
  277. $url_data=[
  278. "mac"=>$station,
  279. "data"=>$data_array
  280. ];
  281. debug_log("clear_label","二次生成发送给远程".json_encode($url_data));
  282. //远程推送时间
  283. $dispose->set_time_results($station,$item,$res['time'],$res['dirt']);
  284. //远程推送
  285. $dispose->getRemoteData($url_data);
  286. }
  287. }
  288. }
  289. //二次进出
  290. debug_log("clear_label", $item.':'. "最后一个信号,方向没有变化,清除缓存数据");
  291. }
  292. }
  293. //清除对应的键值对
  294. //清空头部尾部历史
  295. $dispose->get_label_history(3,$station,$item);
  296. $redis->hdel($key,$item);
  297. $redis->hdel($catchkey,$item);
  298. }
  299. }
  300. }
  301. }
  302. }
  303. /**
  304. * 远程推送数据
  305. *
  306. * @return void
  307. */
  308. public function remotePush(){
  309. while(true){
  310. $redis=Cache::store('redis')->handler();
  311. $key="push_data";
  312. $url="http://localhost:8115/api/accessReport";
  313. // $url="http://127.0.0.1:8000/api/accessReport";
  314. sleep(2);
  315. while($data=$redis->lPop($key)){
  316. if(!empty($data)){
  317. debug_log($key,"远程推送的数据".$data);
  318. $url_res= curl_http_post($data,$url,false);
  319. $num=1;
  320. while($url_res==false){
  321. $num++;
  322. $url_res= curl_http_post($data,$url,false);
  323. if($num>=3){
  324. debug_log($key,"远程推送的地址".$url);
  325. debug_log($key,"连续推送三次失败,远程推送的数据".$data);
  326. break;
  327. }
  328. }
  329. debug_log($key,"远程返回结果".$url_res);
  330. }
  331. }
  332. }
  333. }
  334. public function redis_to_mysql_parea(){
  335. $ues_redis=Cache::store('redis')->handler();
  336. $text="";
  337. $dispose = new dispose($ues_redis);
  338. while(1){
  339. $jsonData= $ues_redis->rpop("mqtt_data_parea4rssi");
  340. debug_log("pare_InAndOUT",'数据redis'.$jsonData);
  341. if(empty($jsonData)){
  342. debug_log("pare_InAndOUT",'没有数据');
  343. sleep(1);
  344. continue;
  345. }
  346. // debug_log("InAndOUT",$jsonData);
  347. $data=json_decode($jsonData,true);
  348. // debug_log("InAndOUT",$data['cnt']);
  349. $time=$data['time'];
  350. $mac=$data['devId'];
  351. $text=$text.$data['cnt'];
  352. if(strlen($text)<24){
  353. continue;
  354. }
  355. $text = $this->handleMessage($text, $mac, $time, $ues_redis);
  356. // foreach ($jsonData as $k => $v) {
  357. // $data = json_decode($v, true);
  358. // $config = $this->selectHash("anbang_four_wire",$data['mac']);
  359. // if(!$config){
  360. // $config = [
  361. // "front" => 70,
  362. // "behind" => 70,
  363. // "left" => 70,
  364. // "right" => 70
  365. // ];
  366. // }else{
  367. // $config = json_decode($config);
  368. // }
  369. // $field = "";
  370. // $infos = $ues_redis->hget("parea_rfidinfos",$field);
  371. // if(!$infos){
  372. // }
  373. // //判断进出段
  374. // //1。当前时间 - 上次时间 > 设定时间
  375. // if( (time() - $v["time"]) > $setInt ){
  376. // //推送离开
  377. // }
  378. // }
  379. // sleep(2);
  380. }
  381. }
  382. // //http://47.114.185.186:8115/api/areaReport
  383. // //{“mac”:”013560”,”data”:[{“label”:”258962f”,”time”:1682317268,”dirt”:2},{“label”:”258962f”,”time”:1682317268,”dirt”:1}]
  384. // }
  385. //打印日志
  386. public function temporary_label_log(){
  387. $redis=Cache::store('redis')->handler();
  388. // $key="temporary_label";
  389. // $list= $redis->HgetAll($key);
  390. // debug_log($key,json_encode($list));
  391. // debug_log($key,"所有的标签");
  392. // foreach($list as $k=>$value){
  393. // debug_log($key,json_encode([$k=>$value]));
  394. // }
  395. // debug_log($key,"所有总数".count($list));
  396. // debug_log($key,"上报的标签");
  397. // $i=0;
  398. // foreach($list as $k=>$value){
  399. // if($value==2){
  400. // debug_log($key,json_encode([$k=>$value]));
  401. // $i++;
  402. // }
  403. // }
  404. // debug_log($key,"正常上报的标签总数".$i);
  405. // debug_log($key,"补出的标签");
  406. // $t=0;
  407. // foreach($list as $k=>$value){
  408. // if($value==3){
  409. // $t++;
  410. // debug_log($key,json_encode([$k=>$value]));
  411. // }
  412. // }
  413. // debug_log($key,"补出的标签总数".$t);
  414. // debug_log($key,"没有上报的的标签");
  415. // $f=0;
  416. // foreach($list as $k=>$value){
  417. // if($value==1){
  418. // debug_log($key,json_encode([$k=>$value]));
  419. // $f++;
  420. // }
  421. // }
  422. // debug_log($key,"没有上报的的标签总数".$f);
  423. // // $redis->del($key);
  424. $dis= new dispose($redis);
  425. $dis->analysisLog();
  426. }
  427. public function temporary_label($redis,$label,$type){
  428. $key="temporary_label";
  429. if($type==1){
  430. $res= $redis->hGet($key,$label);
  431. if($res==false){
  432. $redis->hSet($key,$label,1);
  433. }
  434. }else{
  435. $redis->hSet($key,$label,3);
  436. }
  437. }
  438. //消息处理
  439. public function handleMessage($text, $mac, $time, $ues_redis){
  440. while(strlen($text)>=24){
  441. $da=substr($text,0,24);
  442. $t1 = substr($da,8,2)=='00'||substr($da,8,2)=='10'||substr($da,8,2)=='01' ? true:false;
  443. $t2 =substr($da,10,6)=="FFFFFF"||substr($da,10,6)=="000000" ?true:false;
  444. if($t1&&$t2){
  445. // var_dump($text);
  446. $rfid= substr($da,0,8);
  447. $rssi1= hexdec(substr($da,16,2));
  448. $rssi2= hexdec(substr($da,18,2));
  449. $rssi3= hexdec(substr($da,20,2));
  450. $rssi4= hexdec(substr($da,22,2));
  451. // $rc1 = ($rssi1 == 255 ? 0 : 1);
  452. // $rc2 = ($rssi2 == 255 ? 0 : 1);
  453. // $rc3 = ($rssi3 == 255 ? 0 : 1);
  454. // $rc4 = ($rssi4 == 255 ? 0 : 1);
  455. $DA=[
  456. 'mac' => $mac,
  457. 'label' =>$rfid,
  458. 'rssi1' => $rssi1,
  459. 'rssi2' => $rssi2,
  460. 'rssi3' => $rssi3,
  461. 'rssi4' => $rssi4,
  462. 'report_time'=>$time
  463. ];
  464. $field = $mac."_".$rfid;
  465. $info = $ues_redis->hget("parea_rfidinfos",$field);
  466. debug_log("pare_InAndOUT","数据:".json_encode($DA,true));
  467. if($rssi1 ==255 && $rssi2 == 255 && $rssi3 == 255 && $rssi4 == 255){
  468. debug_log("pare_InAndOUT","无效数据:".json_encode($DA,true));
  469. }else{
  470. if(!$info){
  471. $info = [
  472. "mac" => $mac,
  473. "id" => $rfid,
  474. "firs_time" => $time,
  475. "time" => $time,
  476. "status" => 2,//2出状态,1进状态
  477. "rssi" => [
  478. [
  479. "front" => $rssi1,
  480. "behind" => $rssi2,
  481. "left" => $rssi3,
  482. "right" => $rssi4,
  483. "time" => $time
  484. ]
  485. ]
  486. ];
  487. $ues_redis->hset("parea_rfidinfos",$field, json_encode($info,true));
  488. debug_log("parea_rfidinfos_redis_set_record","redis更新记录".json_encode($info,true));
  489. }else{
  490. $info = json_decode($info,true);
  491. $config = $ues_redis->hget("anbang_four_wire", $info["mac"]);
  492. if (!$config) {
  493. # code...
  494. $config = [
  495. "front_in" => 80,
  496. "behind_in" => 80,
  497. "left_in" => 80,
  498. "right_in" => 80,
  499. "front_out" => 255,
  500. "behind_out" => 255,
  501. "left_out" => 255,
  502. "right_out" => 255,
  503. "expInt" => 12,
  504. "effSigNum" => 6
  505. ];
  506. }else{
  507. $config = json_decode($config,true);
  508. }
  509. // var_dump("+++++++++++++++++",$config);
  510. $info["time"] = $time;
  511. $newRssi = [
  512. "front" => $rssi1,
  513. "behind" => $rssi2,
  514. "left" => $rssi3,
  515. "right" => $rssi4,
  516. "time" => $time
  517. ];
  518. $rssisArr = $info["rssi"];
  519. // var_dump("+++++++++++++++++", $time, $newRssi["time"]);
  520. foreach ($rssisArr as $k => $v) {
  521. # code...
  522. if( ($time - $v["time"] ) > $config['expInt'] ){
  523. unset($rssisArr[$k]);
  524. }
  525. }
  526. // var_dump("+++++++++++++++++",$rssisArr);
  527. if(count($rssisArr) == $config['effSigNum']){
  528. array_shift($rssisArr);
  529. array_push($rssisArr, $newRssi);
  530. }else{
  531. array_push($rssisArr, $newRssi);
  532. }
  533. $rssisArr =array_values($rssisArr);
  534. // var_dump("+++++++++++++++++",$rssisArr);
  535. $info["rssi"] = $rssisArr;
  536. // var_dump("------------",$info["rssi"]);
  537. $cacCount = count($rssisArr);
  538. // if($cacCount > $EFF_SIG_NUM){
  539. $sum1 = 0;
  540. $sum2 = 0;
  541. $sum3 = 0;
  542. $sum4 = 0;
  543. foreach ($rssisArr as $k => $v) {
  544. # code...
  545. $sum1 += ($v["front"] == 255 ? 90 : $v["front"]);
  546. $sum2 += ($v["behind"] == 255 ? 90 : $v["behind"]);
  547. $sum3 += ($v["left"] == 255 ? 90 : $v["left"]);
  548. $sum4 += ($v["right"] == 255 ? 90 : $v["right"]);
  549. }
  550. $info["avg"] = [
  551. "front" => number_format( $sum1/$cacCount, 2 ),
  552. "behind" => number_format( $sum2/$cacCount, 2 ),
  553. "left" => number_format( $sum3/$cacCount, 2 ),
  554. "right" => number_format( $sum4/$cacCount, 2 ),
  555. ];
  556. // var_dump($cacCount, $EFF_SIG_NUM, "dddddddd");
  557. if ($cacCount == $config['effSigNum']) {
  558. # code...
  559. $info = $this->compAndPush($info ,$config);
  560. }
  561. $ues_redis->hset("parea_rfidinfos",$field, json_encode($info,true));
  562. debug_log("parea_rfidinfos_redis_set_record","redis更新记录".json_encode($info,true));
  563. }
  564. }
  565. $text=substr($text,24);
  566. }else{
  567. $text=substr($text,1);
  568. }
  569. }
  570. return $text ?$text : "";
  571. }
  572. //判断进出和推送
  573. public function compAndPush($info, $config ){
  574. //标签多,数据多时候,判断完成后放入redis,异步推送,当前暂时直接推
  575. // $config = $ues_redis->hget("anbang_four_wire", $info["mac"]);
  576. //{"front_in":44,"front_out":44,"behind_in":50,"behind_out":50,"left_in":55,"left_out":55,"right_out":44,"right_out":44}
  577. $avg = $info['avg'];
  578. $status = $info['status'];
  579. $flagIn = $avg["front"] < $config["front_in"] || $avg["behind"] < $config["behind_in"] || $avg["left"] < $config["left_in"] || $avg["right"] < $config["right_in"];
  580. $flagOut = $avg["front"] > $config["front_out"] && $avg["behind"] > $config["behind_out"] && $avg["left"] > $config["left_out"] && $avg["right"] > $config["right_out"];
  581. $url="http://localhost:8115/api/areaReport";
  582. if($flagIn && $status == 2){
  583. if ($info["pushTime"] && (time()-$info['pushTime']) < 5 ) {
  584. # code...
  585. return $info;
  586. }
  587. //推送进
  588. $info['status'] = 1;
  589. $url_data = [
  590. "mac" => $info["mac"],
  591. "data" => [
  592. [
  593. "label" => $info["id"],
  594. "time" => $info["time"],
  595. "dirt" => 1,
  596. "rssi" => $info["rssi"],//数组 [{"front":72,"behind":255,"left":255,"right":255,"time":1685067709},{"front":76,"behind":255,"left":255,"right":255,"time":1685067710}]
  597. "avg" => $info["avg"] //{"front":"77.17","behind":"90.00","left":"90.00","right":"90.00"}
  598. ]
  599. ]
  600. ];
  601. debug_log("pushPareaRes","进推送依赖:".json_encode($info));
  602. $url_res= curl_http_post(json_encode($url_data),$url,false);
  603. $info['pushTime'] = time();
  604. debug_log("pushPareaRes","远程返回结果".$url_res);
  605. }
  606. // if($info['id'] == "E2B15AD5"){
  607. // var_dump($flagIn, $flagOut, $status, $avg["front"],$avg["behind"],$avg["left"], $avg["right"]);
  608. // }
  609. if($flagOut && $status == 1){
  610. if ($info["pushTime"] && (time()-$info['pushTime']) < 5 ) {
  611. # code...
  612. return $info;
  613. }
  614. //推送出
  615. $info['status'] = 2;
  616. $url_data = [
  617. "mac" => $info["mac"],
  618. "data" => [
  619. [
  620. "label" => $info["id"],
  621. "time" => $info["time"],
  622. "dirt" => 2,
  623. "rssi" => $info["rssi"],//数组 [{"front":72,"behind":255,"left":255,"right":255,"time":1685067709},{"front":76,"behind":255,"left":255,"right":255,"time":1685067710}]
  624. "avg" => $info["avg"] //{"front":"77.17","behind":"90.00","left":"90.00","right":"90.00"}
  625. ]
  626. ]
  627. ];
  628. debug_log("pushPareaRes","出推送依赖:".json_encode($info));
  629. $url_res= curl_http_post(json_encode($url_data),$url,false);
  630. $info['pushTime'] = time();
  631. debug_log("pushPareaRes","远程返回结果".$url_res);
  632. }
  633. return $info;
  634. }
  635. // $url="http://47.114.185.186:8115/api/accessReport";
  636. // $url_res= curl_http_post(json_encode($url_data),$url,false);
  637. // debug_log("InAndOUT","远程返回结果".$url_res);
  638. public function test(){
  639. try{
  640. $ues_redis=Cache::store('redis')->handler();
  641. $jsonData= $ues_redis->rpop("mqtt_data");
  642. debug_log("InAndOUT","1212");
  643. }catch(Exception $e){
  644. var_dump($e->getMessage());
  645. }
  646. }
  647. /**
  648. * 删除前1天的数据
  649. *
  650. * @return void
  651. */
  652. public function deleteHistory()
  653. {
  654. while(true)
  655. {
  656. $where[] = ['addTime','<',strtotime("-1 day")];
  657. Db::name('tag_history')->where($where)->delete();
  658. sleep(60*60*24);
  659. }
  660. }
  661. /**
  662. * 检测小程序版本版本 function
  663. *
  664. * @return void
  665. */
  666. public function detectionVersion(){
  667. $token = $_GET['token'];
  668. if (!$token || $token != '444333d3') {
  669. json_fail('缺少token或者token不对');
  670. }
  671. $data["url"]="http://116.62.220.88:8112/static/app/蓝牙小程序/1.1.1/rl-release.apk";
  672. $data["version"]="1.1.1";
  673. json_success("查询版本成功",$data);
  674. }
  675. }