feat(WIP): 베팅 개시 타입 변경

-candidate를 미리 추가. -이를 통해 betting을 중립적으로 운용 가능
2022-01-26 23:10:55 +09:00
parent 3a2fdce3d9
commit f59449c15b
7 changed files with 101 additions and 35 deletions
@@ -0,0 +1,145 @@
+<?php
+
+namespace sammo\API\NationBetting;
+
+use sammo\Session;
+use DateTimeInterface;
+use sammo\DB;
+use Sammo\DTO\BettingItem;
+use sammo\Validator;
+use sammo\Json;
+use sammo\DTO\BettingInfo;
+use sammo\GameConst;
+use sammo\General;
+use sammo\KVStorage;
+use sammo\Util;
+
+use function sammo\getAllNationStaticInfo;
+
+class BetNation extends \sammo\BaseAPI
+{
+    public function validateArgs(): ?string
+    {
+        $v = new Validator($this->args);
+        $v->rule('required', [
+            'betting_id',
+            'betting_type',
+            'amount'
+        ])
+            ->rule('integer', 'betting_id')
+            ->rule('integerArray', 'betting_type')
+            ->rule('integer', 'amount')
+            ->rule('min', 'amount', 1);
+
+        if (!$v->validate()) {
+            return $v->errorStr();
+        }
+        return null;
+    }
+
+    public function getRequiredSessionMode(): int
+    {
+        return static::REQ_GAME_LOGIN | static::REQ_READ_ONLY;
+    }
+
+    public function launch(Session $session, ?DateTimeInterface $modifiedSince, ?string $reqEtag)
+    {
+        $db = DB::db();
+
+        /** @var int */
+        $bettingID = $this->arg['betting_id'];
+        /** @var int[] */
+        $bettingType = $this->arg['betting_type'];
+        /** @var int[] */
+        $amount = $this->args['amount'];
+
+        $gameStor = KVStorage::getStorage($db, 'game_env');
+        $bettingStor = KVStorage::getStorage($db, 'betting');
+        $rawBettingInfo = $bettingStor->getValue("id_{$bettingID}");
+        if($rawBettingInfo === null){
+            return '해당 베팅이 없습니다';
+        }
+
+        try{
+            $bettingInfo = new BettingInfo($rawBettingInfo);
+        }
+        catch(\Error $e){
+            return $e->getMessage();
+        }
+
+        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 '필요한 선택 수를 채우지 못했습니다.';
+        }
+
+
+        $bettingType = array_unique($bettingType, SORT_NUMERIC);//NOTE: key로 바로 사용하므로 중요함
+        if(count($bettingType) != $bettingInfo->selectCnt){
+            return '중복된 값이 있습니다.';
+        }
+
+        if($bettingType[0] < 0){
+            return '올바르지 않은 값이 있습니다.(0 미만)';
+        }
+
+        if(Util::array_last($bettingType) >= count($bettingInfo->candidates)){
+            return '올바르지 않은 값이 있습니다.(초과)';
+        }
+
+        $bettingTypeKey = Json::encode($bettingType);
+        $general = General::createGeneralObjFromDB($session->generalID, ['gold', 'aux'], 1);
+
+        if($bettingInfo->reqInheritancePoint){
+            if($general->getInheritancePoint('previous') < $amount){
+                return '유산포인트가 충분하지 않습니다.';
+            }
+        }
+        else {
+            if($general->getVar('gold') < 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
+        ]);
+
+        if($bettingInfo->reqInheritancePoint){
+            $general->increaseInheritancePoint('previous', -$amount);
+        }
+        else{
+            $general->increaseVar('gold', -$amount);
+        }
+        $db->insertUpdate('ng_betting', $bettingItem->toArray());
+        if(!$db->affected_rows){
+            $general->flushUpdateValues();
+            return '베팅을 실패했습니다.';
+        }
+        $general->applyDB($db);
+
+        return [
+            'result'=>true
+        ];
+    }
+}