model = $model; } public function chatSendMessage(Request $request){ Db::startTrans(); try { $this->model->chatSendMessage($request->uid, $request->post()); Db::commit(); }catch (\Exception $e){ Db::rollback(); return api_error_return($e->getMessage()); } return api_succ_return('发送成功'); } public function chatGetNewMessage(Request $request){ Db::startTrans(); try { $data = $this->model->chatGetNewMessage($request->uid, $request->post()); Db::commit(); }catch (\Exception $e){ Db::rollback(); return api_error_return($e->getMessage()); } return api_succ_return(['msg'=>'成功', 'data'=>$data]); } public function chatGetOldMessage(Request $request){ Db::startTrans(); try { $data = $this->model->chatGetOldMessage($request->uid, $request->post()); Db::commit(); }catch (\Exception $e){ Db::rollback(); return api_error_return($e->getMessage()); } return api_succ_return(['msg'=>'成功', 'data'=>$data]); } public function chatBackMessage(Request $request){ $user_info = Db::name('user')->where('id', $request->uid)->find(); if ($user_info['user_type'] != 99){ return api_error_return('暂无权限'); } if (empty($request->post('message_id'))){ return api_error_return('参数错误'); } Db::name('chat_message')->where('id', $request->post('message_id'))->save(['status'=>1]); return api_succ_return('成功'); } public function chatDenyUser(Request $request){ $user_info = Db::name('user')->where('id', $request->uid)->find(); if ($user_info['user_type'] != 99){ return api_error_return('暂无权限'); } $user_id = $request->post('user_id'); if (empty($user_id)){ return api_error_return('参数错误'); } Db::name('user')->where('id', $user_id)->save(['status'=>0,'deny_reason'=>'群聊里面封禁,乱发消息']); return api_succ_return('成功'); } }