package jnpf.onlinedev.service.impl;
|
|
import cn.hutool.core.bean.BeanUtil;
|
import jnpf.base.UserInfo;
|
import jnpf.base.entity.VisualdevReleaseEntity;
|
import jnpf.base.model.VisualLogModel;
|
import jnpf.base.service.SuperServiceImpl;
|
import jnpf.base.service.VisualdevReleaseService;
|
import jnpf.constant.JnpfConst;
|
import jnpf.consts.ProjectEventConst;
|
import jnpf.event.ProjectEventListener;
|
import jnpf.model.visualjson.FieLdsModel;
|
import jnpf.model.visualjson.FormDataModel;
|
import jnpf.model.visualjson.TableFields;
|
import jnpf.model.visualjson.TableModel;
|
import jnpf.model.visualjson.config.ConfigModel;
|
import jnpf.module.ProjectEventBuilder;
|
import jnpf.module.ProjectEventInstance;
|
import jnpf.onlinedev.entity.VisualLogEntity;
|
import jnpf.onlinedev.mapper.VisualLogMapper;
|
import jnpf.onlinedev.model.enums.OnlineDataTypeEnum;
|
import jnpf.onlinedev.model.log.VisualLogForm;
|
import jnpf.onlinedev.model.log.VisualLogPage;
|
import jnpf.onlinedev.service.VisualLogService;
|
import jnpf.onlinedev.util.OnlinePublicUtils;
|
import jnpf.onlinedev.util.OnlineSwapDataUtils;
|
import jnpf.util.IpUtil;
|
import jnpf.util.JsonUtil;
|
import jnpf.util.PublishEventUtil;
|
import jnpf.util.TableFeildsEnum;
|
import jnpf.util.UserProvider;
|
import jnpf.util.visiual.JnpfKeyConsts;
|
import lombok.RequiredArgsConstructor;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.collections4.CollectionUtils;
|
import org.apache.commons.collections4.MapUtils;
|
import org.springframework.stereotype.Service;
|
import org.springframework.web.context.request.RequestContextHolder;
|
import org.springframework.web.context.request.ServletRequestAttributes;
|
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
/**
|
* 数据日志实现
|
*
|
* @author JNPF开发平台组
|
* @version v5.1.0
|
* @copyright 引迈信息技术有限公司
|
* @date 2024/8/27 18:24:42
|
*/
|
@Slf4j
|
@Service
|
@RequiredArgsConstructor
|
public class VisualLogServiceImpl extends SuperServiceImpl<VisualLogMapper, VisualLogEntity> implements VisualLogService {
|
|
private final VisualdevReleaseService visualdevReleaseService;
|
private final OnlineSwapDataUtils onlineSwapDataUtils;
|
|
/**
|
* 创建日志事件
|
*
|
* @param form 数据id
|
*
|
* <p>[LIMS PATCH 2026-05-15] 从 publishLocalEvent 改为 BROADCASTING，
|
* 使 jnpf-extend 等其它微服务能通过 RocketMQ 跨 JVM 监听 VSLOG_EVENT_KEY，
|
* 便于 LIMS 业务日志统一聚合到 lims_biz_log。
|
* 详见 tasks/jnpf-platform-patches.md 和 docs/release-checklist.md。</p>
|
*/
|
@Override
|
public void createEventLog(VisualLogForm form) {
|
ensureBoundaryListLog(form);
|
// AUDIT-P1（登记 tasks/jnpf-platform-patches.md）：附带请求上下文供审计层0消费
|
try {
|
ServletRequestAttributes attrs = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
|
UserInfo user = UserProvider.getUser(); // 静态方法（终验 javap 核实：无实例 get()、无 userProvider 注入字段）
|
if (attrs != null && user != null) {
|
Map<String, Object> auditCtx = new HashMap<>();
|
auditCtx.put("userId", user.getUserId());
|
auditCtx.put("userName", user.getUserName());
|
auditCtx.put("tenantId", user.getTenantId());
|
auditCtx.put("ip", IpUtil.getIpAddr()); // 无参方法（终验 javap 核实：不存在接收 request 的重载）
|
auditCtx.put("userAgent", attrs.getRequest().getHeader("User-Agent"));
|
auditCtx.put("uri", attrs.getRequest().getRequestURI());
|
// AUDIT-P1 扩展（2026-07-31）：操作入口菜单。header 由前端全局拦截器注入，
|
// 取不到就不放这个键——审计侧按"没带"处理并留痕，不猜。
|
String auditMenuId = attrs.getRequest().getHeader("Jnpf-Menu-Id");
|
if (auditMenuId != null && !auditMenuId.trim().isEmpty()) {
|
auditCtx.put("menuId", auditMenuId.trim());
|
}
|
auditCtx.put("appCode", attrs.getRequest().getHeader("App-Code"));
|
auditCtx.put("appScope", attrs.getRequest().getHeader("Jnpf-App-Scope"));
|
String auditBizSign = attrs.getRequest().getHeader("X-Audit-Biz-Sign");
|
if (auditBizSign != null && !auditBizSign.trim().isEmpty()) {
|
// 固化请求时的关联键；MQ 消费时已脱离 HTTP 线程，不能再读取请求头。
|
auditCtx.put("auditBizSign", auditBizSign.trim());
|
}
|
auditCtx.put("opTime", System.currentTimeMillis());
|
form.setAuditCtx(JsonUtil.getObjectToString(auditCtx)); // form = 该方法内既有的 VisualLogForm 实例
|
}
|
} catch (Throwable t) {
|
log.warn("AUDIT-P1 上下文采集失败, 不影响主流程", t);
|
}
|
try {
|
PublishEventUtil.publish(
|
new ProjectEventBuilder(JnpfConst.VSLOG_EVENT_KEY, form)
|
.setMessageModel(ProjectEventConst.EVENT_PUBLISH_MODEL_BROADCASTING));
|
} catch (Throwable t) {
|
// 日志事件是旁路能力，RocketMQ 不可用时不能影响在线表单主流程保存。
|
log.warn("[VisualLog] 发布表单日志事件失败，已跳过。modelId={}, dataId={}, type={}, error={}",
|
form == null ? null : form.getModelId(),
|
form == null ? null : form.getDataId(),
|
form == null ? null : form.getType(),
|
t.getMessage());
|
}
|
}
|
|
/**
|
* 新增和删除路径原本只发布整行快照，导致统一审计拿不到子表行级变化。
|
* 复用更新路径的 addLog 契约：新增以空数据为 before，删除以空数据为 after。
|
*/
|
private void ensureBoundaryListLog(VisualLogForm form) {
|
if (form == null || CollectionUtils.isNotEmpty(form.getListLog()) || form.getNewData() == null
|
|| (!Objects.equals(form.getType(), 0) && !Objects.equals(form.getType(), 2))) {
|
return;
|
}
|
Map<String, Object> snapshot = form.getNewData();
|
Map<String, Object> originalOld = form.getOldData();
|
try {
|
if (Objects.equals(form.getType(), 0)) {
|
form.setOldData(Collections.emptyMap());
|
} else {
|
form.setOldData(snapshot);
|
form.setNewData(Collections.emptyMap());
|
}
|
List<VisualLogModel> listLog = new ArrayList<>();
|
addLog(form, listLog);
|
form.setListLog(listLog);
|
} catch (Throwable t) {
|
log.warn("[AUDIT] 子表边界差异生成失败，主表审计继续。modelId={}, dataId={}, type={}, error={}",
|
form.getModelId(), form.getDataId(), form.getType(), t.getMessage());
|
} finally {
|
form.setOldData(originalOld);
|
form.setNewData(snapshot);
|
}
|
}
|
|
@Override
|
public List<VisualLogEntity> getList(VisualLogPage pagination) {
|
return this.baseMapper.getList(pagination);
|
}
|
|
/**
|
* 监听日志插入
|
*
|
* @param redisEvent
|
*/
|
@ProjectEventListener(channelRegex = JnpfConst.VSLOG_EVENT_KEY + ".*")
|
public void createLogByEvent(ProjectEventInstance redisEvent) {
|
// [LIMS PATCH 2026-05-15] BROADCASTING 模式下事件经 RocketMQ 跨 JVM 后 source 反序列化为 JSONObject，
|
// 不能直接 cast 成 VisualLogForm（@Builder 无无参构造器无法 parseObject 回去）。
|
// 这里安全跳过非 VisualLogForm 的 source —— 否则抛 ClassCastException 会阻断同一 channel 上后续 listener
|
// （如 jnpf-extend 的 BaseVisualLogListener）。base_visual_log 在跨 JVM 路径下不再被写入，由 lims_biz_log 接管。
|
Object source = redisEvent.getSource();
|
if (!(source instanceof VisualLogForm)) {
|
return;
|
}
|
VisualLogForm form = (VisualLogForm) source;
|
if (Boolean.TRUE.equals(form.getAuditOnly())) {
|
return;
|
}
|
VisualLogEntity visualLogEntity = new VisualLogEntity();
|
visualLogEntity.setType(form.getType());
|
visualLogEntity.setModelId(form.getModelId());
|
visualLogEntity.setDataId(form.getDataId());
|
|
//修改数据
|
if (Objects.equals(form.getType(), 1)) {
|
List<VisualLogModel> listLog = new ArrayList<>();
|
if (CollectionUtils.isNotEmpty(form.getListLog())) {
|
listLog = form.getListLog();
|
} else {
|
addLog(form, listLog);
|
}
|
visualLogEntity.setDataLog(JsonUtil.getObjectToString(listLog));
|
if (CollectionUtils.isNotEmpty(listLog)) {
|
this.save(visualLogEntity);
|
}
|
} else {
|
//新增数据
|
this.save(visualLogEntity);
|
}
|
}
|
|
public void addLog(VisualLogForm formSource, List<VisualLogModel> listLog) {
|
VisualLogForm form = BeanUtil.copyProperties(formSource, VisualLogForm.class);
|
VisualdevReleaseEntity visualdevEntity = visualdevReleaseService.getById(form.getModelId());
|
FormDataModel formData = JsonUtil.getJsonToBean(visualdevEntity.getFormData(), FormDataModel.class);
|
List<FieLdsModel> fieLdsModels = JsonUtil.getJsonToList(formData.getFields(), FieLdsModel.class);
|
List<TableModel> tableModels = JsonUtil.getJsonToList(visualdevEntity.getVisualTables(), TableModel.class);
|
|
List<FieLdsModel> fields = new ArrayList<>();
|
OnlinePublicUtils.recursionFields(fields, fieLdsModels);
|
|
List<Map<String, Object>> swapInfoOld = onlineSwapDataUtils.getSwapInfo(Arrays.asList(form.getOldData()), fields, visualdevEntity.getId(), false, null);
|
Map<String, Object> oldData = swapInfoOld.get(0);
|
List<Map<String, Object>> swapInfoNew = onlineSwapDataUtils.getSwapInfo(Arrays.asList(form.getNewData()), fields, visualdevEntity.getId(), false, null);
|
Map<String, Object> newData = swapInfoNew.get(0);
|
|
for (FieLdsModel item : fields) {
|
//移除系统字段
|
if (isSkipFields(item)) continue;
|
if (JnpfKeyConsts.CHILD_TABLE.equals(item.getConfig().getJnpfKey())) {
|
//子表字段
|
addChildTableLog(item, tableModels, listLog, oldData, newData);
|
} else {
|
addMainMastLog(item, listLog, oldData, newData);
|
}
|
}
|
}
|
|
/**
|
* 添加主附表字段日志
|
*
|
* @param item
|
* @param listLog
|
* @param oldData
|
* @param newData
|
*/
|
private void addMainMastLog(FieLdsModel item, List<VisualLogModel> listLog, Map<String, Object> oldData, Map<String, Object> newData) {
|
String vModel = item.getVModel();
|
ConfigModel config = item.getConfig();
|
String jnpfKey = config.getJnpfKey();
|
String label = config.getLabel();
|
String dataType = config.getDataType();
|
if (!Objects.equals(oldData.get(vModel), newData.get(vModel))) {
|
Integer actionType = 1;//0-新增，1-修改
|
if (oldData.get(vModel) == null || oldData.get(vModel).toString().trim().isEmpty()) {
|
actionType = 0;
|
}
|
boolean nameModified = false;
|
if (JnpfKeyConsts.getNameModified().contains(jnpfKey)
|
&& (JnpfKeyConsts.getNameModifiedNotDynamic().contains(jnpfKey) || OnlineDataTypeEnum.DYNAMIC.getType().equals(dataType))) {
|
nameModified = true;
|
}
|
|
String newValue = getValueByType(newData, vModel, jnpfKey);
|
String oldValue = getValueByType(oldData, vModel, jnpfKey);
|
VisualLogModel vlogModel = new VisualLogModel();
|
vlogModel.setField(vModel);
|
vlogModel.setFieldName(label);
|
vlogModel.setJnpfKey(jnpfKey);
|
vlogModel.setNewData(newValue);
|
vlogModel.setOldData(oldValue);
|
vlogModel.setType(actionType);
|
vlogModel.setNameModified(nameModified);
|
listLog.add(vlogModel);
|
}
|
}
|
|
/**
|
* 添加子表字段日志
|
*
|
* @param item
|
* @param tableModels
|
* @param listLog
|
* @param oldData
|
* @param newData
|
*/
|
private void addChildTableLog(FieLdsModel item, List<TableModel> tableModels, List<VisualLogModel> listLog, Map<String, Object> oldData, Map<String, Object> newData) {
|
ConfigModel config = item.getConfig();
|
String jnpfKey = config.getJnpfKey();
|
String label = config.getLabel();
|
TableModel tableModel = tableModels.stream().filter(t -> t.getTable().equals(config.getTableName())).findFirst().orElse(null);
|
TableFields mainField = tableModel.getFields().stream().filter(t ->
|
Objects.equals(t.getPrimaryKey(), 1) && !t.getField().equalsIgnoreCase(TableFeildsEnum.TENANTID.getField())).findFirst().orElse(null);
|
String mainKey = mainField.getField();
|
|
List<FieLdsModel> children = item.getConfig().getChildren();
|
String vModel = item.getVModel();
|
//子表数据
|
List<Map<String, Object>> childData = new ArrayList<>();
|
//子表表头
|
List<Map<String, Object>> childField = new ArrayList<>();
|
for (FieLdsModel childItem : children) {
|
String jnpfKeyChild = childItem.getConfig().getJnpfKey();
|
if (isSkipFields(childItem))
|
continue;
|
Map<String, Object> childItemMap = new HashMap<>();
|
childItemMap.put("prop", childItem.getVModel());
|
childItemMap.put("label", childItem.getConfig().getLabel());
|
childItemMap.put("jnpfKey", jnpfKeyChild);
|
boolean nameModified = false;
|
if (JnpfKeyConsts.getNameModified().contains(jnpfKeyChild)
|
&& (JnpfKeyConsts.getNameModifiedNotDynamic().contains(jnpfKeyChild) || OnlineDataTypeEnum.DYNAMIC.getType().equals(childItem.getConfig().getDataType()))) {
|
nameModified = true;
|
}
|
childItemMap.put("nameModified", nameModified);
|
childField.add(childItemMap);
|
}
|
|
List<Map<String, Object>> childOld = oldData.get(vModel) == null ? new ArrayList<>() : (List) oldData.get(vModel);
|
List<Map<String, Object>> childNew = newData.get(vModel) == null ? new ArrayList<>() : (List) newData.get(vModel);
|
List<Object> newIds = childNew.stream().map(t -> t.get(mainKey)).collect(Collectors.toList());
|
List<Map<String, Object>> deleteMap = childOld.stream().filter(t -> !newIds.contains(t.get(mainKey))).collect(Collectors.toList());
|
for (Map<String, Object> chilMap : deleteMap) {
|
doDelData(chilMap, children, childData);
|
}
|
for (Map<String, Object> chilMap : childNew) {
|
doNewData(chilMap, mainKey, childOld, children, childData);
|
}
|
if (CollectionUtils.isNotEmpty(childData)) {
|
VisualLogModel vlogModel = new VisualLogModel();
|
vlogModel.setField(vModel);
|
vlogModel.setFieldName(label);
|
vlogModel.setJnpfKey(jnpfKey);
|
vlogModel.setTargetTable(config.getTableName());
|
vlogModel.setChidData(childData);
|
vlogModel.setChidField(childField);
|
vlogModel.setType(1);
|
listLog.add(vlogModel);
|
}
|
}
|
|
private void doDelData(Map<String, Object> chilMap, List<FieLdsModel> children, List<Map<String, Object>> childData) {
|
Map<String, Object> childDataMap = new HashMap<>();
|
for (FieLdsModel childItem : children) {
|
String childJnpfKey = childItem.getConfig().getJnpfKey();
|
//移除系统字段
|
if (isSkipFields(childItem)) continue;
|
String childVmodel = childItem.getVModel();
|
String childVmodelOld = "jnpf_old_" + childItem.getVModel();
|
String oldValue = getValueByType(chilMap, childVmodel, childJnpfKey);
|
childDataMap.put(childVmodel, null);
|
childDataMap.put(childVmodelOld, oldValue);
|
childDataMap.put("jnpf_type", 2);
|
}
|
childData.add(childDataMap);
|
}
|
|
private void doNewData(Map<String, Object> chilMap, String mainKey, List<Map<String, Object>> childOld, List<FieLdsModel> children, List<Map<String, Object>> childData) {
|
Object mainId = chilMap.get(mainKey);
|
Map<String, Object> oldMap = childOld.stream().filter(t -> Objects.equals(t.get(mainKey), mainId)).findFirst().orElse(null);
|
Integer jnpfType = 1;
|
if (oldMap == null) {
|
jnpfType = 0;
|
}
|
Map<String, Object> childDataMap = new HashMap<>();
|
boolean hasChanged = false;
|
for (FieLdsModel childItem : children) {
|
String childJnpfKey = childItem.getConfig().getJnpfKey();
|
//移除系统字段
|
if (isSkipFields(childItem)) continue;
|
String childVmodel = childItem.getVModel();
|
String childVmodelOld = "jnpf_old_" + childItem.getVModel();
|
String newValue = getValueByType(chilMap, childVmodel, childJnpfKey);
|
String oldValue = getValueByType(oldMap, childVmodel, childJnpfKey);
|
if (!Objects.equals(newValue, oldValue)) {
|
hasChanged = true;
|
}
|
childDataMap.put(childVmodel, newValue);
|
childDataMap.put(childVmodelOld, oldValue);
|
childDataMap.put("jnpf_type", jnpfType);
|
}
|
if (hasChanged) {
|
childData.add(childDataMap);
|
}
|
}
|
|
/**
|
* 跳过字段不处理
|
*
|
* @param childItem
|
* @return
|
*/
|
private boolean isSkipFields(FieLdsModel childItem) {
|
//字段不处理直接跳过 ：（JnpfKeyConsts.CALCULATE 计算公式仅展示也跳过）
|
List<String> skipFields = new ArrayList<>();
|
skipFields.addAll(JnpfKeyConsts.getSystemKey());
|
skipFields.add(JnpfKeyConsts.POPUPSELECT_ATTR);
|
skipFields.add(JnpfKeyConsts.RELATIONFORM_ATTR);
|
String jnpfKey = childItem.getConfig().getJnpfKey();
|
return skipFields.contains(jnpfKey) || (JnpfKeyConsts.CALCULATE.equals(jnpfKey) && Objects.equals(childItem.getIsStorage(), 0));
|
}
|
|
private String getValueByType(Map<String, Object> map, String vModel, String jnpfKey) {
|
if (map != null) {
|
Object o = map.get(vModel);
|
String value = o == null ? "" : o.toString();
|
switch (jnpfKey) {
|
case JnpfKeyConsts.UPLOADFZ:
|
List<Map<String, String>> listM = (List) o;
|
if (listM != null) {
|
StringJoiner sj = new StringJoiner(",");
|
listM.stream().forEach(t -> sj.add(t.get("name")));
|
value = sj.toString();
|
}
|
break;
|
case JnpfKeyConsts.LOCATION:
|
Map<String, Object> lcationMap = JsonUtil.stringToMap(value);
|
if (MapUtils.isNotEmpty(lcationMap)) {
|
value = lcationMap.get("fullAddress") != null ? lcationMap.get("fullAddress").toString() : "";
|
}
|
break;
|
default:
|
break;
|
}
|
return value;
|
}
|
return null;
|
}
|
}
|
