From 8324f872ef3a4d0c978a9b1d062800c6a1701c12 Mon Sep 17 00:00:00 2001 From: zhangqian <zhangqian@123.com> Date: 星期五, 01 十二月 2023 09:58:17 +0800 Subject: [PATCH] fix --- api/v1/task.go | 30 ++++++++++++++++-------------- 1 files changed, 16 insertions(+), 14 deletions(-) diff --git a/api/v1/task.go b/api/v1/task.go index afe8397..6729282 100644 --- a/api/v1/task.go +++ b/api/v1/task.go @@ -108,6 +108,9 @@ nowTs := time.Now().Unix() flagMap := make(map[int32]struct{}, 0) for _, task := range taskResponse.Tasks { + if task.Procedure.Status != model.ProcedureStatusWaitProcess { + continue + } if _, ok := flagMap[task.Channel]; !ok && !service.TaskFlagGet(conf.Conf.CurrentDeviceID, task.Channel) && task.Procedure.StartTime <= nowTs { task.CanStarted = true flagMap[task.Channel] = struct{}{} @@ -225,11 +228,13 @@ return err } record := model.TaskStatusSync{ - WorkOrderId: procedure.WorkOrderID, - ProcedureID: procedure.ProcedureID, - DeviceId: procedure.DeviceID, - IsProcessing: false, - IsFinish: true, + WorkOrderId: procedure.WorkOrderID, + ProcedureID: procedure.ProcedureID, + DeviceId: procedure.DeviceID, + ProductProcedureID: procedure.ProductProcedureID, + IsProcessing: false, + IsFinish: true, + FinishedQuantity: procedure.FinishedQuantity, } return service.NewTaskService().SaveTaskStatusSync(db, &record) }) @@ -323,16 +328,13 @@ if err != nil { return err } - err = service.NewProgressService().Add(db, procedure, order) - if err != nil { - return err - } record := model.TaskStatusSync{ - WorkOrderId: procedure.WorkOrderID, - ProcedureID: procedure.ProcedureID, - DeviceId: procedure.DeviceID, - IsProcessing: true, - IsFinish: false, + WorkOrderId: procedure.WorkOrderID, + ProcedureID: procedure.ProcedureID, + DeviceId: procedure.DeviceID, + ProductProcedureID: procedure.ProductProcedureID, + IsProcessing: true, + IsFinish: false, } return service.NewTaskService().SaveTaskStatusSync(db, &record) }) -- Gitblit v1.8.0