fix(ai): 修复会员学习记录查询中的空指针异常

Administrator

2 days ago 8a2d6564e22c28ec357a8c702ffe67d6d790c459

fix(ai): 修复会员学习记录查询中的空指针异常

- 移除注释掉的旧代码逻辑
- 添加对 ApiCompanyStudyVo 对象的空值检查
- 过滤掉 productId 为 null 的情况
- 确保 collect 集合不为空后再执行后续操作
- 在设置练习计数前检查 record 和其 productId 是否为 null
- 提高代码的健壮性和安全性

 src/main/java/cc/mrbird/febs/ai/service/impl/AiMemberServiceImpl.java

@@ -392,23 +392,51 @@
        // 创建分页对象，传入当前页和每页大小
        Page<ApiCompanyStudyVo> page = new Page<>(dto.getPageNow(), dto.getPageSize());
        IPage<ApiCompanyStudyVo> result = aiMemberAnswerService.selectListPage(dto, page);
//        List<ApiCompanyStudyVo> records = result.getRecords();
//        if (CollUtil.isNotEmpty(records)){
//            //stream流获取re cords集合中的元素productId的set集合
//            Set<String> collect = records.stream().map(ApiCompanyStudyVo::getProductId).collect(Collectors.toSet());
//            List<AiMemberAnswer>  list = aiMemberAnswerService.getIdListByCompanyIdAndProductId(companyId,  collect);
//            if (CollUtil.isNotEmpty(list)){
//                //利用stream流，操作集合list，返回一个map对象，key为productId，value为按照productId分组的集合的大小,默认值为0
//                Map<String, Long> memberAnswerItemCountMap =
//                        list.stream().collect(Collectors.groupingBy(
//                                        AiMemberAnswer::getProductId,
//                                        Collectors.counting()
//                                ));
//                for ( ApiCompanyStudyVo record : records){
//                     record.setPracticeCnt(memberAnswerItemCountMap.getOrDefault(record.getProductId(), 0L).intValue());
//                }
//            }
//        }

        List<ApiCompanyStudyVo> records = result.getRecords();
        if (CollUtil.isNotEmpty(records)){
            //stream流获取re cords集合中的元素productId的set集合
            Set<String> collect = records.stream().map(ApiCompanyStudyVo::getProductId).collect(Collectors.toSet());
            // 安全地获取 productId 集合，过滤掉 null 值
            Set<String> collect = records.stream()
                    .filter(Objects::nonNull)
                    .map(ApiCompanyStudyVo::getProductId)
                    .filter(Objects::nonNull)
                    .collect(Collectors.toSet());

            if (CollUtil.isNotEmpty(collect)) {  // 确保 collect 不为空
            List<AiMemberAnswer>  list = aiMemberAnswerService.getIdListByCompanyIdAndProductId(companyId,  collect);
            if (CollUtil.isNotEmpty(list)){
                //利用stream流，操作集合list，返回一个map对象，key为productId，value为按照productId分组的集合的大小,默认值为0
                Map<String, Long> memberAnswerItemCountMap =
                        list.stream().collect(Collectors.groupingBy(
                    Map<String, Long> memberAnswerItemCountMap = list.stream()
                            .collect(Collectors.groupingBy(
                                        AiMemberAnswer::getProductId,
                                        Collectors.counting()
                                ));

                for ( ApiCompanyStudyVo record : records){
                        if (record != null && record.getProductId() != null) {
                     record.setPracticeCnt(memberAnswerItemCountMap.getOrDefault(record.getProductId(), 0L).intValue());
                }
            }
        }
            }
        }

        return new FebsResponse().success().data(result);
    }