TransactionService::createUpdateRecord() - Code Metrics - cashwarden/api - Measure and Improve Code Quality continuously with Scrutinizer

TransactionService::createUpdateRecord() B
last analyzed 2022-01-25 03:18 UTC

↳ Parent: TransactionService
Complexity

Conditions	6
Paths	20
Size

Total Lines	31
Code Lines	24
Duplication

Lines	0
Ratio	0 %
Importance

Changes	1
Bugs	0	Features	0
Metric	Value
cc	6
eloc	24
c	1
b	0
f	0
nc	20
nop	1
dl	0
loc	31
rs	8.9137
<?php

namespace app\core\services;

use app\core\exceptions\CannotOperateException;
use app\core\exceptions\InternalException;
use app\core\exceptions\InvalidArgumentException;
use app\core\helpers\ArrayHelper;
use app\core\models\Account;
use app\core\models\Category;
use app\core\models\Record;
use app\core\models\Tag;
use app\core\models\Transaction;
use app\core\traits\ServiceTrait;
use app\core\types\DirectionType;
use app\core\types\RecordSource;
use app\core\types\TransactionType;
use Exception;
use Yii;
use yii\base\BaseObject;
use yii\base\InvalidConfigException;
use yii\db\Exception as DBException;
use yii\db\Expression;
use yii\web\NotFoundHttpException;
use yiier\graylog\Log;
use yiier\helpers\Setup;

/**
 * @property-read int $accountIdByDesc
 */
class TransactionService extends BaseObject
{
    use ServiceTrait;

    /**
     * @param Transaction $transaction
     * @return bool
     * @throws \yii\db\Exception
     */
    public static function createUpdateRecord(Transaction $transaction)
    {
        $data = [];
        if (in_array($transaction->type, [TransactionType::EXPENSE, TransactionType::TRANSFER])) {
            array_push($data, ['direction' => DirectionType::EXPENSE, 'account_id' => $transaction->from_account_id]);
        }
        if (in_array($transaction->type, [TransactionType::INCOME, TransactionType::TRANSFER])) {
            array_push($data, ['direction' => DirectionType::INCOME, 'account_id' => $transaction->to_account_id]);
        }
        $model = new Record();
        foreach ($data as $datum) {
            $conditions = ['transaction_id' => $transaction->id, 'direction' => $datum['direction']];
            if (!$_model = Record::find()->where($conditions)->one()) {
                $_model = clone $model;
                $_model->source = $transaction->source;
$answer = 42;

$correct = false;

$correct = (bool) $answer;
            }
            $_model->user_id = $transaction->user_id;
            $_model->transaction_id = $transaction->id;
            $_model->category_id = $transaction->category_id;
            $_model->amount_cent = $transaction->amount_cent;
            $_model->currency_amount_cent = $transaction->currency_amount_cent;
            $_model->currency_code = $transaction->currency_code;
            $_model->date = $transaction->date;
            $_model->exclude_from_stats = $transaction->exclude_from_stats;
$answer = 42;

$correct = false;

$correct = (bool) $answer;
            $_model->transaction_type = $transaction->type;
            $_model->load($datum, '');
            if (!$_model->save()) {
                throw new DBException(Setup::errorMessage($_model->firstErrors));
            }
        }
        return true;
    }

    public function createByCSV($filename)
    {
        ini_set("memory_limit", "1024M");
        ini_set("set_time_limit", "0");
        ini_set('max_execution_time', 1200); //1200 seconds = 20 minutes
        $filename = $this->uploadService->getFullFilename($filename);
        $row = $total = $success = $fail = 0;
        $items = [];
        $model = new Transaction();
        if (($handle = fopen($filename, "r")) !== false) {
        if (($handle = fopen(/** @scrutinizer ignore-type */ $filename, "r")) !== false) {
            while (($data = fgetcsv($handle)) !== false) {
                $row++;
                // 去除第一行数据
                if ($row <= 1) {
                    continue;
                }

                $num = count($data);
                $newData = [];
                for ($c = 0; $c < $num; $c++) {
                    $newData[$c] = trim($data[$c]);
                }
                $_model = clone $model;
                try {
                    // 账单日期,类别,收入/支出,金额(CNY),标签（多个英文逗号隔开）,描述,备注,账户1,账户2
                    //2020-08-20,餐饮食品,支出,28.9,,买菜28.9,,
                    $baseConditions = ['user_id' => Yii::$app->user->id];
                    $_model->date = Yii::$app->formatter->asDatetime(strtotime($newData[0]), 'php:Y-m-d H:i');
                    $_model->category_id = Category::find()->where($baseConditions + ['name' => $newData[1]])->scalar();
class Id
{
    public $id;

    public function __construct($id)
    {
        $this->id = $id;
    }

}

class Account
{
    /** @var  Id $id */
    public $id;
}

$account_id = false;

if (starsAreRight()) {
    $account_id = new Id(42);
}

$account = new Account();
if ($account instanceof Id)
{
    $account->id = $account_id;
}
                    if (!$_model->category_id) {
                        throw new DBException(Yii::t('app', 'Category not found.'));
                    }
                    $accountId = Account::find()->where($baseConditions + ['name' => $newData[7]])->scalar();
                    $accountId = $accountId ?: data_get(AccountService::getDefaultAccount(), 'id');
                    if (!$accountId) {
                        throw new DBException(Yii::t('app', 'Default account not found.'));
                    }
                    switch ($newData[2]) {
                        case '收入':
                            $_model->type = TransactionType::getName(TransactionType::INCOME);
$answer = 42;

$correct = false;

$correct = (bool) $answer;
                            $_model->to_account_id = $accountId;
class Id
{
    public $id;

    public function __construct($id)
    {
        $this->id = $id;
    }

}

class Account
{
    /** @var  Id $id */
    public $id;
}

$account_id = false;

if (starsAreRight()) {
    $account_id = new Id(42);
}

$account = new Account();
if ($account instanceof Id)
{
    $account->id = $account_id;
}
                            break;
                        case '支出':
                            $_model->type = TransactionType::getName(TransactionType::EXPENSE);
                            $_model->from_account_id = $accountId;
class Id
{
    public $id;

    public function __construct($id)
    {
        $this->id = $id;
    }

}

class Account
{
    /** @var  Id $id */
    public $id;
}

$account_id = false;

if (starsAreRight()) {
    $account_id = new Id(42);
}

$account = new Account();
if ($account instanceof Id)
{
    $account->id = $account_id;
}
                            break;
                        case '转账':
                            $_model->type = TransactionType::getName(TransactionType::TRANSFER);
                            $_model->from_account_id = $accountId;
                            $_model->to_account_id = Account::find()
                                ->where($baseConditions + ['name' => $newData[8]])
                                ->scalar();
                            if (!$_model->to_account_id) {
                                throw new InvalidArgumentException($newData[8] . '转账「账户2」不能为空');
                            }
                            break;
                        default:
                            # code...
                            break;
                    }
                    $_model->currency_amount = abs($newData[3]);
                    $_model->currency_code = 'CNY';
                    $_model->tags = array_filter(explode('/', $newData[4]));
                    $_model->description = $newData[5];
                    $_model->remark = $newData[6];

                    $_model->source = RecordSource::IMPORT;
                    if (!$_model->validate()) {
                        throw new DBException(Setup::errorMessage($_model->firstErrors));
                    }
                    array_push($items, $_model);
                } catch (\Exception $e) {
                    Log::error('导入运费失败', [$newData, (string)$e]);
                    $failList[] = [
                        'data' => $newData,
                        'reason' => $e->getMessage(),
                    ];
                    $fail++;
                }
                $total++;
            }
            fclose($handle);

            if (!$fail) {
                /** @var Transaction $item */
                foreach (array_reverse($items) as $item) {
                    $item->save();
                    $success++;
                }
            }

            return [
                'total' => $total,
                'success' => $success,
                'fail' => $fail,
                'fail_list' => $failList ?? []
            ];
        }
    }

    /**
     * @param Transaction $transaction
     * @param array $changedAttributes
     * @throws Exception|\Throwable
     */
    public static function deleteRecord(Transaction $transaction, array $changedAttributes)
    {
        $type = $transaction->type;
        if (data_get($changedAttributes, 'type') && $transaction->type !== TransactionType::TRANSFER) {
            $direction = $type == TransactionType::INCOME ? DirectionType::EXPENSE : DirectionType::INCOME;
            Record::deleteAll(['transaction_id' => $transaction->id, 'direction' => $direction]);
        }
    }

    /**
     * @param int $id
     * @param int $userId
     * @return Transaction
     * @throws NotFoundHttpException
     * @throws Exception
     */
    public function copy(int $id, int $userId = 0)
    {
        $model = $this->findCurrentOne($id, $userId);
        $transaction = new Transaction();
        $values = $model->toArray();
        unset($values['date']);
        $transaction->date = Yii::$app->formatter->asDatetime('now', 'php:Y-m-d H:i');
        $transaction->source = RecordSource::CRONTAB;
        $transaction->load($values, '');
        if (!$transaction->save(false)) {
            throw new Exception(Setup::errorMessage($transaction->firstErrors));
        }
        return $transaction;
    }

    /**
     * @param string $desc
     * @param null|int $source
     * @return Transaction
     * @throws InternalException
     * @throws \Throwable
     */
    public function createByDesc(string $desc, $source = null): Transaction
    {
        $model = new Transaction();
        try {
            $model->description = $desc;
            $model->user_id = Yii::$app->user->id;
class Id
{
    public $id;

    public function __construct($id)
    {
        $this->id = $id;
    }

}

class Account
{
    /** @var  Id $id */
    public $id;
}

$account_id = false;

if (starsAreRight()) {
    $account_id = new Id(42);
}

$account = new Account();
if ($account instanceof Id)
{
    $account->id = $account_id;
}
            $rules = $this->getRuleService()->getRulesByDesc($desc);
            $model->type = $this->getDataByDesc(
class Id
{
    public $id;

    public function __construct($id)
    {
        $this->id = $id;
    }

}

class Account
{
    /** @var  Id $id */
    public $id;
}

$account_id = false;

if (starsAreRight()) {
    $account_id = new Id(42);
}

$account = new Account();
if ($account instanceof Id)
{
    $account->id = $account_id;
}
                $rules,
                'then_transaction_type',
                function () use ($desc) {
                    if (ArrayHelper::strPosArr($desc, ['收到', '收入']) !== false) {
                        return TransactionType::getName(TransactionType::INCOME);
                    }
                    return TransactionType::getName(TransactionType::EXPENSE);
                }
            );
            $transactionType = TransactionType::toEnumValue($model->type);
            $transactionType = TransactionType::toEnumValue(/** @scrutinizer ignore-type */ $model->type);

            if (in_array($transactionType, [TransactionType::EXPENSE, TransactionType::TRANSFER])) {
                $model->from_account_id = $this->getDataByDesc(
class Id
{
    public $id;

    public function __construct($id)
    {
        $this->id = $id;
    }

}

class Account
{
    /** @var  Id $id */
    public $id;
}

$account_id = false;

if (starsAreRight()) {
    $account_id = new Id(42);
}

$account = new Account();
if ($account instanceof Id)
{
    $account->id = $account_id;
}
                    $rules,
                    'then_from_account_id',
                    [$this, 'getAccountIdByDesc']
                );
                if (!$model->from_account_id) {
                    throw new CannotOperateException(Yii::t('app', 'Default account not found.'));
                }
            }

            if (in_array($transactionType, [TransactionType::INCOME, TransactionType::TRANSFER])) {
                $model->to_account_id = $this->getDataByDesc(
class Id
{
    public $id;

    public function __construct($id)
    {
        $this->id = $id;
    }

}

class Account
{
    /** @var  Id $id */
    public $id;
}

$account_id = false;

if (starsAreRight()) {
    $account_id = new Id(42);
}

$account = new Account();
if ($account instanceof Id)
{
    $account->id = $account_id;
}
                    $rules,
                    'then_to_account_id',
                    [$this, 'getAccountIdByDesc']
                );
                if (!$model->to_account_id) {
                    throw new CannotOperateException(Yii::t('app', 'Default account not found.'));
                }
            }

            $model->category_id = $this->getDataByDesc(
class Id
{
    public $id;

    public function __construct($id)
    {
        $this->id = $id;
    }

}

class Account
{
    /** @var  Id $id */
    public $id;
}

$account_id = false;

if (starsAreRight()) {
    $account_id = new Id(42);
}

$account = new Account();
if ($account instanceof Id)
{
    $account->id = $account_id;
}
                $rules,
                'then_category_id',
                function () {
                    //  todo 根据交易类型查找默认分类
                    return (int)data_get(CategoryService::getDefaultCategory(), 'id', 0);
                }
            );

            $model->date = $this->getDateByDesc($desc);

            $model->tags = $this->getDataByDesc($rules, 'then_tags');
            $model->status = $this->getDataByDesc($rules, 'then_transaction_status');
class Id
{
    public $id;

    public function __construct($id)
    {
        $this->id = $id;
    }

}

class Account
{
    /** @var  Id $id */
    public $id;
}

$account_id = false;

if (starsAreRight()) {
    $account_id = new Id(42);
}

$account = new Account();
if ($account instanceof Id)
{
    $account->id = $account_id;
}
            $model->reimbursement_status = $this->getDataByDesc($rules, 'then_reimbursement_status');
class Id
{
    public $id;

    public function __construct($id)
    {
        $this->id = $id;
    }

}

class Account
{
    /** @var  Id $id */
    public $id;
}

$account_id = false;

if (starsAreRight()) {
    $account_id = new Id(42);
}

$account = new Account();
if ($account instanceof Id)
{
    $account->id = $account_id;
}

            $model->currency_amount = $this->getAmountByDesc($desc);
            $model->currency_code = user('base_currency_code');
            if (!$model->save()) {
                throw new DBException(Setup::errorMessage($model->firstErrors));
            }
            $source ? Record::updateAll(['source' => $source], ['transaction_id' => $model->id]) : null;
            return $model;
        } catch (Exception $e) {
            Yii::error(
                ['request_id' => Yii::$app->requestId->id, $model->attributes, $model->errors, (string)$e],
                __FUNCTION__
            );
            throw new InternalException($e->getMessage());
        }
    }

    /**
     * @param Record[] $records
     * @return array
     * @throws InvalidConfigException
     */
    public function formatRecords(array $records)
    {
        $items = [];
        foreach ($records as $record) {
            $key = Yii::$app->formatter->asDatetime(strtotime($record->date), 'php:Y-m-d');
            $items[$key]['records'][] = $record;
            $items[$key]['date'] = $key;
            $types = [TransactionType::EXPENSE, TransactionType::INCOME];
            if (in_array($record->transaction_type, $types)) {
                // todo 计算有待优化
                if ($record->direction === DirectionType::EXPENSE) {
                    $items[$key]['record_out_amount_cent'][] = $record->amount_cent;
                    $items[$key]['out'] = Setup::toYuan(array_sum($items[$key]['record_out_amount_cent']));
                }
                if ($record->direction === DirectionType::INCOME) {
                    $items[$key]['record_in_amount_cent'][] = $record->amount_cent;
                    $items[$key]['in'] = Setup::toYuan(array_sum($items[$key]['record_in_amount_cent']));
                }
            }
        }
        return $items;
    }

    /**
     * @param int $id
     * @param int $rating
     * @return int
     * @throws InvalidConfigException
     */
    public function updateRating(int $id, int $rating)
    {
        return Transaction::updateAll(
            ['rating' => $rating, 'updated_at' => Yii::$app->formatter->asDatetime('now')],
            ['id' => $id]
        );
    }

    /**
     * @param Account $account
     * @return bool
     * @throws \yii\db\Exception
     * @throws InvalidConfigException
     */
    public static function createAdjustRecord(Account $account)
    {
        $diff = $account->currency_balance_cent - AccountService::getCalculateCurrencyBalanceCent($account->id);
        if (!$diff) {
            return false;
        }
        $model = new Record();
        $model->direction = $diff > 0 ? DirectionType::INCOME : DirectionType::EXPENSE;
        $model->currency_amount_cent = abs($diff);
        $model->user_id = $account->user_id;
        $model->account_id = $account->id;
        $model->transaction_id = 0;
        $model->transaction_type = TransactionType::ADJUST;
        $model->category_id = CategoryService::getAdjustCategoryId();
class Id
{
    public $id;

    public function __construct($id)
    {
        $this->id = $id;
    }

}

class Account
{
    /** @var  Id $id */
    public $id;
}

$account_id = false;

if (starsAreRight()) {
    $account_id = new Id(42);
}

$account = new Account();
if ($account instanceof Id)
{
    $account->id = $account_id;
}
        $model->currency_code = $account->currency_code;
        $model->date = self::getCreateRecordDate();
        if (!$model->save()) {
            Yii::error(
                ['request_id' => Yii::$app->requestId->id, $model->attributes, $model->errors],
                __FUNCTION__
            );
            throw new DBException(Setup::errorMessage($model->firstErrors));
        }
        return true;
    }


    /**
     * @param string $desc
     * @return array
     * @throws Exception
     */
    public static function matchTagsByDesc(string $desc): array
    {
        if ($tags = TagService::getTagNames()) {
            $tags = implode('|', $tags);
            preg_match_all("!({$tags})!", $desc, $matches);
            return data_get($matches, '0', []);

        }
        return [];
    }

    /**
     * @param array $tags
     * @throws InvalidConfigException
     */
    public static function createTags(array $tags)
    {
        $has = Tag::find()
            ->select('name')
            ->where(['user_id' => Yii::$app->user->id, 'name' => $tags])
            ->column();
        /** @var TagService $tagService */
        $tagService = Yii::createObject(TagService::class);
        foreach (array_diff($tags, $has) as $item) {
            try {
                $tagService->create(['name' => $item]);
            } catch (Exception $e) {
                Log::error('add tag fail', [$item, (string)$e]);
            }
        }
    }

    /**
     * @param string $desc
     * @return mixed|null
     * @throws Exception
     */
    public function getAmountByDesc(string $desc): float
    {
        // todo 支持简单的算数
        preg_match_all('!([0-9]+(?:\.[0-9]{1,2})?)!', $desc, $matches);

        if (count($matches[0])) {
            return array_pop($matches[0]);
        }
        return 0;
    }

    /**
     * @param array $rules
     * @param string $field
     * @param \Closure|array|null $callback
     * @return null|int|string
     * @throws Exception
     */
    private function getDataByDesc(array $rules, string $field, $callback = null)
    {
        foreach ($rules as $rule) {
            if ($data = data_get($rule->toArray(), $field)) {
                return $data;
            }
        }
        return $callback ? call_user_func($callback) : null;
    }

    /**
     * @return int
     * @throws Exception
     */
    public function getAccountIdByDesc(): int
    {
        $userId = Yii::$app->user->id;
        return (int)data_get(AccountService::getDefaultAccount($userId), 'id', 0);
        return (int)data_get(AccountService::getDefaultAccount(/** @scrutinizer ignore-type */ $userId), 'id', 0);
    }

    /**
     * @param string $desc
     * @return string date Y-m-d
     * @throws InvalidConfigException
     */
    private function getDateByDesc(string $desc): string
    {
        if (ArrayHelper::strPosArr($desc, ['昨天', '昨日']) !== false) {
            return self::getCreateRecordDate(time() - 3600 * 24 * 1);
        }

        if (ArrayHelper::strPosArr($desc, ['前天']) !== false) {
            return self::getCreateRecordDate(time() - 3600 * 24 * 2);
        }

        if (ArrayHelper::strPosArr($desc, ['大前天']) !== false) {
            return self::getCreateRecordDate(time() - 3600 * 24 * 3);
        }

        try {
            $time = self::getCreateRecordDate('now', 'php:H:i');
            preg_match_all('!([0-9]+)(月)([0-9]+)(号|日)!', $desc, $matches);
            if (($m = data_get($matches, '1.0')) && $d = data_get($matches, '3.0')) {
                $currMonth = Yii::$app->formatter->asDatetime('now', 'php:m');
                $y = Yii::$app->formatter->asDatetime($m > $currMonth ? strtotime('-1 year') : time(), 'php:Y');
                $m = sprintf("%02d", $m);
                $d = sprintf("%02d", $d);
                return "{$y}-{$m}-{$d} {$time}";
            }

            preg_match_all('!([0-9]+)(号|日)!', $desc, $matches);
            if ($d = data_get($matches, '1.0')) {
                $currDay = Yii::$app->formatter->asDatetime('now', 'php:d');
                $m = Yii::$app->formatter->asDatetime($d > $currDay ? strtotime('-1 month') : time(), 'php:Y-m');
                $d = sprintf("%02d", $d);
                return "{$m}-{$d} {$time}";
            }
        } catch (Exception $e) {
            Log::warning('未识别到日期', $desc);
        }

        return self::getCreateRecordDate();
    }


    /**
     * @param string $value
     * @param string $format
     * @return string
     * @throws InvalidConfigException
     */
    public static function getCreateRecordDate(string $value = 'now', string $format = 'php:Y-m-d H:i')
    {
        return Yii::$app->formatter->asDatetime($value, $format);
    }


    /**
     * @param string $tag
     * @param int $userId
     * @return bool|int|string|null
     */
    public static function countTransactionByTag(string $tag, int $userId)
    {
        return Transaction::find()
            ->where(['user_id' => $userId])
            ->andWhere(new Expression('FIND_IN_SET(:tag, tags)'))->addParams([':tag' => $tag])
            ->count();
    }

    /**
     * @param int $id
     * @param int $userId
     * @return Transaction|object
     * @throws NotFoundHttpException
     */
    public static function findCurrentOne(int $id, int $userId = 0): Transaction
    {
        $userId = $userId ?: Yii::$app->user->id;
        if (!$model = Transaction::find()->where(['id' => $id, 'user_id' => $userId])->one()) {
            throw new NotFoundHttpException('No data found');
        }
        return $model;

    }

    /**
     * @return array
     * @throws Exception
     */
    public function exportData()
    {
        $data = [];
        $categoriesMap = CategoryService::getCurrentMap();
        $accountsMap = AccountService::getCurrentMap();
        $types = TransactionType::texts();
        $items = Transaction::find()
            ->where(['user_id' => Yii::$app->user->id])
            ->orderBy(['date' => SORT_DESC])
            ->asArray()
            ->all();
        foreach ($items as $k => $item) {
            $datum['date'] = $item['date'];
            $datum['category_name'] = data_get($categoriesMap, $item['category_id'], '');
            $datum['type'] = data_get($types, $item['type'], '');
            $datum['currency_amount'] = Setup::toYuan($item['currency_amount_cent']);
            $datum['tags'] = str_replace(',', '/', $item['tags']);
            $datum['description'] = $item['description'];
            $datum['remark'] = $item['remark'];
            $datum['account1'] = '';
            $datum['account2'] = '';
            switch ($item['type']) {
                case TransactionType::INCOME:
                    $datum['account1'] = data_get($accountsMap, $item['to_account_id'], '');
                    break;
                case TransactionType::EXPENSE:
                    $datum['account1'] = data_get($accountsMap, $item['from_account_id'], '');
                    break;
                case TransactionType::TRANSFER:
                    $datum['account1'] = data_get($accountsMap, $item['from_account_id'], '');
                    $datum['account2'] = data_get($accountsMap, $item['to_account_id'], '');
                    break;
                default:
                    # code...
                    break;
            }
            array_push($data, array_values($datum));

        }
        return $data;
    }
}

cashwarden / api

TransactionService::createUpdateRecord() B last analyzed 2022-01-25 03:18 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

TransactionService::createUpdateRecord() B
last analyzed 2022-01-25 03:18 UTC
