From 06236177a345ed6e3c0dc3a3cf923b2f4fd7243f Mon Sep 17 00:00:00 2001
From: feng <18691763612@163.com>
Date: Thu, 4 Dec 2025 16:52:33 +0800
Subject: [PATCH] =?UTF-8?q?=E5=AE=89=E7=9C=BC=E6=8E=A5=E5=8F=A3=E5=8A=A0sp?=
 =?UTF-8?q?ring=20retry=E9=87=8D=E8=AF=95=E6=B3=A8=E8=A7=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/renkang/anyan/client/AnYanClientExecutor.java    | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git a/functional-modules/xj-anyan-api/src/main/java/com/renkang/anyan/client/AnYanClientExecutor.java b/functional-modules/xj-anyan-api/src/main/java/com/renkang/anyan/client/AnYanClientExecutor.java
index 72a6fad..4c5a620 100644
--- a/functional-modules/xj-anyan-api/src/main/java/com/renkang/anyan/client/AnYanClientExecutor.java
+++ b/functional-modules/xj-anyan-api/src/main/java/com/renkang/anyan/client/AnYanClientExecutor.java
@@ -291,6 +291,7 @@ public class AnYanClientExecutor implements AnYanClient {
      * @date 2025/10/24 17:00
      */
     @Override
+    @Retryable(maxAttempts = 2)
     public AnYanUserInfoResult getAnYanUserInfo(String token) {
         HttpHeaders headers = new HttpHeaders();
         headers.add(AnYanConstants.AUTHORIZATION, AnYanConstants.TOKEN_TYPE + token);
@@ -299,6 +300,7 @@ public class AnYanClientExecutor implements AnYanClient {
     }
 
     @Override
+    @Retryable(maxAttempts = 2)
     public List<AnYanAedInfo> queryAnYanAedInfo() {
         //安眼接口本身支持分页查询 , 因此方法用于定时任务批量查询更新 , 这里一次性查询所有
         AnYanResult<Object> result = RestTemplateUtil.postExchange(AnYanApiEnum.QUERY_AN_YAN_AED, buildTokenHeader(), new AnYanAedParam());
@@ -306,6 +308,7 @@ public class AnYanClientExecutor implements AnYanClient {
         return aedPage.getRecords();
     }
     @Override
+    @Retryable(maxAttempts = 2)
     public List<CarePersonList> homeCarePersonList(){
         AnYanResult<Object> result = RestTemplateUtil.postExchange(AnYanApiEnum.CARE_PERSON_BY_TIME, buildTokenHeader(), null);
         List<Object> listMaps = (List<Object>) result.getData();
@@ -313,6 +316,7 @@ public class AnYanClientExecutor implements AnYanClient {
     }
 
     @Override
+    @Retryable(maxAttempts = 2)
     public CareUserListVo careUserDetails(String anYanUserId,String employeeNum){
         JSONObject param = new JSONObject();
         if(StrUtil.isNotEmpty(anYanUserId)){
@@ -326,18 +330,21 @@ public class AnYanClientExecutor implements AnYanClient {
     }
 
     @Override
+    @Retryable(maxAttempts = 2)
     public IPage<CareUserListVo> careUserDetailsPage(CareUserDetailsParam param){
         AnYanResult<Object> result = RestTemplateUtil.postExchange(AnYanApiEnum.CARE_PERSON_PAGE_LIST, buildTokenHeader(), param);
         return new PageResultToBeanUtil<CareUserListVo>().transform(result, CareUserListVo.class);
     }
 
     @Override
+    @Retryable(maxAttempts = 2)
     public IPage<EmergencyContactVO> queryEmergencyContact(EmergencyContactParam param){
         AnYanResult<Object> result = RestTemplateUtil.postExchange(AnYanApiEnum.QUERY_EMPLOYEE_CARE_PERSON, buildTokenHeader(), param);
         return new PageResultToBeanUtil<EmergencyContactVO>().transform(result, EmergencyContactVO.class);
     }
 
     @Override
+    @Retryable(maxAttempts = 2)
     public List<AnYanUpdateUserBatchInfo> updateUserBatch(List<String> employeeNumList) {
         Map<String,List<String>> map = new HashMap<>(1);
         map.put("employeeNumList",employeeNumList);
@@ -347,6 +354,7 @@ public class AnYanClientExecutor implements AnYanClient {
     }
 
     @Override
+    @Retryable(maxAttempts = 2)
     public AnYanUserEmployee updateEmployeeNum(String employeeNum) {
         Map<String,String> map = new HashMap<>(1);
         map.put("employeeNum",employeeNum);
@@ -355,6 +363,7 @@ public class AnYanClientExecutor implements AnYanClient {
     }
 
     @Override
+    @Retryable(maxAttempts = 2)
     public IPage<AnYanHealthCheckNew> queryAnYanHealthCheckNew(AnYanHealthCheckNewParam param) {
         AnYanResult<Object> result = RestTemplateUtil.postExchange(AnYanApiEnum.HEALTH_CHECK_NEW, buildTokenHeader(), param);
         return new PageResultToBeanUtil<AnYanHealthCheckNew>().transform(result, AnYanHealthCheckNew.class);