lims项目框架修改优化--后端
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
chenrui
2025-04-09 17ea3e9ec4f49b3652ff8a1e7dc9af502503d3f0 
 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,8 @@


    //获取检验下单数据


    @Override


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


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


        // TODO 针对人员做权限处理 目前先对检验人员做数据处理  如果是检验人员只能查询到检验项目是自己或者订单分派人是自己的订单，不是检验人员的暂时全查


        boolean checkUserFlag = isCheckUser(SecurityUtils.getUserId().intValue());


        String laboratory = null;


        // 判断是否是全部


        String isOrderAll = null;


@@ -102,7 +100,13 @@


            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.setCheckUserFlag(checkUserFlag);


        otherParam.setCheckUserId(SecurityUtils.getUserId());


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


        return sampleOrderDtoIPage;


    }






@@ -125,7 +129,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();


@@ -193,6 +196,14 @@




            return auxiliaryOutputWorkingHours;


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




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


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


            return insproduct.getId();


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


        if(!CollectionUtils.isEmpty(insProductIds)){


            insProductMapper.batchUpdateInsProductCheckUserId(insProductIds, userId);


        }


        auxiliaryOutputWorkingHoursTemporaryService.saveBatch(outputWorkingHours);




        return 1;


@@ -442,6 +453,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 +507,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 +571,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库存信息


@@ -1125,6 +1039,22 @@


        }


    }






    /**


     * 判断是否为检验人员


     * @param userId


     * @return


     */


    public boolean isCheckUser(Integer userId) {


        List<User> userList = userMapper.selectQualityUserList();


        for (User user : userList) {


            if(userId.equals(user.getId())){


                return true;


            }


        }


        return false;


    }




}