在Django中如何用一个Model的值优雅更新另一个Model？

现有如下Django模型定义：

class Trade(models.Model):
    pips = models.FloatField(default=0)
    direction = models.CharField(max_length=30)
    new_balance = models.FloatField(default=0.0)
    # 省略其他字段...

class Summary(models.Model):
    winning_trades = models.IntegerField(default=0)
    account_balance = models.FloatField(default=0.0)
    # 省略其他字段...

当用户发送POST请求创建Trade记录后，需要自动更新Summary模型数据并返回更新后的Summary数据，请问如何优雅实现该功能？

优雅实现方案 #

1. 用Django信号解耦业务逻辑 #

信号能让Trade创建与Summary更新的逻辑完全分离，符合单一职责原则，避免视图代码臃肿。

步骤1：编写信号处理函数

在app目录下创建signals.py，写入处理逻辑：

from django.db.models.signals import post_save
from django.dispatch import receiver
from .models import Trade, Summary

@receiver(post_save, sender=Trade)
def update_summary_after_trade(sender, instance, created, **kwargs):
    # 仅在创建新Trade记录时触发更新
    if not created:
        return
    
    # 获取系统唯一的汇总记录（根据业务场景调整，比如按用户关联）
    summary, _ = Summary.objects.get_or_create(pk=1)
    
    # 判断是否为盈利交易（此处以pips>0为判断标准，可根据业务修改）
    if instance.pips > 0:
        summary.winning_trades += 1
    
    # 更新账户余额为Trade记录的最新余额
    summary.account_balance = instance.new_balance
    summary.save()

步骤2：注册信号

修改app目录下的apps.py，在ready方法中导入信号：

from django.apps import AppConfig

class YourAppConfig(AppConfig):
    default_auto_field = 'django.db.models.BigAutoField'
    name = 'your_app_name'

    def ready(self):
        import your_app_name.signals

然后在项目settings.py的INSTALLED_APPS中替换原app配置：

INSTALLED_APPS = [
    # ...
    'your_app_name.apps.YourAppConfig',
    # ...
]

2. 用数据库事务保证数据一致性 #

为避免Trade创建成功但Summary更新失败的异常情况，在视图中用事务包裹操作：

from django.db import transaction
from django.http import JsonResponse
from .models import Trade, Summary
from .serializers import TradeSerializer, SummarySerializer

def create_trade(request):
    if request.method == 'POST':
        serializer = TradeSerializer(data=request.data)
        if serializer.is_valid():
            with transaction.atomic():
                trade = serializer.save()
                # 复用更新逻辑（可直接调用信号中的处理函数，或封装为公共方法）
                summary, _ = Summary.objects.get_or_create(pk=1)
                if trade.pips > 0:
                    summary.winning_trades += 1
                summary.account_balance = trade.new_balance
                summary.save()
            
            # 序列化并返回更新后的Summary数据
            summary_serializer = SummarySerializer(summary)
            return JsonResponse(summary_serializer.data, status=201)
        return JsonResponse(serializer.errors, status=400)

3. 封装更新逻辑为模型方法（可选） #

若Summary的更新规则复杂，可将逻辑封装为模型方法，提升代码可读性：

class Summary(models.Model):
    winning_trades = models.IntegerField(default=0)
    account_balance = models.FloatField(default=0.0)

    def update_from_trade(self, trade):
        """根据Trade记录更新汇总数据"""
        if trade.pips > 0:
            self.winning_trades += 1
        self.account_balance = trade.new_balance
        self.save()

之后在信号或视图中直接调用：

summary.update_from_trade(trade)

4. 序列化返回Summary数据 #

使用Django REST Framework的序列化器处理数据返回：

from rest_framework import serializers
from .models import Summary

class SummarySerializer(serializers.ModelSerializer):
    class Meta:
        model = Summary
        fields = ['winning_trades', 'account_balance']

内容的提问来源于stack exchange，提问作者tanjona Randrianasolo