diff --git a/push-service/src/main/java/com/xuqm/push/service/provider/OppoPushProvider.java b/push-service/src/main/java/com/xuqm/push/service/provider/OppoPushProvider.java index 6b9bfc3..f9dea26 100644 --- a/push-service/src/main/java/com/xuqm/push/service/provider/OppoPushProvider.java +++ b/push-service/src/main/java/com/xuqm/push/service/provider/OppoPushProvider.java @@ -59,6 +59,7 @@ public class OppoPushProvider implements PushProvider { String messageId = appKey + "_" + System.currentTimeMillis(); Map notification = new java.util.LinkedHashMap<>(); notification.put("app_message_id", messageId); + notification.put("style", 1); notification.put("title", title); notification.put("content", body); notification.put("click_action_type", 0); @@ -86,6 +87,9 @@ public class OppoPushProvider implements PushProvider { JsonNode json = objectMapper.readTree(response.body()); int code = json.path("code").asInt(-1); if (response.statusCode() == 200 && code == 0) { + String vendorMessageId = json.path("data").path("messageId").asText(""); + log.info("OPPO push accepted: appMessageId={} vendorMessageId={} channelId={} target={} response={}", + messageId, vendorMessageId, channelId, maskToken(token), response.body()); return true; } log.error("OPPO push rejected: httpStatus={} code={} message={}", @@ -139,6 +143,13 @@ public class OppoPushProvider implements PushProvider { return java.util.HexFormat.of().formatHex(digest); } + private static String maskToken(String token) { + if (token == null || token.length() <= 16) { + return "***"; + } + return token.substring(0, 8) + "..." + token.substring(token.length() - 8); + } + private String normalizeActionParameters(String payload) throws Exception { JsonNode parsed = runCatchingJson(payload); if (parsed != null && parsed.isObject()) {