fix sync_submit_task_distribution

@@ -73,24 +73,33 @@ class SyncSubmitTaskDistribution extends Command
         try {
         try {
             $table = (new SyncSubmitTaskModel())->getTable();
             $table = (new SyncSubmitTaskModel())->getTable();
             $new_table = $table . '_backup_' . date('Ymd');
             $new_table = $table . '_backup_' . date('Ymd');
-
+            if(Schema::hasTable($new_table)){
+                $new_table = $table . '_backup_' . date('YmdH');
+            }
             //重命名当前表
             //重命名当前表
             Schema::rename($table, $new_table);
             Schema::rename($table, $new_table);
             //克隆表数据
             //克隆表数据
             DB::statement('CREATE TABLE ' . $table . ' LIKE ' . $new_table);
             DB::statement('CREATE TABLE ' . $table . ' LIKE ' . $new_table);
 
 
             //未入队的写到新表
             //未入队的写到新表
-            $list = DB::table($new_table)->where('status', 0)->get();
-            $data = [];
-            foreach ($list as $task) {
-                $data[] = [
-                    'type' => $task->type,
-                    'data' => $task->data,
-                    'created_at' => $task->created_at,
-                    'updated_at' => $task->updated_at,
-                ];
+            $page = 1;
+            while (true){
+                $list = DB::table($new_table)->where('status', 0)->forPage($page, 5000)->get();
+                if(!count($list)){
+                    break;
+                }
+                $data = [];
+                foreach ($list as $task) {
+                    $data[] = [
+                        'type' => $task->type,
+                        'data' => $task->data,
+                        'created_at' => $task->created_at,
+                        'updated_at' => $task->updated_at,
+                    ];
+                }
+                $data && SyncSubmitTaskModel::insert($data);
+                $page++;
             }
             }
-            $data && SyncSubmitTaskModel::insert($data);
 
 
             DB::commit();
             DB::commit();