package com.ruoyi.publicity.controller;
|
|
import com.ruoyi.common.core.service.IConfigService;
|
import com.ruoyi.publicity.api.PublicityFacade;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiOperation;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.ObjectProvider;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.GetMapping;
|
import org.springframework.web.bind.annotation.PostMapping;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import java.util.LinkedHashMap;
|
import java.util.Map;
|
|
/**
|
* 宣教模块的 HTTP 入口：<b>宣教生成入口 + 开关/状态查询</b>。
|
*
|
* <h3>为什么这些端点是"新增"的（与出入院模块的关键区别）</h3>
|
* 出入院模块的 controller 是<b>把 ruoyi-admin 已有的端点搬进来</b>（URL 一个不变）；
|
* 而宣教在本仓库里<b>从来没有过 controller</b> —— 它原本只是
|
* {@code PatMedInhospServiceImpl#dealOutHospInfo} 内部的两段调用
|
* （入院宣教 L331-409、药品宣教 L411-444），迁出后也只到 Service 层为止。
|
* 因此本类的 URL 是<b>新定义</b>的，前端若要手动触发需要接新地址；
|
* 但"主流程自动触发"不受影响（那是 {@code RyTask} / {@code dealOutHospInfo} 走的门面调用）。
|
*
|
* <h3>端点清单</h3>
|
* <pre>
|
* POST /smartor/publicity/dealInHospPublicity 入院宣教（科室 type=4 / 病区 type=5）
|
* POST /smartor/publicity/dealMedicalPublicity 药品宣教（仅 sltd 站点，type=0）
|
* GET /smartor/publicity/status 开关与子开关状态（只读、不受开关拦截）
|
* </pre>
|
*
|
* <h3>⚠️ 开关的层级（两个开关，别混）</h3>
|
* <ol>
|
* <li>{@code sys_config: publicity.enabled} —— <b>模块级</b>开关，由
|
* {@link PublicityFacade#isEnabled()} 在运行时读（10 秒缓存）。
|
* 它<b>只</b>决定 {@link PublicityFacade} 是否把调用转发下去；
|
* 关闭时两个生成端点返回 0 并打 WARN。</li>
|
* <li>{@code sys_config: in.helibrary.switch} —— <b>入院宣教自身的业务开关</b>，
|
* 只有值等于 {@code "2"} 时入院宣教才真的执行。它在
|
* {@code PublicityServiceImpl} 内部读取，与模块开关无关。</li>
|
* </ol>
|
* 本类的 {@code /status} 会把两者分别如实报出来 —— 这两个开关是排查
|
* "为什么没发宣教"时最容易看错的地方。
|
*
|
* <h3>与出入院模块拦截器的一致性</h3>
|
* 两个生成端点由 {@code PublicityAvailabilityInterceptor} 在模块关闭时拦下并抛
|
* 明确的业务异常（而不是静默返回 0），与 {@code inhospvisit} 的做法一致；
|
* {@code /status} <b>刻意不挂拦截器</b> —— 模块关掉时你更需要能查到状态。
|
*/
|
@Slf4j
|
@Api(description = "宣教")
|
@RestController
|
@RequestMapping("/smartor/publicity")
|
public class PublicityController {
|
|
/** 出院随访「通知类任务」提前几天发（与出入院模块读同一个键） */
|
private static final String VISIT_EARLY_DAY_KEY = "visit.early.day";
|
|
/** 入院宣教自身的业务开关：只有等于 "2" 才执行（与 PublicityServiceImpl 内一致） */
|
private static final String HELIBRARY_SWITCH_KEY = "in.helibrary.switch";
|
|
/** 入院宣教业务开关的"开"值 */
|
private static final String HELIBRARY_SWITCH_ON = "2";
|
|
/**
|
* 本模块常驻门面。
|
* <p>
|
* ⚠️ 注入门面而不是 {@code PublicityService}：门面永远存在，
|
* 即使模块被开关关掉或没被打进应用，本 Controller 也<b>不会启动失败</b>，
|
* 只是调用降级并打 WARN。
|
*/
|
@Autowired
|
private PublicityFacade publicityFacade;
|
|
/**
|
* 参数配置服务（ruoyi-common 的接口，实现在 ruoyi-system）。
|
* <p>
|
* ⚠️ 用 {@code ObjectProvider} 惰性取：本模块只依赖 ruoyi-common，
|
* 在独立部署/测试等"容器里没有实现"的场景下不能因此启动失败。
|
*/
|
@Autowired
|
private ObjectProvider<IConfigService> configServiceProvider;
|
|
/**
|
* 入院宣教：科室维度（type=4）+ 病区维度（type=5）。
|
* <p>
|
* 逐行对应原 {@code PatMedInhospServiceImpl#dealOutHospInfo} L331-409 的调用部分：
|
* 原实现在主流程里直接调 {@code dealInHospPublicity(config)}，此处只是把它暴露成端点。
|
* <p>
|
* 返回处理记录数（与原实现的日志用值同源），便于手工触发时看到结果。
|
*/
|
@ApiOperation("入院宣教（科室 type=4 / 病区 type=5）")
|
@PostMapping("/dealInHospPublicity")
|
public int dealInHospPublicity() {
|
return publicityFacade.dealInHospPublicity(readVisitEarlyDay());
|
}
|
|
/**
|
* 药品宣教：按患者的 {@code medicalCode} 逐个药品编码匹配长期宣教任务（type=0）。
|
* <p>
|
* 仅 {@code spring.profiles.active == "sltd"} 时执行，其它站点由
|
* {@code PublicityServiceImpl} 直接返回 0（站点判断<b>不在</b>本 Controller，
|
* 与原实现位置一致）。
|
*/
|
@ApiOperation("药品宣教（仅 sltd 站点，type=0）")
|
@PostMapping("/dealMedicalPublicity")
|
public int dealMedicalPublicity() {
|
return publicityFacade.dealMedicalPublicity(readVisitEarlyDay());
|
}
|
|
/**
|
* 开关与子开关状态（<b>只读</b>，不触发任何业务）。
|
* <p>
|
* 专为排查"为什么没发宣教"而设：把两个层级的开关、以及"实现是否装配"
|
* 分别报出来，避免把"模块关了"误判成"没配长期宣教任务"。
|
*/
|
@ApiOperation("查询宣教模块开关状态")
|
@GetMapping("/status")
|
public Map<String, Object> status() {
|
Map<String, Object> m = new LinkedHashMap<>();
|
boolean moduleEnabled = publicityFacade.isEnabled();
|
m.put("moduleEnabled", moduleEnabled);
|
m.put("switchKey", "publicity.enabled");
|
m.put("switchValue", readConfig("publicity.enabled"));
|
String helibrary = readConfig(HELIBRARY_SWITCH_KEY);
|
m.put("inHospPublicitySwitchKey", HELIBRARY_SWITCH_KEY);
|
m.put("inHospPublicitySwitchValue", helibrary);
|
m.put("inHospPublicityOn", HELIBRARY_SWITCH_ON.equals(helibrary));
|
m.put("note", "moduleEnabled=false 时两个生成端点会被拦截；"
|
+ "inHospPublicityOn=false 时入院宣教整块不执行，与模块开关无关");
|
return m;
|
}
|
|
/**
|
* 读 {@code sys_config: visit.early.day}（与出入院模块 {@code InhospVisitController} 同一做法）。
|
* <p>
|
* 取不到（没有实现 / 读库异常）时返回 {@code null} 并打 WARN ——
|
* 原实现在这种情况下拿到的也是 {@code null}，故语义一致。
|
*/
|
private String readVisitEarlyDay() {
|
return readConfig(VISIT_EARLY_DAY_KEY);
|
}
|
|
/**
|
* 读任意 {@code sys_config} 键；没有实现或读失败时返回 {@code null} 并打 WARN。
|
*/
|
private String readConfig(String key) {
|
if (configServiceProvider == null) {
|
return null;
|
}
|
try {
|
IConfigService svc = configServiceProvider.stream().findFirst().orElse(null);
|
if (svc == null) {
|
log.warn("【宣教】容器里没有 IConfigService 实现，{} 按未配置（null）处理。", key);
|
return null;
|
}
|
return svc.selectConfigByKey(key);
|
} catch (Exception e) {
|
log.warn("【宣教】读取 {} 失败，按未配置（null）处理：{}", key, e.toString());
|
return null;
|
}
|
}
|
}
|
