| | |
| | | package com.ruoyi.management.service.impl; |
| | | |
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
| | | import com.baomidou.mybatisplus.core.toolkit.Wrappers; |
| | | import com.baomidou.mybatisplus.extension.plugins.pagination.Page; |
| | | import com.ruoyi.common.core.utils.page.PageDTO; |
| | |
| | | |
| | | @Override |
| | | public PageDTO<SlAuditVO> getslAuditList(AuditRecordListQuery auditRecordListQuery) { |
| | | List<Long> rkglIds = new ArrayList<>(); |
| | | List<Long> ckglIds = new ArrayList<>(); |
| | | List<Long> zyglIds = new ArrayList<>(); |
| | | List<Long> auditIds = new ArrayList<>(); |
| | | Long userid = SecurityUtils.getUserId(); |
| | | SysUser data = sysUserClient.getSysUser(userid).getData(); |
| | | getVolumeProductionRkQuery getVolumeProductionRkQuer=new getVolumeProductionRkQuery(); |
| | |
| | | goodsSkuIdList1.add(0L); |
| | | wrapper.in(SlAudit::getSysId,goodsSkuIdList1); |
| | | } |
| | | |
| | | switch (auditRecordListQuery.getType()){ |
| | | case 1: |
| | | rkglIds = slVolumeProductionRkglMapper.selectList(new QueryWrapper<SlVolumeProductionRkgl>() |
| | | .ne("audit_status", 7)).stream().map(SlVolumeProductionRkgl::getId).collect(Collectors.toList()); |
| | | wrapper.in(SlAudit::getRkId,rkglIds); |
| | | if (!data.getUserType().equals("00")){ |
| | | wrapper.in(SlAudit::getShenhId,userid); |
| | | // 只查询相关的审核 |
| | | auditIds = slAuditRecordMapper.selectList(new QueryWrapper<SlAuditRecord>() |
| | | .like("shenh_id", data.getUserId())).stream().map(SlAuditRecord::getAuditId).collect(Collectors.toList()); |
| | | wrapper.in(SlAudit::getId,auditIds); |
| | | } |
| | | |
| | | break; |
| | | case 2: |
| | | ckglIds = slVolumeProductionCKglMapper.selectList(new QueryWrapper<SlVolumeProductionCkgl>() |
| | | .ne("audit_status", 8)).stream().map(SlVolumeProductionCkgl::getId).collect(Collectors.toList()); |
| | | wrapper.in(SlAudit::getRkId,ckglIds); |
| | | if (!data.getUserType().equals("00")){ |
| | | // 只查询相关的审核 |
| | | auditIds = slAuditRecordMapper.selectList(new QueryWrapper<SlAuditRecord>() |
| | | .like("shenh_id", data.getUserId())).stream().map(SlAuditRecord::getAuditId).collect(Collectors.toList()); |
| | | wrapper.in(SlAudit::getId,auditIds); |
| | | } |
| | | |
| | | break; |
| | | case 3: |
| | | zyglIds = slVolumeProductionZyglMapper.selectList(new QueryWrapper<SlVolumeProductionZygl>() |
| | | .ne("audit_status", 7)).stream().map(SlVolumeProductionZygl::getId).collect(Collectors.toList()); |
| | | wrapper.in(SlAudit::getRkId,zyglIds); |
| | | if (!data.getUserType().equals("00")){ |
| | | // 只查询相关的审核 |
| | | auditIds = slAuditRecordMapper.selectList(new QueryWrapper<SlAuditRecord>() |
| | | .like("shenh_id", data.getUserId())).stream().map(SlAuditRecord::getAuditId).collect(Collectors.toList()); |
| | | wrapper.in(SlAudit::getId,auditIds); |
| | | } |
| | | |
| | | break; |
| | | } |
| | | wrapper.eq(SlAudit::getType,auditRecordListQuery.getType()); |
| | | wrapper.eq(SlAudit::getDelFlag,0); |
| | | wrapper.orderByDesc(SlAudit::getCreateTime); |
| | | Page<SlAudit> page1 = this.page(page, wrapper); |
| | | |
| | | PageDTO<SlAuditVO> slEquipmentVOPageDTO = PageDTO.of(page1, SlAuditVO.class); |
| | | List<SlAuditVO> list = slEquipmentVOPageDTO.getList(); |
| | | for (SlAuditVO sl:list){ |