server/game2006api
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
aozhiwei 2024-06-11 15:54:37 +08:00
parent 779edd1470
commit 3121e7dfb4
2 changed files with 53 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
sql/gamedb.sql
View File

@ -1798,7 +1798,7 @@ CREATE TABLE `t_gold_bullion` (
`open_address` varchar(60) COMMENT 'open_address',
`open_time` int(11) NOT NULL DEFAULT '0' COMMENT 'open_time',
`open_account_id` varchar(60) NOT NULL DEFAULT '' COMMENT '账号id(channel + "_" + gameid + "_" + openid)',
`open_try_count` int(11) NOT NULL DEFAULT '0' COMMENT 'open_try_count',
`open_uniqid` varchar(60) NOT NULL DEFAULT '' COMMENT '开启的本次唯一id',
`returned` int(11) NOT NULL DEFAULT '0' COMMENT '是否已超时返还',
`return_time` int(11) NOT NULL DEFAULT '0' COMMENT '返还时间',
`activated` int(11) NOT NULL DEFAULT '0' COMMENT '是否已上连',
@ -1808,7 +1808,6 @@ CREATE TABLE `t_gold_bullion` (
PRIMARY KEY (`idx`),
UNIQUE KEY `idx_token_id` (`token_id`),
UNIQUE KEY `idx_token_id_net_id` (`token_id`, `net_id`),
KEY `idx_open_address_open_status` (`open_address`, `open_status`),
KEY `idx_address_createtime_activate_status` (`address`, `createtime`, `activate`, `status`)
KEY `idx_open_address_open_status` (`open_address`, `open_status`)
) ENGINE=InnoDB AUTO_INCREMENT=10001 DEFAULT CHARSET=utf8 COLLATE=utf8_bin;
/*!40101 SET character_set_client = @saved_cs_client */;

54
webapp/models/GoldBullion.php
View File

@ -2,6 +2,9 @@
namespace models;
require_once('services/AwardService.php');
require_once('services/PropertyChgService.php');
class GoldBullion extends BaseModel {
const OPEN_STATUS_SENT = 1;
@ -25,7 +28,9 @@ class GoldBullion extends BaseModel {
)
);
if (count($rows) > 0) {
$confirmedRows = array();
foreach ($rows as $row) {
$uniqId = self::genUniqId();
SqlHelper::update(
myself()->_getSelfMysql(),
't_gold_bullion',
@ -35,13 +40,56 @@ class GoldBullion extends BaseModel {
),
array(
'open_status' => self::OPEN_STATUS_SEND_BEGIN,
'open_try_count' => function () {
return "open_try_count + 1";
},
'open_uniqid' => $uniqId
)
);
$newRow = SqlHelper::ormSelectOne(
myself()->_getSelfMysql(),
't_gold_bullion',
array(
'idx' => $row['idx'],
)
);
if (!empty($newRow) && $newRow['open_uniqid'] == $uniqId) {
array_push($confirmedRows, $row);
}
self::doSendAward($confirmedRows);
}
}
}
public static function doSendAward($confirmedRows)
{
$propertyChgService = new services\PropertyChgService();
$awardService = new services\AwardService();
if (empty($confirmedRows)) {
return;
}
foreach ($confirmedRows as $row) {
$items = array(
array(
'item_id' => V_ITEM_GOLD,
'item_num' => $row['gold']
)
);
myself()->_addItems($items, $awardService, $propertyChgService);
SqlHelper::update(
myself()->_getSelfMysql(),
't_gold_bullion',
array(
'idx' => $row['idx'],
),
array(
'open_status' => self::OPEN_STATUS_SEND_END,
)
);
}
}
private static function genUniqId()
{
$uniqId = uniqid(md5(rand() . rand() . rand() . myself()->_getSessionId()), true);
return $uniqId;
}
}