From 0f4c7b659f61eb910eb192a4c7a5be3b9fe4eca3 Mon Sep 17 00:00:00 2001
From: zxc <1272811460@qq.com>
Date: Mon, 25 Jul 2022 13:32:53 +0800
Subject: [PATCH] =?UTF-8?q?=E5=88=B7=E6=96=B0=E5=B0=8F=E7=A8=8B=E5=BA=8Fto?=
 =?UTF-8?q?ken=E5=8A=A0=E9=94=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../controller/WeChatNotifyController.java    | 20 ++++++++++++++++---
 1 file changed, 17 insertions(+), 3 deletions(-)

diff --git a/epmet-module/epmet-third/epmet-third-server/src/main/java/com/epmet/controller/WeChatNotifyController.java b/epmet-module/epmet-third/epmet-third-server/src/main/java/com/epmet/controller/WeChatNotifyController.java
index bacb67e3cf..a10a44b148 100644
--- a/epmet-module/epmet-third/epmet-third-server/src/main/java/com/epmet/controller/WeChatNotifyController.java
+++ b/epmet-module/epmet-third/epmet-third-server/src/main/java/com/epmet/controller/WeChatNotifyController.java
@@ -1,9 +1,12 @@
 package com.epmet.controller;
 
+import com.epmet.commons.tools.distributedlock.DistributedLock;
+import com.epmet.commons.tools.exception.ExceptionUtils;
 import com.epmet.commons.tools.utils.Result;
 import com.epmet.constant.ModuleConstant;
 import com.epmet.service.ComponentVerifyTicketService;
 import lombok.extern.slf4j.Slf4j;
+import org.redisson.api.RLock;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
@@ -20,6 +23,8 @@ public class WeChatNotifyController {
 
     @Autowired
     private ComponentVerifyTicketService componentVerifyTicketService;
+    @Autowired
+    private DistributedLock distributedLock;
 
     /**
      * @Description  定时获取  (令牌，component_access_token)
@@ -53,9 +58,18 @@ public class WeChatNotifyController {
      */
     @PostMapping("refreshtoken")
     public Result refreshToken(){
-        log.info("开始刷新/获取接口调用令牌......");
-        componentVerifyTicketService.refreshToken();
-        log.info("刷新/获取接口调用令牌......成功了");
+        RLock lock = null;
+        try {
+            lock = distributedLock.getLock("refresh_authorizer_access_token");
+            log.info("开始刷新/获取接口调用令牌......");
+            componentVerifyTicketService.refreshToken();
+            log.info("刷新/获取接口调用令牌......成功了");
+        }catch (Exception e){
+            log.error("定时刷新authorizer_access_token失败：".concat(ExceptionUtils.getErrorStackTrace(e)));
+            throw e;
+        }finally {
+            distributedLock.unLock(lock);
+        }
         return new Result();
     }