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

1

Browse Source
This commit is contained in:
aozhiwei 2020-03-18 14:23:32 +08:00
parent befe63ef5b
commit d256efc357
13 changed files with 276 additions and 1660 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
webapp/bootstrap/config_loader.php
View File

@ -206,5 +206,11 @@ function getBagConfig($Bag_table, $Bag_id)
$Bag_id = (int)$Bag_id;
return array_key_exists($Bag_id, $Bag_table) ? $Bag_table[$Bag_id] : null;
}
function getDrawTableConfig($drawbig_table, $drawbig_id)
{
$drawbig_id = (int)$drawbig_id;
return array_key_exists($drawbig_id, $drawbig_table) ? $drawbig_table[$drawbig_id] : null;
}
checkMysqlConfig();
checkRedisConfig();

19
webapp/classes/AddReward.php
View File

@ -58,24 +58,24 @@ class AddReward {
}
$item_list = array();
array_push($item_list, array(
'itemid' => $item_id,
'itemnum' => $item_num,
'item_id' => $item_id,
'item_num' => $item_num,
'time' => $time
));
foreach ($item_list as $item) {
$i = $this->getItem($item['itemid']);
$i = $this->getItem($item['item_id']);
if ($i['type'] == 1){
$this->addCoin($item['itemid'], $item['itemnum'], $account_id);
$this->addCoin($item['item_id'], $item['item_num'], $account_id);
} else if ($i['type'] == 2) {
$this->addDiamond($item['itemid'], $item['itemnum'], $account_id);
$this->addDiamond($item['item_id'], $item['item_num'], $account_id);
} else {
$price = $i['diamond'];
if ($time != 0) {
$price = $i['diamond_hour'] * $time;
}
$item_list = $this->addItem($item['itemid'], $item['time'], $account_id, $price);
$item_list = $this->addItem($item['item_id'], $item['time'], $account_id, $price);
}
}
return $item_list;
@ -179,10 +179,7 @@ class AddReward {
':accountid' => $accountid,
'id' => $item_id
));
error_log(22222222);
if (!$row) {
error_log(111111111);
error_log($item_id);
$ret = $conn->execScript('INSERT INTO bag(accountid, id, color_id, status, active_time, create_time, modify_time) ' .
' VALUES(:account_id, :id, 0, :status, :active_time, :create_time, :modify_time) ' .
' ON DUPLICATE KEY UPDATE accountid=:account_id, id=:id, color_id=0, status=:status, active_time=:active_time, modify_time=:modify_time;',
@ -228,8 +225,8 @@ class AddReward {
}
}
array_push($item_list, array(
'itemid' => $item_id,
'itemnum' => $item_num,
'item_id' => $item_id,
'item_num' => $item_num,
'time' => $time,
));
return $item_list;

330
webapp/controller/ActivityController.class.php
View File

@ -86,6 +86,22 @@ class ActivityController{
return $l;
}
protected function getDrawTableConfig($id)
{
$g_conf_lot_cluster = require('../res/lotterydraw@lotterydraw.php');
$lot_conf = getLotteryConfig($g_conf_lot_cluster, $lot_id);
$l = array(
'id' => $lot_conf['id'],
'item_id' => $lot_conf['item_id'],
'num' => $lot_conf['num'],
'weight' => $lot_conf['weight'],
'quailty' => $lot_conf['quailty'],
'jilv' => $lot_conf['jilv'],
'time' => $lot_conf['time'],
);
return $l;
}
protected function getreward($re_id)
{
$g_conf_re_cluster = require('../res/randreward@randreward.php');
@ -99,6 +115,79 @@ class ActivityController{
return $re;
}
public function drawTableInfo()
{
$account_id = $_REQUEST['account_id'];
//登录校验
$login = loginVerify($account_id, $_REQUEST['session_id']);
if (!$login) {
phpcommon\sendError(ERR_USER_BASE + 1, 'session无效');
return;
}
$conn = $this->getMysql($account_id);
if (!$conn) {
phpcommon\sendError(ERR_USER_BASE + 1, '没有这个玩家');
return;
}
$drawtable_uuid = 'game2004api_drawtable_uuid:' . md5($_REQUEST['account_id']);
$drawtable_list = array();
$r = $this->getRedis($drawtable_uuid);
if (!$r) {
die();
return;
}
//道具物品
$user_db_str = $r->get($drawtable_uuid);
if (empty($user_db_str)) {
$drawtable_list = $this->randomReward(2);
$drawtable_db = array(
'drawtable_uuid' => $drawtable_uuid,
'drawtable_list' => $drawtable_list,
);
$r -> set($drawtable_uuid, json_encode($drawtable_db));
$r -> pexpire($drawtable_uuid, 1000 * 3600 * 24);
} else {
$drawtable_db = json_decode($user_db_str, true);
$rowTime = $conn->execQueryOne('SELECT modify_time FROM activity WHERE accountid=:accountid;',
array(
':accountid' => $account_id
));
if (phpcommon\getdayseconds(time()) - phpcommon\getdayseconds($rowTime['modify_time']) > 0) {
$drawtable_list = $this->randomReward(2);
$drdrawtableaw_db = array(
'drawtable_uuid' => $drawtable_uuid,
'drawdrawtable_list' => $drawtable_list,
);
$r -> set($drawtable_uuid, json_encode($drawtable_db));
$r -> pexpire($drawtable_uuid, 1000 * 3600 * 24);
} else {
$user_db = json_decode($user_db_str, true);
if (empty($user_db)) {
phpcommon\sendError(ERR_USER_BASE + 1,'session失效');
return;
}
foreach ($user_db['drawtable_list'] as $drawtable) {
array_push($drawtable_list, array(
'item_id' => $drawtable['item_id'],
'item_num' => $drawtable['item_num'],
'quailty' => $drawtable['quailty'],
'time' => $drawtable['time'],
));
}
}
}
echo json_encode(array(
'errcode' => 0,
'errmsg'=> '',
'drawtable_uuid' => $drawtable_uuid,
'item_list' => $drawtable_list,
));
}
public function luckDrawInfo()
{
$account_id = $_REQUEST['account_id'];
@ -154,7 +243,7 @@ class ActivityController{
//道具物品
$user_db_str = $r->get($draw_uuid);
if (empty($user_db_str)) {
$draw_list = $this->randomReward();
$draw_list = $this->randomReward(1);
$draw_db = array(
'draw_uuid' => $draw_uuid,
'draw_list' => $draw_list,
@ -168,7 +257,7 @@ class ActivityController{
':accountid' => $account_id
));
if (phpcommon\getdayseconds(time()) - phpcommon\getdayseconds($rowTime['modify_time']) > 0) {
$draw_list = $this->randomReward();
$draw_list = $this->randomReward(1);
$draw_db = array(
'draw_uuid' => $draw_uuid,
'draw_list' => $draw_list,
@ -203,6 +292,100 @@ class ActivityController{
}
public function getDrawTable()
{
$account_id = $_REQUEST['account_id'];
//登录校验
$login = loginVerify($account_id, $_REQUEST['session_id']);
if (!$login) {
phpcommon\sendError(ERR_USER_BASE + 1, 'session无效');
return;
}
$conn = $this->getMysql($account_id);
if (!$conn) {
phpcommon\sendError(ERR_USER_BASE + 2, '没有这个玩家');
return;
}
//随机确认奖励
$weight_sum = 0;
$g_conf_lot_cluster = require('../res/lotterydraw@lotterydraw.php');
for ($i = 1; $i <= count($g_conf_lot_cluster); $i++) {
$l = $this->getLottery($i);
$weight_sum += $l['jilv'];
}
$random = Rand(0, $weight_sum);
$weight = 0;
$key = 0;
for ($ii = 1; $ii <= count($g_conf_lot_cluster); $ii++) {
$l = $this->getLottery($ii);
$weight += $l['jilv'];
if ($weight > $random) {
$key = $ii;
break;
}
}
$drawtable_uuid = $_REQUEST['drawtable_uuid'];
$item_id = 0;
$item_num = 0;
$flag = 0;
$r = $this->getRedis($drawtable_uuid);
$user_db_str = $r->get($drawtable_uuid);
if (empty($user_db_str)) {
phpcommon\sendError(ERR_USER_BASE + 1,'session失效');
return;
}
$user_db = json_decode($user_db_str, true);
if (empty($user_db)) {
phpcommon\sendError(ERR_USER_BASE + 1,'session失效');
return;
}
foreach ($user_db['drawtable_list'] as $draw) {
if ($draw['key'] == $key - 1) {
$item_id = $draw['item_id'];
$item_num = $draw['item_num'];
$time = $draw['time'];
$flag = 1;
break;
}
}
if ($flag == 0) {
phpcommon\sendError(ERR_USER_BASE + 3, '没有这个物品');
return;
}
$ret = $conn->execScript('UPDATE activity SET item_id=:item_id, item_num=:item_num, modify_time=:modify_time ' .
' WHERE accountid=:accountid;',
array(
':accountid' => $account_id,
':item_id' => $item_id,
':item_num' => $item_num,
':modify_time' => time()
));
if (!$ret) {
die();
return;
}
//增加奖励
$addreward = new classes\AddReward();
$all_item_list = $addreward->addReward($item_id, $item_num, $account_id, $time);
$coin_num = $addreward->getCoinNum($account_id);
$diamond_num = $addreward->getDiamondNum($account_id);
$item_list = array();
array_push($item_list,array(
'item_id' => $item_id,
'item_num' => $item_num,
'time' => $time,
));
echo json_encode(array(
'errcode' => 0,
'errmsg'=> '',
'coin_nums' => $coin_num,
'diamond_nums' => $diamond_num,
'item_list' => $item_list,
'all_item_list' => $all_item_list
));
}
public function getLuckDraw()
{
$account_id = $_REQUEST['account_id'];
@ -314,13 +497,14 @@ class ActivityController{
}
//增加奖励
$addreward = new classes\AddReward();
$addreward->addReward($item_id, $item_num, $account_id, $time);
$all_item_list = $addreward->addReward($item_id, $item_num, $account_id, $time);
$coin_num = $addreward->getCoinNum($account_id);
$diamond_num = $addreward->getDiamondNum($account_id);
$item_list = array();
array_push($item_list,array(
'item_id' => $item_id,
'item_num' => $item_num,
'time' => $time
));
echo json_encode(array(
'errcode' => 0,
@ -329,10 +513,12 @@ class ActivityController{
'item_num' => $item_num,
'coin_nums' => $coin_num,
'diamond_nums' => $diamond_num,
'item_list' => $item_list
'item_list' => $item_list,
'all_item_list' => $all_item_list
));
}
public function doubleLuckDraw()
{
$account_id = $_REQUEST['account_id'];
@ -368,10 +554,15 @@ class ActivityController{
));
}
protected function randomReward()
protected function randomReward($type)
{
$draw_list = array();
$g_conf_lot_cluster = require('../res/lottery@lottery.php');
$g_conf_lot_cluster = array();
if ($type == 1) {
$g_conf_lot_cluster = require('../res/lottery@lottery.php');
} else {
$g_conf_lot_cluster = require('../res/lotterydraw@lotterydraw.php');
}
for ($i = 1; $i <= count($g_conf_lot_cluster); $i++) {
$item_id = 0;
$item_num = 0;
@ -411,136 +602,9 @@ class ActivityController{
return $draw_list;
}
public function randRewardInfo()
{
$account_id = $_REQUEST['account_id'];
//登录校验
$login = loginVerify($account_id, $_REQUEST['session_id']);
if (!$login) {
phpcommon\sendError(ERR_USER_BASE + 1, 'session无效');
return;
}
$conn = $this->getMysql($account_id);
if (!$conn) {
phpcommon\sendError(ERR_USER_BASE + 1, '没有这个玩家');
return;
}
$randreward_uuid = 'game2004api_randreward_uuid:' . md5($_REQUEST['account_id']);
$randreward_list = array();
$r = $this->getRedis($randreward_uuid);
$user_db_str = $r->get($randreward_uuid);
if (!$r) {
die();
return;
}
if (empty($user_db_str)) {
$randreward_list = $this->getRandomReward();
$randreward_db = array(
'randreward_uuid' => $randreward_uuid,
'randreward_list' => $randreward_list,
);
$r -> set($randreward_uuid, json_encode($randreward_db));
$r -> pexpire($randreward_uuid, 1000 * 7200);
} else {
$randreward_list = $this->getRandomReward();
$randreward_db = array(
'randreward_uuid' => $randreward_uuid,
'randreward_list' => $randreward_list,
);
$r -> set($randreward_uuid, json_encode($randreward_db));
$r -> pexpire($randreward_uuid, 1000 * 7200);
}
$r = $this->getRedis($randreward_uuid);
$user_db_str = $r->get($randreward_uuid);
$user_db = json_decode($user_db_str, true);
foreach ($user_db['randreward_list'] as $randreward) {
//增加奖励
$addreward = new classes\AddReward();
$addreward->addReward($randreward['item_id'], $randreward['item_num'], $account_id);
}
echo json_encode(array(
'errcode' => 0,
'errmsg'=> '',
'randreward_uuid' => $randreward_uuid,
'item_list' => $randreward_list,
));
}
public function doubleRandReward()
{
$account_id = $_REQUEST['account_id'];
//登录校验
$login = loginVerify($account_id, $_REQUEST['session_id']);
if (!$login) {
phpcommon\sendError(ERR_USER_BASE + 1, 'session无效');
return;
}
$randreward_uuid = $_REQUEST['randreward_uuid'];
$r = $this->getRedis($randreward_uuid);
if (!$r) {
die();
return;
}
$user_db_str = $r->get($randreward_uuid);
if (empty($user_db_str)) {
phpcommon\sendError(ERR_USER_BASE + 1,'session失效');
return;
}
$user_db = json_decode($user_db_str, true);
if (empty($user_db)) {
phpcommon\sendError(ERR_USER_BASE + 1,'session失效');
return;
}
$p = $this->getParameter(REWARD_TIMES);
$times = $p['value'] - 1;
foreach ($user_db['randreward_list'] as $randreward) {
//增加奖励
$addreward = new classes\AddReward();
$addreward->addReward($randreward['item_id'], $randreward['item_num'] * $times, $account_id);
}
$r->del($randreward_uuid, json_encode($user_db));
echo json_encode(array(
'errcode' => 0,
'errmsg'=> '',
));
}
protected function getRandomReward()
{
$randreward_list = array();
$g_conf_re_cluster = require('../res/randreward@randreward.php');
for ($i = 1; $i <= count($g_conf_re_cluster); $i++) {
$item_id = 0;
$item_num = 0;
$key = 0;
$re = $this->getreward($i);
//确定商品id和数量
$weight_sum = 0;
$weight_array = $this->getExplode($re['weight']);
for ($ii = 0; $ii < count($weight_array); $ii++) {
$weight_sum += $weight_array[$ii][0];
}
$random = Rand(0, $weight_sum);
$weight = 0;
for ($ii = 0; $ii < count($weight_array); $ii++) {
$weight += $weight_array[$ii][0];
if ($weight > $random) {
$key = $ii;
break;
}
}
$item_id_array = $this->getExplode($re['reward']);
$num_array = $this->getExplode($re['number']);
$item_id = $item_id_array[$key][0];
$item_num = $num_array[$key][0];
array_push($randreward_list, array(
'item_id' => $item_id,
'item_num' => $item_num,
));
}
return $randreward_list;
}
}
?>

282
webapp/controller/EmojiController.class.php
View File

@ -1,282 +0,0 @@
<?php
require 'classes/Quest.php';
require 'classes/AddReward.php';
class EmojiController{
protected function getMysql($account_id)
{
$mysql_conf = getMysqlConfig(crc32($account_id));
$conn = new phpcommon\Mysql(array(
'host' => $mysql_conf['host'],
'port' => $mysql_conf['port'],
'user' => $mysql_conf['user'],
'passwd' => $mysql_conf['passwd'],
'dbname' => 'gamedb2004_' . $mysql_conf['instance_id']
));
return $conn;
}
protected function getEmoji($emoji_id)
{
$emoji_meta_table = require('../res/emoji@emoji.php');
$emoji_meta = getEmojiConfig($emoji_meta_table, $emoji_id);
$emoji = array(
'id' => $emoji_meta['id'],
'name' => $emoji_meta['emoji_name'],
'title' => $emoji_meta['emoji_title'],
'icon' => $emoji_meta['emoji_icon'],
'type' => $emoji_meta['emoji_type'],
'get_type' => $emoji_meta['get_type'],
'number' => $emoji_meta['number'],
'order_weight' => $emoji_meta['order_weight'],
);
return $emoji;
}
public function emojiInfo()
{
$account_id = $_REQUEST['account_id'];
//登录校验
$login = loginVerify($account_id, $_REQUEST['session_id']);
if (!$login) {
phpcommon\sendError(ERR_USER_BASE + 1, 'session无效');
return;
}
$conn = $this->getMysql($account_id);
if (!$conn) {
phpcommon\sendError(ERR_USER_BASE + 1, '没有这个玩家');
return;
}
$emoji_list = array();
$emoji_meta_table = require('../res/emoji@emoji.php');
foreach ($emoji_meta_table as $emoji_info) {
$id = $emoji_info['id'];
$emoji = $this->getEmoji($id);
if (!$emoji) {
continue;
}
$status = 2;
$row = $conn->execQueryOne('SELECT status FROM emoji WHERE accountid=:accountid AND emojiid=:emojiid;',
array(
':accountid' => $account_id,
'emojiid' => $emoji['id']
));
if (!$row && $emoji['get_type'] == 1) {
//插入默认上阵的表情
$ret = $conn->execScript('INSERT INTO emoji(accountid, emojiid, status, create_time, modify_time) ' .
' VALUES(:account_id, :emojiid, 0, :create_time, :modify_time) ' .
' ON DUPLICATE KEY UPDATE accountid=:account_id, emojiid=:emojiid, status=0, modify_time=:modify_time;',
array(
':account_id' => $account_id,
':emojiid' => $id,
':create_time' => time(),
':modify_time' => time(),
//':type' => $emoji['type']
));
if(!$ret){
die();
}
$status = 0;
}
if ($row) {
$status = $row['status'];
}
array_push($emoji_list, array(
'emoji_id' => $emoji['id'],
'emoji_status' => $status,
'emoji_icon' => $emoji['icon'],
'title_icon' => $emoji['title'],
'emoji_type' => $emoji['type'],
'get_type' => $emoji['get_type'],
'coin_num' => $emoji['number'],
'order' => $emoji['order_weight'],
));
}
echo json_encode(array(
'errcode' => 0,
'errmsg' => '',
'emoji_list' => $emoji_list
));
}
public function exchageEmoji()
{
$account_id = $_REQUEST['account_id'];
//登录校验
$login = loginVerify($account_id, $_REQUEST['session_id']);
if (!$login) {
phpcommon\sendError(ERR_USER_BASE + 1, 'session无效');
return;
}
$conn = $this->getMysql($account_id);
if (!$conn) {
phpcommon\sendError(ERR_USER_BASE + 1, '没有这个玩家');
return;
}
$emoji_list = array();
//$usingemoji_id = $_REQUEST['usingemoji_id'];
$exchangeemoji_id = $_REQUEST['exchangeemoji_id'];
$e = $this->getEmoji($exchangeemoji_id);
$emoji_meta_table = require('../res/emoji@emoji.php');
foreach ($emoji_meta_table as $emoji_info) {
$id = $emoji_info['id'];
$emoji = $this->getEmoji($id);
if ($emoji['type'] != $e['type']) {
continue;
}
$row = $conn->execQueryOne('SELECT status FROM emoji WHERE accountid=:accountid AND emojiid=:emojiid;',
array(
':accountid' => $account_id,
':emojiid' => $id,
));
if ($row['status'] != 0 || !$row) {
continue;
}
$using_ret = $conn->execScript('UPDATE emoji SET status=1, modify_time=:modify_time ' .
' WHERE accountid = :account_id AND emojiid = :emojiid;',
array(
':account_id' => $account_id,
':emojiid' => $id,
':modify_time' => time()
));
array_push($emoji_list, array(
'emoji_id' => $usingemoji_id,
'emoji_status' => 1
));
}
/*$row = $conn->execQueryOne('SELECT status FROM emoji WHERE accountid=:accountid AND emojiid=:emojiid;',
array(
':accountid' => $account_id,
':emojiid' => $usingemoji_id,
));
if (!$row) {
phpcommon\sendError(ERR_USER_BASE + 2, '没有这个表情');
return;
}
if ($row['status'] != 0) {
phpcommon\sendError(ERR_USER_BASE + 3, '该表情未上阵');
return;
}
$using_ret = $conn->execScript('UPDATE emoji SET status=1, modify_time=:modify_time ' .
' WHERE accountid = :account_id AND emojiid = :emojiid;',
array(
':account_id' => $account_id,
':emojiid' => $usingemoji_id,
':modify_time' => time()
));
if(!$using_ret){
die();
return;
}
array_push($emoji_list, array(
'emoji_id' => $usingemoji_id,
'emoji_status' => 1
));*/
$row = $conn->execQueryOne('SELECT status FROM emoji WHERE accountid=:accountid AND emojiid=:emojiid;',
array(
':accountid' => $account_id,
':emojiid' => $exchangeemoji_id,
));
if (!$row) {
phpcommon\sendError(ERR_USER_BASE + 2, '没有这个表情');
return;
}
$exchange_ret = $conn->execScript('UPDATE emoji SET status=0, modify_time=:modify_time ' .
' WHERE accountid = :account_id AND emojiid = :emojiid;',
array(
':account_id' => $account_id,
':emojiid' => $exchangeemoji_id,
':modify_time' => time()
));
if(!$exchange_ret){
die();
return;
}
array_push($emoji_list, array(
'emoji_id' => $exchangeemoji_id,
'emoji_status' => 0
));
echo json_encode(array(
'errcode' => 0,
'errmsg' => '',
'emoji_list' => $emoji_list
));
}
public function buyEmoji()
{
$account_id = $_REQUEST['account_id'];
//登录校验
$login = loginVerify($account_id, $_REQUEST['session_id']);
if (!$login) {
phpcommon\sendError(ERR_USER_BASE + 1, 'session无效');
return;
}
$conn = $this->getMysql($account_id);
if (!$conn) {
phpcommon\sendError(ERR_USER_BASE + 1, '没有这个玩家');
return;
}
$id = $_REQUEST['emoji_id'];
$emoji = $this->getEmoji($id);
if (!$emoji) {
phpcommon\sendError(ERR_USER_BASE + 1, '没有这个表情');
return;
}
if ($emoji['get_type'] != 2) {
phpcommon\sendError(ERR_USER_BASE + 1, '不能用钻石购买');
return;
}
//扣除钻石
$row = $conn->execQueryOne('SELECT diamond_num FROM user WHERE accountid=:accountid;',
array(
':accountid' => $account_id
));
if (!$row) {
phpcommon\sendError(ERR_USER_BASE + 2, '没有这个玩家');
return;
}
if ($row['diamond_num'] < $emoji['number']) {
phpcommon\sendError(ERR_USER_BASE + 3, '钻石不足');
return;
}
$ret = $conn->execScript('UPDATE user SET diamond_num=:diamond_num, modify_time=:modify_time ' .
' WHERE accountid=:accountid;',
array(
':accountid' => $account_id,
':diamond_num' => $row['diamond_num'] - $emoji['number'],
':modify_time' => time()
));
if (!$ret) {
die();
return;
}
//修改状态
$addreward = new classes\AddReward();
$addreward->addReward($id, 1, $account_id);
$coin_num = $addreward->getCoinNum($account_id);
$diamond_num = $addreward->getDiamondNum($account_id);
$item_list = array();
array_push($item_list,array(
'item_id' => $id,
'item_num' => 1,
));
echo json_encode(array(
'errcode' => 0,
'errmsg'=> '',
'emoji_status' => 1,
'coin_nums' => $coin_num,
'diamond_nums' => $diamond_num,
'item_list' => $item_list
));
}
}
?>

290
webapp/controller/EquipController.class.php
View File

@ -1,290 +0,0 @@
<?php
require 'classes/Quest.php';
class EquipController{
protected function getMysql($account_id)
{
$mysql_conf = getMysqlConfig(crc32($account_id));
$conn = new phpcommon\Mysql(array(
'host' => $mysql_conf['host'],
'port' => $mysql_conf['port'],
'user' => $mysql_conf['user'],
'passwd' => $mysql_conf['passwd'],
'dbname' => 'gamedb2004_' . $mysql_conf['instance_id']
));
return $conn;
}
protected function getEquip($equip_id)
{
$g_conf_equip_cluster = require('../res/equipUpgrade@equipUpgrade.php');
$equip_conf = getEquipConfig($g_conf_equip_cluster, $equip_id);
$e = array(
'equip_id' => $equip_conf['id'],
'equip_name' => $equip_conf['name'],
'equip_type' => $equip_conf['equip_page'],
'cost_int' => $equip_conf['cost_int'],
'max_lv' => $equip_conf['max_lv'],
'equip_cost' => $equip_conf['cost'],
'equip_attr_type' => $equip_conf['attr_type'],
);
return $e;
}
protected function getParameter($para_id)
{
$g_conf_para_cluster = require('../res/parameter@parameter.php');
$para_conf = getParameterConfig($g_conf_para_cluster, $para_id);
$p = array(
'id' => $para_conf['id'],
'param_name' => $para_conf['param_name'],
'param_value' => $para_conf['param_value'],
);
return $p;
}
protected function subCoin($account_id, $equip_id, $equip_level, $free)
{
$e = $this->getEquip($equip_id);
if (!$e) {
phpcommon\sendError(ERR_USER_BASE + 2, '没有这个装备');
die();
}
if ($e['max_lv'] <= $equip_level) {
phpcommon\sendError(ERR_USER_BASE + 4, '装备已到满级');
die();
}
$conn = $this->getMysql($account_id);
if (!$conn) {
phpcommon\sendError(ERR_USER_BASE + 1, '没有这个玩家');
die();
}
$coin_num = $e['equip_cost'] * ceil($equip_level / 5) + $e['cost_int'];
if ($free == 1) {
$coin_num = 0;
}
$rowCoin = $conn->execQueryOne('SELECT * FROM user WHERE accountid=:accountid;',
array(
':accountid' => $account_id
));
if ($rowCoin['coin_num'] < $coin_num) {
phpcommon\sendError(ERR_USER_BASE + 3, '金币不足');
die();
}
$ret = $conn->execScript('UPDATE user SET coin_num=:coin_num, modify_time=:modify_time ' .
' WHERE accountid=:accountid;',
array(
':accountid' => $account_id,
':coin_num' => $rowCoin['coin_num'] - $coin_num,
':modify_time' => time()
));
if (!$ret) {
die();
}
return $e;
}
public function equipInfo()
{
$account_id = $_REQUEST['account_id'];
//登录校验
$login = loginVerify($account_id, $_REQUEST['session_id']);
if (!$login) {
phpcommon\sendError(ERR_USER_BASE + 1, 'session无效');
return;
}
$conn = $this->getMysql($account_id);
$equip_list = array();
if (!$conn) {
phpcommon\sendError(ERR_USER_BASE + 1, '没有这个玩家');
return;
}
$rowCount = $conn->execQueryRowCount('SELECT * FROM equip WHERE accountid=:account_id;',
array(
':account_id' => $account_id
));
if ($rowCount != 0) {
$active_time = 0;
$equip_level = 0;
$rows = $conn->execQuery('SELECT * FROM equip WHERE accountid=:account_id;',
array(
':account_id' => $account_id
));
foreach ($rows as $row) {
if (time() >= $row['active_time'] && $row['active_time'] != 0) {
$ret = $conn->execScript('UPDATE equip SET active_time=0, equip_experience_level=0, modify_time=:modify_time ' .
' WHERE accountid=:account_id AND equip_id=:equip_id;',
array(
':account_id' => $account_id,
':equip_id' => $row['equip_id'],
':modify_time' => time()
));
if (!$ret) {
die();
return;
}
$equip_level = $row['equip_level'];
$active_time = 0;
} else {
if ($row['active_time'] != 0) {
$active_time = $row['active_time'];
$equip_level = $row['equip_experience_level'];
} else {
$active_time = 0;
$equip_level = $row['equip_level'];
}
}
array_push($equip_list, array(
'equip_id' => $row['equip_id'],
'equip_level' => $equip_level,
'active_time' => $active_time
));
}
}
echo json_encode(array(
'errcode' => 0,
'errmsg' => '',
'equip_list' => $equip_list
));
}
public function updateEquip()
{
$account_id = $_REQUEST['account_id'];
//登录校验
$login = loginVerify($account_id, $_REQUEST['session_id']);
if (!$login) {
phpcommon\sendError(ERR_USER_BASE + 1, 'session无效');
return;
}
$conn = $this->getMysql($account_id);
$skin_list = array();
if (!$conn) {
phpcommon\sendError(ERR_USER_BASE + 1, '没有这个玩家');
return;
}
$equip_id = $_REQUEST['equip_id'];
$free = $_REQUEST['free'];
$equip_level = 0;
$row = $conn->execQueryOne('SELECT * FROM equip WHERE accountid=:account_id AND equip_id=:equip_id;',
array(
':account_id' => $account_id,
':equip_id' => $equip_id
));
if (!$row) {
$e = $this->subCoin($account_id, $equip_id, 1, $free);
$ret = $conn->execScript('INSERT INTO equip(accountid, equip_id, equip_level, equip_experience_level, active_time, create_time, modify_time) ' .
' VALUES(:accountid, :equip_id, :equip_level, :equip_experience_level, :active_time, :create_time, :modify_time) ' .
' ON DUPLICATE KEY UPDATE accountid=:accountid, equip_id=:equip_id, equip_level=:equip_level, equip_experience_level=:equip_experience_level, active_time=:active_time, modify_time=:modify_time;',
array(
':accountid' => $account_id,
':equip_id' => $equip_id,
':equip_level' => 2,
':equip_experience_level' => 0,
':active_time' => 0,
':create_time' => time(),
':modify_time' => time()
));
if (!$ret) {
die();
return;
}
$equip_level = 2;
} else {
$e = $this->subCoin($account_id, $equip_id, $row['equip_level'], $free);
$ret = $conn->execScript('UPDATE equip SET equip_level=:equip_level, modify_time=:modify_time ' .
' WHERE accountid=:account_id AND equip_id=:equip_id;',
array(
':account_id' => $account_id,
':equip_id' => $equip_id,
':equip_level' => $row['equip_level'] + 1,
':modify_time' => time()
));
if (!$ret) {
die();
return;
}
$equip_level = $row['equip_level'] + 1;
}
$quest = new classes\Quest();
$quest->triggerQuest(QUEST_DAY_UPDATEEQUIP, 1, 1, $account_id);
if ($row['equip_level'] + 1 >= $e['max_lv']) {
$quest->triggerQuest(QUEST_SUM_EQUIPMAX, 2, 1, $account_id);
}
echo json_encode(array(
'errcode' => 0,
'errmsg' => '',
));
}
public function freeTryEquip()
{
$account_id = $_REQUEST['account_id'];
//登录校验
$login = loginVerify($account_id, $_REQUEST['session_id']);
if (!$login) {
phpcommon\sendError(ERR_USER_BASE + 1, 'session无效');
return;
}
$conn = $this->getMysql($account_id);
$equip_id = $_REQUEST['equip_id'];
$equip_level = $_REQUEST['equip_level'];
if (!$conn) {
phpcommon\sendError(ERR_USER_BASE + 1, '没有这个角色');
return;
}
$e = $this->getEquip($equip_id);
if (!$e) {
phpcommon\sendError(ERR_USER_BASE + 2, '没有这个装备');
return;
}
$p = $this->getParameter(WEAPON_TRIAL);
$time = $p['param_value'];
$row = $conn->execQueryOne('SELECT * FROM equip WHERE accountid=:account_id AND equip_id=:equip_id;',
array(
':account_id' => $account_id,
':equip_id' => $equip_id
));
if (!$row) {
$ret = $conn->execScript('INSERT INTO equip(accountid, equip_id, equip_level, equip_experience_level, active_time, create_time, modify_time) ' .
' VALUES(:accountid, :equip_id, 1, :equip_experience_level, :active_time, :create_time, :modify_time) ' .
' ON DUPLICATE KEY UPDATE accountid=:accountid, equip_id=:equip_id, equip_level=1, equip_experience_level=9, active_time=:active_time, modify_time=:modify_time;',
array(
':accountid' => $account_id,
':equip_id' => $equip_id,
':active_time' => time() + $time,
':create_time' => time(),
':modify_time' => time(),
':equip_experience_level' => $e['max_lv']
));
if (!$ret) {
die();
return;
}
} else {
$ret = $conn->execScript('UPDATE equip SET active_time=:active_time, equip_experience_level=:equip_experience_level, modify_time=:modify_time ' .
' WHERE accountid=:account_id AND equip_id=:equip_id;',
array(
':account_id' => $account_id,
':equip_id' => $equip_id,
':active_time' => time() + $time,
':modify_time' => time(),
':equip_experience_level' => $e['max_lv']
));
if (!$ret) {
die();
return;
}
}
echo json_encode(array(
'errcode' => 0,
'errmsg' => '',
));
}
}
?>

36
webapp/controller/PassController.class.php
View File

@ -250,16 +250,18 @@ class PassController{
'time' => $drop_multiply[2],
));
$addreward = new classes\AddReward();
foreach ($reward as $r) {
$addreward->addReward($r['item_id'], $r['item_num'], $account_id, $r['time']);
}
$all_item_list = $addreward->addReward($r['item_id'], $r['item_num'], $account_id, $r['time']);
$coin_num = $addreward->getCoinNum($account_id);
$diamond_num = $addreward->getDiamondNum($account_id);
echo json_encode(array(
'errcode' => 0,
'errmsg'=> '',
'status' => 1,
'item_list' => $reward,
'coin_nums' => $coin_num,
'diamond_nums' => $diamond_num
'diamond_nums' => $diamond_num,
'all_item_list' => $all_item_list
));
}
@ -318,19 +320,28 @@ class PassController{
if ($row['integral'] >= $seaPoint['min'] && $row['integral'] <= $seaPoint['max']
|| $row['integral'] >= $seaPoint['min'] && $seaPoint['max'] == -1)
{
$delim = ':';
$drop_multiply = explode($delim, $seaPoint['reward']);
array_push($reward, array(
'item_id' => $drop_multiply[0],
'item_num' => $drop_multiply[1],
'time' => $drop_multiply[2]
));
$drop_multiply = $this->getExplode($seaPoint['reward']);
for($i = 0; $i < count($drop_multiply); $i++) {
array_push($reward, array(
'item_id' => $drop_multiply[$i][0],
'item_num' => $drop_multiply[$i][1],
'time' => $drop_multiply[$i][2]
));
}
$level = $ii;
}
}
$addreward = new classes\AddReward();
foreach ($reward as $r) {
$addreward->addReward($r['item_id'], $r['item_num'], $account_id, $r['time']);
$items = $addreward->addReward($item['item_id'], $item['item_num'], $account_id, $item['time']);
foreach($items as $i) {
array_push($all_item_list, array(
'item_id' => $i['item_id'],
'item_num' => $i['item_num'],
'time' => $i['time'],
));
}
}
$ret = $conn->execScript('UPDATE user SET pass_status=1, modify_time=:modify_time ' .
' WHERE accountid=:accountid;',
@ -348,7 +359,8 @@ class PassController{
'errmsg'=> '',
'item_list' => $reward,
'level' => $level,
'diamond_nums' => $diamond_num
'diamond_nums' => $diamond_num,
'all_item_list' => $all_item_list
));
}

1
webapp/controller/QuestController.class.php
View File

@ -247,6 +247,7 @@ class QuestController{
array_push($item_list, array(
'item_id' => $reward_id,
'item_num' => $reward_num,
'time' => 0
));
}

25
webapp/controller/RoleController.class.php
View File

@ -261,6 +261,7 @@ class RoleController{
public function battleReport()
{
error_log(111111111122222222222222221);
$account_id = $_REQUEST['account_id']; //账号
$conn = $this->getMysql($account_id);
if (!$conn) {
@ -403,30 +404,6 @@ class RoleController{
return;
}
//插入历史记录
$ret = $conn->execScript('INSERT INTO history_record(accountid, room_uuid, map_id, map_tpl_name, map_name, game_time, rank, kills, harms, hurts, alive_time, coin, status, create_time, modify_time) ' .
' VALUES(:accountid, :room_uuid, :map_id, :map_tpl_name, :map_name, :game_time, :rank, :kills, :harms, :hurts, :alive_time, :coin, 0, :create_time, :modify_time) ' .
' ON DUPLICATE KEY UPDATE accountid=:accountid, room_uuid=:room_uuid, map_id=:map_id, map_tpl_name=:map_tpl_name, map_name=:map_name, game_time=:game_time, rank=:rank, kills=:kills, harms=:harms, hurts=:hurts, alive_time=:alive_time, coin=:coin, status=0, modify_time=:modify_time;',
array(
':accountid' => $account_id,
':room_uuid' => $room_uuid,
':map_id' => $map_id,
':map_tpl_name' => $map_tpl_name,
':map_name' => $map_name,
':game_time' => $game_time,
':rank' => $rank,
':kills' => $kills,
':harms' => $harm,
':hurts' => $hurt,
':alive_time' => $alive_time,
':coin' => $coin_num,
':create_time' => time(),
':modify_time' => time()
));
if (!$ret) {
die();
return;
}
//刷新任务
$quest = new classes\Quest();
$quest->triggerQuest(QUEST_DAY_FIGHT, 1, 1, $account_id);

32
webapp/controller/ShareController.class.php
View File

@ -187,7 +187,7 @@ class ShareController{
if ($free != 0) {
$p = $this->getParameter(DIAMONDBOX10);
$diamond_num = $p['param_value'];
$item_list = $this->randBoxReward(2, 0);
$item_list = $this->randBoxReward(2, 10);
} else {
$diamond_num = 0;
$item_list = $this->randBoxReward(1, 1);
@ -244,17 +244,26 @@ class ShareController{
$r -> set($boxreward_uuid, json_encode($boxreward_db));
$r -> pexpire($boxreward_uuid, 1000 * 7200);
}
$all_item_list = array();
$quest = new classes\Quest();
$quest->triggerQuest(71004, 1, 1, $account_id);
foreach ($item_list as $item) {
$addreward = new classes\AddReward();
$addreward->addReward($item['item_id'], $item['item_num'], $account_id, $item['time']);
$items = $addreward->addReward($item['item_id'], $item['item_num'], $account_id, $item['time']);
foreach($items as $i) {
array_push($all_item_list, array(
'item_id' => $i['item_id'],
'item_num' => $i['item_num'],
'time' => $i['time'],
));
}
}
echo json_encode(array(
'errcode' => 0,
'errmsg' => '',
'item_list' => $item_list,
'diamond_nums' => $num,
'all_item_list' => $all_item_list
));
}
@ -362,6 +371,7 @@ class ShareController{
'status' => $row['status'],
'item_id' => $array[0][0],
'num' => $array[0][1],
'time' => $array[0][2],
'people_num' => $sh['people'],
));
}
@ -434,12 +444,14 @@ class ShareController{
array_push($item_list, array(
'item_id' => $array[0][0],
'item_num' => $array[0][1],
'time' => $array[0][2],
));
$addreward->addReward($array[0][0], $array[0][1], $account_id);
$all_item_list = $addreward->addReward($array[0][0], $array[0][1], $account_id, $array[0][2]);
} else if ($ach_id == 6) {
array_push($item_list, array(
'item_id' => 10003,
'item_num' => 50,
'time' => 0,
));
$addreward->addReward(10003, 50, $account_id);
}
@ -458,7 +470,8 @@ class ShareController{
echo json_encode(array(
'errcode' => 0,
'errmsg' => '',
'item_list' => $item_list
'item_list' => $item_list,
'all_item_list' => $all_item_list
));
}
@ -508,15 +521,17 @@ class ShareController{
$addreward = new classes\AddReward();
if ($ach_id != 6) {
$array = $this->getExplode($sh['rewards']);
$addreward->addReward($array[0][0], $array[0][1] * $times, $account_id);
$addreward->addReward($array[0][0], $array[0][1] * $times, $account_id, $array[0][2]);
} else if ($ach_id == 6) {
$addreward->addReward(10003, 50 * $times, $account_id);
$addreward->addReward(10003, 50 * $times, $account_id, 0);
}
$coin_num = $addreward->getCoinNum($account_id);
$diamond_num = $addreward->getDiamondNum($account_id);
echo json_encode(array(
'errcode' => 0,
'errmsg' => '',
'coin_nums' => $coin_num,
'diamond_nums' => $diamond_num
));
}
@ -577,10 +592,11 @@ class ShareController{
$item_num = $kefu['itemnum'];
}
$addreward = new classes\AddReward();
$addreward->addReward($item_id, $item_num, $account_id);
$addreward->addReward($item_id, $item_num, $account_id,0);
array_push($item_list, array(
'item_id' => $item_id,
'item_num' => $item_num,
'time' => 0
));
//保存客服奖励
@ -664,7 +680,7 @@ class ShareController{
foreach ($user_db['kefureward_list'] as $kefureward) {
//增加奖励
$addreward = new classes\AddReward();
$addreward->addReward($kefureward['item_id'], $kefureward['item_num'] * $times, $account_id);
$addreward->addReward($kefureward['item_id'], $kefureward['item_num'] * $times, $account_id, 0);
}
$r->del($kefureward_uuid, json_encode($user_db));
$addreward = new classes\AddReward();

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

@ -201,6 +201,7 @@ class ShopController{
$price = $shop['price'];
$status = $shop['status'];
$tip = $shop['tip'];
$time = $shop['time'];
$flag = 1;
break;
}
@ -225,20 +226,22 @@ class ShopController{
$r -> pexpire($shop_uuid, 1000 * 3600 * 24);
//增加奖励
$addreward = new classes\AddReward();
$addreward->addReward($item_id, $item_num, $account_id);
$all_item_list = $addreward->addReward($item_id, $item_num, $account_id, $time);
$coin_num = $addreward->getCoinNum($account_id);
$diamond_num = $addreward->getDiamondNum($account_id);
$item_list = array();
array_push($item_list,array(
'item_id' => $item_id,
'item_num' => $item_num,
'time' => $time,
));
echo json_encode(array(
'errcode' => 0,
'errmsg'=> '',
'coin_nums' => $coin_num,
'diamond_nums' => $diamond_num,
'item_list' => $item_list
'item_list' => $item_list,
'all_item_list' => $all_item_list
));
}

11
webapp/controller/SignController.class.php
View File

@ -286,6 +286,14 @@ class SignController{
'time' => $time,
));
$addreward->addReward($item_id, $num, $account_id, $time);
$items = $addreward->addReward($item['item_id'], $item['item_num'], $account_id, $item['time']);
foreach($items as $i) {
array_push($all_item_list, array(
'item_id' => $i['item_id'],
'item_num' => $i['item_num'],
'time' => $i['time'],
));
}
}
//$addreward = new classes\AddReward();
//$addreward->addReward($item_id, $num, $account_id);
@ -296,7 +304,8 @@ class SignController{
'errmsg' => '',
'item_list' => $item_list,
'coin_nums' => $coin_num,
'diamond_nums' => $diamond_num
'diamond_nums' => $diamond_num,
'all_item_list' => $all_item_list
));
}

494
webapp/controller/SkinController.class.php
View File

@ -1,494 +0,0 @@
<?php
class SkinController{
protected function getMysql($account_id)
{
$mysql_conf = getMysqlConfig(crc32($account_id));
$conn = new phpcommon\Mysql(array(
'host' => $mysql_conf['host'],
'port' => $mysql_conf['port'],
'user' => $mysql_conf['user'],
'passwd' => $mysql_conf['passwd'],
'dbname' => 'gamedb2004_' . $mysql_conf['instance_id']
));
return $conn;
}
protected function getSkin($skin_id)
{
$g_conf_skin_cluster = require('../res/dress@dress.php');
$skin_conf = getSkinConfig($g_conf_skin_cluster, $skin_id);
$s = array(
'skin_id' => $skin_conf['id'],
'skin_name' => $skin_conf['name'],
'skin_skillid' => $skin_conf['skill_id'],
'skin_compose' => $skin_conf['compose'],
'skin_experience' => $skin_conf['is_experience'],
'skin_type' => $skin_conf['type'],
'duration' => $skin_conf['duration'],
'debris_id' => $skin_conf['debris'],
'cost' => $skin_conf['cost'],
'cost_int' => $skin_conf['cost_int'],
'max_lv' => $skin_conf['max_lv'],
);
return $s;
}
protected function getExplode($string)
{
$delim = "|";
$drop_multiply = explode($delim, $string);
$delim1 = ":";
$arr = array();
for ($i = 0; $i < count($drop_multiply); $i++) {
$mul = explode($delim1, $drop_multiply[$i]);
array_push($arr, $mul);
}
return $arr;
}
protected function getParameter($para_id)
{
$g_conf_para_cluster = require('../res/parameter@parameter.php');
$para_conf = getParameterConfig($g_conf_para_cluster, $para_id);
$p = array(
'id' => $para_conf['id'],
'param_name' => $para_conf['param_name'],
'param_value' => $para_conf['param_value'],
);
return $p;
}
protected function updateActiveTime($row, $conn)
{
$skin_status = 0;
if ($row['skin_type'] == 1) {
$skin_status = 2;
} else if ($row['skin_type'] == 2) {
$skin_status = 3;
}
$ret = $conn->execScript('UPDATE skin SET active_time=0, skin_experience_level=0, skin_experience_type=0, modify_time=:modify_time ' .
' WHERE accountid=:account_id AND skin_id=:skin_id;',
array(
':account_id' => $row['accountid'],
':skin_id' => $row['skin_id'],
':modify_time' => time()
));
if(!$ret){
die();
return;
}
if ($row['skin_status'] == 0 && $row['skin_experience_type'] == 1) {
$ret = $conn->execScript('UPDATE skin SET skin_status=:skin_status, modify_time=:modify_time ' .
' WHERE accountid=:account_id AND skin_id=:skin_id;',
array(
':account_id' => $row['accountid'],
':skin_id' => $row['skin_id'],
':skin_status' => $skin_status,
':modify_time' => time()
));
if(!$ret){
die();
return;
}
$ret = $conn->execScript('UPDATE skin SET skin_status=0, modify_time=:modify_time ' .
' WHERE accountid = :account_id AND skin_id = 14001;',
array(
':account_id' => $row['accountid'],
':modify_time' => time()
));
if(!$ret){
die();
return;
}
}
}
public function skinInfo()
{
$account_id = $_REQUEST['account_id'];
//登录校验
$login = loginVerify($account_id, $_REQUEST['session_id']);
if (!$login) {
phpcommon\sendError(ERR_USER_BASE + 1, 'session无效');
return;
}
$conn = $this->getMysql($account_id);
$skin_list = array();
if(!$conn){
phpcommon\sendError(ERR_USER_BASE + 1,'没有这个玩家');
return;
}
$g_conf_skin_cluster = require('../res/dress@dress.php');
$s = $this->getSkin(14001);
if(!$s){
phpcommon\sendError(ERR_USER_BASE + 1,'没有这个皮肤');
return;
}
$rowCount = $conn->execQueryRowCount('SELECT * FROM skin WHERE accountid = :account_id;',
array(
':account_id' => $account_id
));
if ($rowCount == 0) {
for ($i = 14001; $i <= count($g_conf_skin_cluster) + 14000; $i++) {
$s = $this->getSkin($i);
if(!$s){
phpcommon\sendError(ERR_USER_BASE + 1,'没有这个皮肤');
return;
}
if ($i == 14001) {
$skin_status = 0;
} else if ($s['skin_type'] == 2){
$skin_status = 3;
} else {
$skin_status = 2;
}
$ret = $conn->execScript('INSERT INTO skin(accountid, skin_id, skin_status, fragment_id, fragment_num, active_time, fragment_status, skin_type, skin_level, skin_experience_level, skin_experience_type, 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;',
array(
':account_id' => $account_id,
':skin_id' => $i,
':skin_status' => $skin_status,
':fragment_id' => $s['debris_id'],
':skin_type' => $s['skin_type'],
':create_time' => time(),
':modify_time' => time()
));
if(!$ret){
die();
return;
}
}
}
$time = 0;
$skin_level = 0;
$skin_experience_type = 0;
$skin_status = 0;
$rows = $conn->execQuery('SELECT * FROM skin WHERE accountid = :account_id;',
array(
':account_id' => $account_id,
));
foreach ($rows as $row) {
$s = $this->getSkin($row['skin_id']);
if(time() >= $row['active_time'] && $row['active_time'] != 0){
$this->updateActiveTime($row, $conn);
}
}
$rowsSkin = $conn->execQuery('SELECT * FROM skin WHERE accountid = :account_id;',
array(
':account_id' => $account_id,
));
$skin_id = 0;
foreach ($rowsSkin as $rowSkin) {
$s = $this->getSkin($rowSkin['skin_id']);
if ($skin_id == $rowSkin['skin_id']) {
continue;
}
$skin_id = $rowSkin['skin_id'];
if ($rowSkin['active_time'] != 0) {
$skin_level = $s['max_lv'];
$skin_experience_type = 2;
} else {
$skin_level = $rowSkin['skin_level'];
$skin_experience_type = 0;
}
array_push($skin_list, array(
'skin_id' => $rowSkin['skin_id'],
'skin_status' => $rowSkin['skin_status'],
'fragment_num' => $rowSkin['fragment_num'],
'active_time' => $rowSkin['active_time'],
'skin_level' => $skin_level,
'skin_experience_type' => $skin_experience_type
));
}
echo json_encode(array(
'errcode' => 0,
'errmsg' => '',
'skin_list' => $skin_list
));
}
public function unlockSkin()
{
$account_id = $_REQUEST['account_id'];
//登录校验
$login = loginVerify($account_id, $_REQUEST['session_id']);
if (!$login) {
phpcommon\sendError(ERR_USER_BASE + 1, 'session无效');
return;
}
$conn = $this->getMysql($account_id);
$skin_id = $_REQUEST['skin_id'];
if(!$conn){
phpcommon\sendError(ERR_USER_BASE + 1,'没有这个玩家');
return;
}
$s = $this->getSkin($skin_id);
if(!$s){
phpcommon\sendError(ERR_USER_BASE + 1,'没有这个皮肤1');
return;
}
$row = $conn->execQueryOne('SELECT * FROM skin WHERE accountid = :account_id AND skin_id = :skin_id;',
array(
':account_id' => $account_id,
':skin_id' => $skin_id
));
if(!$row){
phpcommon\sendError(ERR_USER_BASE + 1,'没有这个皮肤');
return;
}
if ($row['skin_type'] != 1) {
phpcommon\sendError(ERR_USER_BASE + 2,'皮肤无法解锁');
return;
}
$fragment_num = 0;
$array = $this->getExplode($s['skin_compose']);
if ($row['fragment_num'] < $array[0][1]) {
phpcommon\sendError(ERR_USER_BASE + 2,'皮肤碎片数量不足');
return;
}
$fragment_num = $row['fragment_num'] - $array[0][1];
$skin_status = 1;
$active_time = 0;
$skin_experience_type = 0;
if ($row['skin_status'] == 0) {
$skin_status = 0;
}
if ($row['active_time'] != 0) {
$active_time = $row['active_time'];
$skin_experience_type = 2;
}
$ret = $conn->execScript('UPDATE skin SET fragment_num=:fragment_num ,skin_status=:skin_status, active_time=:active_time, skin_experience_type=:skin_experience_type, modify_time=:modify_time ' .
' WHERE accountid = :account_id AND skin_id = :skin_id;',
array(
':account_id' => $account_id,
':skin_id' => $skin_id,
':fragment_num' => $fragment_num,
':skin_status' => $skin_status,
':active_time' => $active_time,
':skin_experience_type' => $skin_experience_type,
':modify_time' => time()
));
if (!$ret) {
die();
return;
}
echo json_encode(array(
'errcode' => 0,
'errmsg' => '',
));
}
public function exchangeSkin()
{
$account_id = $_REQUEST['account_id'];
//登录校验
$login = loginVerify($account_id, $_REQUEST['session_id']);
if (!$login) {
phpcommon\sendError(ERR_USER_BASE + 1, 'session无效');
return;
}
$usingskin_id = $_REQUEST['usingskin_id'];
$exchangeskin_id = $_REQUEST['exchangeskin_id'];
$conn = $this->getMysql($account_id);
if(!$conn){
phpcommon\sendError(ERR_USER_BASE + 1, '没有这个玩家');
return;
}
$skin_status = 0;
$row = $conn->execQueryOne('SELECT * FROM skin WHERE accountid=:accountid AND skin_id=:skin_id;',
array(
':accountid' => $account_id,
':skin_id' => $usingskin_id,
));
if (!$row) {
phpcommon\sendError(ERR_USER_BASE + 2, '没有这个皮肤');
return;
}
if ($row['skin_experience_type'] == 0 || $row['skin_experience_type'] == 2) {
$skin_status = 1;
} else if ($row['skin_experience_type'] == 1) {
if ($row['skin_type'] == 1) {
$skin_status = 2;
} else if ($row['skin_type'] == 2) {
$skin_status = 3;
}
}
$using_ret = $conn->execScript('UPDATE skin SET skin_status=:skin_status, modify_time=:modify_time ' .
' WHERE accountid = :account_id AND skin_id = :skin_id;',
array(
':account_id' => $account_id,
':skin_id' => $usingskin_id,
':skin_status' => $skin_status,
':modify_time' => time()
));
if(!$using_ret){
die();
return;
}
$exchange_ret = $conn->execScript('UPDATE skin SET skin_status=0, modify_time=:modify_time ' .
' WHERE accountid = :account_id AND skin_id = :skin_id;',
array(
':account_id' => $account_id,
':skin_id' => $exchangeskin_id,
':modify_time' => time()
));
if(!$exchange_ret){
die();
return;
}
echo json_encode(array(
'errcode' => 0,
'errmsg' => '',
));
}
public function freetryskin()
{
$account_id = $_REQUEST['account_id'];
//登录校验
$login = loginVerify($account_id, $_REQUEST['session_id']);
if (!$login) {
phpcommon\sendError(ERR_USER_BASE + 1, 'session无效');
return;
}
$conn = $this->getMysql($account_id);
$skin_id = $_REQUEST['skin_id'];
if(!$conn){
phpcommon\sendError(ERR_USER_BASE + 1,'没有这个角色');
return;
}
$s = $this->getSkin($skin_id);
if(!$s){
phpcommon\sendError(ERR_USER_BASE + 2,'没有这个皮肤');
return;
}
$rowSkin = $conn->execQueryOne('SELECT * FROM skin WHERE accountid=:accountid AND skin_id=:skin_id;',
array(
':accountid' => $account_id,
':skin_id' => $skin_id,
));
if (!$rowSkin) {
$ret = $conn->execScript('INSERT INTO skin(accountid, skin_id, skin_status, fragment_id, fragment_num, active_time, fragment_status, skin_type, skin_level, skin_experience_level, skin_experience_type, 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;',
array(
':account_id' => $account_id,
':skin_id' => $skin_id,
':skin_status' => 2,
':fragment_id' => $skin_id - 1000,
':skin_type' => 1,
':create_time' => time(),
':modify_time' => time()
));
if(!$ret){
die();
return;
}
}
$row = $conn->execQueryOne('SELECT * FROM skin WHERE accountid=:accountid AND skin_id=:skin_id;',
array(
':accountid' => $account_id,
':skin_id' => $skin_id,
));
$time = 0;
$ex_level = 0;
$ex_type = 0;
if ($s['skin_type'] == 2) {
$time = $s['duration'];
}
$ex_level = $s['max_lv'];
$p = $this->getParameter(SKIN_SKILL_TIME);
$time = $p['param_value'];
if ($row['skin_status'] <= 1) {
$ex_type = 2;
} else {
$ex_type = 1;
}
$ret = $conn->execScript('UPDATE skin SET active_time=:active_time, skin_experience_level=:skin_experience_level, skin_experience_type=:skin_experience_type, modify_time=:modify_time ' .
' WHERE accountid = :account_id AND skin_id = :skin_id;',
array(
':account_id' => $account_id,
':skin_id' => $skin_id,
':active_time' => time() + $time,
':skin_experience_level' => $ex_level,
':skin_experience_type' => $ex_type,
':modify_time' => time()
));
if(!$ret){
die();
return;
}
echo json_encode(array(
'errcode' => 0,
'errmsg' => '',
));
}
public function updateSkin()
{
$account_id = $_REQUEST['account_id'];
//登录校验
$login = loginVerify($account_id, $_REQUEST['session_id']);
if (!$login) {
phpcommon\sendError(ERR_USER_BASE + 1, 'session无效');
return;
}
$conn = $this->getMysql($account_id);
if (!$conn) {
phpcommon\sendError(ERR_USER_BASE + 1, '没有这个角色');
return;
}
$skin_id = $_REQUEST['skin_id'];
$free = $_REQUEST['free'];
$row = $conn->execQueryOne('SELECT * FROM skin WHERE accountid=:account_id AND skin_id=:skin_id;',
array(
':account_id' => $account_id,
':skin_id' => $skin_id
));
if (!$row) {
phpcommon\sendError(ERR_USER_BASE + 1, '皮肤不存在');
return;
}
$s = $this->getSkin($skin_id);
if (!$s) {
phpcommon\sendError(ERR_USER_BASE + 2, '没有这个皮肤');
return;
}
if ($row['skin_level'] >= $s['max_lv']) {
phpcommon\sendError(ERR_USER_BASE + 3, '皮肤已到满级');
return;
}
$debris_num = $s['cost'] * ceil($row['skin_level'] / 5) + $s['cost_int'];
if ($free == 1) {
$debris_num = 0;
}
if ($debris_num > $row['fragment_num']) {
phpcommon\sendError(ERR_USER_BASE + 4, '皮肤碎片数量不足');
return;
}
$ret = $conn->execScript('UPDATE skin SET skin_level=:skin_level, fragment_num=:fragment_num, modify_time=:modify_time ' .
' WHERE accountid=:account_id AND skin_id=:skin_id;',
array(
':account_id' => $account_id,
':skin_id' => $skin_id,
':skin_level' => $row['skin_level'] + 1,
':fragment_num' => $row['fragment_num'] - $debris_num,
':modify_time' => time()
));
if (!$ret) {
die();
return;
}
echo json_encode(array(
'errcode' => 0,
'errmsg' => '',
));
}
}
?>

403
webapp/controller/SupplyBoxController.class.php
View File

@ -1,403 +0,0 @@
<?php
require 'classes/Quest.php';
require 'classes/AddReward.php';
class SupplyBoxController{
protected function getMysql($account_id)
{
$mysql_conf = getMysqlConfig(crc32($account_id));
$conn = new phpcommon\Mysql(array(
'host' => $mysql_conf['host'],
'port' => $mysql_conf['port'],
'user' => $mysql_conf['user'],
'passwd' => $mysql_conf['passwd'],
'dbname' => 'gamedb2004_' . $mysql_conf['instance_id']
));
return $conn;
}
protected function getSupplyBox($box_id)
{
$g_conf_supply_cluster = require('../res/supply@supply.php');
$supply_conf = getSupplyConfig($g_conf_supply_cluster, $box_id);
$s = array(
'id' => $supply_conf['id'],
'drop' => $supply_conf['drop'],
'num' => $supply_conf['num'],
'drop_free' => $supply_conf['drop_free'],
'num_free' => $supply_conf['num_free'],
'price' => $supply_conf['price'],
'parameter' => $supply_conf['parameter'],
);
return $s;
}
protected function getDrop($drop_id)
{
$g_conf_drop_cluster = require('../res/drop@drop.php');
$drop_conf = getDropConfig($g_conf_drop_cluster, $drop_id);
$d = array(
'drop_id' => $drop_conf['drop_id'],
'item_id' => $drop_conf['item_id'],
'num' => $drop_conf['num'],
'weight' => $drop_conf['weight'],
'type' => $drop_conf['type']
);
return $d;
}
protected function getExplode($string)
{
$delim = "|";
$drop_multiply = explode($delim, $string);
$delim1 = ":";
$arr = array();
for ($i = 0; $i < count($drop_multiply); $i++) {
$mul = explode($delim1, $drop_multiply[$i]);
array_push($arr, $mul);
}
return $arr;
}
protected function getParameter($para_id)
{
$g_conf_para_cluster = require('../res/parameter@parameter.php');
$para_conf = getParameterConfig($g_conf_para_cluster, $para_id);
$p = array(
'id' => $para_conf['id'],
'param_name' => $para_conf['param_name'],
'param_value' => $para_conf['param_value'],
);
return $p;
}
public function supplyBoxInfo()
{
$account_id = $_REQUEST['account_id'];
//登录校验
$login = loginVerify($account_id, $_REQUEST['session_id']);
if (!$login) {
phpcommon\sendError(ERR_USER_BASE + 1, 'session无效');
return;
}
$conn = $this->getMysql($account_id);
$box_list = array();
if (!$conn) {
phpcommon\sendError(ERR_USER_BASE + 1, '没有这个玩家');
return;
}
$rowCount = $conn->execQueryRowCount('SELECT * FROM supplybox WHERE accountid=:account_id;',
array(
':account_id' => $account_id
));
if ($rowCount != 0) {
$rows = $conn->execQuery('SELECT * FROM supplybox WHERE accountid = :account_id;',
array(
':account_id' => $account_id
));
foreach ($rows as $row) {
if (phpcommon\getdayseconds(time()) - phpcommon\getdayseconds($row['last_buy_time']) > 0) {
$ret = $conn->execScript('UPDATE supplybox SET free_times=0, buy_times=0, last_buy_time=:time, modify_time=:modify_time ' .
' WHERE accountid=:accountid AND box_id=:box_id;',
array(
':accountid' => $account_id,
':box_id' => $row['box_id'],
':time' => time(),
':modify_time' => time()
));
if (!$ret) {
die();
return;
}
}
array_push($box_list, array(
'box_id' => $row['box_id'],
'buy_times' => $row['buy_times'],
'free_times' => $row['free_times']
));
}
}
echo json_encode(array(
'errcode' => 0,
'errmsg' => '',
'supplybox_list' => $box_list
));
}
public function openSupplyBox()
{
$account_id = $_REQUEST['account_id'];
//登录校验
$login = loginVerify($account_id, $_REQUEST['session_id']);
if (!$login) {
phpcommon\sendError(ERR_USER_BASE + 1, 'session无效');
return;
}
$conn = $this->getMysql($account_id);
if (!$conn) {
phpcommon\sendError(ERR_USER_BASE + 1, '没有这个玩家');
return;
}
$box_id = $_REQUEST['box_id'];
$free_open = $_REQUEST['free_open'];
$free_times = 0;
$buy_times = 0;
$s = $this->getSupplyBox($box_id);
if (!$s) {
phpcommon\sendError(ERR_USER_BASE + 2, '没有这个宝箱');
return;
}
$drop_id = 0;
if ($free_open == 0) {
$drop_id = $s['drop'];
} else {
$drop_id = $s['drop_free'];
}
$d = $this->getDrop($drop_id);
if (!$d) {
phpcommon\sendError(ERR_USER_BASE + 3, '没有这个奖励');
return;
}
$item_list = array();
$row = $conn->execQueryOne('SELECT * FROM supplybox WHERE accountid=:accountid AND box_id=:box_id;',
array(
':accountid' => $account_id,
':box_id' => $box_id
));
if (!$row) {
if ($free_open == 0) {
phpcommon\sendError(ERR_USER_BASE + 2, '没有这个宝箱');
return;
} else if ($free_open == 1) {
$free_times = 1;
$buy_times = 0;
$ret = $conn->execScript('INSERT INTO supplybox(accountid, box_id, buy_times, free_times, last_buy_time, create_time, modify_time) ' .
' VALUES(:accountid, :box_id, 0, 1, :last_buy_time, :create_time, :modify_time) ' .
' ON DUPLICATE KEY UPDATE accountid=:accountid, box_id=:box_id, buy_times=0, free_times=1, last_buy_time=:last_buy_time, modify_time=:modify_time;',
array(
':accountid' => $account_id,
':box_id' => $box_id,
':last_buy_time' => time(),
':create_time' => time(),
':modify_time' => time()
));
if (!$ret) {
die();
return;
}
}
}
if ($free_open == 1) {
$p_times = $this->getParameter(FREE_DRESS_MAX_TIME);
if ($row['free_times'] >= $p_times['param_value']) {
phpcommon\sendError(ERR_USER_BASE + 3, '免费次数不足');
return;
}
$free_times = $row['free_times'] + 1;
$buy_times = $row['buy_times'];
$ret = $conn->execScript('UPDATE supplybox SET free_times=:free_times, last_buy_time=:last_buy_time, modify_time=:modify_time ' .
' WHERE accountid=:accountid AND box_id=:box_id;',
array(
':accountid' => $account_id,
':box_id' => $box_id,
':free_times' => $free_times,
':last_buy_time' => time(),
':modify_time' => time()
));
if (!$ret) {
die();
return;
}
}
//确定奖励倍数
$sum = 0;
$mul = 0;
$array = $this->getExplode($s['num']);
for ($i = 0; $i < count($array); $i++) {
$sum += $array[$i][1];
}
$rand = Rand(0, $sum);
$multiply = 0;
for ($i = 0; $i < count($array); $i++) {
$multiply += $array[$i][1];
if ($multiply > $rand) {
$mul = $array[$i][0];
break;
}
}
//发送奖励
$weight_sum = 0;
$weight_array = $this->getExplode($d['weight']);
for ($i = 0; $i < count($weight_array); $i++) {
$weight_sum += $weight_array[$i][0];
}
$random = Rand(0, $weight_sum);
$weight = 0;
for ($i = 0; $i < count($weight_array); $i++) {
$weight += $weight_array[$i][0];
if ($weight > $random) {
$key = $i;
break;
}
}
$item_id_array = $this->getExplode($d['item_id']);
$num_array = $this->getExplode($d['num']);
$item_id = $item_id_array[$key][0];
$item_num = $num_array[$key][0] * $mul;
array_push($item_list, array(
'item_id' => $item_id,
'item_num' => $item_num,
));
$addreward = new classes\AddReward();
$addreward->addReward($item_id, $item_num, $account_id);
$quest = new classes\Quest();
$quest->triggerQuest(71004, 1, 1, $account_id);
$quest->triggerQuest(72004, 2, 1, $account_id);
echo json_encode(array(
'errcode' => 0,
'errmsg' => '',
'item_list' => $item_list,
/*'box_id' => $box_id,
'buy_times' => $buy_times,
'free_times' => $free_times*/
));
}
public function buySupplyBox()
{
$account_id = $_REQUEST['account_id'];
//登录校验
$login = loginVerify($account_id, $_REQUEST['session_id']);
if (!$login) {
phpcommon\sendError(ERR_USER_BASE + 1, 'session无效');
return;
}
$conn = $this->getMysql($account_id);
if (!$conn) {
phpcommon\sendError(ERR_USER_BASE + 1, '没有这个玩家');
return;
}
$box_id = $_REQUEST['box_id'];
$coin_num = 0;
$buy_times = 0;
$free_times = 0;
$s = $this->getSupplyBox($box_id);
if (!$s) {
phpcommon\sendError(ERR_USER_BASE + 2, '没有这个宝箱');
return;
}
$row = $conn->execQueryOne('SELECT * FROM supplybox WHERE accountid=:account_id AND box_id=:box_id;',
array(
':account_id' => $account_id,
':box_id' => $box_id
));
if (!$row) {
$row = $conn->execQueryOne('SELECT * FROM user WHERE accountid=:accountid;',
array(
':accountid' => $account_id
));
if ($row['coin_num'] < $s['price']) {
phpcommon\sendError(ERR_USER_BASE + 3, '金币不足');
return;
}
$coin_num = $s['price'];
$buy_times = 1;
$free_times = 0;
$ret = $conn->execScript('UPDATE user SET coin_num=:coin_num, modify_time=:modify_time ' .
' WHERE accountid=:accountid;',
array(
':accountid' => $account_id,
':coin_num' => $row['coin_num'] - $s['price'],
':modify_time' => time()
));
$ret = $conn->execScript('INSERT INTO supplybox(accountid, box_id, buy_times, free_times, last_buy_time, create_time, modify_time) ' .
' VALUES(:accountid, :box_id, 1, 0, :last_buy_time, :create_time, :modify_time) ' .
' ON DUPLICATE KEY UPDATE accountid=:accountid, box_id=:box_id, buy_times=1, free_times=0, last_buy_time=0, modify_time=:modify_time;',
array(
':accountid' => $account_id,
':box_id' => $box_id,
':last_buy_time' => time(),
':create_time' => time(),
':modify_time' => time()
));
if (!$ret) {
die();
return;
}
} else {
$row1 = $conn->execQueryOne('SELECT * FROM user WHERE accountid=:accountid;',
array(
':accountid' => $account_id
));
if ($row1['coin_num'] < $s['price'] * pow($s['parameter'], ($row['buy_times']))) {
phpcommon\sendError(ERR_USER_BASE + 3, '金币不足');
return;
}
$coin_num = $s['price'] * pow($s['parameter'], ($row['buy_times']));
$buy_times = $row['buy_times'] + 1;
$free_times = $row['free_times'];
$ret = $conn->execScript('UPDATE user SET coin_num=:coin_num, modify_time=:modify_time ' .
' WHERE accountid=:accountid;',
array(
':accountid' => $account_id,
':coin_num' => $row1['coin_num'] - $coin_num,
':modify_time' => time()
));
$ret = $conn->execScript('UPDATE supplybox SET buy_times=:buy_times, last_buy_time=:time, modify_time=:modify_time ' .
' WHERE accountid=:accountid AND box_id=:box_id;',
array(
':accountid' => $account_id,
':box_id' => $box_id,
':buy_times' => $row['buy_times'] + 1,
':time' => time(),
':modify_time' => time()
));
if (!$ret) {
die();
return;
}
}
echo json_encode(array(
'errcode' => 0,
'errmsg' => '',
/*"box_id" => $box_id,
"buy_times" => $buy_times,
"free_times" => $free_times,
"coin_num" => -$coin_num,*/
));
}
public function supplyReward()
{
$account_id = $_REQUEST['account_id'];
//登录校验
$login = loginVerify($account_id, $_REQUEST['session_id']);
if (!$login) {
phpcommon\sendError(ERR_USER_BASE + 1, 'session无效');
return;
}
$conn = $this->getMysql($account_id);
if (!$conn) {
phpcommon\sendError(ERR_USER_BASE + 1, '没有这个玩家');
return;
}
$item_id = $_REQUEST['item_id'];
$p_num = $this->getParameter(DOUBLE_BOX);
$item_num = $_REQUEST['item_num'] * ($p_num['param_value'] - 1);
$addreward = new classes\AddReward();
$addreward->addReward($item_id, $item_num, $account_id);
echo json_encode(array(
'errcode' => 0,
'errmsg' => '',
));
}
}
?>