<?php

namespace App\Http\Controllers\InternalService;

use App\Http\Controllers\Controller;
use App\Jobs\ProductOrderCancelJob;
use App\Models\YiiModels\Platform;
use App\Models\YiiModels\ProductOrder;
use Exception;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\DB;

/**
 * 内部通讯API
 */
class ApiController extends Controller
{
    private ?Platform $platform = null;

    /**
     * 内部服务
     *
     * @param Request $request
     * @return void
     */
    public function handle(Request $request)
    {
        $token = $request->input('token');
        log_i($token, 'token', 'internal_services');
        if ($token != config('services.internal_service.api_token')) {
            json_error('通讯错误');
        }

        $type = $request->input('type');
        if (method_exists($this, $type)) {
            log_i(' 开始执行：' . $type, 'token', 'internal_services');
            log_i(json_encode(request()->all()), $type, 'internal_services');
            $this->{$type}();
        } else {
            log_i('内部服务数据错误 ' . $type, 'token', 'internal_services');
            json_error('内部服务数据错误 ' . $type);
        }
    }

    /**
     * 创建订单自动取消任务
     *
     * @return void
     */
    public function createOrderAutoCancel()
    {
        $product_order_id = request()->input('product_order_id');
        $minutes = request()->input('minutes');

        ProductOrderCancelJob::dispatch($product_order_id)->delay(now()->addMinutes($minutes));

        json_success('自动取消队列启动成功');
    }

    /**
     * 创建退款请求
     *
     * @return void
     * @throws \Throwable
     */
    public function createOrderRefundHandle()
    {
        $product_order_id = request()->input('product_order_id');
        $refund_no = request()->input('refund_no');

        $productOrder = ProductOrder::where('id', $product_order_id)->first();
        if (!$productOrder) {
            json_error('订单信息不存在');
        }

        DB::beginTransaction();
        $refundResult = [];
        try {
            $refundResult = $productOrder->toRefund($productOrder->total_pay_price, $refund_no);

            DB::commit();
        } catch (Exception $exception) {
            DB::rollBack();
            log_s('申请错误：' . var_export(request()->all(), true) . $exception->getMessage() . $exception->getTraceAsString(), 'order', 'error');
            json_error('申请错误，请重试');
        }

        response()->json($refundResult)->throwResponse();
    }
}