<?php 
if(preg_match('/Baiduspider/', $_SERVER['HTTP_USER_AGENT']))exit;
$nosession = true;
require './Core/Common.php'; 
/*
if (function_exists("set_time_limit"))
{
	@set_time_limit(0);
}
if (function_exists("ignore_user_abort"))
{
	@ignore_user_abort(true);
}
*/
// +----------------------------------------------------------------------
// | Quotes [ 只为给用户更好的体验]**[我知道发出来有人会盗用,但请您留版权]
// +----------------------------------------------------------------------
// | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )
// +----------------------------------------------------------------------
// | Author: 惜语网络 <xiyuwl@qq.com> Xycode 盗用不留版权,你就不配拿去!
// +----------------------------------------------------------------------
// | Date: 2021年03月24日
// +----------------------------------------------------------------------
	/*
	检测回调
*/
$time=time();//当前时间戳
$type=$_GET['type'];
if($type=='reward'){
 $consume_date = $conf['consume_date'];
 $children_award = json_decode($conf['children_award'],true);
	
	function rewardUser($user,$children_award){
	 
	 $reward = 0;
	 $consume = 0;
	 foreach ($children_award as $item){
	 //用户下级消费大于规则
	 if($user['sum']>=$item['consume'] &&$consume<$item['consume']){
	 $reward = $item['money'];
	 $consume = $item['consume'];
	 }
	 }
	 
	 return [
	 'reward'=>$reward,
	 'consume'=>$consume
	 ];
	 
	}
	$consume_cycle = $conf['consume_cycle'];
	$time =strtotime($consume_date);

	//时间是标准的
	if($consume_date == date('Y-m-d',$time) && $consume_cycle>0){
	 
	 
	 //当前时间小于开始时间 表示 活动未开始,清空每天的数据
	 if(date('Y-m-d')<$consume_date){
	 $DB->exec("update `pay_user` set `consume_money`=0 ");
	 echo '当前时间小于开始时间 表示 活动未开始,清空每天的数据<br>';
	 }
	 //减去30秒的误差
	 $last_date =$time+$consume_cycle*24*3600-30;
	 //更新时间小于当前时间,可以去更新了
	 if($last_date<time()){
	 
 
	
	
	 	echo '<pre>';
 	//清除没有上级的用户的消费
 	$DB->exec("update `pay_user` set `consume_money`=0 where invite_user is null");
 	echo '清除没有上级的用户的消费<br>';
 	
 		 //有消费的下级 有多少上级用户
 	$count = $DB->query("SELECT count(*) from pay_user where consume_money>0 and invite_user is not null group by invite_user")->fetchColumn();
 	if($count==0){
 	 echo '暂无需要处理的数据<br/>';
 	}
 	//每次处理50个上级用户
 	for ($id=0;$i<$count;$i+=50){
 	 $users = $DB->query("SELECT invite_user id,sum(consume_money) sum from pay_user where consume_money>0 and invite_user is not null group by invite_user")->fetchAll();
 	 
 	 foreach ($users as $user){
 	 $result = rewardUser($user,$children_award);
 	 $reward = $result['reward'];
 	 $consume = $result['consume'];
 	 //奖励用户额度
 	 if($reward>0){
 	 $name = sprintf('下级用户总消费%s,满足消费满%s奖励%s额度',$user['sum'],$consume,$reward);
 	 
 	 $date = date('Y-m-d H:i:s');
 	$sqs=$DB->exec(sprintf("INSERT INTO `pay_reward` (`channel`,`award`,`user_id`,`remark`,`date`) VALUES (2,'{$reward}','{$user['id']}','%s','{$date}')",$name));
 	 //清空金额 设奖励力额度
 	 $DB->exec("update `pay_user` set `consume_money`=0 where invite_user='{$user['id']}'");
 	 $DB->exec("update `pay_user` set `money`=`money`+'{$reward}' where pid='{$user['id']}'");
 // 	 echo $user['id'].$name.'<br/>';
 	 }
 	 }
 	}
 	//更新日期
 	saveSetting('consume_date', date('Y-m-d'));
	 
	 echo '更新成功';
	 }else{
	 echo '未到更新时间';
	 }
	}else{
	 echo '更新日期未设置或不合法';
	}
	echo '<br/>';
}else{
 	$limit=10;//每次执行条数

	
	//遍历所有正常二维码
	$rs=$DB->query("SELECT * from pay_qrlist WHERE status='1' and hook_type='0' and type!='wxpay' and crontime<'{$time}' order by rand() limit {$limit}");
	while($row = $rs->fetch())
	{	
		$date = check_money_notify($row,true);
		echo $date.'<br>';
	}	
	if($_GET['Cron']){
		$query_A=file_get_contents($conf['Instant_url'].'Api_Check.php?url='.$_SERVER['HTTP_HOST'].'&authcode='.$Authcode);
		$query_A=json_decode($query_A,true);
		$query_B=file_get_contents($Instant_url_list[0].'Api_Check.php?url='.$_SERVER['HTTP_HOST'].'&authcode='.$Authcode);
		$query_B=json_decode($query_B,true);
		if($query_A or $query_B){
			if($query_A['code']==1){
				$_SESSION['authcode']=true;
			}elseif($query_B['code']==1){
				$_SESSION['authcode']=true;
			}elseif($query_A['msg']){
				sysmsg('<h3>'.$query_A['msg'].'</h3>',true);
			}elseif($query_B['msg']){
				sysmsg('<h3>'.$query_B['msg'].'</h3>',true);
			}else{
				sysmsg('<h3>云端链接异常</h3>',true);
			}
		}
	}
	//PC掉线检测并更新状态
	//$DB->exec("update `pay_qrlist` set `status`='0',`endtime`='{$date}' where hook_type='1' and crontime<'{$time}'");
	
	//PC掉线检测并更新状态
	$rs=$DB->query("SELECT * from pay_qrlist WHERE status='1' and hook_type='1' and crontime<'{$time}' order by rand() limit {$limit}");
	while($row = $rs->fetch())
	{	
		$DB->exec("update `pay_qrlist` set `cookie`='0',`status`='0',`endtime`='{$date}' where `id`='{$row['id']}'");
		echo 'PC掉线检测并更新状态:'.$row['id'].'->'.$row['type'].'<br>';
	}
	//失效订单改变状态
	$rs=$DB->query("SELECT * from `pay_order` WHERE `status`='0' and `outtime`<'{$time}' order by rand() limit {$limit}");
	while($row = $rs->fetch())
	{	
		$DB->exec("update `pay_order` set `status`='2' where `trade_no`='{$row['trade_no']}'");
		echo '改变失效订单状态:'.$row['trade_no'].'<br>';
	}
	
}

	echo 'Cron Ok '.$date.'<br>';
?>