sms验证码功能配置文件

jeeplus-modules/jeeplus-system/src/main/java/com/jeeplus/sys/sms/CcopHttpClient.java

@@ -0,0 +1,66 @@
+package com.jeeplus.sys.sms;
+
+import org.apache.http.conn.scheme.Scheme;
+import org.apache.http.conn.ssl.SSLSocketFactory;
+import org.apache.http.impl.client.DefaultHttpClient;
+
+import javax.net.ssl.SSLContext;
+import javax.net.ssl.TrustManager;
+import javax.net.ssl.X509TrustManager;
+import java.security.KeyManagementException;
+import java.security.NoSuchAlgorithmException;
+import java.security.Principal;
+import java.security.SecureRandom;
+import java.security.cert.CertificateException;
+import java.security.cert.X509Certificate;
+
+public class CcopHttpClient
+{
+  public DefaultHttpClient registerSSL(String hostname, String protocol, int port, String scheme)
+    throws NoSuchAlgorithmException, KeyManagementException
+  {
+    DefaultHttpClient httpclient = new DefaultHttpClient();
+
+    SSLContext ctx = SSLContext.getInstance(protocol);
+
+   X509TrustManager tm = new X509TrustManager()
+    {
+      public void checkClientTrusted(X509Certificate[] chain,String authType)
+			 throws CertificateException {
+      }
+
+      public void checkServerTrusted(X509Certificate[] chain,String authType)
+ 			 throws CertificateException {
+        if ((chain == null) || (chain.length == 0))
+          throw new IllegalArgumentException("null or zero-length certificate chain");
+        if ((authType == null) || (authType.length() == 0))
+          throw new IllegalArgumentException("null or zero-length authentication type");
+
+        boolean br = false;
+        Principal principal = null;
+       for (X509Certificate x509Certificate : chain) {   
+          principal = x509Certificate.getSubjectX500Principal();
+          if (principal != null) {
+            br = true;
+            return;
+          }
+        }
+        if (!(br))
+          throw new CertificateException("服务端证书验证失败！");
+      }
+
+      public X509Certificate[] getAcceptedIssuers()
+      {
+        return new X509Certificate[0];
+      }
+
+    };
+    ctx.init(null, new TrustManager[] { tm }, new SecureRandom());
+
+    SSLSocketFactory socketFactory = new SSLSocketFactory(ctx, SSLSocketFactory.ALLOW_ALL_HOSTNAME_VERIFIER);
+    Scheme sch = new Scheme(scheme, port, socketFactory);
+
+    httpclient.getConnectionManager().getSchemeRegistry().register(sch);
+    return httpclient;
+  }
+}

jeeplus-modules/jeeplus-system/src/main/java/com/jeeplus/sys/sms/DateUtil.java

@@ -0,0 +1,78 @@
+/*
+ *  Copyright (c) 2014 The CCP project authors. All Rights Reserved.
+ *
+ *  Use of this source code is governed by a Beijing Speedtong Information Technology Co.,Ltd license
+ *  that can be found in the LICENSE file in the root of the web site.
+ *
+ *   http://www.yuntongxun.com
+ *
+ *  An additional intellectual property rights grant can be found
+ *  in the file PATENTS.  All contributing project authors may
+ *  be found in the AUTHORS file in the root of the source tree.
+ */
+package com.jeeplus.sys.sms;
+
+import java.text.SimpleDateFormat;
+import java.util.Date;
+
+public class DateUtil
+{
+  public static final int DEFAULT = 0;
+  public static final int YM = 1;
+  public static final int YMR_SLASH = 11;
+  public static final int NO_SLASH = 2;
+  public static final int YM_NO_SLASH = 3;
+  public static final int DATE_TIME = 4;
+  public static final int DATE_TIME_NO_SLASH = 5;
+  public static final int DATE_HM = 6;
+  public static final int TIME = 7;
+  public static final int HM = 8;
+  public static final int LONG_TIME = 9;
+  public static final int SHORT_TIME = 10;
+  public static final int DATE_TIME_LINE = 12;
+
+  public static String dateToStr(Date date, String pattern)
+  {
+    if ((date == null) || (date.equals("")))
+      return null;
+    SimpleDateFormat formatter = new SimpleDateFormat(pattern);
+    return formatter.format(date);
+  }
+
+  public static String dateToStr(Date date) {
+    return dateToStr(date, "yyyy/MM/dd");
+  }
+
+  public static String dateToStr(Date date, int type) {
+    switch (type)
+    {
+    case 0:
+      return dateToStr(date);
+    case 1:
+      return dateToStr(date, "yyyy/MM");
+    case 2:
+      return dateToStr(date, "yyyyMMdd");
+    case 11:
+      return dateToStr(date, "yyyy-MM-dd");
+    case 3:
+      return dateToStr(date, "yyyyMM");
+    case 4:
+      return dateToStr(date, "yyyy/MM/dd HH:mm:ss");
+    case 5:
+      return dateToStr(date, "yyyyMMddHHmmss");
+    case 6:
+      return dateToStr(date, "yyyy/MM/dd HH:mm");
+    case 7:
+      return dateToStr(date, "HH:mm:ss");
+    case 8:
+      return dateToStr(date, "HH:mm");
+    case 9:
+      return dateToStr(date, "HHmmss");
+    case 10:
+      return dateToStr(date, "HHmm");
+    case 12:
+      return dateToStr(date, "yyyy-MM-dd HH:mm:ss");
+    }
+    throw new IllegalArgumentException("Type undefined : " + type);
+  }
+}

jeeplus-modules/jeeplus-system/src/main/java/com/jeeplus/sys/sms/EncryptUtil.java

@@ -0,0 +1,62 @@
+/*
+ *  Copyright (c) 2014 The CCP project authors. All Rights Reserved.
+ *
+ *  Use of this source code is governed by a Beijing Speedtong Information Technology Co.,Ltd license
+ *  that can be found in the LICENSE file in the root of the web site.
+ *
+ *   http://www.yuntongxun.com
+ *
+ *  An additional intellectual property rights grant can be found
+ *  in the file PATENTS.  All contributing project authors may
+ *  be found in the AUTHORS file in the root of the source tree.
+ */
+package com.jeeplus.sys.sms;
+
+
+
+import sun.misc.BASE64Decoder;
+import sun.misc.BASE64Encoder;
+
+import java.io.IOException;
+import java.io.UnsupportedEncodingException;
+import java.security.MessageDigest;
+import java.security.NoSuchAlgorithmException;
+
+
+public class EncryptUtil
+{
+  private static final String UTF8 = "utf-8";
+
+  public String md5Digest(String src) throws NoSuchAlgorithmException, UnsupportedEncodingException
+  {
+    MessageDigest md = MessageDigest.getInstance("MD5");
+    byte[] b = md.digest(src.getBytes("utf-8"));
+    return byte2HexStr(b);
+  }
+
+  public String base64Encoder(String src) throws UnsupportedEncodingException
+  {
+    BASE64Encoder encoder = new BASE64Encoder();
+    return encoder.encode(src.getBytes("utf-8"));
+  }
+
+  public String base64Decoder(String dest)
+    throws NoSuchAlgorithmException, IOException
+  {
+    BASE64Decoder decoder = new BASE64Decoder();
+    return new String(decoder.decodeBuffer(dest), "utf-8");
+  }
+
+  private String byte2HexStr(byte[] b)
+  {
+    StringBuilder sb = new StringBuilder();
+    for (int i = 0; i < b.length; ++i) {
+      String s = Integer.toHexString(b[i] & 0xFF);
+      if (s.length() == 1)
+        sb.append("0");
+
+      sb.append(s.toUpperCase());
+    }
+    return sb.toString();
+  }
+}

jeeplus-modules/jeeplus-system/src/main/java/com/jeeplus/sys/sms/LoggerUtil.java

@@ -0,0 +1,61 @@
+package com.jeeplus.sys.sms;
+
+import org.apache.log4j.Logger;
+import org.apache.log4j.PropertyConfigurator;
+
+import java.util.Date;
+
+
+public class LoggerUtil {
+	private static boolean isLog = true;
+	private static Logger logger;
+	static {
+		if (logger == null) {
+			logger = Logger.getLogger(CCPRestSDK.class);
+			
+		}
+	}
+	 
+	public static void setLogger(boolean isLog) {
+		isLog = isLog;
+	}
+	public static void setLog(Logger logger) {
+		logger = logger;
+	}
+	
+	public static void setLogLevel(int level) {
+		if (logger == null) {
+			logger = Logger.getLogger(CCPRestSDK.class);
+		}
+		PropertyConfigurator.configure(PropertiesUtil.getPropertie(level));
+		 
+
+
+	}
+
+	public static void debug(Object msg) {
+		if (isLog)
+			logger.debug(new Date()+" "+msg);
+	}
+
+	public static void info(Object msg) {
+		if (isLog)
+			logger.info(new Date()+" "+msg);
+	}
+
+	public static void warn(Object msg) {
+		if (isLog)
+			logger.warn(msg);
+	}
+
+	public static void error(Object msg) {
+		if (isLog)
+			logger.error(msg);
+	}
+
+	public static void fatal(Object msg) {
+		if (isLog)
+			logger.fatal(msg);
+	}
+	  
+}

jeeplus-modules/jeeplus-system/src/main/java/com/jeeplus/sys/sms/PropertiesUtil.java

@@ -0,0 +1,45 @@
+/*
+ *  Copyright (c) 2013 The CCP project authors. All Rights Reserved.
+ *
+ *  Use of this source code is governed by a Beijing Speedtong Information Technology Co.,Ltd license
+ *  that can be found in the LICENSE file in the root of the web site.
+ *
+ *   http://www.cloopen.com
+ *
+ *  An additional intellectual property rights grant can be found
+ *  in the file PATENTS.  All contributing project authors may
+ *  be found in the AUTHORS file in the root of the source tree.
+ */
+package com.jeeplus.sys.sms;
+import java.util.Properties;
+
+public class PropertiesUtil {
+	
+	
+	public static Properties getPropertie(int level) {
+			String loggerLever="all";
+			if(level==1){
+				loggerLever="info";
+			}else if(level==2){
+				loggerLever="warn";
+			}else if(level==3){
+				loggerLever="error";
+			}else if(level==4){
+				loggerLever="fatal";
+			}
+			Properties props = new Properties();
+			
+			props.setProperty("log4j.rootLogger", loggerLever+",A,R");
+			props.setProperty("log4j.appender.A", "org.apache.log4j.ConsoleAppender");
+			props.setProperty("log4j.appender.A.layout", "org.apache.log4j.PatternLayout");
+			props.setProperty("log4j.appender.R", "org.apache.log4j.RollingFileAppender");
+			props.setProperty("log4j.appender.R.File", "log.txt");
+			props.setProperty("log4j.appender.R.MaxFileSize", "100KB");
+			props.setProperty("log4j.appender.R.MaxBackupIndex", "1");
+			props.setProperty("log4j.appender.R.layout", "org.apache.log4j.PatternLayout");
+			props.setProperty("log4j.appender.R.layout.ConversionPattern", "%p %t %c - %m%n");
+			
+			return props;
+	}
+	
+}

jeeplus-modules/jeeplus-system/src/main/java/com/jeeplus/sys/sms/SMSUtils.java

@@ -0,0 +1,196 @@
+package com.jeeplus.sys.sms;
+
+import com.jeeplus.sys.utils.Global;
+
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStreamReader;
+import java.net.HttpURLConnection;
+import java.net.URL;
+import java.net.URLEncoder;
+import java.util.HashMap;
+
+/*
+功能:		企信通PHP HTTP接口 发送短信
+修改日期:	2014-03-19
+说明:		http://api.cnsms.cn/?ac=send&uid=用户账号&pwd=MD5位32密码&mobile=号码&content=内容
+状态:
+	100 发送成功
+	101 验证失败
+	102 短信不足
+	103 操作失败
+	104 非法字符
+	105 内容过多
+	106 号码过多
+	107 频率过快
+	108 号码内容空
+	109 账号冻结
+	110 禁止频繁单条发送
+	111 系统暂定发送
+	112 号码不正确
+	120 系统升级
+*/
+public class SMSUtils {
+    //发送短信，uid，pwd，参数值请向企信通申请， tel：发送的手机号， content:发送的内容
+    public static String send(String mobile,String content,String sendTime,String checkcontent) throws IOException {
+        BufferedReader in = null;
+        String result = "";
+        try {
+            // 创建StringBuffer对象用来操作字符串
+            StringBuffer sb = new StringBuffer("http://www.lcqxt.com/sms.aspx?action=send");
+
+            // 向StringBuffer追加用户名
+            sb.append("&userid=" + Global.getSmsUserid());//在此申请企信通uid，并进行配置用户名
+
+            // 向StringBuffer追加密码（密码采用MD5 32位 小写）
+            sb.append("&account=" + Global.getSmsAccount());
+
+            // 向StringBuffer追加密码（密码采用MD5 32位 小写）
+            //sb.append("&pwd="+Digests.string2MD5(pwd));//在此申请企信通uid，并进行配置密码
+            sb.append("&password=" + Global.getSmsPassword());
+            // 向StringBuffer追加手机号码
+            sb.append("&mobile=" + mobile);
+            // 向StringBuffer追加消息内容转URL标准码
+            sb.append("&content=" + URLEncoder.encode(content, "utf8"));
+            sb.append("&sendTime=" + sendTime);
+            sb.append("&checkcontent=" + checkcontent);
+
+            // 创建url对象
+            URL url = new URL(sb.toString());
+
+            // 打开url连接
+            HttpURLConnection connection = (HttpURLConnection) url.openConnection();
+
+            // 设置url请求方式 ‘get’ 或者 ‘post’
+            connection.setRequestMethod("POST");
+
+            // 发送
+            in = new BufferedReader(new InputStreamReader(url.openStream()));
+
+            // 返回发送结果
+            String line;
+            while ((line = in.readLine()) != null) {
+                result += line;
+            }
+        }catch (Exception e) {
+            System.out.println("发送 POST 请求出现异常！"+e);
+            e.printStackTrace();
+        }
+        //使用finally块来关闭输出流、输入流
+        finally{
+            try{
+                if(in!=null){
+                    in.close();
+                }
+            }
+            catch(IOException ex){
+                ex.printStackTrace();
+            }
+            return result;
+        }
+    }
+//    //容联云通讯(160040--超过同模板同号码上限)
+//    public static String sends(String mobile,String randomCode) throws IOException {
+//        BufferedReader reader = null;
+//        StringBuffer result = new StringBuffer("");
+//        try {
+//            StringBuffer sb = new StringBuffer("https://app.cloopen.com:8883/2013-12-26/Accounts/"+Global.getRongUserid()+"/SMS/TemplateSMS?");
+//            StringBuffer sbr = new StringBuffer();
+//            String aid = Global.getRongUserid();
+//            String atoken = Global.getRongToken();
+//            SimpleDateFormat sdf =   new SimpleDateFormat( "yyyyMMddHHmmss" );
+//            String time =sdf.format(new Date());
+//            sbr.append(aid).append(atoken).append(time);
+//            //模板指定参数
+//            String [] s = new String[]{randomCode,"60"};
+//            //sig
+//            sb.append("sig="+ MD5.toMD5(sbr.toString()));
+//
+//            // 创建url对象
+//            URL url = new URL(sb.toString());
+//
+//            // 打开url连接
+//            HttpURLConnection connection = (HttpURLConnection) url.openConnection();
+//
+//            // 设置url请求方式 ‘get’ 或者 ‘post’
+//            connection.setRequestMethod("POST");
+//            connection.setRequestProperty("Accept","application/json");
+//            connection.setRequestProperty("Content-Type", "application/json;charset=UTF-8");
+//            String an = Global.getRongUserid()+":"+time;
+//            BASE64Encoder encoder = new BASE64Encoder();
+//            an = encoder.encode(an.getBytes("UTF-8"));
+//            connection.setRequestProperty("Authorization", an);
+//            connection.setRequestProperty("Content-Length", "256");
+//            connection.setDoOutput(true);
+//            connection.connect();
+//            //post请求
+//            DataOutputStream out = new DataOutputStream(connection.getOutputStream());
+//            JSONObject obj = new JSONObject();
+//            obj.element("to", mobile);
+//            obj.element("appId", Global.getAppId());
+//            obj.element("templateId", Global.getTemplateId());
+//            obj.element("datas", s);
+//
+//            out.writeBytes(obj.toString());
+//            out.flush();
+//            out.close();
+//            // 发送
+//            reader = new BufferedReader(new InputStreamReader(
+//                    connection.getInputStream()));
+//            String lines;
+//            while ((lines = reader.readLine()) != null) {
+//                lines = new String(lines.getBytes(), "utf-8");
+//                result.append(lines);
+//            }
+//            System.out.println(result);
+//            // 断开连接
+//            connection.disconnect();
+//        }catch (Exception e) {
+//            System.out.println("发送 POST 请求出现异常！"+e);
+//            e.printStackTrace();
+//        }
+//        //使用finally块来关闭输出流、输入流
+//        finally{
+//            try{
+//                if(reader!=null){
+//                    reader.close();
+//                }
+//            }
+//            catch(IOException ex){
+//                ex.printStackTrace();
+//            }
+//            return result.toString();
+//        }
+//    }
+
+
+    //容联云通讯(160040--超过同模板同号码上限)
+    public static HashMap<String,Object> sends(String mobile,String randomCode) throws IOException {
+        HashMap<String, Object> result = null;
+        CCPRestSDK restAPI = new CCPRestSDK();
+        try {
+            String aid = Global.getRongUserid();
+            String atoken = Global.getRongToken();
+            String appId = Global.getAppId();
+            String templateId = Global.getTemplateId();
+            restAPI.init("app.cloopen.com", "8883");
+            restAPI.setAccount(aid, atoken);
+            restAPI.setAppId(appId);
+            result = restAPI.sendTemplateSMS(mobile,templateId,new String[]{randomCode,"60"});
+        }catch (Exception e) {
+            System.out.println("发送 POST 请求出现异常！"+e);
+            e.printStackTrace();
+        }
+        return result;
+    }
+
+//    public static void main(String[] args) throws Exception {
+//        String inputline =sends("15201428039","系统预警");
+//        System.out.println(inputline);
+//        long sys = System.currentTimeMillis();
+//        System.out.println(sys);
+//    }
+
+
+
+}