同步加工数过滤掉加工数为0的记录

zhangqian

2023-12-29 b6b889b3fcd1ecba07aa90f7ec82c6b7d5d5da3f

同步加工数过滤掉加工数为0的记录

 crontask/cron_task.go

@@ -91,6 +91,9 @@
        return
    }
    for _, progress := range progressList {
        if progress.FinishedQuantity == 0 {
            continue
        }
        caller := nsq.NewCaller(fmt.Sprintf(constvar.NsqTopicSyncTaskProgress, conf.Conf.NsqConf.NodeId), "")
        err = caller.Send(progress)
        if err != nil {