diff --git a/backend/services/reporting-service/src/infrastructure/kafka/activity-event-consumer.controller.ts b/backend/services/reporting-service/src/infrastructure/kafka/activity-event-consumer.controller.ts
index 5e74a0ad..555b7c77 100644
--- a/backend/services/reporting-service/src/infrastructure/kafka/activity-event-consumer.controller.ts
+++ b/backend/services/reporting-service/src/infrastructure/kafka/activity-event-consumer.controller.ts
@@ -231,7 +231,7 @@ export class ActivityEventConsumerController {
 
       // 根据事件类型决定是否记录活动
       if (eventType.includes('authorized') || eventType.includes('Authorized') || eventType.includes('granted')) {
-        const roleTypeLabel = this.getRoleTypeLabel(payload.roleType);
+        const roleTypeLabel = this.getRoleTypeLabel(payload.roleType || '');
         const entityId = payload.authorizationId || message.aggregateId;
 
         // 从不同事件类型中提取区域信息
@@ -307,7 +307,7 @@ export class ActivityEventConsumerController {
   private async handleBenefitActivatedInternal(message: AuthorizationRoleEvent) {
     try {
       const { payload, aggregateId } = message;
-      const roleTypeLabel = this.getRoleTypeLabel(payload.roleType);
+      const roleTypeLabel = this.getRoleTypeLabel(payload.roleType || '');
 
       // 从不同事件类型中提取区域信息
       const regionCode =