| | |
| | | |
| | | func InitTask() error { |
| | | s := gocron.NewScheduler(time.UTC) |
| | | _, err := s.Every(10).Seconds().StartImmediately().Do(func() { |
| | | _, err := s.Every(9).Seconds().StartImmediately().Do(func() { |
| | | plcConfig, code := service.NewDevicePlcService().GetDevicePlc() |
| | | if code != ecode.OK { |
| | | return |
| | | } |
| | | finishNumber, err := service.PlcRead(plcConfig, constvar.PlcStartAddressTypeFinishNumber) |
| | | if err == nil { |
| | | if err == nil && finishNumber != 0 { |
| | | service.PlcCacheSet(constvar.PlcCacheKeyFinishNumber, finishNumber) |
| | | } |
| | | logx.Infof("plc read finish number:%v, err:%v", finishNumber, err) |
| | |
| | | return err |
| | | } |
| | | |
| | | s.Every(59).Seconds().StartImmediately().Do(func() { |
| | | s.Every(60).Seconds().StartImmediately().Do(func() { |
| | | plcConfig, code := service.NewDevicePlcService().GetDevicePlc() |
| | | if code != ecode.OK { |
| | | return |
| | | } |
| | | totalNumber, err := service.PlcRead(plcConfig, constvar.PlcStartAddressTypeTotalNumber) |
| | | if err == nil { |
| | | if err == nil && totalNumber != 0 { |
| | | service.PlcCacheSet(constvar.PlcCacheKeyTotalNumber, totalNumber) |
| | | } |
| | | logx.Infof("plc read total number:%v, err:%v", totalNumber, err) |