zhangqian
2023-12-20 1960a054785d1f81e69abe84b43073ed9df638e0
api/v1/task.go
@@ -234,6 +234,7 @@
         ProductProcedureID: procedure.ProductProcedureID,
         IsProcessing:       false,
         IsFinish:           true,
         FinishedQuantity:   procedure.FinishedQuantity,
      }
      return service.NewTaskService().SaveTaskStatusSync(db, &record)
   })
@@ -310,8 +311,14 @@
         processModelNumber = processModel.Number
      }
      fieldType := constvar.PlcStartAddressTypeTotalNumber
      for _, pc := range plcConfig.Details { //如果有写入地址,优先往写入地址写入,没有的话往读取地址写入
         if pc.FieldName == constvar.PlcStartAddressTypeTotalNumberWrite && pc.Channel == procedure.Channel {
            fieldType = constvar.PlcStartAddressTypeTotalNumberWrite
         }
      }
      plcConfig.CurrentTryTimes = 0
      err = service.PlcWrite(plcConfig, constvar.PlcStartAddressTypeTotalNumber, procedure.Channel, order.Amount.IntPart())
      err = service.PlcWrite(plcConfig, fieldType, procedure.Channel, order.Amount.IntPart())
      if err != nil {
         ctx.FailWithMsg(ecode.NeedConfirmedErr, "PLC请求失败,请检查PLC配置!")
         return
@@ -324,10 +331,6 @@
         return err
      }
      err = taskService.UpdateOrderStatus(db, order.ID, model.OrderStatusProcessing)
      if err != nil {
         return err
      }
      err = service.NewProgressService().Add(db, procedure, order)
      if err != nil {
         return err
      }
@@ -427,7 +430,9 @@
         logx.Errorf("miss param address, k:%v, v:%v", k, v)
         continue
      }
      err := service.PlcWriteDirect(plcConfig, address, v)
      err := service.PlcWriteDirect(plcConfig, v, &model.DevicePlcAddress{
         StartAddress: address,
      })
      if err != nil {
         plcConfig.CurrentErr = err
         failedNumbers++