Skip to content

Commit 750fdb0

Browse files
committed
Merge branch 'dev' into fix/1.1.3/qa
# Conflicts: # internal/repo/activity/answer_repo.go
2 parents a6b6545 + e75142a commit 750fdb0

3 files changed

Lines changed: 5 additions & 6 deletions

File tree

internal/base/middleware/auth.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -126,7 +126,7 @@ func (am *AuthUserMiddleware) AdminAuth() gin.HandlerFunc {
126126
return
127127
}
128128
userInfo, err := am.authService.GetAdminUserCacheInfo(ctx, token)
129-
if err != nil {
129+
if err != nil || userInfo == nil {
130130
handler.HandleResponse(ctx, errors.Forbidden(reason.UnauthorizedError), nil)
131131
ctx.Abort()
132132
return

internal/migrations/init_data.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -47,6 +47,7 @@ var (
4747
&entity.UserRoleRel{},
4848
&entity.PluginConfig{},
4949
&entity.UserExternalLogin{},
50+
&entity.UserNotificationConfig{},
5051
}
5152

5253
roles = []*entity.Role{

internal/repo/activity/answer_repo.go

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -285,12 +285,11 @@ func (ar *AnswerActivityRepo) sendAcceptAnswerNotification(
285285
Type: schema.NotificationTypeAchievement,
286286
ObjectID: op.AnswerObjectID,
287287
ReceiverUserID: act.ActivityUserID,
288+
TriggerUserID: act.TriggerUserID,
288289
}
289290
if act.ActivityUserID == op.QuestionUserID {
290-
msg.TriggerUserID = op.AnswerUserID
291291
msg.ObjectType = constant.AnswerObjectType
292292
} else {
293-
msg.TriggerUserID = op.QuestionUserID
294293
msg.ObjectType = constant.AnswerObjectType
295294
}
296295
if msg.TriggerUserID != msg.ReceiverUserID {
@@ -303,9 +302,9 @@ func (ar *AnswerActivityRepo) sendAcceptAnswerNotification(
303302
ReceiverUserID: act.ActivityUserID,
304303
Type: schema.NotificationTypeInbox,
305304
ObjectID: op.AnswerObjectID,
305+
TriggerUserID: op.TriggerUserID,
306306
}
307307
if act.ActivityUserID != op.QuestionUserID {
308-
msg.TriggerUserID = op.TriggerUserID
309308
msg.ObjectType = constant.AnswerObjectType
310309
msg.NotificationAction = constant.NotificationAcceptAnswer
311310
ar.notificationQueueService.Send(ctx, msg)
@@ -317,15 +316,14 @@ func (ar *AnswerActivityRepo) sendCancelAcceptAnswerNotification(
317316
ctx context.Context, op *schema.AcceptAnswerOperationInfo) {
318317
for _, act := range op.Activities {
319318
msg := &schema.NotificationMsg{
319+
TriggerUserID: act.TriggerUserID,
320320
ReceiverUserID: act.ActivityUserID,
321321
Type: schema.NotificationTypeAchievement,
322322
ObjectID: op.AnswerObjectID,
323323
}
324324
if act.ActivityUserID == op.QuestionObjectID {
325-
msg.TriggerUserID = op.AnswerObjectID
326325
msg.ObjectType = constant.QuestionObjectType
327326
} else {
328-
msg.TriggerUserID = op.QuestionObjectID
329327
msg.ObjectType = constant.AnswerObjectType
330328
}
331329
if msg.TriggerUserID != msg.ReceiverUserID {

0 commit comments

Comments
 (0)