This commit is contained in:
aozhiwei 2023-08-02 15:10:19 +08:00
parent d3e16fd6b6
commit 22b8b1bac4
2 changed files with 14 additions and 6 deletions

View File

@ -7,6 +7,7 @@ require_once("mt/Item.php");
require_once("models/ShopBuyRecord.php");
require_once("models/InAppOrder.php");
require_once("models/InAppRecord.php");
require_once("services/LogService.php");
require_once("ShopAddItemService.php");
@ -18,6 +19,7 @@ use mt\Item;
use models\ShopBuyRecord;
use models\InAppOrder;
use models\InAppRecord;
use services\LogService;
@ -123,11 +125,14 @@ class InAppPurchase {
$itemId = $goodsMeta['item_id'];
$itemNum = $goodsMeta['item_num'];
if ($itemId == V_ITEM_DIAMOND) {
InAppRecord::addAmount($orderDb['price']);
$event = [
'name' => LogService::RECHARGE_DIAMOND,
'val' => $itemNum
];
LogService::productDiamondCallback(['account_id' => $orderDb['account_id']], $event);
$addItemService = new ShopAddItemService();
$addItemService->addItemByAccountId($orderDb['account_id'], $itemId, $itemNum);
} else {
myself()->_addLogEx($orderDb['account_id'], 'InAppPurchase', 'error_goods_item_id',
array(

View File

@ -31,6 +31,13 @@ class ShopAddItemService
}
public function addItem($address,$itemId,$itemNum){
$accountId = $this->getAccountId($address);
if ($accountId) {
$this->addItemByAccountId($accountId);
}
}
public function addItemByAccountId($accountId,$itemId,$itemNum){
if ($itemNum < 1){
return;
}
@ -38,8 +45,7 @@ class ShopAddItemService
if (!$itemMeta){
return;
}
$accountId = $this->getAccountId($address);
$conn = myself()->_getMysql($address);
$conn = myself()->_getMysql($accountId);
if ($this->_isVirtualItem($itemId)) {
$this->_addVirtualItem($conn,$accountId,$itemId, $itemNum);
}else{
@ -67,9 +73,6 @@ class ShopAddItemService
}
}
}
}
public function decItem($address, $itemId, $itemNum)
@ -314,4 +317,4 @@ class ShopAddItemService
);
}
}
}