diff --git a/api/internal/logic/core/commitvmtasklogic.go b/api/internal/logic/core/commitvmtasklogic.go index 580dbf38..b3623fb3 100644 --- a/api/internal/logic/core/commitvmtasklogic.go +++ b/api/internal/logic/core/commitvmtasklogic.go @@ -161,23 +161,18 @@ func (l *CommitVmTaskLogic) CommitVmTask(req *types.CommitVmTaskReq) (resp *type Incident: "任务创建中", CreatedTime: time.Now(), } - - //db := tx.Table("task").Create(&taskModel) - db := tx.Table("task_vm").Create(&taskVm) - db = tx.Table("t_notice").Create(¬iceInfo) - if db.Error != nil { - logx.Errorf("Task creation failure, err: %v", db.Error) - } - //db = tx.Table("t_notice").Create(¬iceInfo) // Save task data to database + tf := l.svcCtx.DbEngin.Create(&taskModel) if tf.Error != nil { return nil, tf.Error } - //tn := l.svcCtx.DbEngin.Create(¬iceInfo) - //if tn.Error != nil { - // return nil, tn.Error - //} + result := l.svcCtx.DbEngin.Table("task_vm").Create(&taskVm) + result = l.svcCtx.DbEngin.Table("t_notice").Create(¬iceInfo) + if result.Error != nil { + logx.Errorf("Task creation failure, err: %v", result.Error) + } + resp.Code = 200 resp.Msg = "Success" return resp, nil