From 34981c30a78e8bbd7791131059a9210f9928b62c Mon Sep 17 00:00:00 2001
From: 刘光辉 <347230014@qq.com>
Date: 星期四, 17 九月 2026 09:24:09 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master' into master
---
jnpf-flowable/jnpf-flowable-biz/src/main/java/jnpf/flowable/mapper/TriggerRecordMapper.java | 116 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 116 insertions(+), 0 deletions(-)
diff --git a/jnpf-flowable/jnpf-flowable-biz/src/main/java/jnpf/flowable/mapper/TriggerRecordMapper.java b/jnpf-flowable/jnpf-flowable-biz/src/main/java/jnpf/flowable/mapper/TriggerRecordMapper.java
new file mode 100644
index 0000000..919d074
--- /dev/null
+++ b/jnpf-flowable/jnpf-flowable-biz/src/main/java/jnpf/flowable/mapper/TriggerRecordMapper.java
@@ -0,0 +1,116 @@
+package jnpf.flowable.mapper;
+
+import cn.hutool.core.collection.CollUtil;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.google.common.collect.ImmutableList;
+import jnpf.base.mapper.SuperMapper;
+import jnpf.flowable.entity.TriggerRecordEntity;
+import jnpf.flowable.entity.TriggerTaskEntity;
+import jnpf.flowable.enums.TriggerRecordEnum;
+import jnpf.flowable.model.flowable.FlowableTaskModel;
+import jnpf.flowable.model.templatenode.nodejson.NodeModel;
+import jnpf.flowable.model.util.FlowNature;
+import jnpf.util.RandomUtil;
+import jnpf.util.StringUtil;
+import org.apache.commons.lang3.StringUtils;
+
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * 绫荤殑鎻忚堪
+ *
+ * @author JNPF@YinMai Info. Co., Ltd
+ * @version 5.0.x
+ * @since 2024/9/10 17:14
+ */
+public interface TriggerRecordMapper extends SuperMapper<TriggerRecordEntity> {
+
+ default List<TriggerRecordEntity> getList(String triggerTaskId) {
+ if (StringUtils.isBlank(triggerTaskId)) {
+ return new ArrayList<>();
+ }
+ return getList(ImmutableList.of(triggerTaskId));
+ }
+
+ default List<TriggerRecordEntity> getList(List<String> triggerTaskIdList) {
+ if (CollUtil.isEmpty(triggerTaskIdList)) {
+ return new ArrayList<>();
+ }
+ QueryWrapper<TriggerRecordEntity> queryWrapper = new QueryWrapper<>();
+ queryWrapper.lambda().in(TriggerRecordEntity::getTriggerId, triggerTaskIdList).orderByAsc(TriggerRecordEntity::getStartTime);
+ return this.selectList(queryWrapper);
+ }
+
+ default List<TriggerRecordEntity> getListByTaskId(String taskId) {
+ if (StringUtils.isBlank(taskId)) {
+ return new ArrayList<>();
+ }
+ QueryWrapper<TriggerRecordEntity> queryWrapper = new QueryWrapper<>();
+ queryWrapper.lambda().eq(TriggerRecordEntity::getTaskId, taskId).orderByDesc(TriggerRecordEntity::getStartTime);
+ return this.selectList(queryWrapper);
+ }
+
+ default void create(TriggerRecordEntity entity) {
+ if (StringUtil.isEmpty(entity.getId())) {
+ entity.setId(RandomUtil.uuId());
+ }
+ entity.setCreatorTime(new Date());
+ this.insert(entity);
+ }
+
+ default void create(TriggerTaskEntity triggerTask, NodeModel nodeModel, FlowableTaskModel taskModel) {
+ TriggerRecordEntity entity = new TriggerRecordEntity();
+ entity.setId(RandomUtil.uuId());
+ entity.setStatus(TriggerRecordEnum.PASSED.getCode());
+ Date date = new Date();
+ entity.setStartTime(date);
+ entity.setEndTime(date);
+
+ entity.setNodeCode(nodeModel.getNodeId());
+ entity.setNodeName(nodeModel.getNodeName());
+ entity.setNodeId(taskModel.getTaskId());
+
+ entity.setTriggerId(triggerTask.getId());
+ if (StringUtil.isNotEmpty(triggerTask.getTaskId())) {
+ entity.setTaskId(triggerTask.getTaskId());
+ }
+
+ this.insert(entity);
+ }
+
+ default void createStart(String triggerId) {
+ TriggerRecordEntity entity = new TriggerRecordEntity();
+ entity.setId(RandomUtil.uuId());
+ entity.setStatus(TriggerRecordEnum.PASSED.getCode());
+ Date date = new Date();
+ entity.setStartTime(date);
+ entity.setEndTime(date);
+ entity.setTriggerId(triggerId);
+ entity.setNodeCode(FlowNature.START_CODE);
+ entity.setNodeName(FlowNature.START_NAME);
+ this.insert(entity);
+ }
+
+ default void createEnd(String triggerId) {
+ TriggerRecordEntity entity = new TriggerRecordEntity();
+ entity.setId(RandomUtil.uuId());
+ entity.setStatus(TriggerRecordEnum.PASSED.getCode());
+ Date date = new Date();
+ entity.setStartTime(date);
+ entity.setEndTime(date);
+ entity.setTriggerId(triggerId);
+ entity.setNodeCode(FlowNature.END_CODE);
+ entity.setNodeName(FlowNature.END_NAME);
+ this.insert(entity);
+ }
+
+ default void delete(List<String> triggerTaskIds) {
+ if (CollUtil.isNotEmpty(triggerTaskIds)) {
+ QueryWrapper<TriggerRecordEntity> queryWrapper = new QueryWrapper<>();
+ queryWrapper.lambda().in(TriggerRecordEntity::getTriggerId, triggerTaskIds);
+ this.delete(queryWrapper);
+ }
+ }
+}
--
Gitblit v1.8.0