frame-module-admin/src/main/java/com/bohuikeji/frame/module/admin/sms/Base64Util.java

@@ -0,0 +1,111 @@
+package com.bohuikeji.frame.module.admin.sms;
+
+import java.io.ByteArrayOutputStream;
+
+public class Base64Util {
+    private static char[] base64EncodeChars = new char[]{
+            'A', 'B', 'C', 'D', 'E', 'F', 'G', 'H',
+            'I', 'J', 'K', 'L', 'M', 'N', 'O', 'P',
+            'Q', 'R', 'S', 'T', 'U', 'V', 'W', 'X',
+            'Y', 'Z', 'a', 'b', 'c', 'd', 'e', 'f',
+            'g', 'h', 'i', 'j', 'k', 'l', 'm', 'n',
+            'o', 'p', 'q', 'r', 's', 't', 'u', 'v',
+            'w', 'x', 'y', 'z', '0', '1', '2', '3',
+            '4', '5', '6', '7', '8', '9', '+', '/'};
+    private static byte[] base64DecodeChars = new byte[]{
+            -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1,
+            -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1,
+            -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, 62, -1, -1, -1, 63,
+            52, 53, 54, 55, 56, 57, 58, 59, 60, 61, -1, -1, -1, -1, -1, -1,
+            -1, 0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14,
+            15, 16, 17, 18, 19, 20, 21, 22, 23, 24, 25, -1, -1, -1, -1, -1,
+            -1, 26, 27, 28, 29, 30, 31, 32, 33, 34, 35, 36, 37, 38, 39, 40,
+            41, 42, 43, 44, 45, 46, 47, 48, 49, 50, 51, -1, -1, -1, -1, -1};
+
+    private Base64Util() {
+    }
+
+    public static String encode(byte[] data) {
+        StringBuffer sb = new StringBuffer();
+        int len = data.length;
+        int i = 0;
+        int b1, b2, b3;
+        while (i < len) {
+            b1 = data[i++] & 0xff;
+            if (i == len) {
+                sb.append(base64EncodeChars[b1 >>> 2]);
+                sb.append(base64EncodeChars[(b1 & 0x3) << 4]);
+                sb.append("==");
+                break;
+            }
+            b2 = data[i++] & 0xff;
+            if (i == len) {
+                sb.append(base64EncodeChars[b1 >>> 2]);
+                sb.append(
+                        base64EncodeChars[((b1 & 0x03) << 4) | ((b2 & 0xf0) >>> 4)]);
+                sb.append(base64EncodeChars[(b2 & 0x0f) << 2]);
+                sb.append("=");
+                break;
+            }
+            b3 = data[i++] & 0xff;
+            sb.append(base64EncodeChars[b1 >>> 2]);
+            sb.append(
+                    base64EncodeChars[((b1 & 0x03) << 4) | ((b2 & 0xf0) >>> 4)]);
+            sb.append(
+                    base64EncodeChars[((b2 & 0x0f) << 2) | ((b3 & 0xc0) >>> 6)]);
+            sb.append(base64EncodeChars[b3 & 0x3f]);
+        }
+        return sb.toString();
+    }
+
+
+    public static byte[] decode(String str) {
+        byte[] data = str.getBytes();
+        int len = data.length;
+        ByteArrayOutputStream buf = new ByteArrayOutputStream(len);
+        int i = 0;
+        int b1, b2, b3, b4;
+        while (i < len) {
+            /* b1 */
+            do {
+                b1 = base64DecodeChars[data[i++]];
+            } while (i < len && b1 == -1);
+            if (b1 == -1) {
+                break;
+            }
+            /* b2 */
+            do {
+                b2 = base64DecodeChars[data[i++]];
+            } while (i < len && b2 == -1);
+            if (b2 == -1) {
+                break;
+            }
+            buf.write(((b1 << 2) | ((b2 & 0x30) >>> 4)));
+            /* b3 */
+            do {
+                b3 = data[i++];
+                if (b3 == 61) {
+                    return buf.toByteArray();
+                }
+                b3 = base64DecodeChars[b3];
+            } while (i < len && b3 == -1);
+            if (b3 == -1) {
+                break;
+            }
+            buf.write((((b2 & 0x0f) << 4) | ((b3 & 0x3c) >>> 2)));
+            /* b4 */
+            do {
+                b4 = data[i++];
+                if (b4 == 61) {
+                    return buf.toByteArray();
+                }
+                b4 = base64DecodeChars[b4];
+            } while (i < len && b4 == -1);
+            if (b4 == -1) {
+                break;
+            }
+            buf.write((((b3 & 0x03) << 6) | b4));
+        }
+        return buf.toByteArray();
+    }
+}

frame-module-admin/src/main/java/com/bohuikeji/frame/module/admin/sms/CryptUtil.java

@@ -0,0 +1,110 @@
+package com.bohuikeji.frame.module.admin.sms;
+
+import javax.crypto.Cipher;
+import javax.crypto.SecretKey;
+import javax.crypto.spec.IvParameterSpec;
+import javax.crypto.spec.SecretKeySpec;
+import java.security.MessageDigest;
+
+public class CryptUtil {
+    private static final String desAlgorithm = "DESede/CBC/NoPadding";
+    private static final String desKeyAlgorithm = "DESede";
+    private static final char[] DIGITS = {
+            '0', '1', '2', '3', '4', '5', '6', '7', '8', '9',
+            'a', 'b', 'c', 'd', 'e', 'f'};
+    private static final byte[] defaultIV = new byte[]{'0', '0', '0', '0', '0', '0', '0', '0'};
+
+    public CryptUtil() {
+    }
+
+    private static SecretKey KeyGenerator(String keyStr) throws Exception {
+        byte[] input = md5Hex(keyStr).substring(0, 24).getBytes("GBK");
+        SecretKey triDesKey = new SecretKeySpec(input, desKeyAlgorithm);
+        return triDesKey;
+    }
+
+    public static String encryptBy3DesAndBase64(String content, String keyStr) throws Exception {
+        return encryptBy3DesAndBase64(content, keyStr, "UTF-8");
+    }
+
+    public static String decryptBy3DesAndBase64(String content, String keyStr) throws Exception {
+        return decryptBy3DesAndBase64(content, keyStr, "UTF-8");
+    }
+
+    public static String encryptBy3DesAndBase64(String content, String keyStr, String encoding) throws
+            Exception {
+        byte[] output = null;
+        byte[] input = null;
+        int residue = (content.getBytes(encoding).length) % 8;
+        if (0 != residue) {
+            int padLen = 8 - residue;
+            StringBuffer strBuf = new StringBuffer(content);
+            for (int i = 0; i < padLen; i++) {
+                strBuf.append(' ');
+            }
+            input = (new String(strBuf)).getBytes(encoding);
+        } else {
+            input = content.getBytes(encoding);
+        }
+        output = encryptBy3Des(input, keyStr);
+        return Base64Util.encode(output).replaceAll("[\\n\\r]", "");
+    }
+
+    public static String decryptBy3DesAndBase64(String content, String keyStr, String encoding) throws
+            Exception {
+        byte[] output = null;
+        byte[] input = null;
+        input = Base64Util.decode(content);
+        output = decryptBy3Des(input, keyStr);
+        String retStr = new String(output, encoding);
+        return (retStr.trim());
+    }
+
+    public static byte[] encryptBy3Des(byte[] content, String keyStr) throws Exception {
+        return cryptBy3Des(keyStr, 1, null, content);
+    }
+
+    public static byte[] decryptBy3Des(byte[] content, String keyStr) throws Exception {
+        return cryptBy3Des(keyStr, 2, null, content);
+    }
+
+    public static byte[] cryptBy3Des(String keyStr, int cryptModel, byte[] iv, byte[] content) throws Exception {
+        Cipher cipher = null;
+        SecretKey key = KeyGenerator(keyStr);
+        IvParameterSpec IVSpec = iv == null ? IvGenerator(defaultIV) : IvGenerator(iv);
+        cipher = Cipher.getInstance(desAlgorithm);
+        cipher.init(cryptModel, key, IVSpec);
+        return cipher.doFinal(content);
+    }
+
+    public static String md5Hex(String content) throws Exception {
+        MessageDigest md5 = null;
+        md5 = MessageDigest.getInstance("MD5");
+        md5.update(content.getBytes("GBK"));
+        return new String(encodeHex(md5.digest()));
+    }
+
+    public static String md5Hex(String content, String charsetName) throws Exception {
+        MessageDigest md5 = null;
+        md5 = MessageDigest.getInstance("MD5");
+        md5.update(content.getBytes(charsetName));
+        return new String(encodeHex(md5.digest()));
+    }
+
+    public static char[] encodeHex(byte[] data) {
+        int len = data.length;
+        char[] out = new char[len << 1];
+        int i = 0;
+        int j = 0;
+        for (; i < len; i++) {
+            out[j++] = DIGITS[(0xf0 & data[i]) >>> 4];
+            out[j++] = DIGITS[0xf & data[i]];
+        }
+        return out;
+    }
+
+    private static IvParameterSpec IvGenerator(byte[] b) {
+        IvParameterSpec IV = new IvParameterSpec(b);
+        return IV;
+    }
+}

frame-module-admin/src/main/java/com/bohuikeji/frame/module/admin/sms/HttpUtil.java

@@ -0,0 +1,157 @@
+package com.bohuikeji.frame.module.admin.sms;
+
+import com.alibaba.fastjson.JSON;
+
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStreamReader;
+import java.io.PrintWriter;
+import java.net.URL;
+import java.net.URLConnection;
+import java.nio.charset.StandardCharsets;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Map.Entry;
+
+/**
+ * @author: Chenzhenyong
+ * @description: 简单发送请求工具类
+ * @date: Created in 12:21 2018/7/24
+ */
+public class HttpUtil {
+
+    // 设置连接超时时间，单位毫秒。
+    private static final int CONNECT_TIMEOUT = 20000;
+    // 请求获取数据的超时时间(即响应时间)，单位毫秒。
+    private static final int SOCKET_TIMEOUT = 20000;
+    // 记录http调用开始时间
+    public static ThreadLocal<Long> httpStartTime = new ThreadLocal() {
+        @Override
+        protected Long initialValue() {
+            return 0L;
+        }
+    };
+
+    /**
+     * post 请求
+     * @param url
+     * @param body
+     * @return
+     */
+    public static String doHttpPost(String url, Map<String, String> body) throws IOException {
+        return doHttpPost(url, null, body);
+    }
+
+    /**
+     * get 请求
+     * @param url
+     * @param req
+     * @return
+     * @throws Exception
+     */
+    public static String doHttpGet(String url, Map<String, String> req,boolean urlEncode) throws Exception{
+        StringBuffer sb = new StringBuffer().append("?");
+        for(Entry<String, String> entry : req.entrySet()){
+            sb.append(entry.getKey()).append("=").append(entry.getValue()).append("&");
+        }
+        return doHttpPost(url+sb.toString(),null,"");
+    }
+
+    /**
+     * HTTP POST
+     *
+     * @param url    请求地址
+     * @param header 请求头
+     * @param req    请求参数
+     * @return 应答参数
+     */
+    public static String doHttpPost(String url, Map<String, String> header, String req) throws IOException {
+        httpStartTime.set(System.currentTimeMillis());
+        PrintWriter outPrintWriter = null;
+        BufferedReader inBufferedReader = null;
+        try {
+            URLConnection urlConnection = new URL(url).openConnection(); // 打开和URL之间的连接
+            // 设置通用的请求属性
+            urlConnection.setRequestProperty("accept", "*/*");
+            urlConnection.setRequestProperty("connection", "Keep-Alive");
+            urlConnection.setRequestProperty("user-agent",
+                    "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
+            if (header != null) {
+                for (Entry<String, String> entry : header.entrySet()) {
+                    urlConnection.setRequestProperty(entry.getKey(), entry.getValue());
+                }
+            }
+
+            urlConnection.setDoOutput(true);
+            urlConnection.setDoInput(true);
+            urlConnection.setConnectTimeout(CONNECT_TIMEOUT);
+            urlConnection.setReadTimeout(SOCKET_TIMEOUT);
+            urlConnection.connect();
+
+            outPrintWriter = new PrintWriter(urlConnection.getOutputStream());
+            outPrintWriter.print(req);
+            outPrintWriter.flush();
+            inBufferedReader = new BufferedReader(new InputStreamReader(
+                    urlConnection.getInputStream(), StandardCharsets.UTF_8));
+            String line = "";
+            String response = "";
+            while ((line = inBufferedReader.readLine()) != null) {
+                response += line;
+            }
+            return response;
+
+        } finally {
+            try {
+                if (outPrintWriter != null) {
+                    outPrintWriter.close();
+                }
+                if (inBufferedReader != null) {
+                    inBufferedReader.close();
+                }
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+    }
+
+    /**
+     * HTTP POST
+     *
+     * @param url    请求地址
+     * @param header 请求头
+     * @param object 请求参数
+     * @return 应答参数
+     */
+    public static String doHttpPostJson(String url, Map<String, String> header, Object object) throws IOException {
+        if (header == null) {
+            header = new HashMap<String, String>();
+        }
+        header.put("Content-Type", "application/json;charset=UTF-8");
+        String req = "";
+        if (object != null) {
+            req = JSON.toJSONString(object);
+        }
+        return doHttpPost(url, header, req);
+    }
+
+    /**
+     * HTTP POST
+     *
+     * @param url    请求地址
+     * @param header 请求头
+     * @param body   请求参数
+     * @return 应答参数
+     */
+    public static String doHttpPost(String url, Map<String, String> header, Map<String, String> body) throws IOException {
+        String req = "";
+        if (body != null) {
+            StringBuilder sb = new StringBuilder();
+            for (Entry<String, String> entry : body.entrySet()) {
+                sb.append(entry.getKey()).append("=").append(entry.getValue()).append("&");
+            }
+            req = sb.toString();
+        }
+        return doHttpPost(url, header, req);
+    }
+
+}

frame-module-admin/src/main/java/com/bohuikeji/frame/module/admin/utils/YiXunGmsUtils.java

@@ -1,19 +1,26 @@
 package com.bohuikeji.frame.module.admin.utils;
 
 import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.bohuikeji.frame.module.admin.component.RedisUtil;
+import com.bohuikeji.frame.module.admin.sms.CryptUtil;
+import com.bohuikeji.frame.module.admin.sms.HttpUtil;
 import jodd.http.HttpRequest;
 import lombok.extern.slf4j.Slf4j;
 import org.junit.Test;
 import org.springframework.util.DigestUtils;
 
+import java.io.IOException;
 import java.nio.charset.StandardCharsets;
+import java.text.SimpleDateFormat;
 import java.time.Duration;
 import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
+import java.util.Date;
 import java.util.HashMap;
 import java.util.Map;
+import java.util.UUID;
 
 /**
  * 51易迅短信平台工具类
@@ -30,27 +37,31 @@ import java.util.Map;
 @Slf4j
 public class YiXunGmsUtils {
 
+    //private static final String SENDBATCH_URL = "https://nsms.51yixun.com/sms/sendBatch";
+    private static final String SEND_URL = "https://nsms.51yixun.com/sms/send";
+    private static final String REPORT_URL = "https://nsms.51yixun.com/sms/report";
+    private static final String MO_URL = "https://nsms.51yixun.com/sms/mo";
 
 
-    public static String SEND_URL="http://sms.51yixun.com:8200/sms/send";
+    /*public static String SEND_URL="http://sms.51yixun.com:8200/sms/send";
 
     public static String REPORT_URL="http://sms.51yixun.com:8200/sms/report";
 
     public static String PRICE_URL="http://sms.51yixun.com:8200/sms/balance";
 
-    public static String MO_URL="http://sms.51yixun.com:8200/sms/mo";
+    public static String MO_URL="http://sms.51yixun.com:8200/sms/mo";*/
 
     /**
      * 短信验证码
      */
-    public static String APPID="LHW-SMS-03ZEV";
-    public static String secretKey="8E9FC62D170554C3";
+    public static String APPID="991727676356580131";
+    public static String secretKey="56f2d1de4b2b40588536673802331115";
 
     /**
      * 普通物流短信
      */
-    public static String APPID_2="LHW-SMS-0T6PH";
-    public static String secretKey_2="AD7FFB4C865654C4";
+    public static String APPID_2="991727676385745955";
+    public static String secretKey_2="a7e6e8b33e2b4a0da073325059548121";
 
     public static String MSG_SIGN="【同城急送】";
 
@@ -154,10 +165,16 @@ public class YiXunGmsUtils {
             Object v = entry.getValue();
             content = content.replace("${" + k + "}", v.toString());
         }
-        Map<String,String> reqParams=getPublicParams("SMS_184115918".equals(templateCode));
+        Map<String,String> reqParams=getPublicParamsn("SMS_184115918".equals(templateCode));
         reqParams.put(phone, content);
-        String resStr=HttpRequest.get(SEND_URL).query(reqParams).send().bodyText();
+        String resStr= null;
+        try {
+            resStr = HttpUtil.doHttpPost(SEND_URL, reqParams);
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
         JSONObject res=JSON.parseObject(resStr);
+        log.error("【短信发送失败】1号码：{}，发送内容：{},返回信息：{}",phone,content,res);
         if("SUCCESS".equals(res.getString("code"))){
             if (isCache){
                 //放入缓存
@@ -165,25 +182,24 @@ public class YiXunGmsUtils {
             }
             return true;
         }
-        log.error("【短信发送失败】号码：{}，发送内容：{},返回信息：{}",phone,content,resStr);
+        log.error("【短信发送失败】2号码：{}，发送内容：{},返回信息：{}",phone,content,resStr);
         return false;
     }
-
-    public static JSONObject getReport(){
+   /* public static JSONObject getReport(){
         String resStr=HttpRequest.get(REPORT_URL).query(getPublicParams(false)).send().bodyText();
         log.info("状态查询接口接口返回：{}",resStr);
         return null;
-    }
-    public static JSONObject getPrice(){
+    }*/
+    /*public static JSONObject getPrice(){
         String resStr=HttpRequest.get(PRICE_URL).query(getPublicParams(false)).send().bodyText();
         log.info("余额接口接口返回：{}",resStr);
         return null;
-    }
-    public static JSONObject geMo(){
+    }*/
+    /*public static JSONObject geMo(){
         String resStr=HttpRequest.get(MO_URL).query(getPublicParams(false)).send().bodyText();
         log.info("查询上行信息接口接口返回：{}",resStr);
         return null;
-    }
+    }*/
 
     @Test
     public void test(){
@@ -193,7 +209,7 @@ public class YiXunGmsUtils {
         params.put("mag","内蒙古自治区呼和浩特市玉泉区昭乌达路三里应B区东门。");
         params.put("rep","内蒙古自治区呼和浩特市玉泉区昭乌达路三里应B区东门。");
 
-        sendMsg("15771335697","SMS_TEMP_ADDRESS_EDIT",params);
+        sendMsg("15540709945","SMS_TEMP_ADDRESS_EDIT",params);
         //getReport();
     }
 
@@ -219,7 +235,7 @@ public class YiXunGmsUtils {
      * @param isCode 是否为验证码短信
      * @return
      */
-    public static Map<String,String> getPublicParams(boolean isCode){
+    /*public static Map<String,String> getPublicParams(boolean isCode){
         Map<String,String> reqParams=new HashMap<>();
         String timestamp=getTimestamp();
         reqParams.put("appId",isCode?APPID:APPID_2);
@@ -227,6 +243,30 @@ public class YiXunGmsUtils {
         reqParams.put("sign",sign(timestamp,isCode?APPID:APPID_2,isCode?secretKey:secretKey_2));
         reqParams.put("batchId","10");
         return reqParams;
+    }*/
+
+    public static Map<String,String> getPublicParamsn(boolean isCode){
+        Map<String, String> params = new HashMap();
+        String timestamp=getTimestamp();
+        params.put("appId",isCode?APPID:APPID_2);
+        params.put("timestamp",timestamp);
+        params.put("type", "msms");
+        try {
+            if(isCode){
+                params.put("sign",CryptUtil.md5Hex(APPID+secretKey+timestamp));
+                log.error("【短信发送1】1发送内容：{}",params);
+            }else {
+                params.put("sign",CryptUtil.md5Hex(APPID_2+secretKey_2+timestamp));
+                log.error("【短信发送2】2发送内容：{}",params);
+            }
+
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        params.put("schTime","");
+        params.put("batchId",UUID.randomUUID().toString().replaceAll("-", "").substring(0, 10));
+        params.put("addserial",NumberUtils.getShort());
+        return params;
     }
 
 }