devsam/core
3
6
Fork 1
Code Issues 60 Pull Requests Releases 1 Wiki Activity

메시지 클래스 새로 작성

Browse Source
This commit is contained in:
Hide_D
2018-04-10 02:38:36 +09:00
parent 50d1c4cd34
commit 2404ab2047
6 changed files with 455 additions and 42 deletions
Download Patch File Download Diff File Expand all files Collapse all files
hwe/func_message.php
-41
View File
@@ -1,47 +1,7 @@
<?php
namespace sammo;
class Message{
//기본 정보
public $id;
public $mailbox;
public $type;
public $isSender;
/** @var mixed[] */
public $src;
/** @var mixed[] */
public $dest;
public $time;
public $text;
public $option;
function __construct($row){
$db_message = $row['message'];
$this->id = $row['id'];
$this->mailbox = $row['mailbox'];
$this->type = $row['type'];
$this->isSender = $row['is_sender'] != 0;
$this->src = $db_message['src'];
if($this->src['nation'] === null){
$this->src['nation'] = '재야';
$this->src['color'] = '#FFFFFF';
$this->src['nation_id'] = null;
}
$this->dest = $db_message['dest'];
if($this->dest['nation'] === null){
$this->dest['nation'] = '재야';
$this->dest['color'] = '#FFFFFF';
$this->dest['nation_id'] = null;
}
$this->time = $row['time'];
$this->text = $db_message['text'];
$this->option = $db_message['option'];
}
}
function getSingleMessage($messageID){
$messageInfo = DB::db()->queryFirstRow('select * from `message` where `id` = %i', $messageID);
@@ -135,7 +95,6 @@ function sendRawMessage($msgType, $isSender, $mailbox, $src, $dest, $msg, $date,
DB::db()->insert('message', [
'address' => $dest,
'type' => $msgType,
'is_sender' => $isSender,
'src' => $src['id'],
'dest' => $dest['id'],
'time' => $date,
hwe/sammo/DiplomacticMessage.php
+28
View File
@@ -0,0 +1,28 @@
<?php
namespace sammo;
class DiplomacticMessage extends Message{
public function __construct(
string $msgType,
MessageTarget $src,
MessageTarget $dest,
string $msg,
\DateTime $date,
\DateTime $validUntil,
array $msgOption
)
{
if ($msgType !== self::MSGTYPE_DIPLOMACY){
throw new \InvalidArgumentException('DiplomaticMessage msgType');
}
parent::__construct(...func_get_args());
//TODO: 누가, 누구에게 보낸 건지 파싱
}
public function send(){
parent::send();
}
}
hwe/sammo/Message.php
+286
View File
@@ -0,0 +1,286 @@
<?php
namespace sammo;
class Message
{
const MAILBOX_PUBLIC = 9999;
const MAILBOX_NATIONAL = 9000;
const MSGTYPE_PUBLIC = 'public';
const MSGTYPE_PRIVATE = 'private';
const MSGTYPE_NATIONAL = 'national';
const MSGTYPE_DIPLOMACY = 'diplomacy';
//기본 정보
public $mailbox = null;
public $id = null;
public $isInboxMail = false;
protected $sendCnt = 0;
public $msgType;
/** @var MessageTarget */
public $src;
/** @var MessageTarget */
public $dest;
public $msg;
/** @var \DateTime */
public $date;
/** @var \DateTime */
public $validUntil;
public $msgOption;
public function __construct(
string $msgType,
MessageTarget $src,
MessageTarget $dest,
string $msg,
\DateTime $date,
\DateTime $validUntil,
array $msgOption
) {
if (!static::isValidMsgType($msgType)) {
throw new \InvalidArgumentException('올바르지 않은 msgType');
}
$this->msgType = $msgType;
$this->src = $src;
$this->dest = $dest;
$this->msg = $msg;
$this->date = $date;
$this->validUntil = $validUntil;
$this->msgOption = $msgOption;
}
public function setSentInfo(int $mailbox, int $messageID) : this
{
if(!Message::isValidMailBox($mailbox)){
throw new \InvalidArgumentException('올바르지 않은 mailbox');
}
do{
if($mailbox === Message::MAILBOX_PUBLIC){
if($this->msgType !== Message::MSGTYPE_PUBLIC){
throw new \InvalidArgumentException('올바르지 않은 mailbox, msgType !== MSGTYPE_PUBLIC');
}
$this->isInboxMail = true;
break;
}
if($mailbox > Message::MAILBOX_NATIONAL){
if($this->msgType === Message::MSGTYPE_DIPLOMACY){
$this->isInboxMail = true;
break;
}
if ($this->msgType !== Message::MSGTYPE_NATIONAL) {
throw new \InvalidArgumentException('올바르지 않은 mailbox, msgType not in (MSGTYPE_DIPLOMACY, MSGTYPE_NATIONAL)');
}
if($this->dest->nationID + Message::MAILBOX_NATIONAL === $mailbox){
$this->isInboxMail = true;
break;
}
if($this->src->nationID + Message::MAILBOX_NATIONAL === $mailbox){
$this->isInboxMail = false;
break;
}
throw new \InvalidArgumentException('송신, 수신국 둘 중의 어느 메일함도 아닙니다');
}
if($this->msgType !== Message::MSGTYPE_PRIVATE){
throw new \InvalidArgumentException('올바르지 않은 mailbox, msgType !== MSGTYPE_PRIVATE');
}
if($this->dest->generalID === $mailbox){
$this->isInboxMail = true;
break;
}
if($this->src->generalID === $mailbox){
$this->isInboxMail = false;
break;
}
throw new \InvalidArgumentException('송신자, 수신자 둘 중의 어느 메일함도 아닙니다');
}while(false);
$this->id = $messageID;
$this->mailbox = $mailbox;
return $this;
}
public static function buildFromArray(array $row) : Message
{
$dbMessage = Json::decode($row['message']);
$msgType = $row['type'];
$src = MessageTarget::buildFromArray($dbMessage['src']);
$dest = MessageTarget::buildFromArray($dbMessage['dest']);
$option = Util::array_get($dbMessage['option'], []);
$args = [
$msgType,
$src,
$dest,
$dbMessage['text'],
new \DateTime($row['time']),
new \DateTime($row['valid_until']),
$option
];
$action = Util::array_get($option['action'], null);
if($msgType === self::MSGTYPE_DIPLOMACY){
$objMessage = new DiplomacticMessage(...$args);
}
else if($action === 'scout'){
$objMessage = new ScoutMessage(...$args);
}
else{
$objMessage = new Message(...$args);
}
$objMessage->setSentInfo($row['mailbox'], $row['id']);
return $objMessage;
}
public static function getMessageByID(int $messageID) : Message
{
$db = DB::db();
$row = $db->queryFirstRow('SELECT * FROM `message` WHERE `id` = %i', $messageID);
if (!$row) {
return null;
}
return static::buildFromArray($row);
}
protected static function isValidMailBox(int $mailbox): bool
{
if ($mailbox > self::MAILBOX_PUBLIC) {
return false;
}
if ($mailbox == self::MAILBOX_NATIONAL) {
return false;
}
if ($mailbox <= 0) {
return false;
}
return true;
}
protected static function isValidMsgType(string $msgType): bool
{
switch ($msgType) {
case static::MSGTYPE_PUBLIC: return true;
case static::MSGTYPE_PRIVATE: return true;
case static::MSGTYPE_NATIONAL: return true;
case static::MSGTYPE_DIPLOMACY: return true;
}
return false;
}
/**
* @param int $mailbox 메일 사서함.
* @param string $msgType 메일 타입. MSGTYPE 중 하나.
* @param int $limit 가져오고자 하는 수. 0 이하의 값이면 모두.
* @param int $fromSeq 가져오고자 하는 위치. $fromSeq보다 '큰' seq만 가져온다. 따라서 0 이하이면 모두 가져옴.
* @return Message[]
*/
protected static function getRawMessage(int $mailbox, string $msgType, int $limit=30, int $fromSeq = 0)
{
$db = DB::db();
if (!static::isValidMsgType($msgType)) {
throw new \InvalidArgumentException('올바르지 않은 $msgType');
}
$where = new \WhereClause('and');
$where->add('mailbox = %i', $mailbox);
$where->add('type = %s', $msgType);
if ($fromSeq > 0) {
$where->add('id > %i', $fromSeq);
}
if ($limit > 0) {
$limitSql = $db->sqleval('LIMIT %i', $limit);
} else {
$limitSql = new \MeekroDBEval('');
}
return array_map(function ($row) {
return static::buildFromArray($row);
}, $db->query('SELECT * FROM `message` WHERE %l %?', $where, $limitSql));
}
protected function sendRaw(int $mailbox){
//NOTE:: 여기선 검증하지 않는다.
if($mailbox === self::MAILBOX_PUBLIC){
$src_id = $this->src->generalID;
$dest_id = self::MAILBOX_PUBLIC;
}
else if($mailbox > self::MAILBOX_NATIONAL){
$src_id = $this->src->nationID + self::MAILBOX_NATIONAL;
$dest_id = $this->dest->nationID + self::MAILBOX_NATIONAL;
}
else{
$src_id = $this->src->generalID;
$dest_id = $this->dest->generalID;
}
$db = DB::db();
$db->insert('message', [
'address' => $mailbox,
'type' => $this->msgType,
'src' => $src_id,
'dest' => $dest_id,
'time' => $this->date->format('Y-m-d H:i:s'),
'valid_until' => $this->validUntil->format('Y-m-d H:i:s'),
'message' => Json::encode([
'src' => $this->src->toArray(),
'dest' =>$this->dest->toArray(),
'text' => $this->msg,
'option' => $this->msgOption
])
]);
return $db->insertId();
}
protected function sendToSender() : int{
if($this->sendCnt > 0){
throw new \RuntimeException('이미 전송한 메일입니다.');
}
if($this->msgType === self::MSGTYPE_PRIVATE){
return $this->sendRaw($this->src->generalID);
}
if($this->msgType === self::MSGTYPE_NATIONAL && $this->src->nationID !== $this->dest->nationID){
return $this->sendRaw($this->src->nationID + self::MAILBOX_NATIONAL);
}
return 0;
}
protected function sendToReceiver() : int{
if($this->sendCnt > 1 || $this->isInboxMail){
throw new \RuntimeException('이미 전송한 메일입니다.');
}
if($this->msgType === self::MSGTYPE_PRIVATE){
return $this->sendRaw($this->dest->generalID);
}
if($this->msgType === self::MSGTYPE_NATIONAL || $this->msgType === self::MSGTYPE_DIPLOMACY){
return $this->sendRaw($this->dest->nationID + self::MAILBOX_NATIONAL);
}
if($this->msgType === self::MSGTYPE_PUBLIC){
return $this->sendRaw(self::MAILBOX_PUBLIC);
}
throw new \RuntimeException('이곳에 올 수 없습니다.');
}
public function send(){
$sendID = $this->sendToSender();
if($sendID){
$this->msgOption['relatedMessageID'] = $sendID;
}
$this->sendToReceiver();
}
}
hwe/sammo/MessageTarget.php
+50
View File
@@ -0,0 +1,50 @@
<?php
namespace sammo;
class MessageTarget {
/** @var int */
public $generalID;
/** @var int */
public $nationID;
/** @var string */
public $nationName;
/** @var string */
public $color;
public function __construct(int $generalID, int $nationID, string $nationName, string $color){
if($mailbox > Message::MAILBOX_NATIONAL){
$this->isGeneral = false;
}
else{
$this->isGeneral = true;
}
$this->generalID = $generalID;
$this->nationID = $nationID;
$this->nationName = $nationName;
$this->color = $color;
}
public static function buildFromArray(array $arr) : MessageTarget
{
if(!Util::array_get($arr['nation'])){
$arr['nation'] = '재야';
$arr['color'] = '#ffffff';
$arr['nation_id'] = 0;
}
return new MessageTarget($arr['id'], $arr['nation_id'], $arr['nation'], $arr['color']);
}
public function toArray() : array{
return [
'id'=>$this->generalID,
'nation_id'=>$this->nationID,
'nation'=>$this->nationName,
'color'=>$this->color
];
}
}
hwe/sammo/ScoutMessage.php
+91
View File
@@ -0,0 +1,91 @@
<?php
namespace sammo;
class ScoutMessage extends Message{
public function __construct(
string $msgType,
MessageTarget $src,
MessageTarget $dest,
string $msg,
\DateTime $date,
\DateTime $validUntil,
array $msgOption
)
{
if ($msgType !== self::MSGTYPE_PRIVATE){
throw new \InvalidArgumentException('DiplomaticMessage msgType');
}
parent::__construct(...func_get_args());
//TODO: 누가, 누구에게 보낸 건지 파싱
}
public static function generateScoutMessage(int $srcGeneralID, int $destGeneralID, &$reason = null, \DateTime $date = null): Message{
if($srcGeneralID == $destGeneralID){
if($reason !== null){
$reason = '같은 장수에게 등용장을 보낼 수 없습니다';
}
return null;
}
$db = DB::db();
$srcGeneral = $db->queryFirstRow('SELECT nation FROM nation WHERE `no`=%i', $srcGeneralID);
$destGeneral = $db->queryFirstRow('SELECT nation, `level` FROM nation WHERE `no`=%i', $destGeneralID);
if($date === null){
$date = new DateTime();
}
if($destGeneral['level'] == 12){
if($reason !== null){
$reason = '군주에게 등용장을 보낼 수 없습니다';
}
return null;
}
if(!$srcGeneral['nation']){
if($reason !== null){
$reason = '재야 상태일 때에는 등용장을 보낼 수 없습니다';
}
return null;
}
if($srcGeneral['nation'] === $destGeneral['nation']){
if($reason !== null){
$reason = '같은 소속의 장수에게 등용장을 보낼 수 없습니다';
}
return null;
}
$srcNationInfo = getNationStaticInfo($srcGeneral['nation']);
$destNationInfo = getNationStaticInfo($destGeneral['nation']);
$src = new MessageTarget(
$srcGeneralID,
$srcGeneral['nation'],
$srcNationInfo['name'],
$srcNationInfo['color']
);
$dest = new MessageTarget(
$destGeneralID,
$destGeneral['nation'],
Util::array_get($srcNationInfo['name'], ''),
Util::array_get($srcNationInfo['color'], '')
);
$msg = "{$src->nationName}(으)로 망명 권유 서신";
$validUntil = new \DateTime("9999-12-31 12:59:59");
$msgOption = [
'action'=>'scout'
];
return new ScoutMessage(Message::MSGTYPE_PRIVATE, $src, $dest, $msg, $date, $validUntil, $msgOption);
}
public function send(){
$this->sendToReceiver();
}
}
hwe/sql/schema.sql
-1
View File
@@ -422,7 +422,6 @@ CREATE TABLE `message` (
`id` INT(11) NOT NULL AUTO_INCREMENT,
`mailbox` INT(11) NOT NULL COMMENT '9999 == public, >= 9000 national',
`type` ENUM('private','national','public','diplomacy') NOT NULL,
`is_sender` BIT(1) NOT NULL,
`src` INT(11) NOT NULL,
`dest` INT(11) NOT NULL,
`time` DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,