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

1

Browse Source
This commit is contained in:
hujiabin 2023-06-27 16:12:08 +08:00
parent e7837de486
commit 876f69fd7a
2 changed files with 11 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
webapp/services/callback/BuyPassCbService.php
View File

@ -12,12 +12,11 @@ use phpcommon\SqlHelper;
class BuyPassCbService
{
public function process($order){
error_log("GameItemMallBuyOk4:BuyPassCbService");
error_log("BuyPassCbService----------------");
$itemService = new ShopAddItemService();
switch ($order['item_id']){
//购买通行证回调
case V_ITEM_PASS : {
error_log("GameItemMallBuyOk5:battlePass");
$itemService->addGameLog($order['address'],"buyItem","begin",array(
'param1' => $order['order_id'],
'param2' => json_encode(array(
@ -38,7 +37,6 @@ class BuyPassCbService
break;
//购买等级回调
case V_ITEM_EXP : {
error_log("GameItemMallBuyOk6:passLevel");
$itemService->addGameLog($order['address'],"buyItem","begin",array(
'param1' => $order['order_id'],
'param2' => json_encode(array(
@ -74,6 +72,15 @@ class BuyPassCbService
'activatetime' => myself()->_getNowTime(),
)
);
$userDb = SqlHelper::ormSelectOne(
myself()->_getMysql($address),
't_user',
array(
'address' => $address
)
);
$this->_updatePassData($userDb);
}
private function _updateUserLevel($address,$exp){

10
webapp/services/callback/GameItemMallBuyOk.php
View File

@ -15,8 +15,7 @@ class GameItemMallBuyOk {
$address = getReqVal('address', '');
$orderId = getReqVal('order_id', '');
error_log("GameItemMallBuyOk1:process", $address, $orderId);
error_log("GameItemMallBuyOk-------------------");
$orderDb = SqlHelper::ormSelectOne(
myself()->_getMysql($address),
't_bc_order',
@ -24,10 +23,8 @@ error_log("GameItemMallBuyOk1:process", $address, $orderId);
'order_id' => $orderId
)
);
error_log("GameItemMallBuyOk2:select order");
//1：已发货 2：订单不存在
if (!$orderDb){
error_log("GameItemMallBuyOk2-1:订单不存在");
echo json_encode(array(
'errcode' => 2,
'errmsg' => "Order does not exist",
@ -35,25 +32,21 @@ error_log("GameItemMallBuyOk1:process", $address, $orderId);
die ;
}
if ($orderDb['status'] == 1){
error_log("GameItemMallBuyOk2-2:订单已发货");
echo json_encode(array(
'errcode' => 1,
'errmsg' => "Order shipped",
));
die;
}
error_log("GameItemMallBuyOk2-3:updateOrderState begin");
// 修改订单状态
$this->_updateOrderState($address,$orderId);
// 小胡 回调的处理
if ($this->_isVirtualItem($orderDb['item_id'])){
$passCbService = new BuyPassCbService();
error_log("GameItemMallBuyOk3:小胡");
$passCbService->process($orderDb);
} else {
// 老宋 处理...
error_log("GameItemMallBuyOk3: 宋");
$shopGoodsCbService = new BuyShopGoodsCbService();
$shopGoodsCbService->process($orderDb);
@ -69,7 +62,6 @@ error_log("GameItemMallBuyOk1:process", $address, $orderId);
}
private function _updateOrderState($address,$transId){
error_log("GameItemMallBuyOk2-4:updateOrderState");
SqlHelper::update
(myself()->_getMysql($address),
't_bc_order',