安眼接口加spring retry重试注解

This commit is contained in:
feng
2025-12-04 16:52:33 +08:00
parent 930b806a25
commit 06236177a3
@@ -291,6 +291,7 @@ public class AnYanClientExecutor implements AnYanClient {
* @date 2025/10/24 17:00 * @date 2025/10/24 17:00
*/ */
@Override @Override
@Retryable(maxAttempts = 2)
public AnYanUserInfoResult getAnYanUserInfo(String token) { public AnYanUserInfoResult getAnYanUserInfo(String token) {
HttpHeaders headers = new HttpHeaders(); HttpHeaders headers = new HttpHeaders();
headers.add(AnYanConstants.AUTHORIZATION, AnYanConstants.TOKEN_TYPE + token); headers.add(AnYanConstants.AUTHORIZATION, AnYanConstants.TOKEN_TYPE + token);
@@ -299,6 +300,7 @@ public class AnYanClientExecutor implements AnYanClient {
} }
@Override @Override
@Retryable(maxAttempts = 2)
public List<AnYanAedInfo> queryAnYanAedInfo() { public List<AnYanAedInfo> queryAnYanAedInfo() {
//安眼接口本身支持分页查询 , 因此方法用于定时任务批量查询更新 , 这里一次性查询所有 //安眼接口本身支持分页查询 , 因此方法用于定时任务批量查询更新 , 这里一次性查询所有
AnYanResult<Object> result = RestTemplateUtil.postExchange(AnYanApiEnum.QUERY_AN_YAN_AED, buildTokenHeader(), new AnYanAedParam()); 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(); return aedPage.getRecords();
} }
@Override @Override
@Retryable(maxAttempts = 2)
public List<CarePersonList> homeCarePersonList(){ public List<CarePersonList> homeCarePersonList(){
AnYanResult<Object> result = RestTemplateUtil.postExchange(AnYanApiEnum.CARE_PERSON_BY_TIME, buildTokenHeader(), null); AnYanResult<Object> result = RestTemplateUtil.postExchange(AnYanApiEnum.CARE_PERSON_BY_TIME, buildTokenHeader(), null);
List<Object> listMaps = (List<Object>) result.getData(); List<Object> listMaps = (List<Object>) result.getData();
@@ -313,6 +316,7 @@ public class AnYanClientExecutor implements AnYanClient {
} }
@Override @Override
@Retryable(maxAttempts = 2)
public CareUserListVo careUserDetails(String anYanUserId,String employeeNum){ public CareUserListVo careUserDetails(String anYanUserId,String employeeNum){
JSONObject param = new JSONObject(); JSONObject param = new JSONObject();
if(StrUtil.isNotEmpty(anYanUserId)){ if(StrUtil.isNotEmpty(anYanUserId)){
@@ -326,18 +330,21 @@ public class AnYanClientExecutor implements AnYanClient {
} }
@Override @Override
@Retryable(maxAttempts = 2)
public IPage<CareUserListVo> careUserDetailsPage(CareUserDetailsParam param){ public IPage<CareUserListVo> careUserDetailsPage(CareUserDetailsParam param){
AnYanResult<Object> result = RestTemplateUtil.postExchange(AnYanApiEnum.CARE_PERSON_PAGE_LIST, buildTokenHeader(), param); AnYanResult<Object> result = RestTemplateUtil.postExchange(AnYanApiEnum.CARE_PERSON_PAGE_LIST, buildTokenHeader(), param);
return new PageResultToBeanUtil<CareUserListVo>().transform(result, CareUserListVo.class); return new PageResultToBeanUtil<CareUserListVo>().transform(result, CareUserListVo.class);
} }
@Override @Override
@Retryable(maxAttempts = 2)
public IPage<EmergencyContactVO> queryEmergencyContact(EmergencyContactParam param){ public IPage<EmergencyContactVO> queryEmergencyContact(EmergencyContactParam param){
AnYanResult<Object> result = RestTemplateUtil.postExchange(AnYanApiEnum.QUERY_EMPLOYEE_CARE_PERSON, buildTokenHeader(), param); AnYanResult<Object> result = RestTemplateUtil.postExchange(AnYanApiEnum.QUERY_EMPLOYEE_CARE_PERSON, buildTokenHeader(), param);
return new PageResultToBeanUtil<EmergencyContactVO>().transform(result, EmergencyContactVO.class); return new PageResultToBeanUtil<EmergencyContactVO>().transform(result, EmergencyContactVO.class);
} }
@Override @Override
@Retryable(maxAttempts = 2)
public List<AnYanUpdateUserBatchInfo> updateUserBatch(List<String> employeeNumList) { public List<AnYanUpdateUserBatchInfo> updateUserBatch(List<String> employeeNumList) {
Map<String,List<String>> map = new HashMap<>(1); Map<String,List<String>> map = new HashMap<>(1);
map.put("employeeNumList",employeeNumList); map.put("employeeNumList",employeeNumList);
@@ -347,6 +354,7 @@ public class AnYanClientExecutor implements AnYanClient {
} }
@Override @Override
@Retryable(maxAttempts = 2)
public AnYanUserEmployee updateEmployeeNum(String employeeNum) { public AnYanUserEmployee updateEmployeeNum(String employeeNum) {
Map<String,String> map = new HashMap<>(1); Map<String,String> map = new HashMap<>(1);
map.put("employeeNum",employeeNum); map.put("employeeNum",employeeNum);
@@ -355,6 +363,7 @@ public class AnYanClientExecutor implements AnYanClient {
} }
@Override @Override
@Retryable(maxAttempts = 2)
public IPage<AnYanHealthCheckNew> queryAnYanHealthCheckNew(AnYanHealthCheckNewParam param) { public IPage<AnYanHealthCheckNew> queryAnYanHealthCheckNew(AnYanHealthCheckNewParam param) {
AnYanResult<Object> result = RestTemplateUtil.postExchange(AnYanApiEnum.HEALTH_CHECK_NEW, buildTokenHeader(), param); AnYanResult<Object> result = RestTemplateUtil.postExchange(AnYanApiEnum.HEALTH_CHECK_NEW, buildTokenHeader(), param);
return new PageResultToBeanUtil<AnYanHealthCheckNew>().transform(result, AnYanHealthCheckNew.class); return new PageResultToBeanUtil<AnYanHealthCheckNew>().transform(result, AnYanHealthCheckNew.class);