Browse Source

增加feign降级错误fallbackFactory

single_db
pref_mail@163.com 10 months ago
parent
commit
9b6c2d45cc
  1. 3
      blade-service-api/logpm-old-project-api/src/main/java/com/logpm/oldproject/feign/IAdvanceClient.java
  2. 65
      blade-service-api/logpm-old-project-api/src/main/java/com/logpm/oldproject/feign/IAdvanceClientFallbackFactory.java
  3. 2
      blade-service/logpm-patch/src/main/java/com/logpm/patch/service/impl/SyncOrderInfoServiceImpl.java

3
blade-service-api/logpm-old-project-api/src/main/java/com/logpm/oldproject/feign/IAdvanceClient.java

@ -35,7 +35,8 @@ import java.util.List;
* @since 2023-05-10 * @since 2023-05-10
*/ */
@FeignClient( @FeignClient(
value = ModuleNameConstant.APPLICATION_OLDPROJECT_NAME value = ModuleNameConstant.APPLICATION_OLDPROJECT_NAME,
fallbackFactory =IAdvanceClientFallbackFactory.class
) )
public interface IAdvanceClient { public interface IAdvanceClient {

65
blade-service-api/logpm-old-project-api/src/main/java/com/logpm/oldproject/feign/IAdvanceClientFallbackFactory.java

@ -0,0 +1,65 @@
package com.logpm.oldproject.feign;
import com.logpm.oldproject.dto.AdvanceDTO;
import com.logpm.oldproject.entity.AdvanceEntity;
import lombok.extern.slf4j.Slf4j;
import org.springframework.cloud.openfeign.FallbackFactory;
import org.springframework.stereotype.Component;
import java.util.List;
@Slf4j
@Component
public class IAdvanceClientFallbackFactory implements FallbackFactory<IAdvanceClient> {
@Override
public IAdvanceClient create(Throwable cause) {
return new IAdvanceClient(){
@Override
public Integer addAdvanceClient(AdvanceEntity advanceEntity) {
return null;
}
@Override
public List<AdvanceEntity> getQueryData(AdvanceDTO advanceDTO) {
return null;
}
@Override
public AdvanceEntity getQueryDataOne(String orderSelfNum) {
log.error(">>>>>>>>>>>>>> 订单号查询失败 {}",orderSelfNum);
log.error(">>>>>>>>>>>>>> 异常信息 {}",cause.getMessage());
return null;
}
@Override
public List<AdvanceEntity> getEntityByMctsTruck(String orderSelfNum, String mctsTruck) {
return null;
}
@Override
public AdvanceEntity fingById(Integer advanceId) {
return null;
}
@Override
public List<AdvanceEntity> findAdvanceEntityByLogiBillNoAndOrderCode(String logiBillNo, String orderCode) {
return null;
}
@Override
public List<AdvanceEntity> getAdvanceList(String orderSelfNum) {
return null;
}
@Override
public List<AdvanceEntity> findListByAdvanceIds(List<Integer> advanceIds) {
return null;
}
};
}
}

2
blade-service/logpm-patch/src/main/java/com/logpm/patch/service/impl/SyncOrderInfoServiceImpl.java

@ -339,7 +339,7 @@ public class SyncOrderInfoServiceImpl implements ISyncOrderInfoService {
//通过订单号查询暂存单 //通过订单号查询暂存单
AdvanceEntity advanceEntity = advanceClient.getQueryDataOne(orderCode);//这个地方有问题 AdvanceEntity advanceEntity = advanceClient.getQueryDataOne(orderCode);//这个地方有问题
if(Objects.isNull(advanceEntity)){ if(Objects.isNull(advanceEntity)){
log.warn("#################saveOrderInfo: 未查询单订单信息 orderCode={}",orderCode); log.info("#################saveOrderInfo: 未查询单订单信息 orderCode={}",orderCode);
throw new CustomerException(403,"未查询单订单信息"); throw new CustomerException(403,"未查询单订单信息");
} }
Integer advanceId = advanceEntity.getId(); Integer advanceId = advanceEntity.getId();

Loading…
Cancel
Save