■ ■ ■ ■ ■ ■
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 | | - | |
210 | | - | subscribe := model.NewMsgSubscribe(constant.ClusterOperator, constant.Cluster, cluster.ID) |
211 | | - | if err := tx.Create(&subscribe).Error; err != nil { |
212 | | - | tx.Rollback() |
213 | | - | } |
214 | | - | |
215 | 209 | | var user model.User |
216 | 210 | | db.DB.Model(&model.User{}).Where("name = admin").First(&user) |
217 | 211 | | |
| skipped 340 lines |