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 queryAnYanAedInfo() { //安眼接口本身支持分页查询 , 因此方法用于定时任务批量查询更新 , 这里一次性查询所有 AnYanResult 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 homeCarePersonList(){ AnYanResult result = RestTemplateUtil.postExchange(AnYanApiEnum.CARE_PERSON_BY_TIME, buildTokenHeader(), null); List listMaps = (List) 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 careUserDetailsPage(CareUserDetailsParam param){ AnYanResult result = RestTemplateUtil.postExchange(AnYanApiEnum.CARE_PERSON_PAGE_LIST, buildTokenHeader(), param); return new PageResultToBeanUtil().transform(result, CareUserListVo.class); } @Override + @Retryable(maxAttempts = 2) public IPage queryEmergencyContact(EmergencyContactParam param){ AnYanResult result = RestTemplateUtil.postExchange(AnYanApiEnum.QUERY_EMPLOYEE_CARE_PERSON, buildTokenHeader(), param); return new PageResultToBeanUtil().transform(result, EmergencyContactVO.class); } @Override + @Retryable(maxAttempts = 2) public List updateUserBatch(List employeeNumList) { Map> 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 map = new HashMap<>(1); map.put("employeeNum",employeeNum); @@ -355,6 +363,7 @@ public class AnYanClientExecutor implements AnYanClient { } @Override + @Retryable(maxAttempts = 2) public IPage queryAnYanHealthCheckNew(AnYanHealthCheckNewParam param) { AnYanResult result = RestTemplateUtil.postExchange(AnYanApiEnum.HEALTH_CHECK_NEW, buildTokenHeader(), param); return new PageResultToBeanUtil().transform(result, AnYanHealthCheckNew.class);