diff --git a/services/reward/notify.go b/services/reward/notify.go
index 4f3190d67..4db218537 100644
--- a/services/reward/notify.go
+++ b/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,
diff --git a/services/reward/operator.go b/services/reward/operator.go
index f32024688..4e1d53b75 100644
--- a/services/reward/operator.go
+++ b/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
 }