You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
234 lines
6.7 KiB
PHP
234 lines
6.7 KiB
PHP
<?php
|
|
|
|
namespace Admin\Controller;
|
|
use Think\Controller;
|
|
|
|
/**
|
|
* 聚合渠道结算接口对接
|
|
* @author cz
|
|
*/
|
|
class AggregateFinanceSetController extends Controller {
|
|
public $apihost;
|
|
public $token = "LYHTQDJS";
|
|
|
|
public function _initialize(){
|
|
$apihost = M("Kv")->field("value")->where("`key` = 'aggregate_finance_api'")->find();
|
|
|
|
if(empty($apihost)){
|
|
echo "请先设置请求接口aggregate_finance_api的值".PHP_EOL;die;
|
|
}
|
|
$this->apihost = $apihost['value'];
|
|
}
|
|
public function setFreeDateCount($begin,$end='')
|
|
{
|
|
if($end == '') $end = $begin;
|
|
//判断日期格式
|
|
$patten = "/^\d{4}[\-](0?[1-9]|1[012])[\-](0?[1-9]|[12][0-9]|3[01])$/";
|
|
if (!preg_match($patten, $begin)) {
|
|
die("开始时间格式错误");
|
|
}
|
|
if (!preg_match($patten, $end)) {
|
|
die("结束时间格式错误");
|
|
}
|
|
if(strtotime($end) < strtotime($begin)){
|
|
die("结束时间不能比开始时间小");
|
|
}
|
|
if(strtotime($end)+86399-24*3600 > time()){
|
|
die("结束时间不能大于当前");
|
|
}
|
|
|
|
$starttime = $begin?strtotime($begin):mktime(0,0,0,date('m'),date('d'),date('Y'));
|
|
$endtime = $end?strtotime($end)+86399:$starttime+86399;
|
|
$datelist = get_date_list($starttime,$endtime,1);
|
|
$countdate = count($datelist);
|
|
for($i=0;$i<$countdate;$i++){
|
|
$this->setDailyCount($datelist[$i]);
|
|
}
|
|
}
|
|
public function setDailyCount($stime="now")
|
|
{
|
|
if(!IS_CLI){
|
|
die("只支持脚本访问");
|
|
}
|
|
if($stime=="now"){
|
|
$stime=time();
|
|
}else{
|
|
$stime = strtotime($stime);
|
|
}
|
|
$nowdate = date("Y-m-d",$stime);
|
|
$w = (int)date("w",$stime);
|
|
$d = (int)date("d",$stime);
|
|
|
|
if($w == 1 || $d == 1){
|
|
if($w == 1){
|
|
echo $nowdate.":".PHP_EOL;
|
|
echo "--周结begin".PHP_EOL;
|
|
$this->setWeekCount($stime);
|
|
}
|
|
if($d == 1){
|
|
echo $nowdate.":".PHP_EOL;
|
|
echo "--月结&补点begin".PHP_EOL;
|
|
$this->setMonthCount($stime);
|
|
}
|
|
}else{
|
|
echo $nowdate."非周一和月初，无需任何处理".PHP_EOL;
|
|
}
|
|
}
|
|
protected function setWeekCount($stime)//进行周结
|
|
{
|
|
$begintime = mktime(0,0,0,date('m',$stime),date('d',$stime)-7,date('Y',$stime));
|
|
$endtime = mktime(0,0,0,date('m',$stime),date('d',$stime),date('Y',$stime))-1;
|
|
$this->getAndSaveData(0,$begintime,$endtime);
|
|
}
|
|
protected function setMonthCount($stime)//进行周结
|
|
{
|
|
$thismonth = date('m',$stime);
|
|
$thisyear = date('Y',$stime);
|
|
if ($thismonth == 1) {
|
|
$lastmonth = 12;
|
|
$lastyear = $thisyear - 1;
|
|
} else {
|
|
$lastmonth = $thismonth - 1;
|
|
$lastyear = $thisyear;
|
|
}
|
|
$lastStartDay = $lastyear . '-' . $lastmonth . '-1';
|
|
$lastEndDay = $lastyear . '-' . $lastmonth . '-' . date('t', strtotime($lastStartDay));
|
|
$begintime = strtotime($lastStartDay);//上个月的月初时间戳
|
|
$endtime = strtotime($lastEndDay)+24*3600-1;//上个月的月末时间戳
|
|
//普通月结
|
|
$this->getAndSaveData(1,$begintime,$endtime);
|
|
//补点
|
|
$this->getAndSaveData(2,$begintime,$endtime);
|
|
|
|
}
|
|
protected function getAndSaveData($type,$begintime,$endtime)
|
|
{
|
|
$sign = md5($begintime.$endtime.$type.$this->token);
|
|
$arr = [
|
|
"begintime"=>$begintime,
|
|
"endtime"=>$endtime,
|
|
"type"=>$type,
|
|
"sign"=>$sign
|
|
];
|
|
$dataurl .= $this->apihost."&".http_build_query($arr);
|
|
$html = file_get_contents($dataurl);
|
|
$rsp = json_decode($html,true);
|
|
if($rsp['code'] != 1){
|
|
echo $rsp['error'].PHP_EOL;die;
|
|
}
|
|
//成功插入
|
|
$Aggregate = M("aggregate_statement","tab_");
|
|
$begintimestr = date("Y-m-d",$begintime);
|
|
$endtimestr = date("Y-m-d",$endtime);
|
|
if($rsp['count'] > 0){
|
|
//插入数据
|
|
foreach ($rsp['data'] as $k => $v) {
|
|
foreach ($v["game_list"] as $ke => &$va) {
|
|
$va['begintime'] = $begintimestr;
|
|
$va['endtime'] = $endtimestr;
|
|
$va['fax_ratio'] = 0;
|
|
}
|
|
$v["statement_info"] = json_encode($v["game_list"],JSON_UNESCAPED_UNICODE);
|
|
unset($v["game_list"]);
|
|
$v['begintime'] = $begintime;
|
|
$v['endtime'] = $endtime;
|
|
$v['create_time'] = time();
|
|
$v['admin_name'] = "system";
|
|
$v['admin_id'] = 0;
|
|
$v['second_party_info'] = json_encode([
|
|
"partner"=>$v['channel_name']
|
|
],JSON_UNESCAPED_UNICODE);
|
|
$Aggregate->add($v);
|
|
}
|
|
}
|
|
|
|
if($type == 0){
|
|
echo "----周结统计ok".PHP_EOL;
|
|
}elseif($type == 1){
|
|
echo "----月结统计ok".PHP_EOL;
|
|
}elseif($type == 2){
|
|
echo "----补点统计ok".PHP_EOL;
|
|
}
|
|
}
|
|
/**
|
|
* 重算聚合接口数据
|
|
* @param [type] $id
|
|
* @return void
|
|
*/
|
|
public function updateAggregateFinanceData($id)
|
|
{
|
|
//获取基础信息
|
|
$Aggregate = M("aggregate_statement","tab_");
|
|
$info = $Aggregate->where("id='{$id}'")->find();
|
|
$sign = md5($info['begintime'].$info['endtime'].$info['withdraw_type'].$this->token);
|
|
$arr = [
|
|
"begintime"=>$info['begintime'],
|
|
"endtime"=>$info['endtime'],
|
|
"type"=>$info['withdraw_type'],
|
|
"sign"=>$sign,
|
|
"channel_id"=>$info['channel_id']
|
|
];
|
|
$dataurl .= $this->apihost."&".http_build_query($arr);
|
|
$html = file_get_contents($dataurl);
|
|
$rsp = json_decode($html,true);
|
|
if($rsp['code'] != 1){
|
|
echo $rsp['error'].PHP_EOL;die;
|
|
}
|
|
//更新信息
|
|
$begintimestr = date("Y-m-d",$info['begintime']);
|
|
$endtimestr = date("Y-m-d",$info['endtime']);
|
|
|
|
if($rsp['count'] > 0){
|
|
//插入数据
|
|
foreach ($rsp['data'] as $k => $v) {
|
|
foreach ($v["game_list"] as $ke => &$va) {
|
|
$va['begintime'] = $begintimestr;
|
|
$va['endtime'] = $endtimestr;
|
|
$va['fax_ratio'] = 0;
|
|
}
|
|
$v["statement_info"] = json_encode($v["game_list"],JSON_UNESCAPED_UNICODE);
|
|
unset($v["game_list"]);
|
|
$v['create_time'] = time();
|
|
$v['admin_name'] = $_SESSION['onethink_admin']['user_auth']['username'];
|
|
$v['admin_id'] = $_SESSION['onethink_admin']['user_auth']['uid'];
|
|
$v['verify_status'] = 0;
|
|
|
|
$first_party_info = json_decode($info['first_party_info'], 1);
|
|
if($first_party_info['partner'] == $info['channel_name']){
|
|
$v['second_party_info'] = $info['first_party_info'];
|
|
$v['first_party_info'] = $info['second_party_info'];
|
|
$v['pay_type'] =0;
|
|
}
|
|
|
|
$res = $Aggregate->where("id='{$id}'")->save($v);
|
|
if(empty($res)){
|
|
return false;
|
|
}
|
|
}
|
|
}else{
|
|
$savedata = [
|
|
"create_time"=>time(),
|
|
"admin_name"=>$_SESSION['onethink_admin']['user_auth']['username'],
|
|
"admin_id"=>$_SESSION['onethink_admin']['user_auth']['uid'],
|
|
"verify_status"=>0,
|
|
"statement_info"=>json_encode([],JSON_UNESCAPED_UNICODE),
|
|
"ratio_money"=>0,
|
|
"pay_money"=>0
|
|
];
|
|
|
|
$first_party_info = json_decode($info['first_party_info'], 1);
|
|
if($first_party_info['partner'] == $info['channel_name']){
|
|
$savedata['second_party_info'] = $info['first_party_info'];
|
|
$savedata['first_party_info'] = $info['second_party_info'];
|
|
$savedata['pay_type'] =0;
|
|
}
|
|
|
|
$res = $Aggregate->where("id='{$id}'")->save($savedata);
|
|
if(empty($res)){
|
|
return false;
|
|
}
|
|
}
|
|
return true;
|
|
}
|
|
}
|