diff --git a/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/service/line/IDayDataService.java b/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/service/line/IDayDataService.java
index d5a32d8..7a34a9f 100644
--- a/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/service/line/IDayDataService.java
+++ b/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/service/line/IDayDataService.java
@@ -119,4 +119,6 @@ public interface IDayDataService {
      * @param calculatedParam 查询条件
      */
     void dataPltHandler(CalculatedParam calculatedParam);
+
+    
 }
diff --git a/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/IDataIntegrityServiceImpl.java b/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/IDataIntegrityServiceImpl.java
index 77b756a..96c0a7d 100644
--- a/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/IDataIntegrityServiceImpl.java
+++ b/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/IDataIntegrityServiceImpl.java
@@ -15,11 +15,15 @@ import com.njcn.device.biz.commApi.CommTerminalGeneralClient;
 import com.njcn.device.biz.pojo.dto.LineDevGetDTO;
 import com.njcn.influx.pojo.constant.InfluxDBTableConstant;
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.ListUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
+import java.time.LocalDateTime;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
@@ -31,13 +35,15 @@ import java.util.stream.Collectors;
  * @CreateTime: 2025-02-28
  * @Description: 数据完成性
  */
+@Slf4j
 @Service
 @RequiredArgsConstructor
 public class IDataIntegrityServiceImpl implements IDataIntegrityService {
 
+    private static final Logger logger = LoggerFactory.getLogger(IDataIntegrityServiceImpl.class);
+
     @Value("${line.num}")
     private  Integer NUM = 100;
-
     @Resource
     private CommTerminalGeneralClient commTerminalGeneralClient;
     @Resource
@@ -48,6 +54,7 @@ public class IDataIntegrityServiceImpl implements IDataIntegrityService {
 
     @Override
     public void dataIntegrity(CalculatedParam<String> calculatedParam) {
+        logger.info("{},integrity表转r_stat_integrity_d算法开始=====》", LocalDateTime.now());
         List<DataIntegrityDto> poList = new ArrayList<>();
         List<String> lineIds = calculatedParam.getIdList();
         String beginDay = LocalDateTimeUtil.format(
diff --git a/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/IDataOnlineRateServiceImpl.java b/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/IDataOnlineRateServiceImpl.java
index bbaabb5..007b5c4 100644
--- a/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/IDataOnlineRateServiceImpl.java
+++ b/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/IDataOnlineRateServiceImpl.java
@@ -24,10 +24,13 @@ import com.njcn.user.api.DeptFeignClient;
 import com.njcn.user.pojo.po.Dept;
 import lombok.RequiredArgsConstructor;
 import org.apache.commons.collections4.ListUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
+import java.time.LocalDateTime;
 import java.util.*;
 import java.util.stream.Collectors;
 
@@ -40,6 +43,8 @@ import java.util.stream.Collectors;
 @RequiredArgsConstructor
 public class IDataOnlineRateServiceImpl implements IDataOnlineRateService {
 
+    private static final Logger logger = LoggerFactory.getLogger(IDataOnlineRateServiceImpl.class);
+
     @Value("${line.num}")
     private  Integer NUM = 100;
 
@@ -59,6 +64,7 @@ public class IDataOnlineRateServiceImpl implements IDataOnlineRateService {
 
     @Override
     public void dataOnlineRate(CalculatedParam calculatedParam) {
+        logger.info("{},onlineRate表转r_stat_onlinerate_d算法开始=====》", LocalDateTime.now());
         LineCountEvaluateParam lineParam = new LineCountEvaluateParam();
         lineParam.setStartTime(TimeUtils.getBeginOfDay(calculatedParam.getDataDate()));
         lineParam.setEndTime(TimeUtils.getEndOfDay(calculatedParam.getDataDate()));
diff --git a/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/IEventDetailServiceImpl.java b/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/IEventDetailServiceImpl.java
new file mode 100644
index 0000000..ba036bb
--- /dev/null
+++ b/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/IEventDetailServiceImpl.java
@@ -0,0 +1,42 @@
+package com.njcn.algorithm.serviceimpl.line;
+
+import com.njcn.algorithm.pojo.bo.CalculatedParam;
+import com.njcn.algorithm.service.line.IEventDetailService;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author wr
+ * @description
+ * @date 2025/3/14 15:03
+ */
+@Slf4j
+@Component
+@RequiredArgsConstructor
+public class IEventDetailServiceImpl implements IEventDetailService {
+
+    private static final Logger logger = LoggerFactory.getLogger(IDataOnlineRateServiceImpl.class);
+
+    @Override
+    public void dataDayHandle(CalculatedParam<String> calculatedParam) {
+
+    }
+
+    @Override
+    public void dataMonthHandle(CalculatedParam<String> calculatedParam) {
+
+    }
+
+    @Override
+    public void dataQuarterHandle(CalculatedParam<String> calculatedParam) {
+
+    }
+
+    @Override
+    public void dataYearHandle(CalculatedParam<String> calculatedParam) {
+
+    }
+}
diff --git a/data-processing/data-processing-api/src/main/java/com/njcn/dataProcess/pojo/dto/DataEventDetailDto.java b/data-processing/data-processing-api/src/main/java/com/njcn/dataProcess/pojo/dto/DataEventDetailDto.java
new file mode 100644
index 0000000..9f1ff21
--- /dev/null
+++ b/data-processing/data-processing-api/src/main/java/com/njcn/dataProcess/pojo/dto/DataEventDetailDto.java
@@ -0,0 +1,38 @@
+package com.njcn.dataProcess.pojo.dto;
+
+import lombok.Data;
+
+import java.time.LocalDate;
+
+/**
+ * @Description: 监测点暂态指标超标明细日表
+ * @Author: wr
+ * @Date: 2025/3/14 13:47
+ */
+@Data
+public class DataEventDetailDto {
+    /**
+     * 监测点ID
+     */
+    private String measurementPointId;
+
+    /**
+     * 时间
+     */
+    private LocalDate dataDate;
+
+    /**
+     * 电压暂升发生次数
+     */
+    private Integer swellTimes;
+
+    /**
+     * 电压暂降发生次数
+     */
+    private Integer sagTimes;
+
+    /**
+     * 短时中断发生次数
+     */
+    private Integer interruptTimes;
+}
diff --git a/data-processing/data-processing-api/src/main/java/com/njcn/dataProcess/pojo/po/RMpEventDetailD.java b/data-processing/data-processing-api/src/main/java/com/njcn/dataProcess/pojo/po/RMpEventDetailD.java
new file mode 100644
index 0000000..454f796
--- /dev/null
+++ b/data-processing/data-processing-api/src/main/java/com/njcn/dataProcess/pojo/po/RMpEventDetailD.java
@@ -0,0 +1,47 @@
+package com.njcn.dataProcess.pojo.po;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.github.jeffreyning.mybatisplus.anno.MppMultiId;
+import lombok.Data;
+
+import java.time.LocalDate;
+
+/**
+ * @Description: 监测点暂态指标超标明细日表
+ * @Author: wr
+ * @Date: 2025/3/14 13:47
+ */
+@Data
+@TableName(value = "r_mp_event_detail_d")
+public class RMpEventDetailD {
+    /**
+     * 监测点ID
+     */
+    @MppMultiId(value = "measurement_point_id")
+    private String measurementPointId;
+
+    /**
+     * 时间
+     */
+    @MppMultiId(value = "data_date")
+    private LocalDate dataDate;
+
+    /**
+     * 电压暂升发生次数
+     */
+    @TableField(value = "swell_times")
+    private Integer swellTimes;
+
+    /**
+     * 电压暂降发生次数
+     */
+    @TableField(value = "sag_times")
+    private Integer sagTimes;
+
+    /**
+     * 短时中断发生次数
+     */
+    @TableField(value = "interrupt_times")
+    private Integer interruptTimes;
+}
diff --git a/data-processing/data-processing-api/src/main/java/com/njcn/dataProcess/pojo/po/RMpEventDetailM.java b/data-processing/data-processing-api/src/main/java/com/njcn/dataProcess/pojo/po/RMpEventDetailM.java
new file mode 100644
index 0000000..eee2cde
--- /dev/null
+++ b/data-processing/data-processing-api/src/main/java/com/njcn/dataProcess/pojo/po/RMpEventDetailM.java
@@ -0,0 +1,47 @@
+package com.njcn.dataProcess.pojo.po;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.github.jeffreyning.mybatisplus.anno.MppMultiId;
+import lombok.Data;
+
+import java.time.LocalDate;
+
+/**
+ * @Description: 监测点暂态指标超标明细月表
+ * @Author: wr
+ * @Date: 2025/3/14 13:47
+ */
+@Data
+@TableName(value = "r_mp_event_detail_m")
+public class RMpEventDetailM {
+    /**
+     * 监测点ID
+     */
+    @MppMultiId(value = "measurement_point_id")
+    private String measurementPointId;
+
+    /**
+     * 时间
+     */
+    @MppMultiId(value = "data_date")
+    private LocalDate dataDate;
+
+    /**
+     * 电压暂升发生次数
+     */
+    @TableField(value = "swell_times")
+    private Integer swellTimes;
+
+    /**
+     * 电压暂降发生次数
+     */
+    @TableField(value = "sag_times")
+    private Integer sagTimes;
+
+    /**
+     * 短时中断发生次数
+     */
+    @TableField(value = "interrupt_times")
+    private Integer interruptTimes;
+}
diff --git a/data-processing/data-processing-api/src/main/java/com/njcn/dataProcess/pojo/po/RMpEventDetailQ.java b/data-processing/data-processing-api/src/main/java/com/njcn/dataProcess/pojo/po/RMpEventDetailQ.java
new file mode 100644
index 0000000..2116d8c
--- /dev/null
+++ b/data-processing/data-processing-api/src/main/java/com/njcn/dataProcess/pojo/po/RMpEventDetailQ.java
@@ -0,0 +1,47 @@
+package com.njcn.dataProcess.pojo.po;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.github.jeffreyning.mybatisplus.anno.MppMultiId;
+import lombok.Data;
+
+import java.time.LocalDate;
+
+/**
+ * @Description: 监测点暂态指标超标明细季表
+ * @Author: wr
+ * @Date: 2025/3/14 13:47
+ */
+@Data
+@TableName(value = "r_mp_event_detail_q")
+public class RMpEventDetailQ {
+    /**
+     * 监测点ID
+     */
+    @MppMultiId(value = "measurement_point_id")
+    private String measurementPointId;
+
+    /**
+     * 时间
+     */
+    @MppMultiId(value = "data_date")
+    private LocalDate dataDate;
+
+    /**
+     * 电压暂升发生次数
+     */
+    @TableField(value = "swell_times")
+    private Integer swellTimes;
+
+    /**
+     * 电压暂降发生次数
+     */
+    @TableField(value = "sag_times")
+    private Integer sagTimes;
+
+    /**
+     * 短时中断发生次数
+     */
+    @TableField(value = "interrupt_times")
+    private Integer interruptTimes;
+}
diff --git a/data-processing/data-processing-api/src/main/java/com/njcn/dataProcess/pojo/po/RMpEventDetailY.java b/data-processing/data-processing-api/src/main/java/com/njcn/dataProcess/pojo/po/RMpEventDetailY.java
new file mode 100644
index 0000000..39c8472
--- /dev/null
+++ b/data-processing/data-processing-api/src/main/java/com/njcn/dataProcess/pojo/po/RMpEventDetailY.java
@@ -0,0 +1,47 @@
+package com.njcn.dataProcess.pojo.po;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.github.jeffreyning.mybatisplus.anno.MppMultiId;
+import lombok.Data;
+
+import java.time.LocalDate;
+
+/**
+ * @Description: 监测点暂态指标超标明细年表
+ * @Author: wr
+ * @Date: 2025/3/14 13:47
+ */
+@Data
+@TableName(value = "r_mp_event_detail_y")
+public class RMpEventDetailY {
+    /**
+     * 监测点ID
+     */
+    @MppMultiId(value = "measurement_point_id")
+    private String measurementPointId;
+
+    /**
+     * 时间
+     */
+    @MppMultiId(value = "data_date")
+    private LocalDate dataDate;
+
+    /**
+     * 电压暂升发生次数
+     */
+    @TableField(value = "swell_times")
+    private Integer swellTimes;
+
+    /**
+     * 电压暂降发生次数
+     */
+    @TableField(value = "sag_times")
+    private Integer sagTimes;
+
+    /**
+     * 短时中断发生次数
+     */
+    @TableField(value = "interrupt_times")
+    private Integer interruptTimes;
+}
diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/dao/relation/mapper/RMpEventDetailDMapper.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/dao/relation/mapper/RMpEventDetailDMapper.java
new file mode 100644
index 0000000..d868152
--- /dev/null
+++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/dao/relation/mapper/RMpEventDetailDMapper.java
@@ -0,0 +1,15 @@
+package com.njcn.dataProcess.dao.relation.mapper;
+
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import com.njcn.dataProcess.pojo.po.RMpEventDetailD;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * @Description:
+ * @Author: wr
+ * @Date: 2025/3/14 13:47
+ */
+@Mapper
+public interface RMpEventDetailDMapper extends MppBaseMapper<RMpEventDetailD> {
+
+}
\ No newline at end of file
diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/dao/relation/mapper/RMpEventDetailMMapper.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/dao/relation/mapper/RMpEventDetailMMapper.java
new file mode 100644
index 0000000..0cd3cf3
--- /dev/null
+++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/dao/relation/mapper/RMpEventDetailMMapper.java
@@ -0,0 +1,14 @@
+package com.njcn.dataProcess.dao.relation.mapper;
+
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import com.njcn.dataProcess.pojo.po.RMpEventDetailM;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * @Description:
+ * @Author: wr
+ * @Date: 2025/3/14 13:47
+ */
+@Mapper
+public interface RMpEventDetailMMapper extends MppBaseMapper<RMpEventDetailM> {
+}
\ No newline at end of file
diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/dao/relation/mapper/RMpEventDetailQMapper.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/dao/relation/mapper/RMpEventDetailQMapper.java
new file mode 100644
index 0000000..2006149
--- /dev/null
+++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/dao/relation/mapper/RMpEventDetailQMapper.java
@@ -0,0 +1,21 @@
+package com.njcn.dataProcess.dao.relation.mapper;
+
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import com.njcn.dataProcess.pojo.po.RMpEventDetailQ;
+import org.apache.ibatis.annotations.Mapper;
+
+
+/**
+ * @Description:
+ * @return: null
+ * @Author: wr
+ * @Date: 2025/3/14 13:48
+ */
+@Mapper
+public interface RMpEventDetailQMapper extends MppBaseMapper<RMpEventDetailQ> {
+
+
+
+
+
+}
diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/dao/relation/mapper/RMpEventDetailYMapper.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/dao/relation/mapper/RMpEventDetailYMapper.java
new file mode 100644
index 0000000..b0c460d
--- /dev/null
+++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/dao/relation/mapper/RMpEventDetailYMapper.java
@@ -0,0 +1,17 @@
+package com.njcn.dataProcess.dao.relation.mapper;
+
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import com.njcn.dataProcess.pojo.po.RMpEventDetailY;
+import org.apache.ibatis.annotations.Mapper;
+
+
+/**
+ * @Description:
+ * @Author: wr
+ * @Date: 2025/3/14 13:48
+ */
+@Mapper
+public interface RMpEventDetailYMapper extends MppBaseMapper<RMpEventDetailY> {
+
+
+}
diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/IRmpEventDetailDService.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/IRmpEventDetailDService.java
new file mode 100644
index 0000000..cba374a
--- /dev/null
+++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/IRmpEventDetailDService.java
@@ -0,0 +1,25 @@
+package com.njcn.dataProcess.service;
+
+
+import com.github.jeffreyning.mybatisplus.service.IMppService;
+import com.njcn.dataProcess.pojo.dto.DataEventDetailDto;
+import com.njcn.dataProcess.pojo.po.RMpEventDetailD;
+
+import java.util.List;
+
+/**
+ * @Description:
+ * @Author: wr
+ * @Date: 2025/3/14 13:49
+ */
+public interface IRmpEventDetailDService extends IMppService<RMpEventDetailD> {
+
+    /**
+     * 批量插入数据
+     * @param eventDetailDto
+     * @Author: wr
+     * @Date: 2025/3/14 14:03
+     */
+    void batchInsertion(List<DataEventDetailDto> eventDetailDto);
+
+}
diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/IRmpEventDetailMService.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/IRmpEventDetailMService.java
new file mode 100644
index 0000000..5b816b1
--- /dev/null
+++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/IRmpEventDetailMService.java
@@ -0,0 +1,24 @@
+package com.njcn.dataProcess.service;
+
+
+import com.github.jeffreyning.mybatisplus.service.IMppService;
+import com.njcn.dataProcess.pojo.dto.DataEventDetailDto;
+import com.njcn.dataProcess.pojo.po.RMpEventDetailM;
+
+import java.util.List;
+
+/**
+ * @Description:
+ * @Author: wr
+ * @Date: 2025/3/14 13:49
+ */
+public interface IRmpEventDetailMService extends IMppService<RMpEventDetailM> {
+    /**
+     * 批量插入数据
+     * @param eventDetailDto
+     * @Author: wr
+     * @Date: 2025/3/14 14:03
+     */
+    void batchInsertion(List<DataEventDetailDto> eventDetailDto);
+
+}
diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/IRmpEventDetailQService.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/IRmpEventDetailQService.java
new file mode 100644
index 0000000..7a6ec75
--- /dev/null
+++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/IRmpEventDetailQService.java
@@ -0,0 +1,24 @@
+package com.njcn.dataProcess.service;
+
+
+import com.github.jeffreyning.mybatisplus.service.IMppService;
+import com.njcn.dataProcess.pojo.dto.DataEventDetailDto;
+import com.njcn.dataProcess.pojo.po.RMpEventDetailQ;
+
+import java.util.List;
+
+/**
+ * @Description:
+ * @Author: wr
+ * @Date: 2025/3/14 13:49
+ */
+public interface IRmpEventDetailQService extends IMppService<RMpEventDetailQ> {
+    /**
+     * 批量插入数据
+     * @param eventDetailDto
+     * @Author: wr
+     * @Date: 2025/3/14 14:03
+     */
+    void batchInsertion(List<DataEventDetailDto> eventDetailDto);
+
+}
diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/IRmpEventDetailYService.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/IRmpEventDetailYService.java
new file mode 100644
index 0000000..576eef7
--- /dev/null
+++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/IRmpEventDetailYService.java
@@ -0,0 +1,24 @@
+package com.njcn.dataProcess.service;
+
+
+import com.github.jeffreyning.mybatisplus.service.IMppService;
+import com.njcn.dataProcess.pojo.dto.DataEventDetailDto;
+import com.njcn.dataProcess.pojo.po.RMpEventDetailY;
+
+import java.util.List;
+
+/**
+ * @Description:
+ * @Author: wr
+ * @Date: 2025/3/14 13:49
+ */
+public interface IRmpEventDetailYService extends IMppService<RMpEventDetailY> {
+
+    /**
+     * 批量插入数据
+     * @param eventDetailDto
+     * @Author: wr
+     * @Date: 2025/3/14 14:03
+     */
+    void batchInsertion(List<DataEventDetailDto> eventDetailDto);
+}
diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbRmpEventDetailDImpl.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbRmpEventDetailDImpl.java
new file mode 100644
index 0000000..51b3fc9
--- /dev/null
+++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbRmpEventDetailDImpl.java
@@ -0,0 +1,27 @@
+package com.njcn.dataProcess.service.impl.influxdb;
+
+import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
+import com.njcn.dataProcess.dao.relation.mapper.RMpEventDetailDMapper;
+import com.njcn.dataProcess.pojo.dto.DataEventDetailDto;
+import com.njcn.dataProcess.pojo.po.RMpEventDetailD;
+import com.njcn.dataProcess.service.IRmpEventDetailDService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * @Description:
+ * @Author: wr
+ * @Date: 2025/3/14 13:54
+ */
+@Service("InfluxdbRmpEventDetailDImpl")
+@RequiredArgsConstructor
+public class InfluxdbRmpEventDetailDImpl extends MppServiceImpl<RMpEventDetailDMapper, RMpEventDetailD> implements IRmpEventDetailDService {
+
+
+    @Override
+    public void batchInsertion(List<DataEventDetailDto> eventDetailDto) {
+
+    }
+}
diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbRmpEventDetailMImpl.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbRmpEventDetailMImpl.java
new file mode 100644
index 0000000..aa198cf
--- /dev/null
+++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbRmpEventDetailMImpl.java
@@ -0,0 +1,27 @@
+package com.njcn.dataProcess.service.impl.influxdb;
+
+import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
+import com.njcn.dataProcess.dao.relation.mapper.RMpEventDetailMMapper;
+import com.njcn.dataProcess.pojo.dto.DataEventDetailDto;
+import com.njcn.dataProcess.pojo.po.RMpEventDetailM;
+import com.njcn.dataProcess.service.IRmpEventDetailMService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * @Description:
+ * @Author: wr
+ * @Date: 2025/3/14 13:54
+ */
+@Service("InfluxdbRmpEventDetailDImpl")
+@RequiredArgsConstructor
+public class InfluxdbRmpEventDetailMImpl extends MppServiceImpl<RMpEventDetailMMapper, RMpEventDetailM> implements IRmpEventDetailMService {
+
+
+    @Override
+    public void batchInsertion(List<DataEventDetailDto> eventDetailDto) {
+
+    }
+}
diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbRmpEventDetailQImpl.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbRmpEventDetailQImpl.java
new file mode 100644
index 0000000..7f468dc
--- /dev/null
+++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbRmpEventDetailQImpl.java
@@ -0,0 +1,27 @@
+package com.njcn.dataProcess.service.impl.influxdb;
+
+import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
+import com.njcn.dataProcess.dao.relation.mapper.RMpEventDetailQMapper;
+import com.njcn.dataProcess.pojo.dto.DataEventDetailDto;
+import com.njcn.dataProcess.pojo.po.RMpEventDetailQ;
+import com.njcn.dataProcess.service.IRmpEventDetailQService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * @Description:
+ * @Author: wr
+ * @Date: 2025/3/14 13:54
+ */
+@Service("InfluxdbRmpEventDetailQImpl")
+@RequiredArgsConstructor
+public class InfluxdbRmpEventDetailQImpl extends MppServiceImpl<RMpEventDetailQMapper, RMpEventDetailQ> implements IRmpEventDetailQService {
+
+
+    @Override
+    public void batchInsertion(List<DataEventDetailDto> eventDetailDto) {
+
+    }
+}
diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbRmpEventDetailYImpl.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbRmpEventDetailYImpl.java
new file mode 100644
index 0000000..4b8b066
--- /dev/null
+++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbRmpEventDetailYImpl.java
@@ -0,0 +1,27 @@
+package com.njcn.dataProcess.service.impl.influxdb;
+
+import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
+import com.njcn.dataProcess.dao.relation.mapper.RMpEventDetailYMapper;
+import com.njcn.dataProcess.pojo.dto.DataEventDetailDto;
+import com.njcn.dataProcess.pojo.po.RMpEventDetailY;
+import com.njcn.dataProcess.service.IRmpEventDetailYService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * @Description:
+ * @Author: wr
+ * @Date: 2025/3/14 13:54
+ */
+@Service("InfluxdbRmpEventDetailYImpl")
+@RequiredArgsConstructor
+public class InfluxdbRmpEventDetailYImpl extends MppServiceImpl<RMpEventDetailYMapper, RMpEventDetailY> implements IRmpEventDetailYService {
+
+
+    @Override
+    public void batchInsertion(List<DataEventDetailDto> eventDetailDto) {
+
+    }
+}
diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/relation/RelationRmpEventDetailDImpl.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/relation/RelationRmpEventDetailDImpl.java
new file mode 100644
index 0000000..459becc
--- /dev/null
+++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/relation/RelationRmpEventDetailDImpl.java
@@ -0,0 +1,35 @@
+package com.njcn.dataProcess.service.impl.relation;
+
+import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
+import com.njcn.dataProcess.dao.relation.mapper.RMpEventDetailDMapper;
+import com.njcn.dataProcess.pojo.dto.DataEventDetailDto;
+import com.njcn.dataProcess.pojo.po.RMpEventDetailD;
+import com.njcn.dataProcess.service.IRmpEventDetailDService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.beans.BeanUtils;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @Description:
+ * @Author: wr
+ * @Date: 2025/3/14 13:54
+ */
+@Service("RelationRmpEventDetailDImpl")
+@RequiredArgsConstructor
+public class RelationRmpEventDetailDImpl extends MppServiceImpl<RMpEventDetailDMapper, RMpEventDetailD> implements IRmpEventDetailDService {
+
+
+    @Override
+    public void batchInsertion(List<DataEventDetailDto> eventDetailDto) {
+        List<RMpEventDetailD> result = new ArrayList<>();
+        eventDetailDto.forEach(item->{
+            RMpEventDetailD limitRate = new RMpEventDetailD();
+            BeanUtils.copyProperties(item, limitRate);
+            result.add(limitRate);
+        });
+        this.saveOrUpdateBatchByMultiId(result);
+    }
+}
diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/relation/RelationRmpEventDetailMImpl.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/relation/RelationRmpEventDetailMImpl.java
new file mode 100644
index 0000000..b989caf
--- /dev/null
+++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/relation/RelationRmpEventDetailMImpl.java
@@ -0,0 +1,35 @@
+package com.njcn.dataProcess.service.impl.relation;
+
+import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
+import com.njcn.dataProcess.dao.relation.mapper.RMpEventDetailMMapper;
+import com.njcn.dataProcess.pojo.dto.DataEventDetailDto;
+import com.njcn.dataProcess.pojo.po.RMpEventDetailM;
+import com.njcn.dataProcess.service.IRmpEventDetailMService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.beans.BeanUtils;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @Description:
+ * @Author: wr
+ * @Date: 2025/3/14 13:54
+ */
+@Service("RelationRmpEventDetailMImpl")
+@RequiredArgsConstructor
+public class RelationRmpEventDetailMImpl extends MppServiceImpl<RMpEventDetailMMapper, RMpEventDetailM> implements IRmpEventDetailMService {
+
+
+    @Override
+    public void batchInsertion(List<DataEventDetailDto> eventDetailDto) {
+        List<RMpEventDetailM> result = new ArrayList<>();
+        eventDetailDto.forEach(item->{
+            RMpEventDetailM limitRate = new RMpEventDetailM();
+            BeanUtils.copyProperties(item, limitRate);
+            result.add(limitRate);
+        });
+        this.saveOrUpdateBatchByMultiId(result);
+    }
+}
diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/relation/RelationRmpEventDetailQImpl.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/relation/RelationRmpEventDetailQImpl.java
new file mode 100644
index 0000000..629fa7b
--- /dev/null
+++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/relation/RelationRmpEventDetailQImpl.java
@@ -0,0 +1,35 @@
+package com.njcn.dataProcess.service.impl.relation;
+
+import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
+import com.njcn.dataProcess.dao.relation.mapper.RMpEventDetailQMapper;
+import com.njcn.dataProcess.pojo.dto.DataEventDetailDto;
+import com.njcn.dataProcess.pojo.po.RMpEventDetailQ;
+import com.njcn.dataProcess.service.IRmpEventDetailQService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.beans.BeanUtils;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @Description:
+ * @Author: wr
+ * @Date: 2025/3/14 13:54
+ */
+@Service("RelationRmpEventDetailQImpl")
+@RequiredArgsConstructor
+public class RelationRmpEventDetailQImpl extends MppServiceImpl<RMpEventDetailQMapper, RMpEventDetailQ> implements IRmpEventDetailQService {
+
+
+    @Override
+    public void batchInsertion(List<DataEventDetailDto> eventDetailDto) {
+        List<RMpEventDetailQ> result = new ArrayList<>();
+        eventDetailDto.forEach(item->{
+            RMpEventDetailQ limitRate = new RMpEventDetailQ();
+            BeanUtils.copyProperties(item, limitRate);
+            result.add(limitRate);
+        });
+        this.saveOrUpdateBatchByMultiId(result);
+    }
+}
diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/relation/RelationRmpEventDetailYImpl.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/relation/RelationRmpEventDetailYImpl.java
new file mode 100644
index 0000000..7701ec0
--- /dev/null
+++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/relation/RelationRmpEventDetailYImpl.java
@@ -0,0 +1,35 @@
+package com.njcn.dataProcess.service.impl.relation;
+
+import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
+import com.njcn.dataProcess.dao.relation.mapper.RMpEventDetailYMapper;
+import com.njcn.dataProcess.pojo.dto.DataEventDetailDto;
+import com.njcn.dataProcess.pojo.po.RMpEventDetailY;
+import com.njcn.dataProcess.service.IRmpEventDetailYService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.beans.BeanUtils;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @Description:
+ * @Author: wr
+ * @Date: 2025/3/14 13:54
+ */
+@Service("RelationRmpEventDetailYImpl")
+@RequiredArgsConstructor
+public class RelationRmpEventDetailYImpl extends MppServiceImpl<RMpEventDetailYMapper, RMpEventDetailY> implements IRmpEventDetailYService {
+
+
+    @Override
+    public void batchInsertion(List<DataEventDetailDto> eventDetailDto) {
+        List<RMpEventDetailY> result = new ArrayList<>();
+        eventDetailDto.forEach(item->{
+            RMpEventDetailY limitRate = new RMpEventDetailY();
+            BeanUtils.copyProperties(item, limitRate);
+            result.add(limitRate);
+        });
+        this.saveOrUpdateBatchByMultiId(result);
+    }
+}