| 1234567891011121314151617181920212223242526272829303132 |
- package work
- import (
- "github.com/robfig/cron"
- "server/modbus"
- "server/service/item"
- )
- func MyJob() {
- c := cron.New()
- _ = c.AddFunc("0 * * * * ?", func() {
- modbus.GetSunPowerInfo()
- modbus.GetDeviceInfo()
- })
- _ = c.AddFunc("0 0 3 * * ?", func() {
- item.CleanupOldDeviceConsumption()
- })
- _ = c.AddFunc("0 * * * * ?", func() {
- modbus.DealWithOffline()
- modbus.DealWithOfflineGateway()
- modbus.DealWithOfflineBluetooths()
- item.Cron{}.RelayOnOffTimeTask()
- })
- _ = c.AddFunc("0 */30 * * * ?", func() {
- item.GetDeviceConsumption()
- })
- _ = c.AddFunc("0 0 0 * * ?", func() {
- item.SummaryWeekConsumption()
- })
- c.Start()
- }
|