<?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 pushEmail($id, $title, $email)
    {
        $options = [
            'id'    => $id,
            'email' => $email,
            'title' => $title,
        ];
        \Webman\RedisQueue\Redis::send('email-message', $options);
    }

    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);
                $this->pushEmail($info->id, $title, $uInfo['uinfo']['email']);
            } 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);
                    $this->pushEmail($info->id, $title, $uInfo['uinfo']['email']);
                } else {
                    // $notice = '重新分配'; 
                    $title = '[询单·分配] 新的客户线索【' . $info->order_no . '】，请及时处理';
                    $content = '[询单·分配] 新的客户线索【' . $info->order_no . '】，请及时处理';
                    $recipient = [$info->recipient];
                    // $this->pushWs($title, $content, $recipient);
                    $this->pushEmail($info->id, $title, $uInfo['uinfo']['email']);
                }
            }

            $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);
                $this->pushEmail($info->id, $title, $uInfo['uinfo']['email']);
            }

            if ($info->status == 2) {
                // $notice = '分配';
                $title = '[询单·分配] 新的客户线索【' . $info->order_no . '】，请及时处理';
                $content = '[询单·分配] 新的客户线索【' . $info->order_no . '】，请及时处理';
                $recipient = [$info->recipient];
                // $this->pushWs($title, $content, $recipient);
                $this->pushEmail($info->id, $title, $uInfo['uinfo']['email']);
            }
        }
        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); 
    }
}