Middleware/cn-data-platform
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

暂态算法

Browse Source
This commit is contained in:
wr
2025-03-14 16:36:59 +08:00
parent 7b986006dd
commit e4c269e3d6
25 changed files with 696 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/service/line/IDayDataService.java
View File

@@ -119,4 +119,6 @@ public interface IDayDataService {
* @param calculatedParam 查询条件
*/
void dataPltHandler(CalculatedParam calculatedParam);
}

9
algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/IDataIntegrityServiceImpl.java
View File

@@ -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(

6
algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/IDataOnlineRateServiceImpl.java
View File

@@ -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()));

42
algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/IEventDetailServiceImpl.java Normal file
View File

@@ -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) {
}
}

38
data-processing/data-processing-api/src/main/java/com/njcn/dataProcess/pojo/dto/DataEventDetailDto.java Normal file
View File

@@ -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;
}

47
data-processing/data-processing-api/src/main/java/com/njcn/dataProcess/pojo/po/RMpEventDetailD.java Normal file
View File

@@ -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;
}

47
data-processing/data-processing-api/src/main/java/com/njcn/dataProcess/pojo/po/RMpEventDetailM.java Normal file
View File

@@ -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;
}

47
data-processing/data-processing-api/src/main/java/com/njcn/dataProcess/pojo/po/RMpEventDetailQ.java Normal file
View File

@@ -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;
}

47
data-processing/data-processing-api/src/main/java/com/njcn/dataProcess/pojo/po/RMpEventDetailY.java Normal file
View File

@@ -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;
}

15
data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/dao/relation/mapper/RMpEventDetailDMapper.java Normal file
View File

@@ -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> {
}

14
data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/dao/relation/mapper/RMpEventDetailMMapper.java Normal file
View File

@@ -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> {
}

21
data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/dao/relation/mapper/RMpEventDetailQMapper.java Normal file
View File

@@ -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> {
}

17
data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/dao/relation/mapper/RMpEventDetailYMapper.java Normal file
View File

@@ -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> {
}

25
data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/IRmpEventDetailDService.java Normal file
View File

@@ -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);
}

24
data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/IRmpEventDetailMService.java Normal file
View File

@@ -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);
}

24
data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/IRmpEventDetailQService.java Normal file
View File

@@ -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);
}

24
data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/IRmpEventDetailYService.java Normal file
View File

@@ -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);
}

27
data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbRmpEventDetailDImpl.java Normal file
View File

@@ -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) {
}
}

27
data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbRmpEventDetailMImpl.java Normal file
View File

@@ -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) {
}
}

27
data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbRmpEventDetailQImpl.java Normal file
View File

@@ -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) {
}
}

27
data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbRmpEventDetailYImpl.java Normal file
View File

@@ -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) {
}
}

35
data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/relation/RelationRmpEventDetailDImpl.java Normal file
View File

@@ -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);
}
}

35
data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/relation/RelationRmpEventDetailMImpl.java Normal file
View File

@@ -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);
}
}

35
data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/relation/RelationRmpEventDetailQImpl.java Normal file
View File

@@ -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);
}
}

35
data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/relation/RelationRmpEventDetailYImpl.java Normal file
View File

@@ -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);
}
}