package crontask
|
|
import (
|
"apsClient/conf"
|
"apsClient/constvar"
|
"apsClient/pkg/ecode"
|
"apsClient/pkg/logx"
|
"apsClient/service"
|
"github.com/go-co-op/gocron"
|
"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)
|
}
|
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
|
}
|
