From 234a2e4efb1f4d5514a285efd762b10f9bce216c Mon Sep 17 00:00:00 2001 From: xiang2lin <251481237@qq.com> Date: Tue, 6 May 2025 09:31:02 +0800 Subject: [PATCH] =?UTF-8?q?=E8=BF=9E=E6=8E=A5=E5=99=A8=E4=BB=A3=E7=A0=81?= =?UTF-8?q?=E6=8F=90=E4=BA=A4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../frame/sys/flow/dao/ISysFlowClassDao.java | 15 + .../sys/flow/dao/ISysFlowClassRuleDao.java | 15 + .../hzya/frame/sys/flow/dao/ISysFlowDao.java | 15 + .../sys/flow/dao/ISysFlowNifiConstantDao.java | 15 + .../sys/flow/dao/ISysFlowStepAccountDao.java | 15 + .../sys/flow/dao/ISysFlowStepConfigBDao.java | 15 + .../sys/flow/dao/ISysFlowStepConfigDao.java | 15 + .../frame/sys/flow/dao/ISysFlowStepDao.java | 15 + .../sys/flow/dao/ISysFlowStepRelationDao.java | 15 + .../flow/dao/impl/SysFlowClassDaoImpl.java | 17 + .../dao/impl/SysFlowClassRuleDaoImpl.java | 17 + .../sys/flow/dao/impl/SysFlowDaoImpl.java | 17 + .../dao/impl/SysFlowNifiConstantDaoImpl.java | 17 + .../dao/impl/SysFlowStepAccountDaoImpl.java | 17 + .../dao/impl/SysFlowStepConfigBDaoImpl.java | 17 + .../dao/impl/SysFlowStepConfigDaoImpl.java | 17 + .../sys/flow/dao/impl/SysFlowStepDaoImpl.java | 17 + .../dao/impl/SysFlowStepRelationDaoImpl.java | 17 + .../sys/flow/entity/SysFlowClassEntity.java | 36 +++ .../sys/flow/entity/SysFlowClassEntity.xml | 193 +++++++++++ .../flow/entity/SysFlowClassRuleEntity.java | 75 +++++ .../flow/entity/SysFlowClassRuleEntity.xml | 247 ++++++++++++++ .../frame/sys/flow/entity/SysFlowEntity.java | 74 +++++ .../frame/sys/flow/entity/SysFlowEntity.xml | 234 ++++++++++++++ .../entity/SysFlowNifiConstantEntity.java | 66 ++++ .../flow/entity/SysFlowNifiConstantEntity.xml | 226 +++++++++++++ .../flow/entity/SysFlowStepAccountEntity.java | 126 ++++++++ .../flow/entity/SysFlowStepAccountEntity.xml | 292 +++++++++++++++++ .../flow/entity/SysFlowStepConfigBEntity.java | 126 ++++++++ .../flow/entity/SysFlowStepConfigBEntity.xml | 292 +++++++++++++++++ .../flow/entity/SysFlowStepConfigEntity.java | 136 ++++++++ .../flow/entity/SysFlowStepConfigEntity.xml | 303 ++++++++++++++++++ .../sys/flow/entity/SysFlowStepEntity.java | 116 +++++++ .../sys/flow/entity/SysFlowStepEntity.xml | 281 ++++++++++++++++ .../entity/SysFlowStepRelationEntity.java | 76 +++++ .../flow/entity/SysFlowStepRelationEntity.xml | 237 ++++++++++++++ .../service/ISysFlowClassRuleService.java | 50 +++ .../flow/service/ISysFlowClassService.java | 36 +++ .../service/ISysFlowNifiConstantService.java | 36 +++ .../sys/flow/service/ISysFlowService.java | 12 + .../service/ISysFlowStepAccountService.java | 12 + .../service/ISysFlowStepConfigBService.java | 12 + .../service/ISysFlowStepConfigService.java | 12 + .../service/ISysFlowStepRelationService.java | 12 + .../sys/flow/service/ISysFlowStepService.java | 12 + .../impl/SysFlowClassRuleServiceImpl.java | 174 ++++++++++ .../service/impl/SysFlowClassServiceImpl.java | 136 ++++++++ .../impl/SysFlowNifiConstantServiceImpl.java | 135 ++++++++ .../flow/service/impl/SysFlowServiceImpl.java | 26 ++ .../impl/SysFlowStepAccountServiceImpl.java | 26 ++ .../impl/SysFlowStepConfigBServiceImpl.java | 26 ++ .../impl/SysFlowStepConfigServiceImpl.java | 26 ++ .../impl/SysFlowStepRelationServiceImpl.java | 26 ++ .../service/impl/SysFlowStepServiceImpl.java | 26 ++ 54 files changed, 4219 insertions(+) create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/dao/ISysFlowClassDao.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/dao/ISysFlowClassRuleDao.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/dao/ISysFlowDao.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/dao/ISysFlowNifiConstantDao.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/dao/ISysFlowStepAccountDao.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/dao/ISysFlowStepConfigBDao.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/dao/ISysFlowStepConfigDao.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/dao/ISysFlowStepDao.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/dao/ISysFlowStepRelationDao.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/dao/impl/SysFlowClassDaoImpl.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/dao/impl/SysFlowClassRuleDaoImpl.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/dao/impl/SysFlowDaoImpl.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/dao/impl/SysFlowNifiConstantDaoImpl.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/dao/impl/SysFlowStepAccountDaoImpl.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/dao/impl/SysFlowStepConfigBDaoImpl.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/dao/impl/SysFlowStepConfigDaoImpl.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/dao/impl/SysFlowStepDaoImpl.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/dao/impl/SysFlowStepRelationDaoImpl.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowClassEntity.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowClassEntity.xml create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowClassRuleEntity.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowClassRuleEntity.xml create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowEntity.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowEntity.xml create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowNifiConstantEntity.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowNifiConstantEntity.xml create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowStepAccountEntity.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowStepAccountEntity.xml create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowStepConfigBEntity.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowStepConfigBEntity.xml create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowStepConfigEntity.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowStepConfigEntity.xml create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowStepEntity.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowStepEntity.xml create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowStepRelationEntity.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowStepRelationEntity.xml create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/service/ISysFlowClassRuleService.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/service/ISysFlowClassService.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/service/ISysFlowNifiConstantService.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/service/ISysFlowService.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/service/ISysFlowStepAccountService.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/service/ISysFlowStepConfigBService.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/service/ISysFlowStepConfigService.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/service/ISysFlowStepRelationService.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/service/ISysFlowStepService.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/service/impl/SysFlowClassRuleServiceImpl.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/service/impl/SysFlowClassServiceImpl.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/service/impl/SysFlowNifiConstantServiceImpl.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/service/impl/SysFlowServiceImpl.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/service/impl/SysFlowStepAccountServiceImpl.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/service/impl/SysFlowStepConfigBServiceImpl.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/service/impl/SysFlowStepConfigServiceImpl.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/service/impl/SysFlowStepRelationServiceImpl.java create mode 100644 base-service/src/main/java/com/hzya/frame/sys/flow/service/impl/SysFlowStepServiceImpl.java diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/dao/ISysFlowClassDao.java b/base-service/src/main/java/com/hzya/frame/sys/flow/dao/ISysFlowClassDao.java new file mode 100644 index 00000000..9437bf82 --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/dao/ISysFlowClassDao.java @@ -0,0 +1,15 @@ +package com.hzya.frame.sys.flow.dao; + +import com.hzya.frame.sys.flow.entity.SysFlowClassEntity; +import com.hzya.frame.basedao.dao.IBaseDao; + +/** + * 流程分类;对应数环通项目分类(sys_flow_class: table)表数据库访问层 + * + * @author xiang2lin + * @since 2025-04-29 10:16:27 + */ +public interface ISysFlowClassDao extends IBaseDao { + +} + diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/dao/ISysFlowClassRuleDao.java b/base-service/src/main/java/com/hzya/frame/sys/flow/dao/ISysFlowClassRuleDao.java new file mode 100644 index 00000000..6359bb58 --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/dao/ISysFlowClassRuleDao.java @@ -0,0 +1,15 @@ +package com.hzya.frame.sys.flow.dao; + +import com.hzya.frame.sys.flow.entity.SysFlowClassRuleEntity; +import com.hzya.frame.basedao.dao.IBaseDao; + +/** + * 流程分类权限表(sys_flow_class_rule: table)表数据库访问层 + * + * @author xiang2lin + * @since 2025-04-29 10:16:27 + */ +public interface ISysFlowClassRuleDao extends IBaseDao { + +} + diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/dao/ISysFlowDao.java b/base-service/src/main/java/com/hzya/frame/sys/flow/dao/ISysFlowDao.java new file mode 100644 index 00000000..985be186 --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/dao/ISysFlowDao.java @@ -0,0 +1,15 @@ +package com.hzya.frame.sys.flow.dao; + +import com.hzya.frame.sys.flow.entity.SysFlowEntity; +import com.hzya.frame.basedao.dao.IBaseDao; + +/** + * 流程主表;流程就是数环通的Linkup(sys_flow: table)表数据库访问层 + * + * @author xiang2lin + * @since 2025-04-29 10:16:19 + */ +public interface ISysFlowDao extends IBaseDao { + +} + diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/dao/ISysFlowNifiConstantDao.java b/base-service/src/main/java/com/hzya/frame/sys/flow/dao/ISysFlowNifiConstantDao.java new file mode 100644 index 00000000..b7c829ce --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/dao/ISysFlowNifiConstantDao.java @@ -0,0 +1,15 @@ +package com.hzya.frame.sys.flow.dao; + +import com.hzya.frame.sys.flow.entity.SysFlowNifiConstantEntity; +import com.hzya.frame.basedao.dao.IBaseDao; + +/** + * nifi常量(sys_flow_nifi_constant: table)表数据库访问层 + * + * @author xiang2lin + * @since 2025-04-29 10:16:27 + */ +public interface ISysFlowNifiConstantDao extends IBaseDao { + +} + diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/dao/ISysFlowStepAccountDao.java b/base-service/src/main/java/com/hzya/frame/sys/flow/dao/ISysFlowStepAccountDao.java new file mode 100644 index 00000000..d5a3c40f --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/dao/ISysFlowStepAccountDao.java @@ -0,0 +1,15 @@ +package com.hzya.frame.sys.flow.dao; + +import com.hzya.frame.sys.flow.entity.SysFlowStepAccountEntity; +import com.hzya.frame.basedao.dao.IBaseDao; + +/** + * 流程步骤账户表(sys_flow_step_account: table)表数据库访问层 + * + * @author xiang2lin + * @since 2025-04-29 10:16:27 + */ +public interface ISysFlowStepAccountDao extends IBaseDao { + +} + diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/dao/ISysFlowStepConfigBDao.java b/base-service/src/main/java/com/hzya/frame/sys/flow/dao/ISysFlowStepConfigBDao.java new file mode 100644 index 00000000..68042e35 --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/dao/ISysFlowStepConfigBDao.java @@ -0,0 +1,15 @@ +package com.hzya.frame.sys.flow.dao; + +import com.hzya.frame.sys.flow.entity.SysFlowStepConfigBEntity; +import com.hzya.frame.basedao.dao.IBaseDao; + +/** + * 映射信息表体(sys_flow_step_config_b: table)表数据库访问层 + * + * @author xiang2lin + * @since 2025-04-29 10:16:28 + */ +public interface ISysFlowStepConfigBDao extends IBaseDao { + +} + diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/dao/ISysFlowStepConfigDao.java b/base-service/src/main/java/com/hzya/frame/sys/flow/dao/ISysFlowStepConfigDao.java new file mode 100644 index 00000000..70f0cd14 --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/dao/ISysFlowStepConfigDao.java @@ -0,0 +1,15 @@ +package com.hzya.frame.sys.flow.dao; + +import com.hzya.frame.sys.flow.entity.SysFlowStepConfigEntity; +import com.hzya.frame.basedao.dao.IBaseDao; + +/** + * 映射信息主表(sys_flow_step_config: table)表数据库访问层 + * + * @author xiang2lin + * @since 2025-04-29 10:16:28 + */ +public interface ISysFlowStepConfigDao extends IBaseDao { + +} + diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/dao/ISysFlowStepDao.java b/base-service/src/main/java/com/hzya/frame/sys/flow/dao/ISysFlowStepDao.java new file mode 100644 index 00000000..52f0a3d5 --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/dao/ISysFlowStepDao.java @@ -0,0 +1,15 @@ +package com.hzya.frame.sys.flow.dao; + +import com.hzya.frame.sys.flow.entity.SysFlowStepEntity; +import com.hzya.frame.basedao.dao.IBaseDao; + +/** + * 流程步骤信息(sys_flow_step: table)表数据库访问层 + * + * @author xiang2lin + * @since 2025-04-29 10:16:27 + */ +public interface ISysFlowStepDao extends IBaseDao { + +} + diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/dao/ISysFlowStepRelationDao.java b/base-service/src/main/java/com/hzya/frame/sys/flow/dao/ISysFlowStepRelationDao.java new file mode 100644 index 00000000..41bbb415 --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/dao/ISysFlowStepRelationDao.java @@ -0,0 +1,15 @@ +package com.hzya.frame.sys.flow.dao; + +import com.hzya.frame.sys.flow.entity.SysFlowStepRelationEntity; +import com.hzya.frame.basedao.dao.IBaseDao; + +/** + * 步骤关联关系表(sys_flow_step_relation: table)表数据库访问层 + * + * @author xiang2lin + * @since 2025-04-29 10:16:28 + */ +public interface ISysFlowStepRelationDao extends IBaseDao { + +} + diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/dao/impl/SysFlowClassDaoImpl.java b/base-service/src/main/java/com/hzya/frame/sys/flow/dao/impl/SysFlowClassDaoImpl.java new file mode 100644 index 00000000..ef35f356 --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/dao/impl/SysFlowClassDaoImpl.java @@ -0,0 +1,17 @@ +package com.hzya.frame.sys.flow.dao.impl; + +import com.hzya.frame.sys.flow.entity.SysFlowClassEntity; +import com.hzya.frame.sys.flow.dao.ISysFlowClassDao; +import org.springframework.stereotype.Repository; +import com.hzya.frame.basedao.dao.MybatisGenericDao; +/** + * 流程分类;对应数环通项目分类(SysFlowClass)表数据库访问层 + * + * @author xiang2lin + * @since 2025-04-29 10:16:27 + */ +@Repository(value = "SysFlowClassDaoImpl") +public class SysFlowClassDaoImpl extends MybatisGenericDao implements ISysFlowClassDao{ + +} + diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/dao/impl/SysFlowClassRuleDaoImpl.java b/base-service/src/main/java/com/hzya/frame/sys/flow/dao/impl/SysFlowClassRuleDaoImpl.java new file mode 100644 index 00000000..02ace295 --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/dao/impl/SysFlowClassRuleDaoImpl.java @@ -0,0 +1,17 @@ +package com.hzya.frame.sys.flow.dao.impl; + +import com.hzya.frame.sys.flow.entity.SysFlowClassRuleEntity; +import com.hzya.frame.sys.flow.dao.ISysFlowClassRuleDao; +import org.springframework.stereotype.Repository; +import com.hzya.frame.basedao.dao.MybatisGenericDao; +/** + * 流程分类权限表(SysFlowClassRule)表数据库访问层 + * + * @author xiang2lin + * @since 2025-04-29 10:16:27 + */ +@Repository(value = "SysFlowClassRuleDaoImpl") +public class SysFlowClassRuleDaoImpl extends MybatisGenericDao implements ISysFlowClassRuleDao{ + +} + diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/dao/impl/SysFlowDaoImpl.java b/base-service/src/main/java/com/hzya/frame/sys/flow/dao/impl/SysFlowDaoImpl.java new file mode 100644 index 00000000..9bd21c11 --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/dao/impl/SysFlowDaoImpl.java @@ -0,0 +1,17 @@ +package com.hzya.frame.sys.flow.dao.impl; + +import com.hzya.frame.sys.flow.entity.SysFlowEntity; +import com.hzya.frame.sys.flow.dao.ISysFlowDao; +import org.springframework.stereotype.Repository; +import com.hzya.frame.basedao.dao.MybatisGenericDao; +/** + * 流程主表;流程就是数环通的Linkup(SysFlow)表数据库访问层 + * + * @author xiang2lin + * @since 2025-04-29 10:16:21 + */ +@Repository(value = "SysFlowDaoImpl") +public class SysFlowDaoImpl extends MybatisGenericDao implements ISysFlowDao{ + +} + diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/dao/impl/SysFlowNifiConstantDaoImpl.java b/base-service/src/main/java/com/hzya/frame/sys/flow/dao/impl/SysFlowNifiConstantDaoImpl.java new file mode 100644 index 00000000..628b92fb --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/dao/impl/SysFlowNifiConstantDaoImpl.java @@ -0,0 +1,17 @@ +package com.hzya.frame.sys.flow.dao.impl; + +import com.hzya.frame.sys.flow.entity.SysFlowNifiConstantEntity; +import com.hzya.frame.sys.flow.dao.ISysFlowNifiConstantDao; +import org.springframework.stereotype.Repository; +import com.hzya.frame.basedao.dao.MybatisGenericDao; +/** + * nifi常量(SysFlowNifiConstant)表数据库访问层 + * + * @author xiang2lin + * @since 2025-04-29 10:16:27 + */ +@Repository(value = "SysFlowNifiConstantDaoImpl") +public class SysFlowNifiConstantDaoImpl extends MybatisGenericDao implements ISysFlowNifiConstantDao{ + +} + diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/dao/impl/SysFlowStepAccountDaoImpl.java b/base-service/src/main/java/com/hzya/frame/sys/flow/dao/impl/SysFlowStepAccountDaoImpl.java new file mode 100644 index 00000000..2c9f580a --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/dao/impl/SysFlowStepAccountDaoImpl.java @@ -0,0 +1,17 @@ +package com.hzya.frame.sys.flow.dao.impl; + +import com.hzya.frame.sys.flow.entity.SysFlowStepAccountEntity; +import com.hzya.frame.sys.flow.dao.ISysFlowStepAccountDao; +import org.springframework.stereotype.Repository; +import com.hzya.frame.basedao.dao.MybatisGenericDao; +/** + * 流程步骤账户表(SysFlowStepAccount)表数据库访问层 + * + * @author xiang2lin + * @since 2025-04-29 10:16:27 + */ +@Repository(value = "SysFlowStepAccountDaoImpl") +public class SysFlowStepAccountDaoImpl extends MybatisGenericDao implements ISysFlowStepAccountDao{ + +} + diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/dao/impl/SysFlowStepConfigBDaoImpl.java b/base-service/src/main/java/com/hzya/frame/sys/flow/dao/impl/SysFlowStepConfigBDaoImpl.java new file mode 100644 index 00000000..377098c8 --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/dao/impl/SysFlowStepConfigBDaoImpl.java @@ -0,0 +1,17 @@ +package com.hzya.frame.sys.flow.dao.impl; + +import com.hzya.frame.sys.flow.entity.SysFlowStepConfigBEntity; +import com.hzya.frame.sys.flow.dao.ISysFlowStepConfigBDao; +import org.springframework.stereotype.Repository; +import com.hzya.frame.basedao.dao.MybatisGenericDao; +/** + * 映射信息表体(SysFlowStepConfigB)表数据库访问层 + * + * @author xiang2lin + * @since 2025-04-29 10:16:28 + */ +@Repository(value = "SysFlowStepConfigBDaoImpl") +public class SysFlowStepConfigBDaoImpl extends MybatisGenericDao implements ISysFlowStepConfigBDao{ + +} + diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/dao/impl/SysFlowStepConfigDaoImpl.java b/base-service/src/main/java/com/hzya/frame/sys/flow/dao/impl/SysFlowStepConfigDaoImpl.java new file mode 100644 index 00000000..b3be492c --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/dao/impl/SysFlowStepConfigDaoImpl.java @@ -0,0 +1,17 @@ +package com.hzya.frame.sys.flow.dao.impl; + +import com.hzya.frame.sys.flow.entity.SysFlowStepConfigEntity; +import com.hzya.frame.sys.flow.dao.ISysFlowStepConfigDao; +import org.springframework.stereotype.Repository; +import com.hzya.frame.basedao.dao.MybatisGenericDao; +/** + * 映射信息主表(SysFlowStepConfig)表数据库访问层 + * + * @author xiang2lin + * @since 2025-04-29 10:16:28 + */ +@Repository(value = "SysFlowStepConfigDaoImpl") +public class SysFlowStepConfigDaoImpl extends MybatisGenericDao implements ISysFlowStepConfigDao{ + +} + diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/dao/impl/SysFlowStepDaoImpl.java b/base-service/src/main/java/com/hzya/frame/sys/flow/dao/impl/SysFlowStepDaoImpl.java new file mode 100644 index 00000000..f25dc8fc --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/dao/impl/SysFlowStepDaoImpl.java @@ -0,0 +1,17 @@ +package com.hzya.frame.sys.flow.dao.impl; + +import com.hzya.frame.sys.flow.entity.SysFlowStepEntity; +import com.hzya.frame.sys.flow.dao.ISysFlowStepDao; +import org.springframework.stereotype.Repository; +import com.hzya.frame.basedao.dao.MybatisGenericDao; +/** + * 流程步骤信息(SysFlowStep)表数据库访问层 + * + * @author xiang2lin + * @since 2025-04-29 10:16:27 + */ +@Repository(value = "SysFlowStepDaoImpl") +public class SysFlowStepDaoImpl extends MybatisGenericDao implements ISysFlowStepDao{ + +} + diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/dao/impl/SysFlowStepRelationDaoImpl.java b/base-service/src/main/java/com/hzya/frame/sys/flow/dao/impl/SysFlowStepRelationDaoImpl.java new file mode 100644 index 00000000..c47941b2 --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/dao/impl/SysFlowStepRelationDaoImpl.java @@ -0,0 +1,17 @@ +package com.hzya.frame.sys.flow.dao.impl; + +import com.hzya.frame.sys.flow.entity.SysFlowStepRelationEntity; +import com.hzya.frame.sys.flow.dao.ISysFlowStepRelationDao; +import org.springframework.stereotype.Repository; +import com.hzya.frame.basedao.dao.MybatisGenericDao; +/** + * 步骤关联关系表(SysFlowStepRelation)表数据库访问层 + * + * @author xiang2lin + * @since 2025-04-29 10:16:28 + */ +@Repository(value = "SysFlowStepRelationDaoImpl") +public class SysFlowStepRelationDaoImpl extends MybatisGenericDao implements ISysFlowStepRelationDao{ + +} + diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowClassEntity.java b/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowClassEntity.java new file mode 100644 index 00000000..ff75dbcc --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowClassEntity.java @@ -0,0 +1,36 @@ +package com.hzya.frame.sys.flow.entity; + +import java.util.Date; +import com.hzya.frame.web.entity.BaseEntity; +/** + * 流程分类;对应数环通项目分类(SysFlowClass)实体类 + * + * @author xiang2lin + * @since 2025-04-29 10:16:27 + */ +public class SysFlowClassEntity extends BaseEntity { + + /** 分类名称 */ + private String name; + /** 上级id */ + private String parentId; + + + public String getName() { + return name; + } + + public void setName(String name) { + this.name = name; + } + + public String getParentId() { + return parentId; + } + + public void setParentId(String parentId) { + this.parentId = parentId; + } + +} + diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowClassEntity.xml b/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowClassEntity.xml new file mode 100644 index 00000000..7cdda3a1 --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowClassEntity.xml @@ -0,0 +1,193 @@ + + + + + + + + + + + + + + + + + id + ,create_user_id + ,create_time + ,modify_user_id + ,modify_time + ,sts + ,name + ,parent_id + + + + + + + + + + + + + + + + insert into sys_flow_class( + + id , + create_user_id , + create_time , + modify_user_id , + modify_time , + sts , + name , + parent_id , + sorts, + sts, + + )values( + + #{id} , + #{create_user_id} , + #{create_time} , + #{modify_user_id} , + #{modify_time} , + #{sts} , + #{name} , + #{parentId} , + COALESCE((select (max(IFNULL( a.sorts, 0 )) + 1) as sort from sys_flow_class a WHERE a.sts = 'Y' ),1), + 'Y', + + ) + + + + insert into sys_flow_class(create_user_id, create_time, modify_user_id, modify_time, sts, name, parent_id, sts) + values + + (#{entity.create_user_id},#{entity.create_time},#{entity.modify_user_id},#{entity.modify_time},#{entity.sts},#{entity.name},#{entity.parentId}, 'Y') + + + + + insert into sys_flow_class(create_user_id, create_time, modify_user_id, modify_time, sts, name, parent_id) + values + + (#{entity.create_user_id},#{entity.create_time},#{entity.modify_user_id},#{entity.modify_time},#{entity.sts},#{entity.name},#{entity.parentId}) + + on duplicate key update + create_user_id = values(create_user_id), + create_time = values(create_time), + modify_user_id = values(modify_user_id), + modify_time = values(modify_time), + sts = values(sts), + name = values(name), + parent_id = values(parent_id) + + +update sys_flow_class set + + create_user_id = #{create_user_id}, + create_time = #{create_time}, + modify_user_id = #{modify_user_id}, + modify_time = #{modify_time}, + sts = #{sts}, + name = #{name}, + parent_id = #{parentId}, + +where id = #{id} + + + +update sys_flow_class set sts= 'N' ,modify_time = #{modify_time},modify_user_id = #{modify_user_id} +where id = #{id} + + + +update sys_flow_class set sts= 'N' ,modify_time = #{modify_time},modify_user_id = #{modify_user_id} + + and id = #{id} + and sts = #{sts} + and name = #{name} + and parent_id = #{parentId} + and sts='Y' + + + + + delete from sys_flow_class where id = #{id} + + + + diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowClassRuleEntity.java b/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowClassRuleEntity.java new file mode 100644 index 00000000..cea32985 --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowClassRuleEntity.java @@ -0,0 +1,75 @@ +package com.hzya.frame.sys.flow.entity; + +import java.util.Date; +import java.util.List; + +import com.hzya.frame.web.entity.BaseEntity; +/** + * 流程分类权限表(SysFlowClassRule)实体类 + * + * @author xiang2lin + * @since 2025-04-29 10:16:27 + */ +public class SysFlowClassRuleEntity extends BaseEntity { + + /** 流程分类id */ + private String flowClassId; + /** 用户id */ + private String userId; + /** 用户名 */ + private String userName; + /** 用户编码 */ + private String userCode; + /** 头像 */ + private String profileIcon; + //权限列表 + List ruleList; + public String getFlowClassId() { + return flowClassId; + } + + public void setFlowClassId(String flowClassId) { + this.flowClassId = flowClassId; + } + + public String getUserId() { + return userId; + } + + public void setUserId(String userId) { + this.userId = userId; + } + + public String getUserName() { + return userName; + } + + public void setUserName(String userName) { + this.userName = userName; + } + + public String getUserCode() { + return userCode; + } + + public void setUserCode(String userCode) { + this.userCode = userCode; + } + + public String getProfileIcon() { + return profileIcon; + } + + public void setProfileIcon(String profileIcon) { + this.profileIcon = profileIcon; + } + + public List getRuleList() { + return ruleList; + } + + public void setRuleList(List ruleList) { + this.ruleList = ruleList; + } +} + diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowClassRuleEntity.xml b/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowClassRuleEntity.xml new file mode 100644 index 00000000..8ef807fe --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowClassRuleEntity.xml @@ -0,0 +1,247 @@ + + + + + + + + + + + + + + + + + + + + id + ,create_user_id + ,create_time + ,modify_user_id + ,modify_time + ,sts + ,flow_class_id + ,user_id + ,user_name + ,user_code + ,profile_icon + + + + + + + + + + + + + + + + insert into sys_flow_class_rule( + + id , + create_user_id , + create_time , + modify_user_id , + modify_time , + sts , + flow_class_id , + user_id , + user_name , + user_code , + profile_icon , + sorts, + sts, + + )values( + + #{id} , + #{create_user_id} , + #{create_time} , + #{modify_user_id} , + #{modify_time} , + #{sts} , + #{flowClassId} , + #{userId} , + #{userName} , + #{userCode} , + #{profileIcon} , + COALESCE((select (max(IFNULL( a.sorts, 0 )) + 1) as sort from sys_flow_class_rule a WHERE a.sts = 'Y' ),1), + 'Y', + + ) + + + + insert into sys_flow_class_rule(create_user_id, create_time, modify_user_id, modify_time, sts, flow_class_id, + user_id, user_name, user_code, profile_icon, sts) + values + + (#{entity.create_user_id},#{entity.create_time},#{entity.modify_user_id},#{entity.modify_time},#{entity.sts},#{entity.flowClassId},#{entity.userId},#{entity.userName},#{entity.userCode},#{entity.profileIcon}, + 'Y') + + + + + insert into sys_flow_class_rule(create_user_id, create_time, modify_user_id, modify_time, sts, flow_class_id, + user_id, user_name, user_code, profile_icon) + values + + (#{entity.create_user_id},#{entity.create_time},#{entity.modify_user_id},#{entity.modify_time},#{entity.sts},#{entity.flowClassId},#{entity.userId},#{entity.userName},#{entity.userCode},#{entity.profileIcon}) + + on duplicate key update + create_user_id = values(create_user_id), + create_time = values(create_time), + modify_user_id = values(modify_user_id), + modify_time = values(modify_time), + sts = values(sts), + flow_class_id = values(flow_class_id), + user_id = values(user_id), + user_name = values(user_name), + user_code = values(user_code), + profile_icon = values(profile_icon) + + + + update sys_flow_class_rule set + + create_user_id = #{create_user_id}, + create_time = #{create_time}, + modify_user_id = #{modify_user_id}, + modify_time = #{modify_time}, + sts = #{sts}, + flow_class_id = #{flowClassId}, + user_id = #{userId}, + user_name = #{userName}, + user_code = #{userCode}, + profile_icon = #{profileIcon}, + + where id = #{id} + + + + update sys_flow_class_rule + set sts= 'N', + modify_time = #{modify_time}, + modify_user_id = #{modify_user_id} + where id = #{id} + + + + update sys_flow_class_rule set sts= 'N' ,modify_time = #{modify_time},modify_user_id = #{modify_user_id} + + and id = #{id} + and sts = #{sts} + and flow_class_id = #{flowClassId} + and user_id = #{userId} + and user_name = #{userName} + and user_code = #{userCode} + and profile_icon = #{profileIcon} + and sts='Y' + + + + + delete + from sys_flow_class_rule + where id = #{id} + + + + diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowEntity.java b/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowEntity.java new file mode 100644 index 00000000..d8527213 --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowEntity.java @@ -0,0 +1,74 @@ +package com.hzya.frame.sys.flow.entity; + +import java.util.Date; +import com.hzya.frame.web.entity.BaseEntity; +/** + * 流程主表;流程就是数环通的Linkup(SysFlow)实体类 + * + * @author xiang2lin + * @since 2025-04-29 10:16:23 + */ +public class SysFlowEntity extends BaseEntity { + + /** 流程名称 */ + private String name; + /** 流程分类id */ + private String classId; + /** 触发方式id */ + private String triggerModeId; + /** 应用组id */ + private String nifiGroupId; + /** 流程描述 */ + private String description; + + //状态， 启动/停止 + private String status; + public String getName() { + return name; + } + + public void setName(String name) { + this.name = name; + } + + public String getClassId() { + return classId; + } + + public void setClassId(String classId) { + this.classId = classId; + } + + public String getTriggerModeId() { + return triggerModeId; + } + + public void setTriggerModeId(String triggerModeId) { + this.triggerModeId = triggerModeId; + } + + public String getNifiGroupId() { + return nifiGroupId; + } + + public void setNifiGroupId(String nifiGroupId) { + this.nifiGroupId = nifiGroupId; + } + + public String getDescription() { + return description; + } + + public void setDescription(String description) { + this.description = description; + } + + public String getStatus() { + return status; + } + + public void setStatus(String status) { + this.status = status; + } +} + diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowEntity.xml b/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowEntity.xml new file mode 100644 index 00000000..ff41d4bd --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowEntity.xml @@ -0,0 +1,234 @@ + + + + + + + + + + + + + + + + + + + + + id + ,create_user_id + ,create_time + ,modify_user_id + ,modify_time + ,sts + ,name + ,status + ,class_id + ,trigger_mode_id + ,nifi_group_id + ,description + + + + + + + + + + + + + + + + insert into sys_flow( + + id , + create_user_id , + create_time , + modify_user_id , + modify_time , + sts , + name , + status , + class_id , + trigger_mode_id , + nifi_group_id , + description , + sorts, + sts, + + )values( + + #{id} , + #{create_user_id} , + #{create_time} , + #{modify_user_id} , + #{modify_time} , + #{sts} , + #{name} , + #{classId} , + #{triggerModeId} , + #{nifiGroupId} , + #{description} , + (select (max(IFNULL( a.sorts, 0 )) + 1) as sort from sys_flow a WHERE a.sts = 'Y' ), + 'Y', + + ) + + + + insert into sys_flow(create_user_id, create_time, modify_user_id, modify_time, sts, name,status, class_id, trigger_mode_id, nifi_group_id, description, sts) + values + + (#{entity.create_user_id},#{entity.create_time},#{entity.modify_user_id},#{entity.modify_time},#{entity.sts},#{entity.name},${entity.status},#{entity.classId},#{entity.triggerModeId},#{entity.nifiGroupId},#{entity.description}, 'Y') + + + + + insert into sys_flow(create_user_id, create_time, modify_user_id, modify_time, sts, name, status,class_id, trigger_mode_id, nifi_group_id, description) + values + + (#{entity.create_user_id},#{entity.create_time},#{entity.modify_user_id},#{entity.modify_time},#{entity.sts},#{entity.name},#{entity.status},#{entity.classId},#{entity.triggerModeId},#{entity.nifiGroupId},#{entity.description}) + + on duplicate key update + create_user_id = values(create_user_id), + create_time = values(create_time), + modify_user_id = values(modify_user_id), + modify_time = values(modify_time), + sts = values(sts), + name = values(name), + class_id = values(class_id), + trigger_mode_id = values(trigger_mode_id), + nifi_group_id = values(nifi_group_id), + description = values(description) + + +update sys_flow set + + create_user_id = #{create_user_id}, + create_time = #{create_time}, + modify_user_id = #{modify_user_id}, + modify_time = #{modify_time}, + sts = #{sts}, + name = #{name}, + status = #{status}, + class_id = #{classId}, + trigger_mode_id = #{triggerModeId}, + nifi_group_id = #{nifiGroupId}, + description = #{description}, + +where id = #{id} + + + +update sys_flow set sts= 'N' ,modify_time = #{modify_time},modify_user_id = #{modify_user_id} +where id = #{id} + + + +update sys_flow set sts= 'N' ,modify_time = #{modify_time},modify_user_id = #{modify_user_id} + + and id = #{id} + and sts = #{sts} + and name = #{name} + and class_id = #{classId} + and trigger_mode_id = #{triggerModeId} + and nifi_group_id = #{nifiGroupId} + and description = #{description} + and sts='Y' + + + + + delete from sys_flow where id = #{id} + + + + diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowNifiConstantEntity.java b/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowNifiConstantEntity.java new file mode 100644 index 00000000..1935fe3a --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowNifiConstantEntity.java @@ -0,0 +1,66 @@ +package com.hzya.frame.sys.flow.entity; + +import java.util.Date; +import com.hzya.frame.web.entity.BaseEntity; +/** + * nifi常量(SysFlowNifiConstant)实体类 + * + * @author xiang2lin + * @since 2025-04-29 10:16:27 + */ +public class SysFlowNifiConstantEntity extends BaseEntity { + + /** 键 */ + private String nifiKey; + /** 值 */ + private String nifiValue; + /** 显示值 */ + private String showValue; + /** 描述 */ + private String description; + /** 分类 */ + private String type; + + + public String getNifiKey() { + return nifiKey; + } + + public void setNifiKey(String nifiKey) { + this.nifiKey = nifiKey; + } + + public String getNifiValue() { + return nifiValue; + } + + public void setNifiValue(String nifiValue) { + this.nifiValue = nifiValue; + } + + public String getShowValue() { + return showValue; + } + + public void setShowValue(String showValue) { + this.showValue = showValue; + } + + public String getDescription() { + return description; + } + + public void setDescription(String description) { + this.description = description; + } + + public String getType() { + return type; + } + + public void setType(String type) { + this.type = type; + } + +} + diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowNifiConstantEntity.xml b/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowNifiConstantEntity.xml new file mode 100644 index 00000000..08a53105 --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowNifiConstantEntity.xml @@ -0,0 +1,226 @@ + + + + + + + + + + + + + + + + + + + + id + ,create_user_id + ,create_time + ,modify_user_id + ,modify_time + ,sts + ,nifi_key + ,nifi_value + ,show_value + ,description + ,type + + + + + + + + + + + + + + + + insert into sys_flow_nifi_constant( + + id , + create_user_id , + create_time , + modify_user_id , + modify_time , + sts , + nifi_key , + nifi_value , + show_value , + description , + type , + sorts, + sts, + + )values( + + #{id} , + #{create_user_id} , + #{create_time} , + #{modify_user_id} , + #{modify_time} , + #{sts} , + #{nifiKey} , + #{nifiValue} , + #{showValue} , + #{description} , + #{type} , + COALESCE((select (max(IFNULL( a.sorts, 0 )) + 1) as sort from sys_flow_nifi_constant a WHERE a.sts = 'Y' ),1), + 'Y', + + ) + + + + insert into sys_flow_nifi_constant(create_user_id, create_time, modify_user_id, modify_time, sts, nifi_key, nifi_value, show_value, description, type, sts) + values + + (#{entity.create_user_id},#{entity.create_time},#{entity.modify_user_id},#{entity.modify_time},#{entity.sts},#{entity.nifiKey},#{entity.nifiValue},#{entity.showValue},#{entity.description},#{entity.type}, 'Y') + + + + + insert into sys_flow_nifi_constant(create_user_id, create_time, modify_user_id, modify_time, sts, nifi_key, nifi_value, show_value, description, type) + values + + (#{entity.create_user_id},#{entity.create_time},#{entity.modify_user_id},#{entity.modify_time},#{entity.sts},#{entity.nifiKey},#{entity.nifiValue},#{entity.showValue},#{entity.description},#{entity.type}) + + on duplicate key update + create_user_id = values(create_user_id), + create_time = values(create_time), + modify_user_id = values(modify_user_id), + modify_time = values(modify_time), + sts = values(sts), + nifi_key = values(nifiKey), + nifi_value = values(nifiValue), + show_value = values(show_value), + description = values(description), + type = values(type) + + +update sys_flow_nifi_constant set + + create_user_id = #{create_user_id}, + create_time = #{create_time}, + modify_user_id = #{modify_user_id}, + modify_time = #{modify_time}, + sts = #{sts}, + nifi_key = #{nifiKey}, + nifi_value = #{nifiValue}, + show_value = #{showValue}, + description = #{description}, + type = #{type}, + +where id = #{id} + + + +update sys_flow_nifi_constant set sts= 'N' ,modify_time = #{modify_time},modify_user_id = #{modify_user_id} +where id = #{id} + + + +update sys_flow_nifi_constant set sts= 'N' ,modify_time = #{modify_time},modify_user_id = #{modify_user_id} + + and id = #{id} + and sts = #{sts} + andnifi_ key = #{nifiKey} + and nifi_value = #{nifiValue} + and show_value = #{showValue} + and description = #{description} + and type = #{type} + and sts='Y' + + + + + delete from sys_flow_nifi_constant where id = #{id} + + + + diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowStepAccountEntity.java b/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowStepAccountEntity.java new file mode 100644 index 00000000..246f11f4 --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowStepAccountEntity.java @@ -0,0 +1,126 @@ +package com.hzya.frame.sys.flow.entity; + +import java.util.Date; +import com.hzya.frame.web.entity.BaseEntity; +/** + * 流程步骤账户表(SysFlowStepAccount)实体类 + * + * @author xiang2lin + * @since 2025-04-29 10:16:27 + */ +public class SysFlowStepAccountEntity extends BaseEntity { + + /** 账户名称 */ + private String name; + /** ip地址 */ + private String ipAddress; + /** 端口 */ + private String port; + /** 数据库名称 */ + private String dbName; + /** 用户名 */ + private String userName; + /** 密码 */ + private String password; + /** 数据库类型 */ + private String dbType; + /** 应用key */ + private String appKey; + /** 应用密钥 */ + private String appSecret; + /** 企业id */ + private String corpid; + /** 应用id */ + private String agentid; + + + public String getName() { + return name; + } + + public void setName(String name) { + this.name = name; + } + + public String getIpAddress() { + return ipAddress; + } + + public void setIpAddress(String ipAddress) { + this.ipAddress = ipAddress; + } + + public String getPort() { + return port; + } + + public void setPort(String port) { + this.port = port; + } + + public String getDbName() { + return dbName; + } + + public void setDbName(String dbName) { + this.dbName = dbName; + } + + public String getUserName() { + return userName; + } + + public void setUserName(String userName) { + this.userName = userName; + } + + public String getPassword() { + return password; + } + + public void setPassword(String password) { + this.password = password; + } + + public String getDbType() { + return dbType; + } + + public void setDbType(String dbType) { + this.dbType = dbType; + } + + public String getAppKey() { + return appKey; + } + + public void setAppKey(String appKey) { + this.appKey = appKey; + } + + public String getAppSecret() { + return appSecret; + } + + public void setAppSecret(String appSecret) { + this.appSecret = appSecret; + } + + public String getCorpid() { + return corpid; + } + + public void setCorpid(String corpid) { + this.corpid = corpid; + } + + public String getAgentid() { + return agentid; + } + + public void setAgentid(String agentid) { + this.agentid = agentid; + } + +} + diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowStepAccountEntity.xml b/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowStepAccountEntity.xml new file mode 100644 index 00000000..777a9aaa --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowStepAccountEntity.xml @@ -0,0 +1,292 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + id + ,create_user_id + ,create_time + ,modify_user_id + ,modify_time + ,sts + ,name + ,ip_address + ,port + ,db_name + ,user_name + ,password + ,db_type + ,app_key + ,app_secret + ,corpId + ,agentId + + + + + + + + + + + + + + + + insert into sys_flow_step_account( + + id , + create_user_id , + create_time , + modify_user_id , + modify_time , + sts , + name , + ip_address , + port , + db_name , + user_name , + password , + db_type , + app_key , + app_secret , + corpId , + agentId , + sorts, + sts, + + )values( + + #{id} , + #{create_user_id} , + #{create_time} , + #{modify_user_id} , + #{modify_time} , + #{sts} , + #{name} , + #{ipAddress} , + #{port} , + #{dbName} , + #{userName} , + #{password} , + #{dbType} , + #{appKey} , + #{appSecret} , + #{corpid} , + #{agentid} , + (select (max(IFNULL( a.sorts, 0 )) + 1) as sort from sys_flow_step_account a WHERE a.sts = 'Y' ), + 'Y', + + ) + + + + insert into sys_flow_step_account(create_user_id, create_time, modify_user_id, modify_time, sts, name, ip_address, port, db_name, user_name, password, db_type, app_key, app_secret, corpId, agentId, sts) + values + + (#{entity.create_user_id},#{entity.create_time},#{entity.modify_user_id},#{entity.modify_time},#{entity.sts},#{entity.name},#{entity.ipAddress},#{entity.port},#{entity.dbName},#{entity.userName},#{entity.password},#{entity.dbType},#{entity.appKey},#{entity.appSecret},#{entity.corpid},#{entity.agentid}, 'Y') + + + + + insert into sys_flow_step_account(create_user_id, create_time, modify_user_id, modify_time, sts, name, ip_address, port, db_name, user_name, password, db_type, app_key, app_secret, corpId, agentId) + values + + (#{entity.create_user_id},#{entity.create_time},#{entity.modify_user_id},#{entity.modify_time},#{entity.sts},#{entity.name},#{entity.ipAddress},#{entity.port},#{entity.dbName},#{entity.userName},#{entity.password},#{entity.dbType},#{entity.appKey},#{entity.appSecret},#{entity.corpid},#{entity.agentid}) + + on duplicate key update + create_user_id = values(create_user_id), + create_time = values(create_time), + modify_user_id = values(modify_user_id), + modify_time = values(modify_time), + sts = values(sts), + name = values(name), + ip_address = values(ip_address), + port = values(port), + db_name = values(db_name), + user_name = values(user_name), + password = values(password), + db_type = values(db_type), + app_key = values(app_key), + app_secret = values(app_secret), + corpId = values(corpId), + agentId = values(agentId) + + +update sys_flow_step_account set + + create_user_id = #{create_user_id}, + create_time = #{create_time}, + modify_user_id = #{modify_user_id}, + modify_time = #{modify_time}, + sts = #{sts}, + name = #{name}, + ip_address = #{ipAddress}, + port = #{port}, + db_name = #{dbName}, + user_name = #{userName}, + password = #{password}, + db_type = #{dbType}, + app_key = #{appKey}, + app_secret = #{appSecret}, + corpId = #{corpid}, + agentId = #{agentid}, + +where id = #{id} + + + +update sys_flow_step_account set sts= 'N' ,modify_time = #{modify_time},modify_user_id = #{modify_user_id} +where id = #{id} + + + +update sys_flow_step_account set sts= 'N' ,modify_time = #{modify_time},modify_user_id = #{modify_user_id} + + and id = #{id} + and sts = #{sts} + and name = #{name} + and ip_address = #{ipAddress} + and port = #{port} + and db_name = #{dbName} + and user_name = #{userName} + and password = #{password} + and db_type = #{dbType} + and app_key = #{appKey} + and app_secret = #{appSecret} + and corpId = #{corpid} + and agentId = #{agentid} + and sts='Y' + + + + + delete from sys_flow_step_account where id = #{id} + + + + diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowStepConfigBEntity.java b/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowStepConfigBEntity.java new file mode 100644 index 00000000..89e9bcda --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowStepConfigBEntity.java @@ -0,0 +1,126 @@ +package com.hzya.frame.sys.flow.entity; + +import java.util.Date; +import com.hzya.frame.web.entity.BaseEntity; +/** + * 映射信息表体(SysFlowStepConfigB)实体类 + * + * @author xiang2lin + * @since 2025-04-29 10:16:28 + */ +public class SysFlowStepConfigBEntity extends BaseEntity { + + /** 主表id */ + private String mainId; + /** 流程id */ + private String flowId; + /** 步骤id */ + private String stepId; + /** 是否主键 */ + private String primaryKeyFlag; + /** 字段名 */ + private String fieldName; + /** 字段备注 */ + private String fieldDescription; + /** 字段类型 */ + private String fieldType; + /** 查询条件 */ + private String whereCondition; + /** 源字段名称;适用于插入场景 */ + private String sourceFieldName; + /** 源字段类型;适用于插入场景 */ + private String sourceFieldType; + /** 源字段描述;适用于插入场景 */ + private String sourceFieldDescription; + + + public String getMainId() { + return mainId; + } + + public void setMainId(String mainId) { + this.mainId = mainId; + } + + public String getFlowId() { + return flowId; + } + + public void setFlowId(String flowId) { + this.flowId = flowId; + } + + public String getStepId() { + return stepId; + } + + public void setStepId(String stepId) { + this.stepId = stepId; + } + + public String getPrimaryKeyFlag() { + return primaryKeyFlag; + } + + public void setPrimaryKeyFlag(String primaryKeyFlag) { + this.primaryKeyFlag = primaryKeyFlag; + } + + public String getFieldName() { + return fieldName; + } + + public void setFieldName(String fieldName) { + this.fieldName = fieldName; + } + + public String getFieldDescription() { + return fieldDescription; + } + + public void setFieldDescription(String fieldDescription) { + this.fieldDescription = fieldDescription; + } + + public String getFieldType() { + return fieldType; + } + + public void setFieldType(String fieldType) { + this.fieldType = fieldType; + } + + public String getWhereCondition() { + return whereCondition; + } + + public void setWhereCondition(String whereCondition) { + this.whereCondition = whereCondition; + } + + public String getSourceFieldName() { + return sourceFieldName; + } + + public void setSourceFieldName(String sourceFieldName) { + this.sourceFieldName = sourceFieldName; + } + + public String getSourceFieldType() { + return sourceFieldType; + } + + public void setSourceFieldType(String sourceFieldType) { + this.sourceFieldType = sourceFieldType; + } + + public String getSourceFieldDescription() { + return sourceFieldDescription; + } + + public void setSourceFieldDescription(String sourceFieldDescription) { + this.sourceFieldDescription = sourceFieldDescription; + } + +} + diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowStepConfigBEntity.xml b/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowStepConfigBEntity.xml new file mode 100644 index 00000000..dece2c36 --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowStepConfigBEntity.xml @@ -0,0 +1,292 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + id + ,create_user_id + ,create_time + ,modify_user_id + ,modify_time + ,sts + ,main_id + ,flow_id + ,step_id + ,primary_key_flag + ,field_name + ,field_description + ,field_type + ,where_condition + ,source_field_name + ,source_field_type + ,source_field_description + + + + + + + + + + + + + + + + insert into sys_flow_step_config_b( + + id , + create_user_id , + create_time , + modify_user_id , + modify_time , + sts , + main_id , + flow_id , + step_id , + primary_key_flag , + field_name , + field_description , + field_type , + where_condition , + source_field_name , + source_field_type , + source_field_description , + sorts, + sts, + + )values( + + #{id} , + #{create_user_id} , + #{create_time} , + #{modify_user_id} , + #{modify_time} , + #{sts} , + #{mainId} , + #{flowId} , + #{stepId} , + #{primaryKeyFlag} , + #{fieldName} , + #{fieldDescription} , + #{fieldType} , + #{whereCondition} , + #{sourceFieldName} , + #{sourceFieldType} , + #{sourceFieldDescription} , + (select (max(IFNULL( a.sorts, 0 )) + 1) as sort from sys_flow_step_config_b a WHERE a.sts = 'Y' ), + 'Y', + + ) + + + + insert into sys_flow_step_config_b(create_user_id, create_time, modify_user_id, modify_time, sts, main_id, flow_id, step_id, primary_key_flag, field_name, field_description, field_type, where_condition, source_field_name, source_field_type, source_field_description, sts) + values + + (#{entity.create_user_id},#{entity.create_time},#{entity.modify_user_id},#{entity.modify_time},#{entity.sts},#{entity.mainId},#{entity.flowId},#{entity.stepId},#{entity.primaryKeyFlag},#{entity.fieldName},#{entity.fieldDescription},#{entity.fieldType},#{entity.whereCondition},#{entity.sourceFieldName},#{entity.sourceFieldType},#{entity.sourceFieldDescription}, 'Y') + + + + + insert into sys_flow_step_config_b(create_user_id, create_time, modify_user_id, modify_time, sts, main_id, flow_id, step_id, primary_key_flag, field_name, field_description, field_type, where_condition, source_field_name, source_field_type, source_field_description) + values + + (#{entity.create_user_id},#{entity.create_time},#{entity.modify_user_id},#{entity.modify_time},#{entity.sts},#{entity.mainId},#{entity.flowId},#{entity.stepId},#{entity.primaryKeyFlag},#{entity.fieldName},#{entity.fieldDescription},#{entity.fieldType},#{entity.whereCondition},#{entity.sourceFieldName},#{entity.sourceFieldType},#{entity.sourceFieldDescription}) + + on duplicate key update + create_user_id = values(create_user_id), + create_time = values(create_time), + modify_user_id = values(modify_user_id), + modify_time = values(modify_time), + sts = values(sts), + main_id = values(main_id), + flow_id = values(flow_id), + step_id = values(step_id), + primary_key_flag = values(primary_key_flag), + field_name = values(field_name), + field_description = values(field_description), + field_type = values(field_type), + where_condition = values(where_condition), + source_field_name = values(source_field_name), + source_field_type = values(source_field_type), + source_field_description = values(source_field_description) + + +update sys_flow_step_config_b set + + create_user_id = #{create_user_id}, + create_time = #{create_time}, + modify_user_id = #{modify_user_id}, + modify_time = #{modify_time}, + sts = #{sts}, + main_id = #{mainId}, + flow_id = #{flowId}, + step_id = #{stepId}, + primary_key_flag = #{primaryKeyFlag}, + field_name = #{fieldName}, + field_description = #{fieldDescription}, + field_type = #{fieldType}, + where_condition = #{whereCondition}, + source_field_name = #{sourceFieldName}, + source_field_type = #{sourceFieldType}, + source_field_description = #{sourceFieldDescription}, + +where id = #{id} + + + +update sys_flow_step_config_b set sts= 'N' ,modify_time = #{modify_time},modify_user_id = #{modify_user_id} +where id = #{id} + + + +update sys_flow_step_config_b set sts= 'N' ,modify_time = #{modify_time},modify_user_id = #{modify_user_id} + + and id = #{id} + and sts = #{sts} + and main_id = #{mainId} + and flow_id = #{flowId} + and step_id = #{stepId} + and primary_key_flag = #{primaryKeyFlag} + and field_name = #{fieldName} + and field_description = #{fieldDescription} + and field_type = #{fieldType} + and where_condition = #{whereCondition} + and source_field_name = #{sourceFieldName} + and source_field_type = #{sourceFieldType} + and source_field_description = #{sourceFieldDescription} + and sts='Y' + + + + + delete from sys_flow_step_config_b where id = #{id} + + + + diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowStepConfigEntity.java b/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowStepConfigEntity.java new file mode 100644 index 00000000..e8e426d9 --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowStepConfigEntity.java @@ -0,0 +1,136 @@ +package com.hzya.frame.sys.flow.entity; + +import java.util.Date; +import com.hzya.frame.web.entity.BaseEntity; +/** + * 映射信息主表(SysFlowStepConfig)实体类 + * + * @author xiang2lin + * @since 2025-04-29 10:16:28 + */ +public class SysFlowStepConfigEntity extends BaseEntity { + + /** 流程id */ + private String flowId; + /** 步骤id */ + private String stepId; + /** 流程操作步骤配置表id */ + private String setpConfigId; + /** 操作类型 */ + private String actionName; + /** 数据库类型;数据库类型+版本 */ + private String dbType; + /** 表名称 */ + private String tableName; + /** 页码 */ + private String rowNum; + /** 每页条数 */ + private String pageLimit; + /** 增量数据字段;例如ts */ + private String maxValueField; + /** 是否建表 */ + private String createTableFlag; + /** 写入模式;覆盖写入/增量写入 */ + private String writeType; + /** 动态sql语句 */ + private String sqlStatement; + + + public String getFlowId() { + return flowId; + } + + public void setFlowId(String flowId) { + this.flowId = flowId; + } + + public String getStepId() { + return stepId; + } + + public void setStepId(String stepId) { + this.stepId = stepId; + } + + public String getSetpConfigId() { + return setpConfigId; + } + + public void setSetpConfigId(String setpConfigId) { + this.setpConfigId = setpConfigId; + } + + public String getActionName() { + return actionName; + } + + public void setActionName(String actionName) { + this.actionName = actionName; + } + + public String getDbType() { + return dbType; + } + + public void setDbType(String dbType) { + this.dbType = dbType; + } + + public String getTableName() { + return tableName; + } + + public void setTableName(String tableName) { + this.tableName = tableName; + } + + public String getRowNum() { + return rowNum; + } + + public void setRowNum(String rowNum) { + this.rowNum = rowNum; + } + + public String getpageLimit() { + return pageLimit; + } + + public void setpageLimit(String pageLimit) { + this.pageLimit = pageLimit; + } + + public String getMaxValueField() { + return maxValueField; + } + + public void setMaxValueField(String maxValueField) { + this.maxValueField = maxValueField; + } + + public String getCreateTableFlag() { + return createTableFlag; + } + + public void setCreateTableFlag(String createTableFlag) { + this.createTableFlag = createTableFlag; + } + + public String getWriteType() { + return writeType; + } + + public void setWriteType(String writeType) { + this.writeType = writeType; + } + + public String getSqlStatement() { + return sqlStatement; + } + + public void setSqlStatement(String sqlStatement) { + this.sqlStatement = sqlStatement; + } + +} + diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowStepConfigEntity.xml b/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowStepConfigEntity.xml new file mode 100644 index 00000000..2316ff22 --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowStepConfigEntity.xml @@ -0,0 +1,303 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + id + ,create_user_id + ,create_time + ,modify_user_id + ,modify_time + ,sts + ,flow_id + ,step_id + ,setp_config_id + ,action_name + ,db_type + ,table_name + ,row_num + ,page_limit + ,max_value_field + ,create_table_flag + ,write_type + ,sql_statement + + + + + + + + + + + + + + + + insert into sys_flow_step_config( + + id , + create_user_id , + create_time , + modify_user_id , + modify_time , + sts , + flow_id , + step_id , + setp_config_id , + action_name , + db_type , + table_name , + row_num , + page_limit , + max_value_field , + create_table_flag , + write_type , + sql_statement , + sorts, + sts, + + )values( + + #{id} , + #{create_user_id} , + #{create_time} , + #{modify_user_id} , + #{modify_time} , + #{sts} , + #{flowId} , + #{stepId} , + #{setpConfigId} , + #{actionName} , + #{dbType} , + #{tableName} , + #{rowNum} , + #{pageLimit} , + #{maxValueField} , + #{createTableFlag} , + #{writeType} , + #{sqlStatement} , + (select (max(IFNULL( a.sorts, 0 )) + 1) as sort from sys_flow_step_config a WHERE a.sts = 'Y' ), + 'Y', + + ) + + + + insert into sys_flow_step_config(create_user_id, create_time, modify_user_id, modify_time, sts, flow_id, step_id, setp_config_id, action_name, db_type, table_name, row_num, page_limit, max_value_field, create_table_flag, write_type, sql_statement, sts) + values + + (#{entity.create_user_id},#{entity.create_time},#{entity.modify_user_id},#{entity.modify_time},#{entity.sts},#{entity.flowId},#{entity.stepId},#{entity.setpConfigId},#{entity.actionName},#{entity.dbType},#{entity.tableName},#{entity.rowNum},#{entity.pageLimit},#{entity.maxValueField},#{entity.createTableFlag},#{entity.writeType},#{entity.sqlStatement}, 'Y') + + + + + insert into sys_flow_step_config(create_user_id, create_time, modify_user_id, modify_time, sts, flow_id, step_id, setp_config_id, action_name, db_type, table_name, row_num, page_limit, max_value_field, create_table_flag, write_type, sql_statement) + values + + (#{entity.create_user_id},#{entity.create_time},#{entity.modify_user_id},#{entity.modify_time},#{entity.sts},#{entity.flowId},#{entity.stepId},#{entity.setpConfigId},#{entity.actionName},#{entity.dbType},#{entity.tableName},#{entity.rowNum},#{entity.pageLimit},#{entity.maxValueField},#{entity.createTableFlag},#{entity.writeType},#{entity.sqlStatement}) + + on duplicate key update + create_user_id = values(create_user_id), + create_time = values(create_time), + modify_user_id = values(modify_user_id), + modify_time = values(modify_time), + sts = values(sts), + flow_id = values(flow_id), + step_id = values(step_id), + setp_config_id = values(setp_config_id), + action_name = values(action_name), + db_type = values(db_type), + table_name = values(table_name), + row_num = values(row_num), + page_limit = values(page_limit), + max_value_field = values(max_value_field), + create_table_flag = values(create_table_flag), + write_type = values(write_type), + sql_statement = values(sql_statement) + + +update sys_flow_step_config set + + create_user_id = #{create_user_id}, + create_time = #{create_time}, + modify_user_id = #{modify_user_id}, + modify_time = #{modify_time}, + sts = #{sts}, + flow_id = #{flowId}, + step_id = #{stepId}, + setp_config_id = #{setpConfigId}, + action_name = #{actionName}, + db_type = #{dbType}, + table_name = #{tableName}, + row_num = #{rowNum}, + page_limit = #{pageLimit}, + max_value_field = #{maxValueField}, + create_table_flag = #{createTableFlag}, + write_type = #{writeType}, + sql_statement = #{sqlStatement}, + +where id = #{id} + + + +update sys_flow_step_config set sts= 'N' ,modify_time = #{modify_time},modify_user_id = #{modify_user_id} +where id = #{id} + + + +update sys_flow_step_config set sts= 'N' ,modify_time = #{modify_time},modify_user_id = #{modify_user_id} + + and id = #{id} + and sts = #{sts} + and flow_id = #{flowId} + and step_id = #{stepId} + and setp_config_id = #{setpConfigId} + and action_name = #{actionName} + and db_type = #{dbType} + and table_name = #{tableName} + and row_num = #{rowNum} + and page_limit = #{pageLimit} + and max_value_field = #{maxValueField} + and create_table_flag = #{createTableFlag} + and write_type = #{writeType} + and sql_statement = #{sqlStatement} + and sts='Y' + + + + + delete from sys_flow_step_config where id = #{id} + + + + diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowStepEntity.java b/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowStepEntity.java new file mode 100644 index 00000000..52e7b316 --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowStepEntity.java @@ -0,0 +1,116 @@ +package com.hzya.frame.sys.flow.entity; + +import java.util.Date; +import com.hzya.frame.web.entity.BaseEntity; +/** + * 流程步骤信息(SysFlowStep)实体类 + * + * @author xiang2lin + * @since 2025-04-29 10:16:27 + */ +public class SysFlowStepEntity extends BaseEntity { + + /** 步骤序号 */ + private Integer step; + /** 步骤类型;1定时任务2数据库3应用 */ + private String stepType; + /** 描述 */ + private String description; + /** 操作动作（名称）;api名称/插件名称 */ + private String apiName; + /** 操作动作类型;api/插件 */ + private String actionType; + /** 应用id */ + private String appId; + /** 操作动作id;api_id,根据操作动作类型来决定是查api还是插件 */ + private String apiId; + /** nifi返回的应用id;刘工接口返回的nifi应用id，不确定要不要 */ + private String nifiAppId; + /** nifi的apiId */ + private String nifiApiId; + /** nifi应用排序模式;先进先出/先进后出 */ + private String sortMode; + + + public Integer getStep() { + return step; + } + + public void setStep(Integer step) { + this.step = step; + } + + public String getStepType() { + return stepType; + } + + public void setStepType(String stepType) { + this.stepType = stepType; + } + + public String getDescription() { + return description; + } + + public void setDescription(String description) { + this.description = description; + } + + public String getApiName() { + return apiName; + } + + public void setApiName(String apiName) { + this.apiName = apiName; + } + + public String getActionType() { + return actionType; + } + + public void setActionType(String actionType) { + this.actionType = actionType; + } + + public String getAppId() { + return appId; + } + + public void setAppId(String appId) { + this.appId = appId; + } + + public String getApiId() { + return apiId; + } + + public void setApiId(String apiId) { + this.apiId = apiId; + } + + public String getNifiAppId() { + return nifiAppId; + } + + public void setNifiAppId(String nifiAppId) { + this.nifiAppId = nifiAppId; + } + + public String getNifiApiId() { + return nifiApiId; + } + + public void setNifiApiId(String nifiApiId) { + this.nifiApiId = nifiApiId; + } + + public String getSortMode() { + return sortMode; + } + + public void setSortMode(String sortMode) { + this.sortMode = sortMode; + } + +} + diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowStepEntity.xml b/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowStepEntity.xml new file mode 100644 index 00000000..814ec1d4 --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowStepEntity.xml @@ -0,0 +1,281 @@ + + + + + + + + + + + + + + + + + + + + + + + + + id + ,create_user_id + ,create_time + ,modify_user_id + ,modify_time + ,sts + ,step + ,step_type + ,description + ,api_name + ,action_type + ,app_id + ,api_id + ,nifi_app_id + ,nifi_api_id + ,sort_mode + + + + + + + + + + + + + + + + insert into sys_flow_step( + + id , + create_user_id , + create_time , + modify_user_id , + modify_time , + sts , + step , + step_type , + description , + api_name , + action_type , + app_id , + api_id , + nifi_app_id , + nifi_api_id , + sort_mode , + sorts, + sts, + + )values( + + #{id} , + #{create_user_id} , + #{create_time} , + #{modify_user_id} , + #{modify_time} , + #{sts} , + #{step} , + #{stepType} , + #{description} , + #{apiName} , + #{actionType} , + #{appId} , + #{apiId} , + #{nifiAppId} , + #{nifiApiId} , + #{sortMode} , + (select (max(IFNULL( a.sorts, 0 )) + 1) as sort from sys_flow_step a WHERE a.sts = 'Y' ), + 'Y', + + ) + + + + insert into sys_flow_step(create_user_id, create_time, modify_user_id, modify_time, sts, step, step_type, description, api_name, action_type, app_id, api_id, nifi_app_id, nifi_api_id, sort_mode, sts) + values + + (#{entity.create_user_id},#{entity.create_time},#{entity.modify_user_id},#{entity.modify_time},#{entity.sts},#{entity.step},#{entity.stepType},#{entity.description},#{entity.apiName},#{entity.actionType},#{entity.appId},#{entity.apiId},#{entity.nifiAppId},#{entity.nifiApiId},#{entity.sortMode}, 'Y') + + + + + insert into sys_flow_step(create_user_id, create_time, modify_user_id, modify_time, sts, step, step_type, description, api_name, action_type, app_id, api_id, nifi_app_id, nifi_api_id, sort_mode) + values + + (#{entity.create_user_id},#{entity.create_time},#{entity.modify_user_id},#{entity.modify_time},#{entity.sts},#{entity.step},#{entity.stepType},#{entity.description},#{entity.apiName},#{entity.actionType},#{entity.appId},#{entity.apiId},#{entity.nifiAppId},#{entity.nifiApiId},#{entity.sortMode}) + + on duplicate key update + create_user_id = values(create_user_id), + create_time = values(create_time), + modify_user_id = values(modify_user_id), + modify_time = values(modify_time), + sts = values(sts), + step = values(step), + step_type = values(step_type), + description = values(description), + api_name = values(api_name), + action_type = values(action_type), + app_id = values(app_id), + api_id = values(api_id), + nifi_app_id = values(nifi_app_id), + nifi_api_id = values(nifi_api_id), + sort_mode = values(sort_mode) + + +update sys_flow_step set + + create_user_id = #{create_user_id}, + create_time = #{create_time}, + modify_user_id = #{modify_user_id}, + modify_time = #{modify_time}, + sts = #{sts}, + step = #{step}, + step_type = #{stepType}, + description = #{description}, + api_name = #{apiName}, + action_type = #{actionType}, + app_id = #{appId}, + api_id = #{apiId}, + nifi_app_id = #{nifiAppId}, + nifi_api_id = #{nifiApiId}, + sort_mode = #{sortMode}, + +where id = #{id} + + + +update sys_flow_step set sts= 'N' ,modify_time = #{modify_time},modify_user_id = #{modify_user_id} +where id = #{id} + + + +update sys_flow_step set sts= 'N' ,modify_time = #{modify_time},modify_user_id = #{modify_user_id} + + and id = #{id} + and sts = #{sts} + and step = #{step} + and step_type = #{stepType} + and description = #{description} + and api_name = #{apiName} + and action_type = #{actionType} + and app_id = #{appId} + and api_id = #{apiId} + and nifi_app_id = #{nifiAppId} + and nifi_api_id = #{nifiApiId} + and sort_mode = #{sortMode} + and sts='Y' + + + + + delete from sys_flow_step where id = #{id} + + + + diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowStepRelationEntity.java b/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowStepRelationEntity.java new file mode 100644 index 00000000..71db7af2 --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowStepRelationEntity.java @@ -0,0 +1,76 @@ +package com.hzya.frame.sys.flow.entity; + +import java.util.Date; +import com.hzya.frame.web.entity.BaseEntity; +/** + * 步骤关联关系表(SysFlowStepRelation)实体类 + * + * @author xiang2lin + * @since 2025-04-29 10:16:28 + */ +public class SysFlowStepRelationEntity extends BaseEntity { + + /** 输入步骤 */ + private String inputStepId; + /** 输出步骤 */ + private String outputStepId; + /** 输入nifi app id */ + private String inputNifiAppId; + /** 输出nifiidapp id */ + private String outputNifiAppId; + /** 输入nifi api id */ + private String inputNifiApiId; + /** 输出nifiidapi id */ + private String outputNifiApiId; + + + public String getInputStepId() { + return inputStepId; + } + + public void setInputStepId(String inputStepId) { + this.inputStepId = inputStepId; + } + + public String getOutputStepId() { + return outputStepId; + } + + public void setOutputStepId(String outputStepId) { + this.outputStepId = outputStepId; + } + + public String getInputNifiAppId() { + return inputNifiAppId; + } + + public void setInputNifiAppId(String inputNifiAppId) { + this.inputNifiAppId = inputNifiAppId; + } + + public String getOutputNifiAppId() { + return outputNifiAppId; + } + + public void setOutputNifiAppId(String outputNifiAppId) { + this.outputNifiAppId = outputNifiAppId; + } + + public String getInputNifiApiId() { + return inputNifiApiId; + } + + public void setInputNifiApiId(String inputNifiApiId) { + this.inputNifiApiId = inputNifiApiId; + } + + public String getOutputNifiApiId() { + return outputNifiApiId; + } + + public void setOutputNifiApiId(String outputNifiApiId) { + this.outputNifiApiId = outputNifiApiId; + } + +} + diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowStepRelationEntity.xml b/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowStepRelationEntity.xml new file mode 100644 index 00000000..c0a560fe --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/entity/SysFlowStepRelationEntity.xml @@ -0,0 +1,237 @@ + + + + + + + + + + + + + + + + + + + + + id + ,create_user_id + ,create_time + ,modify_user_id + ,modify_time + ,sts + ,input_step_id + ,output_step_id + ,input_nifi_app_id + ,output_nifi_app_id + ,input_nifi_api_id + ,output_nifi_api_id + + + + + + + + + + + + + + + + insert into sys_flow_step_relation( + + id , + create_user_id , + create_time , + modify_user_id , + modify_time , + sts , + input_step_id , + output_step_id , + input_nifi_app_id , + output_nifi_app_id , + input_nifi_api_id , + output_nifi_api_id , + sorts, + sts, + + )values( + + #{id} , + #{create_user_id} , + #{create_time} , + #{modify_user_id} , + #{modify_time} , + #{sts} , + #{inputStepId} , + #{outputStepId} , + #{inputNifiAppId} , + #{outputNifiAppId} , + #{inputNifiApiId} , + #{outputNifiApiId} , + (select (max(IFNULL( a.sorts, 0 )) + 1) as sort from sys_flow_step_relation a WHERE a.sts = 'Y' ), + 'Y', + + ) + + + + insert into sys_flow_step_relation(create_user_id, create_time, modify_user_id, modify_time, sts, input_step_id, output_step_id, input_nifi_app_id, output_nifi_app_id, input_nifi_api_id, output_nifi_api_id, sts) + values + + (#{entity.create_user_id},#{entity.create_time},#{entity.modify_user_id},#{entity.modify_time},#{entity.sts},#{entity.inputStepId},#{entity.outputStepId},#{entity.inputNifiAppId},#{entity.outputNifiAppId},#{entity.inputNifiApiId},#{entity.outputNifiApiId}, 'Y') + + + + + insert into sys_flow_step_relation(create_user_id, create_time, modify_user_id, modify_time, sts, input_step_id, output_step_id, input_nifi_app_id, output_nifi_app_id, input_nifi_api_id, output_nifi_api_id) + values + + (#{entity.create_user_id},#{entity.create_time},#{entity.modify_user_id},#{entity.modify_time},#{entity.sts},#{entity.inputStepId},#{entity.outputStepId},#{entity.inputNifiAppId},#{entity.outputNifiAppId},#{entity.inputNifiApiId},#{entity.outputNifiApiId}) + + on duplicate key update + create_user_id = values(create_user_id), + create_time = values(create_time), + modify_user_id = values(modify_user_id), + modify_time = values(modify_time), + sts = values(sts), + input_step_id = values(input_step_id), + output_step_id = values(output_step_id), + input_nifi_app_id = values(input_nifi_app_id), + output_nifi_app_id = values(output_nifi_app_id), + input_nifi_api_id = values(input_nifi_api_id), + output_nifi_api_id = values(output_nifi_api_id) + + +update sys_flow_step_relation set + + create_user_id = #{create_user_id}, + create_time = #{create_time}, + modify_user_id = #{modify_user_id}, + modify_time = #{modify_time}, + sts = #{sts}, + input_step_id = #{inputStepId}, + output_step_id = #{outputStepId}, + input_nifi_app_id = #{inputNifiAppId}, + output_nifi_app_id = #{outputNifiAppId}, + input_nifi_api_id = #{inputNifiApiId}, + output_nifi_api_id = #{outputNifiApiId}, + +where id = #{id} + + + +update sys_flow_step_relation set sts= 'N' ,modify_time = #{modify_time},modify_user_id = #{modify_user_id} +where id = #{id} + + + +update sys_flow_step_relation set sts= 'N' ,modify_time = #{modify_time},modify_user_id = #{modify_user_id} + + and id = #{id} + and sts = #{sts} + and input_step_id = #{inputStepId} + and output_step_id = #{outputStepId} + and input_nifi_app_id = #{inputNifiAppId} + and output_nifi_app_id = #{outputNifiAppId} + and input_nifi_api_id = #{inputNifiApiId} + and output_nifi_api_id = #{outputNifiApiId} + and sts='Y' + + + + + delete from sys_flow_step_relation where id = #{id} + + + + diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/service/ISysFlowClassRuleService.java b/base-service/src/main/java/com/hzya/frame/sys/flow/service/ISysFlowClassRuleService.java new file mode 100644 index 00000000..4994c591 --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/service/ISysFlowClassRuleService.java @@ -0,0 +1,50 @@ +package com.hzya.frame.sys.flow.service; + +import com.alibaba.fastjson.JSONObject; +import com.hzya.frame.sys.flow.entity.SysFlowClassRuleEntity; +import com.hzya.frame.basedao.service.IBaseService; +import com.hzya.frame.web.entity.JsonResultEntity; + +/** + * 流程分类权限表(SysFlowClassRule)表服务接口 + * + * @author xiang2lin + * @since 2025-04-29 10:16:27 + */ +public interface ISysFlowClassRuleService extends IBaseService{ + + /** + * 新增流程分类权限 + * @param object + * @return + */ + JsonResultEntity saveFlowClassRule(JSONObject object); + + /** + * 修改流程分类权限 + * @param object + * @return + */ + JsonResultEntity updateFlowClassRule(JSONObject object); + + /** + * 删除流程分类权限 + * @param object + * @return + */ + JsonResultEntity deleteFlowClassRule(JSONObject object); + + /** + * 列表查询 + * @param object + * @return + */ + JsonResultEntity queryRuleList(JSONObject object); + + /** + * 分页查询 + * @param object + * @return + */ + JsonResultEntity queryRulePagedInfo(JSONObject object); +} diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/service/ISysFlowClassService.java b/base-service/src/main/java/com/hzya/frame/sys/flow/service/ISysFlowClassService.java new file mode 100644 index 00000000..905dcfce --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/service/ISysFlowClassService.java @@ -0,0 +1,36 @@ +package com.hzya.frame.sys.flow.service; + +import com.alibaba.fastjson.JSONObject; +import com.hzya.frame.sys.flow.entity.SysFlowClassEntity; +import com.hzya.frame.basedao.service.IBaseService; +import com.hzya.frame.web.entity.JsonResultEntity; + +/** + * 流程分类;对应数环通项目分类(SysFlowClass)表服务接口 + * + * @author xiang2lin + * @since 2025-04-29 10:16:27 + */ +public interface ISysFlowClassService extends IBaseService{ + + /** + * 新增流程分类 + * @param object + * @return + */ + JsonResultEntity saveFlowClass(JSONObject object); + + /** + * 修改流程分类 + * @param object + * @return + */ + JsonResultEntity updateFlowClass(JSONObject object); + + /** + * 删除流程分类 + * @param object + * @return + */ + JsonResultEntity deleteFlowClass(JSONObject object); +} diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/service/ISysFlowNifiConstantService.java b/base-service/src/main/java/com/hzya/frame/sys/flow/service/ISysFlowNifiConstantService.java new file mode 100644 index 00000000..f4e3a8fe --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/service/ISysFlowNifiConstantService.java @@ -0,0 +1,36 @@ +package com.hzya.frame.sys.flow.service; + +import com.alibaba.fastjson.JSONObject; +import com.hzya.frame.sys.flow.entity.SysFlowNifiConstantEntity; +import com.hzya.frame.basedao.service.IBaseService; +import com.hzya.frame.web.entity.JsonResultEntity; + +/** + * nifi常量(SysFlowNifiConstant)表服务接口 + * + * @author xiang2lin + * @since 2025-04-29 10:16:27 + */ +public interface ISysFlowNifiConstantService extends IBaseService{ + + /** + * 保存nifi常量 + * @param object + * @return + */ + JsonResultEntity saveNifiConstant(JSONObject object); + + /** + * 更新nifi常量 + * @param object + * @return + */ + JsonResultEntity updateNifiConstant(JSONObject object); + + /** + * 更新nifi常量 + * @param object + * @return + */ + JsonResultEntity deleteNifiConstant(JSONObject object); +} diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/service/ISysFlowService.java b/base-service/src/main/java/com/hzya/frame/sys/flow/service/ISysFlowService.java new file mode 100644 index 00000000..7f2f4af8 --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/service/ISysFlowService.java @@ -0,0 +1,12 @@ +package com.hzya.frame.sys.flow.service; + +import com.hzya.frame.sys.flow.entity.SysFlowEntity; +import com.hzya.frame.basedao.service.IBaseService; +/** + * 流程主表;流程就是数环通的Linkup(SysFlow)表服务接口 + * + * @author xiang2lin + * @since 2025-04-29 10:16:24 + */ +public interface ISysFlowService extends IBaseService{ +} diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/service/ISysFlowStepAccountService.java b/base-service/src/main/java/com/hzya/frame/sys/flow/service/ISysFlowStepAccountService.java new file mode 100644 index 00000000..eb7f5df1 --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/service/ISysFlowStepAccountService.java @@ -0,0 +1,12 @@ +package com.hzya.frame.sys.flow.service; + +import com.hzya.frame.sys.flow.entity.SysFlowStepAccountEntity; +import com.hzya.frame.basedao.service.IBaseService; +/** + * 流程步骤账户表(SysFlowStepAccount)表服务接口 + * + * @author xiang2lin + * @since 2025-04-29 10:16:28 + */ +public interface ISysFlowStepAccountService extends IBaseService{ +} diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/service/ISysFlowStepConfigBService.java b/base-service/src/main/java/com/hzya/frame/sys/flow/service/ISysFlowStepConfigBService.java new file mode 100644 index 00000000..80f74441 --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/service/ISysFlowStepConfigBService.java @@ -0,0 +1,12 @@ +package com.hzya.frame.sys.flow.service; + +import com.hzya.frame.sys.flow.entity.SysFlowStepConfigBEntity; +import com.hzya.frame.basedao.service.IBaseService; +/** + * 映射信息表体(SysFlowStepConfigB)表服务接口 + * + * @author xiang2lin + * @since 2025-04-29 10:16:28 + */ +public interface ISysFlowStepConfigBService extends IBaseService{ +} diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/service/ISysFlowStepConfigService.java b/base-service/src/main/java/com/hzya/frame/sys/flow/service/ISysFlowStepConfigService.java new file mode 100644 index 00000000..385d92c4 --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/service/ISysFlowStepConfigService.java @@ -0,0 +1,12 @@ +package com.hzya.frame.sys.flow.service; + +import com.hzya.frame.sys.flow.entity.SysFlowStepConfigEntity; +import com.hzya.frame.basedao.service.IBaseService; +/** + * 映射信息主表(SysFlowStepConfig)表服务接口 + * + * @author xiang2lin + * @since 2025-04-29 10:16:28 + */ +public interface ISysFlowStepConfigService extends IBaseService{ +} diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/service/ISysFlowStepRelationService.java b/base-service/src/main/java/com/hzya/frame/sys/flow/service/ISysFlowStepRelationService.java new file mode 100644 index 00000000..f5358083 --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/service/ISysFlowStepRelationService.java @@ -0,0 +1,12 @@ +package com.hzya.frame.sys.flow.service; + +import com.hzya.frame.sys.flow.entity.SysFlowStepRelationEntity; +import com.hzya.frame.basedao.service.IBaseService; +/** + * 步骤关联关系表(SysFlowStepRelation)表服务接口 + * + * @author xiang2lin + * @since 2025-04-29 10:16:28 + */ +public interface ISysFlowStepRelationService extends IBaseService{ +} diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/service/ISysFlowStepService.java b/base-service/src/main/java/com/hzya/frame/sys/flow/service/ISysFlowStepService.java new file mode 100644 index 00000000..9d3e226f --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/service/ISysFlowStepService.java @@ -0,0 +1,12 @@ +package com.hzya.frame.sys.flow.service; + +import com.hzya.frame.sys.flow.entity.SysFlowStepEntity; +import com.hzya.frame.basedao.service.IBaseService; +/** + * 流程步骤信息(SysFlowStep)表服务接口 + * + * @author xiang2lin + * @since 2025-04-29 10:16:27 + */ +public interface ISysFlowStepService extends IBaseService{ +} diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/service/impl/SysFlowClassRuleServiceImpl.java b/base-service/src/main/java/com/hzya/frame/sys/flow/service/impl/SysFlowClassRuleServiceImpl.java new file mode 100644 index 00000000..b51a3dae --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/service/impl/SysFlowClassRuleServiceImpl.java @@ -0,0 +1,174 @@ +package com.hzya.frame.sys.flow.service.impl; + +import cn.hutool.core.convert.Convert; +import cn.hutool.core.lang.Assert; +import com.alibaba.fastjson.JSONObject; +import com.github.pagehelper.PageHelper; +import com.github.pagehelper.PageInfo; +import com.hzya.frame.sys.flow.entity.SysFlowClassRuleEntity; +import com.hzya.frame.sys.flow.dao.ISysFlowClassRuleDao; +import com.hzya.frame.sys.flow.service.ISysFlowClassRuleService; +import com.hzya.frame.uuid.UUIDUtils; +import com.hzya.frame.web.entity.BaseResult; +import com.hzya.frame.web.entity.JsonResultEntity; +import org.springframework.stereotype.Service; +import org.springframework.beans.factory.annotation.Autowired; +import javax.annotation.Resource; +import com.hzya.frame.basedao.service.impl.BaseService; + +import java.util.List; + +/** + * 流程分类权限表(SysFlowClassRule)表服务实现类 + * + * @author xiang2lin + * @since 2025-04-29 10:16:27 + */ +@Service(value = "sysFlowClassRuleService") +public class SysFlowClassRuleServiceImpl extends BaseService implements ISysFlowClassRuleService { + + private ISysFlowClassRuleDao sysFlowClassRuleDao; + + @Autowired + public void setSysFlowClassRuleDao(ISysFlowClassRuleDao dao) { + this.sysFlowClassRuleDao = dao; + this.dao = dao; + } + + + /** + * 新增流程分类权限 + * + * @param object + * @return + */ + @Override + public JsonResultEntity saveFlowClassRule(JSONObject object) { + SysFlowClassRuleEntity ruleEntity = getData("jsonStr",object,SysFlowClassRuleEntity.class); + try { + this.checkParams(ruleEntity,"save"); + }catch(Exception e){ + return BaseResult.getFailureMessageEntity(e.getMessage()); + } + addRule(ruleEntity); + return BaseResult.getSuccessMessageEntity("保存成功"); + } + + //保存 + private void addRule(SysFlowClassRuleEntity ruleEntity) { + List ruleList = ruleEntity.getRuleList(); + for (SysFlowClassRuleEntity r : ruleList) { + r.setId(UUIDUtils.getUUID()); + r.setCreate_time(Convert.toDate(ruleEntity.getCreate_time(),ruleEntity.getModify_time())); + r.setCreate_user_id(Convert.toStr(ruleEntity.getCreate_user_id(),ruleEntity.getModify_user_id())); + r.setModify_time(r.getCreate_time()); + r.setModify_user_id(r.getCreate_user_id()); + r.setFlowClassId(ruleEntity.getFlowClassId()); + sysFlowClassRuleDao.save(r); + } + } + + /** + * 修改流程分类权限 + * + * @param object + * @return + */ + @Override + public JsonResultEntity updateFlowClassRule(JSONObject object) { + SysFlowClassRuleEntity ruleEntity = getData("jsonStr",object,SysFlowClassRuleEntity.class); + try { + this.checkParams(ruleEntity,"update"); + }catch(Exception e){ + return BaseResult.getFailureMessageEntity(e.getMessage()); + } + //先删除 再重新保存 + SysFlowClassRuleEntity rule = new SysFlowClassRuleEntity(); + rule.setFlowClassId(ruleEntity.getFlowClassId()); + sysFlowClassRuleDao.logicRemoveMultiCondition(rule); + addRule(ruleEntity); + return BaseResult.getSuccessMessageEntity("更新成功"); + } + + /** + * 删除流程分类权限 + * + * @param object + * @return + */ + @Override + public JsonResultEntity deleteFlowClassRule(JSONObject object) { + SysFlowClassRuleEntity ruleEntity = getData("jsonStr",object,SysFlowClassRuleEntity.class); + try { + this.checkParams(ruleEntity,"delete"); + }catch (Exception e){ + return BaseResult.getFailureMessageEntity(e.getMessage()); + } + SysFlowClassRuleEntity deleteRuleEntity = new SysFlowClassRuleEntity(); + deleteRuleEntity.setFlowClassId(ruleEntity.getFlowClassId()); + sysFlowClassRuleDao.logicRemoveMultiCondition(deleteRuleEntity); + return BaseResult.getSuccessMessageEntity("删除成功"); + } + + /** + * 列表查询 + * + * @param object + * @return + */ + @Override + public JsonResultEntity queryRuleList(JSONObject object) { + SysFlowClassRuleEntity ruleEntity = getData("jsonStr",object,SysFlowClassRuleEntity.class); + try { + checkParams(ruleEntity,"queryList"); + }catch(Exception e){ + return BaseResult.getFailureMessageEntity(e.getMessage()); + } + List sysFlowClassRuleEntities = sysFlowClassRuleDao.queryByLike(ruleEntity); + SysFlowClassRuleEntity reuslt = new SysFlowClassRuleEntity(); + reuslt.setFlowClassId(ruleEntity.getFlowClassId()); + reuslt.setRuleList(sysFlowClassRuleEntities); + return BaseResult.getSuccessMessageEntity("查询数据成功",reuslt); + } + + /** + * 分页查询 + * + * @param object + * @return + */ + @Override + public JsonResultEntity queryRulePagedInfo(JSONObject object) { + SysFlowClassRuleEntity ruleEntity = getData("jsonStr",object,SysFlowClassRuleEntity.class); + try { + checkParams(ruleEntity,"queryPaged"); + }catch(Exception e){ + return BaseResult.getFailureMessageEntity(e.getMessage()); + } + PageHelper.startPage(ruleEntity.getPageNum(), ruleEntity.getPageSize()); + List queryByLike = this.dao.queryByLike(ruleEntity); + PageInfo pageInfo = new PageInfo(queryByLike); + return BaseResult.getSuccessMessageEntity("查询数据成功",pageInfo); + } + + /** + * 检查参数 + * @param entity 参数对象 + * @param type 操作；类型 + */ + private void checkParams(SysFlowClassRuleEntity entity,String type){ + Assert.notNull(entity,"请求参数不能为空"); + Assert.notEmpty(entity.getFlowClassId(),"flowClassId不能为空"); + if ("save".equals(type)){ + Assert.notEmpty(entity.getRuleList(),"ruleList不能为空"); + }else if ("update".equals(type)){ + Assert.notEmpty(entity.getRuleList(),"ruleList不能为空"); + }else if ("delete".equals(type)){ + + }else if ("queryPaged".equals(type)){ + Assert.notNull(entity.getPageNum(),"pageNum不能为空"); + Assert.notNull(entity.getPageSize(),"pageSize不能为空"); + } + + } +} diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/service/impl/SysFlowClassServiceImpl.java b/base-service/src/main/java/com/hzya/frame/sys/flow/service/impl/SysFlowClassServiceImpl.java new file mode 100644 index 00000000..5b710436 --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/service/impl/SysFlowClassServiceImpl.java @@ -0,0 +1,136 @@ +package com.hzya.frame.sys.flow.service.impl; + +import cn.hutool.core.lang.Assert; +import com.alibaba.fastjson.JSONObject; +import com.hzya.frame.sys.flow.dao.ISysFlowDao; +import com.hzya.frame.sys.flow.entity.SysFlowClassEntity; +import com.hzya.frame.sys.flow.dao.ISysFlowClassDao; +import com.hzya.frame.sys.flow.entity.SysFlowEntity; +import com.hzya.frame.sys.flow.service.ISysFlowClassService; +import com.hzya.frame.uuid.UUIDUtils; +import com.hzya.frame.web.entity.BaseResult; +import com.hzya.frame.web.entity.JsonResultEntity; +import com.hzya.frame.web.exception.BaseSystemException; +import org.apache.commons.collections.CollectionUtils; +import org.springframework.stereotype.Service; +import org.springframework.beans.factory.annotation.Autowired; +import javax.annotation.Resource; +import com.hzya.frame.basedao.service.impl.BaseService; + +import java.util.List; + +/** + * 流程分类;对应数环通项目分类(SysFlowClass)表服务实现类 + * + * @author xiang2lin + * @since 2025-04-29 10:16:27 + */ +@Service(value = "sysFlowClassService") +public class SysFlowClassServiceImpl extends BaseService implements ISysFlowClassService { + + private ISysFlowClassDao sysFlowClassDao; + @Autowired + private ISysFlowDao sysFlowDao; + + @Autowired + public void setSysFlowClassDao(ISysFlowClassDao dao) { + this.sysFlowClassDao = dao; + this.dao = dao; + } + + /** + * 新增流程分类 + * + * @param object + * @return + */ + @Override + public JsonResultEntity saveFlowClass(JSONObject object) { + SysFlowClassEntity flowClass = getData("jsonStr",object,SysFlowClassEntity.class); + try { + this.checkParams(flowClass,"add"); + }catch(Exception e){ + return BaseResult.getFailureMessageEntity(e.getMessage()); + } + flowClass.setId(UUIDUtils.getUUID()); + sysFlowClassDao.save(flowClass); + return BaseResult.getSuccessMessageEntity("新增成功"); + } + + /** + * 修改流程分类 + * + * @param object + * @return + */ + @Override + public JsonResultEntity updateFlowClass(JSONObject object) { + SysFlowClassEntity flowClass = getData("jsonStr",object,SysFlowClassEntity.class); + try { + this.checkParams(flowClass,"update"); + }catch(Exception e){ + return BaseResult.getFailureMessageEntity(e.getMessage()); + } + sysFlowClassDao.update(flowClass); + return BaseResult.getSuccessMessageEntity("更新成功"); + } + + /** + * 删除流程分类 + * + * @param object + * @return + */ + @Override + public JsonResultEntity deleteFlowClass(JSONObject object) { + SysFlowClassEntity flowClass = getData("jsonStr",object,SysFlowClassEntity.class); + try { + this.checkParams(flowClass,"delete"); + }catch(Exception e){ + return BaseResult.getFailureMessageEntity(e.getMessage()); + } + sysFlowClassDao.logicRemove(flowClass); + return BaseResult.getSuccessMessageEntity("删除成功"); + } + + /** + * 参数检查 + * @param flowClass + * @param type + */ + private void checkParams(SysFlowClassEntity flowClass,String type){ + Assert.notNull(flowClass,"请求参数不能为空"); + if ("add".equals(type)){//新增 + Assert.notEmpty(flowClass.getName(),"名称不能为空"); + //查询是否有同名的 + SysFlowClassEntity flowQuery = new SysFlowClassEntity(); + flowQuery.setName(flowClass.getName()); + List query = sysFlowClassDao.query(flowQuery); + if (CollectionUtils.isNotEmpty(query)){ + throw new BaseSystemException(flowClass.getName()+"已存在"); + } + }else if ("update".equals(type)){//更新 + Assert.notEmpty(flowClass.getId(),"id不能为空"); + //查一下有没有同名的 + SysFlowClassEntity flowQuery = new SysFlowClassEntity(); + flowQuery.setName(flowClass.getName()); + List query = sysFlowClassDao.query(flowQuery); + if (CollectionUtils.isNotEmpty(query)){ + for (SysFlowClassEntity f : query) { + if (!f.getId().equals(flowClass.getId())){ + throw new BaseSystemException(flowClass.getName()+"已存在"); + } + } + } + }else if ("delete".equals(type)){//删除 + Assert.notEmpty(flowClass.getId(),"id不能为空"); + //查一下这个分类有没有被引用 + SysFlowEntity sysFlowEntity = new SysFlowEntity(); + sysFlowEntity.setClassId(flowClass.getId()); + List query = sysFlowDao.query(sysFlowEntity); + if (CollectionUtils.isNotEmpty(query)){ + throw new BaseSystemException("该分类已被引用，删除失败"); + } + } + } +} diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/service/impl/SysFlowNifiConstantServiceImpl.java b/base-service/src/main/java/com/hzya/frame/sys/flow/service/impl/SysFlowNifiConstantServiceImpl.java new file mode 100644 index 00000000..42c3f193 --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/service/impl/SysFlowNifiConstantServiceImpl.java @@ -0,0 +1,135 @@ +package com.hzya.frame.sys.flow.service.impl; + +import cn.hutool.core.lang.Assert; +import cn.hutool.core.util.StrUtil; +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONObject; +import com.hzya.frame.sys.flow.entity.SysFlowNifiConstantEntity; +import com.hzya.frame.sys.flow.dao.ISysFlowNifiConstantDao; +import com.hzya.frame.sys.flow.service.ISysFlowNifiConstantService; +import com.hzya.frame.web.entity.BaseResult; +import com.hzya.frame.web.entity.JsonResultEntity; +import com.hzya.frame.web.exception.BaseSystemException; +import org.apache.commons.collections.CollectionUtils; +import org.springframework.stereotype.Service; +import org.springframework.beans.factory.annotation.Autowired; +import javax.annotation.Resource; +import com.hzya.frame.basedao.service.impl.BaseService; + +import java.util.List; + +/** + * nifi常量(SysFlowNifiConstant)表服务实现类 + * + * @author xiang2lin + * @since 2025-04-29 10:16:27 + */ +@Service(value = "sysFlowNifiConstantService") +public class SysFlowNifiConstantServiceImpl extends BaseService implements ISysFlowNifiConstantService { + + private ISysFlowNifiConstantDao sysFlowNifiConstantDao; + + @Autowired + public void setSysFlowNifiConstantDao(ISysFlowNifiConstantDao dao) { + this.sysFlowNifiConstantDao = dao; + this.dao = dao; + } + + /** + * 保存nifi常量 + * + * @param object + * @return + */ + @Override + public JsonResultEntity saveNifiConstant(JSONObject object) { + SysFlowNifiConstantEntity sysFlowNifiConstantEntity = null; + try { + sysFlowNifiConstantEntity = preCheck(object,"save"); + }catch(Exception e){ + return BaseResult.getFailureMessageEntity(e.getMessage()); + } + sysFlowNifiConstantDao.save(sysFlowNifiConstantEntity); + return BaseResult.getSuccessMessageEntity("保存成功"); + } + + /** + * 更新nifi常量 + * + * @param object + * @return + */ + @Override + public JsonResultEntity updateNifiConstant(JSONObject object) { + SysFlowNifiConstantEntity sysFlowNifiConstantEntity = null; + try { + sysFlowNifiConstantEntity = preCheck(object,"update"); + }catch(Exception e){ + return BaseResult.getFailureMessageEntity(e.getMessage()); + } + sysFlowNifiConstantDao.update(sysFlowNifiConstantEntity); + return BaseResult.getSuccessMessageEntity("更新成功"); + } + + /** + * 更新nifi常量 + * + * @param object + * @return + */ + @Override + public JsonResultEntity deleteNifiConstant(JSONObject object) { + SysFlowNifiConstantEntity sysFlowNifiConstantEntity = null; + try { + sysFlowNifiConstantEntity = preCheck(object,"delete"); + }catch(Exception e){ + return BaseResult.getFailureMessageEntity(e.getMessage()); + } + sysFlowNifiConstantDao.logicRemove(sysFlowNifiConstantEntity); + return BaseResult.getSuccessMessageEntity("删除成功"); + } + + + /** + * 参数校验 + * @param entity + * @param type + */ + private void checkParams(SysFlowNifiConstantEntity entity,String type){ + Assert.notNull(entity,"请求参数不能为空"); + if ("save".equals(type)){ + Assert.notEmpty(entity.getNifiKey(),"nifiKey不能为空"); + Assert.notEmpty(entity.getNifiValue(),"nifiValue不能为空"); + //检查是否有重名的key + SysFlowNifiConstantEntity nifi = new SysFlowNifiConstantEntity(); + nifi.setNifiKey(entity.getNifiKey()); + List query = sysFlowNifiConstantDao.query(nifi); + if (CollectionUtils.isNotEmpty(query)){ + throw new BaseSystemException(nifi.getNifiKey()+"重复"); + } + }else if ("update".equals(type)){ + Assert.notEmpty(entity.getId(),"id不能为空"); + Assert.notEmpty(entity.getNifiKey(),"key不能为空"); + Assert.notEmpty(entity.getNifiValue(),"value不能为空"); + SysFlowNifiConstantEntity nifi = new SysFlowNifiConstantEntity(); + nifi.setNifiKey(entity.getNifiKey()); + List query = sysFlowNifiConstantDao.query(nifi); + if (CollectionUtils.isNotEmpty(query)){ + for (SysFlowNifiConstantEntity n : query) { + if (!n.getId().equals(entity.getId())){ + throw new BaseSystemException(entity.getNifiKey()+"重复"); + } + } + } + }else if ("delete".equals(type)){ + Assert.notEmpty(entity.getId(),"id不能为空"); + } + } + + //前置操作 + private SysFlowNifiConstantEntity preCheck(JSONObject object,String type){ + SysFlowNifiConstantEntity entity = getData("jsonStr", object,SysFlowNifiConstantEntity.class); + checkParams(entity,type); + return entity; + } +} diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/service/impl/SysFlowServiceImpl.java b/base-service/src/main/java/com/hzya/frame/sys/flow/service/impl/SysFlowServiceImpl.java new file mode 100644 index 00000000..5a1a55e8 --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/service/impl/SysFlowServiceImpl.java @@ -0,0 +1,26 @@ +package com.hzya.frame.sys.flow.service.impl; + +import com.hzya.frame.sys.flow.entity.SysFlowEntity; +import com.hzya.frame.sys.flow.dao.ISysFlowDao; +import com.hzya.frame.sys.flow.service.ISysFlowService; +import org.springframework.stereotype.Service; +import org.springframework.beans.factory.annotation.Autowired; +import javax.annotation.Resource; +import com.hzya.frame.basedao.service.impl.BaseService; +/** + * 流程主表;流程就是数环通的Linkup(SysFlow)表服务实现类 + * + * @author xiang2lin + * @since 2025-04-29 10:16:26 + */ +@Service(value = "sysFlowService") +public class SysFlowServiceImpl extends BaseService implements ISysFlowService { + + private ISysFlowDao sysFlowDao; + + @Autowired + public void setSysFlowDao(ISysFlowDao dao) { + this.sysFlowDao = dao; + this.dao = dao; + } +} diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/service/impl/SysFlowStepAccountServiceImpl.java b/base-service/src/main/java/com/hzya/frame/sys/flow/service/impl/SysFlowStepAccountServiceImpl.java new file mode 100644 index 00000000..a82cac3a --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/service/impl/SysFlowStepAccountServiceImpl.java @@ -0,0 +1,26 @@ +package com.hzya.frame.sys.flow.service.impl; + +import com.hzya.frame.sys.flow.entity.SysFlowStepAccountEntity; +import com.hzya.frame.sys.flow.dao.ISysFlowStepAccountDao; +import com.hzya.frame.sys.flow.service.ISysFlowStepAccountService; +import org.springframework.stereotype.Service; +import org.springframework.beans.factory.annotation.Autowired; +import javax.annotation.Resource; +import com.hzya.frame.basedao.service.impl.BaseService; +/** + * 流程步骤账户表(SysFlowStepAccount)表服务实现类 + * + * @author xiang2lin + * @since 2025-04-29 10:16:28 + */ +@Service(value = "sysFlowStepAccountService") +public class SysFlowStepAccountServiceImpl extends BaseService implements ISysFlowStepAccountService { + + private ISysFlowStepAccountDao sysFlowStepAccountDao; + + @Autowired + public void setSysFlowStepAccountDao(ISysFlowStepAccountDao dao) { + this.sysFlowStepAccountDao = dao; + this.dao = dao; + } +} diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/service/impl/SysFlowStepConfigBServiceImpl.java b/base-service/src/main/java/com/hzya/frame/sys/flow/service/impl/SysFlowStepConfigBServiceImpl.java new file mode 100644 index 00000000..3addfd52 --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/service/impl/SysFlowStepConfigBServiceImpl.java @@ -0,0 +1,26 @@ +package com.hzya.frame.sys.flow.service.impl; + +import com.hzya.frame.sys.flow.entity.SysFlowStepConfigBEntity; +import com.hzya.frame.sys.flow.dao.ISysFlowStepConfigBDao; +import com.hzya.frame.sys.flow.service.ISysFlowStepConfigBService; +import org.springframework.stereotype.Service; +import org.springframework.beans.factory.annotation.Autowired; +import javax.annotation.Resource; +import com.hzya.frame.basedao.service.impl.BaseService; +/** + * 映射信息表体(SysFlowStepConfigB)表服务实现类 + * + * @author xiang2lin + * @since 2025-04-29 10:16:28 + */ +@Service(value = "sysFlowStepConfigBService") +public class SysFlowStepConfigBServiceImpl extends BaseService implements ISysFlowStepConfigBService { + + private ISysFlowStepConfigBDao sysFlowStepConfigBDao; + + @Autowired + public void setSysFlowStepConfigBDao(ISysFlowStepConfigBDao dao) { + this.sysFlowStepConfigBDao = dao; + this.dao = dao; + } +} diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/service/impl/SysFlowStepConfigServiceImpl.java b/base-service/src/main/java/com/hzya/frame/sys/flow/service/impl/SysFlowStepConfigServiceImpl.java new file mode 100644 index 00000000..4c06c479 --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/service/impl/SysFlowStepConfigServiceImpl.java @@ -0,0 +1,26 @@ +package com.hzya.frame.sys.flow.service.impl; + +import com.hzya.frame.sys.flow.entity.SysFlowStepConfigEntity; +import com.hzya.frame.sys.flow.dao.ISysFlowStepConfigDao; +import com.hzya.frame.sys.flow.service.ISysFlowStepConfigService; +import org.springframework.stereotype.Service; +import org.springframework.beans.factory.annotation.Autowired; +import javax.annotation.Resource; +import com.hzya.frame.basedao.service.impl.BaseService; +/** + * 映射信息主表(SysFlowStepConfig)表服务实现类 + * + * @author xiang2lin + * @since 2025-04-29 10:16:28 + */ +@Service(value = "sysFlowStepConfigService") +public class SysFlowStepConfigServiceImpl extends BaseService implements ISysFlowStepConfigService { + + private ISysFlowStepConfigDao sysFlowStepConfigDao; + + @Autowired + public void setSysFlowStepConfigDao(ISysFlowStepConfigDao dao) { + this.sysFlowStepConfigDao = dao; + this.dao = dao; + } +} diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/service/impl/SysFlowStepRelationServiceImpl.java b/base-service/src/main/java/com/hzya/frame/sys/flow/service/impl/SysFlowStepRelationServiceImpl.java new file mode 100644 index 00000000..a34d3d43 --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/service/impl/SysFlowStepRelationServiceImpl.java @@ -0,0 +1,26 @@ +package com.hzya.frame.sys.flow.service.impl; + +import com.hzya.frame.sys.flow.entity.SysFlowStepRelationEntity; +import com.hzya.frame.sys.flow.dao.ISysFlowStepRelationDao; +import com.hzya.frame.sys.flow.service.ISysFlowStepRelationService; +import org.springframework.stereotype.Service; +import org.springframework.beans.factory.annotation.Autowired; +import javax.annotation.Resource; +import com.hzya.frame.basedao.service.impl.BaseService; +/** + * 步骤关联关系表(SysFlowStepRelation)表服务实现类 + * + * @author xiang2lin + * @since 2025-04-29 10:16:28 + */ +@Service(value = "sysFlowStepRelationService") +public class SysFlowStepRelationServiceImpl extends BaseService implements ISysFlowStepRelationService { + + private ISysFlowStepRelationDao sysFlowStepRelationDao; + + @Autowired + public void setSysFlowStepRelationDao(ISysFlowStepRelationDao dao) { + this.sysFlowStepRelationDao = dao; + this.dao = dao; + } +} diff --git a/base-service/src/main/java/com/hzya/frame/sys/flow/service/impl/SysFlowStepServiceImpl.java b/base-service/src/main/java/com/hzya/frame/sys/flow/service/impl/SysFlowStepServiceImpl.java new file mode 100644 index 00000000..0c9a1b29 --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sys/flow/service/impl/SysFlowStepServiceImpl.java @@ -0,0 +1,26 @@ +package com.hzya.frame.sys.flow.service.impl; + +import com.hzya.frame.sys.flow.entity.SysFlowStepEntity; +import com.hzya.frame.sys.flow.dao.ISysFlowStepDao; +import com.hzya.frame.sys.flow.service.ISysFlowStepService; +import org.springframework.stereotype.Service; +import org.springframework.beans.factory.annotation.Autowired; +import javax.annotation.Resource; +import com.hzya.frame.basedao.service.impl.BaseService; +/** + * 流程步骤信息(SysFlowStep)表服务实现类 + * + * @author xiang2lin + * @since 2025-04-29 10:16:27 + */ +@Service(value = "sysFlowStepService") +public class SysFlowStepServiceImpl extends BaseService implements ISysFlowStepService { + + private ISysFlowStepDao sysFlowStepDao; + + @Autowired + public void setSysFlowStepDao(ISysFlowStepDao dao) { + this.sysFlowStepDao = dao; + this.dao = dao; + } +}