修复缓存的保存和更新

zhangzengfei

2024-04-16 66a495ff696547087a10f26c87628d9c7ae1fa85

修复缓存的保存和更新

 models/cache.go

@@ -20,8 +20,8 @@
    return caches, nil
}

func (c *Cache) Update() error {
    return db.Table(c.TableName()).Save(&c).Error
func (c *Cache) UpdateRetryCount() error {
    return db.Table(c.TableName()).Update("retry", c.Retry+1).Error
}

func (c *Cache) Delete() error {

 service/resend.go

@@ -14,9 +14,7 @@
    for _, c := range cacheItems {
        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
            c.Update()
            c.UpdateRetryCount()
        } else {
            c.Delete()
            logger.Debug("The data resend successful.")