1
我正在尝试开发一种拍卖类型系统，客户在此下订单，然后不同的商店可以为该订单提供价格。在渠道中使用django信号消费者类别
这个系统的一个有趣的部分是，当订单最初创建时，可用商店将有60秒来提出他们各自的报价。当第一家商店提供报价时，“拍卖”现在只有其他商店的20秒才能提出自己的报价。如果他们确实提出了另一个要约，在这个较小的分配时间内，那么这20秒就会刷新。只要有足够的时间，优惠可以继续收到，但不能超过60秒。
class Order(models.Model):
customer = models.ForeignKey(Customer)
create_time = models.DateTimeField(auto_now_add=True)
update_time = models.DateTimeField(auto_now_add=True)
total = models.FloatField(default=0)
status = models.IntegerField(default=0)
delivery_address = models.ForeignKey(DeliveryAddress)
store = models.ForeignKey(Store, null=True, blank=True, related_name='orders', on_delete=models.CASCADE)
credit_card = models.ForeignKey(CreditCard, null=True, blank=True, related_name='orders')
class OrderOffer(models.Model):
store = models.ForeignKey(Store, related_name="offers", on_delete=models.CASCADE)
order = models.ForeignKey(Order, related_name="offers", on_delete=models.CASCADE)
create_time = models.DateTimeField(auto_now_add=True)
除了这些要求，我还希望在新优惠实时到达时更新客户端。为此，我使用django-channels实现WebSockets。
我有以下consumers.py文件：
from channels.generic.websockets import WebsocketConsumer
from threading import Timer
from api.models import Order, OrderOffer
from django.db.models.signals import post_save
from django.dispatch import receiver
class OrderConsumer(WebsocketConsumer):
def connect(self, message, **kwargs):
"""
Initialize objects here.
"""
order_id = int(kwargs['order_id'])
self.order = Order.objects.get(id=order_id)
self.timer = Timer(60, self.sendDone)
self.timer.start()
self.message.reply_channel.send({"accept": True})
def sendDone(self):
self.send(text="Done")
# How do I bind self to onOffer?
@receiver(post_save, sender=OrderOffer)
def onOffer(self, sender, **kwargs):
self.send(text="Offer received!")
if (len(self.offers) == 0):
self.offerTimer = Timer(20, self.sendDone)
self.offers = [kwargs['instance'],]
else:
self.offerTimer = Timer(20, self.sendDone)
self.offers.append(kwargs['instance'])
def receive(self, text=None, bytes=None, **kwargs):
# Echo
self.send(text=text, bytes=bytes)
def disconnect(self, message, **kwargs):
"""
Perform necessary disconnect operations.
"""
pass
我已经成功地得以我的客户端和服务器之间建立WebSocket的通信信道。我测试过发送消息，一切似乎都没问题。现在我想检测新的OrderOffer的创建，并向客户端发送通知。为此，我需要访问self变量，使用self.send，这是不可能的，因为信号修饰器不发送此参数。我试着用自我声明onOffer迫使它，但我得到了以下错误：
TypeError: onOffer() missing 1 required positional argument: 'self'
如果我能以某种方式使用关键字参数，即信号台，我可能会做这样的事情： context = self 。
我将不胜感激任何帮助，甚至对我原来的问题的替代解决方案。