No Description

admin_views.py 24KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559
  1. # -*- coding: utf-8 -*-
  2. from __future__ import division
  3. import json
  4. from collections import defaultdict
  5. from datetime import datetime
  6. from itertools import chain, groupby
  7. from django.conf import settings
  8. from django.db import transaction
  9. from django.db.models import Count, Sum
  10. from django_logit import logit
  11. from django_response import response
  12. from paginator import pagination
  13. from TimeConvert import TimeConvert as tc
  14. from account.models import UserInfo
  15. from integral.models import SaleclerkSubmitLogInfo
  16. from logs.models import MchInfoEncryptLogInfo
  17. from mch.models import AdministratorInfo, ConsumeInfoSubmitLogInfo, ModelInfo, SaleclerkInfo
  18. from statistic.models import (ConsumeModelSaleStatisticInfo, ConsumeSaleStatisticInfo, ConsumeUserStatisticInfo,
  19. ModelSaleStatisticInfo)
  20. from utils.error.errno_utils import (AdministratorStatusCode, ProductBrandStatusCode, ProductCouponStatusCode,
  21. ProductMachineStatusCode, UserStatusCode)
  22. WECHAT = settings.WECHAT
  23. @logit
  24. def querysn(request):
  25. brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
  26. admin_id = request.POST.get('admin_id', '')
  27. model_id = request.POST.get('model_id', '')
  28. sn = request.POST.get('sn', '')
  29. if brand_id != settings.KODO_DEFAULT_BRAND_ID:
  30. return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
  31. if not AdministratorInfo.objects.filter(admin_id=admin_id, admin_type=AdministratorInfo.MAINTENANCE, user_status=AdministratorInfo.ACTIVATED, status=True).exists():
  32. return response(AdministratorStatusCode.MAINTENANCE_NOT_FOUND)
  33. log = ConsumeInfoSubmitLogInfo.objects.filter(brand_id=brand_id, model_id=model_id, serialNo=sn, submit_during_activity=True).order_by('has_used', '-pk').first()
  34. if not log:
  35. log = ConsumeInfoSubmitLogInfo.objects.filter(brand_id=brand_id, model_id=model_id, serialNo=sn).order_by('-submit_during_activity', 'dupload').first()
  36. if not log:
  37. return response(ProductMachineStatusCode.SN_NOT_FOUND)
  38. return response(200, 'Query SN Success', u'查询序列号成功', data=log.data)
  39. @logit
  40. def queryusedsn(request):
  41. brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
  42. admin_id = request.POST.get('admin_id', '')
  43. if brand_id != settings.KODO_DEFAULT_BRAND_ID:
  44. return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
  45. if not AdministratorInfo.objects.filter(admin_id=admin_id, admin_type=AdministratorInfo.MAINTENANCE, user_status=AdministratorInfo.ACTIVATED, status=True).exists():
  46. return response(AdministratorStatusCode.MAINTENANCE_NOT_FOUND)
  47. logs = ConsumeInfoSubmitLogInfo.objects.filter(brand_id=brand_id, admin_id=admin_id, has_used=True).order_by('-used_at')
  48. logs = [log.data for log in logs]
  49. return response(200, 'Query Used SN Success', u'查询核销序列号成功', data={
  50. 'logs': logs,
  51. })
  52. @logit
  53. @transaction.atomic
  54. def usecoupon(request):
  55. brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
  56. admin_id = request.POST.get('admin_id', '')
  57. model_id = request.POST.get('model_id', '')
  58. sn = request.POST.get('sn', '')
  59. if brand_id != settings.KODO_DEFAULT_BRAND_ID:
  60. return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
  61. if not AdministratorInfo.objects.filter(
  62. admin_id=admin_id,
  63. admin_type=AdministratorInfo.MAINTENANCE,
  64. user_status=AdministratorInfo.ACTIVATED,
  65. status=True
  66. ).exists():
  67. return response(AdministratorStatusCode.MAINTENANCE_NOT_FOUND)
  68. log = ConsumeInfoSubmitLogInfo.objects.filter(
  69. brand_id=brand_id,
  70. model_id=model_id,
  71. serialNo=sn,
  72. submit_during_activity=True,
  73. has_used=False
  74. ).first()
  75. if not log:
  76. return response(ProductMachineStatusCode.SN_NOT_FOUND)
  77. logdata = log.data
  78. if logdata.get('final_coupon_info', {}).get('coupon_has_expired', True):
  79. return response(ProductCouponStatusCode.COUPON_HAS_EXPIRED)
  80. log.has_used = True
  81. log.used_at = tc.utc_datetime()
  82. log.save()
  83. return response(200, 'Use Coupon Success', u'核销优惠券成功')
  84. @logit
  85. def userinfo(request):
  86. brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
  87. admin_id = request.POST.get('admin_id', '')
  88. page = request.POST.get('page', 1)
  89. num = request.POST.get('num', 20)
  90. if brand_id != settings.KODO_DEFAULT_BRAND_ID:
  91. return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
  92. try:
  93. administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
  94. except AdministratorInfo.DoesNotExist:
  95. return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
  96. userinfos = UserInfo.objects.filter(status=True).order_by('-created_at')
  97. count = userinfos.count()
  98. userinfos, left = pagination(userinfos, page, num)
  99. userinfos = [userinfo.admindata for userinfo in userinfos]
  100. return response(200, 'Userinfo Success', u'用户列表获取成功', data={
  101. 'userinfos': userinfos,
  102. 'count': count,
  103. 'left': left,
  104. })
  105. @logit
  106. def query_usergoods(request):
  107. brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
  108. admin_id = request.POST.get('admin_id', '')
  109. user_id = request.POST.get('user_id', '')
  110. if brand_id != settings.KODO_DEFAULT_BRAND_ID:
  111. return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
  112. # 校验用户是否存在
  113. try:
  114. user = UserInfo.objects.get(user_id=user_id)
  115. except UserInfo.DoesNotExist:
  116. return response(UserStatusCode.USER_NOT_FOUND)
  117. try:
  118. administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
  119. except AdministratorInfo.DoesNotExist:
  120. return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
  121. logs = ConsumeInfoSubmitLogInfo.objects.filter(brand_id=administrator.brand_id, user_id=user_id, status=True).order_by('-created_at')
  122. logs = [log.adminuserdata for log in logs]
  123. return response(200, 'Userinfo Goods Success', u'用户商品列表获取成功', data={
  124. 'logs': logs,
  125. })
  126. @logit
  127. def query_userinfo(request):
  128. brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
  129. admin_id = request.POST.get('admin_id', '')
  130. phone = request.POST.get('phone', '')
  131. if brand_id != settings.KODO_DEFAULT_BRAND_ID:
  132. return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
  133. try:
  134. administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
  135. except AdministratorInfo.DoesNotExist:
  136. return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
  137. userinfos = UserInfo.objects.filter(status=True, phone=phone).order_by('-created_at')
  138. userinfos = [userinfo.admindata for userinfo in userinfos]
  139. return response(200, 'Userinfo Success', u'用户列表获取成功', data={
  140. 'userinfos': userinfos,
  141. })
  142. @logit
  143. def userinfo_update(request):
  144. brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
  145. admin_id = request.POST.get('admin_id', '')
  146. user_id = request.POST.get('user_id', '')
  147. integral = int(request.POST.get('integral', 0))
  148. if brand_id != settings.KODO_DEFAULT_BRAND_ID:
  149. return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
  150. try:
  151. administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
  152. except AdministratorInfo.DoesNotExist:
  153. return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
  154. # 校验用户是否存在
  155. try:
  156. user = UserInfo.objects.get(user_id=user_id, status=True)
  157. except UserInfo.DoesNotExist:
  158. return response(UserStatusCode.USER_NOT_FOUND)
  159. user.integral = integral
  160. user.save()
  161. return response(200, 'Userinfo Update Success', u'修改用户信息成功', data={})
  162. # 统计
  163. def statistic_userprofile(request):
  164. brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
  165. admin_id = request.POST.get('admin_id', '')
  166. start_time = request.POST.get('start_time', '')
  167. end_time = request.POST.get('end_time', '')
  168. model_name = request.POST.get('model_name', '')
  169. if brand_id != settings.KODO_DEFAULT_BRAND_ID:
  170. return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
  171. try:
  172. administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
  173. except AdministratorInfo.DoesNotExist:
  174. return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
  175. if model_name:
  176. logs = ConsumeModelSaleStatisticInfo.objects.filter(model_name=model_name, ymd__gte=start_time, ymd__lte=end_time)
  177. else:
  178. logs = ConsumeModelSaleStatisticInfo.objects.filter(ymd__gte=start_time, ymd__lte=end_time)
  179. sexs = {0: 0, 1: 0, 2: 0}
  180. subscribes = {0: 0, 1: 0}
  181. has_membercards = {0: 0, 1: 0}
  182. provinces = defaultdict(int)
  183. for log in logs:
  184. for user in log.users:
  185. try:
  186. user = UserInfo.objects.get(user_id=user, status=True)
  187. except UserInfo.DoesNotExist:
  188. continue
  189. provinces[user.province_name] += 1
  190. sexs[user.sex] += 1
  191. subscribes[user.subscribe] += 1
  192. has_membercards[user.has_membercard] += 1
  193. return response(200, 'Get User Profile Success', u'获取用户画像成功', data={
  194. 'provinces': provinces,
  195. 'sexs': sexs,
  196. 'subscribe': subscribes,
  197. 'has_membercards': has_membercards,
  198. })
  199. def statistic_daily(request):
  200. brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
  201. admin_id = request.POST.get('admin_id', '')
  202. start_time = request.POST.get('start_time', '')
  203. end_time = request.POST.get('end_time', '')
  204. if brand_id != settings.KODO_DEFAULT_BRAND_ID:
  205. return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
  206. try:
  207. administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
  208. except AdministratorInfo.DoesNotExist:
  209. return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
  210. sale_logs = ConsumeSaleStatisticInfo.objects.filter(ymd__gte=start_time, ymd__lte=end_time)
  211. user_logs = ConsumeUserStatisticInfo.objects.filter(ymd__gte=start_time, ymd__lte=end_time)
  212. sale_logs = [log.data for log in sale_logs]
  213. user_logs = [log.data for log in user_logs]
  214. return response(200, 'Get User Sales Statistic Success', u'获取销量统计成功', data={
  215. 'sale_logs': sale_logs,
  216. 'user_logs': user_logs,
  217. })
  218. def statistic_model(request):
  219. brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
  220. admin_id = request.POST.get('admin_id', '')
  221. start_time = request.POST.get('start_time', '')
  222. end_time = request.POST.get('end_time', '')
  223. if brand_id != settings.KODO_DEFAULT_BRAND_ID:
  224. return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
  225. try:
  226. administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
  227. except AdministratorInfo.DoesNotExist:
  228. return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
  229. logs = ConsumeModelSaleStatisticInfo.objects.filter(ymd__gte=start_time, ymd__lte=end_time).values_list('model_name').annotate(Sum('num'))
  230. logs = [{'model_name': log[0], 'num': log[1]} for log in logs]
  231. return response(200, 'Get Model Statistic Success', u'获取型号统计成功', data={
  232. 'logs': logs
  233. })
  234. def statistic_distributor(request):
  235. brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
  236. admin_id = request.POST.get('admin_id', '')
  237. start_time = request.POST.get('start_time', '')
  238. end_time = request.POST.get('end_time', '')
  239. model_name = request.POST.get('model_name', '')
  240. distributor_name = request.POST.get('distributor_name', '')
  241. if brand_id != settings.KODO_DEFAULT_BRAND_ID:
  242. return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
  243. try:
  244. administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
  245. except AdministratorInfo.DoesNotExist:
  246. return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
  247. logs = SaleclerkSubmitLogInfo.objects.filter(ymd__gte=start_time, ymd__lte=end_time, distributor_name__contains=distributor_name, model_uni_name__contains=model_name, test_user=False, dupload=False, test_sn=False, status=True)
  248. daily_logs = list(logs.values('ymd').annotate(num=Count('pk')).order_by('ymd'))
  249. daily_code1_logs = list(logs.filter(code_version=1).values('ymd').annotate(num=Count('pk')).order_by('ymd'))
  250. daily_code1_hasScan_logs = list(logs.filter(code_version=1, has_scan=True).values('ymd').annotate(num=Count('pk')).order_by('ymd'))
  251. daily_code2_logs = list(logs.filter(code_version=2).values('ymd').annotate(num=Count('pk')).order_by('ymd'))
  252. daily_code2_hasScan_logs = list(logs.filter(code_version=2, has_scan=True).values('ymd').annotate(num=Count('pk')).order_by('ymd'))
  253. i1 = 0
  254. i2 = 0
  255. i3 = 0
  256. i4 = 0
  257. for i in range(0, len(daily_logs)):
  258. daily_logs[i]['code1'] = 0
  259. daily_logs[i]['code2'] = 0
  260. daily_logs[i]['has_code1_scan_num'] = 0
  261. daily_logs[i]['has_code2_scan_num'] = 0
  262. if i1 < len(daily_code1_hasScan_logs) and daily_logs[i]['ymd'] == daily_code1_hasScan_logs[i1]['ymd']:
  263. daily_logs[i]['has_code1_scan_num'] = daily_code1_hasScan_logs[i1]['num']
  264. i1 += 1
  265. if i2 < len(daily_code1_logs) and daily_logs[i]['ymd'] == daily_code1_logs[i2]['ymd']:
  266. daily_logs[i]['code1'] = daily_code1_logs[i2]['num']
  267. i2 += 1
  268. if i3 < len(daily_code2_logs) and daily_logs[i]['ymd'] == daily_code2_logs[i3]['ymd']:
  269. daily_logs[i]['code2'] = daily_code2_logs[i3]['num']
  270. i3 += 1
  271. if i4 < len(daily_code2_hasScan_logs) and daily_logs[i]['ymd'] == daily_code2_hasScan_logs[i4]['ymd']:
  272. daily_logs[i]['has_code2_scan_num'] = daily_code2_hasScan_logs[i4]['num']
  273. i4 += 1
  274. model_logs = list(logs.values('model_uni_name').annotate(num=Count('pk')).order_by('model_uni_name'))
  275. model_code1_logs = list(logs.filter(code_version=1).values('model_uni_name').annotate(num=Count('pk')).order_by('model_uni_name'))
  276. model_code1_hasScan_logs = list(logs.filter(code_version=1, has_scan=True).values('model_uni_name').annotate(num=Count('pk')).order_by('model_uni_name'))
  277. model_code2_logs = list(logs.filter(code_version=2).values('model_uni_name').annotate(num=Count('pk')).order_by('model_uni_name'))
  278. model_code2_hasScan_logs = list(logs.filter(code_version=2, has_scan=True).values('model_uni_name').annotate(num=Count('pk')).order_by('model_uni_name'))
  279. i1 = 0
  280. i2 = 0
  281. i3 = 0
  282. i4 = 0
  283. for i in range(0, len(model_logs)):
  284. model_logs[i]['code1'] = 0
  285. model_logs[i]['code2'] = 0
  286. model_logs[i]['has_code1_scan_num'] = 0
  287. model_logs[i]['has_code2_scan_num'] = 0
  288. if i1 < len(model_code1_hasScan_logs) and model_logs[i]['model_uni_name'] == model_code1_hasScan_logs[i1]['model_uni_name']:
  289. model_logs[i]['has_code1_scan_num'] = model_code1_hasScan_logs[i1]['num']
  290. i1 += 1
  291. if i2 < len(model_code1_logs) and model_logs[i]['model_uni_name'] == model_code1_logs[i2]['model_uni_name']:
  292. model_logs[i]['code1'] = model_code1_logs[i2]['num']
  293. i2 += 1
  294. if i3 < len(model_code2_logs) and model_logs[i]['model_uni_name'] == model_code2_logs[i3]['model_uni_name']:
  295. model_logs[i]['code2'] = model_code2_logs[i3]['num']
  296. i3 += 1
  297. if i4 < len(model_code2_hasScan_logs) and model_logs[i]['model_uni_name'] == model_code2_hasScan_logs[i4]['model_uni_name']:
  298. model_logs[i]['has_code2_scan_num'] = model_code2_hasScan_logs[i4]['num']
  299. i4 += 1
  300. model_logs.sort(key=lambda k: (-k['num']))
  301. distributor_logs = list(logs.values('distributor_name').annotate(num=Count('pk')).order_by('distributor_name'))
  302. distributor_code1_logs = list(logs.filter(code_version=1).values('distributor_name').annotate(num=Count('pk')).order_by('distributor_name'))
  303. distributor_code1_hasScan_logs = list(logs.filter(code_version=1, has_scan=True).values('distributor_name').annotate(num=Count('pk')).order_by('distributor_name'))
  304. distributor_code2_logs = list(logs.filter(code_version=2).values('distributor_name').annotate(num=Count('pk')).order_by('distributor_name'))
  305. distributor_code2_hasScan_logs = list(logs.filter(code_version=2, has_scan=True).values('distributor_name').annotate(num=Count('pk')).order_by('distributor_name'))
  306. i1 = 0
  307. i2 = 0
  308. i3 = 0
  309. i4 = 0
  310. for i in range(0, len(distributor_logs)):
  311. distributor_logs[i]['code1'] = 0
  312. distributor_logs[i]['code2'] = 0
  313. distributor_logs[i]['has_code1_scan_num'] = 0
  314. distributor_logs[i]['has_code2_scan_num'] = 0
  315. if i1 < len(distributor_code1_hasScan_logs) and distributor_logs[i]['distributor_name'] == distributor_code1_hasScan_logs[i1]['distributor_name']:
  316. distributor_logs[i]['has_code1_scan_num'] = distributor_code1_hasScan_logs[i1]['num']
  317. i1 += 1
  318. if i2 < len(distributor_code1_logs) and distributor_logs[i]['distributor_name'] == distributor_code1_logs[i2]['distributor_name']:
  319. distributor_logs[i]['code1'] = distributor_code1_logs[i2]['num']
  320. i2 += 1
  321. if i3 < len(distributor_code2_logs) and distributor_logs[i]['distributor_name'] == distributor_code2_logs[i3]['distributor_name']:
  322. distributor_logs[i]['code2'] = distributor_code2_logs[i3]['num']
  323. i3 += 1
  324. if i4 < len(distributor_code2_hasScan_logs) and distributor_logs[i]['distributor_name'] == distributor_code2_hasScan_logs[i4]['distributor_name']:
  325. distributor_logs[i]['has_code2_scan_num'] = distributor_code2_hasScan_logs[i4]['num']
  326. i4 += 1
  327. distributor_logs.sort(key=lambda k: (-k['num']))
  328. return response(200, 'Get Distributor Statistic Success', u'获取经销商统计成功', data={
  329. 'daily_logs': daily_logs,
  330. 'model_logs': model_logs,
  331. 'distributor_logs': distributor_logs
  332. })
  333. def dashboard(request):
  334. brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
  335. admin_id = request.POST.get('admin_id', '')
  336. start_time = request.POST.get('start_time', '')
  337. end_time = request.POST.get('end_time', '')
  338. if brand_id != settings.KODO_DEFAULT_BRAND_ID:
  339. return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
  340. try:
  341. administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
  342. except AdministratorInfo.DoesNotExist:
  343. return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
  344. # 销售员统计
  345. sale_logs = SaleclerkSubmitLogInfo.objects.filter(ymd__gte=start_time, ymd__lte=end_time, test_user=False, dupload=False, test_sn=False, status=True)
  346. sale_count = sale_logs.count()
  347. sale_daily_logs = list(sale_logs.values('ymd').annotate(num=Count('pk')))
  348. sale_model_logs = list(sale_logs.values('model_uni_name').annotate(num=Count('pk')).order_by('-num'))[:10]
  349. sale_distributor_logs = list(sale_logs.values('distributor_name').annotate(num=Count('pk')).order_by('-num'))[:10]
  350. # 消费者统计
  351. logs = ConsumeInfoSubmitLogInfo.objects.filter(ymd__gte=start_time, ymd__lte=end_time, test_user=False, dupload=False, status=True)
  352. consumer_count = logs.count()
  353. consumer_daily_logs = list(logs.values('ymd').annotate(num=Count('pk')).order_by('ymd'))
  354. consumer_model_logs = list(logs.values('model_uni_name').annotate(num=Count('pk')).order_by('-num'))[:10]
  355. consumer_province_logs = list(logs.values('province').annotate(num=Count('pk')).order_by('-num'))[:10]
  356. return response(200, 'Get Distributor Statistic Success', u'获取经销商统计成功', data={
  357. 'sale_daily_logs': sale_daily_logs,
  358. 'sale_model_logs': sale_model_logs,
  359. 'sale_distributor_logs': sale_distributor_logs,
  360. 'consumer_daily_logs': consumer_daily_logs,
  361. 'consumer_model_logs': consumer_model_logs,
  362. 'consumer_province_logs': consumer_province_logs,
  363. 'sale_count': sale_count,
  364. 'consumer_count': consumer_count,
  365. })
  366. def statistic_consumer(request):
  367. brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
  368. admin_id = request.POST.get('admin_id', '')
  369. start_time = request.POST.get('start_time', '')
  370. end_time = request.POST.get('end_time', '')
  371. if brand_id != settings.KODO_DEFAULT_BRAND_ID:
  372. return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
  373. try:
  374. administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
  375. except AdministratorInfo.DoesNotExist:
  376. return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
  377. # 消费者统计
  378. logs = ConsumeInfoSubmitLogInfo.objects.filter(ymd__gte=start_time, ymd__lte=end_time, test_user=False, dupload=False, status=True)
  379. daily_logs = list(logs.values('ymd').annotate(num=Count('pk')).order_by('ymd'))
  380. daily_code1_logs = list(logs.filter(code_version=1).values('ymd').annotate(num=Count('pk')).order_by('ymd'))
  381. daily_code2_logs = list(logs.filter(code_version=2).values('ymd').annotate(num=Count('pk')).order_by('ymd'))
  382. j = 0
  383. k = 0
  384. for i in range(0, len(daily_logs)):
  385. daily_logs[i]['code1'] = 0
  386. daily_logs[i]['code2'] = 0
  387. if j < len(daily_code1_logs) and daily_logs[i]['ymd'] == daily_code1_logs[j]['ymd']:
  388. daily_logs[i]['code1'] = daily_code1_logs[j]['num']
  389. j += 1
  390. if k < len(daily_code2_logs) and daily_logs[i]['ymd'] == daily_code2_logs[k]['ymd']:
  391. daily_logs[i]['code2'] = daily_code2_logs[k]['num']
  392. k += 1
  393. model_logs = list(logs.values('model_uni_name').annotate(num=Count('pk')).order_by('model_uni_name'))
  394. model_code1_logs = list(logs.filter(code_version=1).values('model_uni_name').annotate(num=Count('pk')).order_by('model_uni_name'))
  395. model_code2_logs = list(logs.filter(code_version=2).values('model_uni_name').annotate(num=Count('pk')).order_by('model_uni_name'))
  396. j = 0
  397. k = 0
  398. for i in range(0, len(model_logs)):
  399. model_logs[i]['code1'] = 0
  400. model_logs[i]['code2'] = 0
  401. if j < len(model_code1_logs) and model_logs[i]['model_uni_name'] == model_code1_logs[j]['model_uni_name']:
  402. model_logs[i]['code1'] = model_code1_logs[j]['num']
  403. j += 1
  404. if k < len(model_code2_logs) and model_logs[i]['model_uni_name'] == model_code2_logs[k]['model_uni_name']:
  405. model_logs[i]['code2'] = model_code2_logs[k]['num']
  406. k += 1
  407. model_logs.sort(key=lambda k: (-k['num']))
  408. province_logs = list(logs.values('province').annotate(num=Count('pk')).order_by('province'))
  409. province_code1_logs = list(logs.filter(code_version=1).values('province').annotate(num=Count('pk')).order_by('province'))
  410. province_code2_logs = list(logs.filter(code_version=2).values('province').annotate(num=Count('pk')).order_by('province'))
  411. j = 0
  412. k = 0
  413. for i in range(0, len(province_logs)):
  414. province_logs[i]['code1'] = 0
  415. province_logs[i]['code2'] = 0
  416. if j < len(province_code1_logs) and province_logs[i]['province'] == province_code1_logs[j]['province']:
  417. province_logs[i]['code1'] = province_code1_logs[j]['num']
  418. j += 1
  419. if k < len(province_code2_logs) and province_logs[i]['province'] == province_code2_logs[k]['province']:
  420. province_logs[i]['code2'] = province_code2_logs[k]['num']
  421. k += 1
  422. province_logs.sort(key=lambda k: (-k['num']))
  423. return response(200, 'Get Consumer Statistic Success', u'获取消费者统计成功', data={
  424. 'daily_logs': daily_logs,
  425. 'model_logs': model_logs,
  426. 'province_logs': province_logs,
  427. })