分析一下 public void creatSnapshot(KunxiaoanSnapshotProjectVO projectVO) { // 通过recordNumber判断昆小安项目表是否存在数据，不存在就新增，存在就获取数据 KunxiaoanProject kunxiaoanProject = this.kunxiaoanProjectMapper.selectOneByExample(new Example.Builder(KunxiaoanProject.class).andWhere(WeekendSqls.<KunxiaoanProject>custom().andEqualTo(KunxiaoanProject::getRecordNumber, projectVO.getRecordNumber())).build()); if (null == kunxiaoanProject) { kunxiaoanProject = new KunxiaoanProject().init(projectVO); this.kunxiaoanProjectMapper.create(kunxiaoanProject); } this.kunxiaoanSnapshotMapper.create(new KunxiaoanSnapshot().init(projectVO, kunxiaoanProject.getId())); // 通过反射来扫描随手拍照片字段，把照片移动到最终路径 Field[] fields = projectVO.getClass().getDeclaredFields(); for (Field field: fields) { final String fieldName = field.getName(); if (fieldName.contains("Photo")) { field.setAccessible(true); try { String path = field.get(projectVO).toString(); if (StringUtils.isNotBlank(path)) { this.fileUploadUtils.moveTempFileToFinal(path); } } catch (Exception e) { log.error("反射：================",e); throw new ApiException(ApiException.E_FILE_SAVE_ERROR); } } } }

这段代码实现了一个创建项目快照的方法 creatSnapshot，分为以下几个步骤：

1. 通过 recordNumber 判断昆小安项目表是否存在数据，不存在就新增，存在就获取数据。
2. 如果项目表中不存在该项目，则新建一个昆小安项目实例，并将传入的 projectVO 转换成昆小安项目实例的属性，然后插入到昆小安项目表中。
3. 无论该项目是否已存在，都将传入的 projectVO 转换成昆小安快照实例的属性，并将昆小安项目的 id 作为外键插入到昆小安快照表中。
4. 最后通过反射来扫描随手拍照片字段，把照片移动到最终路径。

需要注意的是，该方法中使用了一些自定义的方法，如 init()、create() 和 moveTempFileToFinal()，这些方法的作用需要查看其实现代码才能确定。此外，该方法还抛出了 ApiException 异常，但是没有给出异常信息，需要进一步排查异常的原因。

相关问题

根据接口“”@FeignClient(name = "UserUgsApi", url = "${newbim.login-domain}") public interface IApplicationServicePlatformClient {@PostMapping("/ums/v1/feign/omp/project/search") ResultWrapper<QueryAllProject> listUserProject(@RequestHeader("BSP_TOKEN") String bspToken, @RequestHeader("BSP_USER_ID") String bspUserId, @RequestHeader("BSP_USER_ENV_ID") String bspUserEnvId, @RequestHeader("BSP_USER_TENANT") String bspUserTenant, @RequestBody ProjectCondition queryProjectDto);和代码“@Component @Slf4j public class ApplicationServicePlatformClientProxy { @Autowired private IApplicationServicePlatformClient applicationServicePlatformClient; public QueryAllProject listUserProject(String appId, String companyId, String designStatusList, String pageSize, ProjectCondition userId) { ResultWrapper<QueryAllProject> result = null; return result.getData(); } }”，修改下面代码：@Override public List<ProjectCountVO> projectCount(String beginTime, String endTime, Integer forceType, String projectId) { List<TaskTask> taskTaskList = this.listStatisticsTask(beginTime, endTime, forceType, projectId); if(CollectionUtil.isEmpty(taskTaskList)){ return Collections.emptyList(); } List<ProjectCountVO> result = new ArrayList<>(); Map<String, List<TaskTask>> projectTaskMap = taskTaskList.stream().collect(Collectors.groupingBy(TaskTask::getProjectId)); for (Map.Entry<String, List<TaskTask>> projectTaskEntry : projectTaskMap.entrySet()) { String currentProjectId = projectTaskEntry.getKey(); ProjectCountVO projectCountVO = new ProjectCountVO(); projectCountVO.setId(currentProjectId); // 查询项目名称 QueryAllProject queryAllProject = applicationServicePlatformClient.listUserProject(); projectCountVO.setName(projectName); List<TaskTask> taskList = projectTaskEntry.getValue(); projectCountVO.setTaskCount(taskList.size()); Integer problemCount = CollectionUtil.isEmpty(taskList) ? 0 : taskList.stream().collect(Collectors.summingInt(task-> Optional.ofNullable(task.getProblemNum()).orElse(0))); projectCountVO.setProblemCount(problemCount); result.add(projectCountVO); } return result; }

根据你提供的代码，需要将方法projectCount中的代码进行修改。其中，需要调用IApplicationServicePlatformClient接口中的listUserProject方法，获取所有项目信息。代码修改如下：

@Override
public List<ProjectCountVO> projectCount(String beginTime, String endTime, Integer forceType, String projectId) {
    List<TaskTask> taskTaskList = this.listStatisticsTask(beginTime, endTime, forceType, projectId);
    if(CollectionUtil.isEmpty(taskTaskList)){
        return Collections.emptyList();
    }
    List<ProjectCountVO> result = new ArrayList<>();
    Map<String, List<TaskTask>> projectTaskMap = taskTaskList.stream().collect(Collectors.groupingBy(TaskTask::getProjectId));
    for (Map.Entry<String, List<TaskTask>> projectTaskEntry : projectTaskMap.entrySet()) {
        String currentProjectId = projectTaskEntry.getKey();
        ProjectCountVO projectCountVO = new ProjectCountVO();
        projectCountVO.setId(currentProjectId);

        // 查询项目名称
        ResultWrapper<QueryAllProject> resultWrapper = applicationServicePlatformClient.listUserProject("BSP_TOKEN", "BSP_USER_ID", "BSP_USER_ENV_ID", "BSP_USER_TENANT", new ProjectCondition());
        if(resultWrapper.isSuccess()){
            QueryAllProject queryAllProject = resultWrapper.getData();
            List<ProjectVO> projectList = queryAllProject.getProjectList();
            for(ProjectVO project : projectList){
                if(project.getId().equals(currentProjectId)){
                    projectCountVO.setName(project.getName());
                    break;
                }
            }
        }

        List<TaskTask> taskList = projectTaskEntry.getValue();
        projectCountVO.setTaskCount(taskList.size());
        Integer problemCount = CollectionUtil.isEmpty(taskList) ? 0 : taskList.stream().collect(Collectors.summingInt(task-> Optional.ofNullable(task.getProblemNum()).orElse(0)));
        projectCountVO.setProblemCount(problemCount);
        result.add(projectCountVO);
    }
    return result;
}

需要调用listUserProject方法时，需要传入4个请求头参数，分别是BSP_TOKEN、BSP_USER_ID、BSP_USER_ENV_ID和BSP_USER_TENANT。另外，还需要传入一个空的ProjectCondition对象作为请求体参数。调用listUserProject方法后，需要判断请求是否成功，如果成功，则从返回结果中获取项目列表，遍历项目列表，查找当前项目的名称，并将名称设置到对应的ProjectCountVO对象中。最后将所有的ProjectCountVO对象添加到结果集中返回。

调用“@Resource private ApplicationServicePlatformClientProxy applicationServicePlatformClientProxy;”获取“projectName"修改下面代码：@Override public List<ProjectCountVO> projectCount(String beginTime, String endTime, Integer forceType, String projectId) { List<TaskTask> taskTaskList = this.listStatisticsTask(beginTime, endTime, forceType, projectId); if(CollectionUtil.isEmpty(taskTaskList)){ return Collections.emptyList(); } List<ProjectCountVO> result = new ArrayList<>(); Map<String, List<TaskTask>> projectTaskMap = taskTaskList.stream().collect(Collectors.groupingBy(TaskTask::getProjectId)); for (Map.Entry<String, List<TaskTask>> projectTaskEntry : projectTaskMap.entrySet()) { projectId = projectTaskEntry.getKey(); ProjectCountVO projectCountVO = new ProjectCountVO(); projectCountVO.setId(projectId); //查询项目名称 String projectName = Optional.ofNullable(projectTaskMap.get(projectId)).map(taskList -> taskList.get(0).getName()).orElse(""); projectCountVO.setName(projectName); List<TaskTask> taskList = projectTaskEntry.getValue(); projectCountVO.setTaskCount(taskList.size()); Integer problemCount = CollectionUtil.isEmpty(taskList) ? 0 : taskList.stream().collect(Collectors.summingInt(task-> Optional.ofNullable(task.getProblemNum()).orElse(0))); projectCountVO.setProblemCount(problemCount); result.add(projectCountVO); } return result; }

可以改成这样：

@Override
public List<ProjectCountVO> projectCount(String beginTime, String endTime, Integer forceType, String projectId) {
    List<TaskTask> taskTaskList = this.listStatisticsTask(beginTime, endTime, forceType, projectId);
    if(CollectionUtil.isEmpty(taskTaskList)){
        return Collections.emptyList();
    }

    List<ProjectCountVO> result = new ArrayList<>();
    Map<String, List<TaskTask>> projectTaskMap = taskTaskList.stream().collect(Collectors.groupingBy(TaskTask::getProjectId));

    for (Map.Entry<String, List<TaskTask>> projectTaskEntry : projectTaskMap.entrySet()) {
        projectId = projectTaskEntry.getKey();
        ProjectCountVO projectCountVO = new ProjectCountVO();
        projectCountVO.setId(projectId);

        // 查询项目名称
        String projectName = Optional.ofNullable(applicationServicePlatformClientProxy.getProjectById(projectId)).map(ProjectVO::getName).orElse("");
        projectCountVO.setName(projectName);

        List<TaskTask> taskList = projectTaskEntry.getValue();
        projectCountVO.setTaskCount(taskList.size());

        Integer problemCount = CollectionUtil.isEmpty(taskList) ? 0 : taskList.stream().collect(Collectors.summingInt(task-> Optional.ofNullable(task.getProblemNum()).orElse(0)));
        projectCountVO.setProblemCount(problemCount);

        result.add(projectCountVO);
    }
    return result;
}

其中，我们使用 `applicationServicePlatformClientProxy` 的 `getProjectById` 方法获取项目名称，并将其赋值给 `projectName` 变量。同时，我们将原来代码中的 `projectId` 参数改为局部变量，避免在循环中修改参数值带来的问题。