小程序订阅服务推送功能

dq-financial-hrms-auth/src/main/java/com/daqing/financial/hrauth/config/WeChatConfig.java

@@ -76,6 +76,12 @@ public class WeChatConfig implements Serializable {
      */
     private String OPEN_USER_INFO_URL ="https://api.weixin.qq.com/sns/userinfo?access_token=%s&openid=%s&lang=zh_CN";
 
+
+    /**
+     * 小程序订阅服务
+     */
+    private String ORDER_URL ="https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=%s&secret=%s";
+
     // 设置@Value注解取值不到忽略（不报错）
     @Bean
     public static PropertySourcesPlaceholderConfigurer placeholderConfigurer() {

dq-financial-hrms-auth/src/main/java/com/daqing/financial/hrauth/controller/WXTokenController.java

@@ -1,19 +1,29 @@
 package com.daqing.financial.hrauth.controller;
 
-
+import com.alibaba.fastjson.JSON;
-import com.daqing.financial.hrauth.util.WXPublicUtils;
+import com.daqing.financial.hrauth.config.WeChatConfig;
+import com.daqing.financial.hrauth.util.*;
 import io.swagger.annotations.Api;
 import lombok.extern.slf4j.Slf4j;
+import net.sf.json.JSONObject;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
 import javax.servlet.http.HttpServletRequest;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
 
 @RestController
 @RequestMapping("/wxpublic")
 @Api(tags = "验证公众平台token")
 @Slf4j
 public class WXTokenController {
+
+    @Autowired
+    private WeChatConfig weChatConfig;
+
     @RequestMapping("/verify_wx_token")
     public String verifyWXToken(HttpServletRequest request) {
         String msgSignature = request.getParameter("signature");
@@ -26,6 +36,52 @@ public class WXTokenController {
         return null;
     }
 
+    @RequestMapping("/sendDingyue")
+    public void sendDingyue(String open_id,String time,String jieguo){
+        System.out.println("来了订阅服务推送~~~~~~~~~~~~~~~~~~~~");
+        Template template=new Template();
+        template.setTemplate_id("Oj6kc3K8a1CWd-l4VaWsYM3R-Obr3UOX_M6AQxD7Hpc");//签名id
+        template.setTouser(open_id);//用户的 openid
+        List<TemplateParam> paras=new ArrayList<TemplateParam>();
+        paras.add(new TemplateParam("thing1.DATA","模板内容"));
+        paras.add(new TemplateParam("thing2.DATA",time));
+        paras.add(new TemplateParam("thing3.DATA",jieguo));
+        paras.add(new TemplateParam("thing4.DATA","模板内容"));
+        template.setTemplateParamList(paras);
+
+/*        String url="https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid="
+                + 小程序的appid
+                + "&secret="
+                + 小程序的Secret*/
+
+        String url = String.format(weChatConfig.getORDER_URL(),weChatConfig.getXcxAppid(),weChatConfig.getXcxAppsecret());
+
+        System.out.println("消息订阅请求路径===="+url);
+        //获取access_token
+        Map<String ,Object> baseMap =  HttpUtils.doGet(url);
+        String accessToken = (String)baseMap.get("access_token");
+
+        String requestUrl="https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token=ACCESS_TOKEN";
+        requestUrl=requestUrl.replace("ACCESS_TOKEN", accessToken);
+        //requestUrl=requestUrl.replace("ACCESS_TOKEN", WxAppletUserInfo.getMPToken().getString("access_token"));
+
+        System.out.println(template.toJSON());
+        JSONObject jsonResult= CommonUtil.httpsRequest(requestUrl, "POST", template.toJSON());
+        System.out.println("jsonResult===="+jsonResult);
+        if(jsonResult!=null){
+            System.out.println(jsonResult);
+            int errorCode=jsonResult.getInt("errcode");
+            String errorMessage=jsonResult.getString("errmsg");
+            if(errorCode==0){
+                System.out.println("Send Success");
+            }else{
+                System.out.println("服务通知发送失败:"+errorCode+","+errorMessage);
+            }
+        }
+    }
+
+
+
 }
 
 

dq-financial-hrms-auth/src/main/java/com/daqing/financial/hrauth/util/CommonUtil.java

@@ -0,0 +1,202 @@
+package com.daqing.financial.hrauth.util;
+
+import java.io.BufferedReader;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+import java.io.OutputStream;
+import java.io.UnsupportedEncodingException;
+import java.net.ConnectException;
+import java.net.HttpURLConnection;
+import java.net.URL;
+
+import javax.net.ssl.HttpsURLConnection;
+import javax.net.ssl.SSLContext;
+import javax.net.ssl.SSLSocketFactory;
+import javax.net.ssl.TrustManager;
+
+import net.sf.json.JSONObject;
+
+public class CommonUtil {
+
+    public static JSONObject httpsRequest(String requestUrl, String requestMethod, String outputStr) {
+
+        JSONObject jsonObject = null;
+        StringBuffer buffer = new StringBuffer();
+        try {
+            // 创建SSLContext对象，并使用我们指定的信任管理器初始化
+            TrustManager[] tm = { new MyX509TrustManager() };
+            SSLContext sslContext = SSLContext.getInstance("SSL", "SunJSSE");
+            sslContext.init(null, tm, new java.security.SecureRandom());
+            // 从上述SSLContext对象中得到SSLSocketFactory对象
+            SSLSocketFactory ssf = sslContext.getSocketFactory();
+
+            URL url = new URL(requestUrl);
+            HttpsURLConnection httpUrlConn = (HttpsURLConnection) url.openConnection();
+            httpUrlConn.setSSLSocketFactory(ssf);
+
+            httpUrlConn.setDoOutput(true);
+            httpUrlConn.setDoInput(true);
+            httpUrlConn.setUseCaches(false);
+            // 设置请求方式（GET/POST）
+            httpUrlConn.setRequestMethod(requestMethod);
+
+            if ("GET".equalsIgnoreCase(requestMethod)) {
+                httpUrlConn.connect();
+            }
+
+
+            // 当有数据需要提交时
+            if (null != outputStr) {
+                OutputStream outputStream = httpUrlConn.getOutputStream();
+                // 注意编码格式，防止中文乱码
+                outputStream.write(outputStr.getBytes("UTF-8"));
+                outputStream.close();
+            }
+
+            // 将返回的输入流转换成字符串
+            InputStream inputStream = httpUrlConn.getInputStream();
+            InputStreamReader inputStreamReader = new InputStreamReader(inputStream, "utf-8");
+            BufferedReader bufferedReader = new BufferedReader(inputStreamReader);
+
+            String str = null;
+            while ((str = bufferedReader.readLine()) != null) {
+                buffer.append(str);
+            }
+            bufferedReader.close();
+            inputStreamReader.close();
+            // 释放资源
+            inputStream.close();
+            inputStream = null;
+            httpUrlConn.disconnect();
+            jsonObject = JSONObject.fromObject(buffer.toString());
+        } catch (ConnectException ce) {
+            ce.printStackTrace();
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return jsonObject;
+    }
+
+    public static String httpRequest(String requestUrl, String requestMethod, String outputStr) {
+
+
+        StringBuffer buffer = new StringBuffer();
+        try {
+
+
+            URL url = new URL(requestUrl);
+            HttpURLConnection httpUrlConn = (HttpURLConnection) url.openConnection();
+
+
+            httpUrlConn.setDoOutput(true);
+            httpUrlConn.setDoInput(true);
+            httpUrlConn.setUseCaches(false);
+            // 设置请求方式（GET/POST）
+            httpUrlConn.setRequestMethod(requestMethod);
+
+            if ("GET".equalsIgnoreCase(requestMethod)) {
+                httpUrlConn.connect();
+            }
+
+
+            // 当有数据需要提交时
+            if (null != outputStr) {
+                OutputStream outputStream = httpUrlConn.getOutputStream();
+                // 注意编码格式，防止中文乱码
+                outputStream.write(outputStr.getBytes("UTF-8"));
+                outputStream.close();
+            }
+
+            // 将返回的输入流转换成字符串
+            InputStream inputStream = httpUrlConn.getInputStream();
+            InputStreamReader inputStreamReader = new InputStreamReader(inputStream, "utf-8");
+            BufferedReader bufferedReader = new BufferedReader(inputStreamReader);
+
+            String str = null;
+            while ((str = bufferedReader.readLine()) != null) {
+                buffer.append(str);
+            }
+            bufferedReader.close();
+            inputStreamReader.close();
+            // 释放资源
+            inputStream.close();
+            inputStream = null;
+            httpUrlConn.disconnect();
+            //jsonObject = JSONObject.fromObject(buffer.toString());
+        } catch (ConnectException ce) {
+            ce.printStackTrace();
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return buffer.toString();
+    }
+    public static String urlEncodeUTF8(String source){
+        String result = source;
+        try {
+            result = java.net.URLEncoder.encode(source,"utf-8");
+        } catch (UnsupportedEncodingException e) {
+            e.printStackTrace();
+        }
+        return result;
+    }
+
+    public static String httpsRequestForStr(String requestUrl, String requestMethod, String outputStr) {
+
+        String result="";
+        StringBuffer buffer = new StringBuffer();
+        try {
+            // 创建SSLContext对象，并使用我们指定的信任管理器初始化
+            TrustManager[] tm = { new MyX509TrustManager() };
+            SSLContext sslContext = SSLContext.getInstance("SSL", "SunJSSE");
+            sslContext.init(null, tm, new java.security.SecureRandom());
+            // 从上述SSLContext对象中得到SSLSocketFactory对象
+            SSLSocketFactory ssf = sslContext.getSocketFactory();
+
+            URL url = new URL(requestUrl);
+            HttpsURLConnection httpUrlConn = (HttpsURLConnection) url.openConnection();
+            httpUrlConn.setSSLSocketFactory(ssf);
+
+            httpUrlConn.setDoOutput(true);
+            httpUrlConn.setDoInput(true);
+            httpUrlConn.setUseCaches(false);
+            // 设置请求方式（GET/POST）
+            httpUrlConn.setRequestMethod(requestMethod);
+
+            if ("GET".equalsIgnoreCase(requestMethod)) {
+                httpUrlConn.connect();
+            }
+
+
+            // 当有数据需要提交时
+            if (null != outputStr) {
+                OutputStream outputStream = httpUrlConn.getOutputStream();
+                // 注意编码格式，防止中文乱码
+                outputStream.write(outputStr.getBytes("UTF-8"));
+                outputStream.close();
+            }
+
+            // 将返回的输入流转换成字符串
+            InputStream inputStream = httpUrlConn.getInputStream();
+            InputStreamReader inputStreamReader = new InputStreamReader(inputStream, "utf-8");
+            BufferedReader bufferedReader = new BufferedReader(inputStreamReader);
+
+            String str = null;
+            while ((str = bufferedReader.readLine()) != null) {
+                buffer.append(str);
+            }
+            bufferedReader.close();
+            inputStreamReader.close();
+            // 释放资源
+            inputStream.close();
+            inputStream = null;
+            httpUrlConn.disconnect();
+            result=buffer.toString();
+        } catch (ConnectException ce) {
+            ce.printStackTrace();
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return result;
+    }
+
+}

dq-financial-hrms-auth/src/main/java/com/daqing/financial/hrauth/util/HttpUtil.java

@@ -0,0 +1,108 @@
+package com.daqing.financial.hrauth.util;
+
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import org.apache.http.Consts;
+import org.apache.http.HttpEntity;
+import org.apache.http.NameValuePair;
+import org.apache.http.client.entity.UrlEncodedFormEntity;
+import org.apache.http.client.methods.CloseableHttpResponse;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+import org.apache.http.message.BasicNameValuePair;
+import org.apache.http.util.EntityUtils;
+
+public class HttpUtil {
+
+    private static final CloseableHttpClient httpclient = HttpClients.createDefault();
+
+    /**
+     * 发送HttpGet请求
+     * @param url
+     * @return
+     */
+    public static String sendGet(String url) {
+
+        HttpGet httpget = new HttpGet(url);
+        CloseableHttpResponse response = null;
+        try {
+            response = httpclient.execute(httpget);
+        } catch (IOException e1) {
+            e1.printStackTrace();
+        }
+        String result = null;
+        try {
+            HttpEntity entity = response.getEntity();
+            if (entity != null) {
+                result = EntityUtils.toString(entity);
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        } finally {
+            try {
+                response.close();
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+        return result;
+    }
+
+    /**
+     * 发送HttpPost请求，参数为map
+     * @param url
+     * @param map
+     * @return
+     */
+    public static String sendPost(String url, Map<String, String> map) {
+        List<NameValuePair> formparams = new ArrayList<NameValuePair>();
+        for (Map.Entry<String, String> entry : map.entrySet()) {
+            formparams.add(new BasicNameValuePair(entry.getKey(), entry.getValue()));
+        }
+        UrlEncodedFormEntity entity = new UrlEncodedFormEntity(formparams, Consts.UTF_8);
+        HttpPost httppost = new HttpPost(url);
+        httppost.setEntity(entity);
+        CloseableHttpResponse response = null;
+        try {
+            response = httpclient.execute(httppost);
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+        HttpEntity entity1 = response.getEntity();
+        String result = null;
+        try {
+            result = EntityUtils.toString(entity1);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return result;
+    }
+
+    /**
+     * 发送不带参数的HttpPost请求
+     * @param url
+     * @return
+     */
+    public static String sendPost(String url) {
+        HttpPost httppost = new HttpPost(url);
+        CloseableHttpResponse response = null;
+        try {
+            response = httpclient.execute(httppost);
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+        HttpEntity entity = response.getEntity();
+        String result = null;
+        try {
+            result = EntityUtils.toString(entity);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return result;
+    }
+
+}

dq-financial-hrms-auth/src/main/java/com/daqing/financial/hrauth/util/MyX509TrustManager.java

@@ -0,0 +1,26 @@
+package com.daqing.financial.hrauth.util;
+import java.security.cert.CertificateException;
+import java.security.cert.X509Certificate;
+import javax.net.ssl.X509TrustManager;
+
+/**
+ * 信任管理器
+ *
+ * @author liufeng
+ * @date 2013-04-10
+ */
+public class MyX509TrustManager implements X509TrustManager {
+
+    // 检查客户端证书
+    public void checkClientTrusted(X509Certificate[] chain, String authType) throws CertificateException {
+    }
+
+    // 检查服务器端证书
+    public void checkServerTrusted(X509Certificate[] chain, String authType) throws CertificateException {
+    }
+
+    // 返回受信任的X509证书数组
+    public X509Certificate[] getAcceptedIssuers() {
+        return null;
+    }
+}

dq-financial-hrms-auth/src/main/java/com/daqing/financial/hrauth/util/Template.java

@@ -0,0 +1,68 @@
+package com.daqing.financial.hrauth.util;
+
+import java.util.List;
+
+public class Template {
+
+    private String touser;
+    private String template_id;
+    private String page;
+    private List<TemplateParam> templateParamList;
+
+
+    public String getTouser() {
+        return touser;
+    }
+
+    public void setTouser(String touser) {
+        this.touser = touser;
+    }
+
+    public String getTemplate_id() {
+        return template_id;
+    }
+
+    public void setTemplate_id(String template_id) {
+        this.template_id = template_id;
+    }
+
+    public String getPage() {
+        return page;
+    }
+
+    public void setPage(String page) {
+        this.page = page;
+    }
+
+
+
+    public String toJSON() {
+        StringBuffer buffer = new StringBuffer();
+        buffer.append("{");
+        buffer.append(String.format("\"touser\":\"%s\"", this.touser)).append(",");
+        buffer.append(String.format("\"template_id\":\"%s\"", this.template_id)).append(",");
+        buffer.append(String.format("\"page\":\"%s\"", this.page)).append(",");
+        buffer.append("\"data\":{");
+        TemplateParam param = null;
+        for (int i = 0; i < this.templateParamList.size(); i++) {
+            param = templateParamList.get(i);
+            // 判断是否追加逗号
+            if (i < this.templateParamList.size() - 1){
+                buffer.append(String.format("\"%s\": {\"value\":\"%s\"},", param.getKey(), param.getValue()));
+            }else{
+                buffer.append(String.format("\"%s\": {\"value\":\"%s\"}", param.getKey(), param.getValue()));
+            }
+        }
+        buffer.append("}");
+        buffer.append("}");
+        return buffer.toString();
+    }
+
+    public List<TemplateParam> getTemplateParamList() {
+        return templateParamList;
+    }
+
+    public void setTemplateParamList(List<TemplateParam> templateParamList) {
+        this.templateParamList = templateParamList;
+    }
+}

dq-financial-hrms-auth/src/main/java/com/daqing/financial/hrauth/util/TemplateParam.java

@@ -0,0 +1,25 @@
+package com.daqing.financial.hrauth.util;
+
+public class TemplateParam {
+
+    private String key;
+    private String value;
+
+    public TemplateParam(String key,String value){
+        this.key=key;
+        this.value=value;
+    }
+    public String getValue() {
+        return value;
+    }
+    public void setValue(String value) {
+        this.value = value;
+    }
+    public String getKey() {
+        return key;
+    }
+    public void setKey(String key) {
+        this.key = key;
+    }
+
+}