<?php

namespace app\queue\redis;

use app\common\enum\PayEnum;
use app\common\model\store_order_cart_info\StoreOrderCartInfo;
use app\common\model\store_product\StoreProduct;
use app\common\model\system_store\SystemStore;
use app\common\service\xpyun\XpsdkPrintApi;
use Webman\RedisQueue\Consumer;
use support\Log;

/**
 * 芯华云订单推送队列消费
 */
class OrderXprinterPushSend implements Consumer
{
    // 要消费的队列名
    public $queue = 'order_xprinter_push_send';

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

    // 消费
    public function consume($data)
    {

            $order=$data['order'];
            $total_price = $order['total_price'];
            $pay_price = $order['pay_price'];
            $deduction_price = $order['deduction_price'];
            $pay_time = date('Y-m-d H:i:s', $order['pay_time']);
            $pay_type = PayEnum::getPaySceneDesc($order['pay_type']);
            $SystemStore = SystemStore::where('id', $order['store_id'])->find();
            $cart_info=StoreOrderCartInfo::where('oid',$order['id'])->select()->each(function($item){
                $find = StoreProduct::with('unitName')->withTrashed()->find();
                $item['store_name']=$find['store_name'];
                return $item;
            });

            $product_arr=[];
            foreach ($cart_info as $k=>$v){
                $product_arr[]=[
                    'name'=>$v['name'],
                    'price'=>$v['price'].'元',
                    'quantity'=>$v['cart_num'],
                    'subtotal'=>$v['total_price'].'元'
                ];
            }

            $api=new XpsdkPrintApi();
            $order=[
                'system_store'=>$SystemStore['name']??'',
                'system_phone'=>$SystemStore['phone']??'',
                'verify_code'=>$order['verify_code'],
                'order_id'=>$order['order_id'],
                'create_time'=>$pay_time,
                'pay_price'=>$pay_price,
                'total_price'=>$total_price,
                'deduction_price'=>$deduction_price,
                'pay_type_name'=>$pay_type,
                'product_arr'=>$product_arr
            ];
            ($api->printFontAlign('74AMP5N6DP21148',$order));
    }
    // 消费失败时
    public function onConsumeFailure(\Throwable $exception, $package)
    {
        $package['max_attempts'] = 0;
        Log::error('推送订单失败', ['order_id' => $package['data'], 'error' => $package['error']]);
        return true;
    }
}