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


@@ -10,14 +10,11 @@


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.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 +25,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,11 +35,8 @@


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;


@@ -160,9 +155,21 @@


            spotCheckQuarterItemMapper.updateById(spotCheckQuarterItem);


        }






        // 创建工时暂存


        // 缓存样品id, 编号map


//        addWorkingHoursTemporary(userId, insSamples, ids, order);




        return 1;


    }




    /**


     * 创建工时暂存


     * @param userId


     * @param insSamples


     * @param ids


     * @param order


     */


    private void addWorkingHoursTemporary(Integer userId, List<InsSample> insSamples, List<Integer> ids, InsOrder order) {


        Map<Integer, String> sampleMap = insSamples.stream().collect(Collectors.toMap(InsSample::getId, InsSample::getSampleCode));


        List<InsProduct> insProductList = insProductMapper.selectList(Wrappers.<InsProduct>lambdaQuery()


                .in(InsProduct::getInsSampleId, ids)


@@ -194,8 +201,6 @@


            return auxiliaryOutputWorkingHours;


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


        auxiliaryOutputWorkingHoursTemporaryService.saveBatch(outputWorkingHours);




        return 1;


    }




    public static String getWeek(String dayStr) {


@@ -442,6 +447,9 @@


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


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


                }


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


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


                }


                insProductMapper.insert(product);


            }


        }


@@ -557,112 +565,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库存信息


@@ -1034,7 +942,8 @@


        // 查询标准树


        List<StandardProductList> standardProductLists = standardProductListMapper.selectList(Wrappers.<StandardProductList>lambdaQuery()


                .eq(StandardProductList::getStandardMethodListId, insProduct.getStandardMethodListId())


                .eq(StandardProductList::getTree, tree));


                .eq(StandardProductList::getTree, tree)


                .orderByAsc(StandardProductList::getSort));


        for (StandardProductList standardProductList : standardProductLists) {


            standardProductList.setId(null);


        }