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

1

Browse Source
This commit is contained in:
wangwei01 2019-06-20 13:26:06 +08:00
parent 64f6e2d957
commit 0e8b5cec84
4 changed files with 92 additions and 143 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

63
webapp/classes/AddReward.php Normal file
View File

@ -0,0 +1,63 @@
<?php
namespace classes;
use phpcommon;
class AddReward {
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' => 'gamedb2001_' . $mysql_conf['instance_id']
));
return $conn;
}
public function addReward($item_id, $item_num, $account_id)
{
$conn = $this->getMysql($account_id);
if (!$conn) {
phpcommon\sendError(ERR_USER_BASE + 1, '没有这个玩家');
die();
}
if ($item_id == 10001) {
$row1 = $conn->execQueryOne('SELECT * FROM user WHERE accountid=:accountid;',
array(
':accountid' => $account_id
));
$ret = $conn->execScript('UPDATE user SET coin_num=:coin_num, modify_time=:modify_time ' .
' WHERE accountid=:accountid;',
array(
':accountid' => $account_id,
':coin_num' => $item_num + $row1['coin_num'],
':modify_time' => time()
));
if (!$ret) {
die();
}
} else if ($item_id > 13000 && $item_id < 14000) {
$rowSkin = $conn->execQueryOne('SELECT * FROM skin WHERE accountid=:accountid AND fragment_id=:fragment_id;',
array(
':accountid' => $account_id,
':fragment_id' => $item_id
));
$ret = $conn->execScript('UPDATE skin SET fragment_num=:fragment_num, modify_time=:modify_time ' .
' WHERE accountid=:accountid AND fragment_id=:fragment_id;',
array(
':accountid' => $account_id,
':fragment_id' => $item_id,
':fragment_num' => $item_num + $rowSkin['fragment_num'],
':modify_time' => time()
));
if (!$ret) {
die();
}
}
}
}
?>

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

@ -1,6 +1,7 @@
<?php <?php
require 'classes/Quest.php'; require 'classes/Quest.php';
require 'classes/AddReward.php';
class QuestController{ class QuestController{
@ -27,7 +28,7 @@ class QuestController{
'condition' => $quest_conf['condition'], 'condition' => $quest_conf['condition'],
'value' => $quest_conf['value'], 'value' => $quest_conf['value'],
'active_value' => $quest_conf['active_value'], 'active_value' => $quest_conf['active_value'],
'gold' => $quest_conf['gold'], 'reward' => $quest_conf['reward'],
); );
return $q; return $q;
} }
@ -368,45 +369,23 @@ class QuestController{
'item_id' => $item_id, 'item_id' => $item_id,
'item_num' => $item_num, 'item_num' => $item_num,
)); ));
if ($item_id == 10001) { $addreward = new classes\AddReward();
$row1 = $conn->execQueryOne('SELECT * FROM user WHERE accountid=:accountid;', $addreward->addReward($item_id, $item_num, $account_id);
array(
':accountid' => $account_id
));
$ret = $conn->execScript('UPDATE user SET coin_num=:coin_num, modify_time=:modify_time ' .
' WHERE accountid=:accountid;',
array(
':accountid' => $account_id,
':coin_num' => $item_num + $row1['coin_num'],
':modify_time' => time()
));
if (!$ret) {
die();
return;
}
}
} else { } else {
$q = $this->getQuest($quest_id); $q = $this->getQuest($quest_id);
if (!$q) { if (!$q) {
phpcommon\sendError(ERR_USER_BASE + 2, '没有这个任务'); phpcommon\sendError(ERR_USER_BASE + 2, '没有这个任务');
return; return;
} }
$reward = $q['gold']; $array = $this->getExplode($q['reward']);
$row1 = $conn->execQueryOne('SELECT * FROM user WHERE accountid=:accountid;', $reward_id = $array[0][0];
array( $reward_num = $array[0][1];
':accountid' => $account_id $addreward = new classes\AddReward();
$addreward->addReward($reward_id, $reward_num, $account_id);
array_push($item_list, array(
'item_id' => $reward_id,
'item_num' => $reward_num,
)); ));
$ret = $conn->execScript('UPDATE user SET coin_num=:coin_num, modify_time=:modify_time ' .
' WHERE accountid=:accountid;',
array(
':accountid' => $account_id,
':coin_num' => $reward + $row1['coin_num'],
':modify_time' => time()
));
if (!$ret) {
die();
return;
}
} }
if ($row['quest_type'] == 1) { if ($row['quest_type'] == 1) {
$active = $conn->execQueryOne('SELECT active_num, active_sum FROM active WHERE accountid=:accountid;', $active = $conn->execQueryOne('SELECT active_num, active_sum FROM active WHERE accountid=:accountid;',

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

@ -1,6 +1,7 @@
<?php <?php
require 'classes/Quest.php'; require 'classes/Quest.php';
require 'classes/AddReward.php';
class SignController{ class SignController{
@ -195,31 +196,6 @@ class SignController{
)); ));
} }
public function addReward($item_id, $item_num, $account_id)
{
$conn = $this->getMysql($account_id);
if (!$conn) {
phpcommon\sendError(ERR_USER_BASE + 1, '没有这个玩家');
return;
}
$rowSkin = $conn->execQueryOne('SELECT * FROM skin WHERE accountid=:accountid AND fragment_id=:fragment_id;',
array(
':accountid' => $account_id,
':fragment_id' => $item_id
));
$ret = $conn->execScript('UPDATE skin SET fragment_num=:fragment_num, modify_time=:modify_time ' .
' WHERE accountid=:accountid AND fragment_id=:fragment_id;',
array(
':accountid' => $account_id,
':fragment_id' => $item_id,
':fragment_num' => $item_num + $rowSkin['fragment_num'],
':modify_time' => time()
));
if (!$ret) {
die();
}
}
public function signReward() public function signReward()
{ {
$account_id = $_REQUEST['account_id']; $account_id = $_REQUEST['account_id'];
@ -243,12 +219,12 @@ class SignController{
phpcommon\sendError(ERR_USER_BASE + 2, '今日已签到'); phpcommon\sendError(ERR_USER_BASE + 2, '今日已签到');
return; return;
} }
$sign_days = $row['sign_days'] + 1;
$ret = $conn->execScript('UPDATE sign SET sign_time=:sign_time, sign_days=:sign_days, modify_time=:modify_time ' . $ret = $conn->execScript('UPDATE sign SET sign_time=:sign_time, sign_days=:sign_days, modify_time=:modify_time ' .
' WHERE accountid=:accountid;', ' WHERE accountid=:accountid;',
array( array(
':accountid' => $account_id, ':accountid' => $account_id,
':sign_days' => $row['sign_days'] + 1, ':sign_days' => $sign_days,
':sign_time' => time(), ':sign_time' => time(),
':modify_time' => time() ':modify_time' => time()
)); ));
@ -258,36 +234,19 @@ class SignController{
} }
//获得奖励 //获得奖励
$g_conf_sign_cluster = require('../res/signDaily@signDaily.php'); $g_conf_sign_cluster = require('../res/signDaily@signDaily.php');
$sign_days = $row['sign_days'] % count($g_conf_sign_cluster); $day = $sign_days % count($g_conf_sign_cluster);
if ($sign_days == 0) { if ($day == 0) {
$sign_days = count($g_conf_sign_cluster); $day = count($g_conf_sign_cluster);
} }
$s = $this->getSign($sign_days + 90000); $s = $this->getSign($day + 90000);
$item_id = $s['item_id']; $item_id = $s['item_id'];
$num = $s['num']; $num = $s['num'];
if ($double == 1) { if ($double == 1) {
$p_gold = $this->getParameter(DOUBLE_SIGN_IN); $p_gold = $this->getParameter(DOUBLE_SIGN_IN);
$num = $num * $p_gold['param_value']; $num = $num * $p_gold['param_value'];
} }
if ($item_id == 10001) { $addreward = new classes\AddReward();
$row2 = $conn->execQueryOne('SELECT * FROM user WHERE accountid=:accountid;', $addreward->addReward($item_id, $num, $account_id);
array(
':accountid' => $account_id
));
$ret = $conn->execScript('UPDATE user SET coin_num=:coin_num, modify_time=:modify_time WHERE accountid=:accountid;',
array(
':accountid' => $account_id,
':coin_num' => $num + $row2['coin_num'],
':modify_time' => time()
));
if (!$ret) {
die();
return;
}
} else if($item_id > 13000 && $item_id < 14000){
$this->addReward($item_id, $num, $account_id);
}
echo json_encode(array( echo json_encode(array(
'errcode' => 0, 'errcode' => 0,
'errmsg' => '', 'errmsg' => '',

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

@ -1,6 +1,7 @@
<?php <?php
require 'classes/Quest.php'; require 'classes/Quest.php';
require 'classes/AddReward.php';
class SupplyBoxController{ class SupplyBoxController{
@ -248,21 +249,10 @@ class SupplyBoxController{
'item_id' => $item_id, 'item_id' => $item_id,
'item_num' => $item_num, 'item_num' => $item_num,
)); ));
if ($item_id == 10001) {
$row1 = $conn->execQueryOne('SELECT * FROM user WHERE accountid=:accountid;', $addreward = new classes\AddReward();
array( $addreward->addReward($item_id, $item_num, $account_id);
':accountid' => $account_id
));
$ret = $conn->execScript('UPDATE user SET coin_num=:coin_num, modify_time=:modify_time ' .
' WHERE accountid=:accountid;',
array(
':accountid' => $account_id,
':coin_num' => $item_num + $row1['coin_num'],
':modify_time' => time()
));
} else if($item_id > 13000 && $item_id < 14000){
$this->addReward($item_id, $item_num, $account_id);
}
$quest = new classes\Quest(); $quest = new classes\Quest();
$quest->triggerQuest(71004, 1, 1, $account_id); $quest->triggerQuest(71004, 1, 1, $account_id);
$quest->triggerQuest(72004, 2, 1, $account_id); $quest->triggerQuest(72004, 2, 1, $account_id);
@ -366,31 +356,6 @@ class SupplyBoxController{
)); ));
} }
public function addReward($item_id, $item_num, $account_id)
{
$conn = $this->getMysql($account_id);
if (!$conn) {
phpcommon\sendError(ERR_USER_BASE + 1, '没有这个玩家');
return;
}
$rowSkin = $conn->execQueryOne('SELECT * FROM skin WHERE accountid=:accountid AND fragment_id=:fragment_id;',
array(
':accountid' => $account_id,
':fragment_id' => $item_id
));
$ret = $conn->execScript('UPDATE skin SET fragment_num=:fragment_num, modify_time=:modify_time ' .
' WHERE accountid=:accountid AND fragment_id=:fragment_id;',
array(
':accountid' => $account_id,
':fragment_id' => $item_id,
':fragment_num' => $item_num + $rowSkin['fragment_num'],
':modify_time' => time()
));
if (!$ret) {
die();
}
}
public function supplyReward() public function supplyReward()
{ {
$account_id = $_REQUEST['account_id']; $account_id = $_REQUEST['account_id'];
@ -408,25 +373,8 @@ class SupplyBoxController{
$item_id = $_REQUEST['item_id']; $item_id = $_REQUEST['item_id'];
$p_num = $this->getParameter(DOUBLE_BOX); $p_num = $this->getParameter(DOUBLE_BOX);
$item_num = $_REQUEST['item_num'] * ($p_num['param_value'] - 1); $item_num = $_REQUEST['item_num'] * ($p_num['param_value'] - 1);
if ($item_id == 10001) { $addreward = new classes\AddReward();
$row = $conn->execQueryOne('SELECT * FROM user WHERE accountid=:accountid;', $addreward->addReward($item_id, $item_num, $account_id);
array(
':accountid' => $account_id
));
$ret = $conn->execScript('UPDATE user SET coin_num=:coin_num, modify_time=:modify_time ' .
' WHERE accountid=:accountid;',
array(
':accountid' => $account_id,
':coin_num' => $item_num + $row['coin_num'],
':modify_time' => time()
));
if (!$ret) {
die();
return;
}
} else if($item_id > 13000 && $item_id < 14000){
$this->addReward($item_id, $item_num, $account_id);
}
echo json_encode(array( echo json_encode(array(
'errcode' => 0, 'errcode' => 0,
'errmsg' => '', 'errmsg' => '',