feat: update UUID generation to use uuid7 for improved uniqueness across models

Author: liuruibin

apps/application/chat_pipeline/step/chat_step/impl/base_chat_step.py

@@ -9,7 +9,7 @@
 import logging
 import time
 import traceback
-import uuid
+import uuid_utils.compat as uuid
 from typing import List
 
 from django.db.models import QuerySet
@@ -238,7 +238,7 @@ def execute_stream(self, message_list: List[BaseMessage],
                        model_setting=None):
         chat_result, is_ai_chat = self.get_stream_result(message_list, chat_model, paragraph_list,
                                                          no_references_setting, problem_text)
-        chat_record_id = uuid.uuid1()
+        chat_record_id = uuid.uuid7()
         r = StreamingHttpResponse(
             streaming_content=event_content(chat_result, chat_id, chat_record_id, paragraph_list,
                                             post_response_handler, manage, self, chat_model, message_list, problem_text,
@@ -286,7 +286,7 @@ def execute_block(self, message_list: List[BaseMessage],
         reasoning_content_end = model_setting.get('reasoning_content_end', '</think>')
         reasoning = Reasoning(reasoning_content_start,
                               reasoning_content_end)
-        chat_record_id = uuid.uuid1()
+        chat_record_id = uuid.uuid7()
         # 调用模型
         try:
             chat_result, is_ai_chat = self.get_block_result(message_list, chat_model, paragraph_list,

apps/application/migrations/0001_initial.py

@@ -90,7 +90,7 @@ class Migration(migrations.Migration):
             fields=[
                 ('create_time', models.DateTimeField(auto_now_add=True, verbose_name='创建时间')),
                 ('update_time', models.DateTimeField(auto_now=True, verbose_name='修改时间')),
-                ('id', models.UUIDField(default=uuid.uuid1, editable=False, primary_key=True, serialize=False, verbose_name='主键id')),
+                ('id', models.UUIDField(default=uuid_utils.compat.uuid7, editable=False, primary_key=True, serialize=False, verbose_name='主键id')),
                 ('secret_key', models.CharField(max_length=1024, unique=True, verbose_name='秘钥')),
                 ('workspace_id', models.CharField(db_index=True, default='default', max_length=64, verbose_name='工作空间id')),
                 ('is_active', models.BooleanField(default=True, verbose_name='是否开启')),
@@ -162,7 +162,7 @@ class Migration(migrations.Migration):
             fields=[
                 ('create_time', models.DateTimeField(auto_now_add=True, verbose_name='创建时间')),
                 ('update_time', models.DateTimeField(auto_now=True, verbose_name='修改时间')),
-                ('id', models.UUIDField(default=uuid_utils.compat.uuid1, editable=False, primary_key=True, serialize=False, verbose_name='主键id')),
+                ('id', models.UUIDField(default=uuid_utils.compat.uuid7, editable=False, primary_key=True, serialize=False, verbose_name='主键id')),
                 ('vote_status', models.CharField(choices=[('-1', '未投票'), ('0', '赞同'), ('1', '反对')], default='-1', max_length=10, verbose_name='投票')),
                 ('problem_text', models.CharField(max_length=10240, verbose_name='问题')),
                 ('answer_text', models.CharField(max_length=40960, verbose_name='答案')),
@@ -185,7 +185,7 @@ class Migration(migrations.Migration):
             fields=[
                 ('create_time', models.DateTimeField(auto_now_add=True, verbose_name='创建时间')),
                 ('update_time', models.DateTimeField(auto_now=True, verbose_name='修改时间')),
-                ('id', models.UUIDField(default=uuid_utils.compat.uuid1, editable=False, primary_key=True, serialize=False, verbose_name='主键id')),
+                ('id', models.UUIDField(default=uuid_utils.compat.uuid7, editable=False, primary_key=True, serialize=False, verbose_name='主键id')),
                 ('workspace_id', models.CharField(db_index=True, default='default', max_length=64, verbose_name='工作空间id')),
                 ('name', models.CharField(default='', max_length=128, verbose_name='版本名称')),
                 ('publish_user_id', models.UUIDField(default=None, null=True, verbose_name='发布者id')),

apps/application/models/application.py

@@ -120,7 +120,7 @@ class Meta:
 
 
 class WorkFlowVersion(AppModelMixin):
-    id = models.UUIDField(primary_key=True, max_length=128, default=uuid.uuid1, editable=False, verbose_name="主键id")
+    id = models.UUIDField(primary_key=True, max_length=128, default=uuid.uuid7, editable=False, verbose_name="主键id")
     application = models.ForeignKey(Application, on_delete=models.CASCADE)
     workspace_id = models.CharField(max_length=64, verbose_name="工作空间id", default="default", db_index=True)
     name = models.CharField(verbose_name="版本名称", max_length=128, default="")

apps/application/models/application_api_key.py

@@ -1,4 +1,4 @@
-import uuid
+import uuid_utils.compat as uuid
 
 from django.contrib.postgres.fields import ArrayField
 from django.db import models
@@ -9,7 +9,7 @@
 
 
 class ApplicationApiKey(AppModelMixin):
-    id = models.UUIDField(primary_key=True, max_length=128, default=uuid.uuid1, editable=False, verbose_name="主键id")
+    id = models.UUIDField(primary_key=True, max_length=128, default=uuid.uuid7, editable=False, verbose_name="主键id")
     secret_key = models.CharField(max_length=1024, verbose_name="秘钥", unique=True)
     user = models.ForeignKey(User, on_delete=models.CASCADE, verbose_name="用户id")
     workspace_id = models.CharField(max_length=64, verbose_name="工作空间id", default="default", db_index=True)

apps/application/models/application_chat.py

@@ -48,7 +48,7 @@ class ChatRecord(AppModelMixin):
     """
     对话日志 详情
     """
-    id = models.UUIDField(primary_key=True, max_length=128, default=uuid.uuid1, editable=False, verbose_name="主键id")
+    id = models.UUIDField(primary_key=True, max_length=128, default=uuid.uuid7, editable=False, verbose_name="主键id")
     chat = models.ForeignKey(Chat, on_delete=models.CASCADE)
     vote_status = models.CharField(verbose_name='投票', max_length=10, choices=VoteChoices.choices,
                                    default=VoteChoices.UN_VOTE)

apps/application/serializers/application.py

@@ -246,7 +246,7 @@ def is_valid(self, *, user_id=None, raise_exception=False):
 
         @staticmethod
         def to_application_model(user_id: str, application: Dict):
-            return Application(id=uuid.uuid1(), name=application.get('name'), desc=application.get('desc'),
+            return Application(id=uuid.uuid7(), name=application.get('name'), desc=application.get('desc'),
                                prologue=application.get('prologue'),
                                dialogue_number=application.get('dialogue_number', 0),
                                user_id=user_id, model_id=application.get('model_id'),
@@ -429,12 +429,12 @@ def insert_workflow(self, instance: Dict):
         application_model.save()
         # 插入认证信息
         ApplicationAccessToken(application_id=application_model.id,
-                               access_token=hashlib.md5(str(uuid.uuid1()).encode()).hexdigest()[8:24]).save()
+                               access_token=hashlib.md5(str(uuid.uuid7()).encode()).hexdigest()[8:24]).save()
         return ApplicationCreateSerializer.ApplicationResponse(application_model).data
 
     @staticmethod
     def to_application_knowledge_mapping(application_id: str, dataset_id: str):
-        return ApplicationKnowledgeMapping(id=uuid.uuid1(), application_id=application_id, dataset_id=dataset_id)
+        return ApplicationKnowledgeMapping(id=uuid.uuid7(), application_id=application_id, dataset_id=dataset_id)
 
     def insert_simple(self, instance: Dict):
         self.is_valid(raise_exception=True)
@@ -449,7 +449,7 @@ def insert_simple(self, instance: Dict):
         application_model.save()
         # 插入认证信息
         ApplicationAccessToken(application_id=application_model.id,
-                               access_token=hashlib.md5(str(uuid.uuid1()).encode()).hexdigest()[8:24]).save()
+                               access_token=hashlib.md5(str(uuid.uuid7()).encode()).hexdigest()[8:24]).save()
         # 插入关联数据
         QuerySet(ApplicationKnowledgeMapping).bulk_create(application_knowledge_mapping_model_list)
         return ApplicationCreateSerializer.ApplicationResponse(application_model).data
@@ -484,7 +484,7 @@ def import_(self, instance: dict, with_valid=True):
         application_model.save()
         # 插入认证信息
         ApplicationAccessToken(application_id=application_model.id,
-                               access_token=hashlib.md5(str(uuid.uuid1()).encode()).hexdigest()[8:24]).save()
+                               access_token=hashlib.md5(str(uuid.uuid7()).encode()).hexdigest()[8:24]).save()
         QuerySet(Tool).bulk_create(tool_model_list) if len(tool_model_list) > 0 else None
         return True
 
@@ -511,7 +511,7 @@ def to_application(application, workspace_id, user_id):
         for node in work_flow.get('nodes', []):
             if node.get('type') == 'search-dataset-node':
                 node.get('properties', {}).get('node_data', {})['dataset_id_list'] = []
-        return Application(id=uuid.uuid1(),
+        return Application(id=uuid.uuid7(),
                            user_id=user_id,
                            name=application.get('name'),
                            workspace_id=workspace_id,

apps/application/serializers/application_access_token.py

@@ -7,7 +7,7 @@
     @desc:
 """
 import hashlib
-import uuid
+import uuid_utils.compat as uuid
 
 from django.core.cache import cache
 from django.db.models import QuerySet
@@ -53,7 +53,7 @@ def edit(self, instance):
         if 'is_active' in instance:
             application_access_token.is_active = instance.get("is_active")
         if 'access_token_reset' in instance and instance.get('access_token_reset'):
-            application_access_token.access_token = hashlib.md5(str(uuid.uuid1()).encode()).hexdigest()[8:24]
+            application_access_token.access_token = hashlib.md5(str(uuid.uuid7()).encode()).hexdigest()[8:24]
         if 'access_num' in instance and instance.get('access_num') is not None:
             application_access_token.access_num = instance.get("access_num")
         if 'white_active' in instance and instance.get('white_active') is not None:
@@ -91,7 +91,7 @@ def one(self, with_valid=True):
         if application_access_token is None:
             application_access_token = ApplicationAccessToken(application_id=application_id,
                                                               access_token=hashlib.md5(
-                                                                  str(uuid.uuid1()).encode()).hexdigest()[
+                                                                  str(uuid.uuid7()).encode()).hexdigest()[
                                                                            8:24], is_active=True)
             application_access_token.save()
         application_setting_model = DatabaseModelManage.get_model('application_setting')

apps/application/serializers/application_api_key.py

@@ -45,8 +45,8 @@ def generate(self, with_valid=True):
             self.is_valid(raise_exception=True)
         application_id = self.data.get("application_id")
         application = QuerySet(Application).filter(id=application_id).first()
-        secret_key = 'application-' + hashlib.md5(str(uuid.uuid1()).encode()).hexdigest()
-        application_api_key = ApplicationApiKey(id=uuid.uuid1(),
+        secret_key = 'application-' + hashlib.md5(str(uuid.uuid7()).encode()).hexdigest()
+        application_api_key = ApplicationApiKey(id=uuid.uuid7(),
                                                 secret_key=secret_key,
                                                 user_id=application.user_id,
                                                 application_id=application_id)

apps/application/serializers/application_chat_record.py

@@ -6,7 +6,7 @@
     @date：2025/6/10 15:10
     @desc:
 """
-import uuid
+import uuid_utils.compat as uuid
 from functools import reduce
 from typing import Dict
 
@@ -208,15 +208,15 @@ def post_improve(self, instance: Dict):
         problem_paragraph_mappings = []
         for chat_record in chat_record_list:
             paragraph = Paragraph(
-                id=uuid.uuid1(),
+                id=uuid.uuid7(),
                 document_id=document_id,
                 content=chat_record.answer_text,
                 knowledge_id=knowledge_id,
                 title=chat_record.problem_text
             )
             problem, _ = Problem.objects.get_or_create(content=chat_record.problem_text, knowledge_id=knowledge_id)
             problem_paragraph_mapping = ProblemParagraphMapping(
-                id=uuid.uuid1(),
+                id=uuid.uuid7(),
                 knowledge_id=knowledge_id,
                 document_id=document_id,
                 problem_id=problem.id,
@@ -284,7 +284,7 @@ def improve(self, instance: Dict, with_valid=True):
             max_position=Max('position')
         )['max_position'] or 0
         paragraph = Paragraph(
-            id=uuid.uuid1(),
+            id=uuid.uuid7(),
             document_id=document_id,
             content=instance.get("content"),
             knowledge_id=knowledge_id,
@@ -294,7 +294,7 @@ def improve(self, instance: Dict, with_valid=True):
         problem_text = instance.get('problem_text') if instance.get(
             'problem_text') is not None else chat_record.problem_text
         problem, _ = QuerySet(Problem).get_or_create(content=problem_text, knowledge_id=knowledge_id)
-        problem_paragraph_mapping = ProblemParagraphMapping(id=uuid.uuid1(), knowledge_id=knowledge_id,
+        problem_paragraph_mapping = ProblemParagraphMapping(id=uuid.uuid7(), knowledge_id=knowledge_id,
                                                             document_id=document_id,
                                                             problem_id=problem.id,
                                                             paragraph_id=paragraph.id)

apps/application/views/application_chat.py

@@ -6,7 +6,7 @@
     @date：2025/6/10 11:00
     @desc:
 """
-import uuid
+import uuid_utils.compat as uuid
 
 from django.utils.translation import gettext_lazy as _
 from drf_spectacular.utils import extend_schema
@@ -114,7 +114,7 @@ class OpenView(APIView):
     def get(self, request: Request, workspace_id: str, application_id: str):
         return result.success(OpenChatSerializers(
             data={'workspace_id': workspace_id, 'application_id': application_id,
-                  'chat_user_id': str(uuid.uuid1()), 'chat_user_type': ChatUserType.ANONYMOUS_USER,
+                  'chat_user_id': str(uuid.uuid7()), 'chat_user_type': ChatUserType.ANONYMOUS_USER,
                   'debug': True}).open())