监测点稳态指标越限次数统计

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")

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.service.ILimitRate;
-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.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)

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;
  * </p>
  * @author web2023
  */
-public interface DataLimitRateMapper extends MppBaseMapper<DataLimitRateDto> {
+public interface DataLimitRateMapper extends InfluxDbBaseMapper<DataLimitRateDto> {
 
 
 

data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/ILimitRate.java

@@ -12,7 +12,7 @@ import java.util.List;
  * @Author: wr
  * @Date: 2025/3/6 10:22
  */
-public interface ILimitRateService extends IMppService<RStatLimitRateD> {
+public interface ILimitRate extends IMppService<RStatLimitRateD> {
 
     /**
      * 批量插入数据

data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbLimitRateImpl.java

@@ -1,26 +1,23 @@
 package com.njcn.dataProcess.service.impl.influxdb;
 
 import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
-import com.njcn.dataProcess.dao.imapper.DataVMapper;
 import com.njcn.dataProcess.dao.relation.mapper.RStatLimitRateRelationMapper;
 import com.njcn.dataProcess.pojo.dto.DataLimitRateDto;
 import com.njcn.dataProcess.pojo.po.RStatLimitRateD;
-import com.njcn.dataProcess.service.ILimitRateService;
+import com.njcn.dataProcess.service.ILimitRate;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Service;
 
 import java.util.List;
 
 /**
- * Description:
+ * @Description:
- * Date: 2024/11/18  14:33【需求编号】
+ * @Author: wr
- *
+ * @Date: 2025/3/7 10:13
- * @author clam
- * @version V1.0.0
  */
 @Service("InfluxdbLimitRateImpl")
 @RequiredArgsConstructor
-public class InfluxdbLimitRateImpl extends MppServiceImpl<RStatLimitRateRelationMapper, RStatLimitRateD> implements ILimitRateService {
+public class InfluxdbLimitRateImpl extends MppServiceImpl<RStatLimitRateRelationMapper, RStatLimitRateD> implements ILimitRate {
 
     @Override
     public void batchInsertion(List<DataLimitRateDto> limitRateList) {

data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/relation/RelationLimitRateImpl.java

@@ -3,11 +3,8 @@ package com.njcn.dataProcess.service.impl.relation;
 import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
 import com.njcn.dataProcess.dao.relation.mapper.RStatLimitRateRelationMapper;
 import com.njcn.dataProcess.pojo.dto.DataLimitRateDto;
-import com.njcn.dataProcess.pojo.po.RStatDataVD;
 import com.njcn.dataProcess.pojo.po.RStatLimitRateD;
-import com.njcn.dataProcess.service.IDataV;
+import com.njcn.dataProcess.service.ILimitRate;
-import com.njcn.dataProcess.service.ILimitRateService;
-import com.njcn.dataProcess.util.TimeUtils;
 import lombok.RequiredArgsConstructor;
 import org.springframework.beans.BeanUtils;
 import org.springframework.stereotype.Service;
@@ -18,16 +15,16 @@ import java.util.List;
 
 
 /**
- * @author hongawen
+ * @Description:
- * @version 1.0
+ * @Author: wr
- * @data 2024/11/7 11:02
+ * @Date: 2025/3/7 10:13
  */
 @Service("RelationLimitRateImpl")
 @RequiredArgsConstructor
-public class RelationLimitRateImpl extends MppServiceImpl<RStatLimitRateRelationMapper, RStatLimitRateD> implements ILimitRateService {
+public class RelationLimitRateImpl extends MppServiceImpl<RStatLimitRateRelationMapper, RStatLimitRateD> implements ILimitRate {
 
     @Resource
-    private ILimitRateService limitRateService;
+    private ILimitRate limitRate;
 
     @Override
     public void batchInsertion(List<DataLimitRateDto> limitRateList) {
@@ -37,6 +34,6 @@ public class RelationLimitRateImpl extends MppServiceImpl<RStatLimitRateRelation
             BeanUtils.copyProperties(item, limitRate);
             result.add(limitRate);
         });
-        limitRateService.saveOrUpdateBatchByMultiId(result);
+        this.saveOrUpdateBatchByMultiId(result);
     }
 }