218 lines
8.0 KiB
PHP
218 lines
8.0 KiB
PHP
<?php
|
|
|
|
namespace app\queue\redis;
|
|
|
|
use app\inquiry\service\InquiryLogService;
|
|
use app\common\model\CrmCustomer;
|
|
use app\common\model\InquiryLog;
|
|
use Webman\RedisQueue\Consumer;
|
|
use app\common\model\User;
|
|
use app\common\utils\FeishuMessage;
|
|
use support\exception\BusinessException;
|
|
use support\Log;
|
|
use support\Model;
|
|
|
|
class InquiryToCrmNew implements Consumer
|
|
{
|
|
// 要消费的队列名
|
|
public $queue = 'inquiry-to-crm-new';
|
|
|
|
// 连接名，对应 plugin/webman/redis-queue/redis.php 里的连接`
|
|
public $connection = 'default';
|
|
|
|
// 消费
|
|
public function consume($data)
|
|
{
|
|
|
|
/*
|
|
询单 与 CRM 之间的同步场景描述
|
|
|
|
添加（询单）
|
|
添加 不发 不分 （不同步）1
|
|
添加 发了 不分 （要同步）2
|
|
添加 不发 分了 （要同步）3
|
|
添加 不发 直分 （要同步）4
|
|
|
|
更新（询单）
|
|
没发 没分 更新 （不同步）5
|
|
没发 分过 更新 （要同步）6
|
|
发过 没分 更新 （要同步）7
|
|
发过 分过 更新 （要同步）8
|
|
*/
|
|
|
|
try {
|
|
// 获取询盘信息
|
|
$info = InquiryLog::with(['channelInfo', 'countryInfo', 'enter'])->where('id', $data['id'])->first();
|
|
|
|
// 无论添加 或 更新，询单必然要存在
|
|
if (!$info) {
|
|
throw new BusinessException('询盘不存在：' . $data['id']);
|
|
}
|
|
|
|
if ($info->status == 0 && $info->recipient == 0) {
|
|
// 如果询单未发、未分，则不与crm同步，不做任何处理
|
|
return true;
|
|
}
|
|
|
|
// 更改库信息
|
|
$this->syncCustomer($info);
|
|
} 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 = [
|
|
<<<<<<< HEAD
|
|
'corp_abbr' => $uInfo['corpId'],
|
|
=======
|
|
'corp_id' => $uInfo['corpId'],
|
|
>>>>>>> feature/distinct
|
|
'user_id' => $info->recipient,
|
|
'channel_id' => $info->channel,
|
|
'country_id' => $info->country,
|
|
'magnitude' => $info->quality,
|
|
'email' => $info->email,
|
|
'phone' => $info->tel,
|
|
'WhatsApp' => $info->whatsapp,
|
|
'contacts' => $info->contacts,
|
|
'desc_collect' => $info->content,
|
|
];
|
|
if (!$crmCustomerInfo->update($udata)) {
|
|
throw new BusinessException('同步失败，更新客户线索失败');
|
|
}
|
|
} else {
|
|
$crmCustomer = new CrmCustomer();
|
|
$crmCustomer->sn = $info->order_no;
|
|
<<<<<<< HEAD
|
|
$crmCustomer->corp_abbr = $uInfo['corpId'];
|
|
=======
|
|
$crmCustomer->corp_id = $uInfo['corpId'];
|
|
>>>>>>> feature/distinct
|
|
$crmCustomer->user_id = $uInfo['recipient'];
|
|
$crmCustomer->type = 1;
|
|
$crmCustomer->channel_id = $info->channel;
|
|
$crmCustomer->country_id = $info->country;
|
|
$crmCustomer->magnitude = $info->quality;
|
|
$crmCustomer->email = $info->email;
|
|
$crmCustomer->phone = $info->tel;
|
|
$crmCustomer->WhatsApp = $info->whatsapp;
|
|
$crmCustomer->contacts = $info->contacts;
|
|
$crmCustomer->desc_collect = $info->content;
|
|
$crmCustomer->enter_user_id = $info->enter_user_id;
|
|
$crmCustomer->obtain = time();
|
|
<<<<<<< HEAD
|
|
=======
|
|
if(empty($uInfo['recipient'])){
|
|
$crmCustomer->deleted_at = time();
|
|
}
|
|
>>>>>>> feature/distinct
|
|
// 修改同步CRM状态
|
|
$info->sync_crm = 1;
|
|
// 保存
|
|
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);
|
|
}
|
|
|
|
if ($info->status == 2) {
|
|
// $notice = '分配';
|
|
$title = '[询单·分配] 新的客户线索【' . $info->order_no . '】，请及时处理';
|
|
$content = '[询单·分配] 新的客户线索【' . $info->order_no . '】，请及时处理';
|
|
$recipient = [$info->recipient];
|
|
$this->pushWs($title, $content, $recipient);
|
|
}
|
|
}
|
|
return true;
|
|
}
|
|
|
|
public function recipientInfo(Model $info)
|
|
{
|
|
$recipient = 0;
|
|
$corpId = 0;
|
|
$uinfo = null;
|
|
if (!empty($info->recipient)) {
|
|
$recipient = $info->recipient;
|
|
$uinfo = User::where('id', $info->recipient)->first();
|
|
if ($uinfo) {
|
|
$corpId = $uinfo->corp_id;
|
|
}
|
|
}
|
|
return [
|
|
'recipient' => $recipient,
|
|
'corpId' => $corpId,
|
|
'uinfo' => $uinfo
|
|
];
|
|
}
|
|
|
|
// 消费失败回调
|
|
/*
|
|
$package = [
|
|
'id' => 1357277951, // 消息ID
|
|
'time' => 1709170510, // 消息时间
|
|
'delay' => 0, // 延迟时间
|
|
'attempts' => 2, // 消费次数
|
|
'queue' => 'send-mail', // 队列名
|
|
'data' => ['to' => 'tom@gmail.com', 'content' => 'hello'], // 消息内容
|
|
'max_attempts' => 5, // 最大重试次数
|
|
'error' => '错误信息' // 错误信息
|
|
]
|
|
*/
|
|
public function onConsumeFailure(\Throwable $e, $package)
|
|
{
|
|
echo "consume failure\n";
|
|
echo $e->getMessage() . "\n";
|
|
// 无需反序列化
|
|
var_export($package);
|
|
}
|
|
} |