Merge pull request '游戏返利' (#408) from feature/game_rebate into release
Reviewed-on: http://8.136.139.249:3000/wmtx/platform/pulls/408master
commit
083c7710e4
@ -0,0 +1,183 @@
|
||||
<?php
|
||||
|
||||
namespace Admin\Controller;
|
||||
|
||||
use Base\Repository\GameRepository;
|
||||
use Base\Service\GameRebateService;
|
||||
use User\Api\UserApi as UserApi;
|
||||
use Base\Service\PresidentDepositService;
|
||||
|
||||
/**
|
||||
* 游戏返利
|
||||
*/
|
||||
class GameRebateController extends ThinkController
|
||||
{
|
||||
public function single()
|
||||
{
|
||||
$this->records('A');
|
||||
}
|
||||
|
||||
public function accumulative()
|
||||
{
|
||||
$this->records('C');
|
||||
}
|
||||
|
||||
public function daily()
|
||||
{
|
||||
$this->records('B');
|
||||
}
|
||||
|
||||
public function records($awardType)
|
||||
{
|
||||
$page = I('p', 1);
|
||||
$row = I('row', 10);
|
||||
$baseGameId = I('base_game_id', 0);
|
||||
$serverId = I('server_id', '');
|
||||
$roleName = I('role_name', '');
|
||||
$userAccount = I('user_account', '');
|
||||
$reviewStatus = I('review_status', -1);
|
||||
$sendStatus = I('send_status', -1);
|
||||
$reviewerId = I('reviewer_id', 0);
|
||||
|
||||
$where = [
|
||||
'_string' => '1=1',
|
||||
];
|
||||
$where['type'] = $awardType;
|
||||
if ($baseGameId != 0) {
|
||||
$where['base_game_id'] = $baseGameId;
|
||||
}
|
||||
if ($userAccount != '') {
|
||||
$where['user_account'] = ['like', $userAccount . '%'];
|
||||
}
|
||||
if ($roleName != '') {
|
||||
$where['role_name'] = ['like', $roleName . '%'];
|
||||
}
|
||||
if ($serverId != '') {
|
||||
$where['server_id'] = $serverId;
|
||||
}
|
||||
if ($reviewStatus != -1) {
|
||||
$where['review_status'] = $reviewStatus;
|
||||
}
|
||||
if ($sendStatus != -1) {
|
||||
$where['send_status'] = $sendStatus;
|
||||
}
|
||||
if ($reviewerId != 0) {
|
||||
$where['reviewer_id'] = $reviewerId;
|
||||
}
|
||||
|
||||
if (I('send_time_start', '') != '') {
|
||||
$where['_string'] .= ' and send_time>=' . strtotime(I('send_time_start') . ' 00:00:00');
|
||||
}
|
||||
if (I('send_time_end', '') != '') {
|
||||
$where['_string'] .= ' and send_time<=' . strtotime(I('send_time_end') . ' 23:59:59');
|
||||
}
|
||||
|
||||
$query = M('rebate_orders', 'tab_')->where($where);
|
||||
|
||||
$records = [];
|
||||
if (I('export', 0) == 1 || $row == 'all') {
|
||||
$records = $query->select();
|
||||
} else {
|
||||
$countQuery = clone $query;
|
||||
$records = $query->page($page, $row)->select();
|
||||
$count = $countQuery->count();
|
||||
}
|
||||
|
||||
$sendStatusList = [
|
||||
0 => '待发放',
|
||||
1 => '发放成功',
|
||||
2 => '发放异常',
|
||||
];
|
||||
|
||||
$reviewStatusList = [
|
||||
0 => '待审核',
|
||||
1 => '审核通过',
|
||||
2 => '审核拒绝',
|
||||
];
|
||||
|
||||
$pageTitles = [
|
||||
'A' => '单笔充值福利',
|
||||
'B' => '月卡福利发放',
|
||||
'C' => '累充福利发放',
|
||||
];
|
||||
$pageTitle = $pageTitles[$awardType];
|
||||
if (count($records) > 0) {
|
||||
foreach ($records as $key => $record) {
|
||||
$records[$key]['review_status_text'] = $reviewStatusList[$record['review_status']];
|
||||
$records[$key]['review_time'] = $record['review_time'] > 0 ? date('Y-m-d H:i:s', $record['review_time']) : '--';
|
||||
$records[$key]['send_status_text'] = $sendStatusList[$record['send_status']];
|
||||
$records[$key]['send_time'] = $record['send_time'] > 0 ? date('Y-m-d H:i:s', $record['send_time']) : '--';
|
||||
$records[$key]['award_date_range'] = is_null($record['award_started_at']) || is_null($record['award_ended_at'])
|
||||
? '' : $record['award_started_at'] . ' ~ ' . $record['award_ended_at'];
|
||||
$records[$key]['gift_content'] = implode('<br/>', explode('|', $record['gift_content']));
|
||||
}
|
||||
if (I('export', 0) == 1) {
|
||||
$field = [
|
||||
'base_game_name' => '游戏名称',
|
||||
'server_name' => '区服',
|
||||
'user_account' => '账号',
|
||||
'role_id' => '角色ID',
|
||||
'role_name' => '角色名称',
|
||||
'pay_amount' => '充值金额',
|
||||
'gift_content' => '奖励内容',
|
||||
'review_status_text' => '审核状态',
|
||||
'review_time' => '审核时间',
|
||||
'send_status_text' => '发放状态',
|
||||
'send_time' => '发放时间',
|
||||
'reviewer_username' => '审核人',
|
||||
];
|
||||
|
||||
addOperationLog(['op_type'=>3,'key'=>getNowDate(),'op_name'=>'导出' . $pageTitle . '记录','url'=>U('GameRebate/records'),'menu'=>'推广员-发放福利管理-' . '导出' . $pageTitle . '记录']);
|
||||
|
||||
data2csv($records, $pageTitle, $field);
|
||||
exit;
|
||||
}
|
||||
}
|
||||
$page = set_pagination($count, $row == 'all' ? 99999999 : $row);
|
||||
|
||||
if($page) {
|
||||
$this->assign('_page', $page);
|
||||
}
|
||||
|
||||
$admins = M('ucenter_member', 'sys_')->field(['id', 'username'])->select();
|
||||
$baseGames = M('base_game', 'tab_')->select();
|
||||
|
||||
$gameRepository = new GameRepository();
|
||||
$this->assign('pageTitle', $pageTitle);
|
||||
$this->assign('awardType', $awardType);
|
||||
$this->assign('servers', $gameRepository->getServersByBaseGameId($baseGameId));
|
||||
$this->assign('admins', $admins);
|
||||
$this->assign('baseGames', $baseGames);
|
||||
$this->assign('sendStatusList', $sendStatusList);
|
||||
$this->assign('reviewStatusList', $reviewStatusList);
|
||||
$this->assign('records', $records);
|
||||
$this->display('records');
|
||||
}
|
||||
|
||||
public function review()
|
||||
{
|
||||
$ids = I('ids', []);
|
||||
$status = I('status', 0);
|
||||
try {
|
||||
$service = new GameRebateService();
|
||||
$service->review($ids, $status);
|
||||
$this->ajaxReturn([
|
||||
'status' => 1,
|
||||
'message' => '操作成功'
|
||||
]);
|
||||
} catch (\Exception $e) {
|
||||
$this->ajaxReturn([
|
||||
'status' => 0,
|
||||
'message' => $e->getMessage()
|
||||
]);
|
||||
}
|
||||
}
|
||||
|
||||
public function getServers()
|
||||
{
|
||||
$gameId = I('game_id', 0);
|
||||
$gameRepository = new GameRepository();
|
||||
$servers = $gameRepository->getServersByBaseGameId($gameId);
|
||||
return $this->ajaxReturn(['status' => 1, 'message' => '获取成功', 'data' => ['servers' => $servers]]);
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,475 @@
|
||||
<?php
|
||||
|
||||
namespace Admin\Controller;
|
||||
use Think\Controller;
|
||||
|
||||
/**
|
||||
* 市场专员业绩
|
||||
* @author cz
|
||||
*
|
||||
*/
|
||||
class MarketPerformanceSetController extends Controller {
|
||||
private $beginThismonth;
|
||||
private $endThismonth;
|
||||
private $date;
|
||||
private $nowdata;
|
||||
private $month;//月份
|
||||
private $year;//年份
|
||||
private $adddata;//要添加的数据
|
||||
private $inSideCompanyIds;
|
||||
private $downFlowData;
|
||||
private $channelRatio;
|
||||
private $gameInfo;
|
||||
private $companyInfo;
|
||||
private $settleupMarketorderModel;
|
||||
private $taxRatio;
|
||||
private $oldMarketPerformance;
|
||||
/**
|
||||
* 更新某月数据
|
||||
*/
|
||||
public function setFreeMonth($count_date)
|
||||
{
|
||||
//设置转换精度
|
||||
ini_set('serialize_precision',14);
|
||||
$month = $count_date;
|
||||
if(empty($month)) die("参数错误");
|
||||
|
||||
$this->adddata = [];//置空否者会脚本进来会重复计算
|
||||
$this->date = $month;
|
||||
$tarry = explode('-',$month);
|
||||
$this->year= $tarry[0];
|
||||
if(strlen($tarry[1]) < 2) $tarry[1]="0".$tarry[1];
|
||||
|
||||
$this->month= $tarry[1];
|
||||
$this->beginThismonth=mktime(0,0,0,$tarry[1],1,$tarry[0]);
|
||||
$this->endThismonth=mktime(0,0,0,$tarry[1]-0+1,1,$tarry[0])-1;
|
||||
$this->settleupMarketorderModel=SM("settleup_marketorder","tab_");
|
||||
$this->reCount();
|
||||
$this->setSettleupMarketorder();
|
||||
}
|
||||
/**
|
||||
* 强制重新聚合
|
||||
*/
|
||||
private function reCount()
|
||||
{
|
||||
// $this->settleupMarketorderModel->where(['pay_time'=>$this->date])->delete();
|
||||
echo "旧数据清理成功".PHP_EOL;
|
||||
}
|
||||
/**
|
||||
* 计算公司毛利
|
||||
*/
|
||||
private function setSettleupMarketorder()
|
||||
{
|
||||
$this->setIsTipData();
|
||||
$this->getInsideCompanyid();
|
||||
$this->getChannelRatio();
|
||||
$this->getTaxRatio();
|
||||
$this->getAllDownFlowSpend();
|
||||
$this->getAllGameInfo();
|
||||
$this->getCompanyOtherInfo();
|
||||
$this->getPuStatement();
|
||||
$this->getPuSpecialStatement();
|
||||
$this->performanceSet();
|
||||
$this->settleupMarketorderDbSave();
|
||||
echo "{$this->year}-{$this->month}生成成功".PHP_EOL;
|
||||
}
|
||||
/**
|
||||
* 获取是否标红提示数据，旧数据比对
|
||||
*/
|
||||
private function setIsTipData()
|
||||
{
|
||||
$dbres = $this->settleupMarketorderModel->where(['pay_time'=>$this->date])->select();
|
||||
|
||||
if($dbres){
|
||||
foreach ($dbres as $key => $v) {
|
||||
$this->oldMarketPerformance[$v['company_id']][$v['game_name']]['company_profit'] = $v['company_profit'];
|
||||
}
|
||||
}else{
|
||||
$this->oldMarketPerformance = false;
|
||||
}
|
||||
//取消所有提示
|
||||
$this->settleupMarketorderModel->where("1=1")->save(["is_tip"=>0]);
|
||||
}
|
||||
|
||||
|
||||
|
||||
/**
|
||||
* 获取公司内部公司id
|
||||
*/
|
||||
private function getInsideCompanyid()
|
||||
{
|
||||
$res = M("PromoteCompany","tab_")->where("is_inside = 1")->field("id")->select();
|
||||
if($res){
|
||||
$res = array_column($res,"id");
|
||||
$res[] = 0;
|
||||
}else{
|
||||
$res = [0];
|
||||
}
|
||||
$this->inSideCompanyIds = implode(",",$res);
|
||||
}
|
||||
/**
|
||||
* 支付服务商渠道费
|
||||
* TODO:当前默认除了绑定币其他渠道都1%
|
||||
*/
|
||||
private function getChannelRatio()
|
||||
{
|
||||
$res = M("payment_merchant","tab_")->getField("id,config",true);
|
||||
foreach ($res as $k => $v) {
|
||||
$res[$k] = 1;
|
||||
//------begin------注释的部分表示按实际配置收取
|
||||
// $config = json_decode($v,true);
|
||||
// if(array_key_exists("channel_rate",$config) && $config['channel_rate'] > 0){
|
||||
// $res[$k] = $config['channel_rate'];
|
||||
// }else{
|
||||
// $res[$k] = 0;
|
||||
// }
|
||||
//----------end------
|
||||
}
|
||||
$res[0] = 1;//平台币
|
||||
$res[-1] = 0;//绑定币
|
||||
$this->channelRatio = $res;
|
||||
unset($res);
|
||||
}
|
||||
/**
|
||||
* 获取公司税率
|
||||
*/
|
||||
private function getTaxRatio()
|
||||
{
|
||||
$where = [
|
||||
"time"=>['ELT',$this->beginThismonth]
|
||||
];
|
||||
$tax_data = M("tax_radio","tab_")
|
||||
->field("tax_radio")
|
||||
->order("time desc")
|
||||
->where($where)
|
||||
->find();
|
||||
if($tax_data){
|
||||
$this->taxRatio = $tax_data['tax_radio'];
|
||||
}else{
|
||||
$this->taxRatio = 0;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取所有下游公司支付信息
|
||||
*/
|
||||
private function getAllDownFlowSpend()
|
||||
{
|
||||
$where = [
|
||||
"pay_status"=>1,
|
||||
"s.is_check"=>1,
|
||||
"payed_time"=>["between",[$this->beginThismonth,$this->endThismonth]],
|
||||
"p.company_id"=>["NOT IN",$this->inSideCompanyIds],
|
||||
"p.company_belong"=>['GT',0]
|
||||
];
|
||||
$dbres = M("Spend","tab_")
|
||||
->alias("s")
|
||||
->field("substring_index(game_name, '(', 1) relation_game_name,
|
||||
SUM(pay_amount) pay_amount,
|
||||
IFNULL(SUM(CASE WHEN is_refund = 1 THEN pay_amount ELSE 0 END),0) as refund_amount,
|
||||
p.company_id,p.company_belong,merchant_id")
|
||||
->join("tab_promote as p on s.promote_id = p.id")
|
||||
->where($where)
|
||||
->group("relation_game_name,company_id,merchant_id")
|
||||
->order("pay_amount desc")->select();
|
||||
foreach ($dbres as $v) {
|
||||
if(!array_key_exists($v['relation_game_name'],$this->downFlowData[$v['company_id']])){
|
||||
$this->downFlowData[$v['company_id']][$v['relation_game_name']] = [
|
||||
"cp_pay_amount"=>0,
|
||||
"promote_pay_amount"=>0,
|
||||
"pay_amount"=>0,
|
||||
"channel_amount"=>0,
|
||||
"refund_amount"=>0,
|
||||
"special_amount"=>0,
|
||||
"ratio"=>0
|
||||
];
|
||||
}
|
||||
$channel_amount = round($v['pay_amount']*$this->channelRatio[$v['merchant_id']]/100,2);
|
||||
$cp_amount = $v['pay_amount']-$v['refund_amount'];
|
||||
$promote_amount = $v['pay_amount']-$v['refund_amount'];
|
||||
$this->downFlowData[$v['company_id']][$v['relation_game_name']]['channel_amount'] += $channel_amount;
|
||||
$this->downFlowData[$v['company_id']][$v['relation_game_name']]['cp_pay_amount'] += $cp_amount;
|
||||
$this->downFlowData[$v['company_id']][$v['relation_game_name']]['promote_pay_amount'] += $promote_amount;
|
||||
$this->downFlowData[$v['company_id']][$v['relation_game_name']]['pay_amount'] += $v['pay_amount'];
|
||||
$this->downFlowData[$v['company_id']][$v['relation_game_name']]['refund_amount'] += $v['refund_amount'];
|
||||
}
|
||||
unset($dbres);
|
||||
}
|
||||
/**
|
||||
* 获取游戏信息及cp结算比例
|
||||
*/
|
||||
private function getAllGameInfo()
|
||||
{
|
||||
$games=[];
|
||||
foreach ( $this->downFlowData as $key => $value) {
|
||||
$games = array_merge(array_keys($value),$games);
|
||||
}
|
||||
$games = array_unique($games);
|
||||
//获取游戏信息
|
||||
$gameRes = M("Game","tab_")->where(['relation_game_name'=>['in',$games]])->getField("relation_game_name,relation_game_id",TRUE);
|
||||
foreach ($gameRes as $k => $v) {
|
||||
$this->gameInfo[$k]['relation_game_id'] = $v;
|
||||
$this->gameInfo[$k]['cp_ratio'] = 0;
|
||||
}
|
||||
$this->getCpStatement();
|
||||
}
|
||||
/**
|
||||
* 获取公司信息及推广员账号，市场员信息
|
||||
*/
|
||||
private function getCompanyOtherInfo()
|
||||
{
|
||||
$companyIds = array_unique(array_keys($this->downFlowData));
|
||||
$companyRes = M("promote_company","tab_")->alias("pc")
|
||||
->join("tab_promote as p on p.company_id = pc.id")
|
||||
->join("sys_member as m on p.admin_id = m.uid")
|
||||
->where(['pc.id'=>['in',$companyIds],'p.level'=>1])
|
||||
->group("pc.id")
|
||||
->getField("pc.id company_id,pc.company_name,pc.company_belong,pc.develop_type,p.id promote_id,p.account promote_account,p.admin_id,m.real_name",TRUE);
|
||||
$this->companyInfo = $companyRes;
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取下游结算比例,以最后一周的结算比例为最终比例
|
||||
*/
|
||||
private function getPuStatement()
|
||||
{
|
||||
//1.获取下游周结结算单
|
||||
$where = [
|
||||
"_string"=>"statement_begin_time between {$this->beginThismonth} and {$this->endThismonth} OR statement_end_time between {$this->beginThismonth} and {$this->endThismonth}",
|
||||
"company_type"=>2,
|
||||
"withdraw_type"=>0
|
||||
];
|
||||
$statement_pool = M("company_statement_pool","tab_")->where($where)->order("statement_begin_time desc")->select();
|
||||
//获取结算分段
|
||||
$date_arr = [];
|
||||
foreach ($statement_pool as $k => $v) {
|
||||
$tem = [
|
||||
"statement_begin_time"=>$v['statement_begin_time'],
|
||||
"statement_end_time"=>$v['statement_end_time'],
|
||||
"begin_time"=>date("Y.m.d",$v['statement_begin_time']),
|
||||
"end_time"=>date("Y.m.d",$v['statement_end_time']),
|
||||
"withdraw_type"=>0
|
||||
];
|
||||
if($v['statement_begin_time'] < $this->beginThismonth){
|
||||
$tem['statement_begin_time'] = $this->beginThismonth;
|
||||
$tem['begin_time'] = date("Y.m.d",$this->beginThismonth);
|
||||
}
|
||||
if($v['statement_end_time'] > $this->endThismonth){
|
||||
$tem['statement_end_time'] = $this->endThismonth;
|
||||
$tem['end_time'] = date("Y.m.d",$this->endThismonth);
|
||||
}
|
||||
$this->getPuAllStatement($tem,$v);
|
||||
$this->getPuCompanyStatement($tem);//对公周结
|
||||
$date_arr[] = $tem;
|
||||
}
|
||||
//2.获取对公的下游
|
||||
$tem = [
|
||||
"statement_begin_time"=>$this->beginThismonth,
|
||||
"statement_end_time"=>$this->endThismonth,
|
||||
"begin_time"=>date("Y.m.d",$this->beginThismonth),
|
||||
"end_time"=>date("Y.m.d",$this->endThismonth),
|
||||
"withdraw_type"=>1
|
||||
];
|
||||
$this->getPuCompanyStatement($tem);
|
||||
|
||||
}
|
||||
/**
|
||||
* 获取所有个人周结
|
||||
*/
|
||||
private function getPuAllStatement($time,$pool){
|
||||
$id = $pool['id'];
|
||||
//获取基本信息
|
||||
$infolist = M("company_statement_info","tab_")->where("pool_id = '{$id}'")->select();
|
||||
//获取母单
|
||||
if(!empty($pool['create_lack_ids'])){
|
||||
$l_ids = $pool['create_lack_ids'];
|
||||
$lack_info = M("company_lack_statement_info","tab_")->where("id in ({$l_ids})")->select();
|
||||
$infolist =array_merge($infolist,$lack_info);
|
||||
}
|
||||
foreach ($infolist as $v) {
|
||||
$sinfo = json_decode($v['statement_info'],true);
|
||||
foreach ($sinfo as $va) {
|
||||
foreach ($va["game_list"] as $val) {
|
||||
|
||||
//奖罚不算
|
||||
if( !array_key_exists($val['game_name'],$this->gameInfo) ){
|
||||
continue;
|
||||
}
|
||||
//其他计算日期不算
|
||||
if( ($val['statement_begin_time'] != $time['begin_time']) && ($val['statement_end_time'] != $time['end_time']) ){
|
||||
continue;
|
||||
}
|
||||
if(!array_key_exists($val['game_name'],$this->downFlowData[$v['company_id']])){
|
||||
continue;
|
||||
}
|
||||
if($this->downFlowData[$v['company_id']][$val['game_name']]["ratio"] == 0){
|
||||
$this->downFlowData[$v['company_id']][$val['game_name']]["ratio"] = $val['ratio'];
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 对公的下游结算
|
||||
*/
|
||||
private function getPuCompanyStatement($time)
|
||||
{
|
||||
$where = [
|
||||
"company_belong"=>["NOT IN",[0,9]],
|
||||
"withdraw_type"=>$time['withdraw_type']
|
||||
];
|
||||
if($time['recount']){
|
||||
$where['_string'] = "statement_begin_time = {$time['statement_begin_time']} OR statement_end_time = {$time['statement_end_time']}";
|
||||
}else{
|
||||
$where['statement_begin_time'] = $time['statement_begin_time'];
|
||||
$where['statement_end_time'] = $time['statement_end_time'];
|
||||
}
|
||||
$res = M("company_statement","tab_")->where($where)->select();
|
||||
if($res){
|
||||
foreach ($res as $v) {
|
||||
$sinfo = json_decode($v['statement_info'],true);
|
||||
foreach ($sinfo as $val) {
|
||||
//奖罚不算
|
||||
if( !array_key_exists($val['game_name'],$this->gameInfo) ){
|
||||
continue;
|
||||
}
|
||||
//其他计算日期不算
|
||||
if( ($val['statement_begin_time'] != $time['begin_time']) && ($val['statement_end_time'] != $time['end_time']) ){
|
||||
continue;
|
||||
}
|
||||
if(!array_key_exists($val['game_name'],$this->downFlowData[$v['company_id']])){
|
||||
continue;
|
||||
}
|
||||
if($this->downFlowData[$v['company_id']][$val['game_name']]["ratio"] == 0){
|
||||
$this->downFlowData[$v['company_id']][$val['game_name']]["ratio"] = $val['ratio'];
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
/**
|
||||
* 特殊补点
|
||||
*/
|
||||
private function getPuSpecialStatement()
|
||||
{
|
||||
$where = [
|
||||
"company_belong"=>["NOT IN",[0,9]],
|
||||
"withdraw_type"=>3,
|
||||
"_string"=>"statement_begin_time >= {$this->beginThismonth} and statement_end_time <= {$this->endThismonth}"
|
||||
];
|
||||
$res = M("company_statement","tab_")->where($where)->select();
|
||||
if($res){
|
||||
foreach ($res as $v) {
|
||||
$sinfo = json_decode($v['statement_info'],true);
|
||||
foreach ($sinfo as $va) {
|
||||
foreach ($va["game_list"] as $val) {
|
||||
//奖罚不算
|
||||
if( !array_key_exists($val['game_name'],$this->gameInfo) ){
|
||||
continue;
|
||||
}
|
||||
$this->downFlowData[$v['company_id']][$val['game_name']]["special_amount"] += $val['sum_money'];
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
//获取cp结算单
|
||||
private function getCpStatement()
|
||||
{
|
||||
$where = [
|
||||
"company_belong"=>9,
|
||||
"withdraw_type"=>1,
|
||||
"statement_begin_time"=>$this->beginThismonth,
|
||||
"statement_end_time"=>$this->endThismonth
|
||||
];
|
||||
$res = M("company_statement","tab_")->where($where)->select();
|
||||
if($res){
|
||||
foreach ($res as $v) {
|
||||
$sinfo = json_decode($v['statement_info'],true);
|
||||
foreach ($sinfo as $val) {
|
||||
//获取真实游戏名
|
||||
$games = $this->cpOPName2GName($val['game_name'],$v['company_id']);
|
||||
foreach ($games as $game) {
|
||||
if( !array_key_exists($game,$this->gameInfo) ){
|
||||
continue;
|
||||
}
|
||||
if($v['pay_type'] == 1){
|
||||
$ratio = $val['first_ratio'];
|
||||
}else{
|
||||
$ratio = $val['second_ratio'];
|
||||
}
|
||||
$this->gameInfo[$game]['cp_ratio'] = $ratio;
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
//结算包名还原游戏名
|
||||
private function cpOPName2GName($OPName,$company_id)
|
||||
{
|
||||
$where = [
|
||||
"partner_id"=>$company_id,
|
||||
"_string"=>"original_package_name = '{$OPName}' OR relation_game_name = '{$OPName}'"
|
||||
];
|
||||
$game = M("Game","tab_")->field("relation_game_name")->where($where)->group("relation_game_name")->select();
|
||||
if($game){
|
||||
return array_column($game,"relation_game_name");
|
||||
}else{
|
||||
return [$OPName];
|
||||
}
|
||||
}
|
||||
/**
|
||||
* 计算相应数据
|
||||
*/
|
||||
private function performanceSet()
|
||||
{
|
||||
foreach ($this->downFlowData as $company_id => $games) {
|
||||
$baseArr = $this->companyInfo[$company_id];
|
||||
$baseArr['pay_time'] = $this->date;
|
||||
$baseArr['is_settlement'] = 1;
|
||||
foreach ($games as $k => $v) {
|
||||
// if($company_id == 452){
|
||||
// dd($v);
|
||||
// }
|
||||
$game = $this->gameInfo[$k];
|
||||
$cp_ratio = $game['cp_ratio'];
|
||||
$tempArr = $baseArr;
|
||||
$tempArr['game_id'] = $game['relation_game_id'];
|
||||
$tempArr['relation_game_id'] = $game['relation_game_id'];
|
||||
$tempArr['game_name'] = $k;
|
||||
$tempArr['pay_amount'] = $v['pay_amount'];
|
||||
$tempArr['cp_amount'] = round($v['cp_pay_amount']*$cp_ratio/100,2);
|
||||
$tempArr['promote_amount'] = round($v['promote_pay_amount']*$v['ratio']/100+$v['special_amount'],2);
|
||||
$tempArr['channel_amount'] = $v['channel_amount'];
|
||||
$tempArr['refund_amount'] = $v['refund_amount'];
|
||||
$tempArr['company_tax'] = round( ($v['pay_amount']-$tempArr['cp_amount']-$tempArr['promote_amount']) * ($this->taxRatio / 100),2 );
|
||||
$tempArr['company_profit'] = $tempArr['pay_amount']-$tempArr['cp_amount']-$tempArr['promote_amount']-$tempArr['channel_amount']-$tempArr['company_tax'];
|
||||
$tempArr['is_tip'] = 0;
|
||||
if($this->oldMarketPerformance){
|
||||
if(!array_key_exists($company_id,$this->oldMarketPerformance) || !array_key_exists($k,$this->oldMarketPerformance[$company_id])){
|
||||
$tempArr['is_tip'] = 1;
|
||||
}else{
|
||||
if($this->oldMarketPerformance[$company_id][$k]['company_profit'] != $tempArr['company_profit'].''){
|
||||
$tempArr['is_tip'] = 1;
|
||||
}
|
||||
}
|
||||
}
|
||||
if($tempArr['promote_amount'] != 0){
|
||||
$this->adddata[]= $tempArr;
|
||||
}
|
||||
|
||||
}
|
||||
}
|
||||
}
|
||||
/**
|
||||
* 毛利数据库操作
|
||||
*/
|
||||
private function settleupMarketorderDbSave()
|
||||
{
|
||||
//删除旧数据
|
||||
$this->settleupMarketorderModel->where(['pay_time'=>$this->date])->delete();
|
||||
$this->settleupMarketorderModel->addAll($this->adddata);
|
||||
}
|
||||
|
||||
}
|
||||
@ -0,0 +1,137 @@
|
||||
<?php
|
||||
namespace Base\Service;
|
||||
|
||||
use GuzzleHttp\Client;
|
||||
|
||||
class GameRebateService
|
||||
{
|
||||
const SIGN_KEY = 'Eza65532qaOIAAWasdq962aqweasd';
|
||||
|
||||
private function getClient()
|
||||
{
|
||||
return new Client([
|
||||
'base_uri' => 'http://rebate.99you.cn/xyy_apply.php/23400/',
|
||||
'timeout' => 10.0,
|
||||
]);
|
||||
}
|
||||
|
||||
public function sendByOrder($order)
|
||||
{
|
||||
$gift = M('rebate_gifts', 'tab_')->where(['type' => $order['type'], 'gift_key' => $order['gift_key']])->find();
|
||||
$hasError = false;
|
||||
$sendResult = '';
|
||||
if ($gift['game_currency'] > 0) {
|
||||
$result = $this->sendCurrency($order['server_id'], $order['role_id'], $gift['game_currency']);
|
||||
if ($result['code'] != 1) {
|
||||
$hasError = true;
|
||||
}
|
||||
$sendResult .= ($result['msg'] ?? '');
|
||||
$sendResult .= ';';
|
||||
}
|
||||
if ($gift['gift_id'] > 0) {
|
||||
$result = $this->sendGift($order['server_id'], $order['role_id'], $gift['gift_id']);
|
||||
if ($result['code'] != 1) {
|
||||
$hasError = true;
|
||||
}
|
||||
$sendResult .= ($result['msg'] ?? '');
|
||||
}
|
||||
M('rebate_orders', 'tab_')->where(['id' => $order['id']])->save([
|
||||
'send_status' => $hasError ? 2 : 1,
|
||||
'send_time' => time(),
|
||||
'send_result' => $sendResult,
|
||||
]);
|
||||
}
|
||||
|
||||
public function sendCurrency($serverId, $roleId, $currency)
|
||||
{
|
||||
$sign = md5($currency.$serverId.$roleId.self::SIGN_KEY);
|
||||
$params = [
|
||||
'act' => 'sendgold',
|
||||
'serverid' => $serverId,
|
||||
'role_id' => $roleId,
|
||||
'money' => $currency,
|
||||
'sign' => $sign
|
||||
];
|
||||
return $this->get('', $params);
|
||||
}
|
||||
|
||||
public function sendGift($serverId, $roleId, $giftId)
|
||||
{
|
||||
$sign = md5($giftId.$serverId.$roleId.self::SIGN_KEY);
|
||||
$params = [
|
||||
'act' => 'send_email',
|
||||
'serverid' => $serverId,
|
||||
'role_id' => $roleId,
|
||||
'prop_id' => $giftId,
|
||||
'sign' => $sign
|
||||
];
|
||||
return $this->get('', $params);
|
||||
}
|
||||
|
||||
protected function get($uri, array $params = [])
|
||||
{
|
||||
try {
|
||||
$response = $this->getClient()->get($uri, [
|
||||
'verify' => false,
|
||||
'query' => $params,
|
||||
]);
|
||||
$result = (string)$response->getBody();
|
||||
return json_decode($result, true);
|
||||
} catch (\Exception $e) {
|
||||
return [
|
||||
'code' => 3,
|
||||
'msg' => '网络异常:' . $e->getMessage(),
|
||||
];
|
||||
}
|
||||
}
|
||||
|
||||
public function review(array $ids, $status)
|
||||
{
|
||||
if (!in_array($status, [1, 2])) {
|
||||
throw new \Exception('状态异常');
|
||||
}
|
||||
if (count($ids) == 0) {
|
||||
throw new \Exception('请选择要操作的记录');
|
||||
}
|
||||
$orders = M('rebate_orders', 'tab_')->field(['id'])->where(['review_status' => 0, 'id' => ['in', $ids]])->select();
|
||||
if (count($orders) != count($ids)) {
|
||||
throw new \Exception('含有不存在的记录或者已审核的记录');
|
||||
}
|
||||
|
||||
$adminInfo = $_SESSION['onethink_admin']['user_auth'];
|
||||
M('rebate_orders', 'tab_')->where(['review_status' => 0, 'id' => ['in', $ids]])->save([
|
||||
'review_status' => $status,
|
||||
'review_time' => time(),
|
||||
'reviewer_id' => $adminInfo['uid'],
|
||||
'reviewer_username' => $adminInfo['username'],
|
||||
]);
|
||||
}
|
||||
|
||||
public function sendAll($type)
|
||||
{
|
||||
$orders = M('rebate_orders', 'tab_')->where(['type' => $type, 'review_status' => 1, 'send_status' => 0])->select();
|
||||
foreach ($orders as $order) {
|
||||
if ($type == 'B') {
|
||||
if (time() < strtotime($order['award_started_at'] . ' 00:00:00') || time() > strtotime($order['award_ended_at'] . ' 23:59:59')) {
|
||||
continue;
|
||||
}
|
||||
}
|
||||
$this->sendByOrder($order);
|
||||
}
|
||||
}
|
||||
|
||||
public function sendDaily($date)
|
||||
{
|
||||
$map = [
|
||||
'type' => 'B',
|
||||
'review_status' => 1,
|
||||
'send_status' => 1,
|
||||
'award_started_at' => ['elt', $date],
|
||||
'award_ended_at' => ['egt', $date]
|
||||
];
|
||||
$orders = M('rebate_orders', 'tab_')->where($map)->select();
|
||||
foreach ($orders as $order) {
|
||||
$this->sendByOrder($order);
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,134 @@
|
||||
<?php
|
||||
|
||||
namespace Base\Tool\GameResource;
|
||||
|
||||
use GuzzleHttp\Client;
|
||||
use GuzzleHttp\Exception\RequestException;
|
||||
|
||||
/**
|
||||
* 逍遥游之仙魔降世-测试资源接口
|
||||
*/
|
||||
class XyyClient
|
||||
{
|
||||
const SIGN_NAME = 'sign';
|
||||
const SUCCESS = '0000';
|
||||
|
||||
const KEY = 'Eza65532qaOIAAWasdq962aqweasd';
|
||||
|
||||
protected $client;
|
||||
|
||||
private $apis = [
|
||||
'provide' => ['uri' => '/', 'method' => 'get'],
|
||||
];
|
||||
|
||||
public function __construct()
|
||||
{
|
||||
$this->client = new Client([
|
||||
'base_uri' => 'http://rebate.99you.cn/wdzx_apply.php/23399',
|
||||
'timeout' => 10.0,
|
||||
]);
|
||||
}
|
||||
|
||||
public function api($api, array $params = [])
|
||||
{
|
||||
$api = $this->apis[$api] ?? null;
|
||||
if (is_null($api)) {
|
||||
throw new \Exception('接口不存在');
|
||||
}
|
||||
$params[self::SIGN_NAME] = $this->sign($params);
|
||||
try {
|
||||
return $this->request($api, $params);
|
||||
} catch (\Exception $e) {
|
||||
$env = C('APP_ENV', null, 'prod');
|
||||
return ['code' => 3, 'msg' => '接口请求错误。' . ($env == 'prod' ? '' : $e->getMessage()) , 'data' => []];
|
||||
}
|
||||
}
|
||||
|
||||
public function request($api, $params)
|
||||
{
|
||||
if ($api['method'] == 'get') {
|
||||
return $this->get($api['uri'], $params);
|
||||
} else {
|
||||
return $this->post($api['uri'], $params);
|
||||
}
|
||||
}
|
||||
|
||||
protected function post($uri, array $params = [])
|
||||
{
|
||||
$response = $this->client->post($uri, [
|
||||
'verify' => false,
|
||||
'form_params' => $params,
|
||||
]);
|
||||
$result = (string)$response->getBody();
|
||||
return json_decode($result, true);
|
||||
}
|
||||
|
||||
protected function get($uri, array $params = [])
|
||||
{
|
||||
$response = $this->client->get($uri, [
|
||||
'verify' => false,
|
||||
'query' => $params,
|
||||
]);
|
||||
$result = (string)$response->getBody();
|
||||
return json_decode($result, true);
|
||||
}
|
||||
|
||||
protected function sign($params)
|
||||
{
|
||||
return md5($params['orderid'] . $params['serverid'] . $params['role_id'] . self::KEY);
|
||||
}
|
||||
|
||||
public function apply($order, $role)
|
||||
{
|
||||
$data = [
|
||||
'role_id' => $role['role_id'],
|
||||
'serverid' => $role['server_id'],
|
||||
'amount' => $order['ref_amount'],
|
||||
// 'money' => intval($order['ref_amount']) * 10,
|
||||
'orderid' => $order['order_no'],
|
||||
];
|
||||
|
||||
$result = $this->api('provide', $data);
|
||||
if ($result['code'] == 1) {
|
||||
return [
|
||||
'status' => true,
|
||||
'message' => $result['msg'],
|
||||
'result' => $result
|
||||
];
|
||||
} else {
|
||||
return [
|
||||
'status' => false,
|
||||
'message' => $result['msg'],
|
||||
'result' => $result
|
||||
];
|
||||
}
|
||||
}
|
||||
|
||||
public function getResourceTypes($deviceType)
|
||||
{
|
||||
if ($deviceType == 'andriod') {
|
||||
return [['id' => 1, 'name' => '通用', 'device_type' => 'andriod']];
|
||||
} elseif ($deviceType == 'ios') {
|
||||
return [['id' => 2, 'name' => '通用', 'device_type' => 'ios']];
|
||||
}
|
||||
}
|
||||
|
||||
public function getResources($typeId, $deviceType)
|
||||
{
|
||||
return [
|
||||
1 => ['ref_id' => 1, 'name' => '60元宝', 'amount' => 6],
|
||||
2 => ['ref_id' => 2, 'name' => '300元宝', 'amount' => 30],
|
||||
3 => ['ref_id' => 3, 'name' => '980元宝', 'amount' => 98],
|
||||
4 => ['ref_id' => 4, 'name' => '1280元宝', 'amount' => 128],
|
||||
5 => ['ref_id' => 5, 'name' => '1980元宝', 'amount' => 198],
|
||||
6 => ['ref_id' => 6, 'name' => '3280元宝', 'amount' => 328],
|
||||
7 => ['ref_id' => 7, 'name' => '6480元宝', 'amount' => 648],
|
||||
8 => ['ref_id' => 8, 'name' => '10000元宝', 'amount' => 1000],
|
||||
9 => ['ref_id' => 9, 'name' => '20000元宝', 'amount' => 2000],
|
||||
10 => ['ref_id' => 10, 'name' => '30000元宝', 'amount' => 3000],
|
||||
11 => ['ref_id' => 11, 'name' => '50000元宝', 'amount' => 5000],
|
||||
12 => ['ref_id' => 12, 'name' => '100000元宝', 'amount' => 10000],
|
||||
13 => ['ref_id' => 13, 'name' => '200000元宝', 'amount' => 20000],
|
||||
];
|
||||
}
|
||||
}
|
||||
Loading…
Reference in New Issue