添加微信MP的集成

udf-starter-weixin-mp-api/pom.xml

@@ -23,6 +23,10 @@
             <groupId>org.itkk.udf</groupId>
             <artifactId>udf-starter-amqp-rabbitmq</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.itkk.udf</groupId>
+            <artifactId>udf-starter-cache-redis</artifactId>
+        </dependency>
         <!-- commons-codec -->
         <dependency>
             <groupId>commons-codec</groupId>

udf-starter-weixin-mp-api/src/main/java/org/itkk/udf/weixin/mp/api/Menu.java

@@ -0,0 +1,56 @@
+package org.itkk.udf.weixin.mp.api;
+
+import org.itkk.udf.weixin.mp.api.domain.BaseResult;
+import org.itkk.udf.weixin.mp.api.domain.MenuGroup;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.stereotype.Component;
+import org.springframework.web.client.RestTemplate;
+
+/**
+ * Menu
+ */
+@Component
+public class Menu {
+
+    /**
+     * weixinMpApiProperties
+     */
+    @Autowired
+    private WeixinMpApiProperties weixinMpApiProperties;
+
+    /**
+     * token
+     */
+    @Autowired
+    private Token token;
+
+    /**
+     * externalRestTemplate
+     */
+    @Autowired
+    @Qualifier("externalRestTemplate")
+    private RestTemplate externalRestTemplate;
+
+    /**
+     * 创建菜单
+     *
+     * @param businessCode 业务代码
+     * @param menuGroup    菜单组
+     * @return BaseResult
+     */
+    public BaseResult create(String businessCode, MenuGroup menuGroup) {
+        //获得接口地址
+        String path = weixinMpApiProperties.getApiPath().get("menu_create");
+        //拼接url
+        StringBuilder url = new StringBuilder(path);
+        url.append(WeixinMpConsont.appendAccessToken(token.get(businessCode)));
+        //请求
+        BaseResult result = externalRestTemplate.postForEntity(url.toString(), menuGroup, BaseResult.class).getBody();
+        //验证
+        WeixinMpConsont.checkResult(result);
+        //返回
+        return result;
+    }
+
+}

udf-starter-weixin-mp-api/src/main/java/org/itkk/udf/weixin/mp/api/Token.java

@@ -0,0 +1,82 @@
+package org.itkk.udf.weixin.mp.api;
+
+import org.itkk.udf.weixin.mp.api.domain.AccessToken;
+import org.itkk.udf.weixin.mp.api.meta.WeixinMpApiAuthMeta;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.stereotype.Component;
+import org.springframework.web.client.RestTemplate;
+
+import java.util.concurrent.TimeUnit;
+
+/**
+ * Token
+ */
+@Component
+public class Token {
+
+    /**
+     * DISTRIBUTED_LOCK_KEY_PREFIX
+     */
+    private static final String WEIXIN_MP_TOKEN_KEY_PREFIX = ":WEIXIN_MP_TOKEN:";
+
+    /**
+     * weixinMpApiProperties
+     */
+    @Autowired
+    private WeixinMpApiProperties weixinMpApiProperties;
+
+    /**
+     * externalRestTemplate
+     */
+    @Autowired
+    @Qualifier("externalRestTemplate")
+    private RestTemplate externalRestTemplate;
+
+    /**
+     * redisTemplate
+     */
+    @Autowired
+    private RedisTemplate<Object, Object> redisTemplate;
+
+    /**
+     * profiles
+     */
+    @Value("${spring.profiles.active}")
+    private String profiles;
+
+    /**
+     * 获取access_token
+     *
+     * @param businessCode 业务代码
+     * @return AccessToken
+     */
+    protected String get(String businessCode) {
+        //获得认证相关信息
+        WeixinMpApiAuthMeta auth = weixinMpApiProperties.getAuth().get(businessCode);
+        //生成缓存key
+        String key = profiles + WEIXIN_MP_TOKEN_KEY_PREFIX + businessCode + ":" + auth.getAppId();
+        //检查缓存是否存在,如果存在,则直接返回
+        if (redisTemplate.hasKey(key)) {
+            return (String) redisTemplate.opsForValue().get(key);
+        }
+        //获得接口地址
+        String path = weixinMpApiProperties.getApiPath().get("token");
+        //拼接url
+        StringBuilder url = new StringBuilder(path);
+        url.append("?appid=").append(auth.getAppId()).append("&secret=").append(auth.getAppSecret()).append("&grant_type=client_credential");
+        //请求
+        AccessToken result = externalRestTemplate.getForEntity(url.toString(), AccessToken.class).getBody();
+        //验证
+        WeixinMpConsont.checkResult(result);
+        //缓存(新增 & 更新)
+        final int num200 = 200;
+        int expiresIn = result.getExpires_in() - num200;
+        redisTemplate.opsForValue().set(key, result.getAccess_token(), expiresIn, TimeUnit.SECONDS);
+        //返回
+        return result.getAccess_token();
+    }
+
+}

udf-starter-weixin-mp-api/src/main/java/org/itkk/udf/weixin/mp/api/WeixinMpApiProperties.java

@@ -25,4 +25,9 @@ public class WeixinMpApiProperties {
      */
     private Map<String, String> snsPath;
 
+    /**
+     * 接口地址
+     */
+    private Map<String, String> apiPath;
+
 }

udf-starter-weixin-mp-api/src/main/java/org/itkk/udf/weixin/mp/api/WeixinMpConsont.java

@@ -25,6 +25,16 @@ public class WeixinMpConsont {
 
     }
 
+    /**
+     * 描述 : 构建参数
+     *
+     * @param accessToken 令牌
+     * @return 参数
+     */
+    public static String appendAccessToken(String accessToken) {
+        return "?access_token=" + accessToken;
+    }
+
     /**
      * <p>
      * 检查返回值

udf-starter-weixin-mp-api/src/main/java/org/itkk/udf/weixin/mp/api/domain/AccessToken.java

@@ -0,0 +1,27 @@
+package org.itkk.udf.weixin.mp.api.domain;
+
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * AccessToken
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+public class AccessToken extends BaseResult {
+    /**
+     * ID
+     */
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 凭证
+     */
+    private String access_token; //NOSONAR
+
+    /**
+     * 凭证有效期
+     */
+    private Integer expires_in; //NOSONAR
+
+}

udf-starter-weixin-mp-api/src/main/java/org/itkk/udf/weixin/mp/api/domain/Menu.java

@@ -0,0 +1,59 @@
+package org.itkk.udf.weixin.mp.api.domain;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * Menu
+ */
+@Data
+public class Menu implements Serializable {
+
+    /**
+     * ID
+     */
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 二级菜单数组，个数应为1~5个
+     */
+    private List<Menu> sub_button; //NOSONAR
+
+    /**
+     * 菜单的响应动作类型，view表示网页类型，click表示点击类型，miniprogram表示小程序类型
+     */
+    private String type;
+
+    /**
+     * 菜单标题，不超过16个字节，子菜单不超过60个字节
+     */
+    private String name;
+
+    /**
+     * 菜单KEY值，用于消息接口推送，不超过128字节(click等点击类型必须)
+     */
+    private String key;
+
+    /**
+     * 网页链接，用户点击菜单可打开链接，不超过1024字节(view、miniprogram类型必须)
+     */
+    private String url;
+
+    /**
+     * 调用新增永久素材接口返回的合法media_id(media_id类型和view_limited类型必须)
+     */
+    private String media_id; //NOSONAR
+
+    /**
+     * 小程序的appid（仅认证公众号可配置） (miniprogram类型必须)
+     */
+    private String appid;
+
+    /**
+     * 小程序的页面路径 (miniprogram类型必须)
+     */
+    private String pagepath;
+
+}

udf-starter-weixin-mp-api/src/main/java/org/itkk/udf/weixin/mp/api/domain/MenuGroup.java

@@ -0,0 +1,24 @@
+package org.itkk.udf.weixin.mp.api.domain;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * MenuGroup
+ */
+@Data
+public class MenuGroup implements Serializable {
+
+    /**
+     * ID
+     */
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 一级菜单数组，个数应为1~3个
+     */
+    private List<Menu> button;
+
+}

udf-starter-weixin-mp-api/src/main/java/org/itkk/udf/weixin/mp/api/utils/ShaOne.java

@@ -4,7 +4,7 @@
  * Created by Administrator
  * Copyright (C) 2016 LLSFW, All rights reserved.
  */
-package org.itkk.udf.weixin.mp.api;
+package org.itkk.udf.weixin.mp.api.utils;
 
 
 import java.io.UnsupportedEncodingException;

udf-starter-weixin-mp/src/main/java/org/itkk/udf/weixin/mp/service/WeixinMpCallbackService.java

@@ -6,6 +6,7 @@ import org.itkk.udf.amqp.rabbitmq.Rabbitmq;
 import org.itkk.udf.amqp.rabbitmq.RabbitmqMessage;
 import org.itkk.udf.weixin.mp.api.*;
 import org.itkk.udf.weixin.mp.api.meta.WeixinMpApiAuthMeta;
+import org.itkk.udf.weixin.mp.api.utils.ShaOne;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;