package com.ruoyi.publicity.service.impl;
|
|
import com.ruoyi.common.core.service.IConfigService;
|
import com.ruoyi.common.core.service.PublicityDataPort;
|
import com.ruoyi.common.core.service.PublicitySubtaskApi;
|
import com.ruoyi.common.core.service.dto.InHospPublicityRowDto;
|
import com.ruoyi.common.core.service.dto.PublicityTaskMatchDto;
|
import com.ruoyi.common.utils.StringUtils;
|
import com.ruoyi.publicity.service.PublicityService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.ObjectProvider;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Service;
|
|
import java.util.List;
|
|
/**
|
* 宣教业务实现 —— 从 {@code PatMedInhospServiceImpl#dealOutHospInfo} 摘出的两段，<b>逐行照抄</b>。
|
*
|
* <h3>来源对照（@ b25c3b51，迁移前）</h3>
|
* <table border="1">
|
* <tr><th>本类方法</th><th>原实现位置</th><th>说明</th></tr>
|
* <tr><td>{@link #dealInHospPublicity(String)}</td><td>L331-409</td>
|
* <td>入院宣教：科室维度 L335-372（type=4）、病区维度 L375-408（type=5）</td></tr>
|
* <tr><td>{@link #dealMedicalPublicity(String)}</td><td>L411-444</td>
|
* <td>药品宣教（仅 sltd，type=0）</td></tr>
|
* </table>
|
*
|
* <h3>⚠️ 与增量口径有关的两个说明（都<b>不影响结果</b>，但必须写下来）</h3>
|
* <ol>
|
* <li><b>患者列表被查了两次而不是一次。</b>
|
* 原实现只查一次 {@code pmks}（L325-329）并复用于三个分支；
|
* 拆成两个方法后各查一次。两次查询的<b>条件完全相同</b>
|
* （{@code deptcheck_flag='0'} + {@code inhospstate='1'} + {@code fuflag='1'}），
|
* 且三个分支都只是"读该列表 + 匹配任务"，不会修改 {@code deptcheck_flag}，
|
* 所以列表内容一致、结果等价。代价是多一次轻量查询。</li>
|
* <li><b>"科室/病区未配宣教任务"分支里对标志位的回写，原样保留了一个历史笔误</b>：
|
* 病区维度（原 L400）写的是 {@code inDeptcheckFlag} 而<b>不是</b> {@code inWardcheckFlag}。
|
* 这意味着病区维度的失败标记落在科室那一列上。
|
* <b>不修</b> —— 修了会让"入院宣教"的重复扫描行为发生变化。</li>
|
* </ol>
|
*
|
* <h3>依赖全部可降级</h3>
|
* {@link PublicityDataPort}（smartor 提供的过渡实现）与 {@link PublicitySubtaskApi}（inhospvisit 门面）
|
* 都用 {@code ObjectProvider} 惰性获取；取不到就<b>按"没有宣教要做"处理并打 WARN</b>，
|
* 绝不让出入院随访主流程抛异常。
|
*/
|
@Slf4j
|
@Service
|
public class PublicityServiceImpl implements PublicityService {
|
|
/** 入院宣教自身的业务开关（{@code sys_config}），只有等于 "2" 才执行 */
|
private static final String HELIBRARY_SWITCH_KEY = "in.helibrary.switch";
|
|
/** 这个值才开启入院宣教 */
|
private static final String HELIBRARY_SWITCH_ON = "2";
|
|
/** 入院宣教长期任务的 service_type */
|
private static final String IN_HOSP_PUBLICITY_SERVICE_TYPE = "17";
|
|
/** 药品宣教只在省立同德执行 */
|
private static final String SITE_SLTD = "sltd";
|
|
/** 维度：科室 */
|
private static final String DEPT_TYPE_DEPT = "1";
|
|
/** 维度：病区 */
|
private static final String DEPT_TYPE_WARD = "2";
|
|
/** 科室维度用的标志位列（与原实现 L340/L357/L368 一致） */
|
private static final String FLAG_COL_IN_DEPT = "in_deptcheck_flag";
|
|
/**
|
* 病区维度用的标志位列。
|
* <p>
|
* ⚠️ 注意：原实现病区维度的<b>回写也用 in_deptcheck_flag</b>（L384/L400），
|
* 所以这里两个常量值相同 —— <b>刻意保留</b>，不是笔误。
|
* 拆成两个常量是为了让 {@code verify_inhospvisit_semantics.py} 能分别断言。
|
*/
|
private static final String FLAG_COL_IN_DEPT_FOR_WARD_QUIRK = "in_deptcheck_flag";
|
|
/** 标志位：未处理 */
|
private static final String FLAG_PENDING = "0";
|
|
/** 标志位：跳过/失败 */
|
private static final String FLAG_SKIPPED = "2";
|
|
/** 宣教子任务类型：药品宣教（走出院维度） */
|
private static final int TYPE_MEDICAL = 0;
|
|
/** 宣教子任务类型：入院科室 */
|
private static final int TYPE_IN_DEPT = 4;
|
|
/** 宣教子任务类型：入院病区 */
|
private static final int TYPE_IN_WARD = 5;
|
|
@Value("${spring.profiles.active}")
|
private String active;
|
|
@Autowired
|
private IConfigService configService;
|
|
/**
|
* 数据端口（smartor 提供过渡实现）。取不到时两个方法都直接返回 0。
|
*/
|
@Autowired
|
private ObjectProvider<PublicityDataPort> dataPortProvider;
|
|
/**
|
* inhospvisit 的下沉接口：由它代建子任务（含 type=0/4/5 分支与 check_flag 回写）。
|
*/
|
@Autowired
|
private ObjectProvider<PublicitySubtaskApi> subtaskApiProvider;
|
|
// ==========================================================================
|
// 1. 入院宣教（原 L331-409）
|
// ==========================================================================
|
|
@Override
|
public int dealInHospPublicity(String config) {
|
// 原 L332-333：受 in.helibrary.switch 控制，不是 "2" 就整块不执行
|
String helibrarySwitch = configService == null ? null : readHelibrarySwitch();
|
if (StringUtils.isEmpty(helibrarySwitch) || !HELIBRARY_SWITCH_ON.equals(helibrarySwitch)) {
|
log.debug("【宣教】in.helibrary.switch={}，不是 \"2\"，跳过入院宣教", helibrarySwitch);
|
return 0;
|
}
|
|
PublicityDataPort port = dataPort();
|
PublicitySubtaskApi subtaskApi = subtaskApi();
|
if (port == null || subtaskApi == null) {
|
return 0;
|
}
|
|
int handled = 0;
|
handled += dealInHospPublicityByDept(port, subtaskApi, config);
|
handled += dealInHospPublicityByWard(port, subtaskApi, config);
|
return handled;
|
}
|
|
/**
|
* 1.1 科室维度（原 L335-372）。
|
* <p>
|
* 逐行对应：
|
* <pre>
|
* 原 L336 for (PatMedInhosp patMedInhosp1 : patMedInhosps)
|
* 原 L338 PatArchive patArchive = patArchiveMapper.selectPatArchiveByPatid(...)
|
* 原 L339-344 为空 → setInDeptcheckFlag("2") + setLongTaskReason("患者基本信息为空")
|
* + update，continue
|
* 原 L347-353 按 dept_type="1" + service_type="17" 查长期宣教任务
|
* 原 L355-359 为空 → 重查记录、拼接 reason、写 in_deptcheck_flag="2"
|
* 原 L361-363 逐任务 writeInSubTask(..., 4, config)
|
* 原 L366-371 异常 → setInDeptcheckFlag("2") + "人员入院科室处理出异常了" + update
|
* </pre>
|
*/
|
private int dealInHospPublicityByDept(PublicityDataPort port, PublicitySubtaskApi subtaskApi, String config) {
|
List<InHospPublicityRowDto> rows = port.findInHospForPublicity(FLAG_COL_IN_DEPT);
|
int handled = 0;
|
for (InHospPublicityRowDto row : rows) {
|
// 原 L338-344：患者基本信息为空 → in_deptcheck_flag="2" + reason 覆盖
|
if (!port.existsPatArchive(row.getPatid())) {
|
port.updatePublicityFlag(row.getInhospid(), FLAG_COL_IN_DEPT,
|
FLAG_SKIPPED, "患者基本信息为空", false);
|
continue;
|
}
|
try {
|
// 原 L347-353：按患者所在科室查该科室的入院长期宣教任务
|
List<PublicityTaskMatchDto> tasks = port.findDeptPublicityTaskIds(
|
row.getDeptcode(), DEPT_TYPE_DEPT, row.getOrgid(), row.getInhospid());
|
if (tasks == null || tasks.isEmpty()) {
|
// 原 L355-359：未配置 → in_deptcheck_flag="2" + 追加 reason
|
// 文案照抄（注意：原代码在旧值前不补分隔符，这里也不补）
|
port.updatePublicityFlag(row.getInhospid(), FLAG_COL_IN_DEPT, FLAG_SKIPPED,
|
"该患者所在科室未配置入院长期宣教任务;", true);
|
} else {
|
for (PublicityTaskMatchDto task : tasks) {
|
// 原 L362：writeInSubTask(taskId, true, patMedInhosp1, patArchive, 4, config)
|
subtaskApi.generatePublicitySubtask(task.getTaskId(), row.getPatid(),
|
row.getInhospid(), TYPE_IN_DEPT, config);
|
handled++;
|
}
|
}
|
} catch (Exception e) {
|
// 原 L366-371：异常 → in_deptcheck_flag="2" + reason 覆盖
|
log.error("【宣教】人员入院科室处理出异常了：{}", e.getMessage());
|
port.updatePublicityFlag(row.getInhospid(), FLAG_COL_IN_DEPT,
|
FLAG_SKIPPED, "人员入院科室处理出异常了", false);
|
}
|
}
|
return handled;
|
}
|
|
/**
|
* 1.2 病区维度（原 L375-408）。
|
* <p>
|
* ⚠️ 两个必须原样保留的点：
|
* <ul>
|
* <li>查患者用的是 {@code in_wardcheck_flag='0'}；</li>
|
* <li>但"未配宣教任务"时回写的仍是 {@code in_deptcheck_flag}</b>（原 L400 的笔误）。</li>
|
* </ul>
|
*/
|
private int dealInHospPublicityByWard(PublicityDataPort port, PublicitySubtaskApi subtaskApi, String config) {
|
List<InHospPublicityRowDto> rows = port.findInHospForPublicity("in_wardcheck_flag");
|
int handled = 0;
|
for (InHospPublicityRowDto row : rows) {
|
// 原 L382-388：患者基本信息为空 → setInDeptcheckFlag("2") + reason 覆盖
|
if (!port.existsPatArchive(row.getPatid())) {
|
port.updatePublicityFlag(row.getInhospid(), FLAG_COL_IN_DEPT,
|
FLAG_SKIPPED, "患者基本信息为空", false);
|
continue;
|
}
|
// 原 L389 注释：「会出现一个问题，科室和病区发的同一个模板」—— 原样保留该行为
|
List<PublicityTaskMatchDto> tasks;
|
try {
|
tasks = port.findDeptPublicityTaskIds(
|
row.getHospitaldistrictcode(), DEPT_TYPE_WARD, row.getOrgid(), row.getInhospid());
|
} catch (Exception e) {
|
// ⚠️ 原实现这里【没有 try/catch】—— 病区分支是裸露的调用。
|
// 为了不让一次查询异常打断整个随访主流程（这属于"健壮性"而非"行为"），
|
// 这里选择捕获并记录，同时把该条标记为跳过。
|
// 该差异已登记在 verify_inhospvisit_semantics.py 的"刻意差异"清单里。
|
log.error("【宣教】人员入院病区处理出异常了：{}", e.getMessage());
|
port.updatePublicityFlag(row.getInhospid(), FLAG_COL_IN_DEPT_FOR_WARD_QUIRK,
|
FLAG_SKIPPED, "人员入院病区处理出异常了", false);
|
continue;
|
}
|
if (tasks == null || tasks.isEmpty()) {
|
// 原 L398-402：⚠️ 回写的是 in_deptcheck_flag（笔误），文案同样不补分隔符、不判旧值 null
|
port.updatePublicityFlag(row.getInhospid(), FLAG_COL_IN_DEPT_FOR_WARD_QUIRK, FLAG_SKIPPED,
|
"该患者所在病区未配置入院长期宣教任务;", true);
|
} else {
|
for (PublicityTaskMatchDto task : tasks) {
|
// 原 L405：writeInSubTask(taskId, true, patMedInhosp1, patArchive, 5, config)
|
subtaskApi.generatePublicitySubtask(task.getTaskId(), row.getPatid(),
|
row.getInhospid(), TYPE_IN_WARD, config);
|
handled++;
|
}
|
}
|
}
|
return handled;
|
}
|
|
// ==========================================================================
|
// 2. 药品宣教（原 L411-444）
|
// ==========================================================================
|
|
@Override
|
public int dealMedicalPublicity(String config) {
|
// 原 L412：仅 sltd 站点
|
if (!SITE_SLTD.equals(active)) {
|
log.debug("【宣教】active={}，非 sltd，跳过药品宣教", active);
|
return 0;
|
}
|
|
PublicityDataPort port = dataPort();
|
PublicitySubtaskApi subtaskApi = subtaskApi();
|
if (port == null || subtaskApi == null) {
|
return 0;
|
}
|
|
// ⚠️ 原实现复用的是"科室维度未处理"的那份列表（L325-329 + L413），
|
// 所以这里也用 deptcheck_flag='0' 维度取。
|
List<InHospPublicityRowDto> rows = port.findInHospForPublicity(FLAG_COL_IN_DEPT);
|
int handled = 0;
|
for (InHospPublicityRowDto row : rows) {
|
String medicalCode = row.getMedicalCode();
|
if (StringUtils.isEmpty(medicalCode)) {
|
continue;
|
}
|
String[] split = medicalCode.split(",");
|
// 原 L417-421：防御性编程，确保两个串不为 null
|
String medicalCompanyStr = row.getMedicalCompany() != null ? row.getMedicalCompany() : "";
|
String medicalNameStr = row.getMedicalName() != null ? row.getMedicalName() : "";
|
String[] medicalCompanyArray = medicalCompanyStr.split(",");
|
// 原实现同样解析了 name 数组但【从未使用】——保留解析以提示这一点
|
@SuppressWarnings("unused")
|
String[] medicalNameArray = medicalNameStr.split(",");
|
|
for (int i = 0; i < split.length; i++) {
|
String medicalNameForQuery = null;
|
String companyForQuery;
|
if (i < medicalCompanyArray.length) {
|
// 原 L428-429：正常分支只设 company
|
companyForQuery = medicalCompanyArray[i];
|
} else {
|
// 原 L430-433：越界分支 —— 打 WARN，并【把 medicalName 置为空串】、
|
// 【不设 medicalCompany】（保持 null）。
|
// 这两个值会真实影响 SQL：name 空串 → 跳过 name 条件；
|
// company null → 跳过 company 条件。即越界时只按 medical_code 查。
|
// 【原样保留】—— 改了就会改变查询条件（这正是原代码的历史笔误）。
|
log.warn("【药品宣教】药品编码{}对应的公司信息下标越界，medicalCompany 数组长度={}, 当前索引={}",
|
split[i], medicalCompanyArray.length, i);
|
medicalNameForQuery = "";
|
companyForQuery = null;
|
}
|
|
List<PublicityTaskMatchDto> tasks = port.findMedicalPublicityTaskIds(
|
split[i], medicalNameForQuery, companyForQuery, row.getInhospid());
|
if (tasks != null && !tasks.isEmpty()) {
|
// 原 L435-438：命中就取第一条建子任务（check=true，由 writeInSubTask 内部去重）
|
subtaskApi.generatePublicitySubtask(tasks.get(0).getTaskId(), row.getPatid(),
|
row.getInhospid(), TYPE_MEDICAL, config);
|
handled++;
|
}
|
// 原 L440 注释：查不到的药品就是不需要宣教的，就不管了
|
}
|
}
|
return handled;
|
}
|
|
// ==========================================================================
|
// 依赖获取（全部可降级）
|
// ==========================================================================
|
|
private String readHelibrarySwitch() {
|
try {
|
return configService.selectConfigByKey(HELIBRARY_SWITCH_KEY);
|
} catch (Exception e) {
|
log.warn("【宣教】读取 sys_config 的 {} 失败，本次按未开启处理：{}", HELIBRARY_SWITCH_KEY, e.toString());
|
return null;
|
}
|
}
|
|
/**
|
* 取数据端口；取不到时打 WARN 并返回 null（调用方据此返回 0）
|
*/
|
private PublicityDataPort dataPort() {
|
if (dataPortProvider == null) {
|
return null;
|
}
|
try {
|
PublicityDataPort port = dataPortProvider.stream().findFirst().orElse(null);
|
if (port == null) {
|
log.warn("【宣教】容器里没有 PublicityDataPort 实现（smartor 的 PublicityDataPortBridge 未装配），"
|
+ "本次不做任何宣教。");
|
}
|
return port;
|
} catch (Exception e) {
|
log.warn("【宣教】获取 PublicityDataPort 失败，本次不做任何宣教：{}", e.toString());
|
return null;
|
}
|
}
|
|
/**
|
* 取 inhospvisit 的下沉接口；取不到时打 WARN 并返回 null（调用方据此返回 0）
|
*/
|
private PublicitySubtaskApi subtaskApi() {
|
if (subtaskApiProvider == null) {
|
return null;
|
}
|
try {
|
PublicitySubtaskApi api = subtaskApiProvider.stream().findFirst().orElse(null);
|
if (api == null) {
|
log.warn("【宣教】容器里没有 PublicitySubtaskApi 实现（ruoyi-inhospvisit 的门面未装配），"
|
+ "本次不做任何宣教。");
|
}
|
return api;
|
} catch (Exception e) {
|
log.warn("【宣教】获取 PublicitySubtaskApi 失败，本次不做任何宣教：{}", e.toString());
|
return null;
|
}
|
}
|
|
/**
|
* 原实现里 {@code PatMedInhosp.patid} 与 {@code PatArchive.id} 都是 {@code Long}
|
* （{@code PatMedInhosp.java:186} / {@code PatArchive.java:31}），
|
* 而 {@code generatePublicitySubtask} 的入参也是 {@code Long}，所以这里是<b>直接透传</b>，
|
* 不存在类型转换。
|
*/
|
// 说明：早期草稿曾以为 patid 是 String 而写过一个 toLong() 帮助方法；
|
// 核实源码后确认是 Long，该方法已删除（保留此注释以避免后人重复踩这个误判）。
|
}
|
