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

zhangqian

2023-08-25 48ef530180aeec4f91517e2b86ef75745c28241c

 api/v1/task.go

@@ -265,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 {
@@ -297,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