这篇文章主要讲解了Django ORM如何实现按天获取数据去重求和,内容清晰明了,对此有兴趣的小伙伴可以学习一下,相信大家阅读完之后会有帮助。
我就废话不多说了,大家还是直接看代码吧!
def total_data(request): data = request_body(request, 'POST') if not data: return http_return(400, '参数错误') # 前端传入毫秒为单位的时间戳 startTimestamp = data.get('startTime', '') endTimestamp = data.get('endTime', '') if startTimestamp and endTimestamp: startTimestamp = int(startTimestamp/1000) endTimestamp = int(endTimestamp/1000) else: return http_return(400, '参数有误') # 小于2019-05-30 00:00:00的时间不合法 if endTimestamp < startTimestamp or endTimestamp <= 1559145600 or startTimestamp <= 1559145600: return http_return(400, '无效时间') if startTimestamp and endTimestamp: # 给定时间查询 startTime = datetime.fromtimestamp(startTimestamp) endTime = datetime.fromtimestamp(endTimestamp) t1 = datetime(startTime.year, startTime.month, startTime.day) t2 = datetime(endTime.year, endTime.month, endTime.day, 23, 59, 59, 999999) # 用户总人数 totalUsers = User.objects.exclude(status='destroy').count() # 音频总数 totalAudioStory = AudioStory.objects.filter(isDelete=False).count() # 专辑总数 totalAlbums = Album.objects.filter(isDelete=False).count() # 新增用户人数 newUsers = User.objects.filter(createTime__range=(t1, t2)).exclude(status='destroy').count() # 活跃用户人数 activityUsers = LoginLog.objects.filter(createTime__range=(t1, t2), isManager=False).values('userUuid_id').\ annotate(Count('userUuid_id')).count() # 新增音频数 newAudioStory = AudioStory.objects.filter(createTime__range=(t1, t2)).count() # 男性 male = User.objects.filter(gender=1).exclude(status='destroy').count() # 女性 female = User.objects.filter(gender=2).exclude(status='destroy').count() # 未知 unkonwGender = User.objects.filter(gender=0).exclude(status='destroy').count() # 模板音频 aduioStoryCount = AudioStory.objects.filter( isDelete=False, audioStoryType=1, isUpload=1, createTime__range=(t1, t2)).count() # 自由录制 freedomStoryCount = AudioStory.objects.filter( isDelete=False, audioStoryType=0, isUpload=1, createTime__range=(t1, t2)).count() # 儿歌 tags1 = Tag.objects.filter(code="RECORDTYPE", name='儿歌').first() tags1Count = tags1.tagsAudioStory.filter(isDelete=False, createTime__range=(t1, t2)).count() # 儿歌作品数 user1Count = tags1.tagsAudioStory.filter(isDelete=False, createTime__range=(t1, t2)).\ values('userUuid_id').annotate(Count('userUuid_id')).count() # 录音类型人数,去重 # result = Tag.objects.filter(code="RECORDTYPE").annotate(Count('tagsAudioStory')) # 父母学堂 tags2 = Tag.objects.filter(code="RECORDTYPE", name='父母学堂').first() tags2Count = tags2.tagsAudioStory.filter(isDelete=False, createTime__range=(t1, t2)).count() user2Count = tags2.tagsAudioStory.filter(isDelete=False, createTime__range=(t1, t2)).\ values('userUuid_id').annotate(Count('userUuid_id')).count() # 国学 tags3 = Tag.objects.filter(code="RECORDTYPE", name='国学').first() tags3Count = tags3.tagsAudioStory.filter(isDelete=False, createTime__range=(t1, t2)).count() user3Count = tags3.tagsAudioStory.filter(isDelete=False, createTime__range=(t1, t2)).\ values('userUuid_id').annotate(Count('userUuid_id')).count() # 英文 tags4 = Tag.objects.filter(code="RECORDTYPE", name='英文').first() tags4Count = tags4.tagsAudioStory.filter(isDelete=False, createTime__range=(t1, t2)).count() user4Count = tags4.tagsAudioStory.filter(isDelete=False, createTime__range=(t1, t2)). \ values('userUuid_id').annotate(Count('userUuid_id')).count() # 其他 tags5 = Tag.objects.filter(code="RECORDTYPE", name='其他').first() tags5Count = tags5.tagsAudioStory.filter(isDelete=False, createTime__range=(t1, t2)).count() user5Count = tags5.tagsAudioStory.filter(isDelete=False, createTime__range=(t1, t2)).\ values('userUuid_id').annotate(Count('userUuid_id')).count() recordTypePercentage = [ {'name': '儿歌', 'tagsNum': tags1Count, 'userNum': user1Count}, {'name': '儿歌', 'tagsNum': tags2Count, 'userNum': user2Count}, {'name': '国学', 'tagsNum': tags3Count, 'userNum': user3Count}, {'name': '英文', 'tagsNum': tags4Count, 'userNum': user4Count}, {'name': '其他', 'tagsNum': tags5Count, 'userNum': user5Count} ] # 活跃用户排行 data1_list = [] # result = AudioStory.objects.filter(isDelete=False, createTime__range=(t1, t2)).values('userUuid_id').annotate(Count('userUuid_id'))[:1] res = User.objects.annotate(audioStory_count_by_user = Count("useAudioUuid")).order_by('-audioStory_count_by_user')[:5] for index,item in enumerate(res.values()): data = { 'orderNum': index+1, 'name': item['nickName'], 'recordCount': item['audioStory_count_by_user'] } data1_list.append(data) # 热门录制排行 data2_list = [] res = Story.objects.filter(status="normal", createTime__range=(t1, t2)).order_by('-recordNum')[:5] for index,item in enumerate(res.values()): data = { 'orderNum': index + 1 or -1, 'name': item['name'] or '', 'recordNum': item['recordNum'] or 0 } data2_list.append(data) # 热门播放排行 data3_list = [] audioStory = AudioStory.objects.filter(isDelete=False, createTime__range=(t1, t2)).order_by('-playTimes')[:5] for index,item in enumerate(audioStory): data = { 'orderNum': index + 1, 'name': item.storyUuid.name if item.audioStoryType else item.name, 'playTimes': item.playTimes } data3_list.append(data) # 图表数据--新增用户 graph2 = User.objects.filter(createTime__range=(t1, t2)).\ extra(select={"time": "DATE_FORMAT(createTime,'%%Y-%%m-%%e')"}).\ order_by('time').values('time')\ .annotate(userNum=Count('createTime')).values('time', 'userNum') if graph2: graph2 = list(graph2) else: graph2 = [] # 活跃用户 graph3 = LoginLog.objects.filter(createTime__range=(t1, t2), isManager=False). \ extra(select={"time": "DATE_FORMAT(createTime,'%%Y-%%m-%%e')"}). \ values('time').annotate(userNum=Count('createTime', distinct=True)).values('time', 'userNum') if graph3: graph3 = list(graph3) else: graph3 = [] return http_return(200, 'OK', { 'totalUsers': totalUsers, # 总用户人数 'totalAudioStory': totalAudioStory, # 音频总数 'totalAlbums': totalAlbums, # 总的专辑数 'newUsers': newUsers, # 新增用户人数 'activityUsers': activityUsers, # 活跃用户人数 'newAudioStory': newAudioStory, # 新增音频数 'activityUsersRank': data1_list, # 活跃用户排行 'male': male, # 男性 'female': female, # 女性 'unkonwGender': unkonwGender, # 未知性别 'aduioStoryCount': aduioStoryCount, # 模板音频数量 'freedomStoryCount': freedomStoryCount, # 自由录制音频数量 'recordTypePercentage': recordTypePercentage, 'hotRecordRank': data2_list, # 热门录制排行 'hotPlayAudioStoryRank': data3_list, # 热门播放排行 'newUserGraph': graph2, # 新增用户折线图 'activityUserGraph': graph3, # 活跃用户折线图 })
补充知识:Django 对符合条件的某个字段进行求和,聚合函数annotate()
开发环境:Ubuntu16.04+Django 1.11.9+Python2.7
对符合条件的某个字段求和
之前在开发的时候,有同事问Django是否存在着这样的方法,可以直接将符合条件的某个字段直接求和.
当时不知道这样的方法是否存在,但是想了想自己解决这类似问题的方法,先用filter将符合条件的取出来,然后进行for循环,取出需要的字段,进行求和.感觉是挺low的,于是一起Baidu,写代码测试最后找到了可以求值的方法,聚合函数annotate().
from django.db.models import Sum
from models import Book
all_price = Book.objects.values('price').annotate(num_books=Sum('price')).filter(author='Yu')
print all_price[0]['num_books']
输出结果:650
上面的参数换个顺序,不会出错但不符合预期结果.
all_price = Book.objects.annotate(num_books=Sum('price')).filter(author='Yu').values('price')
print all_youxibi[0]['num_books']
输出结果:'nums_book'
看完上述内容,是不是对Django ORM如何实现按天获取数据去重求和有进一步的了解,如果还想学习更多内容,欢迎关注亿速云行业资讯频道。
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。