通过Django Admin导入JSON文件至数据模型的字段匹配问题

看起来你当前的递归函数在处理嵌套JSON时，没有正确追踪数据层级、匹配关联模型，也没有完成实际的模型实例创建操作。我来帮你重构这个逻辑，实现从嵌套JSON到Django多模型的数据导入。

核心思路 #

1. 基于Relacion模型映射字段：通过origen（JSON字段名）匹配destino（模型字段名）和modelo（目标模型），明确每个JSON字段要导入到哪个模型的哪个字段。
2. 递归遍历JSON时追踪上下文：处理嵌套结构时，记录当前正在处理的父模型实例（比如Product和它的References、Feature是关联关系），方便后续设置外键。
3. 动态操作Django模型：用Django的apps.get_model根据modelo字符串获取对应的模型类，实现动态创建/更新实例。

实现代码 #

首先，假设你的目标模型（比如Product、Reference、Feature）已经定义，并且包含必要的外键关联（比如Product和Reference之间有外键）。以下是完整的导入逻辑：

from django.apps import apps
import json
from django.contrib import messages

def procesar_json(obj, relaciones, parent_instance=None, parent_model=None):
    """
    递归遍历JSON，根据Relacion映射导入数据到对应模型
    :param obj: 当前处理的JSON对象（dict或list）
    :param relaciones: 当前Entidad对应的Relacion查询集
    :param parent_instance: 父模型实例（用于设置外键）
    :param parent_model: 父模型类（用于匹配关联的子模型）
    """
    if isinstance(obj, list):
        for item in obj:
            procesar_json(item, relaciones, parent_instance, parent_model)
        return
    
    # 处理单个JSON对象（dict）
    instance_data = {}
    current_model = None
    
    # 先找到当前JSON对象对应的目标模型
    for k, v in obj.items():
        rel = relaciones.filter(origen=k).first()
        if rel:
            current_model = apps.get_model('你的应用名', rel.modelo)
            break
    
    if not current_model:
        # 如果当前对象没有匹配的模型，继续递归处理子字段
        for k, v in obj.items():
            if isinstance(v, (dict, list)):
                procesar_json(v, relaciones, parent_instance, parent_model)
        return
    
    # 收集当前模型的字段值
    for k, v in obj.items():
        rel = relaciones.filter(origen=k, modelo=current_model.__name__).first()
        if rel:
            instance_data[rel.destino] = v
        # 递归处理嵌套的子对象（比如Product下的References）
        elif isinstance(v, (dict, list)):
            # 先创建当前实例，再处理子对象的外键
            if instance_data and not parent_instance:
                current_instance = current_model.objects.create(**instance_data)
                procesar_json(v, relaciones, current_instance, current_model)
            else:
                procesar_json(v, relaciones, parent_instance, parent_model)
    
    # 创建当前模型实例（如果有收集到数据且还未创建）
    if instance_data and not parent_instance:
        current_model.objects.create(**instance_data)
    # 如果是子对象，设置外键后创建
    elif instance_data and parent_instance and parent_model:
        # 假设子模型有指向父模型的外键字段，比如product = models.ForeignKey(Product, ...)
        # 这里需要你根据实际模型调整外键字段名，或者在Relacion中增加外键映射
        instance_data[f'{parent_model.__name__.lower()}'] = parent_instance
        current_model.objects.create(**instance_data)

def importa(data, relaciones):
    # 从JSON的root开始遍历，这里根据你的JSON结构调整入口
    procesar_json(data['root'], relaciones)

然后修改Admin中的importar_datos方法：

def importar_datos(self, request, queryset):
    imported_count = 0
    for entidad in queryset:
        try:
            with open(entidad.archivo.path, 'r', encoding='utf-8') as f:
                data = json.load(f)
                importa(data, entidad.relaciones.all())
            imported_count += 1
        except Exception as e:
            self.message_user(request, f"导入{entidad.nombre}失败: {str(e)}", level=messages.ERROR)
    self.message_user(request, f"成功导入{imported_count}个实体的数据")
importar_datos.short_description = "Importar datos seleccionado(s)"

关键说明 #

1. 模型关联处理：代码中假设子模型的外键字段名是父模型名的小写（比如Product的子模型Reference有product外键），如果你的模型外键字段名不同，可以在Relacion模型中新增一个parent_field字段来指定，或者手动调整代码中的外键字段名。
2. JSON入口调整：importa函数中从data['root']开始遍历，你可以根据实际JSON结构修改这个入口（比如直接从data['root']['Products']开始）。
3. 错误处理：增加了异常捕获，方便在Admin中提示导入失败的原因。
4. Relacion配置：确保你在Admin中为每个Entidad配置正确的Relacion，比如：
   • 对于JSON中的id字段（Product的id），origen设为id，destino设为模型的id（或对应字段），modelo设为Product。
   • 对于RefCode字段，origen设为RefCode，destino设为ref_code，modelo设为Reference。

内容的提问来源于stack exchange，提问作者Diego Peñalver Montero