diff --git a/app/Http/Controllers/Api/ProjectController.php b/app/Http/Controllers/Api/ProjectController.php index c7611a60..a670b1c7 100755 --- a/app/Http/Controllers/Api/ProjectController.php +++ b/app/Http/Controllers/Api/ProjectController.php @@ -178,6 +178,12 @@ class ProjectController extends AbstractController $column['project_id'] = $project->id; ProjectColumn::createInstance($column)->save(); } + $dialog = WebSocketDialog::createGroup(null, $project->userid, 'project'); + if (empty($dialog)) { + throw new ApiException('创建项目聊天室失败'); + } + $project->dialog_id = $dialog->id; + $project->save(); }); // $data = Project::find($project->id); diff --git a/app/Models/Project.php b/app/Models/Project.php index aec43ed9..4ba078cb 100644 --- a/app/Models/Project.php +++ b/app/Models/Project.php @@ -165,26 +165,6 @@ class Project extends AbstractModel return $this->appendattrs['owner_userid']; } - /** - * @param $value - * @return int|mixed - */ - public function getDialogIdAttribute($value) - { - if ($value === 0 && $this->id) { - return AbstractModel::transaction(function() { - $this->lockForUpdate(); - $dialog = WebSocketDialog::createGroup(null, $this->relationUserids(), 'project'); - if ($dialog) { - $this->dialog_id = $dialog->id; - $this->save(); - } - return $dialog->id; - }); - } - return $value; - } - /** * @return \Illuminate\Database\Eloquent\Relations\HasMany */