123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150 |
- <?php
- namespace App\Http\Controllers;
- use App\Models\Kele;
- use App\Workerman\Events;
- use GatewayWorker\BusinessWorker;
- use GuzzleHttp\Client;
- use Illuminate\Http\Request;
- use Illuminate\Support\Facades\Log;
- use Workerman\Worker;
- use GatewayWorker\Lib\Gateway;
- class IndexController extends Controller
- {
- public function index($data){
- $kele=Kele::find(1);
- $kele->name=$data;
- $kele->save();
- }
- public function websocket(){
- dd(1);
-
- $message='{"cmd":"ping","sn":"T69174","timestamp":1682491407}';
- $id='7f00000108fd00000001';
- Gateway::sendToUid($id,$message);
- Gateway::sendToClient($id,$message);
- dd(json_decode($message,true));
- }
-
- public function JudgeMessage($client_id,$message){
- try {
- $re=json_decode($message,true);
- if (!isset($re['cmd'])){
- Gateway::sendToClient($client_id,$message);
- }
- if ($re['cmd']=='declare'){
- $this->declare($client_id,$re);
- }elseif ($re['cmd']=='ping'){
- $this->ping($client_id,$re);
- }elseif($re['cmd']=='to_client'){
- $data=$re['data'];
- switch ($data['cmd']){
- case 'addUserRet':
- $this->addUserRet($client_id,$re);
- break;
- case 'delAllUserRet':
- $this->delAllUserRet($client_id,$data);
- default:
- $this->delAllUserRet($client_id,$data);
- break;
- }
- }
- }catch (\Exception $exception){
- Log::error('出错了啊:'.$exception->getMessage());
- Gateway::sendToClient($client_id,$message);
- }
- }
-
- public function ping($client_id,$data){
- $message=[
- 'cmd'=>'pong'
- ];
- Log::error($client_id.'这是心跳'.json_encode($data));
- Gateway::sendToClient($client_id,json_encode($message));
-
- $url='http://api.szy.admin.cliu.cc/api/ws/ping?sn='.$data['sn'].'&time='.$data['timestamp'].'&client_id='.$client_id;
- $client=new Client();
- $client->get($url);
- }
-
- public function declare($client_id,$data){
- $message=[
- 'cmd'=>'declare',
- 'message'=>'success'
- ];
- Log::error('这是第一次连接'.json_encode($data));
-
- Gateway::sendToClient($client_id,json_encode($message));
-
- $url='http://api.szy.admin.cliu.cc/api/ws/device?sn='.$data['sn'].'&time='.$data['timestamp'].'&client_id='.$client_id;
- $client=new Client();
- $client->get($url);
- }
-
- public function addUserRet($client_id,$data){
- if ($data['data']['code']!=0){
-
- Log::error('不成功');
-
- $url='http://api.szy.admin.cliu.cc/api/ws/SendError?sn='.$data['form'].'&phone='.$data['data']['user_id'].'&client_id='.$client_id;
- $client=new Client();
- $client->get($url);
- }else{
-
- $url='http://api.szy.admin.cliu.cc/api/ws/SendSucc?sn='.$data['form'].'&phone='.$data['data']['user_id'].'&client_id='.$client_id;
- $client=new Client();
- $client->get($url);
- }
- }
-
- public function delAllUserRet($client_id,$data){
- Log::error($data);
- if ($data['code']==0){
- Log::error('删除全部信息成功!');
- }
- }
- public function demos(){
- $index=new TcpController();
- $index->Accept(14321,'FA73502771890126,http://fangw.jiuweiyun.cn/api/auth/230329143852O2TNZGM_0000 CL1685698345ED');
- }
- }
|