From eb1fec00280548a5ed3dcda373e78f4d9e4f8fce Mon Sep 17 00:00:00 2001
From: "1437892690@qq.com" <1437892690@qq.com>
Date: Thu, 2 May 2024 09:16:59 +0800
Subject: [PATCH] =?UTF-8?q?[=E5=8A=9F=E8=83=BD]=20=E5=B0=86neatlogic-itsm-?=
=?UTF-8?q?base=E6=A8=A1=E5=9D=97=E4=B8=AD=E7=9A=84mapper=E6=8C=AA?=
=?UTF-8?q?=E5=88=B0neatlogic-itsm=E6=A8=A1=E5=9D=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
关联 #[1146889473327104]将neatlogic-itsm-base模块中的mapper挪到neatlogic-itsm模块 http://192.168.0.96:8090/demo/rdm.html#/story-detail/939050947543040/939050947543042/1146889473327104
---
...ProcessTaskStepAuditDetailHandlerBase.java | 19 +-
.../core/ProcessTaskConditionBase.java | 43 +-
.../crossover/ICatalogCrossoverMapper.java | 32 +
.../crossover/IChannelCrossoverMapper.java | 28 +
.../IChannelTypeCrossoverMapper.java | 26 +
.../IProcessStepHandlerCrossoverMapper.java | 25 +
.../IProcessStepHandlerCrossoverUtil.java} | 85 +-
.../IProcessTaskAgentCrossoverMapper.java | 28 +
.../IProcessTaskAgentCrossoverService.java | 29 +
.../IProcessTaskCrossoverMapper.java} | 425 +-
.../IProcessTaskScoreCrossoverMapper.java} | 32 +-
...rocessTaskSerialNumberCrossoverMapper.java | 30 +
.../IProcessTaskSlaCrossoverMapper.java | 29 +
.../IProcessTaskStepDataCrossoverMapper.java | 31 +
.../IProcessTaskStepTaskCrossoverMapper.java | 32 +
...ocessTaskStepTimeAuditCrossoverMapper.java | 28 +
.../IScoreTemplateCrossoverMapper.java | 28 +
.../ISelectContentByHashCrossoverMapper.java | 36 +
.../process/dao/mapper/CatalogMapper.java | 117 -
.../process/dao/mapper/CatalogMapper.xml | 389 --
.../process/dao/mapper/ChannelMapper.java | 151 -
.../process/dao/mapper/ChannelMapper.xml | 871 ----
.../process/dao/mapper/ChannelTypeMapper.java | 122 -
.../process/dao/mapper/ChannelTypeMapper.xml | 463 --
.../process/dao/mapper/PriorityMapper.java | 59 -
.../process/dao/mapper/PriorityMapper.xml | 266 --
.../mapper/ProcessCommentTemplateMapper.java | 44 -
.../mapper/ProcessCommentTemplateMapper.xml | 210 -
.../dao/mapper/ProcessEventMapper.java | 47 -
.../process/dao/mapper/ProcessEventMapper.xml | 5 -
.../dao/mapper/ProcessStepHandlerMapper.java | 14 -
.../dao/mapper/ProcessStepHandlerMapper.xml | 25 -
.../process/dao/mapper/ProcessTagMapper.java | 40 -
.../process/dao/mapper/ProcessTagMapper.xml | 72 -
.../dao/mapper/ProcessTaskAgentMapper.java | 50 -
.../dao/mapper/ProcessTaskAgentMapper.xml | 169 -
.../process/dao/mapper/ProcessTaskMapper.xml | 4092 -----------------
.../mapper/ProcessTaskSerialNumberMapper.java | 32 -
.../mapper/ProcessTaskSerialNumberMapper.xml | 96 -
.../dao/mapper/ProcessTaskSlaMapper.java | 95 -
.../dao/mapper/ProcessTaskSlaMapper.xml | 382 --
.../dao/mapper/ProcessTaskStepDataMapper.java | 32 -
.../dao/mapper/ProcessTaskStepDataMapper.xml | 107 -
.../dao/mapper/ProcessTaskStepTaskMapper.java | 114 -
.../dao/mapper/ProcessTaskStepTaskMapper.xml | 614 ---
.../ProcessTaskStepTimeAuditMapper.java | 15 -
.../mapper/ProcessTaskStepTimeAuditMapper.xml | 82 -
.../dao/mapper/SelectContentByHashMapper.java | 31 -
.../dao/mapper/SelectContentByHashMapper.xml | 75 -
.../mapper/score/ProcessTaskScoreMapper.xml | 107 -
.../dao/mapper/score/ScoreTemplateMapper.java | 53 -
.../dao/mapper/score/ScoreTemplateMapper.xml | 257 --
.../process/dao/mapper/task/TaskMapper.java | 57 -
.../process/dao/mapper/task/TaskMapper.xml | 188 -
.../mapper/workcenter/WorkcenterMapper.java | 90 -
.../mapper/workcenter/WorkcenterMapper.xml | 386 --
.../event/core/ProcessEventHandler.java | 103 -
.../core/OperationAuthHandlerBase.java | 22 +-
.../core/ProcessAuthManager.java | 54 +-
.../process/service/ChannelService.java | 24 -
.../process/service/ChannelServiceImpl.java | 164 -
.../service/ProcessTaskAgentService.java | 29 -
.../service/ProcessTaskAgentServiceImpl.java | 112 -
.../sla/core/SlaCalculateHandlerBase.java | 13 +-
.../core/ProcessStepHandlerBase.java | 725 ++-
.../core/ProcessStepInternalHandlerBase.java | 91 +-
.../core/ProcessTaskStepTimeoutDetector.java | 43 -
67 files changed, 900 insertions(+), 11485 deletions(-)
create mode 100644 src/main/java/neatlogic/framework/process/crossover/ICatalogCrossoverMapper.java
create mode 100644 src/main/java/neatlogic/framework/process/crossover/IChannelCrossoverMapper.java
create mode 100644 src/main/java/neatlogic/framework/process/crossover/IChannelTypeCrossoverMapper.java
create mode 100644 src/main/java/neatlogic/framework/process/crossover/IProcessStepHandlerCrossoverMapper.java
rename src/main/java/neatlogic/framework/process/{stephandler/core/IProcessStepHandlerUtil.java => crossover/IProcessStepHandlerCrossoverUtil.java} (65%)
create mode 100644 src/main/java/neatlogic/framework/process/crossover/IProcessTaskAgentCrossoverMapper.java
create mode 100644 src/main/java/neatlogic/framework/process/crossover/IProcessTaskAgentCrossoverService.java
rename src/main/java/neatlogic/framework/process/{dao/mapper/ProcessTaskMapper.java => crossover/IProcessTaskCrossoverMapper.java} (30%)
rename src/main/java/neatlogic/framework/process/{dao/mapper/score/ProcessTaskScoreMapper.java => crossover/IProcessTaskScoreCrossoverMapper.java} (51%)
mode change 100755 => 100644
create mode 100644 src/main/java/neatlogic/framework/process/crossover/IProcessTaskSerialNumberCrossoverMapper.java
create mode 100644 src/main/java/neatlogic/framework/process/crossover/IProcessTaskSlaCrossoverMapper.java
create mode 100644 src/main/java/neatlogic/framework/process/crossover/IProcessTaskStepDataCrossoverMapper.java
create mode 100644 src/main/java/neatlogic/framework/process/crossover/IProcessTaskStepTaskCrossoverMapper.java
create mode 100644 src/main/java/neatlogic/framework/process/crossover/IProcessTaskStepTimeAuditCrossoverMapper.java
create mode 100644 src/main/java/neatlogic/framework/process/crossover/IScoreTemplateCrossoverMapper.java
create mode 100644 src/main/java/neatlogic/framework/process/crossover/ISelectContentByHashCrossoverMapper.java
delete mode 100644 src/main/java/neatlogic/framework/process/dao/mapper/CatalogMapper.java
delete mode 100644 src/main/java/neatlogic/framework/process/dao/mapper/CatalogMapper.xml
delete mode 100644 src/main/java/neatlogic/framework/process/dao/mapper/ChannelMapper.java
delete mode 100644 src/main/java/neatlogic/framework/process/dao/mapper/ChannelMapper.xml
delete mode 100644 src/main/java/neatlogic/framework/process/dao/mapper/ChannelTypeMapper.java
delete mode 100644 src/main/java/neatlogic/framework/process/dao/mapper/ChannelTypeMapper.xml
delete mode 100644 src/main/java/neatlogic/framework/process/dao/mapper/PriorityMapper.java
delete mode 100644 src/main/java/neatlogic/framework/process/dao/mapper/PriorityMapper.xml
delete mode 100644 src/main/java/neatlogic/framework/process/dao/mapper/ProcessCommentTemplateMapper.java
delete mode 100644 src/main/java/neatlogic/framework/process/dao/mapper/ProcessCommentTemplateMapper.xml
delete mode 100644 src/main/java/neatlogic/framework/process/dao/mapper/ProcessEventMapper.java
delete mode 100644 src/main/java/neatlogic/framework/process/dao/mapper/ProcessEventMapper.xml
delete mode 100644 src/main/java/neatlogic/framework/process/dao/mapper/ProcessStepHandlerMapper.java
delete mode 100644 src/main/java/neatlogic/framework/process/dao/mapper/ProcessStepHandlerMapper.xml
delete mode 100644 src/main/java/neatlogic/framework/process/dao/mapper/ProcessTagMapper.java
delete mode 100644 src/main/java/neatlogic/framework/process/dao/mapper/ProcessTagMapper.xml
delete mode 100644 src/main/java/neatlogic/framework/process/dao/mapper/ProcessTaskAgentMapper.java
delete mode 100644 src/main/java/neatlogic/framework/process/dao/mapper/ProcessTaskAgentMapper.xml
delete mode 100644 src/main/java/neatlogic/framework/process/dao/mapper/ProcessTaskMapper.xml
delete mode 100644 src/main/java/neatlogic/framework/process/dao/mapper/ProcessTaskSerialNumberMapper.java
delete mode 100644 src/main/java/neatlogic/framework/process/dao/mapper/ProcessTaskSerialNumberMapper.xml
delete mode 100644 src/main/java/neatlogic/framework/process/dao/mapper/ProcessTaskSlaMapper.java
delete mode 100644 src/main/java/neatlogic/framework/process/dao/mapper/ProcessTaskSlaMapper.xml
delete mode 100644 src/main/java/neatlogic/framework/process/dao/mapper/ProcessTaskStepDataMapper.java
delete mode 100644 src/main/java/neatlogic/framework/process/dao/mapper/ProcessTaskStepDataMapper.xml
delete mode 100644 src/main/java/neatlogic/framework/process/dao/mapper/ProcessTaskStepTaskMapper.java
delete mode 100644 src/main/java/neatlogic/framework/process/dao/mapper/ProcessTaskStepTaskMapper.xml
delete mode 100644 src/main/java/neatlogic/framework/process/dao/mapper/ProcessTaskStepTimeAuditMapper.java
delete mode 100644 src/main/java/neatlogic/framework/process/dao/mapper/ProcessTaskStepTimeAuditMapper.xml
delete mode 100644 src/main/java/neatlogic/framework/process/dao/mapper/SelectContentByHashMapper.java
delete mode 100644 src/main/java/neatlogic/framework/process/dao/mapper/SelectContentByHashMapper.xml
delete mode 100755 src/main/java/neatlogic/framework/process/dao/mapper/score/ProcessTaskScoreMapper.xml
delete mode 100755 src/main/java/neatlogic/framework/process/dao/mapper/score/ScoreTemplateMapper.java
delete mode 100755 src/main/java/neatlogic/framework/process/dao/mapper/score/ScoreTemplateMapper.xml
delete mode 100755 src/main/java/neatlogic/framework/process/dao/mapper/task/TaskMapper.java
delete mode 100644 src/main/java/neatlogic/framework/process/dao/mapper/task/TaskMapper.xml
delete mode 100644 src/main/java/neatlogic/framework/process/dao/mapper/workcenter/WorkcenterMapper.java
delete mode 100644 src/main/java/neatlogic/framework/process/dao/mapper/workcenter/WorkcenterMapper.xml
delete mode 100644 src/main/java/neatlogic/framework/process/event/core/ProcessEventHandler.java
delete mode 100755 src/main/java/neatlogic/framework/process/service/ChannelService.java
delete mode 100644 src/main/java/neatlogic/framework/process/service/ChannelServiceImpl.java
delete mode 100755 src/main/java/neatlogic/framework/process/service/ProcessTaskAgentService.java
delete mode 100644 src/main/java/neatlogic/framework/process/service/ProcessTaskAgentServiceImpl.java
delete mode 100755 src/main/java/neatlogic/framework/process/stephandler/core/ProcessTaskStepTimeoutDetector.java
diff --git a/src/main/java/neatlogic/framework/process/audithandler/core/ProcessTaskStepAuditDetailHandlerBase.java b/src/main/java/neatlogic/framework/process/audithandler/core/ProcessTaskStepAuditDetailHandlerBase.java
index f8e504dd..5d5c86ce 100755
--- a/src/main/java/neatlogic/framework/process/audithandler/core/ProcessTaskStepAuditDetailHandlerBase.java
+++ b/src/main/java/neatlogic/framework/process/audithandler/core/ProcessTaskStepAuditDetailHandlerBase.java
@@ -1,29 +1,22 @@
package neatlogic.framework.process.audithandler.core;
-import org.apache.commons.lang3.StringUtils;
-import org.springframework.beans.factory.annotation.Autowired;
-
-import neatlogic.framework.process.dao.mapper.SelectContentByHashMapper;
+import neatlogic.framework.crossover.CrossoverServiceFactory;
+import neatlogic.framework.process.crossover.ISelectContentByHashCrossoverMapper;
import neatlogic.framework.process.dto.ProcessTaskStepAuditDetailVo;
+import org.apache.commons.lang3.StringUtils;
public abstract class ProcessTaskStepAuditDetailHandlerBase implements IProcessTaskStepAuditDetailHandler {
-
- protected static SelectContentByHashMapper selectContentByHashMapper;
-
- @Autowired
- private void setSelectContentByHashMapper(SelectContentByHashMapper _selectContentByHashMapper) {
- selectContentByHashMapper = _selectContentByHashMapper;
- }
@Override
public int handle(ProcessTaskStepAuditDetailVo processTaskStepAuditDetailVo) {
+ ISelectContentByHashCrossoverMapper selectContentByHashCrossoverMapper = CrossoverServiceFactory.getApi(ISelectContentByHashCrossoverMapper.class);
String oldContent = processTaskStepAuditDetailVo.getOldContent();
if(StringUtils.isNotBlank(oldContent)) {
- processTaskStepAuditDetailVo.setOldContent(selectContentByHashMapper.getProcessTaskContentStringByHash(oldContent));
+ processTaskStepAuditDetailVo.setOldContent(selectContentByHashCrossoverMapper.getProcessTaskContentStringByHash(oldContent));
}
String newContent = processTaskStepAuditDetailVo.getNewContent();
if(StringUtils.isNotBlank(newContent)) {
- processTaskStepAuditDetailVo.setNewContent(selectContentByHashMapper.getProcessTaskContentStringByHash(newContent));
+ processTaskStepAuditDetailVo.setNewContent(selectContentByHashCrossoverMapper.getProcessTaskContentStringByHash(newContent));
}
return myHandle(processTaskStepAuditDetailVo);
}
diff --git a/src/main/java/neatlogic/framework/process/condition/core/ProcessTaskConditionBase.java b/src/main/java/neatlogic/framework/process/condition/core/ProcessTaskConditionBase.java
index f115f9c4..eb5a18ac 100644
--- a/src/main/java/neatlogic/framework/process/condition/core/ProcessTaskConditionBase.java
+++ b/src/main/java/neatlogic/framework/process/condition/core/ProcessTaskConditionBase.java
@@ -15,9 +15,13 @@ along with this program. If not, see .*/
package neatlogic.framework.process.condition.core;
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
import neatlogic.framework.asynchronization.threadlocal.UserContext;
import neatlogic.framework.common.constvalue.Expression;
import neatlogic.framework.common.constvalue.GroupSearch;
+import neatlogic.framework.crossover.CrossoverServiceFactory;
import neatlogic.framework.dao.mapper.UserMapper;
import neatlogic.framework.dto.AuthenticationInfoVo;
import neatlogic.framework.dto.condition.ConditionVo;
@@ -25,21 +29,18 @@ import neatlogic.framework.process.constvalue.ConditionConfigType;
import neatlogic.framework.process.constvalue.ProcessTaskStatus;
import neatlogic.framework.process.constvalue.ProcessTaskStepStatus;
import neatlogic.framework.process.constvalue.ProcessWorkcenterField;
-import neatlogic.framework.process.dao.mapper.ProcessTaskAgentMapper;
-import neatlogic.framework.process.dao.mapper.ProcessTaskMapper;
+import neatlogic.framework.process.crossover.IProcessTaskAgentCrossoverMapper;
+import neatlogic.framework.process.crossover.IProcessTaskAgentCrossoverService;
+import neatlogic.framework.process.crossover.IProcessTaskCrossoverMapper;
import neatlogic.framework.process.dto.SqlDecoratorVo;
import neatlogic.framework.process.dto.agent.ProcessTaskAgentTargetVo;
import neatlogic.framework.process.dto.agent.ProcessTaskAgentVo;
-import neatlogic.framework.process.service.ProcessTaskAgentService;
import neatlogic.framework.process.workcenter.dto.JoinTableColumnVo;
import neatlogic.framework.process.workcenter.table.ProcessTaskSqlTable;
import neatlogic.framework.process.workcenter.table.ProcessTaskStepSqlTable;
import neatlogic.framework.process.workcenter.table.ProcessTaskStepWorkerSqlTable;
import neatlogic.framework.service.AuthenticationInfoService;
import neatlogic.framework.util.TimeUtil;
-import com.alibaba.fastjson.JSON;
-import com.alibaba.fastjson.JSONArray;
-import com.alibaba.fastjson.JSONObject;
import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.lang3.StringUtils;
@@ -57,20 +58,6 @@ public abstract class ProcessTaskConditionBase implements IProcessTaskCondition
userMapper = _userMapper;
}
- protected static ProcessTaskAgentMapper processTaskAgentMapper;
-
- @Resource
- public void setProcessTaskAgentMapper(ProcessTaskAgentMapper _processTaskAgentMapper) {
- processTaskAgentMapper = _processTaskAgentMapper;
- }
-
- protected static ProcessTaskMapper processTaskMapper;
-
- @Resource
- public void setProcessTaskMapper(ProcessTaskMapper _processTaskMapper) {
- processTaskMapper = _processTaskMapper;
- }
-
protected static AuthenticationInfoService authenticationInfoService;
@Resource
@@ -78,13 +65,6 @@ public abstract class ProcessTaskConditionBase implements IProcessTaskCondition
authenticationInfoService = _authenticationInfoService;
}
- protected ProcessTaskAgentService processTaskAgentService;
-
- @Resource
- public void setProcessTaskAgentService(ProcessTaskAgentService _processTaskAgentService) {
- processTaskAgentService = _processTaskAgentService;
- }
-
protected void getSimpleSqlConditionWhere(ConditionVo condition, StringBuilder sqlSb, String tableShortName, String columnName) {
Object value = StringUtils.EMPTY;
if (condition.getValueList() instanceof String) {
@@ -222,17 +202,20 @@ public abstract class ProcessTaskConditionBase implements IProcessTaskCondition
* @return 工单idList
*/
private List getAgentProcessTaskId() {
+ IProcessTaskAgentCrossoverMapper processTaskAgentCrossoverMapper = CrossoverServiceFactory.getApi(IProcessTaskAgentCrossoverMapper.class);
+ IProcessTaskCrossoverMapper processTaskCrossoverMapper = CrossoverServiceFactory.getApi(IProcessTaskCrossoverMapper.class);
Set allProcessTaskIdSet = new HashSet<>();
//1 找出所有当前用户授权记录
- List taskAgentVos = processTaskAgentMapper.getProcessTaskAgentDetailListByToUserUuid(UserContext.get().getUserUuid(true));
+ List taskAgentVos = processTaskAgentCrossoverMapper.getProcessTaskAgentDetailListByToUserUuid(UserContext.get().getUserUuid(true));
//2 循环记录 找出给个授权记录对应的taskIdList 并append
for (ProcessTaskAgentVo taskAgentVo : taskAgentVos) {
List taskAgentTargetVos = taskAgentVo.getProcessTaskAgentTargetVos();
if (CollectionUtils.isNotEmpty(taskAgentTargetVos)) {
+ IProcessTaskAgentCrossoverService processTaskAgentCrossoverService = CrossoverServiceFactory.getApi(IProcessTaskAgentCrossoverService.class);
//根据channelUuid找到formUser 所有能处理的工单idList
- List channelUuidList = processTaskAgentService.getChannelUuidListByProcessTaskAgentId(taskAgentVo.getId());
+ List channelUuidList = processTaskAgentCrossoverService.getChannelUuidListByProcessTaskAgentId(taskAgentVo.getId());
AuthenticationInfoVo authenticationInfoVo = authenticationInfoService.getAuthenticationInfo(taskAgentVo.getFromUserUuid());
- Set processTaskIdSet = processTaskMapper.getProcessTaskIdSetByChannelUuidListAndAuthenticationInfo(channelUuidList, authenticationInfoVo);
+ Set processTaskIdSet = processTaskCrossoverMapper.getProcessTaskIdSetByChannelUuidListAndAuthenticationInfo(channelUuidList, authenticationInfoVo);
allProcessTaskIdSet.addAll(processTaskIdSet);
}
}
diff --git a/src/main/java/neatlogic/framework/process/crossover/ICatalogCrossoverMapper.java b/src/main/java/neatlogic/framework/process/crossover/ICatalogCrossoverMapper.java
new file mode 100644
index 00000000..8760a4dd
--- /dev/null
+++ b/src/main/java/neatlogic/framework/process/crossover/ICatalogCrossoverMapper.java
@@ -0,0 +1,32 @@
+/*
+ * Copyright (C) 2024 深圳极向量科技有限公司 All Rights Reserved.
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Affero General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU Affero General Public License for more details.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see .
+ */
+
+package neatlogic.framework.process.crossover;
+
+import neatlogic.framework.crossover.ICrossoverService;
+import neatlogic.framework.process.dto.CatalogVo;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+public interface ICatalogCrossoverMapper extends ICrossoverService {
+
+ CatalogVo getCatalogByUuid(String uuid);
+
+ List getUpwardUuidListByLftRht(@Param("lft") Integer lft, @Param("rht") Integer rht);
+
+}
diff --git a/src/main/java/neatlogic/framework/process/crossover/IChannelCrossoverMapper.java b/src/main/java/neatlogic/framework/process/crossover/IChannelCrossoverMapper.java
new file mode 100644
index 00000000..e894ba19
--- /dev/null
+++ b/src/main/java/neatlogic/framework/process/crossover/IChannelCrossoverMapper.java
@@ -0,0 +1,28 @@
+/*
+ * Copyright (C) 2024 深圳极向量科技有限公司 All Rights Reserved.
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Affero General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU Affero General Public License for more details.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see .
+ */
+
+package neatlogic.framework.process.crossover;
+
+import neatlogic.framework.crossover.ICrossoverService;
+import neatlogic.framework.process.dto.ChannelVo;
+
+public interface IChannelCrossoverMapper extends ICrossoverService {
+
+ ChannelVo getChannelByUuid(String channelUuid);
+
+ String getWorktimeUuidByChannelUuid(String channelUuid);
+}
diff --git a/src/main/java/neatlogic/framework/process/crossover/IChannelTypeCrossoverMapper.java b/src/main/java/neatlogic/framework/process/crossover/IChannelTypeCrossoverMapper.java
new file mode 100644
index 00000000..98df529c
--- /dev/null
+++ b/src/main/java/neatlogic/framework/process/crossover/IChannelTypeCrossoverMapper.java
@@ -0,0 +1,26 @@
+/*
+ * Copyright (C) 2024 深圳极向量科技有限公司 All Rights Reserved.
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Affero General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU Affero General Public License for more details.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see .
+ */
+
+package neatlogic.framework.process.crossover;
+
+import neatlogic.framework.crossover.ICrossoverService;
+import neatlogic.framework.process.dto.ChannelTypeVo;
+
+public interface IChannelTypeCrossoverMapper extends ICrossoverService {
+
+ ChannelTypeVo getChannelTypeByUuid(String uuid);
+}
diff --git a/src/main/java/neatlogic/framework/process/crossover/IProcessStepHandlerCrossoverMapper.java b/src/main/java/neatlogic/framework/process/crossover/IProcessStepHandlerCrossoverMapper.java
new file mode 100644
index 00000000..fffdda03
--- /dev/null
+++ b/src/main/java/neatlogic/framework/process/crossover/IProcessStepHandlerCrossoverMapper.java
@@ -0,0 +1,25 @@
+/*
+ * Copyright (C) 2024 深圳极向量科技有限公司 All Rights Reserved.
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Affero General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU Affero General Public License for more details.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see .
+ */
+
+package neatlogic.framework.process.crossover;
+
+import neatlogic.framework.crossover.ICrossoverService;
+
+public interface IProcessStepHandlerCrossoverMapper extends ICrossoverService {
+
+ String getProcessStepHandlerConfigByHandler(String handler);
+}
diff --git a/src/main/java/neatlogic/framework/process/stephandler/core/IProcessStepHandlerUtil.java b/src/main/java/neatlogic/framework/process/crossover/IProcessStepHandlerCrossoverUtil.java
similarity index 65%
rename from src/main/java/neatlogic/framework/process/stephandler/core/IProcessStepHandlerUtil.java
rename to src/main/java/neatlogic/framework/process/crossover/IProcessStepHandlerCrossoverUtil.java
index c69d843e..7f237ac1 100644
--- a/src/main/java/neatlogic/framework/process/stephandler/core/IProcessStepHandlerUtil.java
+++ b/src/main/java/neatlogic/framework/process/crossover/IProcessStepHandlerCrossoverUtil.java
@@ -1,19 +1,23 @@
-/*Copyright (C) 2024 深圳极向量科技有限公司 All Rights Reserved.
-
-This program is free software: you can redistribute it and/or modify
-it under the terms of the GNU Affero General Public License as published by
-the Free Software Foundation, either version 3 of the License, or
-(at your option) any later version.
-
-This program is distributed in the hope that it will be useful,
-but WITHOUT ANY WARRANTY; without even the implied warranty of
-MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
-GNU Affero General Public License for more details.
-
-You should have received a copy of the GNU Affero General Public License
-along with this program. If not, see .*/
-package neatlogic.framework.process.stephandler.core;
-
+/*
+ * Copyright (C) 2024 深圳极向量科技有限公司 All Rights Reserved.
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Affero General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU Affero General Public License for more details.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see .
+ */
+
+package neatlogic.framework.process.crossover;
+
+import neatlogic.framework.crossover.ICrossoverService;
import neatlogic.framework.notify.core.INotifyTriggerType;
import neatlogic.framework.process.audithandler.core.IProcessTaskAuditType;
import neatlogic.framework.process.constvalue.ProcessTaskOperationType;
@@ -21,9 +25,7 @@ import neatlogic.framework.process.dto.ProcessTaskStepVo;
import neatlogic.framework.process.dto.ProcessTaskVo;
import neatlogic.framework.process.stepremind.core.IProcessTaskStepRemindType;
-import java.util.List;
-
-public interface IProcessStepHandlerUtil {
+public interface IProcessStepHandlerCrossoverUtil extends ICrossoverService {
/**
* @Description: 触发动作
* @Author: linbq
@@ -42,15 +44,6 @@ public interface IProcessStepHandlerUtil {
**/
void notify(ProcessTaskStepVo currentProcessTaskStepVo, INotifyTriggerType trigger);
- /**
- * @Description: 计算时效
- * @Author: linbq
- * @Date: 2021/1/20 16:17
- * @Params:[currentProcessTaskVo, isAsync]
- * @Returns:void
- **/
- void calculateSla(ProcessTaskVo currentProcessTaskVo, boolean isAsync);
-
/**
* @Description: 计算时效
* @Author: linbq
@@ -69,15 +62,6 @@ public interface IProcessStepHandlerUtil {
**/
void calculateSla(ProcessTaskStepVo currentProcessTaskStepVo);
- /**
- * @Description: 计算时效
- * @Author: linbq
- * @Date: 2021/1/20 16:17
- * @Params:[currentProcessTaskVo, isAsync]
- * @Returns:void
- **/
- void calculateSla(ProcessTaskVo currentProcessTaskVo, ProcessTaskStepVo currentProcessTaskStepVo, boolean isAsync);
-
/**
* @Description: 记录操作时间
* @Author: linbq
@@ -96,15 +80,6 @@ public interface IProcessStepHandlerUtil {
**/
void audit(ProcessTaskStepVo currentProcessTaskStepVo, IProcessTaskAuditType action);
- /**
- * @Description: 自动评分
- * @Author: linbq
- * @Date: 2021/1/20 16:22
- * @Params:[currentProcessTaskVo]
- * @Returns:void
- **/
- void autoScore(ProcessTaskVo currentProcessTaskVo);
-
/**
* @Description: 获取验证基本信息数据是否合法,并验证
* @Author: linbq
@@ -114,15 +89,6 @@ public interface IProcessStepHandlerUtil {
**/
boolean baseInfoValidFromDb(ProcessTaskStepVo currentProcessTaskStepVo);
- /**
- * @Description: 验证基本信息数据是否合法
- * @Author: linbq
- * @Date: 2021/1/20 16:21
- * @Params:[currentProcessTaskStepVo, processTaskVo]
- * @Returns:boolean
- **/
- boolean baseInfoValid(ProcessTaskStepVo currentProcessTaskStepVo, ProcessTaskVo processTaskVo);
-
/**
* @Description: 验证前置步骤指派处理人是否合法
* @Author: linbq
@@ -132,15 +98,6 @@ public interface IProcessStepHandlerUtil {
**/
boolean assignWorkerValid(ProcessTaskStepVo currentProcessTaskStepVo);
- /**
- * 找出流转到哪些步骤时,需要指定targetStepId步骤的处理人
- * @param processTaskId 工单id
- * @param currentStepId 当前流转步骤id
- * @param targetStepId 配置了由当前步骤处理人指定处理人的步骤id
- * @return
- */
- List getNextStepIdList(Long processTaskId, Long currentStepId, Long targetStepId);
-
/**
* @Description: 保存步骤提醒
* @Author: linbq
diff --git a/src/main/java/neatlogic/framework/process/crossover/IProcessTaskAgentCrossoverMapper.java b/src/main/java/neatlogic/framework/process/crossover/IProcessTaskAgentCrossoverMapper.java
new file mode 100644
index 00000000..5fa24043
--- /dev/null
+++ b/src/main/java/neatlogic/framework/process/crossover/IProcessTaskAgentCrossoverMapper.java
@@ -0,0 +1,28 @@
+/*
+ * Copyright (C) 2024 深圳极向量科技有限公司 All Rights Reserved.
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Affero General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU Affero General Public License for more details.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see .
+ */
+
+package neatlogic.framework.process.crossover;
+
+import neatlogic.framework.crossover.ICrossoverService;
+import neatlogic.framework.process.dto.agent.ProcessTaskAgentVo;
+
+import java.util.List;
+
+public interface IProcessTaskAgentCrossoverMapper extends ICrossoverService {
+
+ List getProcessTaskAgentDetailListByToUserUuid(String toUserUuid);
+}
diff --git a/src/main/java/neatlogic/framework/process/crossover/IProcessTaskAgentCrossoverService.java b/src/main/java/neatlogic/framework/process/crossover/IProcessTaskAgentCrossoverService.java
new file mode 100644
index 00000000..846cc5ce
--- /dev/null
+++ b/src/main/java/neatlogic/framework/process/crossover/IProcessTaskAgentCrossoverService.java
@@ -0,0 +1,29 @@
+/*
+ * Copyright (C) 2024 深圳极向量科技有限公司 All Rights Reserved.
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Affero General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU Affero General Public License for more details.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see .
+ */
+
+package neatlogic.framework.process.crossover;
+
+import neatlogic.framework.crossover.ICrossoverService;
+
+import java.util.List;
+
+public interface IProcessTaskAgentCrossoverService extends ICrossoverService {
+
+ List getFromUserUuidListByToUserUuidAndChannelUuid(String toUserUuid, String channelUuid);
+
+ List getChannelUuidListByProcessTaskAgentId(Long processTaskAgentId);
+}
diff --git a/src/main/java/neatlogic/framework/process/dao/mapper/ProcessTaskMapper.java b/src/main/java/neatlogic/framework/process/crossover/IProcessTaskCrossoverMapper.java
similarity index 30%
rename from src/main/java/neatlogic/framework/process/dao/mapper/ProcessTaskMapper.java
rename to src/main/java/neatlogic/framework/process/crossover/IProcessTaskCrossoverMapper.java
index 60697588..f92cc94f 100644
--- a/src/main/java/neatlogic/framework/process/dao/mapper/ProcessTaskMapper.java
+++ b/src/main/java/neatlogic/framework/process/crossover/IProcessTaskCrossoverMapper.java
@@ -1,99 +1,39 @@
-/*Copyright (C) $today.year 深圳极向量科技有限公司 All Rights Reserved.
-
-This program is free software: you can redistribute it and/or modify
-it under the terms of the GNU Affero General Public License as published by
-the Free Software Foundation, either version 3 of the License, or
-(at your option) any later version.
-
-This program is distributed in the hope that it will be useful,
-but WITHOUT ANY WARRANTY; without even the implied warranty of
-MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
-GNU Affero General Public License for more details.
-
-You should have received a copy of the GNU Affero General Public License
-along with this program. If not, see .*/
-
-package neatlogic.framework.process.dao.mapper;
-
+/*
+ * Copyright (C) 2024 深圳极向量科技有限公司 All Rights Reserved.
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Affero General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU Affero General Public License for more details.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see .
+ */
+
+package neatlogic.framework.process.crossover;
+
+import neatlogic.framework.crossover.ICrossoverService;
import neatlogic.framework.dto.AuthenticationInfoVo;
-import neatlogic.framework.file.dto.FileVo;
-import neatlogic.framework.form.dto.AttributeDataVo;
import neatlogic.framework.process.dto.*;
-import neatlogic.framework.process.dto.automatic.ProcessTaskStepAutomaticRequestVo;
import org.apache.ibatis.annotations.Param;
import java.util.List;
-import java.util.Map;
import java.util.Set;
-public interface ProcessTaskMapper {
-
- List getProcessTaskByStatusList(@Param("statusList") List statusList, @Param("count") Integer count);
-
- /**
- * 获取工单基本信息(已删除则忽略)
- *
- * @param processTaskId
- * @return
- */
- ProcessTaskVo getProcessTaskBaseInfoById(Long processTaskId);
-
- /**
- * 获取工单基本信息(不限是否已删除)
- *
- * @param processTaskId
- * @return
- */
- ProcessTaskVo getProcessTaskBaseInfoByIdIncludeIsDeleted(Long processTaskId);
-
- List getTaskListByIdList(List idList);
-
- /**
- * 查询待处理的工单id
- *
- * @param map 工单查询条件
- * @return 工单ID列表
- */
- List getProcessingTaskIdListByCondition(@Param("conditionMap") Map map);
-
- /**
- * 查询待处理的工单数量
- *
- * @param map 工单查询条件
- * @return 工单数量
- */
- int getProcessingTaskCountByCondition(@Param("conditionMap") Map map);
+public interface IProcessTaskCrossoverMapper extends ICrossoverService {
List getProcessTaskStepBaseInfoByProcessTaskId(Long processTaskId);
-// List getProcessTaskStepIdByConvergeId(Long convergeId);
-
ProcessTaskFormVo getProcessTaskFormByProcessTaskId(Long processTaskId);
- List getProcessTaskFormExtendAttributeListByProcessTaskIdAndTag(@Param("processTaskId") Long processTaskId, @Param("tag") String tag);
-
- List getProcessTaskFormListByProcessTaskIdList(List existsProcessTaskIdList);
-
- List getProcessTaskFormAttributeDataIdListByProcessTaskId(Long processTaskId);
-
- List getProcessTaskFormAttributeDataListByProcessTaskId(Long processTaskId);
-
- List getProcessTaskExtendFormAttributeDataIdListByProcessTaskId(Long processTaskId);
-
- List getProcessTaskExtendFormAttributeDataListByProcessTaskId(@Param("processTaskId") Long processTaskId, @Param("tag") String tag);
-
- List getProcessTaskStepContentByProcessTaskStepId(Long processTaskStepId);
-
- List getProcessTaskStepContentByProcessTaskId(Long processTaskId);
-
- String getProcessTaskStartContentByProcessTaskId(Long processTaskId);
-
List getProcessTaskStepUserByStepId(
@Param("processTaskStepId") Long processTaskStepId, @Param("userType") String userType);
- List getProcessTaskStepUserByStepIdList(
- @Param("processTaskStepIdList") List processTaskStepIdList, @Param("userType") String userType);
-
List
getProcessTaskStepWorkerPolicy(ProcessTaskStepWorkerPolicyVo processTaskStepWorkerPolicyVo);
@@ -102,22 +42,14 @@ public interface ProcessTaskMapper {
List getProcessTaskStepWorkerListByProcessTaskIdList(List processTaskIdList);
- List getProcessTaskStepWorkerListByProcessTaskStepIdListAndUserType(@Param("processTaskStepIdList") List processTaskStepIdList, @Param("userType") String userType);
-
int checkProcessTaskStepWorkerIsExistsByPrimaryKey(ProcessTaskStepWorkerVo processTaskStepWorkerVo);
Long getProcessTaskLockById(Long processTaskId);
- ProcessTaskVo getProcessTaskVoLockById(Long processTaskId);
-
int checkProcessTaskConvergeIsExists(ProcessTaskConvergeVo processTaskStepConvergeVo);
List getProcessTaskConvergeListByStepId(Long processTaskStepId);
-// List getFromProcessTaskStepByToId(Long toProcessTaskStepId);
-
- List getFromProcessTaskStepIdListByToId(Long toProcessTaskStepId);
-
List getToProcessTaskStepByFromIdAndType(
@Param("fromProcessTaskStepId") Long fromProcessTaskStepId, @Param("type") String type);
@@ -128,8 +60,6 @@ public interface ProcessTaskMapper {
List getProcessTaskStepRelByFromId(Long fromProcessTaskStepId);
- List getProcessTaskStepRelListByFromIdList(List fromProcessTaskStepIdList);
-
List getProcessTaskStepRelByToId(Long toProcessTaskStepId);
List getProcessTaskStepRelListByToIdList(List toStepIdList);
@@ -138,37 +68,15 @@ public interface ProcessTaskMapper {
List getProcessTaskStepRelListByProcessTaskIdList(List processTaskIdList);
- ProcessTaskStepVo getStartProcessTaskStepByProcessTaskId(Long processTaskId);
-
- ProcessTaskStepVo getEndProcessTaskStepByProcessTaskId(Long processTaskId);
-
List getProcessTaskStepByProcessTaskIdAndType(@Param("processTaskId") Long processTaskId,
@Param("type") String type);
- List getProcessTaskActiveStepByProcessTaskIdAndProcessStepType(
- @Param("processTaskId") Long processTaskId, @Param("processStepTypeList") List processStepTypeList,
- @Param("isActive") Integer isActive);
-
ProcessTaskStepVo getProcessTaskStepBaseInfoById(Long processTaskStepId);
ProcessTaskVo getProcessTaskById(Long id);
- List getProcessTaskByIdStrList(List idList);
-
- List getProcessTaskBySerialNumberList(List serialNumberList);
-
- List getProcessTaskStepAuditList(ProcessTaskStepAuditVo processTaskStepAuditVo);
-
- List getProcessTaskStepListByProcessTaskId(Long processTaskId);
-
List getProcessTaskStepListByProcessTaskIdList(List processTaskIdList);
- Set getProcessTaskStepIdSetByChannelUuidListAndAuthenticationInfo(
- @Param("keyword") String keyword,
- @Param("channelUuidList") List channelUuidList,
- @Param("authenticationInfoVo") AuthenticationInfoVo authenticationInfoVo
- );
-
Set getProcessTaskIdSetByChannelUuidListAndAuthenticationInfo(@Param("channelUuidList") List channelUuidList, @Param("authenticationInfoVo") AuthenticationInfoVo authenticationInfoVo);
int checkIsWorker(@Param("processTaskId") Long processTaskId,
@@ -177,213 +85,41 @@ public interface ProcessTaskMapper {
int checkIsProcessTaskStepUser(ProcessTaskStepUserVo processTaskStepUserVo);
- List getProcessTaskAssignWorker(ProcessTaskAssignWorkerVo processTaskAssignWorkerVo);
-
ProcessTaskStepVo getProcessTaskStepBaseInfoByProcessTaskIdAndProcessStepUuid(
@Param("processTaskId") Long processTaskId, @Param("processStepUuid") String processStepUuid);
- List getProcessTaskAuditList(ProcessTaskStepAuditVo processTaskStepAuditVo);
-
List getProcessTaskListByIdList(List processTaskIdList);
List getProcessTaskStepListByIdList(List processTaskStepIdList);
-// ProcessTaskStepNotifyPolicyVo getProcessTaskStepNotifyPolicy(ProcessTaskStepNotifyPolicyVo processTaskStepNotifyPolicyVo);
-
- Map getProcessTaskOldFormAndPropByTaskId(Long processTaskId);
-
- List