2022.05.01

application/api/controller/Login.php

@@ -44,6 +44,7 @@ class Login extends Base
      *
      */
     public function Register(){
+        $this->error('系统升级中...');
         $phone = input('phone');
         $ver_code = input('ver_code');
         $password = input('password');

application/api/controller/UserCenter.php

@@ -279,6 +279,7 @@ class UserCenter extends Base
      *
      */
     public function examples(){
+        $this->error('系统升级中...');
         $id = input('id');
         $phone = input('phone');
         $wallet_address = input('wallet_address');
@@ -674,6 +675,7 @@ class UserCenter extends Base
      * @return  name:pay type:string require:0 default:0 desc:支付信息
      */
     public function toRecharge(){
+        $this->error('系统升级中...');
         $data = $this->request->post();
         $param_arr = [
             'money'=>'请输入充值金额',

application/index/controller/Test.php

@@ -13,28 +13,177 @@ use library\Controller;
 use think\Db;
 class Test extends Controller
 {
-    public function index(){
-        $url2 = 'http://192.144.219.204:8083/ddc/official?address=0xde1e79a75e18ae997117706f938eb610cea283d9';
-        $res2=curlRequest($url2);
-        dump($res2);
-        die;
+    /*
+     *
+     * 创建用户新钱包地址
+     *
+     */
+    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]]);
+            }
+        }
     }
-    public function aaa(){
+
+    /*
+     *
+     * 重新铸造所有商品HASH
+     *
+     */
+    public function castingNewHash(){
+        set_time_limit(0);
         $redis = new Redis();
-        $nonce = $redis->get('nonce');
-        dump($nonce);
-        die;
-        $str='10-'.rand(100000000,999999999);
-        $address = '0xc472ec30ec813784b19872565e045c7153ea3f17';
-        $set_count = 2;
-        $url='http://192.144.219.204:8083/ddc1155/safeMint?to='.$address.'&ddcURI='.$str.'&nonce='.$nonce.'&amount='.$set_count;
-        $res=curlRequest($url);
-        dump($address);
-        dump($str);
-        dump($nonce);
-        dump($set_count);
-        dump($res);
-        $redis->set('nonce',$nonce+1);
-        $redis->del('noncenx');
+        $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');
     }
 }