<?php

namespace app\queue\command\kuaishou;


use app\gateway\service\RedisService;

use app\merchant\service\OrderHistoryService;
use app\merchant\service\OrderLastHistoryService;
use app\merchant\service\OrderLastweekHistoryService;
use app\merchant\service\OrderService;
use app\merchant\service\OrderTwoHistoryService;
use app\robot\controller\api\Qqbot;
use dever\Log;
use think\admin\Command;
use think\console\Input;
use think\console\Output;
use think\Collection;
use think\facade\Db;

/**
 * 快手商家更新令牌
 * Class KamiOrderStatusSync
 * @package app\data\command
 */
class KsBotInterceptNotify extends Command
{
    protected $redis = false;
    protected function configure()
    {
        $this->setName('xQueue:KsBotInterceptNotify')->setDescription('[ 快手商家 ] 查询拦截订单定时推送并反馈');
    }

    /**
     * @param Input  $input
     * @param Output $output
     * @throws \think\admin\Exception
     */
    protected function execute(Input $input, Output $output)
    {
        ini_set('memory_limit', '1024M');

//        Db::name('merchant_order_lj')->where('order_id','=', $value['order_id'])->find()


//        $cur = time();
//        $time = 180;
//        $whereRaw = $cur . '-unix_timestamp(create_at) >=' . $time;


        list($count, $total) = [0, Db::name('merchant_order_lj')->whereRaw('status = 4')->count()];
        $countFaild = 0;
        $countSuccess = 0 ;


        Db::name('merchant_order_lj')->whereRaw('status = 4')->chunk(100, function (Collection $data) use (&$count, $total,&$countFaild,&$countSuccess) {

//        var_dump($orderlist);die;
            $url = 'send_group_msg';
            $param = array();
            $qqBotService = new Qqbot($this->app);

            foreach ($data->toArray() as $vo) {
                $count++;
                $orderInfo = $this->getOrder($vo['order_id']);
                if ($orderInfo['status'] == '2') {
                    $countFaild++;
                    $update = [
                        'status' => 3
                    ];
                    Db::name('merchant_order_lj')->where('order_id', '=', $vo['order_id'])->update($update);

                    $param['group_id'] = '687976099';#群组号
                    $atqq = '949734474';

                    $param['message'] = "[CQ:at,qq=" . $atqq . "] " . $vo['account'] . " 拦截失败，已经充值成功。 ";
                    $send = $qqBotService->send($url, $param);
                    if (isset($send['status']) && $send['status'] == 'ok') {
                        $this->setQueueProgress(" {$vo['order_id']} 拦截失败并通知客服", $count / $total * 100);
                    } else {
                        $this->setQueueProgress(" {$vo['order_id']} 拦截失败机器人异常，未发生通知", $count / $total * 100);
                    }

                } elseif ($orderInfo['status'] == '3') {
                    $countSuccess++;
                    $update = [
                        'status' => 2
                    ];
                    Db::name('merchant_order_lj')->where('order_id', '=', $vo['order_id'])->update($update);
                    $this->setQueueProgress(" {$vo['order_id']} 拦截成功", $count / $total * 100);

//                    $param['group_id'] = '869366904';#群组号
//                    $atqq = '949734474';
//
//                    $param['message'] = "[CQ:at,qq=".$atqq."] ".$vo['account']." 拦截成功,系统正在操作退款。 ";
//                    $send = $this->send($url, $param);
//                    if(isset($send['status']) && $send['status'] == 'ok'){
//                        $this->setQueueProgress(" {$vo['order_id']} 拦截失败并通知客服", $count / $total * 100);
//                    }else{
//                        $this->setQueueProgress(" {$vo['order_id']} 拦截失败机器人异常，未发生通知", $count / $total * 100);
//                    }
                } elseif ($orderInfo['status'] == '4') {
                    $this->redis();

                    $is_send=true;

                    if ($this->redis->get('rediskey-' . $vo['order_id'])) {
                        $is_send = false;
                    }
//                            $timeout_staus = 2;
                    if ($this->redis->get('rediskey-1H-' . $vo['order_id'])) {
                        $is_send = false;
                    }

//
                    if ($this->redis->get('rediskey-TOP-' . $vo['order_id'])) {
                        $is_send = false;
                    }

                    if (!$this->redis->get('rediskey-lj-' . $vo['order_id'])) {

                        if($vo['cid']==6){
                            $url = 'https://d.reapi.bao111.com/gateway/api.bxtlanjie/order';

                            if(isset($value['order_id']) && $value['order_id']){
                                try {

                                    #推送到redis队列
                                    $msg = http_post($url, $value);
//                                        var_dump($msg);
                                    // var_dump($msg);
                                    if($msg != 'ok'){
                                        Log::write('gateway', 'failorder_d', $value);
                                    }else{
                                        $send=['status'=>'ok'] ;
                                    }


                                } catch (\Exception $e) {

                                    Log::write('errorTip', 'failorder_d', $e->getMessage());
                                }
                            }
                        }elseif($is_send){
                            $chanelGroup = $qqBotService->getChanelGroup($vo['cid'], $vo['mid']);
                            $param['group_id'] = $chanelGroup['group_id'];#群组号
                            $cur = time();
                            $create_at= strtotime($vo['create_at']);
                            $cssj = $cur - $create_at;
//                        $cssj = $cur . '-unix_timestamp(create_at)';
                            $numtiem = 600;
                            $num = intval($cssj / $numtiem);

                            if ($num > 10) {
                                $param['message'] = $chanelGroup['atqq'] . "[CQ:at,qq=530979976] 请人工介入核实，以下为客户申请拦截订单，此次为第" . $num . "次提醒，请优先处理 \r " . $vo['account'];
                                $send = $qqBotService->send($url, $param);
                            } elseif ($num <= 1) {
                                $send = ['status'=>'ok'];

                            }else {
                                $param['message'] = $chanelGroup['atqq'] . " 以下为客户申请拦截订单，此次为第" . $num . "次提醒，请优先处理 \r " . $vo['account'];
                                $send = $qqBotService->send($url, $param);
                            }


                        }

                        if (isset($send['status']) && $send['status'] == 'ok') {
                            $this->setQueueProgress(" {$vo['order_id']} 重新拦截并推送渠道成功", $count / $total * 100);
                        } elseif(!$is_send) {
                            $this->setQueueProgress(" {$vo['order_id']} 为机器人超时拦截，停止推送", $count / $total * 100);
                        }else {
                            $this->setQueueProgress(" {$vo['order_id']} 重新拦截并推送渠道失败", $count / $total * 100);
                        }
                        $this->redis->set('rediskey-lj-' . $vo['order_id'], '1', 10 * 60);
                    }

                }
            }


        });
        $chulizhong = $count - $countSuccess - $countFaild;
        $this->setQueueSuccess("总计 {$total} 个拦截订单， 拦截成功 {$countSuccess} 个订单，失败 {$countFaild}  笔订单 ，还有 {$chulizhong}正在拦截！");
    }

    protected function getOrder($order_id)
    {
        $orderService = OrderService::instance();
        $order = $orderService->get($order_id);
        if (!$order) {
            $orderLastweekHistoryService = OrderLastweekHistoryService::instance();
            $order = $orderLastweekHistoryService->get($order_id);
        }
        if (!$order) {
            $orderLastHistoryService = OrderLastHistoryService::instance();
            $order = $orderLastHistoryService->get($order_id);
        }
        if (!$order) {
            $orderTwoHistoryService = OrderTwoHistoryService::instance();
            $order = $orderTwoHistoryService->get($order_id);
        }
        if (!$order) {
            $orderHistoryService = OrderHistoryService::instance();
            $order = $orderHistoryService->get($order_id);
        }
        return $order;
    }

    # 查找订单

    public function send($url, $param)
    {
        $geturl = 'http://127.0.0.1:7374/' . $url;
        return http_post($geturl, $param);

    }

    protected function redis()
    {
        if (!$this->redis) {
            $this->redis = RedisService::getInstance();
        }
    }

}