yusheng-php/application/cron/controller/PerformPerSecond.php

<?php

namespace app\cron\controller;

use app\common\model\Redpacket;
use app\common\model\UserWallet;
use think\Cache;
use think\Db;
use Yzh\YunPay;

/*
 * 定时任务,每秒执行的方法
 */
class PerformPerSecond
{
    /*
         * 运行函数
         */
    function index()
    {
        echo  "拍卖房结束提醒：\n";
        $this->auction_end_notice();//拍卖房结束提醒
        echo "\n";

        echo "Pk房连线中倒计时结束操作PK结束：\n";
        $this->pk_start_end();
        echo "\n";

        echo "Pk房PK进行中倒计时结束操作PK结束：\n";
        $this->pk_end();
        echo "\n";

        echo "Pk房PK结束惩罚倒计时结束断开操作：\n";
        $this->pk_close();
        echo "\n";

        echo "pk发起10秒后无应答拒绝：\n";
        $this->pk_start_refuse();
        echo "\n";

        echo "房间红包清退：\n";
        $this->processExpiredRedpackets();
        echo "\n";

        echo "提现云账号订单状态查询：\n";
        $this->withdraw_order_status();
        echo "\n";

        echo "签约房时间结束处理：\n";
        $this->sign_room_time_end();
        echo "\n";

        echo "系统降身价：\n";
        $this->system_downgrade();
        echo "\n";

        echo "签约到期处理：\n";
        $this->sign_room_expire();
        echo "\n";

    }


    //拍卖房结束提醒
    protected function auction_end_notice()
    {
        $auction_list = db::name('vs_room_auction')->where(['status'=>2,'duration' => ['<',time()]])->select();
        $data_count = 0;
        if($auction_list){
            foreach ($auction_list as &$value){
                model('api/RoomAuction')->room_auction_end($value['room_id'],$value['auction_id']);
                $data_count++;
            }
        }
        echo "拍卖结束提醒完成-共" . $data_count . "条数据\n";
    }


    //pk发起10秒后无应答拒绝
    protected function pk_start_refuse()
    {
        $pk_list = db::name('vs_room_pk')->where(['status'=>1])->select();
        $data_count = 0;
        if($pk_list){
            foreach ($pk_list as &$value){
                if($value['createtime'] + 10 <= time()){
                    //pk发起10秒后无应答拒绝
                    model('api/RoomPk')->accept_pk($value['pk_id'],2);
                    $data_count++;
                }
            }
        }
        echo "pk发起10秒后无应答拒绝-共". $data_count . "条数据\n";
    }



    //Pk房连线中倒计时结束操作PK结束
    protected function pk_start_end()
    {
        $pk_list = db::name('vs_room_pk')->where(['status'=>2])->select();
        $data_count = 0;
        if($pk_list){
            foreach ($pk_list as &$value){
                if($value['updatetime'] + 300 <= time()){
                    //pk结束
                    model('api/RoomPk')->end_pk($value['pk_id'],4);
                }
                $data_count++;
            }
        }
        echo "Pk房连线中倒计时结束操作PK结束-共". $data_count . "条数据\n";
    }


    //Pk房PK进行中倒计时结束操作PK结束
    protected function pk_end()
    {
        $pk_list = db::name('vs_room_pk')->where(['status'=>3])->select();
        $data_count = 0;
        if($pk_list){
            foreach ($pk_list as &$value){
                if($value['start_time'] + $value['pk_times'] * 60 <= time()){
                    //pk结束
                    model('api/RoomPk')->end_pk($value['pk_id']);
                }
                $data_count++;
            }
        }
        echo "Pk房PK进行中倒计时结束操作PK结束-共". $data_count . "条数据\n";
    }


    //Pk房PK结束惩罚倒计时结束断开操作
    protected function pk_close()
    {
        $pk_list = db::name('vs_room_pk')->where(['status'=>['in',[4,7]]])->select();
        $data_count = 0;
        if($pk_list){
            foreach ($pk_list as &$value){
                if($value['updatetime'] + 300 <= time()){
                    //断开操作
                    model('api/RoomPk')->end_pk($value['pk_id'],2);
                }
                $data_count++;
            }
        }
        echo "Pk房PK结束惩罚倒计时结束断开操作-共". $data_count . "条数据\n";
    }
    /*
     * 提现云账号订单状态查询
     */
    public function withdraw_order_status(){
        //一个月内的数据
        $time = time() - 7 * 86400;
        $withdrawal = db::name('vs_user_withdrawal')->where(['deal_type'=>2,'status'=>['in',[4,5]]])->where(['submit_yun_time'=>['>=',$time]])->select();
        echo "提现云账号订单状态查询条数（".count($withdrawal)."）：\n";
        foreach ($withdrawal as $key => $value) {
            if($value['status'] == 5){
                if((time()-$value['pay_time']) >= 3600){
                    continue;
                }
            }
            if(in_array($value['yun_order_status'],[261,5077])){
                continue;
            }
            echo "提现订单查询：".$value['order_sn']."\n";
            $yun_pay = new YunPay($value['order_sn'], "", "", "", "","");
            $result = $yun_pay->queryOrder($value['type']);
            if($result['code'] == 1){
                if($result['data']['code']==0){
                    db::name('vs_user_withdrawal')->where('order_sn',$value['order_sn'])->update([
                        'status' => 6,
                        'pay_time' => time(),
                        'pay_message' => $result['data']['msg'],
                        'updatetime' => time(),
                        'yun_order_status' => $result['data']['code'],
//                        'personal_tax_rate' => $result['personal_tax_rate'] ?? 0,
                        'received_tax_amount' => $result['data']['received_tax_amount'] ?? 0,
                    ]);
                }else{
                    db::name('vs_user_withdrawal')->where('order_sn',$value['order_sn'])->update([
                        'status' => 5,
                        'pay_time' => time(),
                        'pay_message' => $result['data']['msg'],
                        'updatetime' => time(),
                        'yun_order_status' => $result['data']['code'],
//                        'personal_tax_rate' => $result['personal_tax_rate'] ?? 0,
                        'received_tax_amount' => $result['data']['received_tax_amount'] ?? 0,
                    ]);
                    if(in_array($result['data']['code'],[5077,261]) && $value['yun_order_status'] == null){
                        // if($result['data']['code']==5077 && $value['yun_order_status'] == null){
                        //该支付宝账户不存在或未开通手机号转账功能。如有疑问，请收款用户联系支付宝客服咨询。
                        //退还金币
                        $res = model('api/UserWithdrawal')->withdrawal_fail($value['order_sn']);
                        if($res){
                            echo "提现订单失败，退回金币成功\n";
                        }else{
                            echo "提现订单失败，退回金币失败：".$res['msg']."\n";
                        }
                    }
                }

                echo "提现订单查询成功：".$result['msg']."\n";
            }else{
                echo "提现订单查询失败：".$result['msg']."\n";
            }
        }
    }

    //房间火热值更新
    public function room_hot_update(){
        $room_id_list = db::name('vs_room_hot_value_log')->field('id,room_id')->select();
        $room_list = db::name('vs_room_hot_value_log')->field('room_id,sum(hot_value) as value')->group('room_id')->select();

        if($room_list){
            $data_count = 0;
            $data_room_list = [];
            foreach ($room_list as $value){
                $hot_value = 0;
                $hot_values = db::name('vs_room')->where('id',$value['room_id'])->field('hot_value,today_hot_value')->find();
                if($hot_values['today_hot_value'] == $value['value'] || $value['value'] == 0){
                    continue;
                }
                if($hot_values['today_hot_value'] < $value['value']){
                    $hot_value = $hot_values['hot_value'] + ($value['value'] - $hot_values['today_hot_value']);
                }
                if($hot_values['today_hot_value'] > $value['value']){
                    $hot_value = $hot_values['hot_value'];
                    $today_hot_value = $value['value'];
                }

                $res = db::name('vs_room')->where('id',$value['room_id'])->update([
                    'today_hot_value' => $today_hot_value,
                    'hot_value' => $hot_value,
                    'updatetime' => time()
                ]);
                if($res){
//                    db::name('vs_room_hot_value_log')->where('room_id',$value['room_id'])->delete();
                    $data_room_list[] =  $value['room_id'];
                }
                $data_count ++;
            }
            foreach ($room_id_list as $v){
                if(in_array($v['room_id'],$data_room_list)){
                    db::name('vs_room_hot_value_log')->where('id',$v['id'])->delete();
                }
            }
            echo "房间火热值更新操作-共". $data_count . "条数据\n";
        }
    }


    /**
     * 处理过期红包退款
     */
    public function processExpiredRedpackets()
    {
        $now = time();
        $processedCount = 0;

        // 1. 处理到时间的未开始红包，更新为进行中
        $pendingRedpackets = Db::name('redpacket')
            ->where('status', Redpacket::STATUS_PENDING)
            ->where('start_time', '<=', $now)
            ->select();

        foreach ($pendingRedpackets as $redpacket) {
            Db::name('redpacket')
                ->where('id', $redpacket['id'])
                ->update([
                    'status' => Redpacket::STATUS_ACTIVE,
                    'updatetime' => $now
                ]);

            // 更新Redis缓存
            $redis = Cache::store('redis')->handler();
            $redisKey = "redpacket:{$redpacket['id']}";
            $redis->hSet($redisKey, 'status', Redpacket::STATUS_ACTIVE);

            $processedCount++;
        }

        // 2. 处理已过期的进行中红包，更新为已结束并退款
        $expiredRedpackets = Db::name('redpacket')
            ->where('status', Redpacket::STATUS_ACTIVE)
            ->where('end_time', '<', $now)
            ->where('left_count', '>', 0)
            ->select();

        foreach ($expiredRedpackets as $redpacket) {
            Db::startTrans();
            try {
                // 退款给发红包用户
                if ($redpacket['left_amount'] > 0) {
                    // 更新用户钱包
                    $coinField = $redpacket['coin_type'] == 1 ? 'coin' : 'earnings';
                    //增加余额
                    $addres = Db::name('user_wallet')
                        ->where('user_id', $redpacket['user_id'])
                        ->inc($coinField, $redpacket['left_amount'])
                        ->update();
                    //记录用户金币日志
                    $data = [
                        'user_id' => $redpacket['user_id'],
                        'change_value' => $redpacket['left_amount'],
                        'room_id' => $redpacket['room_id'],
                        'money_type' => $redpacket['coin_type'],
                        //记录日志 32-发红包（金币），29-发红包（钻石），30-抢红包（金币），31-抢红包（钻石），33-红包剩余退回（金币），34-红包剩余退回（钻石）
                        'change_type' =>  $redpacket['coin_type'] == 1 ? 33 : 34,
                        'from_id' => $redpacket['room_id'],
                        'remarks' => '红包剩余退回',
                        'createtime' => time()
                    ];

                    $res = Db::name('vs_user_money_log')->insert($data);
                    if(!$res || !$addres){
                        Db::rollback();
                    }
                }

                // 更新红包状态为已结束
                Db::name('redpacket')
                    ->where('id', $redpacket['id'])
                    ->update([
                        'status' => Redpacket::STATUS_FINISHED,
                        'updatetime' => $now
                    ]);

                // 更新Redis缓存
                $redis = Cache::store('redis')->handler();
                $redisKey = "redpacket:{$redpacket['id']}";
                $redis->hSet($redisKey, 'status', Redpacket::STATUS_FINISHED);

                Db::commit();
                $processedCount++;
            } catch (\Exception $e) {
                Db::rollback();
                // 记录日志
                \think\Log::error("红包退款失败: {$redpacket['id']}, 错误: " . $e->getMessage());
            }
        }
        echo "处理过期红包-共". $processedCount . "条数据\n";
    }

    //签约房时间结束处理
    public function sign_room_time_end(){
        $res = Db::name('vs_room_sign')->where('sign_type',1)->select();
        if($res){
            foreach ($res as $value){
                if($value['end_time'] <= time()){
                    model('api/Sign')->end_sign(0,$value['room_id'],$value['id'],$value['sign_user_id'],0);
                }
            }
        }
        //签约到期
        $res1 = Db::name('vs_user_sign')->where(['end_time' => ['<=',time()]])->select();
        if($res1){
            foreach ($res1 as $value){
                //查找家族
                $myFamily = db::name('vs_family')
                    ->where(['user_id' => $value['sign_user_id'],'type' => 0,'pid' => $value['parent_user_id'],'deletetime' => 0])->find();
                if($myFamily){
                    $mySignFamily = db::name('vs_family')->where(['user_id' => $value['parent_user_id'],'type' => 1])->find();
                    //删除群成员
                    model('api/Tencent')->delete_group_member('f'.$mySignFamily['id'], $value['sign_user_id']);
                    //退出家族
                    db::name('vs_family')->where('id', $myFamily['id'])->update(['deletetime' => time()]);
                }
            }
        }
    }

    //系统降身价
    public function system_downgrade(){
        //获取系统信息
        $down_market_value = get_system_config_value('down_market_value');
        if($down_market_value){
            $day = $down_market_value[0];
            $market_value = $down_market_value[1];
        }else{
            $day = 0;
            $market_value = 0;
        }

        if($day && $market_value){
            //查询每个用户的身价
            $user_market_value = db::name('user')->field('id,market_value')->select();
            if($user_market_value){
                foreach ($user_market_value as $value){
                    if($value['market_value'] > 1){
                        //获取他的降级时间
                        $down_time = db::name('vs_user_market_value_log')->where(['user_id' => $value['id'],'type' =>1])
                            ->order('id desc')->value('createtime');

                        //如果没有降级记录，则使用当前时间作为起始时间
                        if(empty($down_time)){
                            $down_time = time();
                        }

                        //检查是否到了降级时间
                        if(time() - $down_time >= $day*86400){
                            //开始降身价
                            db::startTrans();
                            try {
                                $market_values = max($value['market_value'] - $market_value, 1);
                                $update_result = db::name('user')->where('id', $value['id'])->update(['market_value' => $market_values]);

                                if($update_result) {
                                    $data = [
                                        'user_id' => $value['id'],
                                        'before' => $value['market_value'],
                                        'change_value' => $market_value,
                                        'afterwards' => $market_values,
                                        'type' => 1,
                                        'createtime' => time()
                                    ];
                                    $res = db::name('vs_user_market_value_log')->insert($data);

                                    if($res){
                                        db::commit();
                                    }else{
                                        db::rollback();
                                        \think\Log::error("系统降身价失败: 插入日志失败 user_id={$value['id']}");
                                    }
                                } else {
                                    db::rollback();
                                    \think\Log::error("系统降身价失败: 更新用户身价失败 user_id={$value['id']}");
                                }
                            } catch (\Exception $e) {
                                db::rollback();
                                \think\Log::error("系统降身价异常: " . $e->getMessage() . " user_id={$value['id']}");
                            }
                        }
                    }
                }
            }
        }
    }

    public function sign_room_expire(){
        $res = Db::name('vs_room_sign')->where(['end_time' => ['>',time()],'status' => 1])->select();
        if($res){
            foreach ($res as $value){
                db::name('vs_room_sign')->where('id',$value['id'])->update(['status' => 2]);
                //处理家族
                $myFamily = db::name('vs_family')
                    ->where(['user_id' => $value['sign_user_id'],'type' => 0,'pid' => $value['parent_user_id'],'deletetime' => 0])->find();
                if($myFamily){
                    $mySignFamily = db::name('vs_family')->where(['user_id' => $value['parent_user_id'],'type' => 1])->find();
                    //删除群成员
                    model('api/Tencent')->delete_group_member('f'.$mySignFamily['id'], $value['sign_user_id']);
                    //退出家族
                    db::name('vs_family')->where('id', $myFamily['id'])->update(['deletetime' => time()]);
                }
            }
        }
    }

}