szcollect_admin/application/index/controller/Test.php

<?php
/*
 * Created by PhpStorm.
 * User: mashouyi
 * Date: 2022-04-29 8:59
 */
namespace app\index\controller;

use app\common\library\AliPay;
use think\cache\driver\Redis;
use EasyWeChat\Factory;
use library\Controller;
use think\Db;
class Test extends Controller
{
    /*
     *
     * 创建用户新钱包地址
     *
     */
    public function createAddressAgain(){
        set_time_limit(0);
        $member = Db::name('store_member_copy')
//            ->where('id',100004)
            ->where('wallet_address','eq','')
//            ->whereNull('wallet_address')
            ->field('id,offline_account,phone,wallet_address')
            ->limit(30)
            ->order('id asc')
            ->select();
        foreach ($member as &$v){
            $offline_account = json_decode(getOfflineAccount(),true);
            $address = $offline_account['address'];
            $phone =$v['phone'];
            $phone .= rand(10000,99999);
            $url = "http://192.144.219.204:8083/ddc/createAddress?name=".$phone."&account=".$address;
            $res=curlRequest($url);
            $laddress = json_decode($res,true);
            if ($laddress['code']==0){
                $wallet_address = $laddress['data']['opbChainClientAddress'];
                Db::name('store_member_copy')
//                    ->whereNull('wallet_address')
                    ->where('id',$v['id'])
                    ->update(['wallet_address'=>$wallet_address,'offline_account'=>json_encode($offline_account,true),['again'=>1]]);
            }
        }
    }

    /*
     *
     * 重新铸造所有商品HASH
     *
     */
    public function castingNewHash(){
        set_time_limit(0);
        $redis = new Redis();
        $list = Db::name('store_order_info_copy')->whereIn('status',[1,3])->group('c_id')->field('c_id,count(distinct id) as count')->select();
        $id = 0;
        $set_count = 0;
        foreach($list as $k => $v) {
            $hash_again_count = $redis->get('hash_again_' . $v['c_id']);
            if($hash_again_count){
                $number = $v['count']+100;
                $redis->del('castingHash_' . $v['c_id']);
                $redis->Incrby('castingHash_' . $v['c_id'], $number);
                $count = $redis->get('castingHash_' . $v['c_id']);
                if ($count && $count > 0) {
                    $id = $v['c_id'];
                    $set_count = $count;
                    break;
                }
                if ($id) {
                    $redis = new Redis();
                    $nonce = $redis->get('nonce');
                    $address = '0xc472ec30ec813784b19872565e045c7153ea3f17';
                    $str = $id . rand(100000000, 999999999);
                    $url2 = "http://192.144.219.204:8083/ddc1155/safeMint?amount=$set_count&ddcURI=$str&nonce=$nonce&to=" . $address;
                    $res2 = curlRequest($url2);
                    $result = json_decode($res2, true);
                    if ($result['code']) {

                    } else {
                        $data['goods_id'] = $id;
                        $data['hash'] = $res2;
                        $data['nonce'] = $nonce;
                        $data['ddcURI'] = $str;
                        $data['amout'] = $set_count;
                        if (Db::name('hash2')->insert($data)) {
                            $redis->Incrby('hash_again_' . $id, 1);
                            $redis->set('nonce', $nonce + 1);
                            $redis->del('noncenx');
                            $redis->del('castingHash_' . $id);
                        }
                    }
                }
            }
        }
    }
    /*
     *
     * 修改藏品company_hash和ddcid
     *
     */
    public function getCompanyHash(){
        set_time_limit(0);
        Db::name('store_order_info_copy')
            ->whereIn('status','1,3')
            ->where('company_hash','eq','')
            ->chunk('20',function ($list){
                foreach($list as $k => &$v) {
                    $hash = Db::name('hash2')->where('goods_id',$v['c_id'])->field('hash,ddcid')->find();
                    if(!empty($hash)){
                        Db::name('store_order_info_copy')->where('id',$v['id'])->update(['company_hash'=>$hash['hash'],'ddcid'=>$hash['ddcid']]);
                    }
                }
            },'id','desc');
    }
    /**
     * 重新发放藏品hash（默认全部平台发放）
     */
    public function sendHashAgain(){
        set_time_limit(0);
        Db::name('store_order_info_copy')
            ->whereIn('status','1,3')
            ->where('company_hash','neq','')
            ->chunk('20',function ($list){
                $from = '0xc472ec30ec813784b19872565e045c7153ea3f17';
                $sender = '0xc472ec30ec813784b19872565e045c7153ea3f17';
                $privateKey = '0x831c68556c2c8aa8c4a5b175d157a6196ecf3384f61bfa05242565b919e3004f';
                $redis = new Redis();
                foreach ($list as &$v){
                    if ($v['status']==1){
                        $mid = $v['mid'];
                    }elseif ($v['status']==3){
                        //$from = Db::name('store_member')->where('id',$v['to_mid'])->value('wallet_address');
                        //获取用户钱包地址、私钥
//                        $from_mem = Db::name('store_member')->where('id',$v['to_mid'])->field('wallet_address,offline_account')->find();
//                        $from = $from_mem['wallet_address'];
//                        $offline_account = json_decode($from_mem['offline_account'],true);
//                        if(isset($offline_account['privateKey'])){
//                            $privateKey = $offline_account['privateKey'];
//                        }else{
//                            $privateKey = '';
//                        }

                        $mid = $v['to_mid'];
                    }
                    if (empty($from) || $from == ''){
                        continue;
                    }
                    if (empty($privateKey) || $privateKey == ''){
                        continue;
                    }
                    $to = Db::name('store_member')->where('id',$mid)->value('wallet_address');
                    if (empty($to) || $to == ''){
                        continue;
                    }

                    if ($this->redisNonceSetNx()){
                        $nonce = $redis->get('nonce');
                        $ddcid = $v['ddcid'];
                        //$url = "http://192.144.219.204:8083/ddc1155/safeTransferFrom?amount=1&ddcId=$ddcid&from=$from&nonce=$nonce&to=$to";
                        $url = "http://192.144.219.204:8083/ddc1155/safeTransferFrom?sender=$sender&from=$from&to=$to&ddcId=$ddcid&amount=1&nonce=$nonce&privateKey=$privateKey";
                        $res=curlRequest($url);
                        echo $res.'<br />';
                        $result=json_decode($res,true);
                        if($result['code']){
                            // $redis->set('nonce',$nonce+1);
                            // $redis->del('noncenx');
                            continue;
                        }else{


                            Db::name('store_order_info_copy')
                                ->where('id',$v['id'])
                                ->update(['collectors_hash2'=>$res,'collectors_hash_time'=>date('Y-m-d H:i:s')]);


                            $redis->set('nonce',$nonce+1);
                            $redis->del('noncenx');
                        }
                    }else{
                        echo 2222;
                    }

                }
            },'id','desc');
    }
}