改成串行

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) //同步生产数据