| | |
|---|
| | | @Override |
|---|
| | | @Synchronized |
|---|
| | | @Transactional(rollbackFor = Exception.class) |
|---|
| | | public void generateTask(Short resouce, LocToTaskParams map, Long loginUserId) throws Exception { |
|---|
| | | if (Objects.isNull(map.getSiteNo())) { |
|---|
| | | throw new CoolException("站点不能为空！"); |
|---|
| | | } |
|---|
| | | public synchronized void generateTask(Short resouce, LocToTaskParams map, Long loginUserId) throws Exception { |
|---|
| | | // 出库口未传时默认 1001 |
|---|
| | | String siteNo = StringUtils.isNotBlank(map.getSiteNo()) ? map.getSiteNo() : "1001"; |
|---|
| | | if (Objects.isNull(map.getItems()) || map.getItems().isEmpty()) { |
|---|
| | | throw new CoolException("明细不能为空！"); |
|---|
| | | } |
|---|
| | | String siteNo = map.getSiteNo(); |
|---|
| | | List<LocItem> items = map.getItems(); |
|---|
| | | Map<Long, List<LocItem>> listMap = items.stream().collect(Collectors.groupingBy(LocItem::getLocId)); |
|---|
| | | WkOrder order; |
|---|
| | |
|---|
| | | if (map.getType().equals(Constants.TASK_TYPE_ORDER_OUT_STOCK)) { |
|---|
| | | taskItem.setWkType(Short.parseShort(order.getWkType())) |
|---|
| | | .setSourceCode(order.getCode()) |
|---|
| | | .setSourceId(order.getId()); |
|---|
| | | .setSourceId(order.getId()) |
|---|
| | | .setOrderItemId(item.getOrderItemId()); |
|---|
| | | } else if (map.getType().equals(Constants.TASK_TYPE_WAVE_OUT_STOCK)) { |
|---|
| | | taskItem.setSourceId(wave.getId()) |
|---|
| | | .setWkType(Short.parseShort(OrderWorkType.ORDER_WORK_TYPE_OTHER.type)) |
|---|
