可针对单个波次进行暂停，开始， 主单添加进度条

skyouc

4 天以前 646bfdde5c37f0b0d479bbcbc7503bc8482e67d6

 rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/WaveServiceImpl.java

@@ -110,7 +110,6 @@
        return R.ok();
    }


    /**
     * 选择波次明细下发任务
     *
@@ -121,26 +120,23 @@
    @Override
    @Transactional(rollbackFor = Exception.class)
    public R waveToTask(Map<String, Object> map, Long loginUserId) {
        if (Objects.isNull(map.get("waveItem"))) {
        if (Objects.isNull(map.get("ids"))) {
            throw new CoolException("参数不能为空！！");
        }
        String waveId = map.get("wave").toString();
        Wave waves = this.getById(Long.parseLong(waveId));
        List<Long> WaveIds = JSONArray.parseArray(JSON.toJSONString(map.get("ids")), Long.class);
        List<Wave> waves = waveService.listByIds(WaveIds);
        if (Objects.isNull(waves)) {
            throw new CoolException("波次数据不存在！！");
            throw new CoolException("数据错误： 波次不存在！！");
        }
        List<Long> waveItems = JSONArray.parseArray(JSON.toJSONString(map.get("waveItem")), Long.class);
        if (waveItems.isEmpty()) {
            throw new CoolException("波次明细不能为空！！");
        }
        List<WaveItem> items = waveItemService.listByIds(waveItems);
        for (Wave wave : waves) {
            List<WaveItem> items = waveItemService.list(new LambdaQueryWrapper<WaveItem>().eq(WaveItem::getWaveId, wave.getId()));
        if (items.isEmpty()) {
            throw new CoolException("波次明细不存在！！");
        }

            List<Long> ids = items.stream().map(WaveItem::getId).collect(Collectors.toList());
        if (!waveItemService.update(new LambdaUpdateWrapper<WaveItem>()
                .set(WaveItem::getExceStatus, WaveItemExceStatus.WAVE_EXCE_STATUS_ING.val)
                .in(WaveItem::getId, waveItems))) {
                    .set(WaveItem::getExceStatus, WaveExceStatus.WAVE_EXCE_STATUS_EXCING.val)
                    .in(WaveItem::getId, ids))) {
            throw new CoolException("执行状态修改失败！！");
        }

@@ -161,10 +157,6 @@
        }
        List<OrderOutItemDto> results = LocManageUtil.getOutOrderList(params, waveRule);
        if (results.isEmpty()) {
            Wave wave = waveService.getById(waveId);
            if (Objects.isNull(wave)) {
                throw new CoolException("<UNK>");
            }
            wave.setUpdateBy(loginUserId).setUpdateTime(new Date());
            if (wave.getAnfme().compareTo(wave.getWorkQty()) == 0) {
                wave.setExceStatus(WaveExceStatus.WAVE_EXCE_STATUS_TASK.val);
@@ -176,14 +168,14 @@
        }
        try {
            /**生成出库任务*/
            generateOutTask(results, loginUserId, waves);
                generateOutTask(results, loginUserId, wave);
        } catch (Exception e) {
            log.error("UNK", e);
            throw new CoolException(e.getMessage());
        }

        List<TaskItem> taskItems = taskItemService.list(new LambdaQueryWrapper<TaskItem>()
                .in(TaskItem::getSource, waveItems));
                    .in(TaskItem::getSource, ids));
        if (Cools.isEmpty(taskItems)) {
            throw new CoolException("暂无合适库存信息！！");
        }
@@ -192,13 +184,13 @@
            Double workQty = Math.round((waveItem.getWorkQty() + item.getAnfme()) * 10000) / 10000.0;
            waveItem.setWorkQty(workQty);
            if (workQty.compareTo(waveItem.getAnfme()) < 0) {
                waveItem.setExceStatus(WaveItemExceStatus.WAVE_EXCE_STATUS_ING.val);
                    waveItem.setExceStatus(WaveExceStatus.WAVE_EXCE_STATUS_EXCING.val);
            } else {
                waveItem.setExceStatus(WaveItemExceStatus.WAVE_EXCE_STATUS_PUBD.val);
                    waveItem.setExceStatus(WaveExceStatus.WAVE_EXCE_STATUS_TASK.val);
            }

            if (!waveItemService.update(new LambdaUpdateWrapper<WaveItem>()
                    .set(WaveItem::getExceStatus, WaveItemExceStatus.WAVE_EXCE_STATUS_PUBD.val)
                        .set(WaveItem::getExceStatus, WaveExceStatus.WAVE_EXCE_STATUS_TASK.val)
                    .setSql("work_qty = work_qty + " + item.getAnfme())
                    .set(WaveItem::getUpdateBy, loginUserId)
                    .set(WaveItem::getUpdateTime, new Date())
@@ -211,9 +203,11 @@
                .set(Wave::getWorkQty, taskItems.stream().mapToDouble(TaskItem::getAnfme).sum())
                .set(Wave::getUpdateBy, loginUserId)
                .set(Wave::getUpdateTime, new Date())
                .eq(Wave::getId, waveId))) {
                    .eq(Wave::getId, wave.getId()))) {
            throw new CoolException("波次状态修改失败！！");
        }
        }

        return R.ok();
    }