流程信息配置功能、项目关联流程功能

xiangpei

2024-11-27 4655d854b2652ac138cde15b8acdd7f6e324d812

 business/src/main/java/com/ycl/service/impl/ProjectProcessServiceImpl.java

@@ -1,6 +1,8 @@
package com.ycl.service.impl;

import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;
import com.baomidou.mybatisplus.extension.conditions.update.LambdaUpdateChainWrapper;
import com.ycl.domain.entity.ProjectProcess;
import com.ycl.mapper.ProjectProcessMapper;
import com.ycl.service.ProjectProcessService;
@@ -16,6 +18,7 @@
import org.springframework.util.Assert;

import java.util.List;
import java.util.Objects;
import java.util.stream.Collectors;

/**
@@ -29,56 +32,6 @@
public class ProjectProcessServiceImpl extends ServiceImpl<ProjectProcessMapper, ProjectProcess> implements ProjectProcessService {

    private final ProjectProcessMapper projectProcessMapper;

    /**
     * 添加
     * @param form
     * @return
     */
    @Override
    public Result add(ProjectProcessForm form) {
        ProjectProcess entity = ProjectProcessForm.getEntityByForm(form, null);
        baseMapper.insert(entity);
        return Result.ok("添加成功");
    }

    /**
     * 修改
     * @param form
     * @return
     */
    @Override
    public Result update(ProjectProcessForm form) {
        ProjectProcess entity = baseMapper.selectById(form.getId());

        // 为空抛IllegalArgumentException，做全局异常处理
        Assert.notNull(entity, "记录不存在");
        BeanUtils.copyProperties(form, entity);
        baseMapper.updateById(entity);
        return Result.ok("修改成功");
    }

    /**
     * 批量删除
     * @param ids
     * @return
     */
    @Override
    public Result remove(List<String> ids) {
        baseMapper.deleteBatchIds(ids);
        return Result.ok("删除成功");
    }

    /**
     * id删除
     * @param id
     * @return
     */
    @Override
    public Result removeById(String id) {
        baseMapper.deleteById(id);
        return Result.ok("删除成功");
    }

    /**
     * 分页查询
@@ -104,13 +57,23 @@
        return Result.ok().data(vo);
    }

    /**
     * 列表
     * @return
     */

    @Override
    public Result all() {
        List<ProjectProcess> entities = baseMapper.selectList(null);
        return Result.ok().data(entities);
    public Result projectSetProcess(ProjectProcessForm form) {
        // 查询该项目是否已经绑定过流程了，检查绑定的流程是否在运行，在运行就删了
        ProjectProcess pp = new LambdaQueryChainWrapper<>(baseMapper)
                .eq(ProjectProcess::getProjectId, form.getProjectId())
                .one();
        if (Objects.nonNull(pp)) {
            // TODO 处理之前绑定过的流程数据
            new LambdaUpdateChainWrapper<>(baseMapper)
                    .eq(ProjectProcess::getProjectId, form.getProjectId())
                    .set(ProjectProcess::getFlowableProcessId, form.getFlowableProcessId())
                    .update();
        } else {
            ProjectProcess entity = ProjectProcessForm.getEntityByForm(form, null);
            baseMapper.insert(entity);
        }
        return Result.ok("流程变更成功");
    }
}