OMC/be.ems
1
0
Fork 0
Code Issues Releases 3 Activity

feat: cb message eventName

Browse Source
This commit is contained in:
zhangsz
2025-07-08 14:46:32 +08:00
parent 8d76d68b96
commit a7a4efdcb2
1 changed files with 2 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
features/ue/cb_message/service.go
View File

@@ -372,18 +372,8 @@ func (s *CBMessageService) sendDeactivateRequest(msg CBMessage) error {
// 提取eventName (从messageJson中获取，如果没有eventName字段，可能需要从其他地方获取) // 提取eventName (从messageJson中获取，如果没有eventName字段，可能需要从其他地方获取)
eventName, ok := messageData["eventName"].(string) eventName, ok := messageData["eventName"].(string)
if !ok { if !ok || eventName == "" {
// 如果messageJson中没有eventName，尝试从messageIdProfile中获取 return fmt.Errorf("eventName not found in message_json")
if messageIdProfile, exists := messageData["messageIdProfile"]; exists {
if profile, ok := messageIdProfile.(map[string]interface{}); ok {
if msgId, exists := profile["messageId"]; exists {
eventName = fmt.Sprintf("message_%v", msgId)
}
}
}
if eventName == "" {
return fmt.Errorf("eventName not found in message_json")
}
} }
// 构造删除请求的payload，只包含messageIdProfile和warningAreaList // 构造删除请求的payload，只包含messageIdProfile和warningAreaList