app\components\AccountManager::update()

Complexity

Conditions	6
Paths	6

Size

Total Lines	42
Code Lines	21

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

1 Method

Rating	Name	Duplication	Size	Complexity
A	AccountManager::monitor()	0	14	2

<?php
/**
 * Created for IG Monitoring.
 * User: jakim <pawel@jakimowski.info>
 * Date: 28.04.2018
 */

namespace app\components;


use app\components\traits\FindOrCreate;
use app\models\Account;
use app\models\Media;
use app\models\MediaAccount;
use yii\base\Component;
use yii\helpers\StringHelper;

class AccountManager extends Component
{
    use FindOrCreate;

    public function monitorRelatedAccounts(Account $parent, array $accounts)
    {
        foreach ($accounts as $account) {
            if (is_string($account)) {
                /** @var Account $account */
                $account = $this->findOrCreate(['username' => $account], Account::class);
            }
            //calculation monitoring level
            if ($parent->accounts_monitoring_level > 1) {
                $level = $parent->accounts_monitoring_level - 1;
                if ($level > $account->accounts_monitoring_level) {
                    $account->accounts_monitoring_level = $level;
                }
            }

            $this->monitor($account, $parent->proxy_id, $parent->proxy_tag_id);

            $tags = empty($parent->accounts_default_tags) ? $parent->tags : StringHelper::explode($parent->accounts_default_tags, ',', true, true);
            $tagManager = \Yii::createObject(TagManager::class);
            $tagManager->saveForAccount($account, $tags);
        }
    }

    public function monitor($account, $proxyId = null, $proxyTagId = null): Account
    {
        if (is_string($account)) {
            /** @var Account $account */
            $account = $this->findOrCreate(['username' => $account], Account::class);
        }

        $account->proxy_id = $proxyId;
        $account->proxy_tag_id = $proxyTagId;
        $account->monitoring = 1;

        $account->save();

        return $account;
    }

    public function saveForMedia(Media $media, array $usernames)
    {
        $this->saveUsernames($usernames);

        $createdAt = (new \DateTime())->format('Y-m-d H:i:s');
        $rows = array_map(function ($id) use ($media, $createdAt) {
            return [
                $media->id,
                $id,
                $createdAt,
            ];
        }, Account::find()
            ->andWhere(['username' => $usernames])
            ->column());

        $sql = \Yii::$app->db->queryBuilder
            ->batchInsert(MediaAccount::tableName(), ['media_id', 'account_id', 'created_at'], $rows);
        $sql = str_replace('INSERT INTO ', 'INSERT IGNORE INTO ', $sql);
        \Yii::$app->db->createCommand($sql)
            ->execute();
    }

    /**
     * @param array|string[] $usernames
     * @throws \yii\db\Exception
     */
    public function saveUsernames(array $usernames)
    {
        $createdAt = (new \DateTime())->format('Y-m-d H:i:s');
        $rows = array_map(function ($username) use ($createdAt) {
            return [
                $username,
                $createdAt,
                $createdAt,
            ];
        }, $usernames);

        $sql = \Yii::$app->db->getQueryBuilder()
            ->batchInsert(Account::tableName(), ['username', 'updated_at', 'created_at'], $rows);
        $sql = str_replace('INSERT INTO ', 'INSERT IGNORE INTO ', $sql);
        \Yii::$app->db->createCommand($sql)
            ->execute();
    }
}