代码初始化

yanxuan-wx-store-sharer-common/src/main/java/com/netease/yanxuan/wx/store/sharer/common/util/SpringContextUtils.java

+package com.netease.yanxuan.wx.store.sharer.common.util;
+
+import org.springframework.beans.BeansException;
+import org.springframework.beans.factory.NoSuchBeanDefinitionException;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.ApplicationContextAware;
+import org.springframework.stereotype.Component;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
+
+import javax.servlet.http.HttpServletRequest;
+
+@Component
+public class SpringContextUtils implements ApplicationContextAware {
+
+    /**
+     * 上下文对象实例
+     */
+    private static ApplicationContext applicationContext;
+
+    @Override
+    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
+        SpringContextUtils.applicationContext = applicationContext;
+    }
+
+    /**
+     * 获取applicationContext
+     */
+    public static ApplicationContext getApplicationContext() {
+        return applicationContext;
+    }
+
+    /**
+     * 获取HttpServletRequest
+     */
+    public static HttpServletRequest getHttpServletRequest() {
+        return ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
+    }
+
+    public static String getDomain() {
+        HttpServletRequest request = getHttpServletRequest();
+        StringBuffer url = request.getRequestURL();
+        return url.delete(url.length() - request.getRequestURI().length(), url.length()).toString();
+    }
+
+    public static String getOrigin() {
+        HttpServletRequest request = getHttpServletRequest();
+        return request.getHeader("Origin");
+    }
+
+    /**
+     * 通过name获取 Bean.
+     */
+    public static Object getBean(String name) {
+        return getApplicationContext().getBean(name);
+    }
+
+    /**
+     * 通过class获取Bean.
+     */
+    public static <T> T getBean(Class<T> clazz) {
+        return getApplicationContext().getBean(clazz);
+    }
+
+    /**
+     * 通过name,以及Clazz返回指定的Bean
+     */
+    public static <T> T getBean(String name, Class<T> clazz) {
+        return getApplicationContext().getBean(name, clazz);
+    }
+
+    /**
+     * 通过name,以及Clazz返回指定的Bean,为空不报错
+     */
+    public static <T> T getBeanIfExists(String name, Class<T> clazz) {
+        try {
+            return getApplicationContext().getBean(name, clazz);
+        } catch (NoSuchBeanDefinitionException e) {
+            return null;
+        }
+    }
+}

yanxuan-wx-store-sharer-integration/src/main/java/com/netease/yanxuan/wx/store/sharer/integration/core/WeChatContextHolder.java

@@ -53,7 +53,6 @@ public class WeChatContextHolder {
             return createAccessToken();
         }
         // 双重检查锁定
-        // 双重检查锁定
         String accessToken = redisClient.getStr(CoreConstant.REDIS_TOKEN_WECHAT_KEY);
         if (StringUtils.isNotBlank(accessToken)) {
             return accessToken;

yanxuan-wx-store-sharer-integration/src/main/java/com/netease/yanxuan/wx/store/sharer/integration/handler/IWeChatRequest.java

 package com.netease.yanxuan.wx.store.sharer.integration.handler;
 
+import com.netease.yanxuan.wx.store.sharer.common.util.SpringContextUtils;
+import com.netease.yanxuan.wx.store.sharer.integration.core.WeChatContextHolder;
 import org.springframework.http.HttpMethod;
 
 /**
@@ -17,4 +19,9 @@ public interface IWeChatRequest {
      * 请求地址
      */
     String getRequestUrl();
+
+    default String getAccessToken() {
+        WeChatContextHolder weChatContextHolder = SpringContextUtils.getBean(WeChatContextHolder.class);
+        return weChatContextHolder.getAccessToken();
+    }
 }

yanxuan-wx-store-sharer-integration/src/main/java/com/netease/yanxuan/wx/store/sharer/integration/handler/WeChatRestTemplateHandler.java

@@ -2,7 +2,6 @@ package com.netease.yanxuan.wx.store.sharer.integration.handler;
 
 import com.netease.yanxuan.wx.store.sharer.common.exception.BizException;
 import com.netease.yanxuan.wx.store.sharer.common.handler.RestTemplateClient;
-import com.netease.yanxuan.wx.store.sharer.integration.core.WeChatContextHolder;
 import com.netease.yanxuan.wx.store.sharer.integration.meta.model.vo.WeChatCoreVO;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -19,11 +18,9 @@ import org.springframework.stereotype.Service;
 @RequiredArgsConstructor
 public class WeChatRestTemplateHandler {
     private final RestTemplateClient restTemplateClient;
-    private final WeChatContextHolder weChatContextHolder;
 
     public <T, R extends WeChatCoreVO> R execute(String url, HttpMethod method, T params, Class<R> resType) {
-        String accessToken = weChatContextHolder.getAccessToken();
-        R result = restTemplateClient.execute(url + "?access_token=" + accessToken, method, params, resType);
+        R result = restTemplateClient.execute(url, method, params, resType);
         if (!"0".equals(result.getErrcode())) {
             throw new BizException("调用微信接口失败，" + result.getErrmsg());
         }

yanxuan-wx-store-sharer-integration/src/main/java/com/netease/yanxuan/wx/store/sharer/integration/handler/impl/WeChatGetSharerProductCommissionRequest.java

@@ -31,7 +31,7 @@ public class WeChatGetSharerProductCommissionRequest implements IWeChatRequest {
 
     @Override
     public String getRequestUrl() {
-        return weChatConfig.getUrl() + WeChatApi.GET_SHARER_PRODUCT_COMMISSION_INFO;
+        return weChatConfig.getUrl() + WeChatApi.GET_SHARER_PRODUCT_COMMISSION_INFO + "?access_token=" + getAccessToken();
     }
 
     /**

yanxuan-wx-store-sharer-integration/src/main/java/com/netease/yanxuan/wx/store/sharer/integration/handler/impl/WeChatPromoteProductDetailRequest.java

@@ -32,7 +32,7 @@ public class WeChatPromoteProductDetailRequest implements IWeChatRequest {
 
     @Override
     public String getRequestUrl() {
-        return weChatConfig.getUrl() + WeChatApi.GET_PROMOTE_PRODUCT_DETAIL;
+        return weChatConfig.getUrl() + WeChatApi.GET_PROMOTE_PRODUCT_DETAIL + "?access_token=" + getAccessToken();
     }
 
     /**

yanxuan-wx-store-sharer-integration/src/main/java/com/netease/yanxuan/wx/store/sharer/integration/handler/impl/WeChatPromoteProductLinkRequest.java

@@ -31,7 +31,7 @@ public class WeChatPromoteProductLinkRequest implements IWeChatRequest {
 
     @Override
     public String getRequestUrl() {
-        return weChatConfig.getUrl() + WeChatApi.GET_PRODUCT_PROMOTION_LINK_INFO;
+        return weChatConfig.getUrl() + WeChatApi.GET_PRODUCT_PROMOTION_LINK_INFO + "?access_token=" + getAccessToken();
     }
 
     /**

yanxuan-wx-store-sharer-integration/src/main/java/com/netease/yanxuan/wx/store/sharer/integration/handler/impl/WeChatPromoteProductListRequest.java

@@ -32,7 +32,7 @@ public class WeChatPromoteProductListRequest implements IWeChatRequest {
 
     @Override
     public String getRequestUrl() {
-        return weChatConfig.getUrl() + WeChatApi.GET_PROMOTE_PRODUCT_LIST;
+        return weChatConfig.getUrl() + WeChatApi.GET_PROMOTE_PRODUCT_LIST + "?access_token=" + getAccessToken();
     }
 
     /**

yanxuan-wx-store-sharer-integration/src/main/java/com/netease/yanxuan/wx/store/sharer/integration/handler/impl/WeChatSetSharerCommissionRequest.java

@@ -32,7 +32,7 @@ public class WeChatSetSharerCommissionRequest implements IWeChatRequest {
 
     @Override
     public String getRequestUrl() {
-        return weChatConfig.getUrl() + WeChatApi.SET_SHARER_COMMISSION_INFO;
+        return weChatConfig.getUrl() + WeChatApi.SET_SHARER_COMMISSION_INFO + "?access_token=" + getAccessToken();
     }
 
     /**

yanxuan-wx-store-sharer-integration/src/main/java/com/netease/yanxuan/wx/store/sharer/integration/handler/impl/WeChatSetSharerProductCommissionRequest.java

@@ -31,7 +31,7 @@ public class WeChatSetSharerProductCommissionRequest implements IWeChatRequest {
 
     @Override
     public String getRequestUrl() {
-        return weChatConfig.getUrl() + WeChatApi.SET_SHARER_PRODUCT_COMMISSION_INFO;
+        return weChatConfig.getUrl() + WeChatApi.SET_SHARER_PRODUCT_COMMISSION_INFO + "?access_token=" + getAccessToken();
     }
 
     /**

yanxuan-wx-store-sharer-integration/src/main/java/com/netease/yanxuan/wx/store/sharer/integration/handler/impl/WeChatSharerListRequest.java

@@ -31,7 +31,7 @@ public class WeChatSharerListRequest implements IWeChatRequest {
 
     @Override
     public String getRequestUrl() {
-        return weChatConfig.getUrl() + WeChatApi.GET_BIND_SHARER_LIST;
+        return weChatConfig.getUrl() + WeChatApi.GET_BIND_SHARER_LIST + "?access_token=" + getAccessToken();
     }
 
     /**

yanxuan-wx-store-sharer-integration/src/main/java/com/netease/yanxuan/wx/store/sharer/integration/handler/impl/WeChatSharerRegisterBindRequest.java

@@ -31,7 +31,7 @@ public class WeChatSharerRegisterBindRequest implements IWeChatRequest {
 
     @Override
     public String getRequestUrl() {
-        return weChatConfig.getUrl() + WeChatApi.GET_USER_INFO;
+        return weChatConfig.getUrl() + WeChatApi.GET_USER_INFO + "?access_token=" + getAccessToken();
     }
 
     /**