plc连接加入连接池并设置连接超时为5秒

zhangqian

2023-08-25 48ef530180aeec4f91517e2b86ef75745c28241c

 api/v1/task.go

@@ -23,6 +23,28 @@

type TaskApi struct{}

// TaskCountdown
// @Tags      Task
// @Summary   新任务倒计时
// @Produce   application/json
// @Success   200   {object}  contextx.Response{data=response.TaskCountdown}  "成功"
// @Router    /v1/task/countdown [get]
func (slf *TaskApi) TaskCountdown(c *gin.Context) {
   ctx, ok := contextx.NewContext(c, nil)
   if !ok {
      return
   }
   var resp response.TaskCountdown
   workOrder, err := service.NewTaskService().GetComingTask()
   if err == nil {
      seconds := workOrder.StartTime - time.Now().Unix()
      resp.CountDownHour = seconds / 3600
      resp.CountDownMinute = seconds % 3600 / 60
      resp.ShowCountDown = true
   }
   ctx.OkWithDetailed(resp)
}

// TaskGet
// @Tags      Task
// @Summary   获取任务
@@ -98,7 +120,7 @@
      OrderId:   procedure.OrderID,
      Product:   order.ProductName,
      Procedure: procedure.ProceduresInfo.ProcedureName,
      Device:    procedure.ProceduresInfo.DeviceName}, &result, time.Second*5)
      Device:    procedure.ProceduresInfo.DeviceName}, &result, time.Second*3)
   if err != nil {
      logx.Errorf("TaskStart GetProcessModel error:%v", err.Error())
      ctx.FailWithMsg(ecode.UnknownErr, "未获取到工艺参数")
@@ -194,7 +216,7 @@
      OrderId:   procedure.OrderID,
      Product:   order.ProductName,
      Procedure: procedure.ProceduresInfo.ProcedureName,
      Device:    procedure.ProceduresInfo.DeviceName}, &result, time.Second*5)
      Device:    procedure.ProceduresInfo.DeviceName}, &result, time.Second*3)
   if err != nil {
      logx.Errorf("SendProcessParams GetProcessModel error:%v", err.Error())
      ctx.FailWithMsg(ecode.UnknownErr, "未获取到工艺参数")
@@ -243,11 +265,10 @@
   if code != ecode.OK {
      return errors.New("请先配置PLC")
   }
   conn, err := plc.NewModbusConnection(fmt.Sprintf("%s:%v", plcConfig.Address, plcConfig.Port))
   conn, err := plc.GetModbusConnection(fmt.Sprintf("%s:%v", plcConfig.Address, plcConfig.Port))
   if err != nil {
      return errors.New(fmt.Sprintf("连接plc失败: %v", err.Error()))
   }
   defer conn.Close()

   logx.Info("----------------开始下发工艺参数-----------------")
   for k, v := range paramsMap {
@@ -275,11 +296,10 @@
   if code != ecode.OK {
      return errors.New("请先配置PLC")
   }
   conn, err := plc.NewModbusConnection(fmt.Sprintf("%s:%v", plcConfig.Address, plcConfig.Port))
   conn, err := plc.GetModbusConnection(fmt.Sprintf("%s:%v", plcConfig.Address, plcConfig.Port))
   if err != nil {
      return errors.New(fmt.Sprintf("连接plc失败: %v", err.Error()))
   }
   defer conn.Close()

   logx.Info("----------------开始下发工艺参数-----------------")
   var missNumbers int