■ ■ ■ ■ ■ ■
pkg/service/cluster_import.go
| skipped 205 lines |
| 206 | 206 | | if err := tx.Create(&subscribe).Error; err != nil { |
| 207 | 207 | | c.handlerImportError(tx, cluster, err) |
| 208 | 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 | + | } |
| 209 | 219 | | |
| 210 | 220 | | if err := c.projectResourceRepository.Create(model.ProjectResource{ |
| 211 | 221 | | ResourceID: cluster.ID, |
| skipped 330 lines |
