| | |
|---|
| | | 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)) { |
|---|
