Browse Source

Merge branch 'dev' into pre-production

master
zhaoqiaobo 7 months ago
parent
commit
84555145ed
  1. 9
      blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionDeliveryListServiceImpl.java
  2. 2
      blade-service/logpm-report/src/main/java/com/logpm/report/reader/DeliveryDetailReader.java
  3. 3
      blade-service/logpm-report/src/main/java/com/logpm/report/util/ReportExcelUtil.java

9
blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionDeliveryListServiceImpl.java

@ -6433,17 +6433,18 @@ public class DistributionDeliveryListServiceImpl extends BaseServiceImpl<Distrib
DistributionLoadscanEntity loadscanEntity = distributionLoadscanService.getOne(Wrappers.<DistributionLoadscanEntity>query().lambda().eq(DistributionLoadscanEntity::getDeliveryId, deliveryId).eq(DistributionLoadscanEntity::getReservationId, reservationId) DistributionLoadscanEntity loadscanEntity = distributionLoadscanService.getOne(Wrappers.<DistributionLoadscanEntity>query().lambda().eq(DistributionLoadscanEntity::getDeliveryId, deliveryId).eq(DistributionLoadscanEntity::getReservationId, reservationId)
.eq(DistributionLoadscanEntity::getPackageId, orderPackageId) .eq(DistributionLoadscanEntity::getPackageId, orderPackageId)
.ne(DistributionLoadscanEntity::getScanStatus, LoadingStatusConstant.quxiao.getValue())); .ne(DistributionLoadscanEntity::getScanStatus, LoadingStatusConstant.quxiao.getValue()));
log.info("滞留取消任务条数", row); log.info("滞留取消任务条数:{}", row);
if (row == 1) { if (row == 1) {
//存在计划 //存在计划
//进行了一条包件任务的取消,此时就应该对预约、配送任务进行数量的维护 //进行了一条包件任务的取消,此时就应该对预约、配送任务进行数量的维护
distributionAsyncService.checkRetentionReservationAndDeliveryInfo(reservationId, deliveryId); distributionAsyncService.checkRetentionReservationAndDeliveryInfo(reservationId, deliveryId);
} else { }
//包件未预约 处于异常驳回状态 //包件未预约 处于异常驳回状态
//查询异常信息,对异常信息进行清理 //查询异常信息,对异常信息进行清理
log.info("滞留查询审核列表信息", row); log.info("滞留查询审核列表信息:{}", row);
DistributionLoadscanAbnormalEntity abnormalEntity = distributionLoadscanAbnormalService.getOne(Wrappers.<DistributionLoadscanAbnormalEntity>query().lambda() DistributionLoadscanAbnormalEntity abnormalEntity = distributionLoadscanAbnormalService.getOne(Wrappers.<DistributionLoadscanAbnormalEntity>query().lambda()
.eq(DistributionLoadscanAbnormalEntity::getPackageId, orderPackageId) .eq(DistributionLoadscanAbnormalEntity::getPackageId, orderPackageId)
@ -6458,7 +6459,7 @@ public class DistributionDeliveryListServiceImpl extends BaseServiceImpl<Distrib
log.error(">>>>>>>>>>>>>>>查询异常信息错误:{}",orderPackageId); log.error(">>>>>>>>>>>>>>>查询异常信息错误:{}",orderPackageId);
} }
//查询出多个包件信息 //查询出多个包件信息
}
if (Func.isNotEmpty(loadscanEntity)) { if (Func.isNotEmpty(loadscanEntity)) {
//修改包件状态 达到回库的状态 //修改包件状态 达到回库的状态
DistributionParcelListEntity parcelListEntity = distributionParcelListService.getById(loadscanEntity.getPackageId()); DistributionParcelListEntity parcelListEntity = distributionParcelListService.getById(loadscanEntity.getPackageId());

2
blade-service/logpm-report/src/main/java/com/logpm/report/reader/DeliveryDetailReader.java

@ -38,7 +38,7 @@ public class DeliveryDetailReader implements ExportReader {
@Override @Override
public List<T> findList(Page page, Wrapper query) { public List<T> findList(Page page, Wrapper query) {
return asyncService.getdetailPages(page, query, Convert.toInt(page.getCurrent()), Convert.toInt(page.getTotal())); return asyncService.getdetailPages(page, query, Convert.toInt(page.getCurrent()), Convert.toInt(page.getSize()));
} }
} }

3
blade-service/logpm-report/src/main/java/com/logpm/report/util/ReportExcelUtil.java

@ -116,8 +116,6 @@ public class ReportExcelUtil {
int findNum = (int) Math.ceil((count / pageSize.doubleValue())); int findNum = (int) Math.ceil((count / pageSize.doubleValue()));
// 封装查询后需要导出的数据 // 封装查询后需要导出的数据
Map<Integer, List<Object>> pageMap = new ConcurrentHashMap<>(ReportConstants.HASHMAP_DEFAULT_SIZE); Map<Integer, List<Object>> pageMap = new ConcurrentHashMap<>(ReportConstants.HASHMAP_DEFAULT_SIZE);
// 定义线程池,大表导出使用一个线程池
ExecutorService executorService = ThreadPoolUtil.getThreadPool();
// 控制线程全部查询完后执行导出操作 // 控制线程全部查询完后执行导出操作
CountDownLatch countDownLatch = new CountDownLatch(findNum); CountDownLatch countDownLatch = new CountDownLatch(findNum);
ExcelWriter excelWriter = null; ExcelWriter excelWriter = null;
@ -128,7 +126,6 @@ public class ReportExcelUtil {
e.printStackTrace(); e.printStackTrace();
} }
int num = 0; int num = 0;
List<CompletableFuture<List>> futures = new ArrayList<>();
for (int i = 0; i < sheetNum; i++) { for (int i = 0; i < sheetNum; i++) {
// sheet编号 // sheet编号
int finalI = i + 1; int finalI = i + 1;

Loading…
Cancel
Save