优化，防重复处理

app/Console/Commands/Plantask.php

@@ -51,13 +51,13 @@ class Plantask extends Command
             }
 
             //更新
-            $ids = array_column($list,'id');
+            /*$ids = array_column($list,'id');
 
             $update = [
                 'new_task_status' => 1,
             ];
 
-            DB::table('hx_gift_user_party')->whereIn('id',$ids)->update($update);
+            DB::table('hx_gift_user_party')->whereIn('id',$ids)->update($update);*/
         }
 
 

app/Jobs/GiftJob.php

@@ -81,7 +81,10 @@ class GiftJob implements ShouldQueue
     public function goaaa(){
         
         //
-        $data = DB::table('hx_gift_user_party')->where('id',$this->msgid)->first();
+        $data = DB::table('hx_gift_user_party')->where('id',$this->msgid)->where('new_task_status',0)->first();
+        if(empty($data)){
+            return true;
+        }
 
         DB::beginTransaction();
 
@@ -117,6 +120,14 @@ class GiftJob implements ShouldQueue
             }
         }
 
+        $update_data = ['new_task_status'=>1];
+        $rs_update = DB::table('hx_gift_user_party')->where('id',$this->msgid)->update($update_data);
+
+        if(!$rs_update){
+            Db::rollBack();
+            return false;
+        }
+
         Db::commit();
         return true;
     }