// 冻结金额减少的情况 err = r.data.rpushCache(ctx, cacheKey, -frozenAmount) if err != nil { _ = tx.Rollback() return nil, err } // 错误金额增加的情况 err = r.data.rpushCache(ctx, cacheKey, incorrectAmount) if err != nil { _ = tx.Rollback() return nil, err }把这两个写在一个rpush里
时间: 2024-04-15 12:28:55 浏览: 13
如果您希望将冻结金额减少和错误金额增加的操作放在同一个 `rpush` 中,您可以使用一个包含两个元素的数组来传递这两个值。下面是相应的示例代码:
```go
data := []int{-frozenAmount, incorrectAmount}
err = r.data.rpushCache(ctx, cacheKey, data...)
if err != nil {
_ = tx.Rollback()
return nil, err
}
```
在上述代码中,我们将 `-frozenAmount` 和 `incorrectAmount` 放入了 `data` 数组中,并通过 `...` 运算符将数组元素展开传递给 `rpushCache` 方法中的可变参数。这样,两个值会作为一个整体被推入缓存。
请注意,为了使上述代码正常工作,`r.data.rpushCache` 方法需要接受可变参数,并能够处理多个值的输入。确保您的缓存实现支持此功能。
相关问题
cacheKey := r.CacheKey(req.Id) err = r.data.setCache(ctx, cacheKey, result) if err != nil { _ = tx.Rollback() return nil, biz.ErrRecordAlreadyExists } 在下面增加使用缓存的 rpush方法 分两种情况 一个是冻结金额要-一个是-错了金额要加上怎么写 直接给我写到代码里
下面是根据您的要求添加缓存的示例代码:
```go
cacheKey := r.CacheKey(req.Id)
err = r.data.setCache(ctx, cacheKey, result)
if err != nil {
_ = tx.Rollback()
return nil, biz.ErrRecordAlreadyExists
}
// 冻结金额减少的情况
err = r.data.rpushCache(ctx, cacheKey, -frozenAmount)
if err != nil {
_ = tx.Rollback()
return nil, err
}
// 错误金额增加的情况
err = r.data.rpushCache(ctx, cacheKey, incorrectAmount)
if err != nil {
_ = tx.Rollback()
return nil, err
}
```
请注意,上述代码中的 `r.data.setCache` 和 `r.data.rpushCache` 方法是示意方法,您需要根据您的具体缓存实现进行相应的修改。同时,为了保证数据的一致性,建议在缓存操作失败时进行事务的回滚。
func (r *ewalletRepo) Update(ctx context.Context, req *biz.Ewallet) (*biz.Ewallet, error) { // 开启事务 tx, err := r.data.db.Tx(ctx) if err != nil { return nil, biz.ErrRecordAlreadyExists } // 修改 sum, err := tx.Ewallet.Update().SetBalance(req.Balance).SetFrozenAmount(req.Frozen_Amount).Where(ewallet.HasCustomerWith(customer.ID(req.Id))).Save(ctx) if err != nil { _ = tx.Rollback() return nil, v1.ErrorUniversalError(err.Error()) } else if sum != 1 { _ = tx.Rollback() return nil, v1.ErrorUniversalError(err.Error()) } // 查询 result, err := tx.Ewallet.Query().Where(ewallet.HasCustomerWith(customer.ID(req.Id))).Only(ctx) if err != nil { _ = tx.Rollback() return nil, v1.ErrorUniversalError(err.Error()) } cacheKey := r.CacheKey(req.Id) _ = r.data.cache.Del(ctx, cacheKey) err = r.data.setCache(ctx, cacheKey, result) if err != nil { _ = tx.Rollback() return nil, biz.ErrRecordAlreadyExists } // 执行事务 err = tx.Commit() if err != nil { // 事务回滚 _ = tx.Rollback() return nil, biz.ErrRecordAlreadyExists } return r.composes(result, err) } 改成不是直接修改数据库,而是修改缓存 添加到缓存 从底部存 头部取 使用LPOP 移出并获取列表的第一个元素 RPUSH 在列表中添加一个或多个值到列表尾部
func (r *ewalletRepo) Update(ctx context.Context, req *biz.Ewallet) (*biz.Ewallet, error) {
// 修改缓存
cacheKey := r.CacheKey(req.Id)
err := r.data.setCache(ctx, cacheKey, req)
if err != nil {
return nil, biz.ErrRecordAlreadyExists
}
// 添加到缓存底部
err = r.data.cache.RPush(ctx, cacheKey, req)
if err != nil {
return nil, biz.ErrRecordAlreadyExists
}
// 从缓存头部取
result, err := r.data.cache.LPop(ctx, cacheKey)
if err != nil {
return nil, biz.ErrRecordAlreadyExists
}
return r.composes(result, err)
}