Hide_D
dd38344319
- 경매장을 모든 입찰 기록이 남는 새로운 경매장 로직으로 변경
- ng_auction, ng_auction_bid
- DTO 사용
- 상회입찰 시 개인메시지로 알림
- 기존의 '배경에서 조용히 이루어지는' 유니크 입찰을 공개된 유니크 경매장으로 변경
- 종료 기간 명시
- 종료 기간에 가까워질때 입찰하면 자동 연장
- 최대 연장기간 있음
- 유니크 제한인 경우 24턴 연장
- 중원정세에서 '보물수배'로 알림
Reviewed-on: https://storage.hided.net/gitea/devsam/core/pulls/221
525 lines
16 KiB
PHP
525 lines
16 KiB
PHP
<?php
|
|
|
|
namespace sammo;
|
|
|
|
use DateTime;
|
|
use DateTimeImmutable;
|
|
use DateTimeInterface;
|
|
use sammo\DTO\AuctionBidItem;
|
|
use sammo\DTO\AuctionBidItemData;
|
|
use sammo\DTO\AuctionInfo;
|
|
use sammo\Enums\AuctionType;
|
|
use sammo\Enums\InheritanceKey;
|
|
use sammo\Enums\RankColumn;
|
|
use sammo\Enums\ResourceType;
|
|
|
|
abstract class Auction
|
|
{
|
|
|
|
protected AuctionInfo $info;
|
|
|
|
static AuctionType $auctionType;
|
|
|
|
public const COEFF_AUCTION_CLOSE_MINUTES = 24;
|
|
public const COEFF_EXTENSION_MINUTES_PER_BID = (1 / 6);
|
|
public const COEFF_EXTENSION_MINUTES_LIMIT_BY_BID = 1;
|
|
public const COEFF_EXTENSION_MINUTES_BY_EXTENSION_QUERY = 1;
|
|
public const MIN_AUCTION_CLOSE_MINUTES = 30;
|
|
public const MIN_EXTENSION_MINUTES_PER_BID = 1;
|
|
public const MIN_EXTENSION_MINUTES_LIMIT_BY_BID = 5;
|
|
public const MIN_EXTENSION_MINUTES_BY_EXTENSION_QUERY = 5;
|
|
|
|
protected AuctionBidItem|null|false $_highestBid = false;
|
|
|
|
static public function genObfuscatedName(int $id): string
|
|
{
|
|
$db = DB::db();
|
|
$gameStor = KVStorage::getStorage($db, 'game_env');
|
|
|
|
$namePool = $gameStor->getValue('obfuscatedNamePool');
|
|
if ($namePool === null) {
|
|
$rng = new RandUtil(new LiteHashDRBG(Util::simpleSerialize(
|
|
UniqueConst::$hiddenSeed,
|
|
)));
|
|
$namePool = [];
|
|
foreach (GameConst::$randGenFirstName as $ch0) {
|
|
foreach (GameConst::$randGenMiddleName as $ch1) {
|
|
foreach (GameConst::$randGenLastName as $ch2) {
|
|
$namePool[] = "{$ch0}{$ch1}{$ch2}";
|
|
}
|
|
}
|
|
}
|
|
$namePool = $rng->shuffle($namePool);
|
|
$gameStor->setValue('obfuscatedNamePool', $namePool);
|
|
}
|
|
|
|
|
|
$dupIdx = intdiv($id, count($namePool));
|
|
$subIdx = $id % count($namePool);
|
|
if ($dupIdx == 0) {
|
|
return $namePool[$subIdx];
|
|
}
|
|
return "{$namePool[$subIdx]}{$dupIdx}";
|
|
}
|
|
|
|
static protected function openAuction(AuctionInfo $info, General $general): int|string
|
|
{
|
|
$db = DB::db();
|
|
if ($info->id !== null) {
|
|
return 'id가 지정되어 있습니다.';
|
|
}
|
|
|
|
$db->insert('ng_auction', $info->toArray());
|
|
return $db->insertId();
|
|
}
|
|
|
|
public function getHighestBid(): ?AuctionBidItem
|
|
{
|
|
$db = DB::db();
|
|
|
|
if ($this->_highestBid !== false) {
|
|
return $this->_highestBid;
|
|
}
|
|
|
|
if (!$this->info->detail->isReverse) {
|
|
$rawHighestBid = $db->queryFirstRow(
|
|
'SELECT * FROM ng_auction_bid WHERE auction_id = %i ORDER BY `amount` DESC LIMIT 1',
|
|
$this->info->id
|
|
);
|
|
} else {
|
|
$rawHighestBid = $db->queryFirstRow(
|
|
'SELECT * FROM ng_auction_bid WHERE auction_id = %i ORDER BY `amount` ASC LIMIT 1',
|
|
$this->info->id
|
|
);
|
|
}
|
|
|
|
if (!$rawHighestBid) {
|
|
$this->_highestBid = null;
|
|
return null;
|
|
}
|
|
|
|
$highestBid = AuctionBidItem::fromArray($rawHighestBid);
|
|
$this->_highestBid = $highestBid;
|
|
return $highestBid;
|
|
}
|
|
|
|
public function getMyPrevBid(): ?AuctionBidItem
|
|
{
|
|
$db = DB::db();
|
|
if (!$this->info->detail->isReverse) {
|
|
$rawMyPrevBid = $db->queryFirstRow(
|
|
'SELECT * FROM ng_auction_bid WHERE general_id = %i AND auction_id = %i ORDER BY `amount` DESC LIMIT 1',
|
|
$this->general->getID(),
|
|
$this->info->id
|
|
);
|
|
} else {
|
|
$rawMyPrevBid = $db->queryFirstRow(
|
|
'SELECT * FROM ng_auction_bid WHERE general_id = %i AND auction_id = %i ORDER BY `amount` ASC LIMIT 1',
|
|
$this->general->getID(),
|
|
$this->info->id
|
|
);
|
|
}
|
|
if (!$rawMyPrevBid) {
|
|
return null;
|
|
}
|
|
return AuctionBidItem::fromArray($rawMyPrevBid);
|
|
}
|
|
|
|
public function __construct(protected readonly int $auctionID, protected General $general)
|
|
{
|
|
$db = DB::db();
|
|
$rawAuctionInfo = $db->queryFirstRow('SELECT * FROM `ng_auction` WHERE id = %i', $auctionID);
|
|
if (!$rawAuctionInfo) {
|
|
throw new \RuntimeException("해당 경매가 없습니다: {$auctionID}");
|
|
}
|
|
$this->info = AuctionInfo::fromArray($rawAuctionInfo);
|
|
$thisAuctionType = static::$auctionType;
|
|
if ($this->info->type !== $thisAuctionType) {
|
|
throw new \RuntimeException("잘못된 경매 타입입니다: {$this->info->type->value} != {$thisAuctionType->value}");
|
|
}
|
|
}
|
|
|
|
public function getInfo(): AuctionInfo
|
|
{
|
|
return $this->info;
|
|
}
|
|
|
|
public function shrinkCloseDate(?DateTimeInterface $date): ?string
|
|
{
|
|
if ($date === null) {
|
|
$date = new DateTimeImmutable();
|
|
}
|
|
|
|
$this->info->closeDate = $date;
|
|
$db = DB::db();
|
|
$db->update('ng_auction', $this->info->toArray('id'), 'id = %i', $this->info->id);
|
|
|
|
return null;
|
|
}
|
|
|
|
public function extendLatestBidCloseDate(?DateTimeInterface $date): ?string
|
|
{
|
|
if ($date === null) {
|
|
$db = DB::db();
|
|
$gameStor = KVStorage::getStorage($db, 'game_env');
|
|
$turnTerm = $gameStor->getValue('turnterm');
|
|
$date = $this->info->closeDate->add(TimeUtil::secondsToDateInterval(
|
|
max(static::MIN_EXTENSION_MINUTES_PER_BID, $turnTerm * static::COEFF_EXTENSION_MINUTES_PER_BID) * 60
|
|
));
|
|
}
|
|
else{
|
|
$date = DateTimeImmutable::createFromInterface($date);
|
|
}
|
|
if ($this->info->detail->availableLatestBidCloseDate !== null && $date < $this->info->detail->availableLatestBidCloseDate) {
|
|
return '기간보다 짧습니다.';
|
|
}
|
|
$this->info->detail->availableLatestBidCloseDate = $date;
|
|
return null;
|
|
}
|
|
|
|
public function extendCloseDate(DateTimeInterface $date, bool $force = false): ?string
|
|
{
|
|
if (!$force) {
|
|
if ($this->info->detail->remainCloseDateExtensionCnt === null) {
|
|
return '연장할 수 없는 경매입니다.';
|
|
}
|
|
if ($this->info->detail->remainCloseDateExtensionCnt === 0) {
|
|
return '더 이상 연장할 수 없습니다';
|
|
}
|
|
if ($this->info->detail->remainCloseDateExtensionCnt > 0) {
|
|
$this->info->detail->remainCloseDateExtensionCnt--;
|
|
}
|
|
}
|
|
|
|
if ($date < $this->info->closeDate) {
|
|
return '종료 기간보다 짧습니다.';
|
|
}
|
|
|
|
$closeDate = DateTimeImmutable::createFromInterface($date);
|
|
$this->info->closeDate = $closeDate;
|
|
return null;
|
|
}
|
|
|
|
public function applyDB(): void
|
|
{
|
|
$db = DB::db();
|
|
$db->update('ng_auction', $this->info->toArray('id'), 'id = %i', $this->info->id);
|
|
}
|
|
|
|
public function refundBid(AuctionBidItem $bidItem, string $reason): void
|
|
{
|
|
if ($bidItem->auctionID !== $this->info->id) {
|
|
throw new \RuntimeException('잘못된 경매입니다.');
|
|
}
|
|
|
|
$db = DB::db();
|
|
if ($bidItem->generalID === $this->general->getID()) {
|
|
$oldBidder = $this->general;
|
|
} else {
|
|
$oldBidder = General::createGeneralObjFromDB($bidItem->generalID);
|
|
}
|
|
|
|
if ($this->info->reqResource === ResourceType::inheritancePoint) {
|
|
$oldBidder->increaseInheritancePoint(InheritanceKey::previous, $bidItem->amount);
|
|
$oldBidder->increaseRankVar(RankColumn::inherit_point_spent_dynamic, -$bidItem->amount);
|
|
} else {
|
|
$oldBidder->increaseVar($this->info->reqResource->value, $bidItem->amount);
|
|
}
|
|
|
|
if ($oldBidder instanceof DummyGeneral) {
|
|
return;
|
|
}
|
|
|
|
$staticNation = $oldBidder->getStaticNation();
|
|
$src = new MessageTarget(0, '', 0, 'System', '#000000');
|
|
$dest = new MessageTarget(
|
|
$oldBidder->getID(),
|
|
$oldBidder->getName(),
|
|
$oldBidder->getNationID(),
|
|
$staticNation['name'],
|
|
$staticNation['color'],
|
|
GetImageURL($oldBidder->getVar('imgsvr'), $oldBidder->getVar('picture'))
|
|
);
|
|
|
|
//TODO: 전역 알림이 나타나야한다. 일반 메시지보다는 중요하고, 메시지보단 약하게..
|
|
//TODO: 바로가기를 제공하는 편이 좋을 것 같다.
|
|
$msg = new Message(
|
|
Message::MSGTYPE_PRIVATE,
|
|
$src,
|
|
$dest,
|
|
$reason,
|
|
new DateTime(),
|
|
new DateTime('9999-12-31'),
|
|
[]
|
|
);
|
|
$oldBidder->applyDB($db);
|
|
$msg->send(true);
|
|
}
|
|
|
|
public function closeAuction(bool $isRollback = false): void
|
|
{
|
|
$db = DB::db();
|
|
|
|
$this->info->finished = true;
|
|
|
|
if ($isRollback) {
|
|
$highestBid = $this->getHighestBid();
|
|
if ($highestBid !== null) {
|
|
$this->refundBid($highestBid, "{$this->info->id}번 {$this->info->detail->title} 경매가 취소되었습니다.");
|
|
}
|
|
$this->rollbackAuction();
|
|
}
|
|
|
|
$db->update('ng_auction', $this->info->toArray('id'), 'id = %i', $this->info->id);
|
|
}
|
|
|
|
private function bidInheritPoint(int $amount, \DateTimeImmutable $now, bool $tryExtendCloseDate): ?string
|
|
{
|
|
$db = DB::db();
|
|
|
|
$auctionInfo = $this->info;
|
|
$general = $this->general;
|
|
|
|
$highestBid = $this->getHighestBid();
|
|
if ($highestBid !== null && $amount <= $highestBid->amount) {
|
|
return '현재입찰가보다 높게 입찰해야 합니다.';
|
|
}
|
|
|
|
$myPrevBid = $this->getMyPrevBid();
|
|
if ($myPrevBid !== null && $highestBid->no !== $myPrevBid->no) {
|
|
//이미 환불 받았으니 무효.
|
|
$myPrevBid = null;
|
|
}
|
|
|
|
$morePoint = $amount - ($myPrevBid ? $myPrevBid->amount : 0);
|
|
$currPoint = $general->getInheritancePoint(InheritanceKey::previous);
|
|
if ($currPoint === null || $currPoint < $morePoint) {
|
|
return '유산포인트가 부족합니다.';
|
|
}
|
|
|
|
$obfuscatedName = static::genObfuscatedName($general->getID());
|
|
//여기서부터 입찰 성공
|
|
|
|
$newBid = new AuctionBidItem(
|
|
null,
|
|
$auctionInfo->id,
|
|
$general->getVar('owner'),
|
|
$general->getID(),
|
|
$amount,
|
|
$now,
|
|
new AuctionBidItemData(
|
|
$general->getVar('owner_name'),
|
|
$obfuscatedName,
|
|
$tryExtendCloseDate,
|
|
)
|
|
);
|
|
$db->insert('ng_auction_bid', $newBid->toArray());
|
|
if ($db->affectedRows() == 0) {
|
|
return '입찰에 실패했습니다: DB 오류';
|
|
}
|
|
|
|
$gameStor = KVStorage::getStorage($db, 'game_env');
|
|
$turnTerm = $gameStor->getValue('turnterm');
|
|
|
|
if ($this->info->detail->availableLatestBidCloseDate !== null) {
|
|
$extendedCloseDate = $now->add(TimeUtil::secondsToDateInterval(
|
|
max(static::MIN_EXTENSION_MINUTES_PER_BID, $turnTerm * static::COEFF_EXTENSION_MINUTES_PER_BID) * 60
|
|
));
|
|
|
|
if ($extendedCloseDate > $this->info->closeDate && $this->info->closeDate < $this->info->detail->availableLatestBidCloseDate) {
|
|
$this->extendCloseDate(min($extendedCloseDate, $this->info->detail->availableLatestBidCloseDate), true);
|
|
$this->applyDB();
|
|
}
|
|
}
|
|
|
|
$general->increaseInheritancePoint(InheritanceKey::previous, -$morePoint);
|
|
$general->increaseRankVar(RankColumn::inherit_point_spent_dynamic, $morePoint);
|
|
|
|
if ($highestBid !== null && $myPrevBid === null) {
|
|
$this->refundBid($highestBid, "{$auctionInfo->id}번 {$auctionInfo->detail->title}에 상회입찰자가 나타났습니다.");
|
|
}
|
|
$general->applyDB($db);
|
|
return null;
|
|
}
|
|
|
|
protected function _bid(int $amount, bool $tryExtendCloseDate = false): ?string
|
|
{
|
|
$auctionInfo = $this->info;
|
|
$general = $this->general;
|
|
|
|
if ($auctionInfo->finished) {
|
|
return '경매가 이미 끝났습니다.';
|
|
}
|
|
|
|
$now = new \DateTimeImmutable();
|
|
|
|
if ($auctionInfo->closeDate < $now) {
|
|
return '경매가 이미 끝났습니다.';
|
|
}
|
|
if ($auctionInfo->openDate > $now) {
|
|
return '경매가 아직 시작되지 않았습니다.';
|
|
}
|
|
|
|
if (!$auctionInfo->detail->isReverse) {
|
|
if ($auctionInfo->detail->finishBidAmount !== null && $auctionInfo->detail->finishBidAmount < $amount) {
|
|
return '즉시판매가보다 높을 수 없습니다.';
|
|
}
|
|
} else {
|
|
if ($auctionInfo->detail->finishBidAmount !== null && $auctionInfo->detail->finishBidAmount > $amount) {
|
|
return '즉시판매가보다 낮을 수 없습니다.';
|
|
}
|
|
}
|
|
|
|
|
|
if ($auctionInfo->reqResource === ResourceType::inheritancePoint) {
|
|
return $this->bidInheritPoint($amount, $now, $tryExtendCloseDate);
|
|
}
|
|
|
|
//reqResource는 말 그대로 '구매자가 내야하는 자원'이다.
|
|
|
|
$db = DB::db();
|
|
|
|
$highestBid = $this->getHighestBid();
|
|
if (!$auctionInfo->detail->isReverse) {
|
|
if ($highestBid !== null && $amount <= $highestBid->amount) {
|
|
return '현재입찰가보다 높게 입찰해야 합니다.';
|
|
}
|
|
} else {
|
|
if ($highestBid !== null && $amount >= $highestBid->amount) {
|
|
return '현재입찰가보다 낮게 입찰해야 합니다.';
|
|
}
|
|
}
|
|
|
|
|
|
$myPrevBid = $this->getMyPrevBid();
|
|
if ($myPrevBid !== null && $highestBid->no !== $myPrevBid->no) {
|
|
//이미 환불 받았으니 무효.
|
|
$myPrevBid = null;
|
|
}
|
|
|
|
$morePoint = $amount - ($myPrevBid ? $myPrevBid->amount : 0);
|
|
$resType = $auctionInfo->reqResource;
|
|
$minReqRes = match ($resType) {
|
|
ResourceType::gold => GameConst::$defaultGold,
|
|
ResourceType::rice => GameConst::$defaultRice,
|
|
};
|
|
|
|
if ($general->getVar($resType->value) < $morePoint + $minReqRes) {
|
|
return $resType->getName() . '이 부족합니다.';
|
|
}
|
|
|
|
//여기서부터 입찰 성공
|
|
|
|
$newBid = new AuctionBidItem(
|
|
null,
|
|
$auctionInfo->id,
|
|
$general->getVar('owner'),
|
|
$general->getID(),
|
|
$amount,
|
|
$now,
|
|
new AuctionBidItemData(
|
|
$general->getVar('owner_name'),
|
|
$general->getName(),
|
|
$tryExtendCloseDate,
|
|
)
|
|
);
|
|
|
|
$db->insert('ng_auction_bid', $newBid->toArray());
|
|
if ($db->affectedRows() == 0) {
|
|
return '입찰에 실패했습니다: DB 오류';
|
|
}
|
|
|
|
$general->increaseVar($resType->value, -$morePoint);
|
|
|
|
$gameStor = KVStorage::getStorage($db, 'game_env');
|
|
$turnTerm = $gameStor->getValue('turnterm');
|
|
$extendedCloseDate = $now->add(TimeUtil::secondsToDateInterval(
|
|
max(static::MIN_EXTENSION_MINUTES_PER_BID, $turnTerm * static::COEFF_EXTENSION_MINUTES_PER_BID) * 60
|
|
));
|
|
|
|
if ($extendedCloseDate > $this->info->closeDate) {
|
|
$this->extendCloseDate($extendedCloseDate, true);
|
|
$this->applyDB();
|
|
}
|
|
|
|
if ($highestBid !== null && $myPrevBid === null) {
|
|
$this->refundBid($highestBid, "{$auctionInfo->id}번 {$auctionInfo->detail->title}에 상회입찰자가 나타났습니다.");
|
|
}
|
|
$general->applyDB($db);
|
|
return null;
|
|
}
|
|
|
|
public function tryFinish(): ?bool
|
|
{
|
|
$now = new DateTimeImmutable();
|
|
if ($now < $this->info->closeDate) {
|
|
return null;
|
|
}
|
|
|
|
//경매를 닫아야한다.
|
|
$highestBid = $this->getHighestBid();
|
|
if ($highestBid === null) {
|
|
$this->closeAuction(true);
|
|
return true;
|
|
}
|
|
|
|
if ($highestBid->aux->tryExtendCloseDate) {
|
|
$db = DB::db();
|
|
$gameStor = KVStorage::getStorage($db, 'game_env');
|
|
$turnTerm = $gameStor->getValue('turnterm');
|
|
|
|
//연장 요청이 있었다.
|
|
$extendedCloseDate = $this->info->closeDate->add(TimeUtil::secondsToDateInterval(
|
|
max(static::MIN_EXTENSION_MINUTES_BY_EXTENSION_QUERY, $turnTerm * static::COEFF_EXTENSION_MINUTES_BY_EXTENSION_QUERY) * 60
|
|
));
|
|
|
|
if ($this->extendCloseDate($extendedCloseDate) === null) {
|
|
$this->extendLatestBidCloseDate(null);
|
|
$this->applyDB();
|
|
return false;
|
|
}
|
|
}
|
|
|
|
$bidder = General::createGeneralObjFromDB($highestBid->generalID);
|
|
$failReason = $this->finishAuction($highestBid, $bidder);
|
|
if ($failReason === null) {
|
|
$this->closeAuction();
|
|
return true;
|
|
}
|
|
|
|
if ($bidder instanceof DummyGeneral) {
|
|
return false;
|
|
}
|
|
|
|
$staticNation = $bidder->getStaticNation();
|
|
$src = new MessageTarget(0, '', 0, 'System', '#000000');
|
|
$dest = new MessageTarget(
|
|
$bidder->getID(),
|
|
$bidder->getName(),
|
|
$bidder->getNationID(),
|
|
$staticNation['name'],
|
|
$staticNation['color'],
|
|
GetImageURL($bidder->getVar('imgsvr'), $bidder->getVar('picture'))
|
|
);
|
|
|
|
//TODO: 전역 알림이 나타나야한다. 일반 메시지보다는 중요하고, 메시지보단 약하게..
|
|
//TODO: 바로가기를 제공하는 편이 좋을 것 같다.
|
|
$msg = new Message(
|
|
Message::MSGTYPE_PRIVATE,
|
|
$src,
|
|
$dest,
|
|
$failReason,
|
|
new \DateTime(),
|
|
new \DateTime('9999-12-31'),
|
|
[]
|
|
);
|
|
$msg->send(true);
|
|
return false;
|
|
}
|
|
|
|
abstract public function bid(int $amount, bool $tryExtendCloseDate): ?string;
|
|
|
|
abstract protected function rollbackAuction(): void;
|
|
abstract protected function finishAuction(AuctionBidItem $highestBid, General $bidder): ?string;
|
|
}
|