|
|
|
@ -19,13 +19,12 @@ use Hyperf\DbConnection\Db; |
|
|
|
use Hyperf\Guzzle\CoroutineHandler; |
|
|
|
use Hyperf\RpcServer\Annotation\RpcService; |
|
|
|
use Hyperf\Di\Annotation\Inject; |
|
|
|
use App\JsonRpc\OrderonlineServiceInterface as OrderonlineRpcService; |
|
|
|
use function AlibabaCloud\Client\json; |
|
|
|
use App\JsonRpc\OrdersServiceInterface; |
|
|
|
|
|
|
|
/** |
|
|
|
* @RpcService(name="OrderOnlineService", protocol="jsonrpc-http", server="jsonrpc-http", publishTo="") |
|
|
|
* @RpcService(name="OrdersService", protocol="jsonrpc-http", server="jsonrpc-http", publishTo="") |
|
|
|
*/ |
|
|
|
class OrderonlineService implements OrderonlineRpcService |
|
|
|
class OrdersService implements OrdersServiceInterface |
|
|
|
{ |
|
|
|
|
|
|
|
/** |
|
|
|
@ -76,7 +75,7 @@ class OrderonlineService implements OrderonlineRpcService |
|
|
|
} catch (\Exception $e) { |
|
|
|
|
|
|
|
Db::rollBack(); |
|
|
|
$this->log->event(LogLabel::ORDER_COMPLETE_LOG, ['jsonrpc_order_service_exception_onlineComplete' => $e->getMessage(), 'params' => json([$global_order_id, $user_id])]); |
|
|
|
$this->log->event(LogLabel::ORDER_COMPLETE_LOG, ['jsonrpc_order_service_exception_onlineComplete' => $e->getMessage(), 'params' => json_encode([$global_order_id, $user_id])]); |
|
|
|
return [ |
|
|
|
"status" => 200, |
|
|
|
"code" => $e->getCode() ?? ErrorCode::ORDER_COMPLETE_FAIL, |