<?php

namespace sammo\API\Betting;

use sammo\Session;
use DateTimeInterface;
use sammo\Betting;
use sammo\DB;
use sammo\DTO\BettingItem;
use sammo\Validator;
use sammo\GameConst;
use sammo\KVStorage;
use sammo\UserLogger;
use sammo\Util;

class Bet extends \sammo\BaseAPI
{
    public function validateArgs(): ?string
    {
        $v = new Validator($this->args);
        $v->rule('required', [
            'bettingID',
            'bettingType',
            'amount'
        ])
            ->rule('integer', 'bettingID')
            ->rule('integerArray', 'bettingType')
            ->rule('integer', 'amount')
            ->rule('min', 'amount', 1);

        if (!$v->validate()) {
            return $v->errorStr();
        }
        return null;
    }

    public function getRequiredSessionMode(): int
    {
        return static::REQ_GAME_LOGIN;
    }

    public function launch(Session $session, ?DateTimeInterface $modifiedSince, ?string $reqEtag)
    {
        $db = DB::db();

        /** @var int */
        $bettingID = $this->args['bettingID'];
        /** @var int[] */
        $bettingType = $this->args['bettingType'];
        /** @var int */
        $amount = $this->args['amount'];

        $gameStor = KVStorage::getStorage($db, 'game_env');

        $bettingHelper = new Betting($bettingID);
        $bettingInfo = $bettingHelper->getInfo();

        if ($bettingInfo->finished) {
            return '이미 종료된 베팅입니다';
        }

        [$year, $month] = $gameStor->getValuesAsArray(['year', 'month']);
        $yearMonth = Util::joinYearMonth($year, $month);


        if ($bettingInfo->closeYearMonth <= $yearMonth) {
            return '이미 마감된 베팅입니다';
        }

        if ($bettingInfo->openYearMonth > $yearMonth) {
            return '아직 시작되지 않은 베팅입니다';
        }

        if (count($bettingType) != $bettingInfo->selectCnt) {
            return '필요한 선택 수를 채우지 못했습니다.';
        }

        $bettingTypeKey = $bettingHelper->convertBettingKey($bettingType);

        $inheritStor = KVStorage::getStorage($db, "inheritance_{$session->userID}");

        $prevBetAmount = $db->queryFirstField('SELECT sum(amount) FROM ng_betting WHERE betting_id = %i AND user_id = %i', $bettingID, $session->userID) ?? 0;

        if ($prevBetAmount + $amount > 1000) {
            return (1000 - $prevBetAmount) . ' 포인트까지만 베팅 가능합니다.';
        }

        if ($bettingInfo->reqInheritancePoint) {
            $remainPoint = ($inheritStor->getValue('previous') ?? [0, 0])[0];
            if ($remainPoint < $amount) {
                return '유산포인트가 충분하지 않습니다.';
            }
        } else {
            $remainPoint = $db->queryFirstField('SELECT gold FROM general WHERE no = %i', $session->generalID) ?? 0;
            if ($remainPoint < GameConst::$generalMinimumGold + $amount) {
                return '금이 부족합니다.';
            }
        }

        $userID = $session->userID;

        $bettingItem = new BettingItem([
            'betting_id' => $bettingID,
            'general_id' => $session->generalID,
            'user_id' => $userID,
            'betting_type' => $bettingTypeKey,
            'amount' => $amount
        ]);

        $db->insertUpdate(
            'ng_betting',
            $bettingItem->toArray(),
            ['amount' => $db->sqleval('amount + %i', $amount)]
        );
        if ($bettingInfo->reqInheritancePoint) {
            $inheritStor->setValue('previous', [$remainPoint - $amount, null]);
            $userLogger = new UserLogger($userID);
            $userLogger->push("{$amount} 포인트를 베팅에 사용", "inheritPoint");
            $userLogger->flush();
        } else {
            $db->update('general', [
                'gold' => $db->sqleval('gold - %i', $amount)
            ], 'no = %i', $session->generalID);
        }
        if (!$db->affected_rows) {
            return '베팅을 실패했습니다.';
        }

        return [
            'result' => true
        ];
    }
}