zhangzengfei
2024-10-22 4ca3791590a7bf50222aa5f80e53edf04739108a
service/resend.go
@@ -9,10 +9,22 @@
   "gat1400Exchange/vo"
)
var resendTaskRunning bool
func ResendImageData() {
   if resendTaskRunning {
      return
   }
   resendTaskRunning = true
   defer func() { resendTaskRunning = false }()
   var cacheMod models.Cache
   total, _ := cacheMod.Count()
   logger.Debug("Start resend task. cache len:%d", total)
   if total == 0 {
      return
   }
   logger.Info("Start resend task. cache len:%d", total)
   for i := 0; i < int(total); i++ {
      var c models.Cache
@@ -21,12 +33,18 @@
         logger.Error(err.Error())
         return
      }
      if c.Type == "1400" {
      if c.Type == "1400-face" {
         if client.FaceCapture([]byte(c.Data)) != vo.StatusSuccess {
            c.UpdateRetryCount()
            logger.Warn("The data resend failed. retry count %d", c.Retry+1)
            return
         }
      } else if c.Type == "1400-person" {
         if client.PersonCapture([]byte(c.Data)) != vo.StatusSuccess {
            c.UpdateRetryCount()
            logger.Warn("The data resend failed. retry count %d", c.Retry+1)
            return
         }
      } else {
         if !util.SendData([]byte(c.Data), config.ForwardConf.SyncServer) {
            c.UpdateRetryCount()