射洪市项目管理系统
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
luohairen
2024-12-04 fc6b946b1020ddff4fe2b01c9e439680cbda6b47 
 business/src/main/java/com/ycl/service/impl/ProcessConfigInfoServiceImpl.java


@@ -1,24 +1,28 @@


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.github.pagehelper.PageInfo;


import com.ycl.domain.dto.FlowProcDefDto;


import com.ycl.domain.dto.FlowProcDefWithConfigDto;


import com.ycl.domain.entity.ProcessConfigInfo;


import com.ycl.domain.entity.SysForm;


import com.ycl.domain.query.ProcessConfigInfoQuery;


import com.ycl.mapper.FlowDeployMapper;


import com.ycl.mapper.ProcessConfigInfoMapper;


import com.ycl.service.ISysDeployFormService;


import com.ycl.service.ProcessConfigInfoService;


import com.ycl.common.base.Result;


import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;


import com.ycl.domain.form.ProcessConfigInfoForm;


import com.ycl.domain.vo.ProcessConfigInfoVO;


import com.ycl.domain.query.ProcessConfigInfoQuery;


import org.springframework.stereotype.Service;


import lombok.RequiredArgsConstructor;


import com.ycl.framework.utils.PageUtil;


import org.springframework.beans.BeanUtils;


import org.springframework.util.Assert;




import java.util.List;


import java.util.Objects;


import java.util.*;


import java.util.function.BinaryOperator;


import java.util.function.Function;


import java.util.stream.Collectors;




/**


@@ -32,6 +36,8 @@


public class ProcessConfigInfoServiceImpl extends ServiceImpl<ProcessConfigInfoMapper, ProcessConfigInfo> implements ProcessConfigInfoService {




    private final ProcessConfigInfoMapper processConfigInfoMapper;


    private final ISysDeployFormService sysDeployFormService;


    private final FlowDeployMapper flowDeployMapper;




    /**


     * 添加


@@ -42,16 +48,16 @@


    public Result save(ProcessConfigInfoForm form) {


        // 根据部署id和版本号查询是否保存过，有就修改，没有就新增


        ProcessConfigInfo entity = new LambdaQueryChainWrapper<>(baseMapper)


                .eq(ProcessConfigInfo::getDeployId, form.getDeployId())


                .eq(ProcessConfigInfo::getDeployVersion, form.getDeployVersion())


                .eq(ProcessConfigInfo::getProcessDefId, form.getProcessDefId())


                .eq(ProcessConfigInfo::getProcessDefVersion, form.getProcessDefVersion())


                .one();


        if (Objects.isNull(entity)) {


            entity = ProcessConfigInfoForm.getEntityByForm(form, null);


            baseMapper.insert(entity);


        } else {


            new LambdaUpdateChainWrapper<>(baseMapper)


                    .eq(ProcessConfigInfo::getDeployId, form.getDeployId())


                    .eq(ProcessConfigInfo::getDeployVersion, form.getDeployVersion())


                    .eq(ProcessConfigInfo::getProcessDefId, form.getProcessDefId())


                    .eq(ProcessConfigInfo::getProcessDefVersion, form.getProcessDefVersion())


                    .set(ProcessConfigInfo::getProjectType, form.getProjectType())


                    .set(ProcessConfigInfo::getFundType, form.getFundType())


                    .set(ProcessConfigInfo::getInvestType, form.getInvestType())


@@ -63,14 +69,13 @@




    /**


     * 根据id查找


     * @param deployId


     * @return


     */


    @Override


    public Result detail(String deployId, Integer deployVersion) {


    public Result detail(String processDefId, Integer processDefVersion) {


        ProcessConfigInfo entity = new LambdaQueryChainWrapper<>(baseMapper)


                .eq(ProcessConfigInfo::getDeployId, deployId)


                .eq(ProcessConfigInfo::getDeployVersion, deployVersion)


                .eq(ProcessConfigInfo::getProcessDefId, processDefId)


                .eq(ProcessConfigInfo::getProcessDefVersion, processDefVersion)


                .one();


        ProcessConfigInfoVO vo = new ProcessConfigInfoVO();


        if (Objects.isNull(entity)) {


@@ -81,4 +86,30 @@


        return Result.ok().data(vo);


    }






    @Override


    public Result list(ProcessConfigInfoQuery query) {


        List<FlowProcDefWithConfigDto> dataList = flowDeployMapper.selectDeployListWithConfig(query);




//        // 根据 processDefId 分组，并取每组中 版本号 最大的那一个


//        Map<String, FlowProcDefWithConfigDto> groupedByProcessDefId = dataList.stream()


//                .collect(Collectors.toMap(


//                        FlowProcDefWithConfigDto::getProcessDefId, // keyMapper: 提取 processDefId 作为键


//                        Function.identity(),                      // valueMapper: 直接使用对象作为值


//                        BinaryOperator.maxBy(Comparator.comparingInt(FlowProcDefWithConfigDto::getProcessDefVersion)) // mergeFunction: 比较 processDefVersion，取最大的


//                ));


//        List<FlowProcDefWithConfigDto> resultList = new ArrayList<>(groupedByProcessDefId.values());




        // 加载挂表单


        for (FlowProcDefWithConfigDto procDef : dataList) {


            // 排除暂停的




            SysForm sysForm = sysDeployFormService.selectSysDeployFormByDeployId(procDef.getDeploymentId());


            if (Objects.nonNull(sysForm)) {


                procDef.setFormName(sysForm.getFormName());


                procDef.setFormId(sysForm.getFormId());


            }


        }


        return Result.ok().data(dataList);


    }


}