|  |  |  | 
|---|
|  |  |  | throw new CoolException("数据错误: 波次不存在!!"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | for (Wave wave : waves) { | 
|---|
|  |  |  | if (wave.getExceStatus() >= WaveExceStatus.WAVE_EXCE_STATUS_EXCING.val) { | 
|---|
|  |  |  | if (wave.getExceStatus() > WaveExceStatus.WAVE_EXCE_STATUS_EXCING.val) { | 
|---|
|  |  |  | throw new CoolException("当前状态无法下发执行!!"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | .set(Wave::getExceStatus, WaveExceStatus.WAVE_EXCE_STATUS_TASK.val) | 
|---|
|  |  |  | .set(Wave::getWorkQty, taskItems.stream().mapToDouble(TaskItem::getAnfme).sum()) | 
|---|
|  |  |  | .set(Wave::getUpdateBy, loginUserId) | 
|---|
|  |  |  | .set(Wave::getMemo, null) | 
|---|
|  |  |  | .set(Wave::getUpdateTime, new Date()) | 
|---|
|  |  |  | .eq(Wave::getId, wave.getId()))) { | 
|---|
|  |  |  | throw new CoolException("波次状态修改失败!!"); | 
|---|
|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | List<Long> orderIds = orderRelas.stream().map(WaveOrderRela::getOrderItemId).collect(Collectors.toList()); | 
|---|
|  |  |  | List<AsnOrderItem> orderItems = asnOrderItemService.list(new LambdaQueryWrapper<AsnOrderItem>().in(AsnOrderItem::getId, orderIds)); | 
|---|
|  |  |  | List<WkOrderItem> orderItems = asnOrderItemService.list(new LambdaQueryWrapper<WkOrderItem>().in(WkOrderItem::getId, orderIds)); | 
|---|
|  |  |  | orderItems.forEach(asnOrderItem -> { | 
|---|
|  |  |  | asnOrderItem.setWorkQty(0.0); | 
|---|
|  |  |  | if (!asnOrderItemService.updateById(asnOrderItem)) { | 
|---|
|  |  |  | 
|---|
|  |  |  | continue; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | taskParams.setItems(Arrays.asList(itemDto.getLocItem())) | 
|---|
|  |  |  | .setSiteNo(itemDto.getSiteNo()) | 
|---|
|  |  |  | .setSiteNo(itemDto.getSitesNo()) | 
|---|
|  |  |  | .setType(Constants.TASK_TYPE_WAVE_OUT_STOCK) | 
|---|
|  |  |  | .setSourceId(wave.getId()) | 
|---|
|  |  |  | .setTarLoc(loc.getCode()); | 
|---|