Microservice/pqs
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

河北超高压算法测试

Browse Source
This commit is contained in:
xuyang
2024-01-19 13:27:56 +08:00
parent cd12aeb57a
commit b68898b224
2 changed files with 15 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/DayDataServiceImpl.java
View File

@@ -594,6 +594,7 @@ public class DayDataServiceImpl implements DayDataService {
@Override
@Transactional(rollbackFor = {Exception.class})
@Deprecated
public void dataToDayHandler(CalculatedParam calculatedParam) {
log.info(LocalDateTime.now() + "data表转day开始=====》");
//influxdb实体
@@ -646,7 +647,7 @@ public class DayDataServiceImpl implements DayDataService {
List<String> lineIds = calculatedParam.getIdList();
//河北数据量较大，以尺寸20分片
List<List<String>> pendingIds = ListUtils.partition(lineIds,1);
List<List<String>> pendingIds = ListUtils.partition(lineIds,5);
String beginDay =LocalDateTimeUtil.format(LocalDateTimeUtil.beginOfDay(LocalDateTimeUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_PATTERN)),DatePattern.NORM_DATETIME_PATTERN);
String endDay = LocalDateTimeUtil.format(LocalDateTimeUtil.endOfDay(LocalDateTimeUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_PATTERN)),DatePattern.NORM_DATETIME_PATTERN);
for (List<String> pendingId : pendingIds) {

7
pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/LimitRateServiceImpl.java
View File

@@ -82,7 +82,7 @@ public class LimitRateServiceImpl extends MppServiceImpl<LimitRatePOMapper, Limi
List<Overlimit> overLimitList = commTerminalGeneralClient.getAllLineOverLimit().getData();
Map<String,List<Overlimit>> overLimitMap = overLimitList.stream().collect(Collectors.groupingBy(Overlimit::getId));
//以尺寸100分片,查询数据
List<List<String>> pendingIds = ListUtils.partition(lineIds,20);
List<List<String>> pendingIds = ListUtils.partition(lineIds,1);
for (List<String> pendingId : pendingIds) {
list1.addAll(getAllTime(pendingId, startTime, endTime));
list2.addAll(getFlickerAllTime(pendingId, startTime, endTime));
@@ -108,7 +108,9 @@ public class LimitRateServiceImpl extends MppServiceImpl<LimitRatePOMapper, Limi
Map<String,List<DataV>> map9 = list9.stream().collect(Collectors.groupingBy(DataV::getLineId));
Map<String,List<DataV>> map10 = list10.stream().collect(Collectors.groupingBy(DataV::getLineId));
Map<String,List<DataPlt>> map11 = list11.stream().collect(Collectors.groupingBy(DataPlt::getLineId));
for (String item : lineIds) {
for (List<String> pendingId : pendingIds) {
for (String item : pendingId) {
List<LimitRate> result = getData(overLimitMap.get(item).get(0), map1.get(item), map2.get(item), map3.get(item), map4.get(item), map5.get(item), map6.get(item), map7.get(item), map8.get(item), map9.get(item), map10.get(item), map11.get(item));
List<RStatLimitRateDPO> collect = result.stream().map(t -> {
RStatLimitRateDPO po = new RStatLimitRateDPO();
@@ -118,6 +120,7 @@ public class LimitRateServiceImpl extends MppServiceImpl<LimitRatePOMapper, Limi
}).collect(Collectors.toList());
list.addAll(collect);
}
}
if (!CollectionUtils.isEmpty(list)){
/*插入mysql*/
statLimitRateDService.saveOrUpdateBatchByMultiId(list,1000);