package com.example.smssend.service.impl;
|
|
import com.example.smssend.domain.SendMagParam;
|
import com.example.smssend.service.SendService;
|
import com.example.smssend.utils.HttpUtils;
|
import com.fasterxml.jackson.core.JsonProcessingException;
|
import com.fasterxml.jackson.core.type.TypeReference;
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Component;
|
import org.springframework.stereotype.Service;
|
import org.springframework.util.ObjectUtils;
|
|
import java.io.UnsupportedEncodingException;
|
import java.net.URLEncoder;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* 发送服务工具类
|
*/
|
@Service
|
public class SendServiceImpl implements SendService {
|
|
@Value("${xhsmsPath}")
|
private String xhsmsPath;
|
// 帐号
|
@Value("${xhsmsAccount}")
|
private String xhsmsAccount;
|
// 接口密码
|
@Value("${xhsmsPwd}")
|
private String xhsmsPwd;
|
// 虚拟接入码
|
@Value("${xhsmsjrm}")
|
private String xhsmsjrm;
|
|
@Override
|
public Boolean sendMsg(SendMagParam sendMagParam) throws JsonProcessingException, UnsupportedEncodingException {
|
|
//短信
|
Map<String, String> map2 = new HashMap<String, String>();
|
map2.put("action", "send");
|
map2.put("account", xhsmsAccount);
|
map2.put("password", xhsmsPwd);
|
map2.put("mobile", sendMagParam.getPhone());
|
map2.put("content", sendMagParam.getContent());
|
map2.put("extno", xhsmsjrm);
|
map2.put("rt", "json");
|
StringBuilder encodedParams = new StringBuilder();
|
|
for (Map.Entry<String, String> entry : map2.entrySet()) {
|
if (encodedParams.length() > 0) {
|
encodedParams.append("&");
|
}
|
// 对键和值进行URL编码
|
String encodedKey = URLEncoder.encode(entry.getKey(), "UTF-8");
|
String encodedValue = URLEncoder.encode(entry.getValue(), "UTF-8");
|
encodedParams.append(encodedKey).append("=").append(encodedValue);
|
}
|
|
String result = HttpUtils.sendPost(xhsmsPath, encodedParams.toString());
|
ObjectMapper objectMapper2 = new ObjectMapper();
|
Map<String, Object> map3 = objectMapper2.readValue(result, new TypeReference<Map<String, Object>>() {
|
});
|
if (!ObjectUtils.isEmpty(map3)) {
|
// String status = map3.get("status").toString();
|
// if (status.equals("0")) {
|
// return true;
|
// }
|
Object ob = map3.get("list");
|
if (!ObjectUtils.isEmpty(ob)) {
|
List<Map<String, Object>> list = (List) ob;
|
Map<String, Object> map = list.get(0);
|
Integer result1 = (Integer) map.get("result");
|
if (result1 != null && result1 == 0) return true;
|
}
|
|
}
|
return false;
|
}
|
|
}
|
