From 1220f5ca98b10b735a47c37a81fbfc554b01e2fe Mon Sep 17 00:00:00 2001
From: liriming <1343021927@qq.com>
Date: 星期一, 20 一月 2025 14:41:35 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'
---
src/components/SimpleProcessDesignerV2/src/SimpleProcessDesigner.vue | 306 +++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 306 insertions(+), 0 deletions(-)
diff --git a/src/components/SimpleProcessDesignerV2/src/SimpleProcessDesigner.vue b/src/components/SimpleProcessDesignerV2/src/SimpleProcessDesigner.vue
new file mode 100644
index 0000000..22e6073
--- /dev/null
+++ b/src/components/SimpleProcessDesignerV2/src/SimpleProcessDesigner.vue
@@ -0,0 +1,306 @@
+<template>
+ <div v-loading="loading" class="overflow-auto">
+ <SimpleProcessModel
+ ref="simpleProcessModelRef"
+ v-if="processNodeTree"
+ :flow-node="processNodeTree"
+ :readonly="false"
+ @save="saveSimpleFlowModel"
+ />
+ <Dialog v-model="errorDialogVisible" title="保存失败" width="400" :fullscreen="false">
+ <div class="mb-2">以下节点内容不完善，请修改后保存</div>
+ <div
+ class="mb-3 b-rounded-1 bg-gray-100 p-2 line-height-normal"
+ v-for="(item, index) in errorNodes"
+ :key="index"
+ >
+ {{ item.name }} : {{ NODE_DEFAULT_TEXT.get(item.type) }}
+ </div>
+ <template #footer>
+ <el-button type="primary" @click="errorDialogVisible = false">知道了</el-button>
+ </template>
+ </Dialog>
+ </div>
+</template>
+
+<script setup lang="ts">
+import SimpleProcessModel from './SimpleProcessModel.vue'
+import { updateBpmSimpleModel, getBpmSimpleModel } from '@/api/bpm/simple'
+import { SimpleFlowNode, NodeType, NodeId, NODE_DEFAULT_TEXT } from './consts'
+import { getModel } from '@/api/bpm/model'
+import { getForm, FormVO } from '@/api/bpm/form'
+import { handleTree } from '@/utils/tree'
+import * as RoleApi from '@/api/system/role'
+import * as DeptApi from '@/api/system/dept'
+import * as PostApi from '@/api/system/post'
+import * as UserApi from '@/api/system/user'
+import * as UserGroupApi from '@/api/bpm/userGroup'
+
+defineOptions({
+ name: 'SimpleProcessDesigner'
+})
+
+const emits = defineEmits(['success', 'init-finished']) // 保存成功事件
+
+const props = defineProps({
+ modelId: {
+ type: String,
+ required: false
+ },
+ modelKey: {
+ type: String,
+ required: false
+ },
+ modelName: {
+ type: String,
+ required: false
+ },
+ // 可发起流程的人员编号
+ startUserIds : {
+ type: Array,
+ required: false
+ },
+ value: {
+ type: [String, Object],
+ required: false
+ }
+})
+
+const loading = ref(false)
+const formFields = ref<string[]>([])
+const formType = ref(20)
+const roleOptions = ref<RoleApi.RoleVO[]>([]) // 角色列表
+const postOptions = ref<PostApi.PostVO[]>([]) // 岗位列表
+const userOptions = ref<UserApi.UserVO[]>([]) // 用户列表
+const deptOptions = ref<DeptApi.DeptVO[]>([]) // 部门列表
+const deptTreeOptions = ref()
+const userGroupOptions = ref<UserGroupApi.UserGroupVO[]>([]) // 用户组列表
+
+// 添加当前值的引用
+const currentValue = ref<SimpleFlowNode | undefined>()
+
+provide('formFields', formFields)
+provide('formType', formType)
+provide('roleList', roleOptions)
+provide('postList', postOptions)
+provide('userList', userOptions)
+provide('deptList', deptOptions)
+provide('userGroupList', userGroupOptions)
+provide('deptTree', deptTreeOptions)
+provide('startUserIds', props.startUserIds)
+
+const message = useMessage() // 国际化
+const processNodeTree = ref<SimpleFlowNode | undefined>()
+const errorDialogVisible = ref(false)
+let errorNodes: SimpleFlowNode[] = []
+
+// 添加更新模型的方法
+const updateModel = () => {
+ if (!processNodeTree.value) {
+ processNodeTree.value = {
+ name: '发起人',
+ type: NodeType.START_USER_NODE,
+ id: NodeId.START_USER_NODE_ID,
+ childNode: {
+ id: NodeId.END_EVENT_NODE_ID,
+ name: '结束',
+ type: NodeType.END_EVENT_NODE
+ }
+ }
+ // 初始化时也触发一次保存
+ saveSimpleFlowModel(processNodeTree.value)
+ }
+}
+
+// 加载流程数据
+const loadProcessData = async (data: any) => {
+ try {
+ if (data) {
+ const parsedData = typeof data === 'string' ? JSON.parse(data) : data
+ processNodeTree.value = parsedData
+ currentValue.value = parsedData
+ // 确保数据加载后刷新视图
+ await nextTick()
+ if (simpleProcessModelRef.value?.refresh) {
+ await simpleProcessModelRef.value.refresh()
+ }
+ }
+ } catch (error) {
+ console.error('加载流程数据失败:', error)
+ }
+}
+
+// 监听属性变化
+watch(
+ () => props.value,
+ async (newValue, oldValue) => {
+ if (newValue && newValue !== oldValue) {
+ await loadProcessData(newValue)
+ }
+ },
+ { immediate: true, deep: true }
+)
+
+// 监听流程节点树变化，自动保存
+watch(
+ () => processNodeTree.value,
+ async (newValue, oldValue) => {
+ if (newValue && oldValue && JSON.stringify(newValue) !== JSON.stringify(oldValue)) {
+ await saveSimpleFlowModel(newValue)
+ }
+ },
+ { deep: true }
+)
+
+const saveSimpleFlowModel = async (simpleModelNode: SimpleFlowNode) => {
+ if (!simpleModelNode) {
+ return
+ }
+
+ // 校验节点
+ errorNodes = []
+ validateNode(simpleModelNode, errorNodes)
+ if (errorNodes.length > 0) {
+ errorDialogVisible.value = true
+ return
+ }
+
+ try {
+ if (props.modelId) {
+ // 编辑模式
+ const data = {
+ id: props.modelId,
+ simpleModel: simpleModelNode
+ }
+ await updateBpmSimpleModel(data)
+ }
+ // 无论是编辑还是新建模式，都更新当前值并触发事件
+ currentValue.value = simpleModelNode
+ emits('success', simpleModelNode)
+ } catch (error) {
+ console.error('保存失败:', error)
+ }
+}
+
+// 校验节点设置。 暂时以 showText 为空 未节点错误配置
+const validateNode = (node: SimpleFlowNode | undefined, errorNodes: SimpleFlowNode[]) => {
+ if (node) {
+ const { type, showText, conditionNodes } = node
+ if (type == NodeType.END_EVENT_NODE) {
+ return
+ }
+ if (type == NodeType.START_USER_NODE) {
+ // 发起人节点暂时不用校验，直接校验孩子节点
+ validateNode(node.childNode, errorNodes)
+ }
+
+ if (
+ type === NodeType.USER_TASK_NODE ||
+ type === NodeType.COPY_TASK_NODE ||
+ type === NodeType.CONDITION_NODE
+ ) {
+ if (!showText) {
+ errorNodes.push(node)
+ }
+ validateNode(node.childNode, errorNodes)
+ }
+
+ if (
+ type == NodeType.CONDITION_BRANCH_NODE ||
+ type == NodeType.PARALLEL_BRANCH_NODE ||
+ type == NodeType.INCLUSIVE_BRANCH_NODE
+ ) {
+ // 分支节点
+ // 1. 先校验各个分支
+ conditionNodes?.forEach((item) => {
+ validateNode(item, errorNodes)
+ })
+ // 2. 校验孩子节点
+ validateNode(node.childNode, errorNodes)
+ }
+ }
+}
+
+onMounted(async () => {
+ try {
+ loading.value = true
+ // 获取表单字段
+ if (props.modelId) {
+ const bpmnModel = await getModel(props.modelId)
+ if (bpmnModel) {
+ formType.value = bpmnModel.formType
+ if (formType.value === 10) {
+ const bpmnForm = (await getForm(bpmnModel.formId)) as unknown as FormVO
+ formFields.value = bpmnForm?.fields
+ }
+ }
+ }
+ // 获得角色列表
+ roleOptions.value = await RoleApi.getSimpleRoleList()
+ // 获得岗位列表
+ postOptions.value = await PostApi.getSimplePostList()
+ // 获得用户列表
+ userOptions.value = await UserApi.getSimpleUserList()
+ // 获得部门列表
+ deptOptions.value = await DeptApi.getSimpleDeptList()
+ deptTreeOptions.value = handleTree(deptOptions.value as DeptApi.DeptVO[], 'id')
+ // 获取用户组列表
+ userGroupOptions.value = await UserGroupApi.getUserGroupSimpleList()
+
+ // 加载流程数据
+ if (props.modelId) {
+ // 获取 SIMPLE 设计器模型
+ const result = await getBpmSimpleModel(props.modelId)
+ if (result) {
+ await loadProcessData(result)
+ } else {
+ updateModel()
+ }
+ } else if (props.value) {
+ await loadProcessData(props.value)
+ } else {
+ updateModel()
+ }
+ } finally {
+ loading.value = false
+ emits('init-finished')
+ }
+})
+
+const simpleProcessModelRef = ref()
+
+/** 获取当前流程数据 */
+const getCurrentFlowData = async () => {
+ try {
+ if (simpleProcessModelRef.value) {
+ const data = await simpleProcessModelRef.value.getCurrentFlowData()
+ if (data) {
+ currentValue.value = data
+ return data
+ }
+ }
+ return currentValue.value
+ } catch (error) {
+ console.error('获取流程数据失败:', error)
+ return currentValue.value
+ }
+}
+
+// 刷新方法
+const refresh = async () => {
+ try {
+ if (currentValue.value) {
+ await loadProcessData(currentValue.value)
+ }
+ } catch (error) {
+ console.error('刷新失败:', error)
+ }
+}
+
+defineExpose({
+ getCurrentFlowData,
+ updateModel,
+ loadProcessData,
+ refresh
+})
+</script>
--
Gitblit v1.9.3