package jnpf.bizcommon.audit.service.entry;
|
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.jdbc.core.JdbcTemplate;
|
import org.springframework.stereotype.Component;
|
|
import java.util.Map;
|
import java.util.concurrent.ConcurrentHashMap;
|
|
/**
|
* 「操作入口」解析：用户是从哪个菜单点进来的。
|
*
|
* <p><b>为什么不按 modelId 反查</b>：一个表单模型可以挂多个菜单——实测 modelId
|
* {@code 846320770681526725} 对应 4 个菜单（待取样沉降菌/浮游菌/悬浮粒子/表面微生物测试）。
|
* 反查只能取其中一个，写进审计就是<b>记错事实</b>。所以入口必须由请求携带
|
* （前端全局拦截器注入 {@code Jnpf-Menu-Id} → 平台 AUDIT-P1 补丁塞进 {@code auditCtx.menuId}），
|
* 本类只负责把 id 翻译成当时的名字。
|
*
|
* <p>缓存口径与 {@code AuditFormRegistry} 同族：只缓存确定性结果（空串 = 确定地查不到），
|
* 瞬时故障不缓存（L061 ①）——一次连接抖动若被永久负缓存，该菜单从此到重启前都没有名字。
|
*
|
* <p><b>返回 null 的三种成因由调用方区分</b>：menuId 为空（请求没带）、确定地查不到、瞬时故障。
|
* 本类只保证「查不到就返回 null，绝不编一个名字」；「没带」与「带了但查不到」写成两种
|
* {@code entrySource} 留痕，是编排侧（Task 6）的事——共用一个表示就会遮住一处漏记。
|
*/
|
@Slf4j
|
@Component
|
public class AuditEntryResolver {
|
|
/** 入口类型：菜单。预留 FORM / FLOW 等，用于解释 entry_id 指向哪张表。 */
|
public static final String TYPE_MENU = "MENU";
|
|
private final Map<String, CacheValue> cache = new ConcurrentHashMap<String, CacheValue>();
|
|
@Autowired
|
private JdbcTemplate jdbcTemplate;
|
|
@Value("${audit.layer0.metadata-cache-ttl-ms:300000}")
|
private long ttlMs = 300_000L;
|
|
/** 菜单名；menuId 为空、查不到、或瞬时故障时返回 null（调用方据此写 entrySource）。 */
|
public String resolveMenuName(String menuId) {
|
if (menuId == null || menuId.trim().isEmpty()) {
|
return null;
|
}
|
String key = menuId.trim();
|
CacheValue cached = cache.get(key);
|
if (cached != null && ttlMs > 0L
|
&& System.currentTimeMillis() - cached.createdAt < ttlMs) {
|
return cached.value.isEmpty() ? null : cached.value;
|
}
|
String name;
|
try {
|
// 排除已删菜单：菜单被删后 f_id 仍是可追溯的事实，但它的名字不该再被当成"当时的入口名"
|
// 写进新记录。f_delete_mark 在 PG 里是 integer，未删除时为 NULL 或 0。
|
name = jdbcTemplate.queryForObject(
|
"SELECT f_full_name FROM base_module WHERE f_id = ? "
|
+ "AND (f_delete_mark IS NULL OR f_delete_mark <> 1) LIMIT 1",
|
String.class, key);
|
} catch (org.springframework.dao.EmptyResultDataAccessException e) {
|
// 确定性：这个 menuId 没有菜单行，再查一万次也一样
|
put(key, "");
|
return null;
|
} catch (Throwable t) {
|
log.warn("[AUDIT-L0] 反查菜单名失败（瞬时，不缓存）menuId={} err={}", key, t.toString());
|
return null;
|
}
|
String normalized = name == null ? "" : name.trim();
|
put(key, normalized);
|
return normalized.isEmpty() ? null : normalized;
|
}
|
|
private void put(String key, String value) {
|
if (ttlMs > 0L) {
|
cache.put(key, new CacheValue(value));
|
}
|
}
|
|
private static final class CacheValue {
|
private final String value;
|
private final long createdAt = System.currentTimeMillis();
|
|
private CacheValue(String value) {
|
this.value = value;
|
}
|
}
|
}
|
