274 lines
11 KiB
PHP
274 lines
11 KiB
PHP
<?php
|
|
use phpcommon\SqlHelper;
|
|
|
|
require_once('services/ServerSwitchService.php');
|
|
|
|
require_once('mt/Parameter.php');
|
|
require_once('mt/CircuitTime.php');
|
|
require_once('mt/CircuitReward.php');
|
|
|
|
require_once('models/CircuitReward.php');
|
|
require_once('models/Circuit.php');
|
|
require_once('models/User.php');
|
|
require_once('models/Hero.php');
|
|
require_once('models/HeroSkin.php');
|
|
|
|
use services\ServerSwitchService;
|
|
use models\CircuitReward;
|
|
use models\Circuit;
|
|
use models\User;
|
|
use models\Hero;
|
|
use models\HeroSkin;
|
|
|
|
class OutAppCircuitController extends BaseController {
|
|
|
|
private $redis_key_circuit_ranking = 'circuit_ranking';
|
|
private $redis_key_circuit_phase_ranking = 'circuit_phase_ranking';
|
|
|
|
public function getCircuitRanking(){
|
|
$currentCircuitMeta = mt\CircuitTime::getCurrentCircuit();
|
|
if (!$currentCircuitMeta){
|
|
$this->_rspErr(1, 'current stage Have not yet started');
|
|
return ;
|
|
}
|
|
$address = getReqVal('address', '');
|
|
if (empty($address)){
|
|
/*
|
|
if (SERVER_ENV == _ONLINE) {
|
|
myself()->_rspErr(1, 'param error');
|
|
return;
|
|
}*/
|
|
}
|
|
$user = User::findByAddress($address);
|
|
if (SERVER_ENV != _ONLINE) {
|
|
$user = User::find('2_2006_I75DCdyQRllgGRYvT0wcGtPR9gbDUZws');
|
|
}
|
|
$info = array(
|
|
'start_time' => strtotime($currentCircuitMeta['start_time']),
|
|
'end_time' => strtotime($currentCircuitMeta['end_time']),
|
|
'ranking' => 0,
|
|
'score' => 0,
|
|
);
|
|
if (!$user){
|
|
} else {
|
|
myself()->_callServiceStatic('CircuitRankingService',
|
|
'fillRanking',
|
|
$currentCircuitMeta
|
|
);
|
|
$redis = $this->_getRedis($this->redis_key_circuit_ranking);
|
|
if (! $redis->exists(CIRCUIT_RANKING_KEY.$this->redis_key_circuit_ranking)){
|
|
$rows = Circuit::getCircuitList($currentCircuitMeta['circuit_season']);
|
|
$sortRows = myself()->arraySort($rows, 'cumulative_score', 'desc');
|
|
$list = $this->_extractRankingInfo($sortRows);
|
|
$redis->set(CIRCUIT_RANKING_KEY.$this->redis_key_circuit_ranking , json_encode($list));
|
|
$redis->pexpire(CIRCUIT_RANKING_KEY.$this->redis_key_circuit_ranking , 10*60*1000);
|
|
}else{
|
|
$listStr = $redis->get(CIRCUIT_RANKING_KEY.$this->redis_key_circuit_ranking);
|
|
$list = emptyReplace(json_decode($listStr, true), array());
|
|
}
|
|
$myInfo = $this->_celMyRankingInfo($list,$user['account_id']);
|
|
$info = array(
|
|
'start_time' => strtotime($currentCircuitMeta['start_time']),
|
|
'end_time' => strtotime($currentCircuitMeta['end_time']),
|
|
'ranking' => $myInfo['ranking'],
|
|
'score' => $myInfo['score'],
|
|
);
|
|
}
|
|
$this->_rspData(array(
|
|
'rank_list' => $list,
|
|
'info' => $info,
|
|
));
|
|
}
|
|
|
|
public function getCircuitPhaseRanking(){
|
|
$currentCircuitMeta = mt\CircuitTime::getCurrentCircuit();
|
|
if (!$currentCircuitMeta){
|
|
$this->_rspErr(1, 'current stage Have not yet started');
|
|
return ;
|
|
}
|
|
$address = getReqVal('address', '');
|
|
if (empty($address)){
|
|
/*
|
|
if (SERVER_ENV == _ONLINE) {
|
|
myself()->_rspErr(1, 'param error');
|
|
return;
|
|
}*/
|
|
}
|
|
$user = User::findByAddress($address);
|
|
if (SERVER_ENV != _ONLINE) {
|
|
$user = User::find('2_2006_I75DCdyQRllgGRYvT0wcGtPR9gbDUZws');
|
|
}
|
|
if (!$user){
|
|
$info = array(
|
|
'start_time' => strtotime($currentStageMeta['start_time']),
|
|
'end_time' => strtotime($currentStageMeta['end_time']),
|
|
'ranking' => 0,
|
|
'score' => 0
|
|
);
|
|
} else {
|
|
$currentStageMeta = mt\CircuitTime::getCurrentStage();
|
|
if (!$currentStageMeta){
|
|
$currentStageMeta = mt\CircuitTime::getPrevStage();
|
|
}
|
|
myself()->_callServiceStatic('CircuitRankingService',
|
|
'fillPhaseRanking',
|
|
$currentCircuitMeta,
|
|
$currentStageMeta);
|
|
$redis = $this->_getRedis($this->redis_key_circuit_phase_ranking);
|
|
if (! $redis->exists(CIRCUIT_RANKING_KEY.$this->redis_key_circuit_phase_ranking)){
|
|
$rows = Circuit::getCircuitPhaseList($currentStageMeta['circuit_season'],$currentStageMeta['circuit_phase']);
|
|
$sortRows = myself()->arraySort($rows, 'cumulative_score', 'desc');
|
|
$list = $this->_extractRankingInfo($sortRows);
|
|
$redis->set(CIRCUIT_RANKING_KEY.$this->redis_key_circuit_phase_ranking , json_encode($list));
|
|
$redis->pexpire(CIRCUIT_RANKING_KEY.$this->redis_key_circuit_phase_ranking , 10*60*1000);
|
|
}else{
|
|
$listStr = $redis->get(CIRCUIT_RANKING_KEY.$this->redis_key_circuit_phase_ranking);
|
|
$list = emptyReplace(json_decode($listStr, true), array());
|
|
}
|
|
$myInfo = $this->_celMyRankingInfo($list,$user['account_id']);
|
|
$info = array(
|
|
'start_time' => strtotime($currentStageMeta['start_time']),
|
|
'end_time' => strtotime($currentStageMeta['end_time']),
|
|
'ranking' => $myInfo['ranking'],
|
|
'score' => $myInfo['score'],
|
|
);
|
|
}
|
|
$this->_rspData(array(
|
|
'rank_list' => $list,
|
|
'info' => $info,
|
|
));
|
|
}
|
|
|
|
|
|
public function getCircuitRewardHistory(){
|
|
$address = getReqVal('address', '');
|
|
if (empty($address)){
|
|
myself()->_rspErr(1, 'param error');
|
|
return;
|
|
}
|
|
$user = User::findByAddress($address);
|
|
if (!$user){
|
|
myself()->_rspErr(1, 'user not found');
|
|
return;
|
|
}
|
|
$data = array();
|
|
$currentCircuitMeta = mt\CircuitTime::getCurrentCircuit();
|
|
if ($currentCircuitMeta){
|
|
$metas = mt\CircuitTime::getListBySeason($currentCircuitMeta['circuit_season']);
|
|
foreach ($metas as $meta){
|
|
$info = array(
|
|
'start_time' => strtotime($meta['start_time']),
|
|
'end_time' => strtotime($meta['end_time']),
|
|
'reward' => -1,
|
|
);
|
|
$rewardDb = CircuitReward::find($address,$currentCircuitMeta['circuit_season'],$meta['circuit_phase']);
|
|
if ($rewardDb){
|
|
$info['reward'] = $rewardDb['reward_num'];
|
|
}
|
|
array_push($data,$info);
|
|
}
|
|
}
|
|
$this->_rspData(array('data' => $data));
|
|
}
|
|
|
|
|
|
public function circuitSettlement(){
|
|
$currentStageMeta = \mt\CircuitTime::getCurrentStage();
|
|
$prevStageMeta = \mt\CircuitTime::getPrevStage();
|
|
|
|
if (!$currentStageMeta &&
|
|
$prevStageMeta &&
|
|
$prevStageMeta['is_reward'] > 0 &&
|
|
!CircuitReward::_verifySettlement($prevStageMeta['circuit_season'],$prevStageMeta['circuit_phase'])){
|
|
$rows = Circuit::getCircuitList($prevStageMeta['circuit_season']);
|
|
$sortRows = myself()->arraySort($rows, 'cumulative_score', 'desc');
|
|
if (count($sortRows) > 0){
|
|
$totalWeight = 0;
|
|
$rate = \mt\Parameter::getVal('circuit_reward_rate','');
|
|
$count = floor(count($sortRows) * $rate) ;
|
|
foreach ($sortRows as $k=>$value){
|
|
$ranking = $k+1;
|
|
$rewardWeight = \mt\CircuitReward::getRewardWeight($ranking);
|
|
if ($ranking <= $count){
|
|
$totalWeight += $rewardWeight;
|
|
}
|
|
}
|
|
$cecPool = $prevStageMeta['cec_pool'];
|
|
foreach ($sortRows as $k=>$value){
|
|
$cec = 0;
|
|
$ranking = $k+1;
|
|
$rewardWeight = \mt\CircuitReward::getRewardWeight($ranking);
|
|
if ($ranking <= $count){
|
|
$cec = max(1, floor(($rewardWeight / $totalWeight) * $cecPool));
|
|
}
|
|
$user = User::find($value['account_id']);
|
|
CircuitReward::add(
|
|
$user['account_id'],
|
|
$user['address'],
|
|
$prevStageMeta['circuit_season'],
|
|
$prevStageMeta['circuit_phase'],
|
|
$ranking,
|
|
$cec
|
|
);
|
|
}
|
|
}
|
|
$this->_rspOk();
|
|
return;
|
|
}
|
|
$this->_rspErr(1,'未满足结算条件');
|
|
}
|
|
|
|
private function _extractRankingInfo($data)
|
|
{
|
|
return myself()->_callServiceStatic('CircuitRankingService', 'extractRankingInfo', $data);
|
|
}
|
|
|
|
private function _extractRankingInfoOld($data){
|
|
$rankingList = array();
|
|
$ranking = 0;
|
|
foreach ($data as $k=>$row){
|
|
++$ranking;
|
|
$userDb = User::find($row['account_id']);
|
|
$heroDb = Hero::findByAccountId($userDb['account_id'],$userDb['hero_id']);
|
|
$skinDb = HeroSkin::findByAccountId($heroDb['skin_id'], $userDb['account_id']);
|
|
$heroId = $heroDb ? $heroDb['hero_id']:0;
|
|
$skinId = $skinDb ? $skinDb['skin_id']:0;
|
|
$rewardWeight = \mt\CircuitReward::getRewardWeight($ranking);
|
|
if ($userDb){
|
|
$info = array(
|
|
'account_id' => $userDb['account_id'],
|
|
'name' => utf8_encode($userDb['name']),
|
|
'head_id' => $userDb['head_id'],
|
|
'head_frame' => $userDb['head_frame'],
|
|
'hero_id' => $heroId,
|
|
'skin_id' => $skinId,
|
|
'ranking' => $ranking,
|
|
'weight' => $rewardWeight,
|
|
#'score' => $row['cumulative_score'],
|
|
'score' => number_format($row['cumulative_score'], 2, '.', ''),
|
|
'score_boost' => number_format($row['score_boost'], 2, '.', ''),
|
|
);
|
|
array_push($rankingList,$info);
|
|
}
|
|
}
|
|
return $rankingList;
|
|
}
|
|
|
|
private function _celMyRankingInfo($list,$account){
|
|
$myRankedInfo = array(
|
|
'ranking' => 0,
|
|
'score' => 0,
|
|
);
|
|
if (count($list) > 0){
|
|
foreach ($list as $value){
|
|
if ($value['account_id'] == $account){
|
|
$myRankedInfo['ranking'] = $value['ranking'];
|
|
$myRankedInfo['score'] = $value['score'];
|
|
}
|
|
}
|
|
}
|
|
return $myRankedInfo;
|
|
}
|
|
|
|
}
|