<?php

namespace app\job\model\order;

use app\common\model\order\OrderAdvance as OrderAdvanceModel;
use app\common\service\product\factory\ProductFactory;
use app\common\model\order\Order as OrderModel;
use app\common\library\helper;
use app\common\service\order\OrderRefundService;

/**
 * 预售定金订单模型
 */
class OrderAdvance extends OrderAdvanceModel
{
    /**
     * 获取订单列表
     */
    public function getCloseList($with = [])
    {
        return $this->with($with)
            ->where('pay_status', '=', 10)
            ->where('order_status', '=', 10)
            ->where('pay_end_time', '<', time())
            ->where('pay_end_time', '>', 0)
            ->select();
    }

    /**
     * 获取退定金订单列表
     */
    public function getReturnList()
    {
        return $this->where('pay_status', '=', 20)
            ->where('order_status', '=', 20)
            ->where('is_refund', '=', 0)
            ->where('money_return', '=', 1)
            ->select();
    }

    /**
     * 未支付订单自动关闭
     */
    public function close()
    {
        // 查询截止时间未支付的订单
        $list = $this->getCloseList(['order.product', 'advance']);
        $closeOrderAdvanceIds = helper::getArrayColumn($list, 'order_advance_id');
        $this->startTrans();
        try {
            // 取消订单事件
            if (!empty($closeOrderAdvanceIds)) {
                $closeOrderIds = helper::getArrayColumn($list, 'order_id');
                foreach ($list as &$order) {
                    // 回退商品库存
                    ProductFactory::getFactory($order['order']['order_source'])->backProductStock($order['order']['product'], false);
                }
                // 批量更新订单状态为已取消
                (new OrderModel)->onBatchUpdate($closeOrderIds, ['order_status' => 20]);
                $this->where('order_advance_id', 'in', $closeOrderAdvanceIds)->update(['order_status' => 20]);
            }
            $this->commit();
            return $closeOrderAdvanceIds;
        } catch (\Exception $e) {
            $this->error = $e->getMessage();
            $this->rollback();
        }

    }

    /**
     * 已取消订单退定金
     */
    public function return()
    {
        // 查询截止时间未支付的订单
        $list = $this->getReturnList();
        $closeOrderAdvanceIds = helper::getArrayColumn($list, 'order_advance_id');
        // 取消订单事件
        if (!empty($closeOrderAdvanceIds)) {
            foreach ($list as &$item) {
                try {
                    if ((new OrderRefundService)->execute($item)) {
                        // 更新订单状态
                        $item->save([
                            'is_refund' => 1,
                            'refund_money' => $item['pay_price'],
                        ]);
                    }
                } catch (\Exception $e) {
                    $this->error = '订单ID：' . $item['order_advance_id'] . ' 退款失败，错误信息：' . $e->getMessage();
                }
            }
        }
        return $closeOrderAdvanceIds;
    }

}