Базовая реализация API для блокировки аккаунта

api/modules/internal/controllers/AccountsController.php

@@ -0,0 +1,30 @@
+<?php
+namespace api\modules\internal\controllers;
+
+use api\components\ApiUser\AccessControl;
+use api\controllers\Controller;
+use common\models\OauthScope as S;
+use yii\helpers\ArrayHelper;
+
+class AccountsController extends Controller {
+
+    public function behaviors() {
+        return ArrayHelper::merge(parent::behaviors(), [
+            'access' => [
+                'class' => AccessControl::class,
+                'rules' => [
+                    [
+                        'actions' => ['block'],
+                        'allow' => true,
+                        'roles' => [S::ACCOUNT_BLOCK],
+                    ],
+                ],
+            ],
+        ]);
+    }
+
+    public function actionBlock(int $accountId) {
+
+    }
+
+}

api/modules/internal/models/BlockForm.php

@@ -0,0 +1,80 @@
+<?php
+namespace api\modules\internal\models;
+
+use api\models\base\ApiForm;
+use common\helpers\Amqp;
+use common\models\Account;
+use common\models\amqp\AccountBanned;
+use PhpAmqpLib\Message\AMQPMessage;
+use Yii;
+
+class BlockForm extends ApiForm {
+
+    const DURATION_FOREVER = -1;
+
+    /**
+     * Нереализованный функционал блокировки аккаунта на определённый период времени.
+     * Сейчас установка этого параметра ничего не даст, аккаунт будет заблокирован навечно,
+     * но по задумке, здесь необходимо передать количество секунд, на которое будет
+     * заблокирован аккаунт пользователя.
+     *
+     * @var int
+     */
+    public $duration = self::DURATION_FOREVER;
+
+    /**
+     * Нереализованный функционал указания причины блокировки аккаунта.
+     *
+     * @var string
+     */
+    public $message;
+
+    /**
+     * @var Account
+     */
+    private $account;
+
+    public function rules() {
+        return [
+            [['duration'], 'integer', 'min' => self::DURATION_FOREVER],
+            [['message'], 'string'],
+        ];
+    }
+
+    public function getAccount(): Account {
+        return $this->account;
+    }
+
+    public function ban(): bool {
+        $transaction = Yii::$app->db->beginTransaction();
+
+        $account = $this->account;
+        $account->status = Account::STATUS_BANNED;
+        $account->save();
+
+        $this->createTask();
+
+        $transaction->commit();
+
+        return true;
+    }
+
+    public function createTask() {
+        $model = new AccountBanned();
+        $model->accountId = $this->account->id;
+        $model->duration = $this->duration;
+        $model->message = $this->message;
+
+        $message = Amqp::getInstance()->prepareMessage($model, [
+            'delivery_mode' => AMQPMessage::DELIVERY_MODE_PERSISTENT,
+        ]);
+
+        Amqp::sendToEventsExchange('accounts.account-banned', $message);
+    }
+
+    public function __construct(Account $account, array $config = []) {
+        $this->account = $account;
+        parent::__construct($config);
+    }
+
+}

common/models/amqp/AccountBanned.php

@@ -0,0 +1,14 @@
+<?php
+namespace common\models\amqp;
+
+use yii\base\Object;
+
+class AccountBanned extends Object {
+
+    public $accountId;
+
+    public $duration = -1;
+
+    public $message = '';
+
+}