调整缓存的数据

zhangzengfei

2024-04-16 808ce8f0bfa59f6333c27391b6983bdd67fd0bd6

 service/resend.go

@@ -1,12 +1,10 @@
package service

import (
   "encoding/json"
   "gat1400Exchange/config"
   "gat1400Exchange/models"
   "gat1400Exchange/pkg/logger"
   "gat1400Exchange/util"
   "gat1400Exchange/vo"
)

func ResendImageData() {
@@ -14,7 +12,7 @@
   cacheItems, _ := cacheMod.FindAll()

   for _, c := range cacheItems {
      if !SendData([]byte(c.Data), config.ForwardConf.SyncServer) {
      if !util.SendData([]byte(c.Data), config.ForwardConf.SyncServer) {
         logger.Warn("The data resend failed. retry count %d", c.Retry)

         c.Retry = c.Retry + 1
@@ -25,21 +23,4 @@
      }
   }

}

func SendData(payload []byte, url string) bool {
   body, err := util.HttpPost(url, nil, payload)
   if err != nil {
      logger.Error("Post request failure, url:%s, err:%s", err.Error())
      return false
   }

   var rsp vo.SyncServerResponse
   err = json.Unmarshal(body, &rsp)
   if err != nil {
      logger.Error("Can't parse response, url:%s, rsp: %v", url, body)
      return false
   }

   return rsp.Success
}