lims项目框架修改优化--后端
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
chenrui
2025-04-09 00c23dd7d4a8f229d5c7fbe3439c6ea230fa7f48 
 inspect-server/src/main/java/com/ruoyi/inspect/service/impl/InsOrderServiceImpl.java


@@ -10,14 +10,12 @@


import com.alibaba.excel.ExcelWriter;


import com.alibaba.excel.write.metadata.WriteSheet;


import com.alibaba.excel.write.style.column.LongestMatchColumnWidthStyleStrategy;


import com.alibaba.excel.write.style.column.SimpleColumnWidthStyleStrategy;


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


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


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


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


import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;


import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;


import com.baomidou.mybatisplus.core.toolkit.Wrappers;


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


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


import com.ruoyi.basic.mapper.IfsInventoryQuantityMapper;


import com.ruoyi.basic.mapper.StandardProductListMapper;


@@ -28,6 +26,7 @@


import com.ruoyi.common.core.domain.entity.User;


import com.ruoyi.common.numgen.NumberGenerator;


import com.ruoyi.common.utils.*;


import com.ruoyi.common.utils.api.IfsApiUtils;


import com.ruoyi.framework.exception.ErrorException;


import com.ruoyi.inspect.dto.*;


import com.ruoyi.inspect.mapper.*;


@@ -37,17 +36,15 @@


import com.ruoyi.inspect.service.InsProductService;


import com.ruoyi.inspect.service.InsSampleService;


import com.ruoyi.inspect.vo.InsOrderPrintingVo;


import com.ruoyi.inspect.vo.SampleDefectsFatherVo;


import com.ruoyi.performance.pojo.AuxiliaryOutputWorkingHours;


import com.ruoyi.performance.pojo.AuxiliaryOutputWorkingHoursTemporary;


import com.ruoyi.performance.service.AuxiliaryOutputWorkingHoursTemporaryService;


import com.ruoyi.system.mapper.CustomMapper;


import com.ruoyi.system.mapper.UserMapper;


import lombok.AllArgsConstructor;


import org.apache.commons.lang3.StringUtils;


import org.springframework.beans.BeanUtils;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;


import org.springframework.util.CollectionUtils;




import javax.servlet.http.HttpServletResponse;


import java.io.IOException;


@@ -94,7 +91,6 @@


    //获取检验下单数据


    @Override


    public IPage<SampleOrderDto> selectInsOrderParameter(IPage<InsOrder> page, SampleOrderDto sampleOrderDto) {


        //todo: 只看我判断全部,个人,组织的权限


        String laboratory = null;


        // 判断是否是全部


        String isOrderAll = null;


@@ -102,7 +98,12 @@


            isOrderAll = "1";


            sampleOrderDto.setState(null);


        }


        return insOrderMapper.selectInsOrderPage(page, QueryWrappers.queryWrappers(sampleOrderDto), laboratory, isOrderAll);


        SampleOrderDto otherParam = new SampleOrderDto();


        otherParam.setLaboratory(laboratory);


        otherParam.setIsOrderAll(isOrderAll);


        otherParam.setCheckUserId(SecurityUtils.getUserId());


        IPage<SampleOrderDto> sampleOrderDtoIPage = insOrderMapper.selectInsOrderPage(page, QueryWrappers.queryWrappers(sampleOrderDto), otherParam);


        return sampleOrderDtoIPage;


    }






@@ -125,7 +126,6 @@


                .in(InsProduct::getInsSampleId, ids)


                .eq(InsProduct::getState, 1)


                .select(InsProduct::getSonLaboratory).groupBy(InsProduct::getSonLaboratory));




        // 批量添加检验任务状态表


        List<InsOrderState> insOrderStateList = insProducts.stream().map(insProduct -> {


            InsOrderState insOrderState = new InsOrderState();


@@ -189,10 +189,18 @@


            auxiliaryOutputWorkingHours.setCheck(userId);//检测人


            auxiliaryOutputWorkingHours.setPrice(insProduct.getPrice());//单价


            auxiliaryOutputWorkingHours.setSampleId(insProduct.getInsSampleId());//样品id


            auxiliaryOutputWorkingHours.setInsProductId(insProduct.getId());//检验项id


            auxiliaryOutputWorkingHours.setInsProductId(Math.toIntExact(insProduct.getId()));//检验项id




            return auxiliaryOutputWorkingHours;


        }).collect(Collectors.toList());




        // 初次分配检验人，各个检验项默认订单的检验人


        List<Integer> insProductIds  = insProductList.stream().map(insproduct -> {


            return Math.toIntExact(insproduct.getId());


        }).collect(Collectors.toList());


        if(!CollectionUtils.isEmpty(insProductIds)){


            insProductMapper.batchUpdateInsProductCheckUserId(insProductIds, userId);


        }


        auxiliaryOutputWorkingHoursTemporaryService.saveBatch(outputWorkingHours);




        return 1;


@@ -298,7 +306,7 @@


                    ip2.addAll(insProducts);


                }


                for (InsProduct product : ip2) {


                    product.setStandardMethodListId(a.getInsulating().getStandardMethodListId());


                    product.setStandardMethodListId(Long.valueOf(a.getInsulating().getStandardMethodListId()));


                }


                addInsProductMethod(a.getId(), ip2);


            }


@@ -316,7 +324,7 @@


                    ip2.addAll(insProducts);


                }


                for (InsProduct product : ip2) {


                    product.setStandardMethodListId(a.getAuxiliaryWireCore().getStandardMethodListId());


                    product.setStandardMethodListId(Long.valueOf(a.getAuxiliaryWireCore().getStandardMethodListId()));


                }


                addInsProductMethod(a.getId(), ip2);


            }


@@ -442,6 +450,9 @@


                if (StringUtils.isBlank(product.getAsk()) || StringUtils.isBlank(product.getTell())) {


                    throw new ErrorException("有检验项的要求值或要求描述为空, 请先去标准库配置要求值或要求描述");


                }


                if (StringUtils.isBlank(product.getSonLaboratory())) {


                    throw new ErrorException("有检验项的的子实验室为绑定, 请先绑定子实验室");


                }


                insProductMapper.insert(product);


            }


        }


@@ -493,7 +504,7 @@


            }


            // 生成编号


            String no = numberGenerator.generateNumberWithPrefix(3,


                    "JCZX/ZB-" + code + LimsDateUtil.resetDate(LocalDateTime.now()),


                    "JCZX/SP-" + code + LimsDateUtil.resetDate(LocalDateTime.now()),


                    InsOrder::getEntrustCode);


            // 判断是否是季度检验, 是季度检验取消原材料季度检验下单


            if (InsOrderTypeConstants.QUARTERLY_TEST.equals(order.getOrderType())) {


@@ -557,112 +568,12 @@


        return productDto2IPage;


    }




    @Override


    public IPage<CostStatisticsDto> costStatistics(IPage<CostStatisticsDto> page, CostStatisticsDto costStatisticsDto) {


        String dates = costStatisticsDto.getDates();


        String[] split = dates.replaceAll("\\[", "").replaceAll("]", "").replaceAll("\"", "").split(",");


        costStatisticsDto.setDates(null);




        //todo:仅看自己




        IPage<CostStatisticsDto> dtoIPage = insOrderMapper.selectCostStatistics(page, QueryWrappers.queryWrappers(costStatisticsDto).ge("create_time", split[0]).le("create_time", split[1] + " 23:59:59"));


        List<CostStatisticsDto> collect = dtoIPage.getRecords().stream().map(dto -> {


            Set<String> uniqueTags = new HashSet<>();


            if (dto.getInspectionItem().contains(",")) {


                for (String s : dto.getInspectionItem().split(",")) {


                    uniqueTags.add(s.split("@")[0]);


                }


            } else {


                uniqueTags.add(dto.getInspectionItem().split("@")[0]);


            }


            dto.setInspectionItem(uniqueTags.toString());


            return dto;


        }).collect(Collectors.toList());


        dtoIPage.setRecords(collect);


        return dtoIPage;


    }




    @Override


    public Map<String, Object> costStatistics2(CostStatisticsDto costStatisticsDto) {


        Map<String, Object> map = new HashMap<>();


        String dates = costStatisticsDto.getDates();


        String[] split = dates.replaceAll("\\[", "").replaceAll("]", "").replaceAll("\"", "").split(",");


        costStatisticsDto.setDates(null);


        List<CostStatisticsDto> costStatisticsDtos = insOrderMapper.selectCostStatistics2(QueryWrappers.queryWrappers(costStatisticsDto).ge("create_time", split[0]).le("create_time", split[1] + " 23:59:59"));


        double totalPrice = costStatisticsDtos.stream()


                .filter(dto -> dto.getPrice() != null) // 过滤掉价格为 null 的对象


                .mapToDouble(value -> value.getPrice().doubleValue() * value.getNum())


                .sum();


        map.put("total", totalPrice);


        return map;


    }




    @Override


    public Map<String, Object> selectSampleDefects(Page page, String inspectionItems, String orderNumber) {


        List<SampleDefectsFatherVo> sampleDefectsFatherVos = insOrderMapper.selectSampleDefects(page, inspectionItems, orderNumber);


        Map<String, Object> map = new HashMap<>();


        map.put("records", sampleDefectsFatherVos);


        Long aLong = insOrderMapper.getCount(inspectionItems, orderNumber);


        map.put("total", aLong);


        return map;


    }




    @Override


    public int updateStatus(Integer id) {


        return insOrderMapper.updateStatus(id);


    }






    @Override


    public void export(CostStatisticsDto costStatisticsDto, HttpServletResponse response) throws IOException {


        //查询导出的费用统计数据


        String dates = costStatisticsDto.getDates();


        String[] split = dates.replaceAll("\\[", "").replaceAll("]", "").replaceAll("\"", "").split(",");


        costStatisticsDto.setDates(null);


        List<CostStatisticsDto> costStatisticsDtos = insOrderMapper.selectCostStatistics2(QueryWrappers.queryWrappers(costStatisticsDto).ge("create_time", split[0]).le("create_time", split[1] + " 23:59:59"));


        costStatisticsDtos = costStatisticsDtos.stream().map(dto -> {


            Set<String> uniqueTags = new HashSet<>();


            if (dto.getInspectionItem().contains(",")) {


                for (String s : dto.getInspectionItem().split(",")) {


                    uniqueTags.add(s.split("@")[0]);


                }


            } else {


                uniqueTags.add(dto.getInspectionItem().split("@")[0]);


            }


            dto.setInspectionItem(uniqueTags.toString());


            return dto;


        }).collect(Collectors.toList());




        response.setContentType("application/vnd.ms-excel");


        response.setCharacterEncoding("UTF-8");


        // 这里URLEncoder.encode可以防止中文乱码 当然和easyexcel没有关系


        String fileName = URLEncoder.encode("样品费用统计导出", "UTF-8");


        response.setHeader("Content-disposition", "attachment;filename=" + fileName + ".xlsx");


        Map<String, List<CostStatisticsDto>> groupByCompany =


                costStatisticsDtos.stream().filter(e -> StrUtil.isNotEmpty(e.getCompany()))


                        .collect(Collectors.groupingBy(CostStatisticsDto::getCompany));


        try {


            // 新建ExcelWriter


            // 新建ExcelWriter


            ExcelWriter excelWriter =


                    EasyExcel.write(response.getOutputStream())


                            .registerWriteHandler(new SimpleColumnWidthStyleStrategy(25))


                            .build();


            for (Map.Entry<String, List<CostStatisticsDto>> companyDataEntry : groupByCompany.entrySet()) {


                String sheetName = companyDataEntry.getKey();


                List<CostStatisticsDto> dataList = companyDataEntry.getValue();


                WriteSheet mainSheet = EasyExcel.writerSheet(sheetName)


                        .head(CostStatisticsDto.class)


                        .registerWriteHandler(new SimpleColumnWidthStyleStrategy(25))


                        .build();


                excelWriter.write(dataList, mainSheet);


            }


            // 关闭流


            excelWriter.finish();


        } catch (IOException e) {


            throw new RuntimeException("导出失败");


        }


    }




    /**


     * 获取ifs库存信息