78 lines
2.8 KiB
PHP
78 lines
2.8 KiB
PHP
|
<?php
|
|||
|
|
|
|||
|
|
namespace app\cron\controller;
|
|||
|
|
|
|||
|
|
use app\common\controller\Push;
|
|||
|
|
use think\Cache;
|
|||
|
|
use think\Db;
|
|||
|
|
|
|||
|
|
|
|||
|
|
/*
|
|||
|
|
* 定时任务,每秒执行的方法
|
|||
|
|
*/
|
|||
|
|
class AppTodayStatistical
|
|||
|
|
{
|
|||
|
|
/*
|
|||
|
|
* 运行函数
|
|||
|
|
*/
|
|||
|
|
function index()
|
|||
|
|
{
|
|||
|
|
echo "每日12点统计用户数据：\n";
|
|||
|
|
$this->daily_statistics();
|
|||
|
|
echo "每日12点统计用户数据结束 \n";
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
/*
|
|||
|
|
* 每日12点统计用户数据
|
|||
|
|
*/
|
|||
|
|
public function daily_statistics(){
|
|||
|
|
echo date('Y-m-d')."每日统计开始：\n";
|
|||
|
|
$time = strtotime(date('Y-m-d'));
|
|||
|
|
$user_list = Db::name('user_wallet')->select();
|
|||
|
|
foreach ($user_list as $k=>$v){
|
|||
|
|
$gift_pack = Db::name('vs_user_gift_pack')->field('gid,num')->where(['user_id'=>$v['user_id'],'is_tester'=>1])->select();
|
|||
|
|
$gift_pack_price = 0;
|
|||
|
|
foreach ($gift_pack as $key=>$val){
|
|||
|
|
$gift_pack_price += Db::name('vs_gift')->where(['gid'=>$val['gid'],])->value('gift_price')*$val['num'];
|
|||
|
|
}
|
|||
|
|
//用户房间今日总流水
|
|||
|
|
//用户房间id
|
|||
|
|
$room_id = db::name('vs_room')->where('user_id', $v['user_id'])->value('room_id');
|
|||
|
|
$transaction = 0;
|
|||
|
|
if($room_id){
|
|||
|
|
$transaction = db::name('vs_give_gift')
|
|||
|
|
->where('from_id',$room_id)
|
|||
|
|
->where('from',2)
|
|||
|
|
->whereTime('createtime', 'today')
|
|||
|
|
->sum('total_price');
|
|||
|
|
}
|
|||
|
|
//公会流水
|
|||
|
|
$guild_flow_price = 0;
|
|||
|
|
$guild_id = db::name('vs_guild')->where(['user_id'=>$v['user_id'],'status'=>1,'delete_time'=>0])->value('guild_id');
|
|||
|
|
if($guild_id){
|
|||
|
|
$guild_flow_price= db::name('vs_guild_flow')->where('guild_id', $guild_id)->where('day', date('Y-m-d',$time))->sum('flow_price');
|
|||
|
|
}
|
|||
|
|
//充值金额
|
|||
|
|
$recharge_price = db::name('vs_user_recharge')->where('pay_status',2)->whereTime('pay_time', 'today')
|
|||
|
|
->sum('money');
|
|||
|
|
//提现
|
|||
|
|
$withdraw_price = db::name('vs_user_withdrawal')->whereIn('status',[2,6])->whereTime('createtime', 'today')->sum('money');
|
|||
|
|
$data = [
|
|||
|
|
'user_id'=>$v['user_id'],
|
|||
|
|
'coin'=>$v['coin'],
|
|||
|
|
'earnings'=>$v['earnings'],
|
|||
|
|
'gift_pack_price'=>$gift_pack_price,
|
|||
|
|
'room_flow_price'=>$transaction,
|
|||
|
|
'guild_flow_price'=>$guild_flow_price,
|
|||
|
|
'recharge_price'=>$recharge_price,
|
|||
|
|
'withdraw_price'=>$withdraw_price,
|
|||
|
|
'day'=>date('Y-m-d',$time),
|
|||
|
|
'createtime'=>$time,
|
|||
|
|
];
|
|||
|
|
Db::name('app_today_statistical')->insert($data);
|
|||
|
|
}
|
|||
|
|
echo date('Y-m-d')."每日统计结束 用户数量".count($user_list)." \n";
|
|||
|
|
}
|
|||
|
|
}
|