doc(log): rename function for clarity and add cache cleanup comment
This commit is contained in:
parent
6bc0fb4d90
commit
9b0e1b1e0f
@ -18,7 +18,7 @@ type FilterTrafficLogDetailsLogic struct {
|
|||||||
svcCtx *svc.ServiceContext
|
svcCtx *svc.ServiceContext
|
||||||
}
|
}
|
||||||
|
|
||||||
// Filter traffic log details
|
// NewFilterTrafficLogDetailsLogic Filter traffic log details
|
||||||
func NewFilterTrafficLogDetailsLogic(ctx context.Context, svcCtx *svc.ServiceContext) *FilterTrafficLogDetailsLogic {
|
func NewFilterTrafficLogDetailsLogic(ctx context.Context, svcCtx *svc.ServiceContext) *FilterTrafficLogDetailsLogic {
|
||||||
return &FilterTrafficLogDetailsLogic{
|
return &FilterTrafficLogDetailsLogic{
|
||||||
Logger: logger.WithContext(ctx),
|
Logger: logger.WithContext(ctx),
|
||||||
|
|||||||
@ -75,6 +75,7 @@ func (l *QuotaTaskLogic) ProcessTask(ctx context.Context, t *asynq.Task) error {
|
|||||||
if err = l.processSubscribes(ctx, subscribes, content, taskInfo); err != nil {
|
if err = l.processSubscribes(ctx, subscribes, content, taskInfo); err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
// 清理用户缓存(仅在有赠送金时清理)
|
||||||
if content.GiftValue != 0 {
|
if content.GiftValue != 0 {
|
||||||
var userIds []int64
|
var userIds []int64
|
||||||
for _, sub := range subscribes {
|
for _, sub := range subscribes {
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user