| | |
|---|
| | | import cn.gistack.sm.sg.DTO.ApprovalDTO; |
|---|
| | | import cn.gistack.sm.sg.DTO.ProjectSearchDTO; |
|---|
| | | import cn.gistack.sm.sg.VO.SgProgressReportVO; |
|---|
| | | import cn.gistack.sm.sg.VO.SgStepReportVO; |
|---|
| | | import cn.gistack.sm.sg.mapper.*; |
|---|
| | | import cn.gistack.sm.sg.service.SgProgressReportService; |
|---|
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
|---|
| | |
|---|
| | | Long gxStepId = sgProgressReportDO.getGxStepId(); |
|---|
| | | List<SgGxStepDO> list = sgGxStepMapper.selectByGxInfoId(gxDeviceId); |
|---|
| | | SgGxStepDO sgGxStepDO = sgGxStepMapper.selectById(gxStepId); |
|---|
| | | LambdaQueryChainWrapper<SgProgressReportDO> wrapper = new LambdaQueryChainWrapper<>(sgProgressReportMapper) |
|---|
| | | .eq(SgProgressReportDO::getGxStepId, gxStepId).eq(SgProgressReportDO::getGxDeviceId,gxDeviceId); |
|---|
| | | if ( sgProgressReportMapper.selectOne(wrapper)!=null){ |
|---|
| | | QueryWrapper<SgProgressReportDO> wrapper = new QueryWrapper<>(); |
|---|
| | | wrapper.eq("gx_step_id", gxStepId).eq("gx_device_id",gxDeviceId); |
|---|
| | | List<SgProgressReportDO> sgProgressReportDOS = sgProgressReportMapper.selectList(wrapper); |
|---|
| | | if ( sgProgressReportDOS!=null && sgProgressReportDOS.size()>0){ |
|---|
| | | throw new ServiceException("此工序已存在审批！"); |
|---|
| | | } |
|---|
| | | for (SgGxStepDO gxStepDO : list) { |
|---|
| | |
|---|
| | | List<SgGxConfigDO> sgGxConfigDOS = new LambdaQueryChainWrapper<>(sgGxConfigMapper) |
|---|
| | | .eq(SgGxConfigDO::getGxDeviceType, deviceType).eq(SgGxConfigDO::getGxStepId, gxStepId).list(); |
|---|
| | | List<String> roIds = sgGxConfigDOS.stream().map(SgGxConfigDO::getRoleId).collect(Collectors.toList()); |
|---|
| | | List<SgProjectPersonConfigDO> personConfigDOS = new LambdaQueryChainWrapper<>(sgProjectPersonConfigMapper).in(SgProjectPersonConfigDO::getRoldId, roIds).list(); |
|---|
| | | List<SgProjectPersonConfigDO> personConfigDOS = new LambdaQueryChainWrapper<>(sgProjectPersonConfigMapper).eq(SgProjectPersonConfigDO::getProgramId,sgProgressReportDO.getProframId()).in(SgProjectPersonConfigDO::getRoldId, roIds).list(); |
|---|
| | | Map<Long, Long> userMap = personConfigDOS.stream().collect(Collectors.toMap(SgProjectPersonConfigDO::getRoldId, SgProjectPersonConfigDO::getUserId)); |
|---|
| | | Date now = DateUtil.now(); |
|---|
| | | sgReportUserMapper.insert(SgReportUserDO.builder().reportId(sgProgressReportDO.getId()).userId(sgProgressReportDO.getReportUser()).approvalContent("提交审批").approvalStatus(0).approvalOrder(0).approvalTime(now).build()); |
|---|
| | |
|---|
| | | SgProgressReportVO sgProgressReportVO = sgProgressReportMapper.queryById(id); |
|---|
| | | List<SgReportUserDO> list = new LambdaQueryChainWrapper<>(sgReportUserMapper).eq(SgReportUserDO::getReportId, id).orderByAsc(SgReportUserDO::getApprovalTime).list(); |
|---|
| | | sgProgressReportVO.setSgReportUserDOS(list); |
|---|
| | | List<SgStepReportVO> sgStepReportVOS = sgProgressReportMapper.selectByDeviceId(sgProgressReportVO.getGxDeviceId()); |
|---|
| | | sgProgressReportVO.setSgStepReportVOS(sgStepReportVOS); |
|---|
| | | return sgProgressReportVO; |
|---|
| | | } |
|---|
| | | |
|---|
