delete ivs

app/admin/controller/Agent.php

@@ -87,6 +87,14 @@ class Agent extends AdminBaseController
         return json($result);
     }
 
+    // 删除直播间
+    public function awsIvsDelete()
+    {
+        $service = new AgentService();
+        $result = $service->awsIvsDelete($this->request->param());
+        return json($result);
+    }
+
     public function userListByChannel()
     {
         $service = new AgentService();

app/admin/route/app.php

@@ -211,6 +211,7 @@ Route::group('/', function () {
     Route::post('agent/aws_ivs_list', 'Agent/awsIvsList');  //直播推流列表
     Route::post('agent/aws_ivs_add', 'Agent/awsIvsAdd')->middleware('admin_log');   //直播推流配置添加
     Route::post('agent/aws_ivs_edit', 'Agent/awsIvsEdit')->middleware('admin_log');   //直播推流配置编辑
+    Route::post('agent/aws_ivs_delete', 'Agent/awsIvsDelete'); // 删除直播间
     Route::post('agent/user_list_by_channel', 'Agent/userListByChannel');  //代理下某个渠道的注册用户列表
     Route::post('agent/stats_by_channel', 'Agent/statsByChannel'); //按天统计用户数据
 

app/admin/service/AgentService.php

@@ -479,6 +479,30 @@ class AgentService extends AdminBaseService
         }
     }
 
+    // 删除直播间
+    public function awsIvsDelete($param)
+    {
+        try {
+            if (empty($param['id'])) {
+                return $this->toData('400', 'Missing param id');
+            }
+            // 获取直播间配置信息
+            $info = AwsIvsModel::where(['id'=>$param['id']])->find();
+            if (empty($info)) {
+                return $this->toData('500', '操作的数据不存在');
+            }
+            // 请求chat服务，删除对应信息
+            $chatFriendsUrl = env('CHAT_SERVER.BASE_URL') . '/api/group/delete/'.$info->agent_chat_group_id;
+            $chatFriendsRes = (new \app\utility\RequestChatServer())->ReqChatServer($chatFriendsUrl, []);
+            Log::info("删除直播间结果：".json_encode($chatFriendsRes));
+            // 删除直播间配置信息
+            $res = $info->delete();
+            return $this->toData('0', 'success', [$res]);
+        } catch (\Exception $e) {
+            return $this->toData('500', '系统异常 请稍后重试', [$e->getMessage(), $e->getTrace()]);
+        }
+    }
+
     // 代理下每个渠道的用户注册列表
     public function userListByChannel($param)
     {