refactor(cs-device): 重命名OverLimitClient及相关类名

- 将OverLimitClient重命名为CsOverLimitClient
- 将OverLimitFallbackFactory重命名为CsOverLimitFallbackFactory
- 更新相关引用类名以匹配新命名
- 修改RStatLimitRateDetailDServiceImpl中的客户端注入名称
This commit is contained in:
贾同学
2025-12-05 11:05:36 +08:00
parent 3526926034
commit 791aac26c0
3 changed files with 9 additions and 9 deletions

View File

@@ -2,7 +2,7 @@ package com.njcn.csdevice.api;
import com.njcn.common.pojo.constant.ServerInfo; import com.njcn.common.pojo.constant.ServerInfo;
import com.njcn.common.pojo.response.HttpResult; import com.njcn.common.pojo.response.HttpResult;
import com.njcn.csdevice.api.fallback.OverLimitFallbackFactory; import com.njcn.csdevice.api.fallback.CsOverLimitFallbackFactory;
import com.njcn.csdevice.pojo.po.Overlimit; import com.njcn.csdevice.pojo.po.Overlimit;
import org.springframework.cloud.openfeign.FeignClient; import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.PostMapping;
@@ -18,8 +18,8 @@ import java.util.Map;
*/ */
@FeignClient(value = ServerInfo.CS_DEVICE_BOOT, @FeignClient(value = ServerInfo.CS_DEVICE_BOOT,
path = "/overLimit", path = "/overLimit",
fallbackFactory = OverLimitFallbackFactory.class,contextId = "overLimit") fallbackFactory = CsOverLimitFallbackFactory.class,contextId = "overLimit")
public interface OverLimitClient { public interface CsOverLimitClient {
/** /**
* *

View File

@@ -3,7 +3,7 @@ package com.njcn.csdevice.api.fallback;
import com.njcn.common.pojo.enums.response.CommonResponseEnum; import com.njcn.common.pojo.enums.response.CommonResponseEnum;
import com.njcn.common.pojo.exception.BusinessException; import com.njcn.common.pojo.exception.BusinessException;
import com.njcn.common.pojo.response.HttpResult; import com.njcn.common.pojo.response.HttpResult;
import com.njcn.csdevice.api.OverLimitClient; import com.njcn.csdevice.api.CsOverLimitClient;
import com.njcn.csdevice.pojo.po.Overlimit; import com.njcn.csdevice.pojo.po.Overlimit;
import com.njcn.device.biz.utils.DeviceEnumUtil; import com.njcn.device.biz.utils.DeviceEnumUtil;
import feign.hystrix.FallbackFactory; import feign.hystrix.FallbackFactory;
@@ -20,9 +20,9 @@ import java.util.Map;
*/ */
@Slf4j @Slf4j
@Component @Component
public class OverLimitFallbackFactory implements FallbackFactory<OverLimitClient> { public class CsOverLimitFallbackFactory implements FallbackFactory<CsOverLimitClient> {
@Override @Override
public OverLimitClient create(Throwable throwable) { public CsOverLimitClient create(Throwable throwable) {
//判断抛出异常是否为解码器抛出的业务异常 //判断抛出异常是否为解码器抛出的业务异常
Enum<?> exceptionEnum = CommonResponseEnum.SERVICE_FALLBACK; Enum<?> exceptionEnum = CommonResponseEnum.SERVICE_FALLBACK;
if (throwable.getCause() instanceof BusinessException) { if (throwable.getCause() instanceof BusinessException) {
@@ -30,7 +30,7 @@ public class OverLimitFallbackFactory implements FallbackFactory<OverLimitClient
exceptionEnum = DeviceEnumUtil.getExceptionEnum(businessException.getResult()); exceptionEnum = DeviceEnumUtil.getExceptionEnum(businessException.getResult());
} }
Enum<?> finalExceptionEnum = exceptionEnum; Enum<?> finalExceptionEnum = exceptionEnum;
return new OverLimitClient() { return new CsOverLimitClient() {
@Override @Override
public HttpResult<List<Overlimit>> getOverLimitByLineIds(List<String> lineIds) { public HttpResult<List<Overlimit>> getOverLimitByLineIds(List<String> lineIds) {
log.error("{}异常,降级处理,异常为:{}", "监测点限值", throwable.toString()); log.error("{}异常,降级处理,异常为:{}", "监测点限值", throwable.toString());

View File

@@ -12,7 +12,7 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.njcn.csdevice.api.CsLineFeignClient; import com.njcn.csdevice.api.CsLineFeignClient;
import com.njcn.csdevice.api.OverLimitClient; import com.njcn.csdevice.api.CsOverLimitClient;
import com.njcn.csdevice.pojo.po.CsLinePO; import com.njcn.csdevice.pojo.po.CsLinePO;
import com.njcn.csdevice.pojo.po.Overlimit; import com.njcn.csdevice.pojo.po.Overlimit;
import com.njcn.csharmonic.mapper.RStatLimitRateDetailDMapper; import com.njcn.csharmonic.mapper.RStatLimitRateDetailDMapper;
@@ -42,7 +42,7 @@ import java.util.stream.Collectors;
public class RStatLimitRateDetailDServiceImpl extends ServiceImpl<RStatLimitRateDetailDMapper, RStatLimitRateDetailDPO> implements IRStatLimitRateDetailDService { public class RStatLimitRateDetailDServiceImpl extends ServiceImpl<RStatLimitRateDetailDMapper, RStatLimitRateDetailDPO> implements IRStatLimitRateDetailDService {
private final CsLineFeignClient csLineFeignClient; private final CsLineFeignClient csLineFeignClient;
private final OverLimitClient overLimitClient; private final CsOverLimitClient overLimitClient;
private final DecimalFormat df = new DecimalFormat("#0.00"); private final DecimalFormat df = new DecimalFormat("#0.00");