From a7cbfcea70d877d471486a4eab01bb5eb7e10243 Mon Sep 17 00:00:00 2001 From: huangfeng Date: Mon, 22 Jul 2024 09:59:59 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E5=A2=9E=E5=8A=A0=E5=A4=A7=E6=B1=89?= =?UTF-8?q?=E7=A7=BB=E5=8A=A8=E9=A1=B5=E9=9D=A2=E6=8E=A5=E5=8F=A3=E8=B0=83?= =?UTF-8?q?=E7=94=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../xymanager_common/sms/dahan/DahanWeb.java | 85 +++++++++++++++++++ .../sms/lwwlkj/LwwlkjWeb.java | 1 + .../sms/rabchaser/RabchaserWeb.java | 13 ++- 3 files changed, 95 insertions(+), 4 deletions(-) create mode 100644 xymanager_common/src/main/java/com/shxy/xymanager_common/sms/dahan/DahanWeb.java diff --git a/xymanager_common/src/main/java/com/shxy/xymanager_common/sms/dahan/DahanWeb.java b/xymanager_common/src/main/java/com/shxy/xymanager_common/sms/dahan/DahanWeb.java new file mode 100644 index 0000000..4fe986b --- /dev/null +++ b/xymanager_common/src/main/java/com/shxy/xymanager_common/sms/dahan/DahanWeb.java @@ -0,0 +1,85 @@ +package com.shxy.xymanager_common.sms.dahan; + +import com.shxy.xymanager_common.exception.ApiException; +import com.shxy.xymanager_common.util.HttpClient; +import com.shxy.xymanager_common.util.JSONUtil; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Service; + +import java.util.HashMap; +import java.util.List; +import java.util.Map; + +@Service +@Slf4j +public class DahanWeb { + private String baseUrl = "http://iot.dahancloud.com/mySms"; + public static String cookie = ""; + + private Map buildHead() { + Map map = new HashMap<>(); + map.put("Cookie", cookie); + return map; + } + + public Object listSms(String msisdn, String date) { + String url = "/smsPage"; + Map dataMap = new HashMap<>(); + dataMap.put("filter", msisdn); + dataMap.put("smsType", "0"); + dataMap.put("page", "340"); + dataMap.put("rows", "10"); + try { + HashMap result = null; + String json = HttpClient.get(baseUrl + url, dataMap, this.buildHead()); + log.info("查询短信记录完成: " + json); + try { + result = JSONUtil.json2Object(json, HashMap.class); + } catch (Exception e) { + throw new ApiException(json); + } + + if (result.get("rows") != null) { + return result.get("rows"); + } else { + String error = String.valueOf(result.get("message")); + throw new ApiException(error); + } + } catch (Exception e) { + log.error("查询短信异常.", e); + throw new ApiException("查询短信异常," + e.getMessage()); + } + } + + public void sendSms(List iccidList, String content) { + String url = "/cardSendMt"; + try { + for (String iccid : iccidList) { + Map dataMap = new HashMap<>(); + dataMap.put("iccid", iccid); + dataMap.put("content", content); + + String json = HttpClient.get(baseUrl + url, dataMap, this.buildHead()); + log.info("发送短信完成:" + json); + HashMap result = null; + try { + result = JSONUtil.json2Object(json, HashMap.class); + } catch (Exception e) { + throw new ApiException(json); + } + if (result.get("code") != null && "200".equalsIgnoreCase(result.get("code").toString())) { + + } else { + String error = String.valueOf(result.get("message")); + throw new ApiException(error); + } + } + } catch (ApiException e) { + throw e; + } catch (Exception e) { + log.error("发送短信异常.", e); + throw new ApiException("发送短信异常," + e.getMessage()); + } + } + +} diff --git a/xymanager_common/src/main/java/com/shxy/xymanager_common/sms/lwwlkj/LwwlkjWeb.java b/xymanager_common/src/main/java/com/shxy/xymanager_common/sms/lwwlkj/LwwlkjWeb.java index 46f0e56..81e99ab 100644 --- a/xymanager_common/src/main/java/com/shxy/xymanager_common/sms/lwwlkj/LwwlkjWeb.java +++ b/xymanager_common/src/main/java/com/shxy/xymanager_common/sms/lwwlkj/LwwlkjWeb.java @@ -33,6 +33,7 @@ public class LwwlkjWeb { HashMap result = null; String json = HttpClient.postUrlEncoded(baseUrl + url, dataMap, this.buildHead()); log.info("查询短信记录完成: " + json); + // 返回是个html return json; } catch (Exception e) { log.error("查询短信异常.", e); diff --git a/xymanager_common/src/main/java/com/shxy/xymanager_common/sms/rabchaser/RabchaserWeb.java b/xymanager_common/src/main/java/com/shxy/xymanager_common/sms/rabchaser/RabchaserWeb.java index ceeb2d9..071cc2b 100644 --- a/xymanager_common/src/main/java/com/shxy/xymanager_common/sms/rabchaser/RabchaserWeb.java +++ b/xymanager_common/src/main/java/com/shxy/xymanager_common/sms/rabchaser/RabchaserWeb.java @@ -16,10 +16,15 @@ public class RabchaserWeb { private String baseUrl = "http://www.rabchaser.com/api"; public static String authorization = ""; - public Object selectMsgReceive(String iccid, String date) { + private Map buildHead() { + Map map = new HashMap<>(); + map.put("Authorization", authorization); + return map; + } + + public Object listSms(String iccid, String date) { String url = "/cardquery/selectMsgReceiveByPage"; - Map headMap = new HashMap<>(); - headMap.put("Authorization", authorization); + Map dataMap = new HashMap<>(); dataMap.put("iccid", iccid); // dataMap.put("receiveTime", date); @@ -27,7 +32,7 @@ public class RabchaserWeb { dataMap.put("pageSize", 10); try { HashMap result = null; - String json = HttpClient.post(baseUrl + url, dataMap, headMap); + String json = HttpClient.post(baseUrl + url, dataMap, this.buildHead()); log.info("查询短信记录完成: " + json); try { result = JSONUtil.json2Object(json, HashMap.class);