From 90575798dcdbaca57983c4895f2a50c39ff2a097 Mon Sep 17 00:00:00 2001
From: jianjun <liujianjun@git.elinkit.com.cn>
Date: Fri, 2 Apr 2021 14:34:43 +0800
Subject: [PATCH] =?UTF-8?q?=E8=8E=B7=E5=8F=96=E7=AC=AC=E4=B8=89=E6=96=B9to?=
 =?UTF-8?q?ken=E9=87=8D=E8=AF=952=E6=AC=A1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/epmet/apiservice/ApiService.java |  4 ++++
 .../impl/LuzhouGridPlatformApiService.java    | 24 ++++++++-----------
 2 files changed, 14 insertions(+), 14 deletions(-)

diff --git a/epmet-module/epmet-third/epmet-third-server/src/main/java/com/epmet/apiservice/ApiService.java b/epmet-module/epmet-third/epmet-third-server/src/main/java/com/epmet/apiservice/ApiService.java
index 9980f5dbc5..f1b01dbc96 100644
--- a/epmet-module/epmet-third/epmet-third-server/src/main/java/com/epmet/apiservice/ApiService.java
+++ b/epmet-module/epmet-third/epmet-third-server/src/main/java/com/epmet/apiservice/ApiService.java
@@ -31,6 +31,10 @@ import java.util.concurrent.TimeUnit;
  * 此抽象类中定义方法的具体返回类型，所有子类都要统一使用，在具体实现中做转换。若是不需要返回，返回null即可。
  */
 public abstract class ApiService {
+    /**
+     * 重试次数
+     */
+    protected final int RETRY_TIME = 3;
 
     /**
      * @Description 判断该客户是否注册了该平台
diff --git a/epmet-module/epmet-third/epmet-third-server/src/main/java/com/epmet/apiservice/impl/LuzhouGridPlatformApiService.java b/epmet-module/epmet-third/epmet-third-server/src/main/java/com/epmet/apiservice/impl/LuzhouGridPlatformApiService.java
index d3b39f4f47..52dce2bc30 100644
--- a/epmet-module/epmet-third/epmet-third-server/src/main/java/com/epmet/apiservice/impl/LuzhouGridPlatformApiService.java
+++ b/epmet-module/epmet-third/epmet-third-server/src/main/java/com/epmet/apiservice/impl/LuzhouGridPlatformApiService.java
@@ -3,36 +3,32 @@ package com.epmet.apiservice.impl;
 import com.alibaba.fastjson.JSON;
 import com.epmet.apiservice.ApiService;
 import com.epmet.apiservice.result.LZGridPlatformBaseResult;
-import com.epmet.apiservice.result.LZGridPlatformProjectAssistResult;
-import com.epmet.commons.tools.constant.StrConstant;
 import com.epmet.commons.tools.exception.RenException;
-import com.epmet.commons.tools.redis.RedisKeys;
 import com.epmet.commons.tools.utils.HttpClientManager;
 import com.epmet.commons.tools.utils.Result;
 import com.epmet.commons.tools.utils.SpringContextUtils;
 import com.epmet.constant.ThirdPlatformActions;
 import com.epmet.dao.ThirdplatformActionDao;
 import com.epmet.dao.ThirdplatformDao;
+import com.epmet.dto.form.ProjectApplyAssistFormDTO;
 import com.epmet.dto.form.UploadFileFormDTO;
 import com.epmet.dto.result.ProjectAssistResult;
-import com.epmet.dto.form.ProjectApplyAssistFormDTO;
 import com.epmet.dto.result.UploadFileResultDTO;
 import com.epmet.entity.ThirdplatformActionEntity;
 import com.epmet.entity.ThirdplatformEntity;
+import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.io.FileUtils;
-import org.apache.commons.io.FilenameUtils;
 import org.apache.commons.lang3.StringUtils;
-import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.stereotype.Component;
 
 import java.io.File;
 import java.util.HashMap;
-import java.util.Objects;
 import java.util.concurrent.TimeUnit;
 
 /**
  * 泸州网格化平台ApiService
  */
+@Slf4j
 @Component("luzhouGridPlatformApiService")
 public class LuzhouGridPlatformApiService extends ApiService {
 
@@ -51,13 +47,13 @@ public class LuzhouGridPlatformApiService extends ApiService {
             HashMap<String, Object> params = new HashMap<>();
             params.put("appKey", platformKey);
             params.put("appSecret", platformSecret);
-            Result<String> result = HttpClientManager.getInstance().sendGet(baseUrl.concat(actionEntity.getApiUrl()), params);
-
-            if (result == null) {
-                throw new RenException("请求第三方平台，获取AccessToken失败。result为null");
-            }
+            Result<String> result = null;
+            int tryTime = 0;
+            do {
+                result = HttpClientManager.getInstance().sendGet(baseUrl.concat(actionEntity.getApiUrl()), params);
+            } while ((result == null || !result.success()) && super.RETRY_TIME<tryTime++);
 
-            if (!result.success()) {
+            if (result == null || !result.success()) {
                 throw new RenException("请求第三方平台，获取AccessToken失败。");
             }
 
@@ -92,7 +88,7 @@ public class LuzhouGridPlatformApiService extends ApiService {
             // 此处设置为第三方系统返回的唯一id
             projectAssistResult.setTaskId(lzResult.getResult());
         }
-        System.out.println("泸州网格化平台项目协助发送成功");
+        log.info("projectAssist 泸州网格化平台项目协助发送成功");
         return projectAssistResult;
     }