x

src/services/storage_integration_rustfs.py

@@ -49,6 +49,7 @@ class StorageIntegrationService:
         batch_id = upload_batch or str(uuid.uuid4())
 
         # 2. 创建新PostgreSQL记录（每次上传都创建新记录）
+        from datetime import datetime
         stp_file = STPFile(
             user_id=user_id,
             object_key=upload_result['object_key'],
@@ -58,7 +59,8 @@ class StorageIntegrationService:
             file_hash=file_hash,
             upload_batch=batch_id,
             status="uploaded",
-            file_path=str(file_path)
+            file_path=str(file_path),
+            upload_time=datetime.now()
         )
 
         session.add(stp_file)
@@ -571,7 +573,7 @@ class StorageIntegrationService:
                 'id': f.id,
                 'task_id': f.processing_tasks[0].task_id if f.processing_tasks else None,
                 'upload_batch': f.upload_batch,
-                'upload_time': f.upload_time.isoformat() if f.upload_time else None,
+                'upload_time': f.upload_time.strftime('%Y-%m-%d %H:%M:%S') if f.upload_time else None,
                 'file_size': f.file_size,
                 'status': f.status,
                 'volume': f.volume,
@@ -644,7 +646,7 @@ class StorageIntegrationService:
                 'filename': f.original_filename,
                 'latest_id': f.id,
                 'latest_task_id': task_id,
-                'latest_upload_time': f.upload_time.isoformat() if f.upload_time else None,
+                'latest_upload_time': f.upload_time.strftime('%Y-%m-%d %H:%M:%S') if f.upload_time else None,
                 'latest_status': f.status,
                 'upload_count': upload_count,
                 'file_size': f.file_size,