■ ■ ■ ■ ■ ■
pkg/service/cluster_create.go
| skipped 109 lines |
| 110 | 110 | | } |
| 111 | 111 | | |
| 112 | 112 | | var user model.User |
| 113 | | - | db.DB.Model(&model.User{}).Where("name = admin").First(&user) |
| | 113 | + | _ = db.DB.Model(&model.User{}).Where("name = 'admin'").First(&user).Error |
| 114 | 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() |
| | 115 | + | if user.ID != "" { |
| | 116 | + | subscribeUser := model.MsgSubscribeUser{ |
| | 117 | + | SubscribeID: subscribe.ID, |
| | 118 | + | UserID: user.ID, |
| | 119 | + | } |
| | 120 | + | if err := tx.Create(&subscribeUser).Error; err != nil { |
| | 121 | + | tx.Rollback() |
| | 122 | + | } |
| 121 | 123 | | } |
| 122 | 124 | | |
| 123 | 125 | | writer, err := ansible.CreateAnsibleLogWriterWithId(cluster.Name, cluster.TaskLog.ID) |
| skipped 17 lines |
