订单完成换真实接口

app/Controller/v3/HorsemanController.php

@@ -3,8 +3,14 @@
 
 namespace App\Controller\v3;
 
+use App\Constants\v3\ErrorCode;
+use App\Constants\v3\LogLabel;
 use App\Controller\BaseController;
+use App\Exception\ErrorCodeException;
+use App\Model\v3\OrderMain;
 use App\Service\v3\Interfaces\HorsemanServiceInterface;
+use App\Service\v3\Interfaces\SeparateAccountsServiceInterface;
+use Hyperf\DbConnection\Db;
 use Hyperf\Di\Annotation\Inject;
 use App\Service\v3\Interfaces\OrderOnlineServiceInterface;
 use App\Request\v3\EmployeesRequest;
@@ -23,6 +29,12 @@ class HorsemanController extends BaseController
      */
     protected $orderOnlineService;
 
+    /**
+     * @Inject
+     * @var SeparateAccountsServiceInterface
+     */
+    protected $separateAccountsService;
+
     public function getOrderList(EmployeesRequest $request)
     {
         $employeesId = $this->request->input('employees_id', -1);
@@ -62,7 +74,17 @@ class HorsemanController extends BaseController
     public function orderComplete(HorsemanOrderRequest $request)
     {
         $globalOrderId = $this->request->input('global_order_id', -1);
-        $res = $this->orderOnlineService->completeForHorseman($globalOrderId);
-        return $this->success($res);
+        $userId = OrderMain::query()->where('global_order_id',$globalOrderId)->value('user_id');
+        Db::beginTransaction();
+        try {
+            $this->orderOnlineService->doComplete($globalOrderId, $userId);
+            $this->separateAccountsService->orderOnlineCompleted($globalOrderId, $userId);
+            Db::commit();
+            return $this->success(true);
+        } catch (\Exception $e) {
+            Db::rollBack();
+            $this->log->event(LogLabel::ORDER_COMPLETE_LOG, ['exception' => $e->getMessage()]);
+            throw new ErrorCodeException(ErrorCode::ORDER_COMPLETE_FAIL);
+        }
     }
 }