php
/
zhjwxt
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
Browse Source

feat(api): 添加聊天功能相关接口和业务逻辑 

- 新增 Chat 控制器，实现聊天功能的各个接口
- 添加 ChatService服务层，处理聊天相关的业务逻辑
- 在路由文件中注册聊天相关的 API 路由
- 修改 ChatFriends 和 ChatMessages 模型，调整软删除字段名称
master
liutong 10 months ago
parent
6ba87727cd
commit
cb440ca228
5 changed files with 419 additions and 2 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Split View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 189
      niucloud/app/api/controller/apiController/Chat.php
  2. 12
      niucloud/app/api/route/route.php
  3. 2
      niucloud/app/model/chat_friends/ChatFriends.php
  4. 2
      niucloud/app/model/chat_messages/ChatMessages.php
  5. 216
      niucloud/app/service/api/apiService/ChatService.php

189
niucloud/app/api/controller/apiController/Chat.php
View File

@ -0,0 +1,189 @@
<?php
// +----------------------------------------------------------------------
// | Niucloud-admin 企业快速开发的多应用管理平台
// +----------------------------------------------------------------------
// | 官方网址：https://www.niucloud.com
// +----------------------------------------------------------------------
// | niucloud团队 版权所有 开源版本可自由商用
// +----------------------------------------------------------------------
// | Author: Niucloud Team
// +----------------------------------------------------------------------
namespace app\api\controller\apiController;
use app\Request;
use app\service\api\apiService\CampusService;
use app\service\api\apiService\ChatService;
use app\service\api\apiService\CommonService;
use core\base\BaseApiService;
/**
* 聊天控制器相关接口
* Class Personnel
* @package app\api\controller\apiController
*/
class Chat extends BaseApiService
{
//获取好友关系列表
public function getChatFriendsList(Request $request)
{
$personnel_id = $request->param('personnel_id', '');//员工人力资源表id(两个参数2选1)
$customer_resources_id = $request->param('customer_resources_id', '');//学生资源表id(两个参数2选1)
if (empty($personnel_id) && empty($customer_resources_id)) {
return fail('缺少参数');
}
$where = [
'personnel_id' => $personnel_id,
'customer_resources_id' => $customer_resources_id,
];
$res = (new ChatService())->getChatFriendsPage($where);
return success($res);
}
//获取好友关系详情
public function getChatFriendsInfo(Request $request)
{
$personnel_id = $request->param('personnel_id','');//员工人力资源表id
$customer_resources_id = $request->param('customer_resources_id','');//学生资源表id
if (empty($personnel_id) && empty($customer_resources_id)) {
return fail('缺少参数');
}
$where = [
'personnel_id' => $personnel_id,
'customer_resources_id' => $customer_resources_id,
];
$res = (new ChatService())->getChatFriendsInfo($where);
if(!$res['data']){
//创建好友关系
$add = (new ChatService())->addChatFriends($where);
if(!$add['code']){
return fail('创建好友关系失败');
}else{
$res = (new ChatService())->getChatFriendsInfo($where);
}
}
if(!$res['code']){
return fail($res['msg']);
}
return success($res['data']);
}
//创建好友关系
public function addChatFriends(Request $request)
{
$personnel_id = $request->param('personnel_id', '');
$customer_resources_id = $request->param('customer_resources_id', '');
if (empty($personnel_id) || empty($customer_resources_id)) {
return fail('缺少参数');
}
$where = [
'personnel_id' => $personnel_id,
'customer_resources_id' => $customer_resources_id,
];
//检测好友关系是否存在
$getChatFriendsInfo = (new ChatService())->getChatFriendsInfo($where);
if ($getChatFriendsInfo['data']) {
return fail('好友关系已存在');
}
$addChatFriends = (new ChatService())->addChatFriends($where);
if (!$addChatFriends['code']) {
return fail($addChatFriends['msg']);
}
return success($addChatFriends['data']);
}
//获取聊天记录
public function getChatMessagesList(Request $request)
{
$friend_id = $request->param('friend_id', '');//关联chat_friends表id
if (empty($friend_id)) {
return fail('发送者类型不正确');
}
$where = [
'friend_id' => $friend_id,
];
$res = (new ChatService())->getChatMessagesList($where);
return success($res);
}
//发送聊天内容
public function sendChatMessages(Request $request)
{
$from_type = $request->param('from_type', '');//发送者类型|personnel=员工,customer=学生(客户)
$from_id = $request->param('from_id', '');//发送者ID
$to_id = $request->param('to_id', '');//接收者ID
$friend_id = $request->param('friend_id', '');//关联chat_friends表id
$message_type = $request->param('message_type', '');//消息类型|text=文本,img=图片
$content = $request->param('content', '');//文本内容（JSON 格式扩展字段）,文本类型=纯文字,图片类型=绝对路径
if (!in_array($message_type, ['text', 'img'])) {
return fail('消息类型不正确');
}
if (!in_array($from_type, ['personnel', 'customer'])) {
return fail('发送者类型不正确');
}
if (empty($from_id) || empty($to_id) || empty($friend_id) || empty($content)) {
return fail('缺少参数');
}
$data = [
'from_type' => $from_type, // 发送者类型：personnel=员工，customer=学生(客户)
'from_id' => $from_id, // 发送者ID（员工/学生），根据from_type判断
'to_id' => $to_id, // 接收者ID（员工/学生），根据from_type判断
'friend_id' => $friend_id, // 关联chat_friends表id
'message_type' => $message_type, // 消息类型：text=文本，img=图片
'content' => $content // 文本内容（JSON格式扩展字段）
];
$res = (new ChatService())->sendChatMessages($data);
if(!$res['code']){
return fail($res['msg']);
}
return success($res['data']);
}
//修改未读消息数量
public function editUnreadCount(Request $request){
$from_type = $request->param('from_type', '');//发送者类型|personnel=员工,customer=学生(客户)
$from_id = $request->param('from_id', '');//发送者ID
$friend_id = $request->param('friend_id', '');//关联chat_friends表id
if (!in_array($from_type, ['personnel', 'customer'])) {
return fail('发送者类型不正确');
}
if (empty($from_id) || empty($friend_id)) {
return fail('缺少参数');
}
$res = (new ChatService())->editUnreadCount($from_type,$friend_id);
// if(!$res){
// return fail('修改失败');
// }
return success($res);
}
}

12
niucloud/app/api/route/route.php
View File

@ -240,6 +240,18 @@ Route::group(function () {
//员工考勤-编辑(员工打卡/请假/签退)
Route::post('attendance/edit', 'apiController.Attendance/edit');
//员工端-用户聊天-好友关系列表
Route::get('chat/getChatFriendsList', 'apiController.Chat/getChatFriendsList');
//员工端-用户聊天-创建好友关系
Route::post('chat/addChatFriends', 'apiController.Chat/addChatFriends');
//员工端-用户聊天-好友关系详情
Route::get('chat/getChatFriendsInfo', 'apiController.Chat/getChatFriendsInfo');
//员工端-用户聊天-获取聊天记录
Route::get('chat/getChatMessagesList', 'apiController.Chat/getChatMessagesList');
//员工端-用户聊天-发送聊天内容
Route::post('chat/sendChatMessages', 'apiController.Chat/sendChatMessages');
//员工端-用户聊天-修改未读消息数量
Route::post('chat/editUnreadCount', 'apiController.Chat/editUnreadCount');

2
niucloud/app/model/chat_friends/ChatFriends.php
View File

@ -42,7 +42,7 @@ class ChatFriends extends BaseModel
* 定义软删除标记字段.
* @var string
*/
protected $deleteTime = 'deleted_at';
protected $deleteTime = 'delete_time';
/**
* 定义软删除字段的默认值.
* @var int

2
niucloud/app/model/chat_messages/ChatMessages.php
View File

@ -40,7 +40,7 @@ class ChatMessages extends BaseModel
* 定义软删除标记字段.
* @var string
*/
protected $deleteTime = 'deleted_at';
protected $deleteTime = 'delete_time';
/**
* 定义软删除字段的默认值.
* @var int

216
niucloud/app/service/api/apiService/ChatService.php
View File

@ -0,0 +1,216 @@
<?php
// +----------------------------------------------------------------------
// | Niucloud-admin 企业快速开发的多应用管理平台
// +----------------------------------------------------------------------
// | 官方网址：https://www.niucloud.com
// +----------------------------------------------------------------------
// | niucloud团队 版权所有 开源版本可自由商用
// +----------------------------------------------------------------------
// | Author: Niucloud Team
// +----------------------------------------------------------------------
namespace app\service\api\apiService;
use app\model\campus\Campus;
use app\model\campus_person_role\CampusPersonRole;
use app\model\chat_friends\ChatFriends;
use app\model\chat_messages\ChatMessages;
use app\model\dict\Dict;
use core\base\BaseApiService;
use think\facade\Db;
/**
* 校区服务层
* Class MemberService
* @package app\service\api\member
*/
class ChatService extends BaseApiService
{
public function __construct()
{
parent::__construct();
}
//查询好友关系列表
public function getChatFriendsPage(array $where)
{
$page_params = $this->getPageParam();//获取请求参数中的页码+分页数
$page = $page_params['page'];
$limit = $page_params['limit'];
$model = new ChatFriends();
//判断用没有员工id
if (!empty($where['personnel_id'])) {
$model = $model->where('personnel_id', $where['personnel_id']);
}
if (!empty($where['customer_resources_id'])) {
$model = $model->where('customer_resources_id', $where['customer_resources_id']);
}
$data = $model->paginate([
'list_rows' => $limit,
'page' => $page,
])->toArray();
return $data;
}
//查询好友关系详情
public function getChatFriendsInfo(array $where)
{
$model = new ChatFriends();
//判断用没有员工id
if (!empty($where['personnel_id'])) {
$model = $model->where('personnel_id', $where['personnel_id']);
}
if (!empty($where['customer_resources_id'])) {
$model = $model->where('customer_resources_id', $where['customer_resources_id']);
}
$data = $model->find();
if ($data) {
$data = $data->toArray();
$res = [
'code' => 1,
'msg' => '操作成功',
'data' => $data
];
return $res;
} else {
$res = [
'code' => 0,
'msg' => '暂无数据',
'data' => []
];
return $res;
}
}
//创建好友关系
public function addChatFriends(array $data)
{
$data = ChatFriends::create($data);
if($data){
$res = [
'code' => 1,
'msg' => '操作成功',
'data' => $data
];
return $res;
}else{
$res = [
'code' => 0,
'msg' => '操作失败',
'data' => []
];
return $res;
}
}
//发送聊天信息
public function sendChatMessages(array $data){
//开启事物操作
Db::startTrans();
try {
$add = ChatMessages::create($data);
if(!empty($data['from_type']) && !empty($data['from_id']) && !empty($data['friend_id'])){
$to_type = 'personnel';
if($data['from_type'] == 'personnel'){
$to_type = 'customer';
}
$this->addUnreadCount($to_type,$data['friend_id']);
$this->editUnreadCount($data['from_type'],$data['friend_id']);
}
if($add){
Db::commit();
$res = [
'code' => 1,
'msg' => '操作成功',
'data' => $add->toArray()
];
return $res;
}else{
Db::rollback();
$res = [
'code' => 0,
'msg' => '操作失败',
'data' => []
];
return $res;
}
}catch (\Exception $exception){
Db::rollback();
$res = [
'code' => 0,
'msg' => '操作失败',
'data' => []
];
return $res;
}
}
//获取聊天记录
public function getChatMessagesList(array $where){
$page_params = $this->getPageParam();//获取请求参数中的页码+分页数
$page = $page_params['page'];
$limit = $page_params['limit'];
$model = new ChatMessages();
$model = $model->where('friend_id',$where['friend_id']);
// 按id倒序排列
$data = $model->order('id', 'desc')->paginate([
'list_rows' => $limit,
'page' => $page,
])->toArray();
return $data;
}
/**
* 修改未读消息数量
* @param $from_type 发送者类型|personnel=员工,customer=学生(客户)
* @param $from_id 发送者ID（员工/学生）
* @param $friend_id 关联chat_friends表id
*/
public function editUnreadCount($from_type ,$friend_id){
$where = [];
if($from_type == 'personnel'){
//员工发送的消息->把员工的未读消息数量清空
$data['unread_count_personnel'] = 0;
}else{
//学生发送的消息->把学生的未读消息数量清空
$data['unread_count_customer_resources'] = 0;
}
$model = ChatFriends::where('id',$friend_id);
$data['updated_at'] = date('Y-m-d H:i:s');
$model = $model->update($data);
return $model;
}
/**
* 追加接收消息的人未读消息数量+1
* @param $to_type 接收者类型|personnel=员工,customer=学生(客户)
* @param $to_id 接收者ID（员工/学生）
* @param $friend_id 关联chat_friends表id
*/
public function addUnreadCount($to_type, $friend_id)
{
$model = ChatFriends::where('id', $friend_id);
if ($to_type == 'personnel') {
// 员工接收的消息 -> 员工的未读消息数量+1
return $model->inc('unread_count_personnel')->update();
} else {
// 学生接收的消息 -> 学生的未读消息数量+1
return $model->inc('unread_count_customer_resources')->update();
}
}
}
Write Preview
Loading…
Cancel
Save