fix: replace uuid.uuid4() with getID() from appPublic.uniqueID for all table ID generation

This commit is contained in:
yumoqing 2026-05-08 15:47:24 +08:00
parent 843ec0cc24
commit d0b588d82c

View File

@ -2,6 +2,7 @@ from ahserver.serverenv import ServerEnv
from appPublic.worker import awaitify from appPublic.worker import awaitify
import json import json
import uuid import uuid
from appPublic.uniqueID import getID
from datetime import datetime, timedelta from datetime import datetime, timedelta
class WorkflowCore: class WorkflowCore:
@ -10,7 +11,7 @@ class WorkflowCore:
async def create_workflow(self, workflow_data, org_id): async def create_workflow(self, workflow_data, org_id):
"""创建审批工作流""" """创建审批工作流"""
workflow_id = str(uuid.uuid4()).replace('-', '') workflow_id = getID()
workflow_data['id'] = workflow_id workflow_data['id'] = workflow_id
workflow_data['org_id'] = org_id workflow_data['org_id'] = org_id
workflow_data['created_at'] = datetime.now() workflow_data['created_at'] = datetime.now()
@ -22,7 +23,7 @@ class WorkflowCore:
async def create_approval_step(self, step_data, org_id): async def create_approval_step(self, step_data, org_id):
"""创建审批步骤""" """创建审批步骤"""
step_id = str(uuid.uuid4()).replace('-', '') step_id = getID()
step_data['id'] = step_id step_data['id'] = step_id
step_data['org_id'] = org_id step_data['org_id'] = org_id
@ -41,7 +42,7 @@ class WorkflowCore:
# 使用第一个匹配的工作流(实际可按条件筛选) # 使用第一个匹配的工作流(实际可按条件筛选)
workflow = workflows[0] workflow = workflows[0]
instance_id = str(uuid.uuid4()).replace('-', '') instance_id = getID()
instance_data = { instance_data = {
'id': instance_id, 'id': instance_id,
@ -117,7 +118,7 @@ class WorkflowCore:
# 创建审批任务 # 创建审批任务
for approver_id in approvers: for approver_id in approvers:
task_id = str(uuid.uuid4()).replace('-', '') task_id = getID()
due_at = None due_at = None
if current_step.get('timeout_hours'): if current_step.get('timeout_hours'):
due_at = datetime.now() + timedelta(hours=current_step['timeout_hours']) due_at = datetime.now() + timedelta(hours=current_step['timeout_hours'])