xinyouhe/fdesk
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

询单与crm消息通知

Browse Source
This commit is contained in:
mzl
2025-08-25 15:41:07 +08:00
parent 118c8d99f2
commit 635027b97c
1 changed files with 54 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/queue/redis/InquiryToCrmNew.php
+54 -11
View File
@@ -56,28 +56,54 @@ class InquiryToCrmNew implements Consumer
// 更改库信息
$this->syncCustomer($info);
$wsdata = [
'sender_id' => 0,
'sender_type' => 'system',
'title' => '有新的客户线索，' . $info->order_no . '，请及时处理',
'content' => '有新的客户线索，' . $info->order_no . '，请及时处理',
'scene' => 1,
'recipient' => [$info->recipient]
];
// 异步推送
\Webman\RedisQueue\Redis::send('notice', $wsdata);
} catch (\Throwable $th) {
throw $th;
}
}
public function pushWs($title, $content, $recipient)
{
$wsdata = [
'sender_id' => 0,
'sender_type' => 'system',
'title' => $title,
'content' => $content,
'scene' => 1,
'recipient' => $recipient
];
// 异步推送
\Webman\RedisQueue\Redis::send('notice', $wsdata);
}
public function syncCustomer(Model $info)
{
$uInfo = $this->recipientInfo($info);
$crmCustomerInfo = CrmCustomer::where('sn', $info->order_no)->first();
if ($crmCustomerInfo) {
// 消息推送
if ($info->status == 2 && empty($crmCustomerInfo->user_id)) {
// $notice = '分配';
$title = '[询单·分配]新的客户线索【' . $info->order_no . '】，请及时处理';
$content = '[询单·分配]新的客户线索【' . $info->order_no . '】，请及时处理';
$recipient = [$info->recipient];
$this->pushWs($title, $content, $recipient);
} else {
if ($info->status == 2 && $crmCustomerInfo->user_id == $info->recipient) {
// $notice = '更新';
$title = '[询单·更新]客户线索' . $info->order_no . '有新的调整，请及时处理';
$content = '[询单·更新]客户线索' . $info->order_no . '有新的调整，请及时处理';
$recipient = [$info->recipient];
$this->pushWs($title, $content, $recipient);
} else {
// $notice = '重新分配';
$title = '[询单·分配]新的客户线索【' . $info->order_no . '】，请及时处理';
$content = '[询单·分配]新的客户线索【' . $info->order_no . '】，请及时处理';
$recipient = [$info->recipient];
$this->pushWs($title, $content, $recipient);
}
}
$udata = [
'corp_abbr' => $uInfo['corpId'],
'user_id' => $info->recipient,
@@ -115,6 +141,23 @@ class InquiryToCrmNew implements Consumer
if (!$crmCustomer->save() || !$info->save()) {
throw new BusinessException('同步失败，创建客户线索失败');
}
// 消息推送
if ($info->status == 1) {
// $notice = '发布';
$title = '[询单·公海]新的客户线索【' . $info->order_no . '】发布';
$content = '[询单·公海]新的客户线索【' . $info->order_no . '】发布';
$recipient = [$info->recipient];
$this->pushWs($title, $content, $recipient);
}
if ($info->status == 2) {
// $notice = '分配';
$title = '[询单·分配]新的客户线索【' . $info->order_no . '】，请及时处理';
$content = '[询单·分配]新的客户线索【' . $info->order_no . '】，请及时处理';
$recipient = [$info->recipient];
$this->pushWs($title, $content, $recipient);
}
}
return true;
}