Ken há 1 dia atrás
pai
commit
8092aa83de
2 ficheiros alterados com 8 adições e 12 exclusões
  1. 1 0
      app/Models/BaseModel.php
  2. 7 12
      app/Services/WalletService.php

+ 1 - 0
app/Models/BaseModel.php

@@ -13,6 +13,7 @@ use Carbon\Carbon;
  * @mixin Builder
  * @method static Builder|static where($column, $operator = null, $value = null, $boolean = 'and')
  * @method static Builder|static create($data)
+ * @method static Builder|static insert($array)
  *
  */
 class BaseModel extends Authenticatable

+ 7 - 12
app/Services/WalletService.php

@@ -22,6 +22,7 @@ use Telegram\Bot\Exceptions\TelegramSDKException;
  */
 class WalletService extends BaseService
 {
+    public static string $MODEL = Wallet::class;
 
     public static function init(Api $telegram, $data, $chatId, $firstName, $messageId, $callbackId): void
     {
@@ -111,7 +112,7 @@ class WalletService extends BaseService
      */
     public static function findOne(array $search): ?Wallet
     {
-        return self::model()::where(self::getWhere($search))->first();
+        return static::$MODEL::where(self::getWhere($search))->first();
     }
 
     /**
@@ -121,7 +122,7 @@ class WalletService extends BaseService
      */
     public static function findAll(array $search = [])
     {
-        return self::model()::where(self::getWhere($search))->get();
+        return static::$MODEL::where(self::getWhere($search))->get();
     }
 
     /**
@@ -132,7 +133,7 @@ class WalletService extends BaseService
     public static function paginate(array $search = [])
     {
         $limit = isset($search['limit']) ? $search['limit'] : 15;
-        $paginator = self::model()::where(self::getWhere($search))->paginate($limit);
+        $paginator = static::$MODEL::where(self::getWhere($search))->paginate($limit);
         return ['total' => $paginator->total(), 'data' => $paginator->items()];
     }
 
@@ -144,10 +145,7 @@ class WalletService extends BaseService
     public static function createVirtualWallets(int $memberId)
     {
         $coins = CoinService::findAll(['coin' => 'USDT']);
-
         $users = UserService::findOne(['member_id' => $memberId]);
-
-
        Log::error("WallerService");
        Log::error(json_encode($users));
         $walletsData = $coins->map(function ($coin) use ($memberId, $users) {
@@ -158,7 +156,6 @@ class WalletService extends BaseService
                 default:
                     $trons = [];
             }
-
             return [
                 'user_id' => $users['id'],
                 'member_id' => $memberId,
@@ -169,11 +166,9 @@ class WalletService extends BaseService
                 'available_balance' => 0,
                 'frozen_balance' => 0
             ];
-
         })->toArray();
-
         // 批量创建钱包以提高性能
-        self::model()::insert($walletsData);
+        static::$MODEL::insert($walletsData);
 
         // 活动
         // self::newUserRegisterActivity($memberId);
@@ -392,7 +387,7 @@ class WalletService extends BaseService
     {
         $remark = '由于系统漏洞,收益清除,28元指定大小单双玩法!10倍流水即可出款,违规没收';
 
-        $smallList = self::model()::where(function($query) {
+        $smallList = static::$MODEL::where(function($query) {
             $query->where('available_balance', '>', 0)
                   ->where('available_balance', '<', 28);
         })->take(100)->get();
@@ -409,7 +404,7 @@ class WalletService extends BaseService
         }
 
 
-        // $bigList = self::model()::where('available_balance', '>', 28)->get();
+        // $bigList = static::$MODEL::where('available_balance', '>', 28)->get();
         // foreach($bigList as $k => $v){
         //     $amount = ($v->available_balance - 28) * -1;