package crontask import ( "apsClient/conf" "apsClient/constvar" "apsClient/pkg/ecode" "apsClient/pkg/logx" "apsClient/service" "github.com/go-co-op/gocron" "github.com/spf13/cast" "time" ) func InitTask() error { finishNumberTimeInterval := conf.Conf.PLC.FinishNumberTimeInterval totalNumberTimeInterval := conf.Conf.PLC.TotalNumberTimeInterval if finishNumberTimeInterval == 0 { finishNumberTimeInterval = 6 } if totalNumberTimeInterval == 0 { totalNumberTimeInterval = 60 } s := gocron.NewScheduler(time.UTC) _, err := s.Every(finishNumberTimeInterval).Seconds().StartImmediately().Do(func() { plcConfig, code := service.NewDevicePlcService().GetDevicePlc() if code != ecode.OK { return } finishNumber, err := service.PlcRead(plcConfig, constvar.PlcStartAddressTypeFinishNumber) if err == nil && finishNumber != 0 { service.PlcCacheSet(constvar.PlcCacheKeyFinishNumber, finishNumber) _ = service.NewProgressService().UpdateProgress(cast.ToInt64(finishNumber)) } logx.Infof("plc read finish number:%v, err:%v", finishNumber, err) }) if err != nil { return err } s.Every(totalNumberTimeInterval).Seconds().StartImmediately().Do(func() { plcConfig, code := service.NewDevicePlcService().GetDevicePlc() if code != ecode.OK { return } totalNumber, err := service.PlcRead(plcConfig, constvar.PlcStartAddressTypeTotalNumber) if err == nil && totalNumber != 0 { service.PlcCacheSet(constvar.PlcCacheKeyTotalNumber, totalNumber) } logx.Infof("plc read total number:%v, err:%v", totalNumber, err) }) s.StartAsync() return nil }