#2225

update

services/reward/notify.go

@@ -15,10 +15,6 @@ func NotifyRewardOperation(userId, amount int64, sourceType models.SourceType, r
 	switch sourceType {
 	case models.SourceTypeRunCloudbrainTask:
 		return
-	case models.SourceTypeAdminOperate:
-		if operateType == models.OperateTypeDecrease {
-			return
-		}
 	}
 	data := &models.UserRewardOperationRedis{
 		UserId:      userId,

services/reward/operator.go

@@ -86,7 +86,7 @@ func Operate(ctx *models.RewardOperateContext) error {
 	}
 
 	UpdateRewardRecordToFinalStatus(ctx.SourceType.Name(), ctx.RequestId, models.OperateStatusSucceeded)
-	NotifyRewardOperation(ctx.TargetUserId, ctx.Reward.Amount, ctx.Reward.Type, ctx.OperateType)
+	NotifyRewardOperation(ctx.TargetUserId, ctx.Reward.Amount, ctx.SourceType, ctx.Reward.Type, ctx.OperateType)
 	return nil
 }