package crontask
|
|
import (
|
"apsClient/constvar"
|
"apsClient/pkg/ecode"
|
"apsClient/service"
|
"github.com/go-co-op/gocron"
|
"time"
|
)
|
|
func InitTask() error {
|
s := gocron.NewScheduler(time.UTC)
|
_, err := s.Every(2).Seconds().StartImmediately().Do(func() {
|
plcConfig, code := service.NewDevicePlcService().GetDevicePlc()
|
if code != ecode.OK {
|
return
|
}
|
finishNumber, err := service.PlcRead(plcConfig, constvar.PlcStartAddressTypeFinishNumber)
|
if err == nil {
|
service.PlcCacheSet(constvar.PlcCacheKeyFinishNumber, finishNumber)
|
}
|
|
})
|
if err != nil {
|
return err
|
}
|
|
s.Every(1).Minutes().StartImmediately().Do(func() {
|
plcConfig, code := service.NewDevicePlcService().GetDevicePlc()
|
if code != ecode.OK {
|
return
|
}
|
totalNumber, err := service.PlcRead(plcConfig, constvar.PlcStartAddressTypeTotalNumber)
|
if err == nil {
|
service.PlcCacheSet(constvar.PlcCacheKeyTotalNumber, totalNumber)
|
}
|
})
|
|
s.StartAsync()
|
return nil
|
}
|
