CronTaskController.py 51 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934
  1. #!/usr/bin/python3.6
  2. # -*- coding: utf-8 -*-
  3. #
  4. # Copyright (C) 2022 #
  5. # @Time : 2022/4/1 11:27
  6. # @Author : ming
  7. # @Email : zhangdongming@asj6.wecom.work
  8. # @File : CronTaskController.py
  9. # @Software: PyCharm
  10. import datetime
  11. import logging
  12. import time
  13. import requests
  14. from django.db import connection, connections, transaction
  15. from django.db.models import Q, Sum, Count
  16. from django.views import View
  17. from Ansjer.config import USED_SERIAL_REDIS_LIST, UNUSED_SERIAL_REDIS_LIST, CONFIG_INFO, CONFIG_US
  18. from Model.models import Device_User, Device_Info, UidSetModel, UID_Bucket, Unused_Uid_Meal, Order_Model, StsCrdModel, \
  19. VodHlsModel, ExperienceContextModel, AiService, VodHlsSummary, VideoPlaybackTimeModel, DeviceUserSummary, \
  20. CountryModel, DeviceTypeModel, OrdersSummary, DeviceInfoSummary, CompanySerialModel, \
  21. CloudLogModel, UidCloudStorageCount, UserExModel, DeviceDomainRegionModel
  22. from Object.RedisObject import RedisObject
  23. from Object.ResponseObject import ResponseObject
  24. from Object.utils import LocalDateTimeUtil
  25. from Service.CommonService import CommonService
  26. from Service.VodHlsService import SplitVodHlsObject
  27. LOGGER = logging.getLogger('info')
  28. class CronDelDataView(View):
  29. def get(self, request, *args, **kwargs):
  30. request.encoding = 'utf-8'
  31. operation = kwargs.get('operation')
  32. return self.validation(request.GET, request, operation)
  33. def post(self, request, *args, **kwargs):
  34. request.encoding = 'utf-8'
  35. operation = kwargs.get('operation')
  36. return self.validation(request.POST, request, operation)
  37. def validation(self, request_dict, request, operation):
  38. response = ResponseObject()
  39. if operation == 'delAccessLog': # 定时删除访问接口数据
  40. return self.delAccessLog(response)
  41. elif operation == 'delPushInfo': # 定时删除推送数据
  42. return self.delPushInfo(response)
  43. elif operation == 'delVodHls': # 定时删除云存播放列表
  44. return self.delVodHls(response)
  45. elif operation == 'delCloudLog': # 定时删除云存接口数据
  46. return self.delCloudLog(response)
  47. elif operation == 'delTesterDevice': # 定时删除测试账号下的设备数据
  48. return self.delTesterDevice(response)
  49. elif operation == 'cloud-log':
  50. return self.uid_cloud_storage_upload_count(response)
  51. else:
  52. return response.json(404)
  53. @staticmethod
  54. def uid_cloud_storage_upload_count(response):
  55. try:
  56. now_time = int(time.time())
  57. local_time = LocalDateTimeUtil.get_before_days_timestamp(now_time)
  58. format_str = '%Y-%m-%d'
  59. date_str = LocalDateTimeUtil.time_stamp_to_time(local_time, format_str)
  60. start_time, end_time = LocalDateTimeUtil.get_start_and_end_time(date_str, format_str)
  61. cs_uid_qs = UID_Bucket.objects.filter(addTime__gte=int(1669824000)).values('uid')
  62. if not cs_uid_qs.exists():
  63. return response.json(0)
  64. for item in cs_uid_qs:
  65. uid = item['uid']
  66. cloud_log_qs = CloudLogModel.objects.filter(uid=uid, operation=r'cloudstorage/storeplaylist',
  67. time__gte=start_time, time__lte=end_time)
  68. cloud_log_qs = cloud_log_qs.values('uid')[0:1]
  69. if not cloud_log_qs.exists():
  70. continue
  71. count_data = {'uid': uid, 'count': cloud_log_qs.count(), 'created_time': end_time,
  72. 'updated_time': end_time}
  73. UidCloudStorageCount.objects.create(**count_data)
  74. return response.json(0)
  75. except Exception as e:
  76. LOGGER.info('异常详情,errLine:{}, errMsg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
  77. return response.json(500)
  78. @staticmethod
  79. def delAccessLog(response):
  80. try:
  81. cursor = connection.cursor()
  82. # 删除7天前的数据
  83. last_week = LocalDateTimeUtil.get_last_week()
  84. sql = 'DELETE FROM access_log WHERE time < %s limit %s'
  85. cursor.execute(sql, [last_week, 10000])
  86. # 关闭游标
  87. cursor.close()
  88. connection.close()
  89. return response.json(0)
  90. except Exception as e:
  91. return response.json(500, repr(e))
  92. @staticmethod
  93. def delPushInfo(response):
  94. now_time = int(time.time())
  95. cursor = connections['mysql02'].cursor()
  96. try:
  97. # 当前时间转日期
  98. local_date_now = str(datetime.datetime.fromtimestamp(int(now_time)).date())
  99. # 根据日期获取周几
  100. week_val = LocalDateTimeUtil.date_to_week(local_date_now)
  101. # 根据当前时间获取7天前时间戳
  102. expiration_time = LocalDateTimeUtil.get_before_days_timestamp(now_time, 7)
  103. # 每次删除条数
  104. size = 10000
  105. # 删除7天前的数据
  106. sql = "DELETE FROM equipment_info WHERE addTime<= %s LIMIT %s "
  107. for i in range(6):
  108. cursor.execute(sql, [expiration_time, size])
  109. if week_val == 1:
  110. sql = "DELETE FROM equipment_info_sunday WHERE add_time<= %s LIMIT %s "
  111. if week_val == 2:
  112. sql = "DELETE FROM equipment_info_monday WHERE add_time<= %s LIMIT %s "
  113. if week_val == 3:
  114. sql = "DELETE FROM equipment_info_tuesday WHERE add_time<= %s LIMIT %s "
  115. if week_val == 4:
  116. sql = "DELETE FROM equipment_info_wednesday WHERE add_time<= %s LIMIT %s "
  117. if week_val == 5:
  118. sql = "DELETE FROM equipment_info_thursday WHERE add_time<= %s LIMIT %s "
  119. if week_val == 6:
  120. sql = "DELETE FROM equipment_info_friday WHERE add_time<= %s LIMIT %s "
  121. if week_val == 7:
  122. sql = "DELETE FROM equipment_info_saturday WHERE add_time<= %s LIMIT %s "
  123. for i in range(5):
  124. cursor.execute(sql, [expiration_time, size])
  125. # 关闭游标
  126. cursor.close()
  127. return response.json(0)
  128. except Exception as e:
  129. return response.json(500, repr(e))
  130. @staticmethod
  131. def delVodHls(response):
  132. nowTime = int(time.time())
  133. try:
  134. cursor = connection.cursor()
  135. month_ago_time = nowTime - 3 * 30 * 24 * 60 * 60 # 删除3个月前的数据
  136. sql = 'DELETE FROM `vod_hls` WHERE endTime<{} LIMIT 50000'.format(month_ago_time)
  137. cursor.execute(sql)
  138. cursor.close()
  139. # 删除vod_hls分表数据
  140. split_vod_hls_obj = SplitVodHlsObject()
  141. split_vod_hls_obj.del_vod_hls_data(end_time__lt=month_ago_time)
  142. return response.json(0)
  143. except Exception as e:
  144. return response.json(500, repr(e))
  145. @staticmethod
  146. def delCloudLog(response):
  147. nowTime = int(time.time())
  148. cursor = connection.cursor()
  149. try:
  150. # 删除3个月前的数据
  151. sql = "DELETE FROM `cloud_log` WHERE time<={} LIMIT 50000".format(
  152. nowTime - 3 * 30 * 24 * 60 * 60)
  153. cursor.execute(sql)
  154. # 关闭游标
  155. cursor.close()
  156. return response.json(0)
  157. except Exception as e:
  158. return response.json(500, repr(e))
  159. @staticmethod
  160. def delTesterDevice(response):
  161. try:
  162. userID_list = [
  163. 'tech01@ansjer.com',
  164. 'tech02@ansjer.com',
  165. 'tech03@ansjer.com',
  166. 'tech04@ansjer.com',
  167. 'tech05@ansjer.com',
  168. 'tech06@ansjer.com',
  169. 'tech07@ansjer.com',
  170. 'tech08@ansjer.com',
  171. 'tech09@ansjer.com',
  172. 'tech10@ansjer.com',
  173. 'fix01@ansjer.com',
  174. 'fix02@ansjer.com',
  175. 'fix03@ansjer.com',
  176. 'fix04@ansjer.com',
  177. 'fix05@ansjer.com']
  178. device_user = Device_User.objects.filter(username__in=userID_list)
  179. device_info_qs = Device_Info.objects.filter(
  180. userID__in=device_user).values('UID')
  181. uid_list = []
  182. for device_info in device_info_qs:
  183. uid_list.append(device_info['UID'])
  184. with transaction.atomic():
  185. # 删除设备云存相关数据
  186. UidSetModel.objects.filter(uid__in=uid_list).delete()
  187. UID_Bucket.objects.filter(uid__in=uid_list).delete()
  188. Unused_Uid_Meal.objects.filter(uid__in=uid_list).delete()
  189. Order_Model.objects.filter(UID__in=uid_list).delete()
  190. StsCrdModel.objects.filter(uid__in=uid_list).delete()
  191. VodHlsModel.objects.filter(uid__in=uid_list).delete()
  192. # 删除vod_hls分表数据
  193. split_vod_hls_obj = SplitVodHlsObject()
  194. split_vod_hls_obj.del_vod_hls_data(uid__in=uid_list)
  195. ExperienceContextModel.objects.filter(uid__in=uid_list).delete()
  196. Device_Info.objects.filter(userID__in=device_user).delete()
  197. return response.json(0)
  198. except Exception as e:
  199. return response.json(500, repr(e))
  200. class CronUpdateDataView(View):
  201. def get(self, request, *args, **kwargs):
  202. request.encoding = 'utf-8'
  203. operation = kwargs.get('operation')
  204. return self.validation(request.GET, request, operation)
  205. def post(self, request, *args, **kwargs):
  206. request.encoding = 'utf-8'
  207. operation = kwargs.get('operation')
  208. return self.validation(request.POST, request, operation)
  209. def validation(self, request_dict, request, operation):
  210. response = ResponseObject()
  211. if operation == 'updateUnusedUidBucket': # 定时更新过期云存关联的未使用套餐状态
  212. return self.updateUnusedUidBucket(response)
  213. elif operation == 'updateUnusedAiService': # 定时更新过期ai关联的未使用套餐状态
  214. return self.updateUnusedAiService(response)
  215. elif operation == 'reqUpdateSerialStatus': # 定时请求更新序列号状态
  216. return self.reqUpdateSerialStatus(response)
  217. elif operation == 'updateSerialStatus': # 更新序列号状态
  218. return self.updateSerialStatus(request_dict, response)
  219. elif operation == 'reset-region-id': # 重置地区id
  220. return self.reset_region_id(request_dict, response)
  221. else:
  222. return response.json(404)
  223. @staticmethod
  224. def updateUnusedUidBucket(response):
  225. """
  226. 监控云存套餐过期修改状态
  227. @param response:
  228. @return:
  229. """
  230. # 定时更新已过期套餐修改状态为2
  231. now_time = int(time.time())
  232. expired_uid_bucket = UID_Bucket.objects.filter(endTime__lte=now_time)
  233. expired_uid_bucket = expired_uid_bucket.filter(~Q(use_status=2)).values('id')
  234. if expired_uid_bucket.exists():
  235. expired_uid_bucket.update(use_status=2)
  236. # 监控有未使用套餐则自动生效
  237. expired_uid_buckets = \
  238. UID_Bucket.objects.filter(endTime__lte=now_time, has_unused=1).values("id", "uid")[0:1000]
  239. for expired_uid_bucket in expired_uid_buckets:
  240. unuseds = Unused_Uid_Meal.objects.filter(
  241. uid=expired_uid_bucket['uid']).values(
  242. "id",
  243. "uid",
  244. "channel",
  245. "addTime",
  246. "expire",
  247. "num",
  248. "bucket_id").order_by('addTime')[0:1]
  249. if not unuseds.exists():
  250. continue
  251. unused = unuseds[0]
  252. try:
  253. with transaction.atomic():
  254. count_unused = Unused_Uid_Meal.objects.filter(
  255. uid=expired_uid_bucket['uid']).count()
  256. has_unused = 1 if count_unused > 1 else 0
  257. endTime = CommonService.calcMonthLater(
  258. unused['expire'] * unused['num'])
  259. UID_Bucket.objects.filter(
  260. uid=expired_uid_bucket['uid']).update(
  261. channel=unused['channel'],
  262. endTime=endTime,
  263. bucket_id=unused['bucket_id'],
  264. updateTime=now_time,
  265. use_status=1,
  266. has_unused=has_unused)
  267. Unused_Uid_Meal.objects.filter(id=unused['id']).delete()
  268. StsCrdModel.objects.filter(
  269. uid=expired_uid_bucket['uid']).delete() # 删除sts记录
  270. except Exception as e:
  271. print(repr(e))
  272. continue
  273. return response.json(0)
  274. @staticmethod
  275. def updateUnusedAiService(response):
  276. now_time = int(time.time())
  277. ai_service_qs = AiService.objects.filter(
  278. endTime__lte=now_time,
  279. use_status=1).values(
  280. 'id',
  281. 'uid')[
  282. 0:200]
  283. for ai_service in ai_service_qs:
  284. try:
  285. with transaction.atomic():
  286. AiService.objects.filter(
  287. id=ai_service['id']).update(
  288. use_status=2) # 更新过期ai订单状态
  289. # 如果存在未使用套餐,更新为使用
  290. unused_ai_service = AiService.objects.filter(
  291. uid=ai_service['uid'],
  292. use_status=0).order_by('addTime')[
  293. :1].values(
  294. 'id',
  295. 'endTime')
  296. if unused_ai_service.exists():
  297. # 未使用套餐的endTime在购买的时候保存为有效时间
  298. effective_day = unused_ai_service[0]['endTime']
  299. endTime = now_time + effective_day
  300. AiService.objects.filter(
  301. id=unused_ai_service[0]['id']).update(
  302. use_status=1, endTime=endTime, updTime=now_time)
  303. except Exception:
  304. continue
  305. return response.json(0)
  306. @classmethod
  307. def reqUpdateSerialStatus(cls, response):
  308. redis_obj = RedisObject()
  309. logger = logging.getLogger('info')
  310. # 更新已使用序列号其他服务器的状态
  311. used_serial_redis_list = redis_obj.lrange(USED_SERIAL_REDIS_LIST, 0, -1) # 读取redis已使用序列号
  312. logger.info('---请求更新序列号接口---used_serial_redis_list:{}---status:{}'.format(used_serial_redis_list, 3))
  313. if used_serial_redis_list:
  314. used_serial_redis_list = [str(i, 'utf-8') for i in used_serial_redis_list]
  315. cls.do_request_function(used_serial_redis_list, 3)
  316. # 更新未使用序列号其他服务器的状态
  317. unused_serial_redis_list = redis_obj.lrange(UNUSED_SERIAL_REDIS_LIST, 0, -1) # 读取redis未使用序列号
  318. logger.info('---请求更新序列号接口---unused_serial_redis_list:{}---status:{}'.format(unused_serial_redis_list, 1))
  319. if unused_serial_redis_list:
  320. unused_serial_redis_list = [str(i, 'utf-8') for i in unused_serial_redis_list]
  321. cls.do_request_function(unused_serial_redis_list, 1)
  322. return response.json(0)
  323. @staticmethod
  324. def do_request_function(serial_redis_list, status):
  325. """
  326. 请求更新序列号状态
  327. @param serial_redis_list: 序列号redis列表
  328. @param status: 状态, 1: 未使用, 3: 已占用
  329. """
  330. data = {
  331. 'serial_redis_list': str(serial_redis_list),
  332. 'status': status
  333. }
  334. # 确认域名列表
  335. orders_domain_name_list = CommonService.get_orders_domain_name_list()
  336. redis_obj = RedisObject()
  337. logger = logging.getLogger('info')
  338. logger.info('---请求更新序列号线程---data:{},orders_domain_name_list:{}'.format(data, orders_domain_name_list))
  339. try:
  340. requests_failed_flag = False # 请求失败标志位
  341. for domain_name in orders_domain_name_list:
  342. url = '{}cron/update/updateSerialStatus'.format(domain_name)
  343. response = requests.post(url=url, data=data, timeout=5)
  344. logger.info('---请求更新序列号响应时间---:{}'.format(response.elapsed.total_seconds()))
  345. result = response.json()
  346. if result['result_code'] != 0: # 请求失败标志位置位
  347. requests_failed_flag = True
  348. break
  349. # 状态为未使用,重置美洲服的地区id
  350. if status == 1: # 美洲服直接更新
  351. if CONFIG_INFO == CONFIG_US:
  352. DeviceDomainRegionModel.objects.filter(~Q(region_id=0), serial_number__in=serial_redis_list).\
  353. update(region_id=0)
  354. else: # 其他服请求到美洲服更新
  355. req_url = 'https://www.dvema.com/cron/update/reset-region-id'
  356. req_data = {
  357. 'serial_redis_list': str(serial_redis_list)
  358. }
  359. response = requests.post(url=req_url, data=req_data, timeout=5)
  360. logger.info('---请求重置地区id响应时间---:{}'.format(response.elapsed.total_seconds()))
  361. result = response.json()
  362. if result['result_code'] != 0: # 请求失败标志位置位
  363. requests_failed_flag = True
  364. break
  365. if not requests_failed_flag: # 请求成功删除redis序列号
  366. if status == 1:
  367. for i in serial_redis_list:
  368. redis_obj.lrem(UNUSED_SERIAL_REDIS_LIST, 0, i)
  369. elif status == 3:
  370. for i in serial_redis_list:
  371. redis_obj.lrem(USED_SERIAL_REDIS_LIST, 0, i)
  372. except Exception as e:
  373. logger.info('---更新序列号状态异常---:{}'.format(repr(e)))
  374. @staticmethod
  375. def updateSerialStatus(request_dict, response):
  376. """
  377. 更新序列号状态
  378. @param request_dict: 请求参数
  379. @request_dict serial_redis_list: 序列号redis列表
  380. @request_dict status: 状态, 1: 未使用, 3: 已占用
  381. @param response: 响应对象
  382. """
  383. serial_redis_list = request_dict.get('serial_redis_list', None)
  384. status = request_dict.get('status', None)
  385. logger = logging.getLogger('info')
  386. logger.info('---更新序列号状态参数---serial_redis_list:{},status:{}'.format(serial_redis_list, status))
  387. if not all([serial_redis_list, status]):
  388. return response.json(444)
  389. now_time = int(time.time())
  390. try:
  391. serial_redis_list = eval(serial_redis_list)
  392. CompanySerialModel.objects.filter(serial_number__in=serial_redis_list).update(status=int(status),
  393. update_time=now_time)
  394. return response.json(0)
  395. except Exception as e:
  396. logger.info('---更新序列号状态异常---:{}'.format(repr(e)))
  397. return response.json(500)
  398. @staticmethod
  399. def reset_region_id(request_dict, response):
  400. """
  401. 重置地区id
  402. @param request_dict: 请求参数
  403. @request_dict serial_redis_list: 序列号redis列表
  404. @param response: 响应对象
  405. """
  406. serial_redis_list = request_dict.get('serial_redis_list', None)
  407. logger = logging.getLogger('info')
  408. logger.info('---重置地区id参数---serial_redis_list:{}'.format(serial_redis_list))
  409. if not serial_redis_list:
  410. return response.json(444)
  411. try:
  412. serial_redis_list = eval(serial_redis_list)
  413. DeviceDomainRegionModel.objects.filter(serial_number__in=serial_redis_list).update(region_id=0)
  414. return response.json(0)
  415. except Exception as e:
  416. logger.info('---重置地区id异常---:{}'.format(repr(e)))
  417. return response.json(500)
  418. class CronCollectDataView(View):
  419. def get(self, request, *args, **kwargs):
  420. request.encoding = 'utf-8'
  421. operation = kwargs.get('operation')
  422. return self.validation(request.GET, request, operation)
  423. def post(self, request, *args, **kwargs):
  424. request.encoding = 'utf-8'
  425. operation = kwargs.get('operation')
  426. return self.validation(request.POST, request, operation)
  427. def validation(self, request_dict, request, operation):
  428. response = ResponseObject()
  429. if operation == 'collectPlayBack': # 定时保存云存视频回放
  430. return self.collect_play_back(response)
  431. elif operation == 'collectDeviceUser': # 定时保存用户数据
  432. return self.collect_device_user(response)
  433. elif operation == 'collectOrder': # 定时保存订单数据
  434. return self.collect_order(response)
  435. elif operation == 'collectDeviceInfo': # 定时保存设备数据
  436. return self.collect_device_info(response)
  437. else:
  438. return response.json(404)
  439. @staticmethod
  440. def collect_play_back(response):
  441. try:
  442. now_time = int(time.time())
  443. today = datetime.datetime.today()
  444. start_time = datetime.datetime(today.year, today.month, today.day)
  445. end_time = start_time + datetime.timedelta(days=1)
  446. start_time = CommonService.str_to_timestamp(start_time.strftime('%Y-%m-%d %H:%M:%S'))
  447. end_time = CommonService.str_to_timestamp(end_time.strftime('%Y-%m-%d %H:%M:%S'))
  448. this_month_str = datetime.datetime(today.year, today.month, 1)
  449. this_month_stamp = CommonService.str_to_timestamp(this_month_str.strftime('%Y-%m-%d %H:%M:%S'))
  450. video_play_back_time_qs = VideoPlaybackTimeModel.objects.filter(startTime__gte=start_time,
  451. startTime__lt=end_time,
  452. playMode='cloud').values('uid').annotate(
  453. play_duration=Sum('duration'), play_frequency=Count('uid'))
  454. with transaction.atomic():
  455. for item in video_play_back_time_qs:
  456. vod_hls_summary_qs = VodHlsSummary.objects.filter(uid=item['uid'], time=this_month_stamp)
  457. if vod_hls_summary_qs.exists():
  458. vod_hls_summary = vod_hls_summary_qs.first()
  459. vod_hls_summary.play_duration += item['play_duration']
  460. vod_hls_summary.play_frequency += 1
  461. vod_hls_summary.updated_time = now_time
  462. vod_hls_summary.save()
  463. else:
  464. VodHlsSummary.objects.create(uid=item['uid'], time=this_month_stamp, created_time=now_time,
  465. play_duration=item['play_duration'], play_frequency=1,
  466. updated_time=now_time)
  467. return response.json(0)
  468. except Exception as e:
  469. return response.json(500, repr(e))
  470. @staticmethod
  471. def collect_device_user(response):
  472. try:
  473. created_time = int(time.time())
  474. today = datetime.datetime.today()
  475. start_time = datetime.datetime(today.year, today.month, today.day)
  476. end_time = start_time + datetime.timedelta(days=1)
  477. increase_user_qs = Device_User.objects.filter(data_joined__year=today.year, data_joined__month=today.month,
  478. data_joined__day=today.day).values('region_country')
  479. start_time = CommonService.str_to_timestamp(start_time.strftime('%Y-%m-%d %H:%M:%S'))
  480. end_time = CommonService.str_to_timestamp(end_time.strftime('%Y-%m-%d %H:%M:%S'))
  481. active_user_qs = UserExModel.objects.filter(updTime__gte=start_time, updTime__lt=end_time).values(
  482. 'userID__region_country')
  483. country_qs = CountryModel.objects.all().values('id', 'region__name', 'country_name')
  484. country_dict = {}
  485. continent_dict = {}
  486. for item in country_qs:
  487. country_dict[item['id']] = item['country_name']
  488. continent_dict[item['country_name']] = item['region__name']
  489. with transaction.atomic():
  490. if increase_user_qs.exists():
  491. increase_user_count = increase_user_qs.count()
  492. increase_user_country_list = increase_user_qs.values('region_country').annotate(
  493. count=Count('region_country')).order_by('count')
  494. increase_user_country_dict = {}
  495. increase_user_continent_dict = {}
  496. for item in increase_user_country_list:
  497. country_name = country_dict.get(item['region_country'], '未知国家')
  498. continent_name = continent_dict.get(country_name, '未知大洲')
  499. increase_user_country_dict[country_name] = item['count']
  500. if continent_name not in increase_user_continent_dict:
  501. increase_user_continent_dict[continent_name] = 0
  502. increase_user_continent_dict[continent_name] += item['count']
  503. DeviceUserSummary.objects.create(time=start_time, count=increase_user_count,
  504. country=increase_user_country_dict, created_time=created_time,
  505. continent=increase_user_continent_dict)
  506. if active_user_qs.exists():
  507. active_user_count = active_user_qs.count()
  508. active_user_country_list = active_user_qs.values('userID__region_country').annotate(
  509. count=Count('userID__region_country')).order_by('count')
  510. active_user_country_dict = {}
  511. active_user_continent_dict = {}
  512. for item in active_user_country_list:
  513. country_name = country_dict.get(item['userID__region_country'], '未知国家')
  514. continent_name = continent_dict.get(country_name, '未知大洲')
  515. active_user_country_dict[country_name] = item['count']
  516. if continent_name not in active_user_continent_dict:
  517. active_user_continent_dict[continent_name] = 0
  518. active_user_continent_dict[continent_name] += item['count']
  519. DeviceUserSummary.objects.create(time=start_time, query_type=1, count=active_user_count,
  520. country=active_user_country_dict, created_time=created_time,
  521. continent=active_user_continent_dict)
  522. return response.json(0)
  523. except Exception as e:
  524. return response.json(500, repr(e))
  525. @staticmethod
  526. def collect_order(response):
  527. try:
  528. created_time = int(time.time())
  529. today = datetime.datetime.today()
  530. start_time = datetime.datetime(today.year, today.month, today.day)
  531. end_time = start_time + datetime.timedelta(days=1)
  532. start_time = CommonService.str_to_timestamp(start_time.strftime('%Y-%m-%d %H:%M:%S'))
  533. end_time = CommonService.str_to_timestamp(end_time.strftime('%Y-%m-%d %H:%M:%S'))
  534. order_qs = Order_Model.objects.filter(addTime__gte=start_time, addTime__lt=end_time,
  535. status=1).values('UID', 'order_type',
  536. 'store_meal_name', 'price',
  537. 'addTime', 'currency').order_by(
  538. 'addTime')
  539. uid_list = []
  540. all_order_qs = Order_Model.objects.filter(addTime__lt=start_time, status=1).values('UID')
  541. for item in all_order_qs:
  542. if item['UID'] not in uid_list:
  543. uid_list.append(item['UID'])
  544. # 国家表数据
  545. country_qs = CountryModel.objects.values('id', 'country_name')
  546. country_dict = {}
  547. for item in country_qs:
  548. country_dict[item['id']] = item['country_name']
  549. # 设备类型数据
  550. device_type_qs = DeviceTypeModel.objects.values('name', 'type')
  551. device_type_dict = {}
  552. for item in device_type_qs:
  553. device_type_dict[item['type']] = item['name']
  554. with transaction.atomic():
  555. for item in order_qs:
  556. is_pay = 0
  557. price = float(item['price'])
  558. currency = item['currency']
  559. uid_set_qs = UidSetModel.objects.filter(uid=item['UID']).values('tb_country')
  560. country_id = uid_set_qs[0]['tb_country'] if uid_set_qs.exists() else 0
  561. country_name = country_dict.get(country_id, '未知国家')
  562. order_type = item['order_type']
  563. device_info_qs = Device_Info.objects.filter(UID=item['UID']).values('Type')
  564. device_type_id = device_info_qs[0]['Type'] if device_info_qs.exists() else 0
  565. device_type_name = device_type_dict.get(device_type_id, '未知设备')
  566. store_meal_name = item['store_meal_name']
  567. add_time_stamp = item['addTime']
  568. add_time_str = datetime.datetime.fromtimestamp(int(add_time_stamp))
  569. add_time_str = datetime.datetime(add_time_str.year, add_time_str.month, add_time_str.day)
  570. add_time_stamp = CommonService.str_to_timestamp(add_time_str.strftime('%Y-%m-%d %H:%M:%S'))
  571. if price == 0:
  572. is_pay = 1
  573. order_summary_qs = OrdersSummary.objects.filter(time=add_time_stamp, query_type=1,
  574. service_type=order_type)
  575. else:
  576. order_summary_qs = OrdersSummary.objects.filter(time=add_time_stamp, query_type=0,
  577. service_type=order_type)
  578. if item['UID'] not in uid_list:
  579. pay_order_summary_qs = OrdersSummary.objects.filter(time=add_time_stamp, query_type=2,
  580. service_type=order_type)
  581. query_type = 2
  582. else:
  583. pay_order_summary_qs = OrdersSummary.objects.filter(time=add_time_stamp, query_type=3,
  584. service_type=order_type)
  585. query_type = 3
  586. if pay_order_summary_qs.exists():
  587. pay_order_summary = pay_order_summary_qs.first()
  588. pay_order_summary.count += 1
  589. temp_total = eval(pay_order_summary.total)
  590. if currency not in temp_total:
  591. temp_total[currency] = price
  592. else:
  593. temp_total[currency] = round(temp_total[currency] + price, 2)
  594. pay_order_summary.total = temp_total
  595. country_temp_dict = eval(pay_order_summary.country)
  596. if country_name in country_temp_dict:
  597. country_temp_dict[country_name]['数量'] += 1
  598. if currency not in country_temp_dict[country_name]:
  599. country_temp_dict[country_name][currency] = price
  600. else:
  601. country_temp_dict[country_name][currency] = round(
  602. country_temp_dict[country_name][currency] + price, 2)
  603. else:
  604. country_temp_dict[country_name] = {'数量': 1, currency: price}
  605. pay_order_summary.country = country_temp_dict
  606. device_type_temp_dict = eval(pay_order_summary.device_type)
  607. if device_type_name in device_type_temp_dict:
  608. device_type_temp_dict[device_type_name]['数量'] += 1
  609. if currency not in device_type_temp_dict[device_type_name]:
  610. device_type_temp_dict[device_type_name][currency] = price
  611. else:
  612. device_type_temp_dict[device_type_name][currency] = round(
  613. device_type_temp_dict[device_type_name][currency] + price, 2)
  614. else:
  615. device_type_temp_dict[device_type_name] = {'数量': 1, currency: price}
  616. pay_order_summary.device_type = device_type_temp_dict
  617. store_meal_temp_dict = eval(pay_order_summary.store_meal)
  618. if store_meal_name in store_meal_temp_dict:
  619. store_meal_temp_dict[store_meal_name]['数量'] += 1
  620. if currency not in store_meal_temp_dict[store_meal_name]:
  621. store_meal_temp_dict[store_meal_name][currency] = price
  622. else:
  623. store_meal_temp_dict[store_meal_name][currency] = round(
  624. store_meal_temp_dict[store_meal_name][currency] + price, 2)
  625. else:
  626. store_meal_temp_dict[store_meal_name] = {'数量': 1, currency: price}
  627. pay_order_summary.store_meal = store_meal_temp_dict
  628. pay_order_summary.save()
  629. else:
  630. final_total = {currency: price}
  631. country_temp_dict = {
  632. country_name: {
  633. '数量': 1,
  634. currency: price
  635. }
  636. }
  637. device_type_temp_dict = {
  638. device_type_name: {
  639. '数量': 1,
  640. currency: price
  641. }
  642. }
  643. store_meal_temp_dict = {
  644. store_meal_name: {
  645. '数量': 1,
  646. currency: price
  647. }
  648. }
  649. OrdersSummary.objects.create(time=add_time_stamp, count=1, query_type=query_type,
  650. service_type=order_type, total=final_total,
  651. country=country_temp_dict, created_time=created_time,
  652. device_type=device_type_temp_dict,
  653. store_meal=store_meal_temp_dict)
  654. if order_summary_qs.exists():
  655. order_summary = order_summary_qs.first()
  656. order_summary.count += 1
  657. temp_total = eval(order_summary.total)
  658. if currency not in temp_total:
  659. temp_total[currency] = price
  660. else:
  661. temp_total[currency] = round(temp_total[currency] + price, 2)
  662. order_summary.total = temp_total
  663. country_temp_dict = eval(order_summary.country)
  664. if country_name in country_temp_dict:
  665. if is_pay == 0:
  666. country_temp_dict[country_name]['数量'] += 1
  667. if currency not in country_temp_dict[country_name]:
  668. country_temp_dict[country_name][currency] = price
  669. else:
  670. country_temp_dict[country_name][currency] = round(
  671. country_temp_dict[country_name][currency] + price, 2)
  672. else:
  673. country_temp_dict[country_name] += 1
  674. else:
  675. if is_pay == 0:
  676. country_temp_dict[country_name] = {'数量': 1, currency: price}
  677. else:
  678. country_temp_dict[country_name] = 1
  679. order_summary.country = country_temp_dict
  680. device_type_temp_dict = eval(order_summary.device_type)
  681. if device_type_name in device_type_temp_dict:
  682. if is_pay == 0:
  683. device_type_temp_dict[device_type_name]['数量'] += 1
  684. if currency not in device_type_temp_dict[device_type_name]:
  685. device_type_temp_dict[device_type_name][currency] = price
  686. else:
  687. device_type_temp_dict[device_type_name][currency] = round(
  688. device_type_temp_dict[device_type_name][currency] + price, 2)
  689. else:
  690. device_type_temp_dict[device_type_name] += 1
  691. else:
  692. if is_pay == 0:
  693. device_type_temp_dict[device_type_name] = {'数量': 1, currency: price}
  694. else:
  695. device_type_temp_dict[device_type_name] = 1
  696. order_summary.device_type = device_type_temp_dict
  697. store_meal_temp_dict = eval(order_summary.store_meal)
  698. if store_meal_name in store_meal_temp_dict:
  699. if is_pay == 0:
  700. store_meal_temp_dict[store_meal_name]['数量'] += 1
  701. if currency not in store_meal_temp_dict[store_meal_name]:
  702. store_meal_temp_dict[store_meal_name][currency] = price
  703. else:
  704. store_meal_temp_dict[store_meal_name][currency] = round(
  705. store_meal_temp_dict[store_meal_name][currency] + price, 2)
  706. else:
  707. store_meal_temp_dict[store_meal_name] += 1
  708. else:
  709. if is_pay == 0:
  710. store_meal_temp_dict[store_meal_name] = {'数量': 1, currency: price}
  711. else:
  712. store_meal_temp_dict[store_meal_name] = 1
  713. order_summary.store_meal = store_meal_temp_dict
  714. order_summary.save()
  715. else:
  716. final_total = {currency: price}
  717. if is_pay == 0:
  718. country_temp_dict = {
  719. country_name: {
  720. '数量': 1,
  721. currency: price
  722. }
  723. }
  724. device_type_temp_dict = {
  725. device_type_name: {
  726. '数量': 1,
  727. currency: price
  728. }
  729. }
  730. store_meal_temp_dict = {
  731. store_meal_name: {
  732. '数量': 1,
  733. currency: price
  734. }
  735. }
  736. else:
  737. device_type_temp_dict = {
  738. device_type_name: 1
  739. }
  740. store_meal_temp_dict = {
  741. store_meal_name: 1
  742. }
  743. country_temp_dict = {
  744. country_name: 1
  745. }
  746. OrdersSummary.objects.create(time=add_time_stamp, count=1, query_type=is_pay,
  747. service_type=order_type, total=final_total,
  748. country=country_temp_dict, created_time=created_time,
  749. device_type=device_type_temp_dict, store_meal=store_meal_temp_dict)
  750. return response.json(0)
  751. except Exception as e:
  752. return response.json(500, repr(e))
  753. @staticmethod
  754. def collect_device_info(response):
  755. try:
  756. created_time = int(time.time())
  757. today = datetime.datetime.today()
  758. start_time = datetime.datetime(today.year, today.month, today.day)
  759. end_time = start_time + datetime.timedelta(days=1)
  760. start_time = CommonService.str_to_timestamp(start_time.strftime('%Y-%m-%d %H:%M:%S'))
  761. end_time = CommonService.str_to_timestamp(end_time.strftime('%Y-%m-%d %H:%M:%S'))
  762. increase_device_qs = UidSetModel.objects.filter(addTime__gte=start_time, addTime__lt=end_time).values(
  763. 'tb_country',
  764. 'uid',
  765. 'device_type',
  766. 'cloud_vod',
  767. 'is_ai',
  768. 'mobile_4g',
  769. 'addTime')
  770. video_play_back_time_qs = VideoPlaybackTimeModel.objects.filter(startTime__gte=start_time,
  771. startTime__lt=end_time).values('uid')
  772. active_device_qs = UidSetModel.objects.filter(uid__in=video_play_back_time_qs).values('tb_country',
  773. 'addTime',
  774. 'device_type',
  775. 'cloud_vod',
  776. 'is_ai',
  777. 'mobile_4g',
  778. 'uid')
  779. increase_device_count = increase_device_qs.count()
  780. active_device_count = active_device_qs.count()
  781. # 国家表数据
  782. country_qs = CountryModel.objects.values('id', 'country_name', 'region__name')
  783. country_dict = {}
  784. continent_dict = {}
  785. for item in country_qs:
  786. country_dict[item['id']] = item['country_name']
  787. continent_dict[item['country_name']] = item['region__name']
  788. # 设备类型数据
  789. device_type_qs = DeviceTypeModel.objects.values('name', 'type')
  790. device_type_dict = {}
  791. for item in device_type_qs:
  792. device_type_dict[item['type']] = item['name']
  793. with transaction.atomic():
  794. if increase_device_qs.exists():
  795. # 国家大洲设备数据
  796. increase_device_country_list = increase_device_qs.values('tb_country').annotate(
  797. count=Count('tb_country')).order_by('count')
  798. increase_device_country_dict = {}
  799. increase_device_continent_dict = {}
  800. for item in increase_device_country_list:
  801. country_name = country_dict.get(item['tb_country'], '未知国家')
  802. continent_name = continent_dict.get(country_name, '未知大洲')
  803. increase_device_country_dict[country_name] = item['count']
  804. if continent_name not in increase_device_continent_dict:
  805. increase_device_continent_dict[continent_name] = 0
  806. increase_device_continent_dict[continent_name] += item['count']
  807. # 设备类型数据
  808. increase_device_type_list = increase_device_qs.values('device_type').annotate(
  809. count=Count('device_type')).order_by('count')
  810. increase_device_type_dict = {}
  811. for item in increase_device_type_list:
  812. type_name = device_type_dict.get(item['device_type'], '未知设备类型')
  813. increase_device_type_dict[type_name] = item['count']
  814. # 云存设备类型数据
  815. increase_device_vod_list = increase_device_qs.filter(~Q(cloud_vod=2)).values(
  816. 'device_type').annotate(
  817. count=Count('device_type')).order_by('count')
  818. increase_device_vod_dict = {}
  819. for item in increase_device_vod_list:
  820. type_name = device_type_dict.get(item['device_type'], '未知设备类型')
  821. increase_device_vod_dict[type_name] = item['count']
  822. # AI设备类型数据
  823. increase_device_ai_list = increase_device_qs.filter(~Q(is_ai=2)).values('device_type').annotate(
  824. count=Count('device_type')).order_by('count')
  825. increase_device_ai_dict = {}
  826. for item in increase_device_ai_list:
  827. type_name = device_type_dict.get(item['device_type'], '未知设备类型')
  828. increase_device_ai_dict[type_name] = item['count']
  829. # 联通设备类型数据
  830. increase_device_unicom_list = increase_device_qs.filter(~Q(mobile_4g=2)).values(
  831. 'device_type').annotate(
  832. count=Count('device_type')).order_by('count')
  833. increase_device_unicom_dict = {}
  834. for item in increase_device_unicom_list:
  835. type_name = device_type_dict.get(item['device_type'], '未知设备类型')
  836. increase_device_unicom_dict[type_name] = item['count']
  837. DeviceInfoSummary.objects.create(time=start_time, count=increase_device_count,
  838. query_type=0, created_time=created_time,
  839. country=increase_device_country_dict,
  840. continent=increase_device_continent_dict,
  841. vod_service=increase_device_vod_dict,
  842. ai_service=increase_device_ai_dict,
  843. unicom_service=increase_device_unicom_dict,
  844. device_type=increase_device_type_dict)
  845. if active_device_qs.exists():
  846. # 国家大洲设备数据
  847. active_device_country_list = active_device_qs.values('tb_country').annotate(
  848. count=Count('tb_country')).order_by('count')
  849. active_device_country_dict = {}
  850. active_device_continent_dict = {}
  851. for item in active_device_country_list:
  852. country_name = country_dict.get(item['tb_country'], '未知国家')
  853. continent_name = continent_dict.get(country_name, '未知大洲')
  854. active_device_country_dict[country_name] = item['count']
  855. if continent_name not in active_device_continent_dict:
  856. active_device_continent_dict[continent_name] = 0
  857. active_device_continent_dict[continent_name] += item['count']
  858. # 设备类型数据
  859. active_device_type_list = active_device_qs.values('device_type').annotate(
  860. count=Count('device_type')).order_by('count')
  861. active_device_type_dict = {}
  862. for item in active_device_type_list:
  863. type_name = device_type_dict.get(item['device_type'], '未知设备类型')
  864. active_device_type_dict[type_name] = item['count']
  865. # 云存设备类型数据
  866. active_device_vod_list = active_device_qs.filter(~Q(cloud_vod=2)).values('device_type').annotate(
  867. count=Count('device_type')).order_by('count')
  868. active_device_vod_dict = {}
  869. for item in active_device_vod_list:
  870. type_name = device_type_dict.get(item['device_type'], '未知设备类型')
  871. active_device_vod_dict[type_name] = item['count']
  872. # AI设备类型数据
  873. active_device_ai_list = active_device_qs.filter(~Q(is_ai=2)).values('device_type').annotate(
  874. count=Count('device_type')).order_by('count')
  875. active_device_ai_dict = {}
  876. for item in active_device_ai_list:
  877. type_name = device_type_dict.get(item['device_type'], '未知设备类型')
  878. active_device_ai_dict[type_name] = item['count']
  879. # 联通设备类型数据
  880. active_device_unicom_list = active_device_qs.filter(~Q(mobile_4g=2)).values('device_type').annotate(
  881. count=Count('device_type')).order_by('count')
  882. active_device_unicom_dict = {}
  883. for item in active_device_unicom_list:
  884. type_name = device_type_dict.get(item['device_type'], '未知设备类型')
  885. active_device_unicom_dict[type_name] = item['count']
  886. DeviceInfoSummary.objects.create(time=start_time, count=active_device_count,
  887. query_type=1, created_time=created_time,
  888. country=active_device_country_dict,
  889. continent=active_device_continent_dict,
  890. vod_service=active_device_vod_dict,
  891. ai_service=active_device_ai_dict,
  892. unicom_service=active_device_unicom_dict,
  893. device_type=active_device_type_dict)
  894. return response.json(0)
  895. except Exception as e:
  896. return response.json(500, repr(e))