package com.ruoyi.datacollection.collect;
|
|
import com.ruoyi.common.core.service.dto.InhospPositionRecord;
|
import com.ruoyi.common.core.service.dto.SltdGatherReq;
|
import com.ruoyi.datacollection.domain.HnDataGatherVO;
|
import com.ruoyi.datacollection.domain.ServiceSLTDDeptReqVO;
|
import com.ruoyi.datacollection.domain.ServiceSLTDInhospReqVO;
|
import com.ruoyi.datacollection.domain.ServiceSLTDInhospResDTO;
|
import com.ruoyi.datacollection.service.IHNGatherPatArchiveService;
|
import com.ruoyi.common.core.service.IIcd10Service;
|
import com.ruoyi.datacollection.service.IServiceSLTDHealthcareRecordService;
|
import com.ruoyi.datacollection.service.IXHGatherPatArchiveService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import java.time.LocalDateTime;
|
import java.util.Date;
|
import java.util.List;
|
|
/**
|
* 4 个 HIS 采集器的聚合入口（原 smartor 的 HisGatherApiBridge） —— 四个 HIS 采集实现的归属方。
|
*
|
* <h3>方向说明</h3>
|
* 契约声明在 {@code ruoyi-common}、实现放在 smartor：因为
|
* <b>采集实现目前仍在 smartor</b>（新华 / 河南 / 省立同德·南华附一 / 疾病字典），
|
* 而 {@code ruoyi-datacollection} 不能依赖 smartor（否则新模块被单体绑死，模块化倒退）。
|
* Spring 运行期注入本实现。
|
*
|
* <h3>⚠️ 本类必须保持"纯转发"</h3>
|
* 只做两件事：<b>契约 DTO → 内部 VO 的逐字段搬运</b>、<b>调用既有 Service</b>。
|
* <b>不得</b>在这里加业务判断、补默认值、吞异常或改调用顺序 ——
|
* 移植前后的行为差异都要能在 {@code HisDataCollectionServiceImpl} 一处看清。
|
*
|
* <h3>将来动作（分阶段搬迁）</h3>
|
* 采集实现按批搬进 {@code ruoyi-datacollection} 后，对应方法从本类与
|
* {@link HisGatherApi} 一起删除；全部搬完时本类整体删除。
|
* 见 {@code doc/数据采集模块化_调研与实施方案.md}。
|
*/
|
@Slf4j
|
@Component
|
public class HisGatherCollectors {
|
|
@Autowired
|
private IXHGatherPatArchiveService ixhGatherPatArchiveService;
|
|
@Autowired
|
private IHNGatherPatArchiveService ihnGatherPatArchiveService;
|
|
@Autowired
|
private IServiceSLTDHealthcareRecordService serviceSLTDHealthcareRecordService;
|
|
@Autowired
|
private IIcd10Service iIcd10Service;
|
|
public void gatherXhInhospRecords(String cry, LocalDateTime startTime, LocalDateTime endTime) {
|
// 原 RyTask#dealHisData 直调 ixhGatherPatArchiveService.getInHospDataGather(cry, start, end)
|
ixhGatherPatArchiveService.getInHospDataGather(cry, startTime, endTime);
|
}
|
|
public void gatherHnRecords(Date startTime, Date endTime) {
|
// 原 RyTask#dealHisData 组装 HnDataGatherVO（只有 startTime / endTime 两个字段）后调用
|
HnDataGatherVO hnDataGatherVO = new HnDataGatherVO();
|
hnDataGatherVO.setStartTime(startTime);
|
hnDataGatherVO.setEndTime(endTime);
|
ihnGatherPatArchiveService.hnDataGather(hnDataGatherVO);
|
}
|
|
public Boolean gatherSltdDeptWardArea(SltdGatherReq req) {
|
ServiceSLTDDeptReqVO deptReqVO = new ServiceSLTDDeptReqVO();
|
deptReqVO.setOrgId(req.getOrgId());
|
deptReqVO.setCampusIds(req.getCampusIds());
|
return serviceSLTDHealthcareRecordService.queryDeptWardAreaInfoList(deptReqVO);
|
}
|
|
public Boolean gatherSltdHospUser(SltdGatherReq req) {
|
return serviceSLTDHealthcareRecordService.queryHospUserInfoList(toInhospReq(req));
|
}
|
|
public int gatherSltdHealthcareRecords(SltdGatherReq req) {
|
// 原调用点丢弃返回值（只关心落库副作用）；这里把条数透出，供编排判断接口是否触顶截断
|
List<ServiceSLTDInhospResDTO> records = serviceSLTDHealthcareRecordService.queryHealthcareRecordList(toInhospReq(req));
|
return records == null ? 0 : records.size();
|
}
|
|
public List<InhospPositionRecord> querySltdInhospPosition(SltdGatherReq req) {
|
return serviceSLTDHealthcareRecordService.queryInhospPosition(toInhospReq(req));
|
}
|
|
public int gatherIcd10() {
|
return iIcd10Service.queryAddIcd10();
|
}
|
|
/**
|
* 契约 DTO → 内部 VO 的<b>逐字段</b>搬运（契约 DTO 刻意只保留编排真正会设置的字段）。
|
*/
|
private ServiceSLTDInhospReqVO toInhospReq(SltdGatherReq req) {
|
ServiceSLTDInhospReqVO reqVO = new ServiceSLTDInhospReqVO();
|
reqVO.setOrgId(req.getOrgId());
|
reqVO.setCampusId(req.getCampusId());
|
reqVO.setEncounterTimeStart(req.getEncounterTimeStart());
|
reqVO.setEncounterTimeEnd(req.getEncounterTimeEnd());
|
reqVO.setStartHeadTime(req.getStartHeadTime());
|
reqVO.setStartTailTime(req.getStartTailTime());
|
reqVO.setPreOutHospitalHeadDate(req.getPreOutHospitalHeadDate());
|
reqVO.setPreOutHospitalTailDate(req.getPreOutHospitalTailDate());
|
reqVO.setStatusList(req.getStatusList());
|
reqVO.setHealthcareRecordTypeList(req.getHealthcareRecordTypeList());
|
reqVO.setHealthcareRecordNo(req.getHealthcareRecordNo());
|
return reqVO;
|
}
|
}
|
