lejian/application/index/controller/Plantask.php

<?php

namespace app\index\controller;

use app\utils\JingXiu\JingXiuPayUtil;
use think\Controller;
use think\Db;
use think\Cache;

class Plantask extends Controller
{
    //精秀支付订单支付状态查询。 一分钟一次
    public function auto_pay_queue()
    {
        // 处理次数
        $queue_times = 6;
        //查询订单信息 十分钟未处理的
        $order_info = Db::name('pay_order')
            ->where('queue_status', 1)
            ->where('status',0)
            ->where('queue_times','<',$queue_times)
            ->where('createtime','<',time() - 600)
            ->order('queue_times','asc')
            ->find();
        if (!$order_info){
            return '无订单';
        }
        // 增加处理次数
        Db::name('pay_order')->where('id',$order_info['id'])->update(['queue_times' => $order_info['queue_times'] + 1]);
        // 查询订单是否支付成功
        $pay = new JingXiuPayUtil();
        if (!$pay->getOrder($order_info['pay_no'])){
            $this->error($pay->getMessage());
        }
        //PROCESSING=订单待支付，SUCCESS=订单支付成功，TIME_OUT=订单已过期，FAIL=订单支付失败，CLOSE=订单关闭,CALL_FAIL=支付成功未返回
        $params = $pay->getData();
        if (empty($params['order_status']) || $params['order_status'] != 'SUCCESS' || empty($params['out_trade_no'])) {
            $status = $params['order_status'] ?? 'error';
            return '支付信息有误'.$status.':'.$params['out_trade_no'];
        }
        // 开始处理业务逻辑
        $pay_no = $params['out_trade_no'];
        //查询订单信息
        $order_info = Db::name('pay_order')->where('pay_no', $pay_no)->find();
        if (!$order_info) {
            return '订单信息不存在'.$pay_no;
        }
        if ($order_info['status'] == 3){
            return '订单信息_已删除'.$pay_no;
        }
        if ($order_info['status'] == 1 || $order_info['status'] == 2) {
            return '充值入账更新余额失败_status已更新过'.$pay_no;
        }

        $extendType = '';
        //区分vip 还是 冲金币
        $is_g = stripos($pay_no, 'P');
        if ($is_g !== false) {
            $extendType = 'gold';
        } else {
            $is_v = stripos($pay_no, 'V');
            if ($is_v !== false) {
                $extendType = 'vip';
            }
        }

        //status已更新过
        $result = Db::name('pay_order')->where('pay_no', $pay_no)->where('status',$order_info['status'])->setField(['status' => 2]);
        if (!$result) {
            return '充值入账更新余额失败_status更新状态2不成功'.$pay_no;
        }

        //你可以在此编写订单逻辑
        $payEvent = Db::name('pay_event')->where('pay_no', $pay_no)->find();
        $args = json_decode($payEvent['args'] ?? '', true);
        $rechargeM = new \app\common\model\Recharge();
        if ($extendType == 'gold') {
            $payRes = $rechargeM->goldpaysucc($pay_no, $args);
            $payTypeStr = '充值';
        } elseif ($extendType == 'vip') {
            $payRes = $rechargeM->vippaysucc($pay_no, $args);
            $payTypeStr = 'vip';
        } else {
            $payRes = false;
            $payTypeStr = '未知支付类型';
        }
        if (!$payRes) {
            return '更新失败'.$payTypeStr.$pay_no;
        }

        return '订单处理成功'.$payTypeStr.$pay_no;
    }


    //定时跑用户活跃，改成离线。 一分钟一次
    public function auto_user_active(){
        $actitime = time() - 7200;

        $sql = 'update `mt_user` set is_active = 0 where is_active = 1 and id in (select user_id from mt_user_active where requesttime < '.$actitime.')';
        db()->query($sql);
    }

    //发放代理奖励
    public function issuingreward() {
        set_time_limit(0);

        //本周开始时间
        $week_start_time = strtotime(date('Y-m-d')) - ((date('w')==0?7:date('w'))-1)*86400;
        $where['user_id'] = ['gt', 0];
        $where['issuingtime'] = ['elt', $week_start_time];

        $mt_admin = Db::name('admin');
        $list = $mt_admin->field('id, user_id, issuingtime')->where($where)->limit(100)->select();

        if (!$list) {
            echo 'mei shu ju';
            die;
        }

        //上周开始时间 上周结束时间
        $starttime = $week_start_time - 604800;
        $endtime = $week_start_time - 1;

        $money_map['log_type'] = ['in', [21, 22, 23, 54, 60, 82]];
        $money_map['createtime'] = ['between', [$starttime, $endtime]];

        $mt_user_money_log = Db::name('user_money_log');
        $mt_user = Db::name('user');
        $mt_extend_reward = Db::name('extend_reward');
        $issuingtime = time();
        foreach ($list as $k => &$v) {
            //开启事务
            Db::startTrans();
            //修改记录状态
            $rs = $mt_admin->where(['id' => $v['id'], 'issuingtime' => $v['issuingtime']])->setField('issuingtime', $issuingtime);
            if (!$rs) {
                Db::rollback();
                continue;
            }

            $user_ids = $mt_user->where(['intro_uid' => $v['user_id']])->column('id');
            if ($user_ids) {
                $money_map['user_id'] = ['in', $user_ids];
                //周收益
                $week_sum_money = $mt_user_money_log->where($money_map)->sum('change_value');
                $week_sum_money = $week_sum_money > 0 ? $week_sum_money : 0;
                if ($week_sum_money) {
                    //查询推广奖励等级
                    $extend_reward_info = $mt_extend_reward->where(['total_flow' => ['elt', $week_sum_money]])->order('id desc')->find();
                    if ($extend_reward_info) {
                        //额外提成
                        $extra_moeny = number_format($week_sum_money * $extend_reward_info['extra_reward'] / 100, 2, '.', '');
                        if ($extra_moeny > 0) {
                            //发放额外提出
                            $wallet_rs = model('wallet')->lockChangeAccountRemain($v['user_id'],0,'money',$extra_moeny,91,'额外提成奖励');
                            if($wallet_rs['status'] === false){
                                Db::rollback();
                            } else {
                                //发送系统消息
                                \app\common\model\Message::addMessage($v['user_id'],'额外提成奖励','上周额外提成奖励已经发放');
                            }
                        }
                    }
                }
            }

            Db::commit();
        }

        echo 'wan bi';
        die;
    }



    //自动推荐。 一分钟一次
    public function auto_userRecommend()
    {
        $payMoney = config('site.recommend_pay_money');//财富值
        $getMoney = config('site.recommend_get_money');//魅力值
        if ($payMoney <= 0 && $getMoney <= 0) {
            echo 'empty';exit;
        }
        $where = 'u.is_recommend = 0 ';
        $whereAppend = '';
        if ($payMoney > 0) {
            $whereAppend = $where.' and uw.pay_money >= '.$payMoney;
        }
        if ($getMoney > 0) {
            $whereAppend = $where.' and uw.get_money >= '.$getMoney;
        }
        if ($payMoney >0 && $getMoney >0) {
            $whereAppend = $where. ' and (uw.pay_money >= '.$payMoney.' or uw.get_money >= '.$getMoney.')' ;
        }

        $user = Db::name('user')->alias('u')->field('u.id')
            ->join('user_wallet uw','uw.user_id = u.id','LEFT')
            ->where($whereAppend)
            ->select();

        if (empty($user)) {
            echo 'update 0';exit;
        }
        $userIds = array_column($user,'id');
        $userWhere['id'] = ['in',$userIds];
        $userUpdateData['is_recommend'] = 1;
        $userUpdateData['updatetime'] = time();
        $userRes = Db::name('user')->where($userWhere)->update($userUpdateData);
        echo 'update '.$userRes;exit;
    }
}