jyblhdl_admin2/application/api/controller/Timedtask.php

<?php


namespace app\api\controller;
use AlibabaCloud\Client\AlibabaCloud;
use AlibabaCloud\Client\Exception\ClientException;
use AlibabaCloud\Client\Exception\ServerException;
use think\cache\driver\Redis;
use think\Db;
use think\Exception;

/**
 * @title 定时任务
 * Class Timedtask
 * @controller Timedtask
 * @group base
 */
class Timedtask
{


    public function test(){
        $redis = new Redis();
        //存入reids list
        $redis_data = ['hash'=>'bb476912415e6d5d43bc5d15036118fbbb44b3e3e768beb3ae7d625bfe080505','create_at'=>date('Y-m-d H:i:s')];
        $redis->rPush('collectionHash_12',json_encode($redis_data));
    }



    /**
     * @title 取消订单定时任务
     * @desc  未支付的自动取消
     * @author  Gavin
     * @url /api/Timedtask/cancelGoodsOrder
     * @method GET
     */
    public function cancelGoodsOrder(){
        $CancelTime = getCancelTime();
        if ($CancelTime<=0){
            die;
        }
        $redis = new Redis();
        $users = $redis->hkeys('buyUserInfo');
        if ($users){
            foreach ($users as &$value){
                $key = 'order_not_pay_'.$value;
                $len = $redis->hGetLen($key);
                if ($len){
                    $list = $redis->hGetvals($key);
                    foreach ($list as &$a){
                        $info = json_decode($a,true);
                        $cancel_time = strtotime($info['create_at'])+($CancelTime*60);
                        if ($cancel_time<time()){
                            $info['status'] = 2;
                            $info['cancel_at'] = date('Y-m-d H:i:s');
                            Db::name('store_order')->insert($info);
                            //加上库存
                            addCollectionInventory($info['c_id'],$info['num']);
                            //减少用户购买数量
                            DecrByCount($info['mid'],$info['c_id'],$info['num']);
                            //删除数据
                            $redis->hdel($key,$info['order_no']);
                        }
                    }
                }else{
                    $redis->hdel('buyUserInfo',$value);
                }
            }
        }
    }


    /**
     * @title 二级市场未支付的自动取消
     * @desc  二级市场未支付的自动取消
     * @author  Gavin
     * @url /api/Timedtask/SecondaryancelGoodsOrder
     * @method GET
     */
    public function SecondaryancelGoodsOrder(){
        $CancelTime = getCancelTime();
        if ($CancelTime<=0){
            die;
        }
        $list = Db::name('store_order_info_order')->where('status',0)->select();
        foreach ($list as &$v){
            $cancel_time = strtotime($v['create_at'])+($CancelTime*60);
            if ($cancel_time<time()){
                $info['status'] = 2;
                $info['cancel_at'] = date('Y-m-d H:i:s');
                Db::name('store_order_info_order')->where('id',$v['id'])->update($info);
            }
        }
    }

    /**
     * 藏品铸造hash 定时任务
     * @url /api/Timedtask/castingHash
     */
    public function castingHash(){
        set_time_limit(0);
        $redis = new Redis();
        $list = Db::name('store_collection')->where('is_deleted',0)->select();
        $id = 0;
        $set_count = 0;
        foreach ($list as &$v){
            $count = $redis->get('castingHash_'.$v['id']);
            if ($count && $count>0){
                $id = $v['id'];
                $set_count = $count;
                break;
            }
        }
        if ($id){
            if ($this->redisCreateSetNx($id)){
                for ($i=0;$i<$set_count;$i++){
                    if ($i<$set_count){
                        $url ="http://39.107.12.194:8088/creatGoods?commodityId=".$id;
                        $res=curlRequest($url);
                        $result=json_decode($res,true);
                        if (isset($result) && $result['code']=='200'){
                            $data['goods_id']=$id;
                            $data['hash']=$result['result']['hash'];
                            if (Db::name('hash')->insert($data)){
                                $redis->Decr('castingHash_'.$id);  //减一
                                //存入reids list
                                $redis_data = ['hash'=>$data['hash'],'create_at'=>date('Y-m-d H:i:s')];
                                $redis->rPush('collectionHash_'.$id,json_encode($redis_data));
                            }
                        }
                    }else{
                        $redis->del('hash_'.$id);
                    }
                }
            }
        }else{
            $redis->del('hash_'.$id);
        }

    }

    /**
     * 发放hash
     * @url /api/Timedtask/sendHash
     */
    public function sendHash(){
        set_time_limit(0);
        Db::name('store_order_info')
            ->whereNotNull('company_hash')
            ->whereIn('status','1,3')
            ->where('company_hash','neq','')
            ->where('collectors_hash','eq','')
            ->chunk(50,function ($list){
                foreach ($list as &$v){
                    if ($v['status']==1){
                        $from = 'wyg';
                    }elseif ($v['status']==3){
                        $from = Db::name('store_member')->where('id',$v['to_mid'])->value('accountName');
                    }

                    $to = Db::name('store_member')->where('id',$v['mid'])->value('accountName');
                    $url="http://39.107.12.194:8088/transfer?fromAccountName=$from&commodityHash=".$v['company_hash']."&toAccountName=".$to;
                    $res =curlRequest($url);
                    echo $res;
                    $result=json_decode($res,true);
                    if (isset($result) && $result['code']=='200'){
                        Db::name('store_order_info')->where('id',$v['id'])
                            ->update(['collectors_hash'=>$result['result']['hash'],'collectors_hash_time'=>date('Y-m-d H:i:s')]);
                    }
                }
        },'id','asc');
    }



    /**
     * @title 创建链账户
     * @desc  创建链账户
     * @author  Gavin
     * @url /api/Timedtask/createAddress
     * @method GET
     */
    public function createAddress(){
        set_time_limit(0);
        $member = Db::name('store_member')->where('wallet_address','eq','')->field('id,phone,wallet_address')->order('id asc')->limit(30)->select();
        foreach ($member as &$v){
            $phone = $v['phone'];
            $wallet_address = getWalletAddress($phone);
            //dump($wallet_address);
            if ($wallet_address){
                Db::name('store_member')->where('id',$v['id'])->update(['accountName'=>$phone,'wallet_address'=>$wallet_address]);
            }else{
                $phone = $v['phone'].rand(10000,99999);
                $wallet_address = getWalletAddress($phone);
                if ($wallet_address){
                    Db::name('store_member')->where('id',$v['id'])->update(['accountName'=>$phone,'wallet_address'=>$wallet_address]);
                }
            }
        }

    }

    /**
     * redis 加锁
     */
    function redisCreateSetNx($id){
        $redis = new Redis();
        $key = 'hash_'.$id;
        $exptime = 300;
        $is_lock = $redis->setnx($key,time()+$exptime);
        if ($is_lock){
            return true;
        }else{
            //加锁失败的情况下，判断锁是否已经存在，如果存在切已经过期，删除锁，重新加锁
            $val = $redis->get($key);
            if ($val && $val<time()){
                $redis->del($key);
            }
            return $redis->setnx($key,time()+$exptime);
        }
    }


}