update: rollback

app/Jobs/TrafficFetchJob.php

@@ -9,7 +9,6 @@ use Illuminate\Contracts\Queue\ShouldQueue;
 use Illuminate\Foundation\Bus\Dispatchable;
 use Illuminate\Queue\InteractsWithQueue;
 use Illuminate\Queue\SerializesModels;
-use Illuminate\Support\Facades\DB;
 
 class TrafficFetchJob implements ShouldQueue
 {
@@ -45,18 +44,14 @@ class TrafficFetchJob implements ShouldQueue
      */
     public function handle()
     {
-        $user = User::find($this->userId);
+        $user = User::lockForUpdate()->find($this->userId);
         if (!$user) return;
-        try {
+        
-            $user->update([
+        $user->t = time();
-                't' => time(),
+        $user->u = $user->u + $this->u;
-                'u' => DB::raw("u+{$this->u}"),
+        $user->d = $user->d + $this->d;
-                'd' => DB::raw("d+{$this->d}")
+        if (!$user->save()) throw new \Exception('流量更新失败');
-            ]);
-        } catch (\Exception $e) {
-            throw new \Exception('流量更新失败');
-        }
         $mailService = new MailService();
-        $mailService->remindTraffic($user->first());
+        $mailService->remindTraffic($user);
     }
 }

app/Models/ServerLog.php

@@ -13,8 +13,4 @@ class ServerLog extends Model
         'created_at' => 'timestamp',
         'updated_at' => 'timestamp'
     ];
-    protected $fillable = [
-        'u',
-        'd'
-    ];
 }

app/Models/User.php

@@ -13,9 +13,4 @@ class User extends Model
         'created_at' => 'timestamp',
         'updated_at' => 'timestamp'
     ];
-    protected $fillable = [
-        'u',
-        'd',
-        't'
-    ];
 }

app/Services/ServerService.php

@@ -9,7 +9,6 @@ use App\Models\Server;
 use App\Models\ServerTrojan;
 use App\Utils\CacheKey;
 use Illuminate\Support\Facades\Cache;
-use Illuminate\Support\Facades\DB;
 
 class ServerService
 {
@@ -269,18 +268,12 @@ class ServerService
             ->where('user_id', $userId)
             ->where('rate', $rate)
             ->where('method', $method)
+            ->lockForUpdate()
             ->first();
         if ($serverLog) {
-            try {
+            $serverLog->u = $serverLog->u + $u;
-                $serverLog->update([
+            $serverLog->d = $serverLog->d + $d;
-                    'u' => DB::raw("u+{$u}"),
+            return $serverLog->save();
-                    'd' => DB::raw("d+{$d}")
-                ]);
-                return true;
-            } catch (\Exception $e) {
-                info($e);
-                return false;
-            }
         } else {
             $serverLog = new ServerLog();
             $serverLog->user_id = $userId;