<?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;

class InquiryToCrm implements Consumer
{
    // 要消费的队列名
    public $queue = 'inquiry-to-crm';

    // 连接名，对应 plugin/webman/redis-queue/redis.php 里的连接`
    public $connection = 'default';

    // 消费
    public function consume($data)
    {
        try {
            // 获取询盘信息
            $info = InquiryLog::with(['channelInfo', 'countryInfo', 'enter'])->where('id', $data['id'])->where('sync_crm', 0)->first();
            
            if ($info) {
                // 获取用户信息
                $recipient = 0;
                $corpId = 0;
                $uinfo = null;
                if ($info->recipient) {
                    $recipient = $info->recipient;
                    $uinfo = User::where('id', $info->recipient)->first();
                    if ($uinfo) {
                        $corpId = $uinfo->corp_id;
                    }
                    // // 消息推送参数 分配
                    // $scene = 'inquiry-person-allocation';
                    // $receiveType = 'person';
                } else {
                    // // 消息推送参数 发布
                    // $scene = 'inquiry-group-send';
                    // $receiveType = 'group';
                }
                // 同步客户数据
                $crmCustomer = new CrmCustomer();
                $crmCustomer->sn            = $info->order_no;
                $crmCustomer->corp_abbr     = $corpId;
                $crmCustomer->user_id       = $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 ($uinfo && $uinfo->email) {
                //     $options = [
                //         'id'    => $info->id,
                //         'email' => $uinfo->email
                //     ];
                //     // Log::info('发送邮件消息：' . json_encode($options));
                //     \Webman\RedisQueue\Redis::send('email-message', $options);
                // }

                $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;
        }
    }

    // 消费失败回调
    /* 
    $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); 
    }
}