改成串行

zhangqian

2023-12-20 061c52572b3099cf5fee70245981804b9ca4bc6a

 crontask/cron_task.go

@@ -49,21 +49,7 @@
               _ = 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 {
         } else if addressItem.FieldName == constvar.PlcStartAddressTypeTotalNumber {
            value, err := service.PlcReadDirect(plcConfig, addressItem)
            if err != nil {
               logx.Infof("plc read total number err: %v", err)
@@ -75,9 +61,12 @@
            }
            logx.Infof("plc read total number: %v", totalNumber)
         }
      }

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

   if isMaster {
      s.Every(20).Seconds().Do(SyncProductionProgress) //同步生产数据