1

application/api/controller/Pay.php

@@ -939,39 +939,38 @@ class Pay extends Api
         $time = strtotime("-1 hours", time());
         $user_address = Db::name('user_usdt_address')->where('last_recharge', '>', $time)->order('last_recharge desc')->select();
         foreach ($user_address as $k => $v) {
-
+            $user_info = Db::name('user')->where('id', $v['uid'])->find();
 //            trx部分
-                $service = TronService::instance('usdt');
-                $info = $service->getTransfer($user_address['trx_address'], $user_address['last_time']);
+            $service = TronService::instance('usdt');
+            $info = $service->getTransfer($user_address['trx_address'], $user_address['last_time']);
 
 //                bsc部分
-                $service = Web3Service::instance('bsc', 'usdt', '');
-//                $info =$service->getLastTransfer([], [$user_address['bsc_address']], $v['add_time']);
-//                $info =$service->getLastTransfer([], ['0x8f5f8daC38461E5b1A6b230D30433f8A593CCD57'], 1748315888);
-                $info = $service->getLastTransfer([], [$user_address['bsc_address']], $user_address['last_time']);
-                foreach ($info as $k2 => $v2) {
-                    $value = $v2->params['value']->toString();  //金额
-                    $value2 = bcdiv($value, bcpow(10, get_token_info('bsc', 'USDT', 'decimal')), 12);
-                    $transactionHash = $v->transactionHash;
-                    $be = DB::name('user_recharge')->where('hash', $transactionHash)->find();
-                    if ($be) {  //hash重复
-                        continue;
-                    }
-                    $number = date('ymdh', time()) . rand(10000, 99999);//订单编号
-                    $data = [
-                        'order_id' => $number,
-                        'uid' => $v['uid'],
-                        'paid' => 1,
-                        'price' => $value2,
-                        'transactionHash' => $transactionHash,
-                        'pay_time' => time(),
-                        'add_time' => time()
-                    ];
-                    Db::name('user_recharge')->insert($data);
+            $service = Web3Service::instance('bsc', 'usdt', '');
+            $info = $service->getLastTransfer([], [$user_address['bsc_address']], $user_address['last_time']);
+            foreach ($info as $k2 => $v2) {
+                $value = $v2->params['value']->toString();  //金额
+                $value2 = bcdiv($value, bcpow(10, get_token_info('bsc', 'USDT', 'decimal')), 12);
+                $transactionHash = $v->transactionHash;
+                $be = DB::name('user_recharge')->where('hash', $transactionHash)->find();
+                if ($be) {  //hash重复
+                    continue;
                 }
-            Db::name('user_usdt_address')->where('uid',$v['uid'])->update(['last_time' => time()]);
-
-
+                $number = date('ymdh', time()) . rand(10000, 99999);//订单编号
+                $data = [
+                    'order_id' => $number,
+                    'uid' => $v['uid'],
+                    'paid' => 1,
+                    'price' => $value2,
+                    'transactionHash' => $transactionHash,
+                    'pay_time' => time(),
+                    'add_time' => time()
+                ];
+                Db::name('user_recharge')->insert($data);
+            }
+            Db::name('user_usdt_address')->where('uid', $v['uid'])->update(['last_time' => time()]);
+            $money = bcadd($user_info['money'], $value2, 18);
+            Db::name('user')->where('id', $v['uid'])->update(['money' => $money]);
+            MoneyLog::create(['user_id' => $v['uid'], 'money' => $value2, 'before' => $user_info['money'], 'after' => $money, 'memo' => '用户余额充值']);
 
             sleep(60);
         }