提交配置信息2

CZT

2023-11-27 c206acfaedc69c390fb67daa81bc686f58a212ef

 igds-inout/src/main/java/com/ld/igds/inout/manager/InoutManager.java

@@ -114,7 +114,7 @@
            result = inoutService.inoutProgressQuery(param);
            if (null == result) {
                return new PageResponse<>(RespCodeEnum.CODE_2000.getCode(),
                        "系统为查询到执行中的车辆信息", null);
                        "系统未查询到执行中的车辆信息", null);
            }

            // 如果没有流程条件说明不需要做判断，直接返回
@@ -214,35 +214,6 @@
        return data;
    }

    private InoutData updateFiles(InoutData data) throws Exception {
        List<FileData> files = data.getFiles();
        if (null == files) {
            return data;
        }

        for (FileData fileData : files) {
            fileData.setFileId(ContextUtil.getUUID());
            fileData.setCompanyId(data.getCompanyId());
            fileData.setBizId(data.getId());
            if ("HANDLE".equals(fileData.getBizTag())) {
                if (data.getEmptyWeightTime().before(data.getFullWeightTime())) {
                    fileData.setCreateTime(DateUtils.addMinutes(data.getFullWeightTime(), -20));
                } else {
                    fileData.setCreateTime(DateUtils.addMinutes(data.getEmptyWeightTime(), -20));
                }
            }
            if ("WEIGHT_EMPTY".equals(fileData.getBizTag())) {
                fileData.setCreateTime(data.getEmptyWeightTime());
            }
            if ("WEIGHT_FULL".equals(fileData.getBizTag())) {
                fileData.setCreateTime(data.getFullWeightTime());
            }
            coreFileService.addRecord(fileData);
        }

        return data;
    }

    /**
     * 从缓存中获取下一流程
     *
@@ -285,7 +256,9 @@
        }

        if (InoutConstant.PROGRESS_CHECK.equals(data.getProgress())) {
            if (StringUtils.isEmpty(data.getCheckUser())) {
            data.setCheckUser(ContextUtil.getLoginUserCName());
            }
            data.setProgress(nextProgress);
            return data;
        }
@@ -426,11 +399,22 @@
        }

        String loginUser = ContextUtil.getLoginUserCName();
        if (StringUtils.isEmpty(data.getRegisterUser())) {
        data.setRegisterUser(loginUser);
        }
        if (StringUtils.isEmpty(data.getFullWeightUser())) {
        data.setFullWeightUser(loginUser);
        }
        if (StringUtils.isEmpty(data.getEmptyWeightUser())) {
        data.setEmptyWeightUser(loginUser);
        }
        if (StringUtils.isEmpty(data.getHandleUser())) {
        data.setHandleUser(loginUser);
        }
        if (StringUtils.isEmpty(data.getCompleteUser())) {
        data.setCompleteUser(loginUser);
        }

        if (null == data.getCompleteTime()) {
            data.setCompleteTime(new Date());
        }
@@ -443,7 +427,7 @@
        if (null == data.getIntelCard()) {
            data.setIntelCard(data.getUserId());
        }
        if (null != data.getCheckItems()) {
        if (null != data.getCheckItems() && StringUtils.isEmpty(data.getCheckUser())) {
            data.setCheckUser(loginUser);
        }

@@ -485,15 +469,14 @@
            }
        }


        data.setRemarks("");
        //先保存主表，后执行子表
        inoutService.insertData(data);

        if (InoutConstant.TYPE_IN.equals(data.getType())) {
            this.updateCheckItems(data, true);
        }
        this.updateFiles(data);

        fileService.saveInoutFiles(data.getFiles(), data.getCompanyId(), data.getId(), null);
        return null;
    }

@@ -541,9 +524,9 @@

        data = inoutService.inoutQueryById(param);

        if (InoutConstant.PROGRESS_RECORD.equals(data.getProgress())) {
            return "流程结束的数据不支持异常处理！";
        }
//        if (InoutConstant.PROGRESS_RECORD.equals(data.getProgress())) {
//            return "流程结束的数据不支持异常处理！";
//        }
        if (InoutConstant.RECORD_STATUS_DEL.equals(data.getRecordStatus())) {
            return "当前信息已做异常处理，不支持重复执行！";
        }
@@ -644,7 +627,7 @@
            return new PageResponse<>(RespCodeEnum.CODE_1111.getCode(),
                    "提示：当前库区未配置出入库流程信息，请联系管理员", data);
        }

        List<FileData> files = data.getFiles();
        // 获取下一个流程状态
        String curProgress = data.getProgress();
        String nextProgress = getNextProgress(curProgress, data.getType(),
@@ -658,8 +641,10 @@
            return new PageResponse<>(RespCodeEnum.CODE_1111.getCode(), msg, data);
        }

        if (null != files && files.size() > 0) {
        // 执行附件信息
        fileService.saveInoutFiles(data.getFiles(), data.getCompanyId(), data.getId(), curProgress);
            fileService.saveInoutFiles(files, data.getCompanyId(), data.getId(), curProgress);
        }

        //登记完成事件
        inoutEventControl.onInoutRegister(data);
@@ -676,7 +661,7 @@
            return new PageResponse<>(RespCodeEnum.CODE_1111.getCode(),
                    "提示：当前系统中流程配置异常，请联系管理员", data);
        }

        List<FileData> files = data.getFiles();
        // 获取下一个流程状态
        String curProgress = data.getProgress();
        String nextProgress = getNextProgress(curProgress, data.getType(),
@@ -694,8 +679,10 @@
                    data);
        }

        if (null != files && files.size() > 0) {
        // 执行附件信息
        fileService.saveInoutFiles(data.getFiles(), data.getCompanyId(), data.getId(), curProgress);
            fileService.saveInoutFiles(files, data.getCompanyId(), data.getId(), curProgress);
        }

        // 称重完成事件
        inoutEventControl.onInoutWeight(data, curProgress, nextProgress);
@@ -890,6 +877,7 @@
            curData.setCheckTime(new Date());
            data.setCheckTime(new Date());
        }
        curData.setCheckUser(data.getCheckUser());
        curData.setCheckStatus(data.getCheckStatus());
        curData.setFoodYear(data.getFoodYear());

@@ -913,6 +901,7 @@
        curData.setCheckItems(data.getCheckItems());
        curData.setCheckTime(data.getCheckTime());
        curData.setDepotId(data.getDepotId());
        curData.setFoodType(data.getFoodType());

        if (StringUtils.isEmpty(data.getCheckUser())) {
            curData.setCheckUser(ContextUtil.getLoginUserCName());