From 913d47be5fa05c33a958a00b9a85126d817e3f06 Mon Sep 17 00:00:00 2001 From: fuliqi <fuliqi@qq.com> Date: 星期四, 31 十月 2024 15:09:48 +0800 Subject: [PATCH] 首页点位在线折线bug --- ycl-server/src/main/java/com/ycl/platform/service/impl/WorkOrderServiceImpl.java | 34 ++++++++++++++++++++++++++++++---- 1 files changed, 30 insertions(+), 4 deletions(-) diff --git a/ycl-server/src/main/java/com/ycl/platform/service/impl/WorkOrderServiceImpl.java b/ycl-server/src/main/java/com/ycl/platform/service/impl/WorkOrderServiceImpl.java index 8585b6e..ae1a348 100644 --- a/ycl-server/src/main/java/com/ycl/platform/service/impl/WorkOrderServiceImpl.java +++ b/ycl-server/src/main/java/com/ycl/platform/service/impl/WorkOrderServiceImpl.java @@ -14,6 +14,7 @@ import com.ycl.config.ServerConfig; import com.ycl.exception.ServiceException; import com.ycl.platform.domain.entity.*; +import com.ycl.platform.domain.excel.PointExport; import com.ycl.platform.domain.form.*; import com.ycl.platform.domain.query.*; import com.ycl.platform.domain.vo.*; @@ -113,11 +114,11 @@ // 鏌ヨ鍑虹櫧鍚嶅崟鍒楄〃 List<String> serialNumbers = workOrderWhiteMapper.selectList().stream().map(WorkOrderWhite::getSerialNumber).collect(Collectors.toList()); // 閬嶅巻宸ュ崟鍒楄〃锛屽垽鏂槸鍚﹀湪鐧藉悕鍗曚腑 - workOrderList.stream().filter(item -> !serialNumbers.contains(item.getSerialNumber())) + workOrderList = workOrderList.stream().filter(item -> !serialNumbers.contains(item.getSerialNumber())) .collect(Collectors.toList()); - workOrderList.stream().filter(item -> { + workOrderList = workOrderList.stream().filter(item -> { return StringUtils.hasText(item.getSerialNumber()) && Objects.nonNull(item.getStatus()) && !CollectionUtils.isEmpty(item.getErrorTypeList()); - }); + }).collect(Collectors.toList()); if (CollectionUtils.isEmpty(workOrderList)) { return Boolean.TRUE; } @@ -169,7 +170,10 @@ willAddErrorType.add(workOrderErrorType); } } - databaseWorkOrder.setStatus(WorkOrderStatusEnum.DISTRIBUTED); + //閬垮厤浠d笅鍙戠殑宸ュ崟鐩存帴鍙樻垚涓嬪彂 + if(!databaseWorkOrder.getStatus().equals(WorkOrderStatusEnum.WAIT_DISTRIBUTE)) { + databaseWorkOrder.setStatus(WorkOrderStatusEnum.DISTRIBUTED); + } databaseWorkOrder.setUpdateTime(now); willUpdateStatusWorkOrderList.add(databaseWorkOrder); updateNum++; @@ -1053,4 +1057,26 @@ workOrderWhiteMapper.batchDelete(ids); return Result.ok(); } + + /** + * 鎵归噺瀵煎叆鐧藉悕鍗� + * + * @param dataList 鏁版嵁鍒楄〃 + * @author + */ + @Override + public void batchImportWhite(List<PointExport> dataList) { + // 鑾峰緱鎵�鏈夐渶瑕佹柊澧炵殑鐧藉悕鍗曞璞� + List<WorkOrderWhite> whitelist = dataList.stream().map(pointExport -> + new WorkOrderWhite(pointExport.getSerialNumber(), pointExport.getPointName(), SecurityUtils.getUsername())) + .collect(Collectors.toList()); + // 鑾峰緱鎵�鏈夊凡瀛樺湪鐨勭櫧鍚嶅崟璁惧缂栫爜 + List<String> serialNumbers = workOrderWhiteMapper.selectList().stream().map(WorkOrderWhite::getSerialNumber).collect(Collectors.toList()); + // 绛涢�夊嚭鏂板銆佷慨鏀圭殑鐧藉悕鍗曞璞� + List<WorkOrderWhite> updateWhiteList = whitelist.stream().filter(white -> serialNumbers.contains(white.getSerialNumber())).collect(Collectors.toList()); + List<WorkOrderWhite> insertWhiteList = whitelist.stream().filter(white ->!serialNumbers.contains(white.getSerialNumber())).collect(Collectors.toList()); + // 鏂板/淇敼鐧藉悕鍗曡澶囪褰� + updateWhiteList.stream().forEach(white -> workOrderWhiteMapper.updateBySerialNumber(white)); + insertWhiteList.stream().forEach(white -> workOrderWhiteMapper.insert(white)); + } } -- Gitblit v1.8.0