feats

src/main/java/com/example/wenhua/common/ResponseBean.java

@@ -0,0 +1,75 @@
+package com.example.wenhua.common;
+
+import java.io.Serializable;
+
+/**
+ * 接口统一状态返回BEAN.
+ */
+public class ResponseBean<T> implements Serializable {
+
+    private static final long serialVersionUID = 3593827217136880822L;
+
+    public static final int CODE_SUCCESS = 1000;
+    public static final int ERROR_AUTH_FAIL = 1001;
+    public static final int ERROR_AUTH_EXPIRED = 1002;
+    public static final int ERROR_MISSING_PARAMS = 1003;
+    public static final int ERROR_ILLEGAL_PARAMS = 1004;
+    public static final int ERROR_UNAVAILABLE = 1005;
+
+    private int code;
+    private String message;
+    private T data;
+    private String token;
+
+    /**
+     * 禁止外部 new
+     */
+    private ResponseBean() {
+        code = ResponseBean.CODE_SUCCESS;
+    }
+
+    public static <T> ResponseBean success(T data, String ...msgs) {
+        ResponseBean responseBean = new ResponseBean();
+        responseBean.code = ResponseBean.CODE_SUCCESS;
+        responseBean.data = data;
+
+        if (null != msgs && msgs.length > 0) {
+            responseBean.message = msgs[0];
+        }
+
+        return responseBean;
+    }
+
+    public static <T> ResponseBean error(String msg, int code, T ...datas) {
+        ResponseBean responseBean = new ResponseBean();
+        responseBean.code = code;
+        responseBean.message = msg;
+
+        if (null != datas && datas.length > 0) {
+            responseBean.data = datas[0];
+        }
+
+        return responseBean;
+    }
+
+    public int getCode() {
+        return code;
+    }
+
+    public String getMessage() {
+        return message;
+    }
+
+    public T getData() {
+        return data;
+    }
+
+    public String getToken() {
+        return token;
+    }
+
+    @Override
+    public String toString() {
+        return  "{ code: "+code+", message: "+message+", data: <T> }";
+    }
+}

src/main/java/com/example/wenhua/config/WxMpConfiguration.java

@@ -1,9 +1,7 @@
 package com.example.wenhua.config;
 
-//import com.github.binarywang.demo.wx.mp.handler.*;
 import lombok.AllArgsConstructor;
 import me.chanjar.weixin.common.redis.JedisWxRedisOps;
-import me.chanjar.weixin.mp.api.WxMpMessageRouter;
 import me.chanjar.weixin.mp.api.WxMpService;
 import me.chanjar.weixin.mp.api.impl.WxMpServiceImpl;
 import me.chanjar.weixin.mp.config.impl.WxMpDefaultConfigImpl;
@@ -14,9 +12,6 @@ import org.springframework.context.annotation.Configuration;
 import redis.clients.jedis.JedisPool;
 import redis.clients.jedis.JedisPoolConfig;
 
-import java.util.List;
-import java.util.stream.Collectors;
-
 /**
  * wechat mp configuration
  *
@@ -31,31 +26,26 @@ public class WxMpConfiguration {
     @Bean
     public WxMpService wxMpService() {
         // 代码里 getConfigs()处报错的同学，请注意仔细阅读项目说明，你的IDE需要引入lombok插件！！！！
-        final List<WxMpProperties.MpConfig> configs = this.properties.getConfigs();
+        final WxMpProperties.MpConfig configs = this.properties.getConfigs();
         if (configs == null) {
             throw new RuntimeException("大哥，拜托先看下项目首页的说明（readme文件），添加下相关配置，注意别配错了！");
         }
 
         WxMpService service = new WxMpServiceImpl();
-        service.setMultiConfigStorages(configs
-                .stream().map(a -> {
-                    WxMpDefaultConfigImpl configStorage;
-                    if (this.properties.isUseRedis()) {
-                        final WxMpProperties.RedisConfig redisConfig = this.properties.getRedisConfig();
-                        JedisPoolConfig poolConfig = new JedisPoolConfig();
-                        JedisPool jedisPool = new JedisPool(poolConfig, redisConfig.getHost(), redisConfig.getPort(),
-                                redisConfig.getTimeout(), redisConfig.getPassword());
-                        configStorage = new WxMpRedisConfigImpl(new JedisWxRedisOps(jedisPool), a.getAppId());
-                    } else {
-                        configStorage = new WxMpDefaultConfigImpl();
-                    }
+        WxMpDefaultConfigImpl configStorage = new WxMpDefaultConfigImpl();
+        if (this.properties.isUseRedis()) {
+            final WxMpProperties.RedisConfig redisConfig = this.properties.getRedisConfig();
+            JedisPoolConfig poolConfig = new JedisPoolConfig();
+            JedisPool jedisPool = new JedisPool(poolConfig, redisConfig.getHost(), redisConfig.getPort(),
+                    redisConfig.getTimeout(), redisConfig.getPassword());
+            configStorage = new WxMpRedisConfigImpl(new JedisWxRedisOps(jedisPool), configs.getAppId());
+        }
+        configStorage.setAppId(configs.getAppId());
+        configStorage.setSecret(configs.getSecret());
+        configStorage.setToken(configs.getToken());
+        configStorage.setAesKey(configs.getAesKey());
 
-                    configStorage.setAppId(a.getAppId());
-                    configStorage.setSecret(a.getSecret());
-                    configStorage.setToken(a.getToken());
-                    configStorage.setAesKey(a.getAesKey());
-                    return configStorage;
-                }).collect(Collectors.toMap(WxMpDefaultConfigImpl::getAppId, a -> a, (o, n) -> o)));
+        service.setWxMpConfigStorage(configStorage);
         return service;
     }
 }

src/main/java/com/example/wenhua/config/WxMpProperties.java

@@ -50,7 +50,7 @@ public class WxMpProperties {
     /**
      * 多个公众号配置信息
      */
-    private List<MpConfig> configs;
+    private MpConfig configs;
 
     @Data
     public static class MpConfig {

src/main/java/com/example/wenhua/controller/WxJsapiController.java

@@ -1,13 +1,11 @@
 package com.example.wenhua.controller;
 
+import com.example.wenhua.common.ResponseBean;
 import lombok.AllArgsConstructor;
 import me.chanjar.weixin.common.bean.WxJsapiSignature;
 import me.chanjar.weixin.common.error.WxErrorException;
 import me.chanjar.weixin.mp.api.WxMpService;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.PathVariable;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
 
 import java.net.MalformedURLException;
 
@@ -19,14 +17,14 @@ import java.net.MalformedURLException;
  */
 @AllArgsConstructor
 @RestController
-@RequestMapping("/wx/jsapi/{appid}")
+@RequestMapping("/wx")
 public class WxJsapiController {
     private final WxMpService wxService;
 
-    @GetMapping("/getJsapiTicket")
-    public String getJsapiTicket(@PathVariable String appid) throws WxErrorException {
-        final WxJsapiSignature jsapiSignature = this.wxService.switchoverTo(appid).createJsapiSignature("111");
+    @GetMapping("/jsapi")
+    public ResponseBean getJsapiTicket(@RequestParam String url) throws WxErrorException {
+        final WxJsapiSignature jsapiSignature = this.wxService.createJsapiSignature(url);
         System.out.println(jsapiSignature);
-        return this.wxService.getJsapiTicket(true);
+        return ResponseBean.success(jsapiSignature);
     }
 }

src/main/java/com/example/wenhua/exception/GlobalExceptionHandler.java

@@ -0,0 +1,19 @@
+package com.example.wenhua.exception;
+
+import com.example.wenhua.common.ResponseBean;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.web.bind.annotation.ExceptionHandler;
+import org.springframework.web.bind.annotation.ResponseBody;
+import org.springframework.web.bind.annotation.RestControllerAdvice;
+
+@Slf4j
+@RestControllerAdvice
+public class GlobalExceptionHandler {
+
+    @ResponseBody
+    @ExceptionHandler(Exception.class)
+    public ResponseBean handleException(Exception e){
+        log.error(e.getMessage(),e);
+        return ResponseBean.error(e.getMessage(), ResponseBean.ERROR_UNAVAILABLE);
+    }
+}

src/main/resources/application.yml

@@ -1,11 +1,16 @@
+server:
+  port: 7088
+  servlet:
+    context-path: /api
+
 wx:
   mp:
     useRedis: false
     redisConfig:
-      host: 127.0.0.1
-      port: 6379
+      host:
+      port:
     configs:
-      - appId: wxc10b9358486f6009 # ???????appid
-        secret: 57579fc5d9f54ecdc914255ccd4c3206 # ????appsecret
-        token: 111 # ??????Token?
-        aesKey: 111 # ??????EncodingAESKey?
+      appId: wxd3bab568bc42d1de
+      secret: a29e70e90686b36fd3a9ab513d43558e
+      token: fd743543e7710bb0834671c4fa2622d2
+      aesKey: SreLm50AMt6SV9AFfbMLzqYhKN3CnR24cUDZCzumKj2

src/test/java/com/example/wenhua/WenhuaApplicationTests.java

@@ -1,13 +0,0 @@
-package com.example.wenhua;
-
-import org.junit.jupiter.api.Test;
-import org.springframework.boot.test.context.SpringBootTest;
-
-@SpringBootTest
-class WenhuaApplicationTests {
-
-	@Test
-	void contextLoads() {
-	}
-
-}