工作流范例

向右看齐 2024-03-22 11:15 78阅读 0赞

/**
     * 工作流状态获取
     */
    private String getWorkFlowStatus(WorkflowHttpDTO workflowHttpDTO) {
        String applicationStatus = null;
        if (StringUtils.equals(WorkFlowStatusCodeEnum.WORK_FLOW_REMOVE_END.getCode(),
            workflowHttpDTO.getFlowInstStatus())) {
            applicationStatus = "01";
            // 判断当前加油单是否被结算过 如果结算过了就不允许反审 ZJY TODO
            checkSettlement(workflowHttpDTO);
            this.updateMain(applicationStatus, workflowHttpDTO);
            // 通知一下油料出库当前数据被反审 ZJY TODO
    
        }
        if (StringUtils.equals(WorkFlowStatusCodeEnum.WORK_FLOW_RUNNING.getCode(),
            workflowHttpDTO.getFlowInstStatus())) {
            applicationStatus = "02";
            this.updateAll(applicationStatus, workflowHttpDTO);
        }
        if (StringUtils.equals(WorkFlowStatusCodeEnum.WORK_FLOW_SUCCESS_END.getCode(),
            workflowHttpDTO.getFlowInstStatus())) {
            applicationStatus = "03";
            // 通知一下油料出库当前数据可以入库 ZJY TODO
    
            this.updateAll(applicationStatus, workflowHttpDTO);
        }
        // 驳回
        if (StringUtils.equals(WorkFlowStatusCodeEnum.WORK_FLOW_REJECT.getCode(),
            workflowHttpDTO.getFlowInstStatus())) {
            applicationStatus = "04";
            this.updateMain(applicationStatus, workflowHttpDTO);
        }
        if (StringUtils.equals(WorkFlowStatusCodeEnum.WORK_FLOW_ABORT_END.getCode(),
            workflowHttpDTO.getFlowInstStatus())) {
            applicationStatus = "05";
            this.updateMain(applicationStatus, workflowHttpDTO);
        }
        if (StringUtils.equals(WorkFlowStatusCodeEnum.WORK_FLOW_RECOVER.getCode(),
            workflowHttpDTO.getFlowInstStatus())) {
            applicationStatus = "02";
            this.updateMain(applicationStatus, workflowHttpDTO);
        }
        return applicationStatus;
    }

private void updateAll(String applicationStatus, WorkflowHttpDTO workflowHttpDTO) {
        DoRefulDetailDTO dto = JSONUtil.toBean(workflowHttpDTO.getFormJsonData(), DoRefulDetailDTO.class);
        dto.setApplicationStatus(applicationStatus);
        this.update(dto);/**
         * 修改主流程状态
         *
         * @param applicationStatus 审批状态
         * @param workflowHttpDTO   HTTP DTO
         * @throws BussinessException 自定义业务异常
         */
    
    }

@SneakyThrows
    @Transactional(rollbackFor = Exception.class)
    public void updateMain(String applicationStatus, WorkflowHttpDTO workflowHttpDTO) {
        // 解析HTTP DTO中的JSON数据并转换为实体类
        DoRefulDetailDTO dto = JSONUtil.toBean(workflowHttpDTO.getFormJsonData(), DoRefulDetailDTO.class);
        // 创建一个新的实体类并设置ID和审批状态
        MachineRefuel entity = new MachineRefuel();
        if (Objects.isNull(dto.getId())) {
            // 如果ID为空则抛出自定义业务异常
            throw new BussinessException(ErrorCodeEnum.OPERATION_ERROR);
        }
        entity.setId(dto.getId());
        entity.setApplicationStatus(applicationStatus);
        // 根据ID更新表中的记录
        this.machineRefuelMapper.updateById(entity);
    }

下面是接口

/**
         * 工作流调用
         *
         * @param workflowHttpDTO
         * @return Result
         */
        @ApiOperation(value = "工作流调用", notes = "工作流调用")
        @PostMapping("/workflow")
        public R call(@RequestBody WorkflowHttpDTO workflowHttpDTO) {
            return R.ok(this.doRefulService.workflowExcute(workflowHttpDTO));
        }