排行问题

实现的方式： 采用Redis(缓存服务)的自增方法

自增的方法： rd.incre(key, amount)

人气排行

说明： 统计某一商品或产品的评论人数

人气：

• 关注（收藏）的人数
• 评论

实现： Django中QuerySet统计函数。

在从的模型类（多端）中：

class Bookrack(models.Model):bookrack_id = models.IntegerField(primary_key=True)# racks 建议外键关联时，动态向Book实例添加一个QuerySet的属性book = models.ForeignKey(Book, models.DO_NOTHING,'racks', blank=True, null=True)

在主的模型类（一端）中：

class Book(models.Model):book_id = models.IntegerField(primary_key=True)# ...@propertydef star(self):# QuerySet:  count(), filer(xx=x).exists()# 统计人气： 加入书架的数量return self.racks.count()

在序列化类中：

class BookSerializer(serializers.ModelSerializer):category = BookCategorySerializer(many=False)class Meta:model = Bookfields = ('book_id', 'category', 'star')

在View视图中：

class BookView(APIView):def get(self, request):# 查询所有产品（小说）page = int(request.query_params.get('page', 1))paginator = Paginator(Book.objects.all(), 10)pager = paginator.page(page)  # 获取第几页s = BookSerializer(pager.object_list, many=True)return Response({'code': 0,'pages': paginator.num_pages,'page': page,'data': s.data})

【扩展】统计订单详情中的某一个商品的总数量

class Goods(models.Model):name = models.CharField(max_length=20)price = models.FloatField(verbose_name='单价')@propertydef star(self):# 查询当前商品的总销量ret = OrderDetail.objects.filter(goods_id=self.pk).aggregate(Sum('cnt'))return ret['cnt__sum']class Order(models.Model):title = models.CharField(max_length=20)price = models.FloatField(verbose_name='总价')user = models.ForeignKey('AppUser', models.SET_NULL, null=True, blank=True)...class OrderDetail(models.Model):order = models.ForeignKey('Order', models.SET_NULL, 'order_details', null=True, blank=True)goods = models.ForeignKey('Goods', models.SET_NULL, 'order_details', null=True, blank=True)cnt = models.IntegerField(verbose='数量')

查询 商品ID为 9 的人气（总销量）:

from django.db.models import Max, Min, Sumret = OrderDetail.objects.filter(goods_id=9).aggregate(a=Sum('cnt'), b=Max('cnt'))# {'cnt__sum': 1000, 'cnt__max': 90}
print(ret) # {'a': 1000,  'b': 90}

点击排行

说明： 统计某一商品或产品的点击的次数

总排行

说明： 统计某一商品的所有点击次数

涉及的方法：

• redis的hincrby(‘total_rank’, book_id)
• 模型QuerySet的in_bulk(id_list) 批量查询， 返回dict {id: , …}
• sorted(list, key=lambda item: item[1], reverse=True) 排序方法

redis缓存的设计：

def rank(book_id):# 总排行rd.hincrby('total_rank', book_id)def get_total_rank_topn(n):ranks = rd.hgetall('total_rank')return [book_id for book_id, score in sorted(ranks.items(), key=lambda item: int(item[1]),reverse=True)][:n]

获取总排行的商品接口：

class RankView(APIView):def get(self, request):# 总排行ids = caches.get_total_rank_topn(3)books = Book.objects.in_bulk(ids)  # 返回一个dict, {id: <>,  ...}s = BookSerializer([books.get(int(id)) for id in ids], many=True)return Response({'code': 0,'total_top_3': s.data})

月度排行

说明： 统计某一商品在当月的所有点击次数

def rank(book_id):# 总排行rd.hincrby('total_rank', book_id)# 月排行curent_month = datetime.now().strftime('%Y%m')name = f'{curent_month}_rank'rd.hincrby(name, book_id)def get_month_rank_topn(n):curent_month = datetime.now().strftime('%Y%m')name = f'{curent_month}_rank'ranks = rd.hgetall(name)return [book_id for book_id, score in sorted(ranks.items(), key=lambda item: int(item[1]), reverse=True)][:n]

View的设计

class RankView(APIView):def get(self, request):# 总排行ids = caches.get_total_rank_topn(3)books = Book.objects.in_bulk(ids)  # 返回一个dict, {id: <>,  ...}s = BookSerializer([books.get(int(id)) for id in ids], many=True)# 月排行month_ids = caches.get_month_rank_topn(3)month_books = Book.objects.in_bulk(month_ids)s2 = BookSerializer([month_books.get(int(id)) for id in month_ids], many=True)return Response({'code': 0,'total_top_3': s.data,'month_top_3': s2.data})