gxai

@@ -20,6 +20,7 @@ use App\Models\User\User as UserModel;
 use App\Services\ProjectServer;
 use Hashids\Hashids;
 use Illuminate\Console\Command;
+use Illuminate\Support\Facades\Artisan;
 use Illuminate\Support\Facades\DB;
 use Illuminate\Support\Facades\Log;
 use Illuminate\Support\Facades\Schema;
@@ -205,62 +206,13 @@ class CopyProject extends Command
     }
     //复制数据库
     public function copyMysql($project_id,$new_project_id){
-        //切换数据库配置
-        $project = ProjectServer::useProject($new_project_id);
-        //创建数据库
-        ProjectServer::createDatabase($project);
-        //创建表
-        $this->initTable($project_id,$new_project_id);
+        Artisan::call("php artisan copy_project_s $project_id $new_project_id");
         //修改项目状态
         $projectModel = new Project();
         $projectModel->edit(['delete_status'=>0],['id'=>$new_project_id]);
     }
 
     /**
-     * @remark :创建数据库
-     * @name   :initTable
-     * @author :lyh
-     * @method :post
-     * @time   :2023/12/11 10:09
-     */
-    public function initTable($project_id, $news_project_id)
-    {
-        // 设置源数据库
-        config(['database.connections.custom_tmp_mysql_copy.database' => 'gl_data_' . $project_id]);
-        $database_name = DB::connection('custom_tmp_mysql_copy')->getDatabaseName();
-        // 获取源数据库的所有表
-        $tables = Schema::connection('custom_tmp_mysql_copy')->getAllTables();
-        $tables = array_column($tables, 'Tables_in_' . $database_name);
-        foreach ($tables as $table) {
-            // 1. 删除目标数据库中的表
-            DB::connection('custom_mysql')->statement("DROP TABLE IF EXISTS {$table}");
-            // 2. 重新创建表
-            $sql = DB::connection('custom_tmp_mysql_copy')->select("SHOW CREATE TABLE {$table}");
-            DB::connection('custom_mysql')->statement(get_object_vars($sql[0])['Create Table']);
-            // 3. 跳过指定的表
-            if (in_array($table, ['gl_customer_visit', 'gl_customer_visit_item', 'gl_inquiry_other', 'gl_inquiry_form_data', 'gl_inquiry_form'])) {
-                continue;
-            }
-            try {
-                // 4. 重新插入数据
-                DB::connection('custom_mysql')->table($table)->insertUsing(
-                    [], // 插入所有列
-                    function ($query) use ($table, $project_id) {
-                        $name = 'gl_data_' . $project_id . '.' . $table;
-                        $query->select('*')->from("{$name}");
-                    }
-                );
-            }catch (\Exception $e){
-                continue;
-            }
-            // 5. 更新 project_id（如果存在）
-            if (Schema::connection('custom_mysql')->hasColumn($table, 'project_id')) {
-                DB::connection('custom_mysql')->table($table)->update(['project_id' => $news_project_id]);
-            }
-        }
-        return true;
-    }
-    /**
      * @param $message
      * @return bool
      */