■ ■ ■ ■ ■ ■
pkg/service/cluster_import.go
| skipped 200 lines |
201 | 201 | | } |
202 | 202 | | } |
203 | 203 | | |
| 204 | + | subscribe := model.NewMsgSubscribe(constant.ClusterOperator, constant.Cluster, cluster.ID) |
| 205 | + | if err := tx.Create(&subscribe).Error; err != nil { |
| 206 | + | tx.Rollback() |
| 207 | + | } |
| 208 | + | |
| 209 | + | var user model.User |
| 210 | + | db.DB.Model(&model.User{}).Where("name = admin").First(&user) |
| 211 | + | |
| 212 | + | subscribeUser := model.MsgSubscribeUser{ |
| 213 | + | SubscribeID: subscribe.ID, |
| 214 | + | UserID: user.ID, |
| 215 | + | } |
| 216 | + | if err := tx.Create(&subscribeUser).Error; err != nil { |
| 217 | + | tx.Rollback() |
| 218 | + | } |
| 219 | + | |
204 | 220 | | if err := c.projectResourceRepository.Create(model.ProjectResource{ |
205 | 221 | | ResourceID: cluster.ID, |
206 | 222 | | ProjectID: project.ID, |
| skipped 324 lines |