backend/java-mall
6
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

增加 uni cloud push 函数推送公共接口

Browse Source
This commit is contained in:
Jack 2025-06-22 03:03:47 +08:00
parent 0698c35a5f
commit f06ca9839b
2 changed files with 236 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
mall-common/src/main/java/com/suisung/mall/common/service/UniCloudPushService.java Normal file
View File

@ -0,0 +1,29 @@
/*
* Copyright (c) 2025. Lorem ipsum dolor sit amet, consectetur adipiscing elit.
* Morbi non lorem porttitor neque feugiat blandit. Ut vitae ipsum eget quam lacinia accumsan.
* Etiam sed turpis ac ipsum condimentum fringilla. Maecenas magna.
* Proin dapibus sapien vel ante. Aliquam erat volutpat. Pellentesque sagittis ligula eget metus.
* Vestibulum commodo. Ut rhoncus gravida arcu.
*/
package com.suisung.mall.common.service;
import cn.hutool.json.JSONObject;
import com.suisung.mall.common.service.impl.UniCloudPushServiceImpl;
import java.util.List;
public interface UniCloudPushService {
/**
* 向多个客户端ID批量发送推送消息
*
* @param clientIds 目标客户端ID列表
* @param title 推送标题
* @param content 推送内容
* @param payload 附加数据(JSON对象)
* @return 推送结果响应对象
* @throws UniCloudPushServiceImpl.UniCloudPushException 推送过程中发生的异常
*/
UniCloudPushServiceImpl.PushResponse sendBatchPush(String cloudFunctionUrl, List<String> clientIds, String title, String content, JSONObject payload);
}

207
mall-common/src/main/java/com/suisung/mall/common/service/impl/UniCloudPushServiceImpl.java Normal file
View File

@ -0,0 +1,207 @@
/*
* Copyright (c) 2025. Lorem ipsum dolor sit amet, consectetur adipiscing elit.
* Morbi non lorem porttitor neque feugiat blandit. Ut vitae ipsum eget quam lacinia accumsan.
* Etiam sed turpis ac ipsum condimentum fringilla. Maecenas magna.
* Proin dapibus sapien vel ante. Aliquam erat volutpat. Pellentesque sagittis ligula eget metus.
* Vestibulum commodo. Ut rhoncus gravida arcu.
*/
package com.suisung.mall.common.service.impl;
import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil;
import com.suisung.mall.common.service.UniCloudPushService;
import org.springframework.context.annotation.Lazy;
import org.springframework.http.*;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestClientException;
import org.springframework.web.client.RestTemplate;
import javax.annotation.Resource;
import java.util.List;
/**
* 调用 UniCloud 云函数 推送服务
* 提供向多个客户端 ID 发送推送消息的功能
*/
@Service
public class UniCloudPushServiceImpl implements UniCloudPushService {
// 请求常量定义
private static final String ACTION_KEY = "action";
private static final String CID_LIST_KEY = "cidList";
private static final String MESSAGE_KEY = "message";
private static final String TITLE_KEY = "title";
private static final String CONTENT_KEY = "content";
private static final String PAYLOAD_KEY = "payload";
@Lazy
@Resource
private RestTemplate restTemplate;
/**
* 向多个客户端ID批量发送推送消息
*
* @param clientIds 目标客户端ID列表
* @param title 推送标题
* @param content 推送内容
* @param payload 附加数据(JSON对象)
* @return 推送结果响应对象
* @throws UniCloudPushException 推送过程中发生的异常
*/
@Override
public PushResponse sendBatchPush(String cloudFunctionUrl, List<String> clientIds, String title, String content, JSONObject payload) {
// 参数校验
validatePushParams(clientIds, title, content);
// 构建请求体
JSONObject requestBody = buildPushRequest(clientIds, title, content, payload);
try {
// 执行HTTP请求
ResponseEntity<String> response = executeHttpRequest(cloudFunctionUrl, requestBody);
// 处理响应结果
return processResponse(response);
} catch (RestClientException e) {
// 处理REST客户端异常
throw new UniCloudPushException("推送请求发送失败", e);
} catch (Exception e) {
// 处理其他异常
throw new UniCloudPushException("推送处理过程发生异常", e);
}
}
/**
* 验证推送参数有效性
*/
private void validatePushParams(List<String> clientIds, String title, String content) throws IllegalArgumentException {
if (clientIds == null || clientIds.isEmpty()) {
throw new IllegalArgumentException("客户端ID列表不能为空");
}
if (title == null || title.trim().isEmpty()) {
throw new IllegalArgumentException("推送标题不能为空");
}
if (content == null || content.trim().isEmpty()) {
throw new IllegalArgumentException("推送内容不能为空");
}
}
/**
* 构建推送请求体
*/
private JSONObject buildPushRequest(List<String> clientIds, String title, String content, JSONObject payload) {
JSONObject requestBody = new JSONObject();
requestBody.put(ACTION_KEY, "push");
requestBody.put(CID_LIST_KEY, clientIds);
JSONObject message = new JSONObject();
message.put(TITLE_KEY, title);
message.put(CONTENT_KEY, content);
if (payload != null) {
message.put(PAYLOAD_KEY, payload);
}
requestBody.put(MESSAGE_KEY, message);
return requestBody;
}
/**
* 执行HTTP POST请求
*/
private ResponseEntity<String> executeHttpRequest(String cloudFunctionUrl, JSONObject requestBody) {
// 设置请求头
HttpHeaders headers = new HttpHeaders();
headers.setContentType(MediaType.APPLICATION_JSON);
// 创建请求实体
HttpEntity<String> requestEntity = new HttpEntity<>(requestBody.toString(), headers);
// 执行POST请求
return restTemplate.exchange(
cloudFunctionUrl,
HttpMethod.POST,
requestEntity,
String.class
);
}
/**
* 处理HTTP响应
*/
private PushResponse processResponse(ResponseEntity<String> response) {
if (response.getStatusCode() != HttpStatus.OK) {
throw new UniCloudPushException(
String.format("推送请求失败，状态码: %d，响应: %s",
response.getStatusCodeValue(),
response.getBody())
);
}
String responseBody = response.getBody();
if (responseBody == null || responseBody.trim().isEmpty()) {
throw new UniCloudPushException("推送响应内容为空");
}
// 解析响应JSON
JSONObject responseJson = JSONUtil.parseObj(responseBody);
// 提取响应结果
return new PushResponse(
responseJson.getBool("success"),
responseJson.getInt("code"),
responseJson.getStr("message"),
responseJson.getJSONObject("data")
);
}
/**
* 推送响应结果类
*/
public static class PushResponse {
private final boolean success;
private final int code;
private final String message;
private final JSONObject data;
public PushResponse(boolean success, int code, String message, JSONObject data) {
this.success = success;
this.code = code;
this.message = message;
this.data = data;
}
// Getter方法
public boolean isSuccess() {
return success;
}
public int getCode() {
return code;
}
public String getMessage() {
return message;
}
public JSONObject getData() {
return data;
}
}
/**
* 自定义推送异常类
*/
public static class UniCloudPushException extends RuntimeException {
public UniCloudPushException(String message) {
super(message);
}
public UniCloudPushException(String message, Throwable cause) {
super(message, cause);
}
}
}