提取pid更新

app/Console/Commands/Test.php

@@ -14,6 +14,7 @@ use App\Models\Es\MassMsgSendDetailEs;
 use App\Models\MassMsg;
 use App\Models\MassMsgSendDetail;
 use App\Models\MassPopularizData;
+use App\Models\MomentTask;
 use App\Models\MpPlayletTrendData;
 use App\Models\OfficialWebUserActionSetId;
 use App\Models\PlatformOrderConf;
@@ -675,7 +676,14 @@ class Test extends Command
 
     public function repairData()
     {
-        $listGenerator = $this->massGenerator();
+        $masslistGenerator = $this->massGenerator();
+        $this->repairData2($masslistGenerator);
+        $momelistGenerator = $this->momentGenerator();
+        $this->repairData2($momelistGenerator);
+    }
+
+    public function repairData2($listGenerator)
+    {
         foreach ($listGenerator as $list) {
             foreach ($list as $item) {
                 $dataJson = $item->attachments;
@@ -720,4 +728,28 @@ class Test extends Command
             $idMin = $list->max('id');
         }
     }
+
+    public function momentGenerator()
+    {
+        $limit = 500;
+        $idMin = 0;
+        $idMax = MomentTask::query()->where('is_draw', 1)->max('id');
+
+        while ($idMin < $idMax) {
+            $list = MomentTask::query()
+                ->where('is_draw', 1)
+                ->where('id', '>', $idMin)
+                ->where('id', '<=', $idMax)
+                ->orderBy('id', 'ASC')
+                ->limit($limit)
+                ->get();
+            $count = $list->count();
+            if ($count == 0) break;
+
+            yield $list;
+
+            if ($count < $limit) break;
+            $idMin = $list->max('id');
+        }
+    }
 }