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-10-22 17:36:31 +08:00
parent 1eca89bde6
commit d86c55c962
5 changed files with 468 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
sql/gamedb.sql
View File

@ -100,7 +100,6 @@ CREATE TABLE `user` (
`newhand2` int(11) NOT NULL DEFAULT '0' COMMENT '精英礼包领取状态',
`game_times2` int(11) NOT NULL DEFAULT '0' COMMENT '精英礼包战斗场次',
`view_times2` int(11) NOT NULL DEFAULT '0' COMMENT '精英礼包视频场次',
`guildcoin_num` int(11) NOT NULL DEFAULT '0' COMMENT '战队货币',
`new_second_equip` int(11) NOT NULL DEFAULT '2' COMMENT '新玩家隔天结算武器',
PRIMARY KEY (`idx`),
@ -200,8 +199,6 @@ CREATE TABLE `activity` (
`item_num` int(11) NOT NULL DEFAULT '0' COMMENT '物品数量',
`create_time` int(11) NOT NULL DEFAULT '0' COMMENT '创建时间',
`modify_time` int(11) NOT NULL DEFAULT '0' COMMENT '修改时间',
`now_days` int(11) NOT NULL DEFAULT '0' COMMENT '当前第几天',
PRIMARY KEY (`idx`),
UNIQUE KEY `accountid` (`accountid`)
@ -290,5 +287,16 @@ CREATE TABLE `shop_data` (
UNIQUE KEY `accountid` (`accountid`)
) ENGINE=InnoDB AUTO_INCREMENT=10001 DEFAULT CHARSET=utf8 COLLATE=utf8_bin;
DROP TABLE IF EXISTS `festival_activity`;
/*!40101 SET @saved_cs_client = @@character_set_client */;
/*!40101 SET character_set_client = utf8 */;
CREATE TABLE `festival_activity` (
`idx` int(11) NOT NULL AUTO_INCREMENT COMMENT '自增id',
`accountid` varchar(60) NOT NULL DEFAULT '' COMMENT '账号id',
`blobdata` mediumblob COMMENT '节日活动数据json',
`create_time` int(11) NOT NULL DEFAULT '0' COMMENT '创建时间',
`modify_time` int(11) NOT NULL DEFAULT '0' COMMENT '修改时间',
PRIMARY KEY (`idx`),
UNIQUE KEY `accountid` (`accountid`)
) ENGINE=InnoDB AUTO_INCREMENT=10001 DEFAULT CHARSET=utf8 COLLATE=utf8_bin;
-- Dump completed on 2015-08-19 18:51:22

2
sql/gamedb2004_n_migrate_200426_01.sql
View File

@ -1,6 +1,6 @@
begin;
alter table user add column `free_lot_ticket` int(11) NOT NULL DEFAULT '0' COMMENT '免费抽奖券';
alter table user add column `free_lot_ticket` int(11) NOT NULL DEFAULT '0' COMMENT '免费抽奖券';xes
alter table user add column `free_dou_lot_ticket` int(11) NOT NULL DEFAULT '0' COMMENT '免费十倍抽奖券';
UPDATE user set sign_sum=7 WHERE sign_sum >= 7;
UPDATE actitity set free_times=0, video_times=0;

16
sql/gamedb2004_n_migrate_201022_01.sql Normal file
View File

@ -0,0 +1,16 @@
begin;
CREATE TABLE `festival_activity` (
`idx` int(11) NOT NULL AUTO_INCREMENT COMMENT '自增id',
`accountid` varchar(60) NOT NULL DEFAULT '' COMMENT '账号id',
`blobdata` mediumblob COMMENT '节日活动数据json',
`create_time` int(11) NOT NULL DEFAULT '0' COMMENT '创建时间',
`modify_time` int(11) NOT NULL DEFAULT '0' COMMENT '修改时间',
PRIMARY KEY (`idx`),
UNIQUE KEY `accountid` (`accountid`)
) ENGINE=InnoDB AUTO_INCREMENT=10001 DEFAULT CHARSET=utf8 COLLATE=utf8_bin;
insert into version (version) values(20200324);
commit;

333
webapp/controller/FesActivityController.class.php Normal file
View File

@ -0,0 +1,333 @@
<?php
require 'classes/AddReward.php';
require_once 'metatable/activity.php';
class FesActivityController{
protected function getRedis($act_uuid)
{
$redis_conf = getRedisConfig(crc32($act_uuid));
$r = new phpcommon\Redis(array(
'host' => $redis_conf['host'],
'port' => $redis_conf['port'],
'passwd' => $redis_conf['passwd']
));
return $r;
}
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' => DBNAME_PREFIX . $mysql_conf['instance_id']
));
return $conn;
}
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 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 readFesActDB($account_id) {
$conn = $this->getMysql($account_id);
$row = $conn->execQueryOne('SELECT blobdata FROM festival_activity WHERE accountid=:accountid;',
array(
':accountid' => $account_id
));
if (!empty($row)) {
$fes_db_str = $row['blobdata'];
$fes_db = json_decode($fes_db_str, true);
return $fes_db;
} else {
return null;
}
}
protected function saveFesActDB($account_id, $fes_db) {
$conn = $this->getMysql($account_id);
$row = $conn->execQueryOne('SELECT accountid FROM festival_activity WHERE accountid=:accountid;',
array(
':accountid' => $account_id
));
$fes_db_str = "";
if (!empty($fes_db)) {
$fes_db_str = json_encode($fes_db);
}
if (!empty($row)) {
//update
$row = $conn->execScript('UPDATE festival_activity SET blobdata=:blobdata, modify_time=:modify_time WHERE accountid=:accountid;',
array(
':accountid' => $account_id,
':blobdata' => $fes_db_str,
':modify_time' => time()
));
} else {
//insert
$row = $conn->execScript('INSERT INTO festival_activity(accountid, blobdata, create_time, modify_time) ' .
' VALUES(:account_id, :blobdata, :create_time, :modify_time) ' .
' ON DUPLICATE KEY UPDATE accountid=:account_id, blobdata=:blobdata, modify_time=:modify_time;',
array(
':account_id' => $account_id,
':blobdata' => $fes_db_str,
':create_time' => time(),
':modify_time' => time(),
));
}
}
//节日活动
public function acitivityInfo()
{
$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;
}
//节日活动信息
$this->getfesActInfo($account_id);
$user_db = $this->readFesActDB($account_id);
//metatable\getRewardInfo(1,1,1);
echo json_encode(array(
'errcode' => 0,
'errmsg'=> '',
'isopen' => $user_db['isopen'],
'id' => $user_db['act_id'],
'info_list' => $user_db['info_list'],
));
}
protected function getfesActInfo($account_id)
{
$user_db = $this->readFesActDB($account_id);
$act = metatable\getNowActivity();
$info_list = array();
if (!$act) {
//活动未开启
$act_db = array(
'isopen' => 0,
'act_id' => 0,
'info_list' => $info_list,
);
$this->saveFesActDB($account_id, $act_db);
} else {
//活动开启
if (empty($user_db) || empty($user_db['info_list'])) {
$info_list = $this->getActItem($act['id']);
$act_db = array(
'isopen' => 1,
'act_id' => $act['id'],
'info_list' => $info_list,
);
$this->saveFesActDB($account_id, $act_db);
}
}
}
protected function getActItem($id)
{
$act_conf = metatable\getActivityById($id);
if (!$act_conf) {
die();
return;
}
return metatable\getActInfo($act_conf);
}
public function getActReward()
{
$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;
}
$user_db = $this->readFesActDB($account_id);
if (empty($user_db) || $user_db['isopen'] == 0) {
phpcommon\sendError(ERR_USER_BASE + 3, '活动未开启');
return;
}
$reward = array();
$id = $_REQUEST['id'];
$status = 1;
foreach ($user_db['info_list'] as &$us) {
if ($us['id'] == $id) {
if ($us['status'] != 1) {
phpcommon\sendError(ERR_USER_BASE + 4, '奖励不可领');
return;
}
$us['status'] = 2;
$status = 2;
$reward = metatable\getRewardInfo($user_db['act_id'], $id, 0);
break;
}
}
if (empty($reward) || !$reward) {
phpcommon\sendError(ERR_USER_BASE + 5, '没有这个奖励');
return;
}
//更新奖励状态
$this->saveFesActDB($account_id, $user_db);
//领取奖励
$item_list = array();
$all_item_list = array();
$addreward = new classes\AddReward();
for ($i = 0; $i < count($reward); $i++) {
$item_id = $reward[$i][0];
$num = $reward[$i][1];
$time = $reward[$i][2];
array_push($item_list, array(
'item_id' => $item_id,
'item_num' => $num,
'time' => $time,
));
$items = $addreward->addReward($item_id, $num, $account_id, $time,0);
foreach($items as $j) {
array_push($all_item_list, array(
'item_id' => $j['item_id'],
'item_num' => $j['item_num'],
'time' => $j['time'],
));
}
}
$coin_num = $addreward->getCoinNum($account_id);
$diamond_num = $addreward->getDiamondNum($account_id);
echo json_encode(array(
'errcode' => 0,
'errmsg' => '',
'item_list' => $item_list,
'coin_nums' => $coin_num,
'diamond_nums' => $diamond_num,
'all_item_list' => $all_item_list,
'status' => $status,
'id' => $id,
));
}
public function getActExtraReward()
{
$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;
}
$user_db = $this->readFesActDB($account_id);
if (empty($user_db) || $user_db['isopen'] == 0) {
phpcommon\sendError(ERR_USER_BASE + 3, '活动未开启');
return;
}
$reward = array();
$id = $_REQUEST['id'];
$status = 0;
$times = 0;
foreach ($user_db['info_list'] as &$us) {
if ($us['id'] == $id) {
if ($us['status'] != 0) {
phpcommon\sendError(ERR_USER_BASE + 4, '奖励不可领');
return;
}
if ($us['times'] + 1 >= $us['condition']) {
$status = 1;
$us['status'] = 1;
}
$times = $us['times'] + 1;
$us['times']++;
$reward = metatable\getRewardInfo($user_db['act_id'], $id, 1);
break;
}
}
//更新奖励状态
$this->saveFesActDB($account_id, $user_db);
// if (empty($reward) || !$reward) {
// phpcommon\sendError(ERR_USER_BASE + 5, '没有这个奖励');
// return;
// }
$item_list = array();
$all_item_list = array();
$addreward = new classes\AddReward();
if ($reward && !empty($reward)) {
//领取奖励
for ($i = 0; $i < count($reward); $i++) {
$item_id = $reward[$i][0];
$num = $reward[$i][1];
$time = $reward[$i][2];
array_push($item_list, array(
'item_id' => $item_id,
'item_num' => $num,
'time' => $time,
));
$items = $addreward->addReward($item_id, $num, $account_id, $time,0);
foreach($items as $j) {
array_push($all_item_list, array(
'item_id' => $j['item_id'],
'item_num' => $j['item_num'],
'time' => $j['time'],
));
}
}
}
$coin_num = $addreward->getCoinNum($account_id);
$diamond_num = $addreward->getDiamondNum($account_id);
echo json_encode(array(
'errcode' => 0,
'errmsg' => '',
'item_list' => $item_list,
'coin_nums' => $coin_num,
'diamond_nums' => $diamond_num,
'all_item_list' => $all_item_list,
'times' => $times,
'status' => $status,
'id' => $id,
));
}
}
?>

106
webapp/metatable/activity.php Normal file
View File

@ -0,0 +1,106 @@
<?php
namespace metatable;
use phpcommon;
/*
配置表规范
getXXXConf:获取表所有数据
getXxxById():通过id获取单个数据
_internalGetXXXConf:获取表所有数据内部实现不对外开放
使用方式
require_once 'metatable/XXXX.php';
!!!注意必须使用require_once
*/
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;
}
function getActivityConf()
{
return _internalGetActivityConf();
}
function getActivityById($act_id)
{
$conf = getActivityConf();
$act_id = (int)$act_id;
return array_key_exists($act_id, $conf) ? $conf[$act_id] : null;
}
function _internalGetActivityConf()
{
global $g_act_table;
if (!$g_act_table) {
$g_act_table = require(getConfigBaseDir() . 'activity@activity.php');
}
return $g_act_table;
}
function getNowActivity()
{
$conf = getActivityConf();
for ($i = 1; $i <= count($conf); $i++) {
$act = getActivityById($i);
if (time() >= strtotime($act['time1']) && time() <= strtotime($act['time2'])) {
return $act;
}
}
return null;
}
function getActInfo($act_conf)
{
$info_list = array();
$conditions = getExplode($act_conf['condition']);
for ($i = 0; $i < count($conditions); $i++) {
array_push($info_list,array(
'id' => $i,
'status' => 0,
'times' => 0,
'type' => $conditions[$i][0],
'condition' => $conditions[$i][1],
));
}
return $info_list;
}
function getRewardInfo($act_id, $id, $type)
{
$act_conf = getActivityById($act_id);
if (!$act_conf) {
return null;
}
$items = explode('|', $act_conf['reward']);
if ($type == 1) {
if (empty($act_conf['extra_reward'])) {
return null;
}
$items = explode('|', $act_conf['extra_reward']);
}
$arr = array();
for ($i = 0; $i < count($items); $i++) {
$mul = explode(';', $items[$i]);
array_push($arr, $mul);
}
$arr2 = array();
$str = $arr[$id];
for ($i = 0; $i < count($str); $i++) {
$mul = explode(':', $str[$i]);
array_push($arr2, $mul);
}
return $arr2;
}