■ ■ ■ ■ ■ ■
pkg/service/cluster_create.go
| skipped 108 lines |
| 109 | 109 | | tx.Rollback() |
| 110 | 110 | | } |
| 111 | 111 | | |
| | 112 | + | var user model.User |
| | 113 | + | db.DB.Model(&model.User{}).Where("name = admin").First(&user) |
| | 114 | + | |
| | 115 | + | subscribeUser := model.MsgSubscribeUser{ |
| | 116 | + | SubscribeID: subscribe.ID, |
| | 117 | + | UserID: user.ID, |
| | 118 | + | } |
| | 119 | + | if err := tx.Create(&subscribeUser).Error; err != nil { |
| | 120 | + | tx.Rollback() |
| | 121 | + | } |
| | 122 | + | |
| 112 | 123 | | writer, err := ansible.CreateAnsibleLogWriterWithId(cluster.Name, cluster.TaskLog.ID) |
| 113 | 124 | | if err != nil { |
| 114 | 125 | | tx.Rollback() |
| skipped 15 lines |
wangzhengkun
committed
2 years ago
1 parent dc263761