| | |
|---|
| | | 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{}{} |
|---|
| | |
|---|
| | | ctx.Fail(code) |
|---|
| | | return |
|---|
| | | } |
|---|
| | | if procedure.DeviceID != conf.Conf.CurrentDeviceID { |
|---|
| | | ctx.FailWithMsg(ecode.ParamsErr, "该任务不属于当前设备") |
|---|
| | | return |
|---|
| | | } |
|---|
| | | order, err := taskService.GetOrderByWorkOrderId(procedure.WorkOrderID) |
|---|
| | | if err != nil { |
|---|
| | | ctx.Fail(ecode.UnknownErr) |
|---|
| | |
|---|
| | | |
|---|
| | | var processModelNumber string |
|---|
| | | plcConfig, code := service.NewDevicePlcService().GetDevicePlc() |
|---|
| | | if code == ecode.OK && plcConfig.ID != 0 { |
|---|
| | | if code == ecode.OK && plcConfig.ID != 0 && len(plcConfig.Details) > 0 { |
|---|
| | | plcConfig.MaxTryTimes = 2 |
|---|
| | | device, err := service.GetCurrentDevice() |
|---|
| | | if err != nil { |
|---|
