xiaoyouyuan/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
{
    /**
     * 精秀支付订单支付状态查询
     * @return string|void
     */
    public function 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'])->inc('queue_times');
        // 查询订单是否支付成功
        $pay = new JingXiuPayUtil();
        if (!$pay->getOrder($order_info['pay_no'])){
            $this->error($pay->getMessage());
        }
        $params = $pay->getData();
        if (empty($params['order_status']) || $params['order_status'] != 'SUCCESS' || empty($params['out_trade_no'])) {
            return '支付信息有误';
        }
        // 开始处理业务逻辑
        $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 user_active(){
        $start_time = time() - (3600 * 3);
        $end_time = time() - (3600 * 1);

        $active = "select user_id from mt_user_active where requesttime BETWEEN {$start_time} and {$end_time}";
        $sql = "update `mt_user` set is_active = 0 where is_active = 1 and gender = 1 and id in ({$active})";
        if (!db()->query($sql)){
            return 0;
        }
        return 1;
    }
    //计划任务
    //代替公会的人10秒内发出五句话
    public function firstuser_send()
    {
        //找出24小时内注册的男人
        $map = [
            'jointime' => ['gt',time()-86400],
            'gender' => 1,
            'gh_id'  => 0,
            'auto_first_word' => 0,
        ];
        $oneuser = Db::name('user')->where($map)->order('id asc')->value('id');
        dump($oneuser);
        if(!$oneuser){
            echo 'empty';
            exit;
        }

        //找出公会的人
        $map = [
            'gh_id'  => ['gt',0],
            'gender' => 0,
        ];
        $ghuser = Db::name('user')->where($map)->orderRaw('rand()')->limit(5)->column('id');
        //dump($ghuser);

        //随机取出一句话
        $oneword = Db::name('plantask_accost')->orderRaw('rand()')->limit(5)->column('title');
        //dump($oneword);

        //发送出去
        $tenim = new \app\common\library\Tenim;
        for($i = 0;$i < 5;$i++){
            $ghuser_one  = isset($ghuser[$i])  ? $ghuser[$i]  : $ghuser[array_rand($ghuser)];
            $oneword_one = isset($oneword[$i]) ? $oneword[$i] : $oneword[array_rand($oneword)];
            $tenim->sendMessageToUser($ghuser_one,$oneuser,$oneword_one);
            sleep(2);
        }
        Db::name('user')->where('id',$oneuser)->update(['auto_first_word'=>1]);

    }
    //计划任务，二期之后，废弃
    //代替公会的人发出第一句话
    public function firstword_send()
    {
        exit;
        //找出24小时内注册的男人
        $map = [
            'jointime' => ['gt',time()-86400],
            'gender' => 1,
            'gh_id'  => 0,
        ];
        $oneuser = Db::name('user')->where($map)->orderRaw('rand()')->value('id');
        //dump($oneuser);

        //找出公会的人
        $map = [
            'gh_id'  => ['gt',0],
            'gender' => 0,
        ];
        $ghuser = Db::name('user')->where($map)->orderRaw('rand()')->value('id');
        //dump($ghuser);

        //随机取出一句话
        $oneword = Db::name('plantask_accost')->orderRaw('rand()')->value('title');
        //dump($oneword);

        //发送出去
        $cache = Cache::connect(['type'=>'Redis']);
        $times = $cache->get('plantask_first_word_'.$oneuser);
        //dump($times);

        if($times === false){
            $times = 0;
        }
        if($times < 5){
            $tenim = new \app\common\library\Tenim;
            $tenim->sendMessageToUser($ghuser,$oneuser,$oneword);
            $cache->set('plantask_first_word_'.$oneuser, $times + 1);
        }

    }

    //计划任务
    //清空没用的redis
    public function firstword_clear(){
        $map = [
            'jointime' => ['between',[time()-172800,time()-86400]],
            'gender' => 1,
            'gh_id'  => 0,
        ];
        $map = [];

        $userlist = Db::name('user')->where($map)->order('id asc')->column('id');

        if(empty($userlist)){
            echo 'empty';
            exit;
        }

        //清除
        $cache = Cache::connect(['type'=>'Redis']);
        foreach($userlist as $key => $val){
            $cache->rm('plantask_first_word_'.$val);
        }
    }

    //测试用
    //清空redis
    public function clear_redis(){
        $val = input('uid');
        $cache = Cache::connect(['type'=>'Redis']);
        $cache->rm('plantask_first_word_'.$val);
    }

    //发放代理奖励
    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;
    }

    /**
     * 超过24小时未上传头像的女用户隐身
     * @return void
     */
    public function userHide()
    {
        //找出24小时内注册未上传头像的女用户
        $userHideTime = config('site.user_hide_time');
        $joinTime = time() - ($userHideTime * 60);
        $girlAvatar = config('avatar_girl');
        $where = [
            'jointime' => ['lt',$joinTime],
            'gender' => 0,
            'avatar' => $girlAvatar,
            'status' => 1,
        ];
        $user = Db::name('user')->field('id')->where($where)->order('id asc')->select();
        if(empty($user)){
            echo 'empty';
            exit;
        }
        $userIds = array_column($user,'id');
        $updateWhere['id'] = ['in',$userIds];
        $countRes = Db::name('user')->where($updateWhere)->update(['status'=>2]);//隐藏
        echo 'update '.$countRes;
        exit;
    }

    /**
     * 五分钟禁用女用户账号
     * @return void
     */
    public function userClose()
    {
        $start_time = time() - (3600 * 27);
        $end_time = time() - (5 * 60);

        $where = [
            'gender' => 0,
            'is_closed' => 0,
            'status' => 1,
        ];

        $user = Db::name('user')->field('id')->whereBetween('jointime',[$start_time,$end_time])->where($where)->order('id asc')->select();
        if(empty($user)){
            echo 'empty';
            exit;
        }
        $userIds = array_column($user,'id');
        $updateWhere['id'] = ['in',$userIds];
        $updateWhere2['user_id'] = ['in',$userIds];
        $countRes = Db::name('user')->where($updateWhere)->update(['status'=>0,'is_closed'=>1]);//金庸
        $countRes2 = Db::name('user_token')->where($updateWhere2)->delete();//金庸
        echo 'update '.$countRes;
        echo 'delete '.$countRes2;
        exit;
    }

    /**
     * 自动推荐
     * @return void
     */
    public function 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 ';
        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;
    }
}