This commit is contained in:
aozhiwei 2019-08-23 11:59:55 +08:00
parent 37b1c0e29a
commit b434e12a16
3 changed files with 17 additions and 13 deletions

@ -1 +1 @@
Subproject commit 1e3bb4df855f6d11df75545d10b0c2aacea34a06 Subproject commit 7ecf558df93a2656631782e76c6d35697da72808

View File

@ -84,7 +84,8 @@ class AddReward {
$item_list = $this->addSkin($it['index'], $item_num, $account_id); $item_list = $this->addSkin($it['index'], $item_num, $account_id);
} }
foreach ($item_list as $item) { foreach ($item_list as $item) {
switch ($it['type']) $i = $this->getItem($item['itemid']);
switch ($i['type'])
{ {
case 1: case 1:
//添加金币 //添加金币
@ -92,6 +93,7 @@ class AddReward {
break; break;
case 2: case 2:
//添加钻石 //添加钻石
error_log($item['itemid'], $item['itemnum']);
$this->addDiamond($item['itemid'], $item['itemnum'], $account_id); $this->addDiamond($item['itemid'], $item['itemnum'], $account_id);
break; break;
case 3: case 3:
@ -150,7 +152,7 @@ class AddReward {
} }
$row = $conn->execQueryOne('SELECT status FROM emoji WHERE accountid=:accountid AND emojiid=:emojiid;', $row = $conn->execQueryOne('SELECT status FROM emoji WHERE accountid=:accountid AND emojiid=:emojiid;',
array( array(
':accountid' => $account_id, ':accountid' => $accountid,
':emojiid' => $itemid, ':emojiid' => $itemid,
)); ));
if (!$row) { if (!$row) {
@ -158,7 +160,7 @@ class AddReward {
' VALUES(:account_id, :emojiid, 1, :create_time, :modify_time) ' . ' VALUES(:account_id, :emojiid, 1, :create_time, :modify_time) ' .
' ON DUPLICATE KEY UPDATE accountid=:account_id, emojiid=:emojiid, status=1, modify_time=:modify_time;', ' ON DUPLICATE KEY UPDATE accountid=:account_id, emojiid=:emojiid, status=1, modify_time=:modify_time;',
array( array(
':account_id' => $account_id, ':account_id' => $accountid,
':emojiid' => $itemid, ':emojiid' => $itemid,
':create_time' => time(), ':create_time' => time(),
':modify_time' => time() ':modify_time' => time()
@ -184,6 +186,8 @@ class AddReward {
//添加钻石 //添加钻石
protected function addDiamond($item_id, $item_num, $accountid) protected function addDiamond($item_id, $item_num, $accountid)
{ {
error_log($item_id);
error_log($item_num);
$conn = $this->getMysql($accountid); $conn = $this->getMysql($accountid);
if (!$conn) { if (!$conn) {
phpcommon\sendError(ERR_USER_BASE + 1, '没有这个玩家'); phpcommon\sendError(ERR_USER_BASE + 1, '没有这个玩家');
@ -191,12 +195,12 @@ class AddReward {
} }
$row = $conn->execQueryOne('SELECT diamond_num FROM user WHERE accountid=:accountid;', $row = $conn->execQueryOne('SELECT diamond_num FROM user WHERE accountid=:accountid;',
array( array(
':accountid' => $account_id ':accountid' => $accountid
)); ));
$ret = $conn->execScript('UPDATE user SET diamond_num=:diamond_num, modify_time=:modify_time ' . $ret = $conn->execScript('UPDATE user SET diamond_num=:diamond_num, modify_time=:modify_time ' .
' WHERE accountid=:accountid;', ' WHERE accountid=:accountid;',
array( array(
':accountid' => $account_id, ':accountid' => $accountid,
':diamond_num' => $item_num + $row['diamond_num'], ':diamond_num' => $item_num + $row['diamond_num'],
':modify_time' => time() ':modify_time' => time()
)); ));
@ -214,12 +218,12 @@ class AddReward {
} }
$row = $conn->execQueryOne('SELECT coin_num FROM user WHERE accountid=:accountid;', $row = $conn->execQueryOne('SELECT coin_num FROM user WHERE accountid=:accountid;',
array( array(
':accountid' => $account_id ':accountid' => $accountid
)); ));
$ret = $conn->execScript('UPDATE user SET coin_num=:coin_num, modify_time=:modify_time ' . $ret = $conn->execScript('UPDATE user SET coin_num=:coin_num, modify_time=:modify_time ' .
' WHERE accountid=:accountid;', ' WHERE accountid=:accountid;',
array( array(
':accountid' => $account_id, ':accountid' => $accountid,
':coin_num' => $item_num + $row['coin_num'], ':coin_num' => $item_num + $row['coin_num'],
':modify_time' => time() ':modify_time' => time()
)); ));
@ -237,7 +241,7 @@ class AddReward {
} }
$rowSkin = $conn->execQueryOne('SELECT fragment_num FROM skin WHERE accountid=:accountid AND fragment_id=:fragment_id;', $rowSkin = $conn->execQueryOne('SELECT fragment_num FROM skin WHERE accountid=:accountid AND fragment_id=:fragment_id;',
array( array(
':accountid' => $account_id, ':accountid' => $accountid,
':fragment_id' => $item_id ':fragment_id' => $item_id
)); ));
if (!$rowSkin) { if (!$rowSkin) {
@ -284,7 +288,7 @@ class AddReward {
} }
$rowSkin = $conn->execQueryOne('SELECT fragment_num FROM skin WHERE accountid=:accountid AND fragment_id=:fragment_id;', $rowSkin = $conn->execQueryOne('SELECT fragment_num FROM skin WHERE accountid=:accountid AND fragment_id=:fragment_id;',
array( array(
':accountid' => $account_id, ':accountid' => $accountid,
':fragment_id' => $item_id ':fragment_id' => $item_id
)); ));
if (!$rowSkin) { if (!$rowSkin) {
@ -292,7 +296,7 @@ class AddReward {
' VALUES(:account_id, :skin_id, :skin_status, :fragment_id, 0, 0, 0, :skin_type, 1, 0, 0, :create_time, :modify_time) ' . ' VALUES(:account_id, :skin_id, :skin_status, :fragment_id, 0, 0, 0, :skin_type, 1, 0, 0, :create_time, :modify_time) ' .
' ON DUPLICATE KEY UPDATE accountid=:account_id, skin_id=:skin_id, skin_status=:skin_status, fragment_id=:fragment_id, fragment_num=0, active_time=0, fragment_status=0, skin_type=:skin_type, skin_level=1, skin_experience_level=0, skin_experience_type=0, modify_time=:modify_time;', ' ON DUPLICATE KEY UPDATE accountid=:account_id, skin_id=:skin_id, skin_status=:skin_status, fragment_id=:fragment_id, fragment_num=0, active_time=0, fragment_status=0, skin_type=:skin_type, skin_level=1, skin_experience_level=0, skin_experience_type=0, modify_time=:modify_time;',
array( array(
':account_id' => $account_id, ':account_id' => $accountid,
':skin_id' => $item_id, ':skin_id' => $item_id,
':skin_status' => 1, ':skin_status' => 1,
':fragment_id' => $item_id - 1000, ':fragment_id' => $item_id - 1000,

View File

@ -442,8 +442,8 @@ class PayController{
} }
$itemid = $_REQUEST['itemid']; $itemid = $_REQUEST['itemid'];
$itemnum = $_REQUEST['itemnum']; $itemnum = $_REQUEST['itemnum'];
$itemid = 16002; // $itemid = 16002;
$itemnum = 1; // $itemnum = 1;
$item_meta_table = require('../res/item@item.php'); $item_meta_table = require('../res/item@item.php');
$item_meta = getItemConfig($item_meta_table, $itemid); $item_meta = getItemConfig($item_meta_table, $itemid);