改成串行

zhangqian

2023-12-20 061c52572b3099cf5fee70245981804b9ca4bc6a

 crontask/cron_task.go

@@ -38,7 +38,7 @@
      }
      for _, addressItem := range plcConfig.Details {
         if addressItem.FieldName == constvar.PlcStartAddressTypeFinishNumber {
            value, err := service.PlcReadDirect(plcConfig, addressItem.StartAddress, addressItem.Length, addressItem.Type)
            value, err := service.PlcReadDirect(plcConfig, addressItem)
            if err != nil {
               logx.Infof("plc read finish number err: %v", err)
               continue
@@ -49,22 +49,8 @@
               _ = service.NewProgressService().UpdateProgress(conf.Conf.CurrentDeviceID, addressItem.Channel, finishNumber)
            }
            logx.Infof("plc read finish number: %v", finishNumber)
         }
      }

   })
   if err != nil {
      return err
   }

   s.Every(totalNumberTimeInterval).Seconds().Do(func() {
      plcConfig, code := service.NewDevicePlcService().GetDevicePlc()
      if code != ecode.OK {
         return
      }
      for _, addressItem := range plcConfig.Details {
         if addressItem.FieldName == constvar.PlcStartAddressTypeTotalNumber {
            value, err := service.PlcReadDirect(plcConfig, addressItem.StartAddress, addressItem.Length, addressItem.Type)
         } else if addressItem.FieldName == constvar.PlcStartAddressTypeTotalNumber {
            value, err := service.PlcReadDirect(plcConfig, addressItem)
            if err != nil {
               logx.Infof("plc read total number err: %v", err)
               continue
@@ -75,15 +61,18 @@
            }
            logx.Infof("plc read total number: %v", totalNumber)
         }
      }

      }
   })
   if err != nil {
      return err
   }

   if isMaster {
      s.Every(20).Seconds().Do(SyncProductionProgress) //同步生产数据
      //s.Every(30).Seconds().Do(SyncTaskStatus)         //同步任务状态
      s.Every(10).Seconds().Do(CheckNsqConn) //查询nsq连接
      s.Every(30).Seconds().Do(ReportData)   //上报数据
      s.Every(30).Seconds().Do(SyncTaskStatus)         //同步任务状态
      s.Every(10).Seconds().Do(CheckNsqConn)           //查询nsq连接
      s.Every(30).Seconds().Do(ReportData)             //上报数据
   }

   s.Every(20).Seconds().Do(QueryClusterStatus) //查询集群节点数量