修复数据推送的延时问题

zhangzengfei

2024-04-08 56acb65a68fbe85e3ab8fc3b66e512eb4fcd8a30

修复数据推送的延时问题

 main.go

@@ -61,27 +61,23 @@
                    url := config.Options.ServerUrl
                    result, err1 := service.GetData()
                    if err1 != nil {
                        logger.Warn(err1.Error())
                        time.Sleep(1 * time.Second)
                        retryCount += 1
                        break
                        logger.Warn("获取es数据失败,", err1.Error())
                        return
                    }

                    id, errs2 := service.SendData(result, url)
                    id, err := service.SendData(result, url)
                    logger.Debug("推送的数据 id: ", id)
                    if errs2 == nil {
                        //delStatus := service.DeleteData(id)
                    if err == nil {
                        markStatus := service.MarkData(id)
                        fmt.Println(markStatus)
                        logger.Debug("记录推送状态 markStatus: ", markStatus)
                    } else {
                        logger.Debug("推送的数据失败 id: ", id)
                        time.Sleep(1 * time.Second)
                        logger.Debugf("推送的数据失败 id: %s, err:%s", id, err.Error())
                        time.Sleep(5 * time.Second)
                        retryCount += 1
                    }
                    break
                } else {
                    logger.Debug("服务端连接失败,5秒后尝试重新连接。。。")
                    logger.Debug("服务端连接失败, 5秒后尝试重新连接。。。")
                    time.Sleep(5 * time.Second)
                }
            }