<?php

namespace app\api\controller;

use addons\kefu\library\Common;
use app\common\controller\Api;
use think\Db;
use EasyWeChat\Factory;

/**
 * KeFu 接口
 */
class Kefu extends Api
{
    // 无需登录的接口,*表示全部
    protected $noNeedLogin = ['acceptWxMsg', 'goodsList', 'orderList'];// 实际使用中请去除`goodsList`和`orderList`
    // 无需鉴权的接口,*表示全部
    protected $noNeedRight = ['*'];

    protected $wxBizMsg; // 消息加解密和辅助类实例

    /*
     * 获取未读消息数量
     */
    public function getUnreadMessagesCount()
    {
        $user = $this->auth->getUser();

        // 验证为客服用户
        $kefu_user_info = Common::checkKefuUser(false, $user->id);
        // 获取与客服的会话
        $kefu_session_id = Db::name('kefu_session')->where('user_id', $kefu_user_info['id'])->value('id');
        if ($kefu_session_id) {
            $unread_msg_count = Db::name('kefu_record')
                ->where('session_id', $kefu_session_id)
                ->where('sender_identity', 0)
                ->where('status', 0)
                ->count('id');
        } else {
            $unread_msg_count = 0;
        }

        $this->success('ok', $unread_msg_count);
    }

    /*
     * 获取最后一条未读消息
     */
    public function getUnreadMessages()
    {
        $user = $this->auth->getUser();

        $kefu_user_info = Common::checkKefuUser(false, $user->id);// 验证为客服用户
        $this->success('ok', Common::getUnreadMessages($kefu_user_info['user_id']));
    }

    /*
     * 演示用订单列表接口
     */
    public function orderList()
    {
        // $user = $this->auth->getUser();

        $logo = cdnurl('/assets/addons/kefu/img/buoy1.png', true);

        $order_list = [
            [
                'id'      => 1,
                'subject' => '接口演示订单标题-这是一个演示订单，我来自接口/api/KeFu/orderList',
                'logo'    => $logo,
                'note'    => '接口：/api/KeFu/orderList',
                'price'   => '99',
                'number'  => 1
            ],
            [
                'id'      => 2,
                'subject' => '小米9耳机正品type-c适用于8se/10半入耳式mix3 7pro note3/5原装',
                'logo'    => $logo,
                'note'    => '订单属性订单属性',
                'price'   => '101',
                'number'  => 2
            ],
            [
                'id'      => 3,
                'subject' => '小米9正品耳机等3件商品',
                'logo'    => $logo,
                'note'    => '颜色：红色；礼盒：不要礼盒',
                'price'   => '100',
                'number'  => 3
            ]
        ];

        $this->success('ok', $order_list);
    }

    /*
     * 演示用商品列表接口
     * 此接口用于返回客服前台可用的商品列表
     */
    public function goodsList()
    {
        // $user = $this->auth->getUser();

        $logo = cdnurl('/assets/addons/kefu/img/buoy1.png', true);

        $goods_list = [
            [
                'id'      => 1,
                'subject' => '接口演示商品名称-这是一个演示商品，我来自接口/api/KeFu/goodsList',
                'logo'    => $logo,
                'note'    => '接口：/api/KeFu/goodsList',
                'price'   => '99'
            ],
            [
                'id'      => 2,
                'subject' => '小米9耳机正品type-c适用于8se/10半入耳式mix3 7pro note3/5原装',
                'logo'    => $logo,
                'note'    => '小米通用',
                'price'   => '101'
            ],
            [
                'id'      => 3,
                'subject' => '小米9耳机正品type-c适用于8se/10半入耳式mix3 7pro note3/5原装',
                'logo'    => $logo,
                'note'    => '小米通用',
                'price'   => '100'
            ]
        ];

        $this->success('ok', $goods_list);
    }

    /*
     * 接受/处理来自微信的消息
     */
    public function acceptWxMsg()
    {
        $echostr = $this->request->get('echostr');
        $data    = $this->request->only(['msg_signature', 'timestamp', 'nonce', 'Encrypt']);

        if ($echostr) {
            if ($this->checkSignature()) {
                echo $echostr;
                return;
            }
        }

        // 获取微信小程序配置
        $wechat_temp = Db::name('kefu_config')
            ->whereIn('name', 'wechat_app_id,wechat_app_secret,wechat_token,wechat_encodingkey')
            ->select();
        foreach ($wechat_temp as $key => $value) {
            $wechat_config[$value['name']] = $value['value'];
        }

        $config  = [
            'app_id'  => $wechat_config['wechat_app_id'],
            'secret'  => $wechat_config['wechat_app_secret'],
            'token'   => $wechat_config['wechat_token'],
            'aes_key' => $wechat_config['wechat_encodingkey'],
            /*'log'     => [
                'level' => 'debug',
                'file'  => RUNTIME_PATH . 'log/kefu_wechat.log',
            ],*/
        ];
        $app     = Factory::miniProgram($config);
        $service = $app->customer_service;
        $msg     = '';

        $this->wxBizMsg = new \addons\kefu\library\WechatCrypto\WXBizMsgCrypt();
        $errCode        = $this->wxBizMsg->decryptMsg($data['msg_signature'], $data['timestamp'], $data['nonce'], $data['Encrypt'], $msg);

        if ($errCode == 0) {
            $msg = json_decode($msg, true);

            if (!$msg) {
                \think\Log::record('微信客服消息解析出错，消息内容:' . $msg, 'notice');
                echo "success";
                return;
            }

            if (!empty($msg['MsgType']) && in_array($msg['MsgType'], ["text", "image"])) {

                if ($msg['MsgType'] == "image") {

                    $dlImg        = $this->wxBizMsg->saveImg($msg['MediaId']); // 保存图片
                    $content      = request()->domain() . $dlImg;
                    $message_type = 1;
                } else {

                    $content      = $msg['Content'];
                    $message_type = 0;
                }

                $session = $this->wxBizMsg->userInitialize($msg['FromUserName']);

                if ($session['code'] == 1 || $session['code'] == 2) {

                    if (Db::name('kefu_blacklist')->where('user_id', $session['kefu_user']['id'])->value('id')) {
                        $this->wxBizMsg->sendMessage('您的消息被拒收了，请注意您的发言~', $msg['FromUserName']);
                        return;
                    }

                    if ($session['session']) {
                        // 通知客服新消息
                        $res = Common::socketMessage($session['session']['id'], $content, $message_type, $session['session']['user_id'] . '||user');
                    } else {

                        $user_info = Common::userInfo($session['kefu_user']['id'] . '||user');

                        $last_leave_message_time = Db::name('kefu_leave_message')
                            ->where('user_id', $user_info['id'])
                            ->order('createtime desc')
                            ->value('createtime');

                        if ($last_leave_message_time && ($last_leave_message_time + 20) > time()) {
                            $this->wxBizMsg->sendMessage('由于当前无客服代表在线，请不要频繁发送消息，感谢您的支持！', $msg['FromUserName']);
                            echo "success";
                            return;
                        }

                        $leave_message = [
                            'user_id'    => $user_info['id'],
                            'name'       => $user_info['nickname'],
                            'message'    => $content,
                            'createtime' => time(),
                        ];

                        if (Db::name('kefu_leave_message')->insert($leave_message)) {

                            $leave_message_id = Db::name('kefu_leave_message')->getLastInsID();

                            // 记录轨迹
                            $trajectory = [
                                'user_id'    => $user_info['id'],
                                'csr_id'     => 0,
                                'log_type'   => 6,
                                'note'       => $leave_message_id,
                                'url'        => '',
                                'referrer'   => '',
                                'createtime' => time(),
                            ];

                            Db::name('kefu_trajectory')->insert($trajectory);
                            $this->wxBizMsg->sendMessage('留言成功！', $msg['FromUserName']);
                        }
                    }

                } elseif ($session['code'] == 0) {
                    $this->wxBizMsg->sendMessage($session['msg'], $msg['FromUserName']);
                }

            } else {

                $session = $this->wxBizMsg->userInitialize($msg['FromUserName']);

                if ($session['code'] == 1 || $session['code'] == 0) {
                    $this->wxBizMsg->sendMessage($session['msg'], $msg['FromUserName']);
                }
            }
        } else {
            \think\Log::record('微信客服消息解析出错，消息内容 errCode:' . $errCode, 'notice');
        }

        echo "success";
        return;
    }

    /*是否是验证消息*/
    private function checkSignature()
    {
        $wechat_token = Db::name('kefu_config')->where('name', 'wechat_token')->value('value');

        $signature = $this->request->get('signature');
        $timestamp = $this->request->get('timestamp');
        $nonce     = $this->request->get('nonce');

        $tmpArr = [$wechat_token, $timestamp, $nonce];
        sort($tmpArr, SORT_STRING);
        $tmpStr = implode($tmpArr);
        $tmpStr = sha1($tmpStr);

        if ($tmpStr == $signature) {
            return true;
        } else {
            return false;
        }
    }
}