[瑞成接口] <fix> 注释重试机制和秘钥过期时间判断

src/main/java/com/mth/requestsecret/scheduler/RequestSecretSchedulerTask.java

@@ -71,7 +71,7 @@ public class RequestSecretSchedulerTask implements SchedulingConfigurer {
                 triggerContext -> {
                     getRequestSecret();
                     // 提前一分钟刷新
-                    Instant instant = Instant.ofEpochMilli(requestSecretEndTime).minus(1, ChronoUnit.MINUTES);
+                    Instant instant = Instant.ofEpochMilli(requestSecretEndTime).minus(5, ChronoUnit.MINUTES);
                     return Date.from(instant);
                 }
         );
@@ -105,11 +105,11 @@ public class RequestSecretSchedulerTask implements SchedulingConfigurer {
             requestSecretEndTime = Long.parseLong(datas.getString("requestSecretEndTime"));
             refreshSecret = datas.getString("refreshSecret");
             refreshSecretEndTime = Long.parseLong(datas.getString("refreshSecretEndTime"));
-            // 设置过期时间，30秒内不重新刷新秘钥
-            String expireTime = String.valueOf(requestSecretEndTime -  (14 * 60 * 1000 + 30 * 1000));
+            // // 设置过期时间，30秒内不重新刷新秘钥
+            // String expireTime = String.valueOf(requestSecretEndTime -  (14 * 60 * 1000 + 30 * 1000));
             // redis保存 请求秘钥 和 过期时间
             redisUtil.set(Constants.SJJ_REQUEST_SECRET_PREFIX, requestSecret);
-            redisUtil.set(Constants.SJJ_REQUEST_EXPIRE_TIME_PREFIX, expireTime);
+            // redisUtil.set(Constants.SJJ_REQUEST_EXPIRE_TIME_PREFIX, expireTime);
         }
     }
 

src/main/java/com/mth/requestsecret/service/RestTemplateService.java

@@ -13,14 +13,11 @@ import org.springframework.util.LinkedMultiValueMap;
 import org.springframework.util.MultiValueMap;
 import org.springframework.web.client.RestTemplate;
 
-import java.time.Instant;
-import java.time.LocalDateTime;
-import java.time.ZoneOffset;
 import java.util.Date;
 import java.util.Map;
 import java.util.Objects;
 
-import static com.mth.requestsecret.constant.Constants.*;
+import static com.mth.requestsecret.constant.Constants.SJJ_REQUEST_SECRET_PREFIX;
 
 /**
  * @author fyl
@@ -111,32 +108,32 @@ public class RestTemplateService {
         ResponseEntity<String> responseEntity = restTemplate.exchange(url.toString(), HttpMethod.POST, request, String.class);
         log.info("api response：{}", responseEntity);
 
-        try {
-            // 接口返回码
-            String code = JSONObject.parseObject(responseEntity.getBody()).getString("code");
-            Integer count = threadLocal.get();
-            String threadName = Thread.currentThread().getName();
-
-            // 如非成功返回码，则重新获取秘钥并发送请求，限制重新请求次数
-            if (!RESPONSE_CODE_00.equals(code) && count < REQUEST_LIMIT) {
-                threadLocal.set(++count);
-                log.info("线程名称：{}，重新请求次数：{}", threadName, count);
-                // redis 中获取过期时间
-                String expireTimeStr = redisUtil.get(SJJ_REQUEST_EXPIRE_TIME_PREFIX);
-                LocalDateTime expireTime = Instant.ofEpochMilli(Long.parseLong(expireTimeStr)).atZone(ZoneOffset.ofHours(8)).toLocalDateTime();
-                LocalDateTime now = LocalDateTime.now();
-                // 当前时间超过过期时间，重新请求秘钥，否则重新发送请求
-                if (now.isAfter(expireTime)) {
-                    log.info("redis中过期时间：{}，当前时间：{}", expireTime, now);
-                    // 重新获取秘钥
-                    schedulerTask.getRequestSecret();
-                }
-                // 重新调用请求
-                return commonSendRequest(paramMap, apiMethod);
-            }
-        } finally {
-            threadLocal.remove();
-        }
+        // try {
+        //     // 接口返回码
+        //     String code = JSONObject.parseObject(responseEntity.getBody()).getString("code");
+        //     Integer count = threadLocal.get();
+        //     String threadName = Thread.currentThread().getName();
+        //
+        //     // 如非成功返回码，则重新获取秘钥并发送请求，限制重新请求次数
+        //     if (!RESPONSE_CODE_00.equals(code) && count < REQUEST_LIMIT) {
+        //         threadLocal.set(++count);
+        //         log.info("线程名称：{}，重新请求次数：{}", threadName, count);
+        //         // redis 中获取过期时间
+        //         String expireTimeStr = redisUtil.get(SJJ_REQUEST_EXPIRE_TIME_PREFIX);
+        //         LocalDateTime expireTime = Instant.ofEpochMilli(Long.parseLong(expireTimeStr)).atZone(ZoneOffset.ofHours(8)).toLocalDateTime();
+        //         LocalDateTime now = LocalDateTime.now();
+        //         // 当前时间超过过期时间，重新请求秘钥，否则重新发送请求
+        //         if (now.isAfter(expireTime)) {
+        //             log.info("redis中过期时间：{}，当前时间：{}", expireTime, now);
+        //             // 重新获取秘钥
+        //             schedulerTask.getRequestSecret();
+        //         }
+        //         // 重新调用请求
+        //         return commonSendRequest(paramMap, apiMethod);
+        //     }
+        // } finally {
+        //     threadLocal.remove();
+        // }
         return responseEntity;
     }