You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
136 lines
4.8 KiB
136 lines
4.8 KiB
<?php
|
|
namespace app\controller;
|
|
|
|
use app\BaseController;
|
|
use app\model\Message as MessageModel;
|
|
|
|
class Message extends BaseController
|
|
{
|
|
public function list()
|
|
{
|
|
$cardNo = $this->request->get('card_no', '');
|
|
$since = $this->request->get('since', 0);
|
|
|
|
if (empty($cardNo)) {
|
|
return json(['code' => -1, 'data' => null, 'msg' => '缺少号码牌']);
|
|
}
|
|
|
|
$query = MessageModel::where('card_no', $cardNo)
|
|
->order('created_at', 'asc');
|
|
|
|
if ($since > 0) {
|
|
$query->where('id', '>', intval($since));
|
|
}
|
|
|
|
$messages = $query->select()->toArray();
|
|
$list = array_map(function ($m) {
|
|
return [
|
|
'id' => $m['id'],
|
|
'cardNo' => $m['card_no'],
|
|
'senderType' => $m['sender_type'],
|
|
'content' => $m['content'],
|
|
'time' => date('Y-m-d H:i:s', strtotime($m['created_at'])),
|
|
'staffId' => $m['staff_id'] ?? null,
|
|
'isRead' => $m['is_read'] ?? 0,
|
|
];
|
|
}, $messages);
|
|
|
|
return json(['code' => 0, 'data' => $list, 'msg' => 'ok']);
|
|
}
|
|
|
|
public function send()
|
|
{
|
|
$cardNo = $this->request->post('cardNo', '');
|
|
$senderType = $this->request->post('senderType', 'customer');
|
|
$content = $this->request->post('content', '');
|
|
$staffId = $this->request->post('staffId', null);
|
|
|
|
if (empty($cardNo) || empty($content)) {
|
|
return json(['code' => -1, 'data' => null, 'msg' => '参数不完整']);
|
|
}
|
|
|
|
if (!in_array($senderType, ['customer', 'staff', 'system'])) {
|
|
return json(['code' => -1, 'data' => null, 'msg' => '发送者类型无效']);
|
|
}
|
|
|
|
if (mb_strlen($content) > 500) {
|
|
return json(['code' => -1, 'data' => null, 'msg' => '消息过长，最多500字']);
|
|
}
|
|
|
|
// 拒单禁聊+结单禁聊：订单已取消(status=3)或已完成(status=2)禁止发送
|
|
$order = \app\model\Order::where('card_no', $cardNo)->order('id', 'desc')->find();
|
|
if ($order && (intval($order->status) === 3 || intval($order->status) === 2)) {
|
|
$msg = $order->status === 3 ? '订单已取消，会话已结束' : '订单已完成，会话已结束';
|
|
return json(['code' => -1, 'data' => null, 'msg' => $msg]);
|
|
}
|
|
|
|
// 存储原始文本，Vue 模板 {{ }} 自动转义防 XSS
|
|
$msg = MessageModel::create([
|
|
'card_no' => $cardNo,
|
|
'sender_type' => $senderType,
|
|
'staff_id' => $staffId,
|
|
'content' => $content,
|
|
'is_read' => 0, // 默认未读
|
|
]);
|
|
|
|
return json(['code' => 0, 'data' => ['id' => $msg->id], 'msg' => 'ok']);
|
|
}
|
|
|
|
// 标记消息为已读
|
|
public function read()
|
|
{
|
|
$cardNo = $this->request->post('card_no', '');
|
|
$staffId = $this->request->post('staff_id', null);
|
|
|
|
if (empty($cardNo)) {
|
|
return json(['code' => -1, 'data' => null, 'msg' => '缺少号码牌']);
|
|
}
|
|
|
|
// 顾客端标记员工消息为已读
|
|
if ($staffId === null) {
|
|
MessageModel::where('card_no', $cardNo)
|
|
->where('sender_type', 'staff')
|
|
->where('is_read', 0)
|
|
->update(['is_read' => 1]);
|
|
} else {
|
|
// 员工端标记顾客消息为已读
|
|
MessageModel::where('card_no', $cardNo)
|
|
->where('sender_type', 'customer')
|
|
->where('is_read', 0)
|
|
->update(['is_read' => 1]);
|
|
}
|
|
|
|
return json(['code' => 0, 'data' => null, 'msg' => 'ok']);
|
|
}
|
|
|
|
// GET api/message/unread?card_no=XXX 或 ?card_no=all&staff_id=1
|
|
// 顾客端：传 card_no，查 staff 发送的未读消息数
|
|
// 员工端：传 card_no=all + staff_id，统计所有顾客发来的未读消息数
|
|
public function unread()
|
|
{
|
|
$cardNo = $this->request->get('card_no', '');
|
|
$staffId = $this->request->get('staff_id', null);
|
|
|
|
if (empty($cardNo)) {
|
|
return json(['code' => -1, 'data' => null, 'msg' => '缺少号码牌']);
|
|
}
|
|
|
|
$query = MessageModel::where('is_read', 0);
|
|
|
|
if ($cardNo === 'all' && $staffId !== null) {
|
|
// 员工端：统计所有对话中顾客发来的未读
|
|
$query->where('sender_type', 'customer');
|
|
} elseif ($staffId !== null) {
|
|
// 员工端指定号码牌
|
|
$query->where('card_no', $cardNo)->where('sender_type', 'customer');
|
|
} else {
|
|
// 顾客端：统计该号码牌员工发来的未读
|
|
$query->where('card_no', $cardNo)->where('sender_type', 'staff');
|
|
}
|
|
|
|
$count = $query->count();
|
|
return json(['code' => 0, 'data' => ['count' => $count], 'msg' => 'ok']);
|
|
}
|
|
}
|
|
|
|
|