records = hisGatherApi.querySltdInhospPosition(req);
InhospPositionRecord current = pickInHospRecord(records, serialnum);
if (current == null) {
// 接口按在院状态过滤后没有返回记录：该患者当前已不在"入院"状态。
// 这里只计数、不改库（状态翻转是出院采集的职责），更不拿空值去覆盖位置。
log.warn("【在院信息刷新】HIS 中该患者已不在院（返回为空），位置保持不动，等出院采集处理状态："
+ "inhospid={}, serialnum={}, patname={}", row.getInhospid(), serialnum, row.getPatname());
return Outcome.NOT_IN_HOSP;
}
return applyIfDiff(row, current) ? Outcome.CHANGED : Outcome.UNCHANGED;
}
/**
* 从返回记录里取"在院"的那一条。
*
* 正常只会返回 1 条；这里仍做一层防御：只接受状态为在院的记录，
* 一条都不匹配则返回 {@code null}（按"已不在院"处理），
* 绝不拿一条状态不明的记录去覆盖库内位置。
*/
private InhospPositionRecord pickInHospRecord(List records, String serialnum) {
if (records == null || records.isEmpty()) {
return null;
}
for (InhospPositionRecord record : records) {
if (record == null) {
continue;
}
String status = StringUtils.trim(record.getHealthcareRecordStatus());
if (STATUS_CODE_IN_HOSP.equals(status)) {
return record;
}
log.warn("【在院信息刷新】返回记录状态不是在院，已忽略：serialnum={}, status={}", serialnum, status);
}
return null;
}
/**
* 与库内值逐字段比对，只把"变化的字段"写回；没有任何变化则不动库（也不刷新 update_time）。
*
* @return 是否实际执行了更新
*/
private boolean applyIfDiff(PatMedInhosp row, InhospPositionRecord current) {
PatMedInhosp update = new PatMedInhosp();
update.setInhospid(row.getInhospid());
StringBuilder changedFields = new StringBuilder();
boolean diff = false;
// 科室：有值才更新（口径：科室有值更新科室，病区有值更新病区，互不牵连）
if (current.getDeptId() != null) {
String deptCode = String.valueOf(current.getDeptId());
String old = StringUtils.trimToEmpty(row.getDeptcode());
if (!deptCode.equals(old)) {
update.setDeptcode(deptCode);
changedFields.append("deptcode[").append(old).append("→").append(deptCode).append("] ");
diff = true;
}
}
if (StringUtils.isNotBlank(current.getDeptName())) {
String old = StringUtils.trimToEmpty(row.getDeptname());
if (!current.getDeptName().equals(old)) {
update.setDeptname(current.getDeptName());
changedFields.append("deptname[").append(old).append("→").append(current.getDeptName()).append("] ");
diff = true;
}
}
// 病区：code 与 id 同值（既有采集口径就是两个字段都写 areaId）
if (current.getAreaId() != null) {
String areaId = String.valueOf(current.getAreaId());
String oldCode = StringUtils.trimToEmpty(row.getHospitaldistrictcode());
if (!areaId.equals(oldCode)) {
update.setHospitaldistrictcode(areaId);
changedFields.append("hospitaldistrictcode[").append(oldCode).append("→").append(areaId).append("] ");
diff = true;
}
String oldAreaId = StringUtils.trimToEmpty(row.getHospitaldistrictid());
if (!areaId.equals(oldAreaId)) {
update.setHospitaldistrictid(areaId);
changedFields.append("hospitaldistrictid[").append(oldAreaId).append("→").append(areaId).append("] ");
diff = true;
}
}
if (StringUtils.isNotBlank(current.getAreaName())) {
String old = StringUtils.trimToEmpty(row.getHospitaldistrictname());
if (!current.getAreaName().equals(old)) {
update.setHospitaldistrictname(current.getAreaName());
changedFields.append("hospitaldistrictname[").append(old).append("→").append(current.getAreaName()).append("] ");
diff = true;
}
}
// 床位：按业务口径"接口给什么就是什么，为空则清空"。
// ⚠️ mapper 里"空串=置 null、null=不改动"，所以清空必须显式传空串。
String apiBed = StringUtils.trim(current.getBedNumber());
String dbBed = StringUtils.trimToEmpty(row.getBedNo());
if (StringUtils.isBlank(apiBed)) {
if (StringUtils.isNotBlank(dbBed)) {
update.setBedNo("");
changedFields.append("bed_no[").append(dbBed).append("→(清空)] ");
diff = true;
}
} else if (!apiBed.equals(dbBed)) {
update.setBedNo(apiBed);
changedFields.append("bed_no[").append(dbBed).append("→").append(apiBed).append("] ");
diff = true;
}
if (!diff) {
return false;
}
update.setUpdateTime(new Date());
int rows = inhospVisitFacade.updatePatMedInhosp(update);
if (rows <= 0) {
log.warn("【在院信息刷新】更新未生效（影响行数 {}）：inhospid={}, serialnum={}, 待改字段：{}",
rows, row.getInhospid(), row.getSerialnum(), changedFields);
return false;
}
log.info("【在院信息刷新】已更新：inhospid={}, serialnum={}, patname={}, 变更：{}",
row.getInhospid(), row.getSerialnum(), row.getPatname(), changedFields);
return true;
}
/**
* 抢占本轮运行锁。
*
* Redis 不可用时退化为无锁执行：每天一次的数据刷新不该因为缓存故障整体不跑，
* 最坏情况是手工触发与定时任务叠着跑 —— 而本功能是幂等比对，叠跑只会多打几条日志。
*/
private boolean tryLock() {
try {
if (Boolean.TRUE.equals(redisCache.hasKey(RUN_LOCK_KEY))) {
return false;
}
redisCache.setCacheObject(RUN_LOCK_KEY, String.valueOf(System.currentTimeMillis()),
RUN_LOCK_MINUTES, TimeUnit.MINUTES);
return true;
} catch (Exception e) {
log.warn("【在院信息刷新】Redis 运行锁不可用（{}），本轮无锁执行", e.getMessage());
return true;
}
}
private void unlock() {
try {
redisCache.deleteObject(RUN_LOCK_KEY);
} catch (Exception e) {
log.warn("【在院信息刷新】释放运行锁失败：{}", e.getMessage());
}
}
/**
* 单条患者的处置结果
*/
private enum Outcome {
/**
* 位置有变化并已写回
*/
CHANGED,
/**
* 与库内一致，未改动
*/
UNCHANGED,
/**
* HIS 里该患者已不在"入院"状态（接口返回为空），库内位置保持不动
*/
NOT_IN_HOSP,
/**
* 拿不到可用信息（无流水号 / 返回记录状态不对）
*/
SKIPPED
}
}