admin/sms4j
1
0
Fork 0
mirror of https://gitee.com/dromara/sms4j.git synced 2025-12-06 17:08:40 +08:00
Code Issues Packages Projects Releases Wiki Activity

alibaba 返回响应

Browse Source
This commit is contained in:
handy 2023-05-19 16:48:39 +08:00
parent 7e96649b41
commit 9a554919d0
2 changed files with 39 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
sms4j-provider/src/main/java/org/dromara/sms4j/aliyun/entity/AlibabaResponse.java Normal file
View File

@ -0,0 +1,29 @@
package org.dromara.sms4j.aliyun.entity;
import lombok.Data;
/**
* AlibabaResponse
* <p> 阿里响应参数
*
* @author :handy
* 2023/5/19 16:23
**/
@Data
public class AlibabaResponse {
/**
* 请求返回的结果码
*/
private String Code;
/**
* 请求返回的结果码描述
*/
private String Message;
private String RequestId;
private String BizId;
}

16
sms4j-provider/src/main/java/org/dromara/sms4j/aliyun/service/AlibabaSmsImpl.java
View File

@ -1,10 +1,10 @@
package org.dromara.sms4j.aliyun.service;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.dtflys.forest.config.ForestConfiguration;
import lombok.extern.slf4j.Slf4j;
import org.dromara.sms4j.aliyun.config.AlibabaConfig;
import org.dromara.sms4j.aliyun.entity.AlibabaResponse;
import org.dromara.sms4j.aliyun.utils.AliyunUtils;
import org.dromara.sms4j.api.SmsBlend;
import org.dromara.sms4j.api.callback.CallBack;
@ -98,12 +98,16 @@ public class AlibabaSmsImpl implements SmsBlend {
.addHeader("Content-Type", "application/x-www-form-urlencoded")
.addBody(paramStr)
.onSuccess(((data, req, res) -> {
JSONObject jsonBody = res.get(JSONObject.class);
log.info(jsonBody.toJSONString());
AlibabaResponse alibabaResponse = res.get(AlibabaResponse.class);
smsResponse.setCode(alibabaResponse.getCode());
smsResponse.setMessage(alibabaResponse.getMessage());
smsResponse.setBizId(alibabaResponse.getBizId());
smsResponse.setData(alibabaResponse);
}))
.onError((ex, req, res) -> {
JSONObject jsonBody = res.get(JSONObject.class);
log.info(jsonBody.toJSONString());
AlibabaResponse alibabaResponse = res.get(AlibabaResponse.class);
smsResponse.setErrMessage(alibabaResponse.getMessage());
smsResponse.setErrorCode(alibabaResponse.getCode());
})
.execute();
return smsResponse;
@ -127,7 +131,7 @@ public class AlibabaSmsImpl implements SmsBlend {
@Override
@Restricted
public void sendMessageAsync(String phone, String templateId, LinkedHashMap<String, String> messages, CallBack callBack) {
CompletableFuture<SmsResponse> smsResponseCompletableFuture = CompletableFuture.supplyAsync(() -> sendMessage(phone,templateId, messages), pool);
CompletableFuture<SmsResponse> smsResponseCompletableFuture = CompletableFuture.supplyAsync(() -> sendMessage(phone, templateId, messages), pool);
smsResponseCompletableFuture.thenAcceptAsync(callBack::callBack);
}