产品供销存-后端
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
maven
3 天以前 91c0906bda26d3718b2fa450eed27419388b24a5 
 src/main/java/com/ruoyi/approve/service/impl/ApproveProcessServiceImpl.java


@@ -1,6 +1,9 @@


package com.ruoyi.approve.service.impl;




import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;


import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;


import com.baomidou.mybatisplus.core.metadata.IPage;


import com.baomidou.mybatisplus.extension.plugins.pagination.Page;


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


import com.ruoyi.approve.mapper.ApproveProcessMapper;


import com.ruoyi.approve.pojo.ApproveNode;


@@ -12,19 +15,28 @@


import com.ruoyi.approve.vo.ApproveProcessVO;


import com.ruoyi.common.utils.SecurityUtils;


import com.ruoyi.project.system.domain.SysDept;


import com.ruoyi.project.system.domain.SysUser;


import com.ruoyi.project.system.mapper.SysDeptMapper;


import com.ruoyi.project.system.mapper.SysUserMapper;


import lombok.AllArgsConstructor;


import lombok.RequiredArgsConstructor;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.context.annotation.Lazy;


import org.springframework.data.redis.core.StringRedisTemplate;


import org.springframework.stereotype.Service;


import org.springframework.util.CollectionUtils;


import org.springframework.util.StringUtils;




import java.text.ParseException;


import java.text.SimpleDateFormat;


import java.time.LocalDate;


import java.time.LocalDateTime;


import java.time.format.DateTimeFormatter;


import java.util.ArrayList;


import java.util.Arrays;


import java.util.Date;


import java.util.List;


import java.util.stream.Collectors;




@Service


@RequiredArgsConstructor


@@ -37,34 +49,52 @@




    private final SysDeptMapper sysDeptMapper;


    private final IApproveNodeService approveNodeService;


    private final SysUserMapper sysUserMapper;


    private final ApproveProcessMapper approveProcessMapper;




    @Override


    public void addApprove(ApproveProcessVO approveProcessVO) {


        Long userId = SecurityUtils.getUserId();


        //租户id


        Long tenantId = SecurityUtils.getLoginUser().getTenantId();




    public void addApprove(ApproveProcessVO approveProcessVO) throws ParseException {


        SysUser sysUser = sysUserMapper.selectUserById(approveProcessVO.getApproveUser());


        SysDept sysDept = sysDeptMapper.selectDeptById(approveProcessVO.getApproveDeptId());


        String[] split = approveProcessVO.getApproveUserIds().split(",");


        List<Long> longList = Arrays.stream(split)


                .map(Long::valueOf)  // 将每个 String 转换为 Long


                .collect(Collectors.toList());


        List<SysUser> sysUsers = sysUserMapper.selectUserByIds(longList);


        if(CollectionUtils.isEmpty(sysUsers)) throw new RuntimeException("审核用户不存在");


        if(sysDept == null) throw new RuntimeException("部门不存在");


        if(sysUser == null) throw new RuntimeException("申请人不存在");


        String today = LocalDate.now().format(DATE_FORMAT);


        Long approveId = dailyRedisCounter.incrementAndGet("approveId");


        Long approveId = dailyRedisCounter.incrementAndGetByDb();


        String formattedCount = String.format("%03d", approveId);


        //流程 ID


        String approveID = today + formattedCount;




        SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");


        ApproveProcess approveProcess = new ApproveProcess();


        approveProcess.setApproveId(approveID);


        approveProcess.setApproveUser(userId);


        approveProcess.setApproveDeptName(approveProcessVO.getDeptName());


        approveProcess.setApproveUserNames(approveProcessVO.getApproverNames());


        approveProcess.setApproveTime(new Date());


        approveProcess.setApproveUser(approveProcessVO.getApproveUser());


        approveProcess.setApproveUserName(sysUser.getNickName());


        approveProcess.setApproveDeptId(approveProcessVO.getApproveDeptId());


        approveProcess.setApproveDeptName(sysDept.getDeptName());


        approveProcess.setApproveUserNames(sysUsers.stream().map(SysUser::getNickName).collect(Collectors.joining(",")));


        approveProcess.setApproveTime(StringUtils.isEmpty(approveProcessVO.getApproveTime()) ? null : dateFormat.parse(approveProcessVO.getApproveTime()));


        approveProcess.setApproveReason(approveProcessVO.getApproveReason());


        approveProcess.setApproveOverTime(null);


        approveProcess.setApproveStatus(0);


        approveProcess.setApproveDelete(0);


        approveProcess.setTenantId(tenantId);




        approveProcess.setCreateTime(LocalDateTime.now());


        approveProcess.setTenantId(approveProcessVO.getApproveDeptId());


        approveProcess.setApproveUserIds(approveProcessVO.getApproveUserIds());


        approveProcess.setApproveUserCurrentId(longList.get(0));


        approveProcess.setApproveUserCurrentName(sysUsers


                .stream()


                .filter(SysUser -> SysUser.getUserId().equals(longList.get(0)))


                .collect(Collectors.toList())


                .get(0)


                .getNickName());


        save(approveProcess);


        //初始化审批节点


        approveNodeService.initApproveNodes(approveID);


        approveNodeService.initApproveNodes(approveProcessVO.getApproveUserIds(),approveID,approveProcessVO.getApproveDeptId());


    }




    @Override


@@ -78,19 +108,23 @@


    }




    @Override


    public List<ApproveProcess> listAll() {


        LambdaQueryWrapper<ApproveProcess> queryWrapper = new LambdaQueryWrapper<>();


        queryWrapper.eq(ApproveProcess::getApproveDelete, 0);


        return list(queryWrapper);


    public IPage<ApproveProcess> listAll(Page page,ApproveProcess approveProcess) {


        IPage<ApproveProcess> approveProcessIPage = approveProcessMapper.listPage(page,approveProcess);


        return approveProcessIPage;


    }




    @Override


    public void delApprove(Long[] ids) {


        for (Long id : ids) {


            LambdaQueryWrapper<ApproveProcess> queryWrapper = new LambdaQueryWrapper<>();


            queryWrapper.eq(ApproveProcess::getApproveId, id);


            UpdateWrapper<ApproveProcess> queryWrapper = new UpdateWrapper<>();


            queryWrapper.lambda().set(ApproveProcess::getApproveDelete, 1)


                    .eq(ApproveProcess::getApproveId, id);


            update(queryWrapper);


            // 删除关联的审批节点


            approveNodeService.delApproveNodeByApproveId(id);


        }






    }




    @Override