package jnpf.bizcommon.audit.service.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import jnpf.audit.AuditConsts;
|
import jnpf.audit.AuditApiConsts;
|
import jnpf.base.UserInfo;
|
import jnpf.bizcommon.audit.entity.AuditEventEntity;
|
import jnpf.bizcommon.audit.entity.model.AuditEventDetailVO;
|
import jnpf.bizcommon.audit.entity.model.AuditFieldDiffViewVO;
|
import jnpf.bizcommon.audit.entity.model.AuditEventListVO;
|
import jnpf.bizcommon.audit.entity.model.AuditOperationGroupRow;
|
import jnpf.bizcommon.audit.entity.model.AuditPageQuery;
|
import jnpf.bizcommon.audit.entity.model.DmsFolderAuditDetailVO;
|
import jnpf.bizcommon.audit.entity.model.DmsFolderAuditPageQuery;
|
import jnpf.bizcommon.audit.mapper.AuditEventMapper;
|
import jnpf.bizcommon.audit.mapper.AuditQueryMapper;
|
import jnpf.bizcommon.audit.service.AuditFieldDiffViewService;
|
import jnpf.bizcommon.audit.service.AuditFormRegistry;
|
import jnpf.bizcommon.audit.service.AuditQueryService;
|
import jnpf.bizcommon.audit.service.support.AuditQueryResponseSanitizer;
|
import jnpf.bizcommon.audit.service.support.AuditEventCategories;
|
import jnpf.base.vo.PageListVO;
|
import jnpf.base.vo.PaginationVO;
|
import jnpf.exception.DataException;
|
import jnpf.util.JsonUtil;
|
import jnpf.util.UserProvider;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.util.StringUtils;
|
|
import java.util.ArrayList;
|
import java.util.Collections;
|
import java.util.LinkedHashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
/** 审计事件查询服务；写入侧完成物理合并，查询侧仅按 operationId 组织展示关系。 */
|
@Service
|
public class AuditQueryServiceImpl implements AuditQueryService {
|
|
private static final String SIGNATURE_TARGET_TABLE = "lims_sign";
|
private static final String DMS_APP = "jnpf-dms";
|
private static final String DMS_MODULE = "DMS";
|
private static final String DMS_FOLDER_TYPE = "DMS_FOLDER";
|
private static final String DMS_FOLDER_TABLE = "dms_folders";
|
/** timeline 全量上限（spec：LIMIT 500） */
|
private static final int TIMELINE_LIMIT = 500;
|
/** 列表只下发前 3 条子表标题 + 总数——保持「列表不含 extra 正文」的敏感面约定。 */
|
private static final int LIST_SUB_TITLE_LIMIT = 3;
|
/** 分页大小上限（Step 2 契约：强制 pageSize<=100） */
|
private static final long MAX_PAGE_SIZE = 100L;
|
private static final long DEFAULT_PAGE_SIZE = 20L;
|
|
@Autowired
|
private AuditQueryMapper auditQueryMapper;
|
|
@Autowired
|
private AuditEventMapper auditEventMapper;
|
|
@Autowired
|
private AuditFormRegistry auditFormRegistry;
|
|
@Autowired
|
private AuditFieldDiffViewService auditFieldDiffViewService;
|
|
@Override
|
public PageListVO<AuditEventListVO> page(AuditPageQuery query) {
|
long pageSize = query.getPageSize();
|
if (pageSize <= 0) {
|
pageSize = DEFAULT_PAGE_SIZE;
|
} else if (pageSize > MAX_PAGE_SIZE) {
|
pageSize = MAX_PAGE_SIZE;
|
}
|
long currentPage = query.getCurrentPage();
|
if (currentPage <= 0) {
|
currentPage = 1L;
|
}
|
// Codex 批次三a Minor#3：OFFSET 溢出防护——currentPage 传超大值（如 Long.MAX_VALUE）时
|
// (currentPage-1)*pageSize 会 long 乘法溢出成负数，拼进 SQL LIMIT/OFFSET 语义未定义。
|
// Math.multiplyExact 显式检测溢出，命中则降级为空页（total 仍按条件正常返回，不查明细页）。
|
long offset;
|
boolean offsetOverflow;
|
try {
|
offset = Math.multiplyExact(currentPage - 1, pageSize);
|
offsetOverflow = false;
|
} catch (ArithmeticException ex) {
|
offset = 0L;
|
offsetOverflow = true;
|
}
|
|
QueryWrapper<AuditEventEntity> ew = buildWrapper(query);
|
ew.and(wrapper -> wrapper
|
.isNull("biz_type")
|
.or()
|
.ne("biz_type", DMS_FOLDER_TYPE));
|
long total = auditQueryMapper.countOperations(ew);
|
List<AuditEventListVO> list;
|
if (offsetOverflow) {
|
list = Collections.emptyList();
|
} else {
|
List<AuditOperationGroupRow> groups = auditQueryMapper.selectOperationPage(ew, offset, pageSize);
|
list = buildOperationRows(groups);
|
}
|
|
// 回写生效后的分页参数供返回包装读取（对照 LimsBizLogController：Pagination 承载 total，
|
// JsonUtil.getJsonToBean 窄化成 PaginationVO——同一惯例，仅挪到 Service 层以贴合本任务
|
// 字面执行的 Controller 签名）
|
query.setCurrentPage(currentPage);
|
query.setPageSize(pageSize);
|
query.setTotal(total);
|
|
PageListVO<AuditEventListVO> vo = new PageListVO<>();
|
vo.setList(list);
|
vo.setPagination(JsonUtil.getJsonToBean(query, PaginationVO.class));
|
return vo;
|
}
|
|
@Override
|
public PageListVO<AuditEventListVO> signaturePage(AuditPageQuery query) {
|
AuditPageQuery safeQuery = query == null ? new AuditPageQuery() : query;
|
safeQuery.setTargetTable(SIGNATURE_TARGET_TABLE);
|
|
long pageSize = safeQuery.getPageSize();
|
if (pageSize <= 0) {
|
pageSize = DEFAULT_PAGE_SIZE;
|
} else if (pageSize > MAX_PAGE_SIZE) {
|
pageSize = MAX_PAGE_SIZE;
|
}
|
long currentPage = safeQuery.getCurrentPage();
|
if (currentPage <= 0) {
|
currentPage = 1L;
|
}
|
|
long offset;
|
boolean offsetOverflow;
|
try {
|
offset = Math.multiplyExact(currentPage - 1, pageSize);
|
offsetOverflow = false;
|
} catch (ArithmeticException ex) {
|
offset = 0L;
|
offsetOverflow = true;
|
}
|
|
QueryWrapper<AuditEventEntity> ew = buildWrapper(safeQuery);
|
long total = auditQueryMapper.countEvents(ew);
|
List<AuditEventListVO> list = new ArrayList<>();
|
if (!offsetOverflow) {
|
for (AuditEventEntity event : auditQueryMapper.selectEventPage(ew, offset, pageSize)) {
|
list.add(toListVo(event));
|
}
|
}
|
|
safeQuery.setCurrentPage(currentPage);
|
safeQuery.setPageSize(pageSize);
|
safeQuery.setTotal(total);
|
|
PageListVO<AuditEventListVO> vo = new PageListVO<>();
|
vo.setList(list);
|
vo.setPagination(JsonUtil.getJsonToBean(safeQuery, PaginationVO.class));
|
return vo;
|
}
|
|
@Override
|
public AuditEventDetailVO detail(Long id) {
|
AuditEventEntity entity = auditEventMapper.selectById(id);
|
if (entity == null) {
|
throw new DataException("审计事件不存在：id=" + id);
|
}
|
return toDetailVo(entity);
|
}
|
|
@Override
|
public AuditEventDetailVO signatureDetail(Long id) {
|
AuditEventEntity entity = auditQueryMapper.selectEventDetail(id, SIGNATURE_TARGET_TABLE);
|
if (entity == null) {
|
throw new DataException("电子签名审计事件不存在：id=" + id);
|
}
|
return toDetailVo(entity);
|
}
|
|
@Override
|
public List<AuditEventListVO> timeline(String targetId) {
|
List<AuditOperationGroupRow> groups = groupRows(
|
auditQueryMapper.selectTimeline(targetId, TIMELINE_LIMIT));
|
// target_id 只属于业务目标行；签名等关联事件使用自己的 target_id，需按 operation_id 补查。
|
return buildOperationRows(groups);
|
}
|
|
@Override
|
public PageListVO<AuditEventListVO> dmsFolderPage(DmsFolderAuditPageQuery query) {
|
DmsFolderAuditPageQuery safeQuery = query == null ? new DmsFolderAuditPageQuery() : query;
|
long pageSize = normalizedPageSize(safeQuery.getPageSize());
|
long currentPage = safeQuery.getCurrentPage() <= 0 ? 1L : safeQuery.getCurrentPage();
|
long offset;
|
boolean overflow;
|
try {
|
offset = Math.multiplyExact(currentPage - 1, pageSize);
|
overflow = false;
|
} catch (ArithmeticException ex) {
|
offset = 0L;
|
overflow = true;
|
}
|
|
QueryWrapper<AuditEventEntity> ew = dmsFolderWrapper(safeQuery);
|
long total = auditQueryMapper.countOperations(ew);
|
List<AuditEventListVO> list = overflow ? Collections.emptyList()
|
: buildDmsFolderOperationRows(
|
auditQueryMapper.selectOperationPage(ew, offset, pageSize));
|
safeQuery.setCurrentPage(currentPage);
|
safeQuery.setPageSize(pageSize);
|
safeQuery.setTotal(total);
|
PageListVO<AuditEventListVO> result = new PageListVO<>();
|
result.setList(list);
|
result.setPagination(JsonUtil.getJsonToBean(safeQuery, PaginationVO.class));
|
return result;
|
}
|
|
@Override
|
public DmsFolderAuditDetailVO dmsFolderDetail(Long id) {
|
AuditEventEntity business = auditEventMapper.selectOne(dmsFolderBaseWrapper()
|
.eq("id", id));
|
if (business == null) {
|
throw new DataException("DMS 文件夹审计事件不存在：id=" + id);
|
}
|
DmsFolderAuditDetailVO result = new DmsFolderAuditDetailVO();
|
AuditEventDetailVO businessDetail = toDetailVo(business);
|
applyDmsFolderDiffDisplays(businessDetail, business.getExtra());
|
result.setBusiness(businessDetail);
|
if (StringUtils.hasText(business.getOperationId())) {
|
List<AuditEventEntity> related = auditEventMapper.selectList(
|
new QueryWrapper<AuditEventEntity>()
|
.eq("tenant_id", currentTenantId())
|
.eq("operation_id", business.getOperationId())
|
.eq("app_name", DMS_APP)
|
.eq("biz_module", DMS_MODULE)
|
.eq("biz_type", DMS_FOLDER_TYPE)
|
.in("event_category", AuditEventCategories.PRIMARY_SIGN,
|
AuditEventCategories.REVIEW_SIGN)
|
.orderByAsc("event_time", "id"));
|
List<AuditEventDetailVO> signatures = new ArrayList<>(related.size());
|
for (AuditEventEntity event : related) {
|
signatures.add(toDetailVo(event));
|
}
|
result.setSignatures(signatures);
|
}
|
return result;
|
}
|
|
@Override
|
public List<AuditEventListVO> dmsFolderTimeline(String folderId) {
|
if (!StringUtils.hasText(folderId)) {
|
throw new DataException("文件夹 ID 不能为空");
|
}
|
List<AuditEventEntity> events = auditEventMapper.selectList(dmsFolderBaseWrapper()
|
.eq("target_id", folderId.trim())
|
.orderByAsc("id")
|
.last("LIMIT " + TIMELINE_LIMIT));
|
return buildDmsFolderOperationRows(groupRows(events));
|
}
|
|
private List<AuditEventListVO> buildDmsFolderOperationRows(
|
List<AuditOperationGroupRow> groups) {
|
if (groups.isEmpty()) {
|
return Collections.emptyList();
|
}
|
List<String> gids = new ArrayList<>(groups.size());
|
for (AuditOperationGroupRow group : groups) {
|
gids.add(group.getGid());
|
}
|
return buildOperationRows(groups, auditQueryMapper.selectDmsFolderByOperationGids(
|
gids, currentTenantId(), DMS_APP, DMS_MODULE, DMS_FOLDER_TYPE));
|
}
|
|
private List<AuditEventListVO> buildOperationRows(List<AuditOperationGroupRow> groups) {
|
if (groups.isEmpty()) {
|
return Collections.emptyList();
|
}
|
List<String> gids = new ArrayList<>(groups.size());
|
for (AuditOperationGroupRow group : groups) {
|
gids.add(group.getGid());
|
}
|
return buildOperationRows(groups, auditQueryMapper.selectByOperationGids(gids));
|
}
|
|
/** 将已物理合并的事件挂到 BUSINESS 主行；这里不得再次组合 fieldDiffs。 */
|
private List<AuditEventListVO> buildOperationRows(List<AuditOperationGroupRow> groups,
|
List<AuditEventEntity> events) {
|
Map<String, List<AuditEventEntity>> eventsByGid = new LinkedHashMap<>();
|
for (AuditEventEntity event : events) {
|
String gid = operationGid(event);
|
eventsByGid.computeIfAbsent(gid, ignored -> new ArrayList<>()).add(event);
|
}
|
|
List<AuditEventListVO> result = new ArrayList<>(groups.size());
|
for (AuditOperationGroupRow group : groups) {
|
List<AuditEventEntity> related = eventsByGid.get(group.getGid());
|
if (related == null) {
|
continue;
|
}
|
AuditEventEntity business = null;
|
List<AuditEventListVO> signatures = new ArrayList<>(2);
|
for (AuditEventEntity event : related) {
|
if (AuditEventCategories.BUSINESS.equals(event.getEventCategory())) {
|
business = event;
|
} else if (AuditEventCategories.PRIMARY_SIGN.equals(event.getEventCategory())
|
|| AuditEventCategories.REVIEW_SIGN.equals(event.getEventCategory())) {
|
signatures.add(toListVo(event));
|
}
|
}
|
if (business == null) {
|
continue;
|
}
|
AuditEventListVO main = toListVo(business);
|
main.setSubEvents(signatures);
|
main.setSigned(!signatures.isEmpty());
|
result.add(main);
|
}
|
return result;
|
}
|
|
private List<AuditOperationGroupRow> groupRows(List<AuditEventEntity> events) {
|
Map<String, AuditOperationGroupRow> groups = new LinkedHashMap<>();
|
for (AuditEventEntity event : events) {
|
String gid = operationGid(event);
|
AuditOperationGroupRow group = groups.get(gid);
|
if (group == null) {
|
group = new AuditOperationGroupRow();
|
group.setGid(gid);
|
group.setGrpTime(event.getEventTime());
|
groups.put(gid, group);
|
}
|
}
|
return new ArrayList<>(groups.values());
|
}
|
|
private String operationGid(AuditEventEntity event) {
|
return StringUtils.hasText(event.getOperationId()) ? event.getOperationId() : event.getClientEventId();
|
}
|
|
private QueryWrapper<AuditEventEntity> buildWrapper(AuditPageQuery query) {
|
QueryWrapper<AuditEventEntity> ew = new QueryWrapper<>();
|
if (query.getStartTime() != null) {
|
ew.ge("event_time", query.getStartTime());
|
}
|
if (query.getEndTime() != null) {
|
ew.le("event_time", query.getEndTime());
|
}
|
if (StringUtils.hasText(query.getOperatorName())) {
|
ew.like("operator_name", query.getOperatorName());
|
}
|
if (StringUtils.hasText(query.getAppName())) {
|
ew.eq("app_name", query.getAppName());
|
}
|
// Codex 批次三a Important#1：biz_module 是用户视角的业务应用筛选（app_name 层 0 固定为 jnpf-visualdev）
|
if (StringUtils.hasText(query.getBizModule())) {
|
ew.eq("biz_module", query.getBizModule());
|
}
|
if (StringUtils.hasText(query.getEventType())) {
|
ew.eq("event_type", query.getEventType());
|
}
|
if (StringUtils.hasText(query.getActionCode())) {
|
ew.eq("action_code", query.getActionCode());
|
}
|
if (StringUtils.hasText(query.getTargetTable())) {
|
ew.eq("target_table", query.getTargetTable());
|
}
|
if (StringUtils.hasText(query.getBizCode())) {
|
ew.eq("biz_code", query.getBizCode());
|
}
|
if (StringUtils.hasText(query.getBizType())) {
|
ew.eq("biz_type", query.getBizType());
|
}
|
if (StringUtils.hasText(query.getKeyword())) {
|
ew.like("field_diffs", query.getKeyword());
|
}
|
return ew;
|
}
|
|
private QueryWrapper<AuditEventEntity> dmsFolderWrapper(DmsFolderAuditPageQuery query) {
|
QueryWrapper<AuditEventEntity> ew = dmsFolderBaseWrapper();
|
if (query.getStartTime() != null) {
|
ew.ge("event_time", query.getStartTime());
|
}
|
if (query.getEndTime() != null) {
|
ew.le("event_time", query.getEndTime());
|
}
|
if (StringUtils.hasText(query.getOperatorName())) {
|
ew.like("operator_name", query.getOperatorName().trim());
|
}
|
if (StringUtils.hasText(query.getActionCode())) {
|
ew.eq("action_code", query.getActionCode().trim());
|
}
|
if (StringUtils.hasText(query.getFolderId())) {
|
ew.eq("target_id", query.getFolderId().trim());
|
}
|
if (StringUtils.hasText(query.getKeyword())) {
|
String keyword = query.getKeyword().trim();
|
ew.and(item -> item.like("record_title", keyword)
|
.or().like("field_diffs", keyword)
|
.or().like("extra", keyword));
|
}
|
if (query.getSigned() != null) {
|
String exists = "SELECT 1 FROM audit_events sign_event "
|
+ "WHERE sign_event.tenant_id = audit_events.tenant_id "
|
+ "AND sign_event.operation_id = audit_events.operation_id "
|
+ "AND sign_event.app_name = 'jnpf-dms' "
|
+ "AND sign_event.biz_module = 'DMS' "
|
+ "AND sign_event.biz_type = 'DMS_FOLDER' "
|
+ "AND sign_event.event_category IN ('PRIMARY_SIGN','REVIEW_SIGN')";
|
ew.apply((query.getSigned() ? "EXISTS (" : "NOT EXISTS (") + exists + ")");
|
}
|
return ew;
|
}
|
|
private QueryWrapper<AuditEventEntity> dmsFolderBaseWrapper() {
|
return new QueryWrapper<AuditEventEntity>()
|
.eq("tenant_id", currentTenantId())
|
.eq("app_name", DMS_APP)
|
.eq("biz_module", DMS_MODULE)
|
.eq("biz_type", DMS_FOLDER_TYPE)
|
.eq("target_table", DMS_FOLDER_TABLE)
|
.eq("event_category", AuditEventCategories.BUSINESS);
|
}
|
|
private long normalizedPageSize(long pageSize) {
|
if (pageSize <= 0) {
|
return DEFAULT_PAGE_SIZE;
|
}
|
return Math.min(pageSize, MAX_PAGE_SIZE);
|
}
|
|
private String currentTenantId() {
|
try {
|
UserInfo user = UserProvider.getUser();
|
if (user != null && StringUtils.hasText(user.getTenantId())) {
|
return user.getTenantId().trim();
|
}
|
} catch (RuntimeException | LinkageError ignored) {
|
// Use the platform single-tenant sentinel when no request user is available.
|
}
|
return AuditApiConsts.DEFAULT_TENANT_ID;
|
}
|
|
private AuditEventListVO toListVo(AuditEventEntity e) {
|
AuditEventListVO vo = new AuditEventListVO();
|
vo.setId(e.getId());
|
vo.setOperationId(e.getOperationId());
|
vo.setClientEventId(e.getClientEventId());
|
vo.setEventTime(e.getEventTime());
|
vo.setTenantId(e.getTenantId());
|
vo.setOperatorId(e.getOperatorId());
|
vo.setOperatorName(e.getOperatorName());
|
vo.setOperatorOrgId(e.getOperatorOrgId());
|
vo.setAppName(e.getAppName());
|
vo.setBizModule(e.getBizModule());
|
vo.setParentBizModule(e.getParentBizModule());
|
vo.setIp(e.getIp());
|
vo.setIpRegion(e.getIpRegion());
|
vo.setBrowser(e.getBrowser());
|
vo.setOs(e.getOs());
|
vo.setRequestUri(e.getRequestUri());
|
vo.setEventType(e.getEventType());
|
if (AuditEventCategories.REVIEW_SIGN.equals(e.getEventCategory())) {
|
vo.setSignatureRole("REVIEW");
|
} else if (AuditEventCategories.PRIMARY_SIGN.equals(e.getEventCategory())) {
|
vo.setSignatureRole("PRIMARY");
|
}
|
vo.setActionCode(e.getActionCode());
|
vo.setActionLabel(e.getActionLabel());
|
vo.setSourceLayer(e.getSourceLayer());
|
vo.setTargetTable(e.getTargetTable());
|
vo.setTargetId(AuditQueryResponseSanitizer.hidesTargetId(e.getTargetTable())
|
? null : e.getTargetId());
|
vo.setBizType(e.getBizType());
|
vo.setBizCode(e.getBizCode());
|
vo.setDiffCount(computeDiffCount(e.getFieldDiffs()));
|
vo.setReason(e.getReason());
|
vo.setRecordTitle(e.getRecordTitle());
|
vo.setEntryType(e.getEntryType());
|
vo.setEntryId(e.getEntryId());
|
vo.setEntryName(e.getEntryName());
|
vo.setCreatedAt(e.getCreatedAt());
|
// 子事件保留自身签名标记；BUSINESS 主行会在组装后按关联签名重新赋值。
|
vo.setSigned(AuditConsts.TYPE_E_SIGNATURE.equals(e.getEventType()));
|
applySubTitles(vo, e.getExtra());
|
applyDmsFolderNames(vo, e);
|
return vo;
|
}
|
|
private void applyDmsFolderNames(AuditEventListVO vo, AuditEventEntity event) {
|
if (!DMS_FOLDER_TYPE.equals(event.getBizType()) || !DMS_FOLDER_TABLE.equals(event.getTargetTable())
|
|| !StringUtils.hasText(event.getDataSnapshot())) {
|
return;
|
}
|
try {
|
Map<String, Object> snapshot = JsonUtil.stringToMap(event.getDataSnapshot());
|
if (snapshot != null) {
|
vo.setFolderName(text(snapshot.get("name")));
|
vo.setParentFolderName(text(snapshot.get("parentName")));
|
}
|
} catch (Throwable ignored) {
|
// Snapshot summaries are optional and must never fail the audit list.
|
}
|
}
|
|
private void applyDmsFolderDiffDisplays(AuditEventDetailVO detail, String extraJson) {
|
if (detail == null || detail.getFieldDiffList() == null
|
|| !StringUtils.hasText(extraJson)) {
|
return;
|
}
|
try {
|
Map<String, Object> extra = JsonUtil.stringToMap(extraJson);
|
String oldParentName = folderParentDisplay(extra, "oldParentName", "oldPath");
|
String newParentName = folderParentDisplay(extra, "newParentName", "newPath");
|
for (AuditFieldDiffViewVO diff : detail.getFieldDiffList()) {
|
if (diff != null && "parent_id".equalsIgnoreCase(diff.getField())) {
|
if (StringUtils.hasText(oldParentName)) {
|
diff.setOldDisplay(oldParentName);
|
}
|
if (StringUtils.hasText(newParentName)) {
|
diff.setNewDisplay(newParentName);
|
}
|
}
|
}
|
} catch (Throwable ignored) {
|
// Display-name enrichment is best-effort; raw UUID evidence remains available.
|
}
|
}
|
|
private static String folderParentDisplay(Map<String, Object> extra,
|
String nameKey, String pathKey) {
|
if (extra == null) {
|
return null;
|
}
|
String path = text(extra.get(pathKey));
|
if (StringUtils.hasText(path)) {
|
String[] segments = path.split("/");
|
List<String> names = new ArrayList<>();
|
for (String segment : segments) {
|
if (StringUtils.hasText(segment)) {
|
names.add(segment.trim());
|
}
|
}
|
if (!names.isEmpty()) {
|
return "/" + String.join("/", names);
|
}
|
}
|
String name = text(extra.get(nameKey));
|
return !StringUtils.hasText(name) || name.startsWith("/") ? name : "/" + name;
|
}
|
|
private static String text(Object value) {
|
return value == null || !StringUtils.hasText(String.valueOf(value))
|
? null : String.valueOf(value).trim();
|
}
|
|
/**
|
* 从 extra.recordSubTitles 取子表标题行，只下发前 {@link #LIST_SUB_TITLE_LIMIT} 条 + 总数。
|
* 不整体下发 extra：正文里除 dataSnapshot 外还有各种来源标记与上下文，列表接口不该带出去。
|
*/
|
@SuppressWarnings("unchecked")
|
private void applySubTitles(AuditEventListVO vo, String extraJson) {
|
if (!StringUtils.hasText(extraJson)) {
|
return;
|
}
|
try {
|
Map<String, Object> extra = JsonUtil.stringToMap(extraJson);
|
Object raw = extra == null ? null : extra.get("recordSubTitles");
|
if (!(raw instanceof List)) {
|
return;
|
}
|
List<?> all = (List<?>) raw;
|
List<String> head = new ArrayList<>();
|
for (Object item : all) {
|
if (head.size() >= LIST_SUB_TITLE_LIMIT) {
|
break;
|
}
|
if (item != null) {
|
head.add(String.valueOf(item));
|
}
|
}
|
vo.setSubTitles(head);
|
vo.setSubTitleCount(all.size());
|
} catch (Throwable ignored) {
|
// extra 解析失败不影响列表主行——标题是锦上添花，不能炸掉整页
|
}
|
}
|
|
private AuditEventDetailVO toDetailVo(AuditEventEntity e) {
|
AuditEventDetailVO vo = new AuditEventDetailVO();
|
vo.setId(e.getId());
|
vo.setClientEventId(e.getClientEventId());
|
vo.setOperationId(e.getOperationId());
|
vo.setEventTime(e.getEventTime());
|
vo.setTenantId(e.getTenantId());
|
vo.setOperatorId(e.getOperatorId());
|
vo.setOperatorName(e.getOperatorName());
|
vo.setOperatorOrgId(e.getOperatorOrgId());
|
vo.setAppName(e.getAppName());
|
vo.setBizModule(e.getBizModule());
|
vo.setParentBizModule(e.getParentBizModule());
|
vo.setIp(e.getIp());
|
vo.setIpRegion(e.getIpRegion());
|
vo.setBrowser(e.getBrowser());
|
vo.setOs(e.getOs());
|
vo.setRequestUri(e.getRequestUri());
|
vo.setEventType(e.getEventType());
|
vo.setActionCode(e.getActionCode());
|
vo.setActionLabel(e.getActionLabel());
|
vo.setSourceLayer(e.getSourceLayer());
|
vo.setTargetTable(e.getTargetTable());
|
vo.setTargetId(AuditQueryResponseSanitizer.hidesTargetId(e.getTargetTable())
|
? null : e.getTargetId());
|
vo.setBizType(e.getBizType());
|
vo.setBizCode(e.getBizCode());
|
String modelId = AuditQueryResponseSanitizer.sourceModelId(e.getExtra());
|
Map<String, jnpf.audit.diff.AuditFieldDiff.FieldMeta> metadata =
|
auditFormRegistry.resolveFieldMetadata(modelId, e.getTargetTable());
|
String sanitizedFieldDiffs = AuditQueryResponseSanitizer.sanitizeFieldDiffs(
|
e.getFieldDiffs(), metadata);
|
vo.setFieldDiffs(sanitizedFieldDiffs);
|
vo.setFieldDiffList(auditFieldDiffViewService.build(e, sanitizedFieldDiffs, metadata));
|
vo.setExtra(AuditQueryResponseSanitizer.sanitizeJson(e.getExtra()));
|
vo.setDataSnapshot(AuditQueryResponseSanitizer.sanitizeJson(e.getDataSnapshot(), metadata));
|
vo.setReason(e.getReason());
|
vo.setRecordTitle(e.getRecordTitle());
|
vo.setEntryType(e.getEntryType());
|
vo.setEntryId(e.getEntryId());
|
vo.setEntryName(e.getEntryName());
|
vo.setPrevHash(e.getPrevHash());
|
vo.setCreatedAt(e.getCreatedAt());
|
return vo;
|
}
|
|
/** field_diffs 是 VisualLogModel[] JSON；空/非法 JSON 一律降级为 0，不让摘要计算炸列表接口。 */
|
private Integer computeDiffCount(String fieldDiffs) {
|
if (!StringUtils.hasText(fieldDiffs)) {
|
return 0;
|
}
|
return AuditQueryResponseSanitizer.effectiveDiffCount(fieldDiffs);
|
}
|
}
|
