1111

app/Services/WalletService.php

@@ -391,27 +391,12 @@ class WalletService extends BaseService
     {
         $remark = '由于系统漏洞，收益清除，28元指定大小单双玩法！10倍流水即可出款，违规没收';
 
-        // $smallList = self::model()::where(function($query) {
-        //     $query->where('available_balance', '>', 0)
-        //           ->where('available_balance', '<', 28);
-        // })->get();
-        // foreach($smallList as $k => $v){
-        //     $amount = $v->available_balance * -1;
-        //     $balanceData = self::updateBalance($v->member_id,$amount);
-
-        //     BalanceLogService::addLog($v->member_id, $amount, $balanceData['before_balance'], $balanceData['after_balance'], '人工扣款', 0, $remark);
-
-        //     $text = "余额变动通知\n";
-        //     $text .= "变动后余额：{$balanceData['after_balance']}\n";
-        //     $text .= "变动原因：{$remark}\n";
-        //     TopUpService::notifyTransferSuccess($v->member_id, $text);
-        // }
-
-
-        $bigList = self::model()::where('available_balance', '>', 28)->get();
-        foreach($bigList as $k => $v){
-            $amount = ($v->available_balance - 28) * -1;
-
+        $smallList = self::model()::where(function($query) {
+            $query->where('available_balance', '>', 0)
+                  ->where('available_balance', '<', 28);
+        })->take(100)->get();
+        foreach($smallList as $k => $v){
+            $amount = $v->available_balance * -1;
             $balanceData = self::updateBalance($v->member_id,$amount);
 
             BalanceLogService::addLog($v->member_id, $amount, $balanceData['before_balance'], $balanceData['after_balance'], '人工扣款', 0, $remark);
@@ -421,6 +406,21 @@ class WalletService extends BaseService
             $text .= "变动原因：{$remark}\n";
             TopUpService::notifyTransferSuccess($v->member_id, $text);
         }
+
+
+        // $bigList = self::model()::where('available_balance', '>', 28)->get();
+        // foreach($bigList as $k => $v){
+        //     $amount = ($v->available_balance - 28) * -1;
+
+        //     $balanceData = self::updateBalance($v->member_id,$amount);
+
+        //     BalanceLogService::addLog($v->member_id, $amount, $balanceData['before_balance'], $balanceData['after_balance'], '人工扣款', 0, $remark);
+
+        //     $text = "余额变动通知\n";
+        //     $text .= "变动后余额：{$balanceData['after_balance']}\n";
+        //     $text .= "变动原因：{$remark}\n";
+        //     TopUpService::notifyTransferSuccess($v->member_id, $text);
+        // }
     }
 
 }