🤬
  • ■ ■ ■ ■ ■ ■
    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
Please wait...
Page is in error, reload to recover