From 15ba0234e75ec3fb1eeeb44521d420959713a0cc Mon Sep 17 00:00:00 2001
From: "WIN-C27C5MSVTPO\\16961" <1696136552@qq.com>
Date: Thu, 4 Sep 2025 10:36:12 +0800
Subject: [PATCH] =?UTF-8?q?=E8=AF=A2=E5=8D=95=E6=8E=A8=E9=80=81crm?=
 =?UTF-8?q?=E9=98=9F=E5=88=97=E5=A4=9A=E4=BD=99=E6=96=87=E4=BB=B6=E5=88=A0?=
 =?UTF-8?q?=E9=99=A4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../redis/InquiryToCrmNew_BACKUP_5243.php     | 218 ------------------
 app/queue/redis/InquiryToCrmNew_BASE_5243.php |   0
 .../redis/InquiryToCrmNew_LOCAL_5243.php      | 204 ----------------
 .../redis/InquiryToCrmNew_REMOTE_5243.php     | 207 -----------------
 4 files changed, 629 deletions(-)
 delete mode 100644 app/queue/redis/InquiryToCrmNew_BACKUP_5243.php
 delete mode 100644 app/queue/redis/InquiryToCrmNew_BASE_5243.php
 delete mode 100644 app/queue/redis/InquiryToCrmNew_LOCAL_5243.php
 delete mode 100644 app/queue/redis/InquiryToCrmNew_REMOTE_5243.php

diff --git a/app/queue/redis/InquiryToCrmNew_BACKUP_5243.php b/app/queue/redis/InquiryToCrmNew_BACKUP_5243.php
deleted file mode 100644
index d63b683..0000000
--- a/app/queue/redis/InquiryToCrmNew_BACKUP_5243.php
+++ /dev/null
@@ -1,218 +0,0 @@
-<?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); 
-    }
-}
\ No newline at end of file
diff --git a/app/queue/redis/InquiryToCrmNew_BASE_5243.php b/app/queue/redis/InquiryToCrmNew_BASE_5243.php
deleted file mode 100644
index e69de29..0000000
diff --git a/app/queue/redis/InquiryToCrmNew_LOCAL_5243.php b/app/queue/redis/InquiryToCrmNew_LOCAL_5243.php
deleted file mode 100644
index a350c7e..0000000
--- a/app/queue/redis/InquiryToCrmNew_LOCAL_5243.php
+++ /dev/null
@@ -1,204 +0,0 @@
-<?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 = [
-                'corp_abbr'     => $uInfo['corpId'],
-                '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;
-            $crmCustomer->corp_abbr     = $uInfo['corpId'];
-            $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();
-            // 修改同步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); 
-    }
-}
\ No newline at end of file
diff --git a/app/queue/redis/InquiryToCrmNew_REMOTE_5243.php b/app/queue/redis/InquiryToCrmNew_REMOTE_5243.php
deleted file mode 100644
index 075deda..0000000
--- a/app/queue/redis/InquiryToCrmNew_REMOTE_5243.php
+++ /dev/null
@@ -1,207 +0,0 @@
-<?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 = [
-                'corp_id'     => $uInfo['corpId'],
-                '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;
-            $crmCustomer->corp_id     = $uInfo['corpId'];
-            $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();
-            if(empty($uInfo['recipient'])){
-                $crmCustomer->deleted_at = time();
-            }
-            // 修改同步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); 
-    }
-}
\ No newline at end of file