zhangqian
2023-08-28 e8f65e16f9003358b6fbe2b860aa7e99ff329367
定时任务查询完成数,查到值为0不写入内存
1个文件已修改
8 ■■■■ 已修改文件
crontask/cron_task.go 8 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
crontask/cron_task.go
@@ -11,13 +11,13 @@
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)
@@ -27,13 +27,13 @@
        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)