|
...
|
...
|
@@ -69,13 +69,13 @@ class CopyProject extends Command |
|
|
|
$item->status = NoticeLog::STATUS_FAIL;
|
|
|
|
$item->save();
|
|
|
|
}
|
|
|
|
try {
|
|
|
|
// try {
|
|
|
|
$this->copyMysql($old_project_id,$project_id);
|
|
|
|
$this->output('CopyProjectJob end, old project_id: ' . $old_project_id . ', new project_id: ' . $project_id);
|
|
|
|
}catch (\Exception $e){
|
|
|
|
echo $e->getMessage().PHP_EOL;
|
|
|
|
echo '复制数据库失败:'.$old_project_id . '<->'.$project_id;
|
|
|
|
}
|
|
|
|
// }catch (\Exception $e){
|
|
|
|
// echo $e->getMessage().PHP_EOL;
|
|
|
|
// echo '复制数据库失败:'.$old_project_id . '<->'.$project_id;
|
|
|
|
// }
|
|
|
|
//修改项目状态
|
|
|
|
$projectModel->edit(['delete_status'=>0],['id'=>$project_id]);
|
|
|
|
}
|
|
...
|
...
|
@@ -246,7 +246,7 @@ class CopyProject extends Command |
|
|
|
if (in_array($table, ['gl_customer_visit', 'gl_customer_visit_item', 'gl_inquiry_other', 'gl_inquiry_form_data', 'gl_inquiry_form'])) {
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
try {
|
|
|
|
// try {
|
|
|
|
// 4. 重新插入数据
|
|
|
|
DB::connection('custom_mysql')->table($table)->insertUsing(
|
|
|
|
[], // 插入所有列
|
|
...
|
...
|
@@ -255,9 +255,9 @@ class CopyProject extends Command |
|
|
|
$query->select('*')->from("{$name}");
|
|
|
|
}
|
|
|
|
);
|
|
|
|
}catch (\Exception $e){
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
// }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]);
|
...
|
...
|
|