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
{
    /**
     * @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);
                }
            }
        }
    }

    /**
     * 藏品铸造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){
            for ($i=0;$i<$set_count;$i++){
                $url ="http://47.111.246.47: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));
                    }
                }
            }
        }

    }

    /**
     * 发放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('20',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://47.111.246.47:8088/transfer?fromAccountName=$from&commodityHash=".$v['company_hash']."&toAccountName=".$to;
                    $res =curlRequest($url);
                    $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','desc');
    }



    /**
     * @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($laddress);
            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]);
                }
            }
        }

    }


}