Merge remote-tracking branch 'origin/dev_2.0.0' into dev_2.0.0

dev_2.0.0
xueqingkun
commit ef03a59de4

@ -1,5 +1,6 @@
package com.supervision.service; package com.supervision.service;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.supervision.model.DiagnosisQaRecord; import com.supervision.model.DiagnosisQaRecord;
import com.baomidou.mybatisplus.extension.service.IService; import com.baomidou.mybatisplus.extension.service.IService;
import com.supervision.vo.ask.DiagnosisQaRecordHistoryResVO; import com.supervision.vo.ask.DiagnosisQaRecordHistoryResVO;
@ -14,5 +15,5 @@ import java.util.List;
public interface DiagnosisQaRecordService extends IService<DiagnosisQaRecord> { public interface DiagnosisQaRecordService extends IService<DiagnosisQaRecord> {
List<DiagnosisQaRecordHistoryResVO> queryByProcessId(String processId,Integer pageNum,Integer pageSize); IPage<DiagnosisQaRecordHistoryResVO> queryByProcessId(String processId, Integer pageNum, Integer pageSize);
} }

@ -1,8 +1,10 @@
package com.supervision.service.impl; package com.supervision.service.impl;
import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil; import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.supervision.model.AskTemplateQuestionLibrary; import com.supervision.model.AskTemplateQuestionLibrary;
@ -24,39 +26,43 @@ import java.util.function.Function;
import java.util.stream.Collectors; import java.util.stream.Collectors;
/** /**
* @author flevance * @author flevance
* @description vp_diagnosis_qa_record()Service * @description vp_diagnosis_qa_record()Service
* @createDate 2023-10-20 17:19:21 * @createDate 2023-10-20 17:19:21
*/ */
@Service @Service
@RequiredArgsConstructor @RequiredArgsConstructor
public class DiagnosisQaRecordServiceImpl extends ServiceImpl<DiagnosisQaRecordMapper, DiagnosisQaRecord> public class DiagnosisQaRecordServiceImpl extends ServiceImpl<DiagnosisQaRecordMapper, DiagnosisQaRecord>
implements DiagnosisQaRecordService{ implements DiagnosisQaRecordService {
private final CommonDicService commonDicService; private final CommonDicService commonDicService;
private final AskTemplateQuestionLibraryService askTemplateQuestionLibraryService; private final AskTemplateQuestionLibraryService askTemplateQuestionLibraryService;
@Override @Override
public List<DiagnosisQaRecordHistoryResVO> queryByProcessId(String processId,Integer pageNum,Integer pageSize) { public IPage<DiagnosisQaRecordHistoryResVO> queryByProcessId(String processId, Integer pageNum, Integer pageSize) {
Page<DiagnosisQaRecord> page = this.lambdaQuery().eq(DiagnosisQaRecord::getProcessId, processId).page(new Page<>(pageNum, pageSize)); Page<DiagnosisQaRecord> page = this.lambdaQuery().eq(DiagnosisQaRecord::getProcessId, processId).page(new Page<>(pageNum, pageSize));
List<DiagnosisQaRecordHistoryResVO> resVOS = BeanUtil.copyToList(page.getRecords(), DiagnosisQaRecordHistoryResVO.class);
// 根据questionLibraryId找到对应的字典 // 根据questionLibraryId找到对应的字典
Set<String> questionIdList = page.getRecords().stream().map(DiagnosisQaRecord::getQuestionLibraryId).filter(StrUtil::isNotBlank).collect(Collectors.toSet()); Set<String> questionIdList = page.getRecords().stream().map(DiagnosisQaRecord::getQuestionLibraryId).filter(StrUtil::isNotBlank).collect(Collectors.toSet());
List<AskTemplateQuestionLibrary> askTemplateQuestionLibraryList = askTemplateQuestionLibraryService.listByIds(questionIdList); if (CollUtil.isNotEmpty(questionIdList)){
Map<String, Long> questionLibraryMap = askTemplateQuestionLibraryList.stream().collect(Collectors.toMap(AskTemplateQuestionLibrary::getId, AskTemplateQuestionLibrary::getDictId)); List<AskTemplateQuestionLibrary> askTemplateQuestionLibraryList = askTemplateQuestionLibraryService.listByIds(questionIdList);
List<CommonDic> commonDicList = commonDicService.lambdaQuery().eq(CommonDic::getGroupCode, "AQT").list(); Map<String, Long> questionLibraryMap = askTemplateQuestionLibraryList.stream().collect(Collectors.toMap(AskTemplateQuestionLibrary::getId, AskTemplateQuestionLibrary::getDictId));
Map<Long, CommonDic> dicMap = commonDicList.stream().collect(Collectors.toMap(CommonDic::getId, Function.identity())); List<CommonDic> commonDicList = commonDicService.lambdaQuery().eq(CommonDic::getGroupCode, "AQT").list();
List<DiagnosisQaRecordHistoryResVO> resVOS = BeanUtil.copyToList(page.getRecords(), DiagnosisQaRecordHistoryResVO.class); Map<Long, CommonDic> dicMap = commonDicList.stream().collect(Collectors.toMap(CommonDic::getId, Function.identity()));
for (DiagnosisQaRecordHistoryResVO resVO : resVOS) {
Long dictId = questionLibraryMap.get(resVO.getQuestionLibraryId()); for (DiagnosisQaRecordHistoryResVO resVO : resVOS) {
if (ObjectUtil.isNotEmpty(dictId)){ Long dictId = questionLibraryMap.get(resVO.getQuestionLibraryId());
CommonDic commonDic = dicMap.get(dictId); if (ObjectUtil.isNotEmpty(dictId)) {
resVO.setCommonDic(commonDic); CommonDic commonDic = dicMap.get(dictId);
resVO.setCommonDic(commonDic);
}
} }
} }
// 分页转换 // 分页转换
Page<DiagnosisQaRecordHistoryResVO> resultPage = new Page<>(page.getPages(), page.getSize(), page.getTotal()); IPage<DiagnosisQaRecordHistoryResVO> resultPage = new Page<>(page.getPages(), page.getSize(), page.getTotal());
resultPage.setRecords(resVOS); resultPage.setRecords(resVOS);
return resVOS; return resultPage;
} }
} }

@ -1,6 +1,7 @@
package com.supervision.controller; package com.supervision.controller;
import cn.hutool.core.util.StrUtil; import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.supervision.exception.BusinessException; import com.supervision.exception.BusinessException;
import com.supervision.model.DiagnosisQaRecord; import com.supervision.model.DiagnosisQaRecord;
import com.supervision.service.DiagnosisQaRecordService; import com.supervision.service.DiagnosisQaRecordService;
@ -24,7 +25,7 @@ public class DiagnosisQaRecordController {
private final DiagnosisQaRecordService diagnosisQaRecordService; private final DiagnosisQaRecordService diagnosisQaRecordService;
@ApiOperation("查询问诊历史记录") @ApiOperation("查询问诊历史记录")
@GetMapping("queryHistoryList") @GetMapping("queryHistoryList")
public List<DiagnosisQaRecordHistoryResVO> queryDiagnosisHistoryQaList(String processId,Integer pageNum,Integer pageSize){ public IPage<DiagnosisQaRecordHistoryResVO> queryDiagnosisHistoryQaList(String processId, Integer pageNum, Integer pageSize){
if (StrUtil.isEmpty(processId)){ if (StrUtil.isEmpty(processId)){
throw new BusinessException("processId is empty"); throw new BusinessException("processId is empty");
} }

Loading…
Cancel
Save