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

...

Browse Source
This commit is contained in:
songliang 2023-06-09 17:35:25 +08:00
parent 02f2b1d387
commit a1f2f6ae48
1 changed files with 88 additions and 47 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

131
webapp/controller/ShopController.class.php
View File

@ -79,7 +79,7 @@ class ShopController extends BaseAuthedController
// } // }
// } // }
if(getReqVal('a', '') != 'buyGoodsDirect'){ if (getReqVal('a', '') != 'buyGoodsDirect') {
parent::_handlePre(); parent::_handlePre();
} }
} }
@ -286,21 +286,49 @@ class ShopController extends BaseAuthedController
public function buyGoodsDirect() public function buyGoodsDirect()
{ {
// let repdata = { // let repdata = {
// account_id: string // account_id: string
// order_id: string // order_id: string
// status: string // status: string
// id: string // id: string
// txhash: string // txhash: string
// } // }
// 我返回给你这些数据和一个sign字段, // 我返回给你这些数据和一个sign字段,
// sign使用上面 repdata 按key 顺序排后, 组成key1=val1&key2=val2后, 使用hmac_sha256 hash, key是 iG4Rpsa)6U31$H#^T85$^^3 // sign使用上面 repdata 按key 顺序排后, 组成key1=val1&key2=val2后, 使用hmac_sha256 hash, key是 iG4Rpsa)6U31$H#^T85$^^3
// PENDING = 0, // 初始状态
// TRANSFERING = 1, //只有国库模式才会有该状态
// TRANSFERED = 2, //只有国库模式才会有该状态
// SUCCESS = 9, // 成功的最终状态
// TRANSFER_FAIL = 98, // 转账错误
// FAIL = 99, // 也是错误
//
$token_type = getReqVal('token_type', ''); $account_id = getReqVal('account_id', '');
$goods_num = getReqVal('goods_num', 0); $order_id = getReqVal('order_id', '');
$status = getReqVal('status', '');
$id = getReqVal('id', '');
$txhash = getReqVal('txhash', '');
$order_id = 28; $sign = getReqVal('sign', '');
error_log("buyGoodsDirect-------");
$data = array(
'account_id' => $account_id,
'id' => $id,
'order_id' => $order_id,
'status' => $status,
'txhash' => $txhash,
);
$hash_data = http_build_query($data);
$signature = hash_hmac('sha256', $hash_data, 'iG4Rpsa)6U31$H#^T85$^^3');
if ($signature != $sign) {
$this->_rspErr(1, "signature error, signature: {$signature}, sign: {$sign}");
return;
}
error_log("buyGoodsDirect-------" . $order_id . "---" . $status);
$conn = myself()->_getMysql(''); $conn = myself()->_getMysql('');
@ -308,47 +336,60 @@ class ShopController extends BaseAuthedController
$id = $order['item_id']; $id = $order['item_id'];
$goods_num = $order['goods_num']; $goods_num = $order['goods_num'];
$status = $order['status']; $o_status = $order['status'];
$token_type = $order['token_type'];
if ($status != 0) { if ($o_status != 0) {
$this->_rspErr(1, "order status error, status: {$status}"); $this->_rspErr(1, "order status error, status: {$o_status}");
return; return;
} }
$buyStatus = 1; // 1: 成功, 2: 失败 $buyStatus = 0; // 1: 成功, 2: 失败
SqlHelper::update($conn, 't_shop_buy_order', array('idx' => $order_id), array('status' => $buyStatus) ); switch ($status) {
case "9":
$buyStatus = 1;
break;
case "99":
case "98":
$buyStatus = 2;
break;
}
SqlHelper::update($conn, 't_shop_buy_order', array('idx' => $order_id), array('status' => $buyStatus));
$row = mt\ShopGoods::get($id); $row = mt\ShopGoods::get($id);
if ($row) {
$desired_token_type = $row['token_type'];
$check_token_type = splitStr1($desired_token_type);
// $token_pos = array_search($token_type, $check_token_type, true);
// if (!in_array($token_type, $check_token_type)) {
// $this->_rspErr(1, "token_type parameter error, desired_token_type: {$desired_token_type}");
// return;
// }
$desired_token_type = $row['token_type']; if ($goods_num > $row['max_amount']) {
$check_token_type = splitStr1($desired_token_type); $this->_rspErr(1, "goods_num parameter error, max_amount: {$row['max_amount']}");
$token_pos = array_search($token_type, $check_token_type, true); return;
if (!in_array($token_type, $check_token_type)) { }
$this->_rspErr(1, "token_type parameter error, desired_token_type: {$desired_token_type}");
return; // 这里命名混乱了, 购买个数，一捆个数命名冲突
$goods_count = $row['goods_num'];
$itemMeta = mt\Item::get($row['goods_id']);
$propertyChgService = new services\PropertyChgService();
for ($i = 0; $i < $goods_num; $i++) {
$this->internalAddItem($propertyChgService, $itemMeta, $goods_count);
}
$awardService = new services\AwardService();
$awardService->addItem($row['goods_id'], $goods_num);
ShopBuyRecord::add($id, $goods_num);
} }
if ($goods_num > $row['max_amount']) {
$this->_rspErr(1, "goods_num parameter error, max_amount: {$row['max_amount']}");
return;
}
// 这里命名混乱了, 购买个数，一捆个数命名冲突
$goods_count = $row['goods_num'];
$itemMeta = mt\Item::get($row['goods_id']);
$propertyChgService = new services\PropertyChgService();
for ($i = 0; $i < $goods_num; $i++) {
$this->internalAddItem($propertyChgService, $itemMeta, $goods_count);
}
$awardService = new services\AwardService();
$awardService->addItem($row['goods_id'], $goods_num);
ShopBuyRecord::add($id, $goods_num);
$this->_rspOk(); $this->_rspOk();
} }
public function startGoodsDirect() { public function startGoodsDirect()
{
$id = getReqVal('id', 0); $id = getReqVal('id', 0);
$token_type = getReqVal('token_type', ''); $token_type = getReqVal('token_type', '');
$goods_num = getReqVal('goods_num', 0); $goods_num = getReqVal('goods_num', 0);
@ -376,7 +417,8 @@ class ShopController extends BaseAuthedController
} }
} }
public function statusGoodsDirect() { public function statusGoodsDirect()
{
$order_id = getReqVal('order_id', ''); $order_id = getReqVal('order_id', '');
$conn = myself()->_getMysql(''); $conn = myself()->_getMysql('');
@ -978,5 +1020,4 @@ class ShopController extends BaseAuthedController
$row = $conn->execQueryOne('SELECT LAST_INSERT_ID() as lastId;', array()); $row = $conn->execQueryOne('SELECT LAST_INSERT_ID() as lastId;', array());
return $row['lastId']; return $row['lastId'];
} }
} }