110 lines
3.2 KiB
PHP
110 lines
3.2 KiB
PHP
<?php
|
|
|
|
declare(strict_types=1);
|
|
|
|
namespace app\adminapi\lists\qywx;
|
|
|
|
use app\adminapi\lists\BaseAdminDataLists;
|
|
use app\common\lists\ListsSearchInterface;
|
|
use app\common\model\auth\Admin;
|
|
use app\common\model\QywxExternalContact;
|
|
use app\common\model\QywxMsgSession;
|
|
|
|
/**
|
|
* 企微消息会话列表
|
|
*
|
|
* 查询参数：
|
|
* staff_userid - 过滤某员工的会话（支持传 admin_id 反查）
|
|
* external_userid- 过滤某客户
|
|
* keyword - 按客户名 / 摘要 模糊搜索
|
|
* only_unread - 仅未读
|
|
*/
|
|
class MsgSessionLists extends BaseAdminDataLists implements ListsSearchInterface
|
|
{
|
|
public function setSearch(): array
|
|
{
|
|
return [
|
|
'=' => ['staff_userid', 'external_userid', 'roomid', 'session_type'],
|
|
];
|
|
}
|
|
|
|
private function baseQuery()
|
|
{
|
|
$query = QywxMsgSession::where($this->searchWhere);
|
|
|
|
$adminId = (int) ($this->params['admin_id'] ?? 0);
|
|
if ($adminId > 0) {
|
|
$wxId = Admin::where('id', $adminId)->value('work_wechat_userid');
|
|
if ($wxId) {
|
|
$query->where('staff_userid', $wxId);
|
|
} else {
|
|
// 找不到对应企微 userid 时不返回任何会话
|
|
$query->where('id', 0);
|
|
}
|
|
}
|
|
|
|
$keyword = trim((string) ($this->params['keyword'] ?? ''));
|
|
if ($keyword !== '') {
|
|
$kw = addcslashes($keyword, '%_\\');
|
|
$extIds = QywxExternalContact::whereLike('name', '%' . $kw . '%')->column('external_userid');
|
|
$query->where(function ($q) use ($kw, $extIds) {
|
|
$q->whereLike('last_msg_summary', '%' . $kw . '%');
|
|
if ($extIds) {
|
|
$q->whereOr('external_userid', 'in', $extIds);
|
|
}
|
|
});
|
|
}
|
|
|
|
if (!empty($this->params['only_unread'])) {
|
|
$query->where('unread_staff', '>', 0);
|
|
}
|
|
|
|
return $query->order('last_msg_time', 'desc');
|
|
}
|
|
|
|
public function lists(): array
|
|
{
|
|
$rows = $this->baseQuery()
|
|
->limit($this->limitOffset, $this->limitLength)
|
|
->select()
|
|
->toArray();
|
|
|
|
if (empty($rows)) {
|
|
return [];
|
|
}
|
|
|
|
$extIds = array_values(array_unique(array_filter(array_map(
|
|
fn ($r) => (string) ($r['external_userid'] ?? ''),
|
|
$rows
|
|
))));
|
|
$extMap = [];
|
|
if ($extIds) {
|
|
$extMap = QywxExternalContact::whereIn('external_userid', $extIds)
|
|
->column('name,avatar,type,gender,corp_name,unionid', 'external_userid');
|
|
}
|
|
|
|
$staffIds = array_values(array_unique(array_filter(array_map(
|
|
fn ($r) => (string) ($r['staff_userid'] ?? ''),
|
|
$rows
|
|
))));
|
|
$staffMap = [];
|
|
if ($staffIds) {
|
|
$staffMap = Admin::whereIn('work_wechat_userid', $staffIds)
|
|
->column('id,name,avatar', 'work_wechat_userid');
|
|
}
|
|
|
|
foreach ($rows as &$r) {
|
|
$r['customer'] = $extMap[$r['external_userid']] ?? null;
|
|
$r['staff'] = $staffMap[$r['staff_userid']] ?? null;
|
|
}
|
|
unset($r);
|
|
|
|
return $rows;
|
|
}
|
|
|
|
public function count(): int
|
|
{
|
|
return $this->baseQuery()->count();
|
|
}
|
|
}
|