diff --git a/data-processing/data-processing-api/src/main/java/com/njcn/dataProcess/api/DataLimitRateFeignClient.java b/data-processing/data-processing-api/src/main/java/com/njcn/dataProcess/api/DataLimitRateFeignClient.java index 5148fdc..e51afae 100644 --- a/data-processing/data-processing-api/src/main/java/com/njcn/dataProcess/api/DataLimitRateFeignClient.java +++ b/data-processing/data-processing-api/src/main/java/com/njcn/dataProcess/api/DataLimitRateFeignClient.java @@ -2,7 +2,7 @@ package com.njcn.dataProcess.api; import com.njcn.common.pojo.constant.ServerInfo; import com.njcn.common.pojo.response.HttpResult; -import com.njcn.dataProcess.api.fallback.DataIFeignClientFallbackFactory; +import com.njcn.dataProcess.api.fallback.DataLimitRateFeignClientFallbackFactory; import com.njcn.dataProcess.pojo.dto.DataLimitRateDto; import org.springframework.cloud.openfeign.FeignClient; import org.springframework.web.bind.annotation.PostMapping; @@ -15,7 +15,7 @@ import java.util.List; * @Author: wr * @Date: 2025/3/7 9:30 */ -@FeignClient(value = ServerInfo.PLATFORM_DATA_PROCESSING_BOOT, path = "/dataLimitRate", fallbackFactory = DataIFeignClientFallbackFactory.class, contextId = "dataLimitRate") +@FeignClient(value = ServerInfo.PLATFORM_DATA_PROCESSING_BOOT, path = "/dataLimitRate", fallbackFactory = DataLimitRateFeignClientFallbackFactory.class, contextId = "dataLimitRate") public interface DataLimitRateFeignClient { @PostMapping("/batchInsertion") diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataLimitRateController.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataLimitRateController.java index 8415663..79024ed 100644 --- a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataLimitRateController.java +++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataLimitRateController.java @@ -8,28 +8,17 @@ import com.njcn.common.pojo.response.HttpResult; import com.njcn.common.utils.HttpResultUtil; import com.njcn.dataProcess.annotation.InsertBean; import com.njcn.dataProcess.annotation.QueryBean; -import com.njcn.dataProcess.dto.DataVDTO; -import com.njcn.dataProcess.dto.DataVFiveItemDTO; -import com.njcn.dataProcess.param.LineCountEvaluateParam; -import com.njcn.dataProcess.pojo.dto.CommonMinuteDto; import com.njcn.dataProcess.pojo.dto.DataLimitRateDto; -import com.njcn.dataProcess.pojo.dto.DataVCvtDto; -import com.njcn.dataProcess.pojo.dto.DataVDto; -import com.njcn.dataProcess.pojo.po.RStatLimitRateD; -import com.njcn.dataProcess.service.IDataV; -import com.njcn.dataProcess.service.ILimitRateService; +import com.njcn.dataProcess.service.ILimitRate; import com.njcn.web.controller.BaseController; import io.swagger.annotations.Api; -import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiOperation; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Controller; import org.springframework.validation.annotation.Validated; import org.springframework.web.bind.annotation.*; -import java.time.LocalDateTime; import java.util.List; -import java.util.Map; /** * @author hongawen @@ -45,10 +34,10 @@ import java.util.Map; public class DataLimitRateController extends BaseController { @QueryBean - private ILimitRateService limitRateQuery; + private ILimitRate limitRateQuery; @InsertBean - private ILimitRateService limitRateInsert; + private ILimitRate limitRateInsert; @OperateInfo(info = LogEnum.BUSINESS_COMMON,operateType = OperateType.ADD) diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/dao/imapper/DataLimitRateMapper.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/dao/imapper/DataLimitRateMapper.java index e990b9b..79e5f68 100644 --- a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/dao/imapper/DataLimitRateMapper.java +++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/dao/imapper/DataLimitRateMapper.java @@ -1,7 +1,7 @@ package com.njcn.dataProcess.dao.imapper; -import com.github.jeffreyning.mybatisplus.base.MppBaseMapper; import com.njcn.dataProcess.pojo.dto.DataLimitRateDto; +import com.njcn.influx.base.InfluxDbBaseMapper; /** @@ -10,7 +10,7 @@ import com.njcn.dataProcess.pojo.dto.DataLimitRateDto; *
* @author web2023 */ -public interface DataLimitRateMapper extends MppBaseMapper