feat(ccdi-project): 实现批量查询和保存方法

ccdi-project/src/main/java/com/ruoyi/ccdi/project/service/impl/CcdiModelParamServiceImpl.java

@@ -6,8 +6,13 @@ import com.ruoyi.ccdi.project.domain.CcdiModelParam;
 import com.ruoyi.ccdi.project.domain.CcdiProject;
 import com.ruoyi.ccdi.project.domain.dto.ModelParamQueryDTO;
 import com.ruoyi.ccdi.project.domain.dto.ModelParamSaveDTO;
+import com.ruoyi.ccdi.project.domain.dto.ModelParamSaveAllDTO;
+import com.ruoyi.ccdi.project.domain.dto.ModelParamGroupDTO;
+import com.ruoyi.ccdi.project.domain.dto.ParamValueItem;
 import com.ruoyi.ccdi.project.domain.vo.ModelListVO;
 import com.ruoyi.ccdi.project.domain.vo.ModelParamVO;
+import com.ruoyi.ccdi.project.domain.vo.ModelParamAllVO;
+import com.ruoyi.ccdi.project.domain.vo.ModelGroupVO;
 import com.ruoyi.ccdi.project.mapper.CcdiModelParamMapper;
 import com.ruoyi.ccdi.project.mapper.CcdiProjectMapper;
 import com.ruoyi.ccdi.project.service.ICcdiModelParamService;
@@ -20,6 +25,7 @@ import org.springframework.transaction.annotation.Transactional;
 
 import jakarta.annotation.Resource;
 import java.util.ArrayList;
+import java.util.Comparator;
 import java.util.Date;
 import java.util.List;
 import java.util.Map;
@@ -225,4 +231,115 @@ public class CcdiModelParamServiceImpl implements ICcdiModelParamService {
 
         return count;
     }
+
+    @Override
+    public ModelParamAllVO selectAllParams(Long projectId) {
+        // 1. 参数验证
+        if (projectId == null) {
+            projectId = 0L;
+        }
+
+        // 2. 如果是项目查询,根据 configType 决定查询哪组参数
+        Long effectiveProjectId = projectId;
+        if (projectId > 0) {
+            CcdiProject project = projectMapper.selectById(projectId);
+            if (project == null) {
+                throw new ServiceException("项目不存在");
+            }
+            if ("default".equals(project.getConfigType())) {
+                effectiveProjectId = 0L;
+            }
+        }
+
+        // 3. 查询所有模型的参数
+        List<CcdiModelParam> allParams = modelParamMapper.selectByProjectId(effectiveProjectId);
+
+        // 4. 按模型分组
+        Map<String, List<CcdiModelParam>> groupedParams = allParams.stream()
+            .collect(Collectors.groupingBy(CcdiModelParam::getModelCode));
+
+        // 5. 转换为VO
+        ModelParamAllVO result = new ModelParamAllVO();
+        List<ModelGroupVO> models = new ArrayList<>();
+
+        groupedParams.forEach((modelCode, params) -> {
+            ModelGroupVO groupVO = new ModelGroupVO();
+            groupVO.setModelCode(modelCode);
+            groupVO.setModelName(params.get(0).getModelName());
+
+            List<ModelParamVO> paramVOs = params.stream()
+                .map(param -> {
+                    ModelParamVO vo = new ModelParamVO();
+                    BeanUtils.copyProperties(param, vo);
+                    return vo;
+                })
+                .collect(Collectors.toList());
+
+            groupVO.setParams(paramVOs);
+            models.add(groupVO);
+        });
+
+        // 6. 按模型编码排序(保证固定顺序)
+        models.sort(Comparator.comparing(ModelGroupVO::getModelCode));
+
+        result.setModels(models);
+        return result;
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void saveAllParams(ModelParamSaveAllDTO saveAllDTO) {
+        try {
+            // 1. 参数验证
+            if (saveAllDTO.getProjectId() == null) {
+                throw new ServiceException("项目ID不能为空");
+            }
+            if (saveAllDTO.getModels() == null || saveAllDTO.getModels().isEmpty()) {
+                throw new ServiceException("参数列表不能为空");
+            }
+
+            Long projectId = saveAllDTO.getProjectId();
+
+            // 2. 如果是项目保存,检查是否需要复制默认参数
+            if (projectId > 0) {
+                CcdiProject project = projectMapper.selectById(projectId);
+                if (project == null) {
+                    throw new ServiceException("项目不存在");
+                }
+
+                // 如果是首次保存（configType=default),需要复制所有模型的系统默认参数
+                if ("default".equals(project.getConfigType())) {
+                    for (ModelParamGroupDTO modelGroup : saveAllDTO.getModels()) {
+                        copyDefaultParamsToProject(projectId, modelGroup.getModelCode());
+                    }
+
+                    // 更新项目配置类型为 custom
+                    project.setConfigType("custom");
+                    projectMapper.updateById(project);
+                }
+            }
+
+            // 3. 批量更新所有模型的参数值
+            for (ModelParamGroupDTO modelGroup : saveAllDTO.getModels()) {
+                for (ParamValueItem item : modelGroup.getParams()) {
+                    int updated = modelParamMapper.updateParamValue(
+                        projectId,
+                        modelGroup.getModelCode(),
+                        item.getParamCode(),
+                        item.getParamValue()
+                    );
+                    if (updated == 0) {
+                        log.warn("参数不存在或未更新， modelCode={}, paramCode={}",
+                            modelGroup.getModelCode(), item.getParamCode());
+                    }
+                }
+            }
+
+        } catch (ServiceException e) {
+            throw e;
+        } catch (Exception e) {
+            log.error("批量保存模型参数失败", e);
+            throw new ServiceException("批量保存模型参数失败：" + e.getMessage());
+        }
+    }
 }