开始生产去掉时间未到限制

zhangqian

2024-04-16 8b6a262a56942a1a5764526f315029f1cd410ede

 api/v1/task.go

@@ -105,13 +105,12 @@
      return taskResponse.Tasks[i].Channel < taskResponse.Tasks[i].Channel
   })

   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 {
      if _, ok := flagMap[task.Channel]; !ok && !service.TaskFlagGet(conf.Conf.CurrentDeviceID, task.Channel) {
         task.CanStarted = true
         flagMap[task.Channel] = struct{}{}
      }
@@ -234,6 +233,7 @@
         ProductProcedureID: procedure.ProductProcedureID,
         IsProcessing:       false,
         IsFinish:           true,
         FinishedQuantity:   procedure.FinishedQuantity,
      }
      return service.NewTaskService().SaveTaskStatusSync(db, &record)
   })
@@ -244,8 +244,8 @@
      return
   }

   service.TaskFlagUnset(conf.Conf.CurrentDeviceID, procedure.Channel)
   service.TaskEndTimeSet(conf.Conf.CurrentDeviceID, procedure.Channel, time.Now().Unix()) //设置工序运行结束时间
   service.TaskFlagUnset(procedure.DeviceID, procedure.Channel)
   service.TaskEndTimeSet(procedure.DeviceID, procedure.Channel, time.Now().Unix()) //设置工序运行结束时间
   ctx.Ok()
}

@@ -310,8 +310,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 +330,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
      }
@@ -347,9 +349,9 @@
      return
   }

   service.TaskFlagSet(conf.Conf.CurrentDeviceID, procedure.Channel, int(procedure.ID))
   service.TaskStartTimeSet(conf.Conf.CurrentDeviceID, procedure.Channel, time.Now().Unix()) //设置工序运行开始时间
   service.TaskEndTimeSet(conf.Conf.CurrentDeviceID, procedure.Channel, 0)                   //设置工序运行结束时间
   service.TaskFlagSet(procedure.DeviceID, procedure.Channel, int(procedure.ID))
   service.TaskStartTimeSet(procedure.DeviceID, procedure.Channel, time.Now().Unix()) //设置工序运行开始时间
   service.TaskEndTimeSet(procedure.DeviceID, procedure.Channel, 0)                   //设置工序运行结束时间
   ctx.Ok()
}

@@ -427,7 +429,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++
@@ -505,10 +509,9 @@
      return
   }

   nowTs := time.Now().Unix()
   flagMap := make(map[int32]struct{}, 0)
   for _, task := range taskResponse.Tasks {
      if _, ok := flagMap[task.Channel]; !ok && !service.TaskFlagGet(conf.Conf.CurrentDeviceID, task.Channel) && task.Procedure.StartTime <= nowTs {
      if _, ok := flagMap[task.Channel]; !ok && !service.TaskFlagGet(conf.Conf.CurrentDeviceID, task.Channel) {
         task.CanStarted = true
         flagMap[task.Channel] = struct{}{}
      }