255],
[['min_balance', 'min_balance_milk', 'min_balance_ironsource'], 'number'],
[['notes'], 'string'],
[['chat_link'], 'url'],
];
}
public static function tableName()
{
return 'teams';
}
public function getAccounts()
{
return $this->hasMany(Account::class, ['team_id' => 'id']);
}
public function getTransactions()
{
return $this->hasMany(Transaction::class, ['team_id' => 'id']);
}
public function getClients()
{
return $this->hasMany(Client::class, ['team_id' => 'id']);
}
public function getBalance()
{
return (float)$this->getTransactions()->sum('amount');
}
public function getBalanceByType($type)
{
return (float)$this->getAccounts()->andWhere(['type' => $type])->sum('balance');
}
public function getPositiveTransactions()
{
return $this->getTransactions()
->andWhere(['>', 'amount', 0])
->orderBy(['created_at' => SORT_DESC])
->all();
}
public function getFormattedBalance()
{
return number_format($this->balance, 2, ',', ' ');
}
public function beforeSave($insert)
{
if ($insert && empty($this->access_key)) {
$this->access_key = Yii::$app->security->generateRandomString(32);
}
return parent::beforeSave($insert);
}
public function scenarios()
{
$scenarios = parent::scenarios();
$scenarios[self::SCENARIO_DEFAULT] = [
'name', 'chat_link', 'min_balance', 'min_balance_milk',
'min_balance_ironsource', 'notes', 'access_key'
];
return $scenarios;
}
public function getLatestTransactionDates()
{
return [
'moloco' => $this->getTransactions()
->andWhere(['account_type' => 'moloco'])
->max('spend_date'),
'ironsource' => $this->getTransactions()
->andWhere(['account_type' => 'ironsource'])
->max('spend_date'),
];
}
public function checkAndSendNotifications()
{
foreach ($this->accounts as $account) {
foreach ($account->thresholds as $threshold) {
if ($account->balance < $threshold->threshold_value) {
$this->sendTelegramAlert($threshold);
}
}
}
}
private function sendTelegramAlert($threshold)
{
$message = "⚠️ Внимание!\n"
."Баланс {$threshold->account->name} опустился до "
.number_format($threshold->account->balance, 2, ',', ' ')." $";
foreach ($this->clients as $client) {
try {
$httpClient = new Client();
$httpClient->post(
"https://api.telegram.org/bot".Yii::$app->params['telegram.bot_token']."/sendMessage",
[
'form_params' => [
'chat_id' => $client->chat_id,
'text' => $message,
'parse_mode' => 'HTML'
]
]
);
} catch (\Exception $e) {
Yii::error("Telegram error: {$e->getMessage()}");
}
}
}
}