| | |
| | | import ( |
| | | "apsClient/constvar" |
| | | "apsClient/pkg/ecode" |
| | | "apsClient/pkg/logx" |
| | | "apsClient/service" |
| | | "github.com/go-co-op/gocron" |
| | | "time" |
| | |
| | | if err == nil { |
| | | service.PlcCacheSet(constvar.PlcCacheKeyFinishNumber, finishNumber) |
| | | } |
| | | logx.Infof("plc read finish number:%v, err:%v", finishNumber, err) |
| | | |
| | | }) |
| | | if err != nil { |
| | | return err |
| | | } |
| | | |
| | | s.Every(1).Minutes().StartImmediately().Do(func() { |
| | | s.Every(59).Seconds().StartImmediately().Do(func() { |
| | | plcConfig, code := service.NewDevicePlcService().GetDevicePlc() |
| | | if code != ecode.OK { |
| | | return |
| | |
| | | if err == nil { |
| | | service.PlcCacheSet(constvar.PlcCacheKeyTotalNumber, totalNumber) |
| | | } |
| | | logx.Infof("plc read total number:%v, err:%v", totalNumber, err) |
| | | }) |
| | | |
| | | s.StartAsync() |