|
|
|
<?php
|
|
|
|
|
|
|
|
namespace App\Listeners;
|
|
|
|
|
|
|
|
use App\Events\CopyProject;
|
|
|
|
use App\Events\UpdateHtml;
|
|
|
|
use App\Jobs\updateHtmlJob;
|
|
|
|
use App\Models\Project\After;
|
|
|
|
use App\Models\Project\DeployBuild;
|
|
|
|
use App\Models\Project\DeployOptimize;
|
|
|
|
use App\Models\Project\Payment;
|
|
|
|
use App\Models\Project\Project;
|
|
|
|
use App\Models\Template\Setting;
|
|
|
|
use App\Models\User\User as UserModel;
|
|
|
|
use App\Services\ProjectServer;
|
|
|
|
use Hashids\Hashids;
|
|
|
|
use Illuminate\Contracts\Queue\ShouldQueue;
|
|
|
|
use Illuminate\Support\Facades\DB;
|
|
|
|
use Illuminate\Support\Facades\Schema;
|
|
|
|
|
|
|
|
class CopyProjectListener implements ShouldQueue
|
|
|
|
{
|
|
|
|
public function __construct()
|
|
|
|
{
|
|
|
|
//
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Handle the event.
|
|
|
|
*
|
|
|
|
* @param UpdateHtml $event
|
|
|
|
* @return void
|
|
|
|
*/
|
|
|
|
public function handle(CopyProject $event)
|
|
|
|
{
|
|
|
|
$this->param = $event->data;
|
|
|
|
$this->model = new Project();
|
|
|
|
DB::beginTransaction();
|
|
|
|
try {
|
|
|
|
//复制初始项目
|
|
|
|
$data = $this->model::where('id', $this->param['project_id'])->first();
|
|
|
|
$data = $data->getAttributes();
|
|
|
|
$type = $data['type'];
|
|
|
|
$data['type'] = 0;
|
|
|
|
$data['title'] = $data['title'].'-copy';
|
|
|
|
unset($data['id']);
|
|
|
|
$project_id = $this->model->insertGetId($data);
|
|
|
|
//复制部署表
|
|
|
|
$buildModel = new DeployBuild();
|
|
|
|
$buildData = $buildModel::where('project_id', $this->param['project_id'])->first();
|
|
|
|
if(!empty($buildData)){
|
|
|
|
$buildData = $buildData->getAttributes();
|
|
|
|
$buildData['project_id'] = $project_id;
|
|
|
|
$hashids = new Hashids('test_domain', 5, 'abcdefghjkmnpqrstuvwxyz1234567890');
|
|
|
|
$code = $hashids->encode($project_id);
|
|
|
|
$buildData['test_domain'] = 'https://v6-' . $code . '.globalso.site/';
|
|
|
|
unset($buildData['id']);
|
|
|
|
$buildModel->insert($buildData);
|
|
|
|
}
|
|
|
|
//复制优化表
|
|
|
|
$optimizeModel = new DeployOptimize();
|
|
|
|
$optimizeData = $optimizeModel::where('project_id', $this->param['project_id'])->first();
|
|
|
|
if(!empty($optimizeData)){
|
|
|
|
$optimizeData = $optimizeData->getAttributes();
|
|
|
|
unset($optimizeData['id'],$optimizeData['domain']);
|
|
|
|
$optimizeData['project_id'] = $project_id;
|
|
|
|
$optimizeModel->insert($optimizeData);
|
|
|
|
}
|
|
|
|
//复制付费表
|
|
|
|
$paymentModel = new Payment();
|
|
|
|
$paymentData = $paymentModel::where('project_id', $this->param['project_id'])->first();
|
|
|
|
if(!empty($paymentData)){
|
|
|
|
$paymentData = $paymentData->getAttributes();
|
|
|
|
unset($paymentData['id']);
|
|
|
|
$paymentData['project_id'] = $project_id;
|
|
|
|
$paymentModel->insert($paymentData);
|
|
|
|
}
|
|
|
|
//复制售后表
|
|
|
|
$afterModel = new After();
|
|
|
|
$afterData = $afterModel::where('project_id', $this->param['project_id'])->first();
|
|
|
|
if(!empty($afterData)){
|
|
|
|
$afterData = $afterData->getAttributes();
|
|
|
|
unset($afterData['id']);
|
|
|
|
$afterData['project_id'] = $project_id;
|
|
|
|
$afterModel->insert($afterData);
|
|
|
|
}
|
|
|
|
//复制用户
|
|
|
|
$userModel = new UserModel();
|
|
|
|
$userData = $userModel::where('project_id', $this->param['project_id'])->where('role_id',0)->first();
|
|
|
|
if(!empty($userData)){
|
|
|
|
$userData = $userData->getAttributes();
|
|
|
|
unset($userData['id']);
|
|
|
|
$userData['project_id'] = $project_id;
|
|
|
|
$userModel->insert($userData);
|
|
|
|
}
|
|
|
|
//复制设置的模版
|
|
|
|
$settingTemplateModel = new Setting();
|
|
|
|
$settingData = $settingTemplateModel::where('project_id', $this->param['project_id'])->first();
|
|
|
|
if(!empty($settingData)){
|
|
|
|
$settingData = $settingData->getAttributes();
|
|
|
|
unset($settingData['id']);
|
|
|
|
$settingData['project_id'] = $project_id;
|
|
|
|
$settingTemplateModel->insert($settingData);
|
|
|
|
}
|
|
|
|
DB::commit();
|
|
|
|
}catch (\Exception $e){
|
|
|
|
DB::rollBack();
|
|
|
|
$this->fail('error');
|
|
|
|
}
|
|
|
|
if($type != 0){
|
|
|
|
$this->copyMysql($this->param['project_id'],$project_id);
|
|
|
|
}
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
|
|
|
//复制数据库
|
|
|
|
public function copyMysql($project_id,$new_project_id){
|
|
|
|
//切换数据库配置
|
|
|
|
$project = ProjectServer::useProject($new_project_id);
|
|
|
|
//创建数据库
|
|
|
|
ProjectServer::createDatabase($project);
|
|
|
|
//创建表
|
|
|
|
$this->initTable($project_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) {
|
|
|
|
$has_table = Schema::connection('custom_mysql')->hasTable($table);
|
|
|
|
if (!$has_table) {
|
|
|
|
$sql = DB::connection('custom_tmp_mysql_copy')->select("SHOW CREATE TABLE {$table}");
|
|
|
|
DB::connection('custom_mysql')->statement(get_object_vars($sql[0])['Create Table']);
|
|
|
|
}
|
|
|
|
DB::connection('custom_mysql')->table($table)->truncate(); // 清空目标表数据
|
|
|
|
DB::connection('custom_mysql')->table($table)->insertUsing(
|
|
|
|
[], // 列名数组，留空表示插入所有列
|
|
|
|
function ($query) use ($table,$project_id) {
|
|
|
|
$name = 'gl_data_'.$project_id.'.'.$table;
|
|
|
|
$query->select('*')->from("{$name}");
|
|
|
|
}
|
|
|
|
);
|
|
|
|
if (Schema::connection('custom_mysql')->hasColumn($table, 'project_id')) {
|
|
|
|
DB::connection('custom_mysql')->table($table)->update(['project_id' => $news_project_id]);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
} |
...
|
...
|
|
