| | |
|---|
| | | // @Tags Task |
|---|
| | | // @Summary 下发工艺参数（开始任务） |
|---|
| | | // @Produce application/json |
|---|
| | | // @Param id path int true "工序id" |
|---|
| | | // @Param object body request.SendProcessParams true "查询参数" |
|---|
| | | // @Success 200 {object} contextx.Response{service.GetProcessModel} "成功" |
|---|
| | | // @Router /v1/task/sendProcessParams/{id} [post] |
|---|
| | | func (slf *TaskApi) TaskStart(c *gin.Context) { |
|---|
| | | ctx, ok := contextx.NewContext(c, nil) |
|---|
| | | var params request.SendProcessParams |
|---|
| | | ctx, ok := contextx.NewContext(c, ¶ms) |
|---|
| | | if !ok { |
|---|
| | | return |
|---|
| | | } |
|---|
| | | idx := c.Param("id") |
|---|
| | | if idx == "" { |
|---|
| | | ctx.Fail(ecode.ParamsErr) |
|---|
| | | return |
|---|
| | | } |
|---|
| | | id := convertx.Atoi(idx) |
|---|
| | | taskService := service.NewTaskService() |
|---|
| | | procedure, code := taskService.GetProcedureById(id) |
|---|
| | | procedure, code := taskService.GetProcedureById(params.ProcedureId) |
|---|
| | | if code != ecode.OK { |
|---|
| | | ctx.Fail(code) |
|---|
| | | return |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | err = model.WithTransaction(func(db *gorm.DB) error { |
|---|
| | | err = taskService.UpdateProcedureStatus(db, id, model.ProcedureStatusProcessing) |
|---|
| | | err = taskService.UpdateProcedureStatus(db, params.ProcedureId, model.ProcedureStatusProcessing) |
|---|
| | | if err != nil { |
|---|
| | | return err |
|---|
| | | } |
|---|
