UnicomComboController.py 35 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769
  1. # -*- encoding: utf-8 -*-
  2. """
  3. @File : UnicomComboController.py
  4. @Time : 2022/6/23 9:18
  5. @Author : stephen
  6. @Email : zhangdongming@asj6.wecom.work
  7. @Software: PyCharm
  8. """
  9. import datetime
  10. import json
  11. import logging
  12. import time
  13. import traceback
  14. from decimal import Decimal
  15. from django.db import transaction
  16. from django.http import HttpResponse, JsonResponse
  17. from django.views.generic.base import View
  18. from Model.models import UnicomDeviceInfo, UnicomCombo, Pay_Type, Order_Model, Store_Meal, AiStoreMeal, \
  19. UnicomComboOrderInfo, UnicomComboExperienceHistory, UnicomDeviceStatusChangePush, SysMsgModel, UnicomFlowPush
  20. from Object.ResponseObject import ResponseObject
  21. from Object.TokenObject import TokenObject
  22. from Object.UnicomObject import UnicomObjeect
  23. from Object.utils import LocalDateTimeUtil
  24. from Object.utils.PayUtil import PayService
  25. from Service.CommonService import CommonService
  26. class UnicomComboView(View):
  27. def get(self, request, *args, **kwargs):
  28. request.encoding = 'utf-8'
  29. operation = kwargs.get('operation')
  30. return self.validation(request.GET, request, operation)
  31. def post(self, request, *args, **kwargs):
  32. request.encoding = 'utf-8'
  33. operation = kwargs.get('operation')
  34. return self.validation(request.POST, request, operation)
  35. def validation(self, request_dict, request, operation):
  36. response = ResponseObject('cn')
  37. if operation == 'query-usage-history':
  38. return self.query_device_usage_history(request_dict, response)
  39. elif operation == 'test-notify':
  40. order_id = request_dict.get('orderId', None)
  41. activate_type = request_dict.get('activateType', 0)
  42. iccid = request_dict.get('iccid', None)
  43. combo_id = request_dict.get('comboId', None)
  44. self.create_combo_order_info(order_id, int(activate_type), iccid, int(combo_id))
  45. return HttpResponse('SUCCESS')
  46. elif operation == 'device-queue-monitoring':
  47. return self.device_queue_monitoring_push(request_dict, request)
  48. elif operation == 'device-status-change':
  49. return self.device_status_change_push(request_dict, request)
  50. elif operation == 'device-bind':
  51. return self.device_add(request_dict, response)
  52. elif operation == 'device-status':
  53. return self.update_device_status(request_dict, response)
  54. elif operation == 'update-card':
  55. return self.update_device_card_type(request_dict, response)
  56. elif operation == 'xxx-sign':
  57. return self.get_test_sign(request_dict, response)
  58. else:
  59. token = TokenObject(request.META.get('HTTP_AUTHORIZATION'))
  60. lang = request_dict.get('lang', token.lang)
  61. response = ResponseObject(lang)
  62. if token.code != 0:
  63. return response.json(token.code)
  64. user_id = token.userID
  65. if operation == 'combo-save':
  66. return self.save_unicom_combo(request_dict, response)
  67. elif operation == 'combo-pay':
  68. return self.buy_unicom_combo(user_id, request_dict, request, response)
  69. elif operation == 'combo-list':
  70. return self.query_package_list(response)
  71. elif operation == 'get-device-info':
  72. return self.get_device_info(request_dict, response)
  73. elif operation == 'user-combo-query':
  74. return self.user_combo_query(user_id, request_dict, response)
  75. @classmethod
  76. def user_combo_query(cls, user_id, request_dict, response):
  77. """
  78. 查询套餐流量列表与正在使用流量详情
  79. @param user_id:
  80. @param request_dict:
  81. @param response:
  82. @return:
  83. """
  84. try:
  85. iccid = request_dict.get('iccid', None)
  86. if not iccid:
  87. return response.json(444)
  88. unicom_device_info_qs = UnicomDeviceInfo.objects.filter(iccid=iccid)
  89. if not unicom_device_info_qs.exists():
  90. return response.json(173)
  91. if not unicom_device_info_qs[0].user_id:
  92. unicom_device_info_qs.update(user_id=user_id)
  93. unicom_api = UnicomObjeect()
  94. combo_order_qs = UnicomComboOrderInfo.objects.filter(iccid=iccid, status=1, is_del=False) \
  95. .values('iccid', 'status', 'combo__status', 'combo__combo_name', 'combo__combo_type',
  96. 'combo__flow_total', 'combo__remark', 'combo__expiration_days', 'combo__expiration_type',
  97. 'year', 'month', 'flow_total_usage', 'expire_time', 'activation_time', 'combo__is_unlimited')
  98. if combo_order_qs.exists():
  99. combo_order = combo_order_qs.first()
  100. flow_details = {
  101. 'flowInvalid': 0,
  102. 'iccid': iccid,
  103. 'status': combo_order['status'],
  104. 'isUnlimited': combo_order['combo__is_unlimited'],
  105. 'comboName': combo_order['combo__combo_name'],
  106. 'comboType': combo_order['combo__combo_type'],
  107. 'flowTotal': combo_order['combo__flow_total'],
  108. 'comboRemark': combo_order['combo__remark'],
  109. 'expirationDays': combo_order['combo__expiration_days'],
  110. 'expirationType': combo_order['combo__expiration_type'],
  111. 'flowTotalUsage': combo_order['flow_total_usage'],
  112. 'activationTime': combo_order['activation_time'],
  113. 'expireTime': combo_order['expire_time'],
  114. 'year': combo_order['year'],
  115. 'month': combo_order['month'],
  116. }
  117. activate_flow = float(flow_details['flowTotalUsage'])
  118. flow_total_usage = unicom_api.get_flow_usage_total(iccid)
  119. flow = 0 if flow_total_usage <= 0 else flow_total_usage - activate_flow
  120. flow_details['usableFlow'] = flow_details['flowTotal'] - flow
  121. flow_details['usableFlow'] = \
  122. 0.00 if flow_details['usableFlow'] <= 0 else flow_details['usableFlow']
  123. flow_details['usableFlow'] = Decimal(flow_details['usableFlow']).quantize(Decimal('0.00'))
  124. flow_details.pop('flowTotalUsage')
  125. cls.update_combo_order_sort(iccid)
  126. flow_details['comboList'] = cls.get_combo_order_list(iccid)
  127. return response.json(0, flow_details)
  128. else:
  129. flow_details = {'iccid': iccid, 'flowInvalid': 1, 'comboList': cls.get_combo_order_list(iccid)}
  130. cls.update_combo_order_sort(iccid)
  131. return response.json(0, flow_details)
  132. except Exception as e:
  133. print(e.args)
  134. ex = traceback.format_exc()
  135. print(ex)
  136. return response.json(177, ex)
  137. @classmethod
  138. def get_combo_order_list(cls, iccid):
  139. """
  140. 查询套餐列表
  141. @param iccid:
  142. @return:
  143. """
  144. combo_list = []
  145. now_time = int(time.time())
  146. before_days = LocalDateTimeUtil.get_before_days_timestamp(now_time, 90)
  147. combo_order_qs = UnicomComboOrderInfo.objects.filter(iccid=iccid, is_del=False, created_time__gt=before_days) \
  148. .values('iccid', 'status', 'combo__combo_name', 'combo__flow_total',
  149. 'combo__remark', 'combo__expiration_days', 'combo__expiration_type', 'flow_total_usage',
  150. 'expire_time', 'combo__is_unlimited').order_by('sort')
  151. for item in combo_order_qs:
  152. combo_list.append({
  153. 'iccid': iccid,
  154. 'status': item['status'],
  155. 'comboName': item['combo__combo_name'],
  156. 'isUnlimited': item['combo__is_unlimited'],
  157. 'flowTotal': item['combo__flow_total'],
  158. 'comboRemark': item['combo__remark'],
  159. 'expirationDays': item['combo__expiration_days'],
  160. 'expirationType': item['combo__expiration_type'],
  161. 'expireTime': item['expire_time'],
  162. })
  163. return combo_list
  164. @classmethod
  165. def update_combo_order_sort(cls, iccd):
  166. """
  167. 修改套餐排序
  168. @param iccd: 联通20位ICCID
  169. @return:
  170. """
  171. combo_order_qs = UnicomComboOrderInfo.objects.filter(iccid=iccd, is_del=False)
  172. if combo_order_qs.exists():
  173. unused_qs = combo_order_qs.filter(status=0)
  174. if unused_qs.exists():
  175. unused_qs.update(sort=50)
  176. used_qs = combo_order_qs.filter(status=1)
  177. if used_qs.exists():
  178. used_qs.update(sort=1)
  179. expire_qs = combo_order_qs.filter(status=2)
  180. if expire_qs.exists():
  181. expire_qs.update(sort=100)
  182. @classmethod
  183. def update_device_status(cls, request_dict, response):
  184. """
  185. 修改绑定设备状态,如产生免费套餐用量则删除
  186. @param request_dict:
  187. @param response:
  188. @return:
  189. """
  190. logger = logging.getLogger('info')
  191. serial_no = request_dict.get('serialNo', None)
  192. time_stamp = request_dict.get('timeStamp', None)
  193. sign = request_dict.get('sign', None)
  194. if not all([serial_no, sign, time_stamp]):
  195. return response.json(444)
  196. logger.info('PC工具进入重置ICCID{}'.format(serial_no))
  197. try:
  198. if not CommonService.check_time_stamp_token(sign, time_stamp):
  199. return response.json(13)
  200. now_time = int(time.time())
  201. with transaction.atomic():
  202. device_info_qs = UnicomDeviceInfo.objects.filter(serial_no=serial_no)
  203. if device_info_qs.exists():
  204. iccid = device_info_qs.first().iccid
  205. flow_push_qs = UnicomFlowPush.objects.filter(serial_no=serial_no)
  206. if flow_push_qs.exists():
  207. flow_push_qs.delete()
  208. sys_msg_qs = SysMsgModel.objects.filter(uid=serial_no)
  209. if sys_msg_qs.exists():
  210. sys_msg_qs.delete()
  211. device_info_qs.update(status=1, updated_time=now_time, user_id='')
  212. combo_order_qs = UnicomComboOrderInfo.objects.filter(iccid=iccid)
  213. if combo_order_qs.exists():
  214. combo_order_qs.delete()
  215. combo_experience_history_qs = UnicomComboExperienceHistory.objects.filter(iccid=iccid)
  216. if combo_experience_history_qs.exists():
  217. combo_experience_history_qs.delete()
  218. return response.json(0)
  219. except Exception as e:
  220. print(e.args)
  221. ex = traceback.format_exc()
  222. print(ex)
  223. logger.info('PC工具重置异常ICCID{},msg={}'.format(iccid, ex))
  224. return response.json(177, ex)
  225. @classmethod
  226. def update_device_card_type(cls, request_dict, response):
  227. """
  228. 修改设备卡类型(0:内置卡,1:外插卡)
  229. """
  230. serial_no = request_dict.get('serialNo', None)
  231. time_stamp = request_dict.get('timeStamp', None)
  232. sign = request_dict.get('sign', None)
  233. main_card = request_dict.get('type', None)
  234. if not all([serial_no, main_card, sign, time_stamp]):
  235. return response.json(444)
  236. try:
  237. if not CommonService.check_time_stamp_token(sign, time_stamp):
  238. return response.json(13)
  239. now_time = int(time.time())
  240. with transaction.atomic():
  241. unicom_device_qs = UnicomDeviceInfo.objects.filter(serial_no=serial_no)
  242. if not unicom_device_qs.exists():
  243. return response.json(173)
  244. unicom_device_qs.update(main_card=int(main_card), updated_time=now_time)
  245. return response.json(0)
  246. except Exception as e:
  247. print(e.args)
  248. ex = traceback.format_exc()
  249. print(ex)
  250. return response.json(177, ex)
  251. @classmethod
  252. def get_device_info(cls, request_dict, response):
  253. """
  254. 获取设备信息
  255. @param request_dict:
  256. @param response:
  257. @return:
  258. """
  259. serial_no = request_dict.get('serialNumber', None)
  260. if not serial_no:
  261. return response.json(444)
  262. unicom_device_info_qs = UnicomDeviceInfo.objects.filter(serial_no=serial_no).values()
  263. if not unicom_device_info_qs.exists():
  264. return response.json(173)
  265. return response.json(0, dict(unicom_device_info_qs.first()))
  266. @classmethod
  267. def device_add(cls, request_dict, response):
  268. """
  269. 设备绑定iccid
  270. @param request_dict:
  271. @param response:
  272. @return:
  273. """
  274. iccid = request_dict.get('iccid', None)
  275. serial_no = request_dict.get('serialNo', None)
  276. time_stamp = request_dict.get('timeStamp', None)
  277. sign = request_dict.get('sign', None)
  278. logger = logging.getLogger('info')
  279. logger.info('--->设备调用4G注册接口')
  280. if not all([iccid, serial_no, sign, time_stamp]):
  281. return response.json(444)
  282. # 时间戳token校验
  283. if not CommonService.check_time_stamp_token(sign, time_stamp):
  284. return response.json(13)
  285. n_time = int(time.time())
  286. try:
  287. logger.info('--->参数验证通过,sign验证通过')
  288. with transaction.atomic():
  289. # 待完善代码 根据uid与用户id验证系统设备
  290. unicom_device_qs = UnicomDeviceInfo.objects.filter(iccid=iccid)
  291. if unicom_device_qs.exists():
  292. if unicom_device_qs.first().status == 1 and unicom_device_qs.first().serial_no == serial_no:
  293. cls.user_activate_flow(iccid)
  294. return response.json(0)
  295. unicom_obj = UnicomObjeect()
  296. result = unicom_obj.verify_device(iccid=iccid)
  297. if result.status_code == 200 and result.text:
  298. res_dict = json.loads(result.text)
  299. if res_dict['success']:
  300. if res_dict['data']['status'] == 0:
  301. logger.info('--->设备请求绑定{}验证不存在{}'.format(iccid, res_dict))
  302. return response.json(173)
  303. params = {'iccid': iccid, 'serial_no': serial_no, 'updated_time': n_time,
  304. 'created_time': n_time}
  305. unicom_obj.change_device_to_activate(iccid)
  306. UnicomDeviceInfo.objects.create(**params)
  307. return response.json(0)
  308. else:
  309. logger.info('--->设备请求绑定{}验证失败'.format(iccid))
  310. return response.json(173)
  311. except Exception as e:
  312. print(e)
  313. logger.info('--->设备调用4G注册接口异常')
  314. return response.json(177, repr(e))
  315. @classmethod
  316. def user_activate_flow(cls, iccid):
  317. """
  318. 用户激活初始化流量套餐
  319. @param iccid:
  320. @return:
  321. """
  322. logger = logging.getLogger('info')
  323. try:
  324. while transaction.atomic():
  325. now_time = int(time.time())
  326. unicom_device_info_qs = UnicomDeviceInfo.objects.filter(iccid=iccid)
  327. if not unicom_device_info_qs.exists():
  328. return False
  329. unicom_device_info_qs = unicom_device_info_qs.first()
  330. if unicom_device_info_qs.status != 1:
  331. logger.info('---->用户激活iccid={},业务系统状态为{}'.format(iccid, unicom_device_info_qs.status))
  332. return False
  333. # 联通业务逻辑
  334. unicom_api = UnicomObjeect()
  335. unicom_api.change_device_to_activate(iccid)
  336. # 查看是否体验过免费套餐
  337. experience_history_qs = UnicomComboExperienceHistory.objects.filter(iccid=iccid)
  338. if not experience_history_qs.exists():
  339. logger.info('---->用户首次激活iccid={}'.format(iccid))
  340. combo_qs = UnicomCombo.objects.filter(combo_type=1, status=0, is_del=False) \
  341. .values('id', 'expiration_type', 'expiration_days', 'combo_type')
  342. if combo_qs.exists():
  343. combo_qs = combo_qs.first()
  344. # 保存体验记录
  345. experience_history_vo = {'iccid': iccid, 'experience_type': 0, 'do_time': now_time}
  346. UnicomComboExperienceHistory.objects.create(**experience_history_vo)
  347. # 保存套餐激活信息
  348. cls.create_combo_order_info('', 0, iccid, combo_qs['id'])
  349. # 修改业务联通卡设备激活信息
  350. UnicomDeviceInfo.objects.filter(iccid=iccid).update(status=2, updated_time=now_time)
  351. return True
  352. except Exception as e:
  353. print(e)
  354. return False
  355. @classmethod
  356. def save_unicom_combo(cls, request_dict, response):
  357. """
  358. 联通套餐保存
  359. @param request_dict:
  360. @param response:
  361. @return:
  362. """
  363. combo_id = request_dict.get('id', None)
  364. combo_name = request_dict.get('comboName', None)
  365. flow_total = request_dict.get('flowTotal', None)
  366. expiration_days = request_dict.get('expirationDays', None)
  367. expiration_type = request_dict.get('expirationType', None)
  368. price = request_dict.get('price', None)
  369. remark = request_dict.get('remark', None)
  370. pay_type = request_dict.get('payType', '').split(',')
  371. if not all([pay_type, combo_name, flow_total, expiration_days, expiration_type, price]):
  372. return response.json(444)
  373. try:
  374. flow_total = int(flow_total)
  375. expiration_days = int(expiration_days)
  376. expiration_type = int(expiration_type)
  377. with transaction.atomic():
  378. re_data = {
  379. 'combo_name': combo_name,
  380. 'flow_total': flow_total,
  381. 'expiration_days': expiration_days,
  382. 'expiration_type': expiration_type,
  383. 'price': price,
  384. }
  385. if remark:
  386. re_data['remark'] = remark
  387. if combo_id:
  388. UnicomCombo.objects.filter(id=combo_id).update(**re_data)
  389. UnicomCombo.objects.get(id=combo_id).pay_type.set(pay_type)
  390. return response.json(0)
  391. UnicomCombo.objects.create(**re_data).pay_type.set(pay_type)
  392. return response.json(0)
  393. except Exception as e:
  394. print(e)
  395. return response.json(177, repr(e))
  396. @classmethod
  397. def query_package_list(cls, response):
  398. """
  399. 查询套餐列表
  400. @return:
  401. """
  402. try:
  403. combo_qs = UnicomCombo.objects.filter(is_show=1, status=0, is_del=False) \
  404. .order_by('sort').values('id', 'combo_name',
  405. 'flow_total',
  406. 'expiration_days',
  407. 'expiration_type', 'price',
  408. 'remark')
  409. if not combo_qs.exists():
  410. return response.json(0, [])
  411. combo_list = []
  412. for item in combo_qs:
  413. # 获取支付方式列表
  414. pay_type_qs = Pay_Type.objects.filter(unicomcombo=item['id']).values('id', 'payment')
  415. combo_list.append({
  416. 'id': item['id'],
  417. 'comboName': item['combo_name'],
  418. 'flowTotal': item['flow_total'],
  419. 'expirationDays': item['expiration_days'],
  420. 'expirationType': item['expiration_type'],
  421. 'price': item['price'],
  422. 'remark': item['remark'],
  423. 'payTypes': list(pay_type_qs),
  424. })
  425. return response.json(0, combo_list)
  426. except Exception as e:
  427. print(e)
  428. return response.json(177, repr(e))
  429. @classmethod
  430. def buy_unicom_combo(cls, user_id, request_dict, request, response):
  431. """
  432. 购买联通套餐
  433. @return:
  434. """
  435. try:
  436. with transaction.atomic():
  437. iccid = request_dict.get('iccid', None)
  438. combo_id = request_dict.get('id', None)
  439. pay_type = request_dict.get('payType', None)
  440. activate_type = request_dict.get('activateType', 0)
  441. if not all([iccid, combo_id, pay_type]):
  442. return response.json(444)
  443. combo_id = int(combo_id)
  444. pay_type = int(pay_type)
  445. now_time = int(time.time())
  446. unicom_combo_qs = UnicomCombo.objects.filter(id=combo_id, pay_type=pay_type, is_show=1, is_del=False,
  447. status=0) \
  448. .values('id', 'combo_name', 'price', 'remark')
  449. if not unicom_combo_qs.exists():
  450. return response.json(173)
  451. unicom_device_qs = UnicomDeviceInfo.objects.filter(iccid=iccid) \
  452. .values('serial_no')
  453. if not unicom_device_qs.exists():
  454. return response.json(173)
  455. unicom_combo_qs = unicom_combo_qs.first()
  456. price = unicom_combo_qs['price']
  457. if not price:
  458. return response.json(173)
  459. unicom_device_qs = unicom_device_qs.first()
  460. device_uid = CommonService.query_uid_with_serial(unicom_device_qs['serial_no'])
  461. order_id = CommonService.createOrderID()
  462. rank_id, ai_rank_id = cls.get_cloud_or_ai_combo()
  463. order_dict = {'rank_id': rank_id, 'ai_rank_id': ai_rank_id, 'orderID': order_id, 'UID': device_uid,
  464. 'userID_id': user_id, 'desc': unicom_combo_qs['combo_name'], 'payType': pay_type,
  465. 'payTime': now_time, 'price': price, 'currency': 'CNY', 'addTime': now_time,
  466. 'updTime': now_time,
  467. 'unify_combo_id': str(unicom_combo_qs['id']), 'order_type': 2,
  468. }
  469. params = 'lang=cn' + '&activateType=' + activate_type
  470. result = {'result_code': 0, 'reason': 'success', 'error_code': 0}
  471. if pay_type == 2: # 支付宝
  472. pay_price = PayService.get_two_float(price, 2)
  473. notify_url = 'unicom/wap/pay/ali-notify'
  474. order_dict['pay_url'] = PayService.create_alipay_payment(params, order_id, pay_price,
  475. unicom_combo_qs['combo_name'],
  476. notify_url,
  477. unicom_combo_qs['remark'], response)
  478. res_data = {'redirectUrl': order_dict['pay_url'], 'orderID': order_id}
  479. elif pay_type == 3: # 微信支付
  480. notify_url = 'unicom/wap/pay/wechat-notify'
  481. ip = CommonService.get_ip_address(request)
  482. params = 'activateType=' + activate_type
  483. sign_params = PayService.create_wechat_payment(params, order_id,
  484. price, ip,
  485. notify_url,
  486. unicom_combo_qs['remark'],
  487. response)
  488. result['result'] = sign_params
  489. else:
  490. return response.json(444, {'param': 'pay_type'})
  491. Order_Model.objects.create(**order_dict)
  492. if pay_type == 3:
  493. return JsonResponse(status=200, data=result)
  494. return response.json(0, res_data)
  495. except Exception as e:
  496. print(e)
  497. return response.json(500, repr(e))
  498. @staticmethod
  499. def get_cloud_or_ai_combo():
  500. """
  501. 获取云存或者AI套餐id
  502. @return:
  503. """
  504. rank_id = Store_Meal.objects.all().order_by('sort').values().first()['id']
  505. ai_rank_id = AiStoreMeal.objects.all().values().first()['id']
  506. return rank_id, ai_rank_id
  507. @classmethod
  508. def query_device_usage_history(cls, request_dict, response):
  509. """
  510. 查询实时已用总流量API
  511. @return:
  512. """
  513. iccid = request_dict.get('iccid', None)
  514. if not iccid:
  515. return response.json(444)
  516. unicom_api = UnicomObjeect()
  517. flow = unicom_api.get_flow_usage_total(iccid)
  518. return response.json(0, flow)
  519. @staticmethod
  520. def package_callback_notify(request_dict, request):
  521. """
  522. 异步套餐订购回调
  523. @param request_dict:
  524. @param request:
  525. @return:
  526. """
  527. logger = logging.getLogger('info')
  528. try:
  529. logger.info('联通异步套餐订购回调参数{}'.format(request_dict))
  530. body = request.body.decode("utf-8")
  531. if body:
  532. dict_data = json.loads(body)
  533. sign = dict_data['sign']
  534. logger.info('设备订购异步回调请求参数{}'.format(dict_data))
  535. dict_data.pop('sign')
  536. unicom_obj = UnicomObjeect()
  537. generate_sign = unicom_obj.createSign(**dict_data)
  538. logger.info('设备订购请求签名{}'.format(sign))
  539. logger.info('设备订购生成签名{}'.format(generate_sign))
  540. r_data = {'success': True, 'msg': '成功'}
  541. return HttpResponse(json.dumps(r_data, ensure_ascii=False), content_type="application/json,charset=utf-8")
  542. except Exception as e:
  543. print(repr(e))
  544. r_data = {'success': False, 'msg': '失败'}
  545. return HttpResponse(json.dumps(r_data, ensure_ascii=False), content_type="application/json,charset=utf-8")
  546. @staticmethod
  547. def device_queue_monitoring_push(request_dict, request):
  548. """
  549. 设备套餐队列用完或者到期推送
  550. @param request_dict:
  551. @param request:
  552. @return:
  553. """
  554. logger = logging.getLogger('info')
  555. try:
  556. logger.info('设备套餐队列推送{}'.format(request_dict))
  557. body = request.body.decode("utf-8")
  558. if body:
  559. dict_data = json.loads(body)
  560. sign = dict_data['sign']
  561. logger.info('设备套餐队列回调请求参数{}'.format(dict_data))
  562. dict_data.pop('sign')
  563. unicom_obj = UnicomObjeect()
  564. generate_sign = unicom_obj.createSign(**dict_data)
  565. logger.info('设备套餐队列请求签名{}'.format(sign))
  566. logger.info('设备套餐队列生成签名{}'.format(generate_sign))
  567. r_data = {'success': True, 'msg': '成功'}
  568. return HttpResponse(json.dumps(r_data, ensure_ascii=False), content_type="application/json,charset=utf-8")
  569. except Exception as e:
  570. print(repr(e))
  571. r_data = {'success': False, 'msg': '失败'}
  572. return HttpResponse(json.dumps(r_data, ensure_ascii=False), content_type="application/json,charset=utf-8")
  573. @staticmethod
  574. def device_status_change_push(request_dict, request):
  575. """
  576. 设备状态变更推送执行场景说明
  577. @param request_dict:
  578. @param request:
  579. @return:
  580. """
  581. logger = logging.getLogger('info')
  582. try:
  583. logger.info('设备状态变更推送{}'.format(request_dict))
  584. body = request.body.decode("utf-8")
  585. if body:
  586. dict_data = json.loads(body)
  587. sign = dict_data['sign']
  588. logger.info('设备状态变更推送请求参数{}'.format(dict_data))
  589. dict_data.pop('sign')
  590. unicom_obj = UnicomObjeect()
  591. generate_sign = unicom_obj.createSign(**dict_data)
  592. logger.info('联通设备状态变更推送请求签名{}'.format(sign))
  593. logger.info('联通设备状态变更推送生成签名{}'.format(generate_sign))
  594. assert generate_sign == sign
  595. now_time = int(time.time())
  596. re_data = {
  597. 'iccid': dict_data['iccid'],
  598. 'serial_no': dict_data['serialNo'],
  599. 'sign': sign,
  600. 'type': dict_data['type'],
  601. 'previous_val': dict_data['previousVal'],
  602. 'current_val': dict_data['currentVal'],
  603. 'reason': dict_data['reason'],
  604. 'time': dict_data['time'],
  605. 'updated_time': now_time,
  606. 'created_time': now_time
  607. }
  608. UnicomDeviceStatusChangePush.objects.create(**re_data)
  609. r_data = {'success': True, 'msg': '成功'}
  610. return HttpResponse(json.dumps(r_data, ensure_ascii=False), content_type="application/json,charset=utf-8")
  611. except Exception as e:
  612. print(repr(e))
  613. r_data = {'success': False, 'msg': '失败'}
  614. return HttpResponse(json.dumps(r_data, ensure_ascii=False), content_type="application/json,charset=utf-8")
  615. @classmethod
  616. def create_combo_order_info(cls, order_id, activate_type, iccid, combo_id):
  617. """
  618. 创建套餐生效记录
  619. @param order_id: 订单id
  620. @param activate_type: 激活类型
  621. @param iccid: 联通20位iccid
  622. @param combo_id: 套餐id
  623. @return: True Or False
  624. """
  625. logger = logging.getLogger('info')
  626. logger.info('创建联通订单套餐信息,订单id{}'.format(order_id))
  627. try:
  628. today = datetime.datetime.today()
  629. year = today.year
  630. month = today.month
  631. with transaction.atomic():
  632. unicom_combo_qs = UnicomCombo.objects.filter(id=int(combo_id)).values()
  633. if unicom_combo_qs.exists():
  634. unicom_combo = unicom_combo_qs.first()
  635. now_time = int(time.time())
  636. combo_order_qs = UnicomComboOrderInfo.objects.filter(status=1, iccid=iccid)
  637. status = 0
  638. if not combo_order_qs.exists():
  639. status = 1
  640. combo_order_data = {'iccid': iccid, 'status': status, 'combo_id': int(combo_id),
  641. 'updated_time': now_time,
  642. 'created_time': now_time,
  643. 'year': year, 'month': month}
  644. if order_id:
  645. combo_order_data['order_id'] = order_id
  646. # 有效期类型 1 等于自然月,0天数
  647. if unicom_combo['expiration_type'] == 1:
  648. # 激活类型 1=下月激活 否则等于当月激活
  649. if activate_type == 1:
  650. combo_order_data['next_month_activate'] = True
  651. next_start_time, end_time = cls.get_next_month_data_time()
  652. combo_order_data['activation_time'] = next_start_time
  653. combo_order_data['expire_time'] = end_time
  654. combo_order_data['status'] = 0
  655. else:
  656. start_time, month_end_time = cls.get_month_start_and_end_time()
  657. combo_order_data['activation_time'] = now_time
  658. combo_order_data['expire_time'] = month_end_time
  659. elif unicom_combo['expiration_type'] == 0:
  660. days = unicom_combo['expiration_days']
  661. zero_today, end_time = cls.get_data_time(days)
  662. combo_order_data['activation_time'] = now_time
  663. combo_order_data['expire_time'] = end_time
  664. # 联通业务逻辑
  665. unicom_api = UnicomObjeect()
  666. if status == 1:
  667. unicom_api.change_device_to_activate(iccid)
  668. flow_total_usage = unicom_api.get_flow_usage_total(iccid)
  669. if flow_total_usage > 0:
  670. flow_total_usage = Decimal(flow_total_usage)
  671. flow_total_usage = flow_total_usage.quantize(Decimal('0.00'))
  672. else:
  673. flow_total_usage = 0
  674. combo_order_data['flow_total_usage'] = str(flow_total_usage)
  675. UnicomComboOrderInfo.objects.create(**combo_order_data)
  676. logger.info('保存套餐支付信息success')
  677. return True
  678. except Exception as e:
  679. print(e)
  680. return False
  681. @staticmethod
  682. def get_next_month_data_time():
  683. """
  684. 获取下个月开始时间与结束时间戳
  685. @return: next_start_time,end_time
  686. """
  687. next_month_start = LocalDateTimeUtil.get_next_month_start()
  688. next_start_time, next_end_time = LocalDateTimeUtil.get_start_and_end_time(next_month_start, '%Y-%m-%d')
  689. next_month_end = LocalDateTimeUtil.get_next_month_end()
  690. start_time, end_time = LocalDateTimeUtil.get_start_and_end_time(next_month_end, '%Y-%m-%d')
  691. return next_start_time, end_time
  692. @staticmethod
  693. def get_data_time(days):
  694. """
  695. 获取今天开始时间以及days后日期结束时间戳
  696. @return: next_start_time,end_time
  697. """
  698. zero_today, last_today = LocalDateTimeUtil.get_today_date(True)
  699. now_time = int(time.time())
  700. after_time = LocalDateTimeUtil.get_after_days_timestamp(now_time, days)
  701. time_array = time.localtime(after_time)
  702. start_time, end_time = LocalDateTimeUtil.get_start_and_end_time(time.strftime("%Y-%m-%d", time_array),
  703. '%Y-%m-%d')
  704. return zero_today, end_time
  705. @staticmethod
  706. def get_month_start_and_end_time():
  707. """
  708. 获取当天开始时间与当月结束时间戳
  709. @return:
  710. """
  711. zero_today, last_today = LocalDateTimeUtil.get_today_date(True)
  712. month_end = LocalDateTimeUtil.get_cur_month_end()
  713. start_time, month_end_time = LocalDateTimeUtil.get_start_and_end_time(month_end, '%Y-%m-%d')
  714. return zero_today, month_end_time
  715. @classmethod
  716. def get_test_sign(cls, request_dict, response):
  717. """
  718. 测试盐加密解密
  719. @param request_dict:
  720. @param response:
  721. @return:
  722. """
  723. verify = request_dict.get('verify', False)
  724. if verify:
  725. sign = request_dict.get('sign')
  726. time_stamp = request_dict.get('timeStamp')
  727. sign = CommonService.check_time_stamp_token(sign, time_stamp)
  728. if not sign:
  729. return response.json(13)
  730. return response.json(0)
  731. now_time = int(time.time())
  732. sign = CommonService.encode_data(str(now_time))
  733. return response.json(0, {'sign': sign, 'timeStamp': now_time})