From 5ec61cdaa2c1ab4dd1d58bd94afb49343332e78f Mon Sep 17 00:00:00 2001 From: ZengTao <2773468879@qq.com> Date: 星期五, 07 三月 2025 16:56:35 +0800 Subject: [PATCH] 添加中空大理片汇总数据显示,推送服务器时间供前端使用 --- hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/bigstorage/service/impl/BigStorageCageDetailsServiceImpl.java | 12 +++++++++--- 1 files changed, 9 insertions(+), 3 deletions(-) diff --git a/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/bigstorage/service/impl/BigStorageCageDetailsServiceImpl.java b/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/bigstorage/service/impl/BigStorageCageDetailsServiceImpl.java index 12f6eef..ae517cd 100644 --- a/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/bigstorage/service/impl/BigStorageCageDetailsServiceImpl.java +++ b/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/bigstorage/service/impl/BigStorageCageDetailsServiceImpl.java @@ -6,6 +6,7 @@ import com.github.yulichang.base.MPJBaseServiceImpl; import com.github.yulichang.toolkit.JoinWrappers; import com.github.yulichang.wrapper.MPJLambdaWrapper; +import com.google.common.collect.Lists; import com.mes.base.entity.vo.BigStorageVO; import com.mes.bigstorage.entity.BigStorageCage; import com.mes.bigstorage.entity.BigStorageCageDetails; @@ -450,8 +451,9 @@ } @Override - public List<BigStorageVO> querybigStorageCageDetail() { - return baseMapper.querybigStorageCageDetail(); + public Map<Integer, List<BigStorageVO>> querybigStorageCageDetail() { + List<BigStorageVO> bigStorageCages= baseMapper.querybigStorageCageDetail(); + return bigStorageCages.stream().collect(Collectors.groupingBy(item -> item.getDeviceId())); } @Override @@ -480,7 +482,11 @@ .orderByAsc(BigStorageCageDetails::getTemperingFeedSequence) ); if (CollectionUtils.isNotEmpty(temperingGlassInfos)) { - temperingGlassInfoService.saveBatch(temperingGlassInfos); + //閬垮厤澶ч噺鏁版嵁鎻掑叆瀵艰嚧sqlserver鏁版嵁搴撳紓甯革紝鍒嗘壒娆℃瘡璋冨瓨鍌ㄤ緷娆� + List<List<TemperingGlassInfo>> temperingGlassInfoLists = Lists.partition(temperingGlassInfos, 50); + for (List<TemperingGlassInfo> item : temperingGlassInfoLists) { + temperingGlassInfoService.saveBatch(item); + } return true; } } -- Gitblit v1.8.0