| | |
|---|
| | | params.add(locParams); |
|---|
| | | } |
|---|
| | | List<OrderOutItemDto> results = LocManageUtil.getOutOrderList(params, null); |
|---|
| | | /**生成波次任务**/ |
|---|
| | | generateOutTask(results, loginUserId, waves); |
|---|
| | | } catch (Exception e) { |
|---|
| | | log.error(e.getMessage()); |
|---|
| | |
|---|
| | | 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()); |
|---|
| | | |
|---|
| | | //TODO 生成出库任务，获取波次单据信息 |
|---|
| | | locItemService.generateTask(TaskResouceType.TASK_RESOUCE_WAVE_TYPE.val, taskParams, loginUserId); |
|---|
| | | } |
|---|
| | | } |
|---|
| | |
|---|
| | | .select("id", "loc_id", "loc_code", "order_id", "SUM(anfme) anfme", "SUM(qty) qty", "SUM(work_qty) work_qty", "splr_batch", "fields_index", "matnr_code") |
|---|
| | | .lambda() |
|---|
| | | .eq(LocItem::getMatnrCode, waveItem.getMatnrCode()) |
|---|
| | | .eq(LocItem::getSplrBatch, waveItem.getSplrBatch()) |
|---|
| | | .eq(StringUtils.isNotBlank(waveItem.getFieldsIndex()), LocItem::getFieldsIndex, waveItem.getFieldsIndex()) |
|---|
| | | .groupBy(LocItem::getMatnrCode, LocItem::getSplrBatch, LocItem::getFieldsIndex, LocItem::getId)); |
|---|
| | | .eq(StringUtils.isNotEmpty(waveItem.getSplrBatch()), LocItem::getSplrBatch, waveItem.getSplrBatch()) |
|---|
| | | // .eq(StringUtils.isNotBlank(waveItem.getFieldsIndex()), LocItem::getFieldsIndex, waveItem.getFieldsIndex()) |
|---|
| | | .groupBy(LocItem::getMatnrCode, LocItem::getSplrBatch, LocItem::getId)); |
|---|
| | | List<Double> doubles1 = locItems.stream().map(LocItem::getAnfme).collect(Collectors.toList()); |
|---|
| | | double[] doubles = doubles1.stream().mapToDouble(Double::doubleValue).toArray(); |
|---|
| | | |
|---|
