fix id

zhangzengfei

2024-10-19 1ca4879df9cc3c22181b2a200aa4b793116d3d35

 main.go

@@ -4,7 +4,6 @@
   "data_msg_push_server/config"
   "data_msg_push_server/service"

   "fmt"
   "time"

   "basic.com/valib/logger.git"
@@ -42,6 +41,7 @@

func doServer() {
   total := 0
   retryCount := 0
   for {
      t, err := service.GetTotal()
      if err != nil {
@@ -49,8 +49,8 @@
         return
      }
      total = t
      logger.Debug("未发送的数据总量：", total)
      if total == 0 {
      logger.Debugf("未发送的数据总量:%d, 重试次数:%d", total, retryCount)
      if total == 0 || retryCount > 10 {
         break
      } else {
         for {
@@ -60,21 +60,23 @@
               url := config.Options.ServerUrl
               result, err1 := service.GetData()
               if err1 != nil {
                  logger.Warn(err1.Error())
                  break
                  logger.Warn("获取es数据失败,", err1.Error())
                  return
               }

               id, errs2 := service.SendData(result, url)
               logger.Debug("推送的数据 id: ", id)
               if errs2 == nil {
                  //delStatus := service.DeleteData(id)
                  markStatus := service.MarkData(id)
                  fmt.Println(markStatus)
               id, err := service.SendData(result, url)
               logger.Debug("推送的数据 id: ", result.PicId)
               if err == nil {
                  markStatus := service.MarkData(result.PicId)
                  logger.Debug("记录推送状态 markStatus: ", markStatus)
               } else {
                  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)
            }
         }