lanzu_api_2021-12-26/app/JsonRpc/OrderService.php

<?php

namespace App\JsonRpc;

use App\Commons\Log;
use App\Constants\ErrorCode;
use App\Service\SeparateAccountsServiceInterface;
use App\Service\v3\SfExpress;
use Hyperf\DbConnection\Db;
use Hyperf\RpcServer\Annotation\RpcService;
use Hyperf\Di\Annotation\Inject;
use App\Constants\LogLabel;

/**
 * @RpcService(name="OrderService", protocol="jsonrpc-http", server="jsonrpc-http", publishTo="")
 */
class OrderService implements OrderServiceInterface
{

    /**
     * @Inject
     * @var Log
     */
    protected $log;

    /**
     * @Inject
     * @var \App\Service\OrderServiceInterface
     */
    protected $orderService;

    /**
     * @Inject
     * @var SeparateAccountsServiceInterface
     */
    protected $separateAccountsService;

    public function onlineComplete($global_order_id)
    {
        Db::beginTransaction();
        try {

            $this->orderService->onlineCompleted($global_order_id);
            $this->separateAccountsService->orderOnlineCompleted($global_order_id);

            Db::commit();
            return [
                "status" => 200,
                "code" => 0,
                "result" => [],
                "message" => '调用成功'
            ];
        } catch (\Exception $e) {

            Db::rollBack();
            $this->log->event(LogLabel::ONLINE_COMPLETE_LOG, ['exception' => $e->getMessage()]);
            return [
                "status" => 200,
                "code" =>ErrorCode::SEPARATE_ACCOUNTS_ERROR,
                "result" => [],
                "message" => ErrorCode::getMessage(ErrorCode::SEPARATE_ACCOUNTS_ERROR)
            ];
        }

    }

    /**
     * 线上订单退款
     * 申请退款 state = 8
     * 退款成功 state = 9
    */
    public function onlineRefund($global_order_id){
        $result = [
            "status" => 200,
            "code" => ErrorCode::ORDER_FAILURE,
            "result" => [],
            "message" => ''
        ];

		# 取消顺丰配送
		go(function () use ($global_order_id) {
			SfExpress::getInstance()->cancelOrder(['order_id' => $global_order_id]);
		});

        $res = $this->orderService->onlineRefund($global_order_id);
        if($res['code'] > 0){
            $result['result'] = $res;
            $result['message'] = '退款失败';
        }else{
            $result['code'] = 0;
            $result['result'] = $res;
            $result['message'] = '退款成功';
        };

        return $result;
    }
}