UnicomManageController.py 74 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617
  1. # Copyright (C) 2022 #
  2. # @Time : 2022/7/18 16:16
  3. # @Author : ghl
  4. # @Email : Guanhailogn@asj6.wecom.work
  5. # @File : UnicomManageController.py
  6. # @Software: PyCharm
  7. import datetime
  8. import hashlib
  9. import json
  10. import random
  11. import threading
  12. import time
  13. import uuid
  14. from decimal import Decimal
  15. from math import ceil
  16. import openpyxl
  17. import requests
  18. from django.db import transaction, connection
  19. from django.db.models import Q, F
  20. from django.http import HttpResponse
  21. from django.views.generic.base import View
  22. from Ansjer.config import CONFIG_INFO
  23. from Ansjer.config import LOGGER
  24. from Controller.UnicomCombo.UnicomComboController import UnicomComboView
  25. from Model.models import UnicomDeviceInfo, UnicomCombo, Pay_Type, UnicomComboOrderInfo, Device_User, Order_Model, \
  26. ExchangeCode, UnicomFlowPush, SysMsgModel, UnicomComboExperienceHistory, LogModel, SerialNumberPackage, \
  27. AccessNumberTaskQueue
  28. from Object.EIoTClubObject import EIoTClubObject
  29. from Object.Enums.WXOperatorEnum import WXOperatorEnum
  30. from Object.RedisObject import RedisObject
  31. from Object.ResponseObject import ResponseObject
  32. from Object.TokenObject import TokenObject
  33. from Object.UnicomObject import UnicomObjeect
  34. from Object.WXTechObject import WXTechObject
  35. from Service.CommonService import CommonService
  36. from Service.TelecomService import TelecomService
  37. UNICOM_MANAGE_LOCK = 'BASIC:UNICOM:MANAGE:OPERATION:LOCK'
  38. class UnicomManageControllerView(View):
  39. def get(self, request, *args, **kwargs):
  40. request.encoding = 'utf-8'
  41. operation = kwargs.get('operation')
  42. return self.validation(request.GET, request, operation)
  43. def post(self, request, *args, **kwargs):
  44. request.encoding = 'utf-8'
  45. operation = kwargs.get('operation')
  46. return self.validation(request.POST, request, operation)
  47. def validation(self, request_dict, request, operation):
  48. response = ResponseObject()
  49. # 获取支付类型
  50. if operation == 'get/pay':
  51. return self.get_pay_type(response)
  52. # 获取套餐类型
  53. elif operation == 'combo/type':
  54. return self.get_unicom_combo_type(response)
  55. else:
  56. tko = TokenObject(
  57. request.META.get('HTTP_AUTHORIZATION'),
  58. returntpye='pc')
  59. if tko.code != 0:
  60. return response.json(tko.code)
  61. response.lang = tko.lang
  62. userID = tko.userID
  63. # 获取套餐详细表
  64. if operation == 'get/deta/info':
  65. return self.get_unicom_info(request_dict, response)
  66. # 添加和编辑卡套餐
  67. elif operation == 'edit/combo':
  68. return self.edit_combo(request_dict, response)
  69. # 统计4G套餐
  70. elif operation == 'getComboDataList':
  71. return self.static_info(request_dict, response)
  72. # 删除卡套餐
  73. elif operation == 'dele/combo/info':
  74. return self.combo_order_info(request_dict, response)
  75. # 获取/筛选用户信息
  76. elif operation == 'filter/user':
  77. return self.get_user_info(request_dict, response)
  78. # 充值流量
  79. elif operation == 'getFlowPackages':
  80. return self.get_flow_packages(request_dict, response)
  81. # 获取/筛选4G流量卡订单信息
  82. elif operation == 'query-order':
  83. return self.query_4G_user_order(request_dict, response)
  84. elif operation == 'sim-info':
  85. return self.get_iccid_info(request_dict, response)
  86. elif operation == 'batchGenerateCDK': # 批量生成兑换码
  87. return self.create_package_cdk(request_dict, response)
  88. elif operation == 'getExchangeCodePage': # 分页获取兑换码
  89. return self.get_exchange_code_page(request_dict, response)
  90. elif operation == 'updateExchangeCode': # 修改兑换码
  91. return self.update_exchange_code(request_dict, response)
  92. elif operation == 'resetCardPackage': # 单卡重置流量
  93. return self.reset_card_package(request, request_dict, response, tko.user)
  94. elif operation == 'getPackageDetails':
  95. return self.get_package_details(request_dict, response)
  96. elif operation == 'asyncUpdateStatus':
  97. return self.async_update_status(request_dict, response)
  98. elif operation == 'getFlowComboList': # 获取流量套餐列表
  99. return self.get_flow_combo_list(request_dict, response)
  100. elif operation == 'downloadCDK': # 下载兑换码
  101. return self.package_cdk_export_excel(response)
  102. elif operation == 'uploadSerialNumberFile': # 上传序列号文件绑定4G套餐
  103. return self.serial_number_bind_package_bulk(userID, tko.user, request, request_dict, response)
  104. elif operation == 'iccidBatchReset': # 批量重置流量
  105. return self.iccid_batch_reset(tko.user, request, request_dict, response)
  106. elif operation == 'orderFlowPackage': # 订购流量套餐包
  107. return self.order_flow_package(request_dict, response, userID)
  108. elif operation == 'getSerialNumberPackagePage': # 分页获取序列号绑定套餐
  109. return self.serial_number_package_page(request_dict, response)
  110. elif operation == 'serialNumberPackageUpdate': # 序列号绑定套餐修改
  111. return self.serial_number_package_update(request_dict, response, tko.user)
  112. elif operation == 'transferDevicePackage': # 转移设备套餐
  113. return self.transfer_device_package(request_dict, response, tko.user)
  114. elif operation == 'updateExpirationDate': # 修改套餐过期时间
  115. return self.update_expiration_date(request_dict, response)
  116. elif operation == 'batchOrderFlowPackage': # 批量订购流量套餐包
  117. return self.batch_order_flow_package(request, request_dict, response, userID)
  118. if operation == 'verifyPackageExport':
  119. return self.verify_package_export_excel(request, request_dict, response)
  120. else:
  121. return response.json(404)
  122. @classmethod
  123. def order_flow_package(cls, request_dict, response, user_id):
  124. """
  125. 订购流量套餐包
  126. """
  127. try:
  128. serial_number = request_dict.get('serialNumber', None)
  129. package_id = request_dict.get('packageId', None)
  130. if not all([serial_number, package_id]):
  131. return response.json(444)
  132. serial_number = serial_number[0:9]
  133. result = UnicomComboView().generate_flow_package(serial_number, int(package_id), user_id)
  134. LOGGER.info(f'{serial_number}订购流量套餐包,createdBy:{user_id},result:{result}')
  135. if not result:
  136. response.json(503)
  137. return response.json(0)
  138. except Exception as e:
  139. LOGGER.info('UnicomManageControllerView.order_flow_package,errLine:{}, errMsg:{}'
  140. .format(e.__traceback__.tb_lineno, repr(e)))
  141. return response.json(500)
  142. @classmethod
  143. def reset_card_package(cls, request, request_dict, response, user):
  144. """
  145. iccid单卡重置流量
  146. @param request: 请求体
  147. @param request_dict: 请求参数
  148. @param response: 响应体
  149. @param user: 用户名称
  150. @return: 重置结果
  151. """
  152. try:
  153. serial_number = request_dict.get('serialNumber', None)
  154. if not serial_number:
  155. return response.json(444)
  156. device_info_qs = UnicomDeviceInfo.objects.filter(serial_no=serial_number)
  157. now_time = int(time.time())
  158. if device_info_qs.exists(): # 首先查询SIM卡绑定信息是否存在
  159. if device_info_qs.count() > 1:
  160. return response.json(177)
  161. iccid = device_info_qs.first().iccid
  162. # 根据序列号重置出厂流量套餐
  163. serial_package_qs = SerialNumberPackage.objects.filter(~Q(status=1), serial_number=serial_number)
  164. if serial_package_qs.exists():
  165. serial_package_qs.update(status=1, updated_time=now_time, updated_by=user)
  166. if device_info_qs.first().card_type == 1: # 五兴电信API删除所有套餐历史
  167. data = {'iccids': iccid, 'operator': WXOperatorEnum.TELECOM.value}
  168. wx_tech = WXTechObject()
  169. res = wx_tech.delete_card_package(**data)
  170. if res['code'] == '0':
  171. UnicomComboExperienceHistory.objects.filter(iccid=iccid).delete()
  172. LOGGER.info(f"{serial_number}电信重置流量成功:{json.dumps(res)}")
  173. return response.json(0)
  174. return response.json(176)
  175. flow_push_qs = UnicomFlowPush.objects.filter(serial_no=serial_number)
  176. if flow_push_qs.exists(): # 删除流量预警推送
  177. flow_push_qs.delete()
  178. sys_msg_qs = SysMsgModel.objects.filter(uid=serial_number)
  179. if sys_msg_qs.exists(): # 删除有关系统消息数据
  180. sys_msg_qs.delete()
  181. # 将4G用户信息状态改为已完成测试状态
  182. device_info_qs.update(status=2, updated_time=now_time, user_id='')
  183. combo_order_qs = UnicomComboOrderInfo.objects.filter(iccid=iccid)
  184. if combo_order_qs.exists():
  185. combo_order_qs.delete()
  186. # 删除免费体验记录
  187. combo_experience_history_qs = UnicomComboExperienceHistory.objects.filter(iccid=iccid)
  188. if combo_experience_history_qs.exists():
  189. combo_experience_history_qs.delete()
  190. # 重置流量后,恢复测试流量
  191. result = UnicomComboView().activate_test_flow_package(serial_number)
  192. ip = CommonService.get_ip_address(request)
  193. describe = '重置4G流量序列号{},iccid:{},{}'.format(serial_number, iccid, result)
  194. # 当前缓存是客户首次扫序列号,激活赠送测试流量生成的,重置流量所以要清除
  195. key = f'ASJ:UNICOM:CARD:ACTIVATE:{serial_number}'
  196. redis = RedisObject()
  197. redis.del_data(key)
  198. cls.create_operation_log('unicom/manage/resetCardPackage', ip, request_dict, describe)
  199. return response.json(0)
  200. return response.json(173)
  201. except Exception as e:
  202. LOGGER.info('异常详情,errLine:{}, errMsg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
  203. return response.json(500)
  204. @classmethod
  205. def generate_card_package_order(cls, iccid, serial_number):
  206. """
  207. 模拟设备上电赠送1G
  208. @param iccid:
  209. @param serial_number:
  210. @return:
  211. """
  212. url = 'https://www.zositechc.cn/' if CONFIG_INFO == 'cn' else 'https://test.zositechc.cn/'
  213. url = url + 'unicom/api/device-bind'
  214. now_time = int(time.time())
  215. sign = CommonService.encode_data(str(now_time))
  216. data = {
  217. 'iccid': iccid,
  218. 'serialNo': serial_number,
  219. 'timeStamp': now_time,
  220. 'sign': sign,
  221. 'sim': 1
  222. }
  223. response = requests.post(url=url, data=data, timeout=5)
  224. LOGGER.info(f"生成体验套餐结果:{json.loads(response.text)}")
  225. @classmethod
  226. def create_operation_log(cls, url, ip, request_dict, describe):
  227. """
  228. 存入操作日志
  229. @param url: 请求路径
  230. @param describe: 描述
  231. @param ip: 当前IP
  232. @param request_dict: 请求参数
  233. @return: True | False
  234. """
  235. try:
  236. # 记录操作日志
  237. content = json.loads(json.dumps(request_dict))
  238. log = {
  239. 'ip': ip,
  240. 'user_id': 1,
  241. 'status': 200,
  242. 'time': int(time.time()),
  243. 'content': json.dumps(content),
  244. 'url': url,
  245. 'operation': describe,
  246. }
  247. LogModel.objects.create(**log)
  248. return True
  249. except Exception as e:
  250. print('日志异常,errLine:{}, errMsg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
  251. return False
  252. def get_user_info(self, request_dict, response):
  253. """
  254. 获取/筛选卡用户信息
  255. @param request_dict:
  256. @param response:
  257. @return:
  258. NickName:用户昵称 phone: 电话
  259. serial_no: 设备序列号
  260. """
  261. NickName = request_dict.get('NickName', None)
  262. phone = request_dict.get('phone', None)
  263. iccid = request_dict.get('iccid', None)
  264. serial_no = request_dict.get('serialNo', None)
  265. status = request_dict.get('status')
  266. pageSize = request_dict.get('pageSize', None)
  267. pageNo = request_dict.get('pageNo', None)
  268. if not all({pageNo, pageSize}):
  269. return response.json(444)
  270. page = int(pageNo)
  271. line = int(pageSize)
  272. try:
  273. unicom_device_qs = UnicomDeviceInfo.objects.all().order_by('-updated_time')
  274. device_user_qs = Device_User.objects.filter().values(
  275. 'userID', 'NickName', 'phone')
  276. if status:
  277. unicom_device_qs = unicom_device_qs.filter(status=status)
  278. if iccid:
  279. unicom_device_qs = unicom_device_qs.filter(iccid__icontains=iccid)
  280. if serial_no:
  281. unicom_device_qs = unicom_device_qs.filter(serial_no__icontains=serial_no)
  282. if NickName:
  283. device_user_qs = device_user_qs.filter(NickName__icontains=NickName)
  284. if not device_user_qs.exists():
  285. return response.json(0, [])
  286. userID = device_user_qs.first()['userID']
  287. unicom_device_qs = unicom_device_qs.filter(user_id=userID)
  288. if phone:
  289. device_user_qs = device_user_qs.filter(phone=phone)
  290. if not device_user_qs.exists():
  291. return response.json(0, [])
  292. userID = device_user_qs.first()['userID']
  293. unicom_device_qs = unicom_device_qs.filter(user_id=userID)
  294. total = unicom_device_qs.count()
  295. unicom_device_qs = unicom_device_qs[(page - 1) * line:page * line]
  296. list_data = []
  297. for unicom_device in unicom_device_qs:
  298. data = {'iccid': unicom_device.iccid, 'serialNo': unicom_device.serial_no,
  299. 'userID': unicom_device.user_id, 'cardType': unicom_device.card_type,
  300. 'status': unicom_device.status, 'mainCard': unicom_device.main_card,
  301. 'createdTime': unicom_device.created_time, 'updatedTime': unicom_device.updated_time,
  302. 'cardStatus': self.get_device_status_by_iccid(unicom_device.iccid, unicom_device.card_type,
  303. unicom_device.access_number)}
  304. device_user_qs = Device_User.objects.filter(userID=unicom_device.user_id).values('username', 'NickName',
  305. 'phone')
  306. data['userName'] = device_user_qs[0]['username'] if device_user_qs.exists() else ''
  307. data['NickName'] = device_user_qs[0]['NickName'] if device_user_qs.exists() else ''
  308. data['phone'] = device_user_qs[0]['phone'] if device_user_qs.exists() else ''
  309. list_data.append(data)
  310. return response.json(0, {'list': list_data, 'total': total})
  311. except Exception as e:
  312. print(e)
  313. return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
  314. @staticmethod
  315. def query_sql_4g():
  316. """
  317. 4G关联查询SQL
  318. @return: str
  319. """
  320. sql = 'SELECT '
  321. sql += 'du.username,du.phone,o.UID as uid,o.`status`,udi.serial_no as serialNo,o.orderID,o.`desc`, '
  322. sql += 'o.price,uo.next_month_activate as nextActivate,uo.iccid,uo.`status` as useStatus,uo.`flow_total_usage`,'
  323. sql += 'uo.updated_time as upTime, uo.activation_time as acTime,uo.expire_time as epTime '
  324. sql += 'FROM orders o '
  325. sql += 'LEFT JOIN unicom_combo_order_info uo ON o.orderID = uo.order_id '
  326. sql += 'INNER JOIN device_user du ON du.userID = o.userID_id '
  327. sql += 'INNER JOIN unicom_device_info udi ON udi.iccid = uo.iccid '
  328. return sql
  329. @staticmethod
  330. def query_4G_user_order(request_dict, response):
  331. """
  332. 查询4G用户订单
  333. """
  334. try:
  335. page = int(request_dict.get('pageNo', 1))
  336. size = int(request_dict.get('pageSize', 10))
  337. user_name = request_dict.get('userName', None)
  338. uid = request_dict.get('uid', None)
  339. serial_no = request_dict.get('serialNo', None)
  340. combo_use_type = request_dict.get('comboUseType', None)
  341. cursor = connection.cursor()
  342. sql = UnicomManageControllerView.query_sql_4g()
  343. sql += 'WHERE o.order_type = %s '
  344. param_list = [2]
  345. if user_name:
  346. sql += "and du.username LIKE %s "
  347. param_list.append(user_name)
  348. if uid:
  349. sql += "and o.UID LIKE %s "
  350. param_list.append(uid)
  351. if serial_no:
  352. sql += "and udi.serial_no LIKE %s "
  353. param_list.append(serial_no)
  354. if combo_use_type:
  355. sql += 'and uo.status = %s '
  356. param_list.append(int(combo_use_type))
  357. cursor.execute(sql, param_list)
  358. total = len(cursor.fetchall())
  359. param_list.append((page - 1) * size)
  360. param_list.append(size, )
  361. sql += 'order by o.addTime DESC LIMIT %s,%s '
  362. cursor.execute(sql, param_list)
  363. data_obj = cursor.fetchall()
  364. cursor.close() # 执行完,关闭
  365. connection.close()
  366. result_list = []
  367. col_names = [desc[0] for desc in cursor.description]
  368. for item in data_obj:
  369. order_dict = dict(zip(col_names, item))
  370. order_dict['using_total'] = 0
  371. result_list.append(order_dict)
  372. return response.json(0, {'orderList': result_list, 'total': total})
  373. except Exception as e:
  374. meg = '异常详情,errLine:{}, errMsg:{}'.format(e.__traceback__.tb_lineno, repr(e))
  375. return response.json(500, meg)
  376. @staticmethod
  377. def check_sim_user(iccid):
  378. """
  379. 检查SIM卡用户
  380. @param iccid:物联卡
  381. @return:
  382. """
  383. u_device_qs = UnicomDeviceInfo.objects.filter(iccid=iccid).values('user_id')
  384. if not u_device_qs.exists() or not u_device_qs[0]['user_id']:
  385. return False
  386. return True
  387. @classmethod
  388. def edit_combo(cls, request_dict, response):
  389. """
  390. 添加和编辑卡套餐
  391. @param request_dict:
  392. @param response:
  393. @return:
  394. """
  395. combo_id = request_dict.get('id', None)
  396. combo_name = request_dict.get('comboName', None)
  397. status = request_dict.get('status', None)
  398. combo_type = request_dict.get('comboType', None)
  399. flow_total = request_dict.get('flowTotal', None)
  400. expiration_days = request_dict.get('expirationDays', None)
  401. expiration_type = request_dict.get('expirationType', None)
  402. pay_type = request_dict.get(
  403. 'payTypes', '')[
  404. 1:-1].split(',') # '[1,2]' -> ['1','2']
  405. sort = request_dict.get('sort', None)
  406. price = request_dict.get('price', None)
  407. remark = request_dict.get('remark', None)
  408. is_show = request_dict.get('isShow', None)
  409. virtualPrice = request_dict.get('virtualPrice', None)
  410. if not all([pay_type, price, is_show, status, combo_type, flow_total, expiration_days, expiration_type]):
  411. return response.json(444)
  412. flow_total = int(flow_total)
  413. expiration_days = int(expiration_days)
  414. expiration_type = int(expiration_type)
  415. status = int(status)
  416. combo_type = int(combo_type)
  417. is_show = int(is_show)
  418. sort = int(sort)
  419. nowTime = int(time.time())
  420. # 判断是编辑还是添加
  421. with transaction.atomic():
  422. try:
  423. re_data = {
  424. 'combo_name': combo_name,
  425. 'status': status,
  426. 'combo_type': combo_type,
  427. 'flow_total': flow_total,
  428. 'expiration_days': expiration_days,
  429. 'expiration_type': expiration_type,
  430. 'price': price,
  431. 'sort': sort,
  432. 'remark': remark if remark else '',
  433. 'is_show': is_show,
  434. 'virtual_price': virtualPrice,
  435. }
  436. if combo_id:
  437. combo_type_qs = UnicomCombo.objects.filter(id=combo_id)
  438. if not combo_type_qs.exists():
  439. return response.json(173)
  440. re_data['updated_time'] = nowTime
  441. combo_type_qs.filter(id=combo_id).update(**re_data)
  442. combo_type_qs.get(id=combo_id).pay_type.set(pay_type)
  443. else:
  444. re_data['updated_time'] = int(time.time())
  445. re_data['created_time'] = int(time.time())
  446. UnicomCombo.objects.create(**re_data).pay_type.set(pay_type)
  447. return response.json(0)
  448. except Exception as e:
  449. return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
  450. @staticmethod
  451. def get_unicom_info(request_dict, response):
  452. """
  453. 获取套餐详细表
  454. @param request_dict:
  455. @param response:
  456. @return:
  457. """
  458. pageNo = request_dict.get('pageNo', None)
  459. pageSize = request_dict.get('pageSize', None)
  460. if not all([pageNo, pageSize]):
  461. return response.json(444)
  462. elif pageNo and pageSize:
  463. pass
  464. page = int(pageNo)
  465. line = int(pageSize)
  466. try:
  467. combo_qs = UnicomCombo.objects.filter(is_del=False) \
  468. .values('id', 'status', 'combo_name',
  469. 'flow_total', 'combo_type',
  470. 'expiration_days',
  471. 'expiration_type', 'price', 'is_unlimited',
  472. 'updated_time', 'created_time',
  473. 'remark', 'is_show', 'sort', 'virtual_price').order_by('-created_time', 'sort')
  474. if not combo_qs.exists():
  475. return response.json(0, [])
  476. total = combo_qs.count()
  477. combo_qs = combo_qs[(page - 1) * line:page * line]
  478. combo_list = []
  479. for item in combo_qs:
  480. # 获取支付方式列表
  481. pay_type_list = [pay_type['id'] for pay_type in
  482. UnicomCombo.objects.get(id=item['id']).pay_type.values('id')]
  483. combo_list.append({
  484. 'id': item['id'],
  485. 'status': item['status'],
  486. 'comboType': item['combo_type'],
  487. 'comboName': item['combo_name'],
  488. 'flowTotal': item['flow_total'],
  489. 'expirationDays': item['expiration_days'],
  490. 'expirationType': item['expiration_type'],
  491. 'price': item['price'],
  492. 'sort': item['sort'],
  493. 'isUnlimited': item['is_unlimited'],
  494. 'updatedTime': item['updated_time'],
  495. 'createdTime': item['created_time'],
  496. 'remark': item['remark'],
  497. 'isShow': item['is_show'],
  498. 'payTypes': pay_type_list,
  499. 'virtualPrice': item['virtual_price']
  500. })
  501. return response.json(0, {'list': combo_list, 'total': total})
  502. except Exception as e:
  503. print(e)
  504. return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
  505. @classmethod
  506. def get_pay_type(cls, response):
  507. """
  508. 获取支付类型
  509. @param response:
  510. @return:
  511. """
  512. pay_type_qs = Pay_Type.objects.all().values('id', 'payment')
  513. if not pay_type_qs.exists():
  514. return response.json(0, [])
  515. pay_type_list = []
  516. for pay_type in pay_type_qs:
  517. pay_type_list.append(pay_type)
  518. return response.json(0, pay_type_list)
  519. @classmethod
  520. def get_unicom_combo_type(cls, response):
  521. """
  522. 获取赠送套餐
  523. @param response:
  524. @return:
  525. """
  526. unicom_combo_qs = UnicomCombo.objects.filter(combo_type=2, status=0).values('id', 'combo_name')
  527. if not unicom_combo_qs.exists():
  528. return response.json(0, [])
  529. combo_list = []
  530. for combo in unicom_combo_qs:
  531. combo_list.append(combo)
  532. return response.json(0, combo_list)
  533. @classmethod
  534. def combo_order_info(cls, request_dict, response):
  535. """
  536. 删除卡套餐信息(修改状态)
  537. @param request_dict
  538. @param response
  539. @return:
  540. """
  541. combo_id = request_dict.get('id', None)
  542. if not combo_id:
  543. return response.json(444)
  544. combo_qs = UnicomCombo.objects.filter(id=combo_id)
  545. # 只修改默认状态
  546. if combo_qs.exists():
  547. combo_qs.update(is_del=True)
  548. return response.json(0)
  549. def static_info(self, request_dict, response):
  550. """
  551. 统计联通套餐
  552. @param request_dict:请求参数
  553. @param response: 响应对象
  554. @param return:
  555. """
  556. year = request_dict.get('year', None)
  557. Jan = int(time.mktime(time.strptime(year + '-1-1 00:00:00', "%Y-%m-%d %H:%M:%S")))
  558. Feb = int(time.mktime(time.strptime(year + '-2-1 00:00:00', "%Y-%m-%d %H:%M:%S")))
  559. Mar = int(time.mktime(time.strptime(year + '-3-1 00:00:00', "%Y-%m-%d %H:%M:%S")))
  560. Apr = int(time.mktime(time.strptime(year + '-4-1 00:00:00', "%Y-%m-%d %H:%M:%S")))
  561. May = int(time.mktime(time.strptime(year + '-5-1 00:00:00', "%Y-%m-%d %H:%M:%S")))
  562. Jun = int(time.mktime(time.strptime(year + '-6-1 00:00:00', "%Y-%m-%d %H:%M:%S")))
  563. Jul = int(time.mktime(time.strptime(year + '-7-1 00:00:00', "%Y-%m-%d %H:%M:%S")))
  564. Aug = int(time.mktime(time.strptime(year + '-8-1 00:00:00', "%Y-%m-%d %H:%M:%S")))
  565. Sep = int(time.mktime(time.strptime(year + '-9-1 00:00:00', "%Y-%m-%d %H:%M:%S")))
  566. Oct = int(time.mktime(time.strptime(year + '-10-1 00:00:00', "%Y-%m-%d %H:%M:%S")))
  567. Nov = int(time.mktime(time.strptime(year + '-11-1 00:00:00', "%Y-%m-%d %H:%M:%S")))
  568. Dec = int(time.mktime(time.strptime(year + '-12-1 00:00:00', "%Y-%m-%d %H:%M:%S")))
  569. Jan_next = int(time.mktime(time.strptime(str(int(year) + 1) + '-1-1 00:00:00', "%Y-%m-%d %H:%M:%S")))
  570. list_data = []
  571. unicom_combo_qs = UnicomCombo.objects.filter().values('id', 'combo_type', 'combo_name')
  572. if not unicom_combo_qs.exists():
  573. return response.json(173)
  574. try:
  575. for unicom_combo in unicom_combo_qs:
  576. name = unicom_combo['combo_name']
  577. combo_order = UnicomComboOrderInfo.objects.filter(combo_id=unicom_combo['id'])
  578. if not combo_order.exists():
  579. continue
  580. Jan_count = combo_order.filter(created_time__range=[Jan, Feb]).count()
  581. Feb_count = combo_order.filter(created_time__range=[Feb, Mar]).count()
  582. Mar_count = combo_order.filter(created_time__range=[Mar, Apr]).count()
  583. Apr_count = combo_order.filter(created_time__range=[Apr, May]).count()
  584. May_count = combo_order.filter(created_time__range=[May, Jun]).count()
  585. Jun_count = combo_order.filter(created_time__range=[Jun, Jul]).count()
  586. Jul_count = combo_order.filter(created_time__range=[Jul, Aug]).count()
  587. Aug_count = combo_order.filter(created_time__range=[Aug, Sep]).count()
  588. Sep_count = combo_order.filter(created_time__range=[Sep, Oct]).count()
  589. Oct_count = combo_order.filter(created_time__range=[Oct, Nov]).count()
  590. Nov_count = combo_order.filter(created_time__range=[Nov, Dec]).count()
  591. Dec_count = combo_order.filter(created_time__range=[Dec, Jan_next]).count()
  592. data = [Jan_count, Feb_count, Mar_count, Apr_count, May_count, Jun_count, Jul_count, Aug_count,
  593. Sep_count,
  594. Oct_count, Nov_count, Dec_count]
  595. cloud_data = {
  596. 'name': name,
  597. 'type': 'line',
  598. 'data': data,
  599. }
  600. list_data.append(cloud_data)
  601. return response.json(0, {'list': list_data})
  602. except Exception as e:
  603. print(e)
  604. return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
  605. @classmethod
  606. def get_flow_packages(cls, request_dict, response):
  607. """
  608. 赠送套餐流量
  609. @param request_dict:请求参数
  610. @username request_dict:用户名
  611. @comboType request_dict:套餐类型
  612. @serialNo request_dict:序列号
  613. @param response: 响应对象
  614. @return:
  615. """
  616. userId = request_dict.get('userId', None)
  617. serialNo = request_dict.get('serialNo', None)
  618. comboId = request_dict.get('comboId', None)
  619. if not all([userId, serialNo, comboId]):
  620. return response.json(444)
  621. try:
  622. while transaction.atomic():
  623. combo_info_qs = UnicomCombo.objects.filter(id=comboId, combo_type=2, status=0) \
  624. .values('id', 'combo_name', 'price', 'virtual_price', 'remark', 'combo_type')
  625. unicom_device_info_qs = UnicomDeviceInfo.objects.filter(serial_no=serialNo,
  626. user_id=userId).values \
  627. ('iccid')
  628. if not unicom_device_info_qs.exists() or not combo_info_qs.exists():
  629. return response.json(173)
  630. combo_info_qs = combo_info_qs.first()
  631. unicom_device_info_qs = unicom_device_info_qs.first()
  632. n_time = int(time.time())
  633. order_id = CommonService.createOrderID() # 生成订单号
  634. # 赠送套餐下个月生效
  635. unicom_combo = UnicomComboView.create_combo_order_info(order_id=order_id, activate_type=1,
  636. iccid=unicom_device_info_qs['iccid'],
  637. combo_id=comboId)
  638. if unicom_combo is False:
  639. return response.json(178)
  640. rank_id, ai_rank_id = UnicomComboView.get_cloud_or_ai_combo() # 生成订单必须添加该字段
  641. uid = CommonService.get_uid_by_serial_number(serialNo) # 获取序列号或UID
  642. # 获取套餐信息
  643. order_dict = {
  644. 'orderID': order_id,
  645. 'UID': uid,
  646. 'rank_id': rank_id,
  647. 'ai_rank_id': ai_rank_id,
  648. 'userID_id': userId,
  649. 'desc': combo_info_qs['combo_name'],
  650. 'payType': 10,
  651. 'payTime': n_time,
  652. 'price': combo_info_qs['price'],
  653. 'addTime': n_time,
  654. 'updTime': n_time,
  655. 'status': 1,
  656. 'unify_combo_id': str(combo_info_qs['id']),
  657. 'order_type': 2,
  658. 'store_meal_name': combo_info_qs['combo_name']
  659. }
  660. Order_Model.objects.create(**order_dict)
  661. return response.json(0)
  662. except Exception as e:
  663. print(e)
  664. return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
  665. @classmethod
  666. def get_iccid_info(cls, request_dict, response):
  667. """
  668. 获取联通iccid最新状态
  669. """
  670. try:
  671. iccid = request_dict.get('iccid', None)
  672. if not iccid:
  673. return response.json(444)
  674. re_data = {'iccid': iccid}
  675. result = UnicomObjeect().query_device_status(**re_data)
  676. res_dict = UnicomObjeect().get_text_dict(result)
  677. # 状态不等于1(激活)时进行激活 1:激活;2:停用
  678. return response.json(0, res_dict['data']['status'])
  679. except Exception as e:
  680. print(e)
  681. return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
  682. @classmethod
  683. def package_cdk_export_excel(cls, response):
  684. """
  685. 流量包兑换码导出excel
  686. """
  687. try:
  688. # 创建一个新的excel文档
  689. wb = openpyxl.Workbook()
  690. # 获取默认的工作表
  691. sheet = wb.active
  692. sheet.title = '周视国内流量年卡兑换码'
  693. sheet.column_dimensions['A'].width = 15
  694. sheet.column_dimensions['B'].width = 20
  695. exchange_code = ExchangeCode.objects.filter(status=False, is_down=False)
  696. if not exchange_code.exists():
  697. return response.json(173)
  698. # 将兑换码写入到excel表
  699. for i, vo in enumerate(list(exchange_code)):
  700. code_no = cls.fix_string_length(str(vo.id))
  701. sheet.cell(row=i + 1, column=1, value=code_no)
  702. sheet.cell(row=i + 1, column=2, value=vo.code)
  703. filename = '国内流量年卡兑换码-{}.xlsx'.format(exchange_code.count())
  704. # 创建一个http响应
  705. res = HttpResponse(content_type='application/vnd.ms-excel')
  706. # 设置响应头,告诉浏览器文件要下载而不是直接打开
  707. res['Content-Disposition'] = 'attachment; filename={}'.format(filename)
  708. # 将excel文档保存到http响应中
  709. wb.save(res)
  710. exchange_code.update(is_down=True, updated_time=int(time.time()))
  711. return res
  712. except Exception as e:
  713. LOGGER.info('*****UnicomManageController.package_cdk_export_excel:errLine:{}, errMsg:{}'
  714. .format(e.__traceback__.tb_lineno, repr(e)))
  715. return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
  716. @staticmethod
  717. def fix_string_length(code_no):
  718. """
  719. 将兑换码编号生成固定6位长度
  720. """
  721. if len(code_no) < 6:
  722. return 'NO.' + code_no.rjust(6, '0')
  723. else:
  724. return 'NO.' + code_no
  725. @classmethod
  726. def create_package_cdk(cls, request_dict, response):
  727. """
  728. 批量生成兑换码
  729. """
  730. try:
  731. LOGGER.info('*****UnicomManageController.create_package_cdk,params:{}'.format(request_dict))
  732. quantity = request_dict.get('quantity', None)
  733. package_id = request_dict.get('packageId', None)
  734. if not all([quantity, package_id]):
  735. return response.json(444)
  736. combo_qs = UnicomCombo.objects.filter(id=int(package_id))
  737. if not combo_qs.exists():
  738. return response.json(173)
  739. combo = combo_qs.first()
  740. exchange_code_list = []
  741. now_time = int(time.time())
  742. if combo.combo_type == 3: # 五兴电信
  743. for i in range(int(quantity)):
  744. # 10位兑换码 后面两位为标识代表五兴电信
  745. code = cls.generate_code() + 'WD'
  746. exchange_code_list.append(ExchangeCode(code=code, status=False, is_down=0,
  747. package_type=1, package_id=combo.id,
  748. expire_time=0,
  749. created_time=now_time,
  750. updated_time=now_time))
  751. elif combo.combo_type == 0: # 珠海联通
  752. for i in range(int(quantity)):
  753. # 10位兑换码 后面两位为标识代表五兴电信
  754. code = cls.generate_code() + 'ZL'
  755. exchange_code_list.append(ExchangeCode(code=code, status=False, is_down=0,
  756. package_type=0, package_id=combo.id,
  757. expire_time=0,
  758. created_time=now_time,
  759. updated_time=now_time))
  760. if exchange_code_list:
  761. ExchangeCode.objects.bulk_create(exchange_code_list)
  762. return response.json(0)
  763. return response.json(178)
  764. except Exception as e:
  765. LOGGER.info('*****UnicomManageController.create_package_cdk:errLine:{}, errMsg:{}'
  766. .format(e.__traceback__.tb_lineno, repr(e)))
  767. return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
  768. @classmethod
  769. def generate_code(cls):
  770. # 生成uuid并移除-
  771. uuid_str = str(uuid.uuid4()).replace('-', '')
  772. now_time = int(time.time())
  773. uuid_str += str(now_time)
  774. # 使用SHA1算法生成哈希值
  775. sha1 = hashlib.sha1(uuid_str.encode('utf-8'))
  776. # 取哈希值的前8位,并将其转换为大写字母
  777. code = sha1.hexdigest()[:8].upper()
  778. return code
  779. @classmethod
  780. def get_package_details(cls, request_dict, response):
  781. """
  782. 根据序列号获取套餐包列表
  783. """
  784. serial_number = request_dict.get('serialNumber', None)
  785. if not serial_number:
  786. return response.json(444)
  787. ud_qs = UnicomDeviceInfo.objects.filter(serial_no=serial_number) \
  788. .values('iccid', 'card_type')
  789. package_list = []
  790. if not ud_qs.exists():
  791. return response.json(0, {'packageList': package_list})
  792. iccid = ud_qs[0]['iccid']
  793. card_type = ud_qs[0]['card_type']
  794. if card_type == 0 or card_type == 3:
  795. o_qs = UnicomComboOrderInfo.objects.filter(iccid=iccid) \
  796. .values('id', 'status', 'flow_total_usage', 'flow_exceed', 'activation_time', 'expire_time',
  797. 'combo__combo_name', 'combo__flow_total', 'updated_time') \
  798. .order_by('created_time')
  799. if not o_qs:
  800. return response.json(0, {'packageList': package_list})
  801. return response.json(0, {'package_list': cls.get_unicom_package_list(iccid, o_qs)})
  802. if card_type == 1:
  803. data = {'iccid': iccid, 'operator': 3}
  804. return response.json(0, {'package_list': cls.get_wx_package_list(**data)})
  805. if card_type == 5:
  806. data = {'iccid': iccid, 'timestamp': int(time.time()), 'nonce': random.randint(10000, 99999)}
  807. original_data = EIoTClubObject.query_order_record_list("v3", **data)
  808. return response.json(0, {'package_list': cls.get_dx_package_list(original_data)})
  809. return response.json(0, {'package_list': package_list})
  810. @staticmethod
  811. def get_unicom_package_list(iccid, o_qs):
  812. package_list = []
  813. unicom_api = UnicomObjeect()
  814. for i, item in enumerate(o_qs):
  815. package_status = item['status']
  816. flow_total = item['combo__flow_total']
  817. flow_total_usage = float(unicom_api.get_flow_usage_total(iccid))
  818. activate_flow = float(item['flow_total_usage']) if item['flow_total_usage'] else 0
  819. used = 0
  820. if package_status == 1:
  821. used = flow_total_usage - activate_flow # 已用流量
  822. elif package_status == 2:
  823. index = i + 1
  824. if index < len(o_qs) and o_qs[index]['flow_total_usage']:
  825. package_used_flow = float(o_qs[i + 1]['flow_total_usage'])
  826. used = package_used_flow - activate_flow
  827. else:
  828. used = flow_total_usage - activate_flow
  829. status_dict = {0: "待使用", 1: "使用中", 2: "已失效"}
  830. status = status_dict.get(item['status'])
  831. package_list.append({
  832. 'id': item['id'],
  833. 'packageName': item['combo__combo_name'],
  834. 'status': status,
  835. 'flowTotal': flow_total,
  836. 'used': Decimal(used).quantize(Decimal('0.00')),
  837. 'activationTime': datetime.datetime.fromtimestamp(item['activation_time']).strftime(
  838. '%Y-%m-%d %H:%M:%S'),
  839. 'expireTime': datetime.datetime.fromtimestamp(item['expire_time']).strftime('%Y-%m-%d %H:%M:%S'),
  840. 'updatedTime': datetime.datetime.fromtimestamp(item['updated_time']).strftime('%Y-%m-%d %H:%M:%S')
  841. })
  842. return package_list
  843. @staticmethod
  844. def get_wx_package_list(**data):
  845. """
  846. 获取五兴套餐订购记录
  847. @param data: iccid,operator
  848. @return: 订购记录结果
  849. """
  850. try:
  851. package_list = []
  852. wx_tech = WXTechObject()
  853. result = wx_tech.get_package_order_record(**data)
  854. if not result:
  855. return package_list
  856. status_dict = {0: "待使用", 1: "使用中", 2: "已完成", 3: "已退订", 4: "已失效", 5: "已删除"}
  857. for item in result['data']:
  858. used_flow = float(item['flowTotal']) - float(item['flowRemain'])
  859. package_list.append({
  860. 'packageName': item['packageName'],
  861. 'status': status_dict.get(int(item['state'])),
  862. 'flowTotal': item['flowTotal'],
  863. 'used': Decimal(used_flow).quantize(Decimal('0.00')),
  864. 'activationTime': item['startDate'],
  865. 'expireTime': item['endDate'],
  866. 'updatedTime': ''
  867. })
  868. return package_list
  869. except Exception as e:
  870. print(repr(e))
  871. return []
  872. @staticmethod
  873. def get_device_status_by_iccid(iccid, card_type, access_number=''):
  874. try:
  875. re_data = {'iccid': iccid}
  876. if card_type == 0:
  877. status_dict = {1: '已激活', 2: '可激活', 3: '已停用', 4: '已失效', 5: '可测试', 6: '库存', 7: '已更换', 8: '已清除'}
  878. result = UnicomObjeect().query_device_status(**re_data)
  879. res_dict = UnicomObjeect().get_text_dict(result)
  880. return status_dict.get(int(res_dict['data']['status']), 'N/A')
  881. elif card_type == 1:
  882. status_dict = {1: '库存', 2: '可激活', 3: '已激活', 4: '已停用', 5: '已失效', 6: '强制停机'}
  883. data = {'iccid': iccid, 'operator': 3}
  884. wx_tech = WXTechObject()
  885. result = wx_tech.get_cards_info(**data)
  886. return status_dict.get(int(result['data']['cardStatusCode']), 'N/A')
  887. elif card_type == 3:
  888. status_dict = {'connect': '已激活', 'disconnect': '已停用'}
  889. i = 0
  890. while i < 3:
  891. status_code = TelecomService().get_access_number_network_status(access_number)
  892. if status_code:
  893. return status_dict.get(status_code, 'N/A')
  894. i += 1
  895. access_info = AccessNumberTaskQueue.objects.filter(iccid=iccid, status=1) \
  896. .order_by('-completion_time').values('action')
  897. if not access_info.exists():
  898. return 'N/A'
  899. return '已激活' if access_info[0]['action'] == 2 else '已停用'
  900. else:
  901. return 'N/A'
  902. except Exception as e:
  903. print(repr(e))
  904. return 'N/A'
  905. @classmethod
  906. def async_update_status(cls, request_dict, response):
  907. """
  908. 联通根据序列号异步修改卡状态
  909. @return: 修改结果
  910. """
  911. serial_number = request_dict.get('serialNumber', None)
  912. if not serial_number:
  913. return response.json(444)
  914. status = int(request_dict.get('status', 0))
  915. unicom_qs = UnicomDeviceInfo.objects.filter(serial_no=serial_number, card_type__in=[0, 3])
  916. if not unicom_qs.exists():
  917. return response.json(173)
  918. unicom_service = UnicomObjeect()
  919. iccid = unicom_qs.first().iccid
  920. access_number = unicom_qs.first().access_number
  921. card_type = unicom_qs.first().card_type
  922. if status == 1: # 激活
  923. unicom_service.change_device_to_activate(iccid=iccid, card_type=card_type, access_number=access_number,
  924. reason='后台操作恢复网络')
  925. return response.json(0)
  926. elif status == 3: # 停用
  927. unicom_service.change_device_to_disable(iccid=iccid, card_type=card_type, access_number=access_number,
  928. reason='后台操作断网')
  929. return response.json(0)
  930. return response.json(902)
  931. @classmethod
  932. def get_exchange_code_page(cls, request_dict, response):
  933. """
  934. 分页获取兑换码
  935. @return: 分页数据
  936. """
  937. pageSize = request_dict.get('pageSize', None)
  938. pageNo = request_dict.get('pageNo', None)
  939. code = request_dict.get('code', None)
  940. is_down = request_dict.get('isDown', None)
  941. if not all({pageNo, pageSize}):
  942. return response.json(444)
  943. page = int(pageNo)
  944. line = int(pageSize)
  945. try:
  946. code_qs = ExchangeCode.objects.all()
  947. if code:
  948. code_qs = code_qs.filter(code__icontains=code)
  949. if is_down:
  950. code_qs = code_qs.filter(is_down=int(is_down))
  951. code_list = []
  952. total = code_qs.count()
  953. result = {'total': total, 'data': code_list}
  954. code_qs = code_qs.order_by('-created_time')[(page - 1) * line:page * line]
  955. if not code_qs.exists():
  956. return response.json(0, result)
  957. for item in code_qs:
  958. combo_name = UnicomCombo.objects.filter(id=item.package_id)[0].combo_name
  959. code_list.append({
  960. 'id': item.id,
  961. 'code': item.code,
  962. 'status': item.status,
  963. 'isDown': item.is_down,
  964. 'packageType': item.package_type,
  965. 'comboName': combo_name,
  966. 'expireTime': item.expire_time,
  967. 'createdTime': item.created_time,
  968. 'updatedTime': item.updated_time
  969. })
  970. result['data'] = code_list
  971. return response.json(0, result)
  972. except Exception as e:
  973. LOGGER.info('异常详情,errLine:{}, errMsg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
  974. return response.json(500)
  975. @classmethod
  976. def update_exchange_code(cls, request_dict, response):
  977. """
  978. 修改兑换码数据
  979. """
  980. code_id = request_dict.get('id', None)
  981. is_down = request_dict.get('isDown', None)
  982. status = request_dict.get('status', None)
  983. expire_time = request_dict.get('expireTime', None)
  984. if not code_id:
  985. return response.json(444)
  986. try:
  987. code_qs = ExchangeCode.objects.filter(id=int(code_id))
  988. if not code_qs.exists():
  989. return response.json(173)
  990. params = {}
  991. if is_down:
  992. params['is_down'] = int(is_down)
  993. if status:
  994. params['status'] = int(status)
  995. if expire_time:
  996. params['expire_time'] = int(expire_time)
  997. if not params:
  998. return response.json(0)
  999. code_qs.update(**params)
  1000. return response.json(0)
  1001. except Exception as e:
  1002. LOGGER.info('异常详情,errLine:{}, errMsg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
  1003. return response.json(500)
  1004. @classmethod
  1005. def get_flow_combo_list(cls, request_dict, response):
  1006. """
  1007. 获取4G流量套餐列表
  1008. @return: 套餐列表
  1009. """
  1010. c_type = request_dict.get('type', None)
  1011. combo_qs = UnicomCombo.objects.filter(is_del=False)
  1012. if c_type:
  1013. combo_qs = combo_qs.filter(combo_type=int(c_type))
  1014. if not combo_qs.exists():
  1015. return response.json(173)
  1016. combo_qs = combo_qs.values('id', 'combo_name').order_by('-created_time')
  1017. flow_combo_list = list(combo_qs)
  1018. return response.json(0, flow_combo_list)
  1019. @classmethod
  1020. def serial_number_bind_package_bulk(cls, user_id, user, request, request_dict, response):
  1021. """
  1022. 上传序列号文件绑定套餐id
  1023. @param user_id: user_id
  1024. @param user: 当前操作用户
  1025. @param request: file txt
  1026. @param request_dict: package_id 4G套餐id
  1027. @param response: 响应对象
  1028. @return: 成功数以及异常序列号列表
  1029. """
  1030. redis_obj = RedisObject(5)
  1031. try:
  1032. lock = redis_obj.try_lock(UNICOM_MANAGE_LOCK, 'iccid', 15, 60)
  1033. if not lock:
  1034. return response.json(10074)
  1035. package_id = request_dict.get('packageId', None)
  1036. file = request.FILES['file']
  1037. serial_list = []
  1038. error_list = []
  1039. if not package_id:
  1040. return response.json(444)
  1041. n_time = int(time.time())
  1042. package_id = int(package_id)
  1043. sn_list = []
  1044. uc_qs = UnicomCombo.objects.filter(id=package_id)
  1045. if not uc_qs.exists():
  1046. return response.json(173)
  1047. for line in file:
  1048. serial_number = line.decode().strip()[0:9]
  1049. try:
  1050. sn_qs = SerialNumberPackage.objects.filter(serial_number=serial_number)
  1051. if sn_qs:
  1052. error_list.append({'serialNumber': serial_number, 'msg': '此序列号已绑定套餐'})
  1053. continue
  1054. if serial_number in serial_list:
  1055. error_list.append({'serialNumber': serial_number, 'msg': 'txt存在重复序列号'})
  1056. continue
  1057. data = {'status': 1, 'serial_number': serial_number, 'package_id': package_id,
  1058. 'created_time': n_time, 'updated_time': n_time, 'created_by': user, 'updated_by': user}
  1059. serial_number_p = SerialNumberPackage(**data)
  1060. serial_list.append(serial_number)
  1061. sn_list.append(serial_number_p)
  1062. except Exception as e:
  1063. error_list.append({'serialNumber': serial_number, 'msg': repr(e)})
  1064. if sn_list:
  1065. # 计算总数量和页数,仅计算一次
  1066. total_count = len(sn_list)
  1067. pages = ceil(total_count / 100)
  1068. # 遍历每一页,使用列表切片处理批次
  1069. for page in range(pages):
  1070. # 计算本次循环实际处理的结束索引,考虑最后一页可能不足100的情况
  1071. end = min((page + 1) * 100, total_count)
  1072. # 切片获取当前批次的sn_list
  1073. batch_sn_list = sn_list[page * 100:end]
  1074. # 执行批量创建
  1075. SerialNumberPackage.objects.bulk_create(batch_sn_list)
  1076. # 终身免流量时只保留一个有效套餐并自动激活
  1077. if uc_qs.first().remark == 'LIFETIME_FREE':
  1078. asy = threading.Thread(target=cls.activate_4G_lifetime_free, args=(sn_list, user_id))
  1079. asy.start()
  1080. # 释放锁
  1081. redis_obj.release_lock(UNICOM_MANAGE_LOCK, 'iccid')
  1082. return response.json(0, {'total': len(serial_list), 'errData': error_list})
  1083. except Exception as e:
  1084. LOGGER.info('批量绑定异常详情,errLine:{}, errMsg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
  1085. @classmethod
  1086. def activate_4G_lifetime_free(cls, sn_list, user_id):
  1087. """
  1088. 激活4G终身免流量
  1089. """
  1090. for item in sn_list:
  1091. try:
  1092. serial_number = item.serial_number
  1093. # 查询ICCID
  1094. iccid_qs = UnicomDeviceInfo.objects.filter(serial_no=serial_number).values('iccid')
  1095. if not iccid_qs.exists():
  1096. LOGGER.info(f'*****激活终身免流量iccid不存在serial_number:{serial_number}')
  1097. continue
  1098. now_time = int(time.time())
  1099. # 写入套餐订购记录
  1100. experience_history_vo = {'iccid': iccid_qs[0]['iccid'], 'experience_type': 1, 'do_time': now_time}
  1101. UnicomComboExperienceHistory.objects.create(**experience_history_vo)
  1102. # 根据ICCID删除套餐记录
  1103. UnicomComboOrderInfo.objects.filter(iccid=iccid_qs[0]['iccid']).delete()
  1104. # 激活终身流量
  1105. UnicomComboView().generate_flow_package(serial_number, item.package_id, user_id)
  1106. except Exception as e:
  1107. LOGGER.info('UnicomManageControllerView.activate_4G_lifetime_free,'
  1108. 'errLine:{}, errMsg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
  1109. continue
  1110. @classmethod
  1111. def iccid_batch_reset(cls, user, request, request_dict, response):
  1112. """
  1113. iccid批量重置流量
  1114. """
  1115. redis_obj = RedisObject(5)
  1116. lock = redis_obj.try_lock(UNICOM_MANAGE_LOCK, 'iccid', 15, 60)
  1117. if not lock:
  1118. return response.json(10074)
  1119. file = request.FILES['file']
  1120. binding_type = int(request_dict.get('type', 0))
  1121. if not file:
  1122. return response.json(444)
  1123. ip = CommonService.get_ip_address(request)
  1124. asy = threading.Thread(target=UnicomManageControllerView().async_bulk_reset_flow_package,
  1125. args=(file, user, ip, binding_type))
  1126. asy.start()
  1127. return response.json(0)
  1128. @staticmethod
  1129. def async_bulk_reset_flow_package(file, user, ip, binding_type):
  1130. err_data = []
  1131. date_str = datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S')
  1132. num = 0
  1133. for line in file:
  1134. serial_number = line.decode().strip()[0:9]
  1135. try:
  1136. device_info_qs = UnicomDeviceInfo.objects.filter(serial_no=serial_number)
  1137. now_time = int(time.time())
  1138. if not device_info_qs.exists():
  1139. err_data.append({'serialNumber': serial_number, 'msg': 'data is null'})
  1140. continue
  1141. if device_info_qs.count() > 1:
  1142. err_data.append({'serialNumber': serial_number, 'msg': 'Bind multiple iccid'})
  1143. continue
  1144. iccid = device_info_qs.first().iccid
  1145. if binding_type == 1:
  1146. SerialNumberPackage.objects.filter(serial_number=serial_number).delete()
  1147. else:
  1148. # 根据序列号重置出厂流量套餐
  1149. serial_package_qs = SerialNumberPackage.objects.filter(~Q(status=1), serial_number=serial_number)
  1150. if serial_package_qs.exists():
  1151. serial_package_qs.update(status=1, updated_time=now_time, updated_by=user)
  1152. if device_info_qs.first().card_type == 1: # 五兴电信
  1153. data = {'iccids': iccid, 'operator': WXOperatorEnum.TELECOM.value}
  1154. wx_tech = WXTechObject()
  1155. res = wx_tech.delete_card_package(**data)
  1156. if res['code'] == '0':
  1157. UnicomComboExperienceHistory.objects.filter(iccid=iccid).delete()
  1158. num += 1
  1159. continue
  1160. err_data.append({'serialNumber': serial_number, 'msg': '电信重置流量异常:{}'.format(res['code'])})
  1161. continue
  1162. # 联通
  1163. flow_push_qs = UnicomFlowPush.objects.filter(serial_no=serial_number)
  1164. if flow_push_qs.exists(): # 删除流量预警推送
  1165. flow_push_qs.delete()
  1166. sys_msg_qs = SysMsgModel.objects.filter(uid=serial_number)
  1167. if sys_msg_qs.exists(): # 删除有关系统消息数据
  1168. sys_msg_qs.delete()
  1169. # 将4G用户信息状态改为已完成测试状态
  1170. device_info_qs.update(status=2, updated_time=now_time, user_id='')
  1171. combo_order_qs = UnicomComboOrderInfo.objects.filter(iccid=iccid)
  1172. if combo_order_qs.exists(): # 所有套餐删除
  1173. combo_order_qs.delete()
  1174. combo_experience_history_qs = UnicomComboExperienceHistory.objects.filter(iccid=iccid)
  1175. if combo_experience_history_qs.exists(): # 删除免费体验流量记录
  1176. combo_experience_history_qs.delete()
  1177. result = UnicomComboView().activate_test_flow_package(serial_number) # 订购新的100M测试流量
  1178. describe = '批量重置4G流量序列号{},iccid:{},{}'.format(serial_number, iccid, result)
  1179. num += 1
  1180. # 当前缓存是客户首次扫序列号,激活赠送测试流量生成的,重置流量所以要清除
  1181. key = f'ASJ:UNICOM:CARD:ACTIVATE:{serial_number}'
  1182. redis = RedisObject()
  1183. redis.del_data(key)
  1184. UnicomManageControllerView().create_operation_log('unicom/manage/iccidBatchReset', ip, binding_type,
  1185. describe)
  1186. continue
  1187. except Exception as e:
  1188. err_data.append({'serialNumber': serial_number, 'msg': '重置流量异常:{}'.format(repr(e))})
  1189. continue
  1190. if err_data:
  1191. describe = json.loads(json.dumps(err_data))
  1192. UnicomManageControllerView().create_operation_log('unicom/manage/iccidBatchReset', ip, binding_type,
  1193. describe)
  1194. try:
  1195. redis_obj = RedisObject(5)
  1196. lock = redis_obj.release_lock(UNICOM_MANAGE_LOCK, 'iccid')
  1197. describe = f'{date_str}批量重置流量释放锁{lock},数量:{num}'
  1198. UnicomManageControllerView().create_operation_log('unicom/manage/iccidBatchReset', ip, binding_type,
  1199. describe)
  1200. except Exception as e:
  1201. LOGGER.info('释放锁异常,errLine:{}, errMsg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
  1202. LOGGER.info(f'批量重置流量type={binding_type},err_data={err_data}')
  1203. @classmethod
  1204. def serial_number_package_page(cls, request_dict, response):
  1205. """
  1206. 分页查询序列号无限流量套餐
  1207. """
  1208. serial_number = request_dict.get('serialNumber', None)
  1209. pageSize = request_dict.get('pageSize', None)
  1210. pageNo = request_dict.get('pageNo', None)
  1211. package_id = request_dict.get('packageId', None)
  1212. if not all({pageNo, pageSize}):
  1213. return response.json(444)
  1214. page = int(pageNo)
  1215. line = int(pageSize)
  1216. serial_package_qs = SerialNumberPackage.objects.all()
  1217. if serial_number:
  1218. serial_package_qs = serial_package_qs.filter(serial_number=serial_number)
  1219. if package_id:
  1220. serial_package_qs = serial_package_qs.filter(package_id=int(package_id))
  1221. serial_package_qs = serial_package_qs.annotate(serialNumber=F('serial_number'), packageId=F('package_id'),
  1222. createdTime=F('created_time'), createdBy=F('created_by'),
  1223. updatedTime=F('updated_time'), updatedBy=F('updated_by')) \
  1224. .values('id', 'serialNumber', 'status', 'packageId', 'createdTime', 'createdBy', 'updatedTime', 'updatedBy')
  1225. total = serial_package_qs.count()
  1226. serial_package_qs = serial_package_qs.order_by('-created_time')[(page - 1) * line:page * line]
  1227. if not serial_package_qs.exists():
  1228. return response.json(0, [])
  1229. serial_list = []
  1230. for item in serial_package_qs:
  1231. data = item
  1232. data['packageName'] = UnicomCombo.objects.filter(id=item['packageId']).values('combo_name')[0]['combo_name']
  1233. serial_list.append(data)
  1234. return response.json(0, {'list': serial_list, 'total': total})
  1235. @classmethod
  1236. def serial_number_package_update(cls, request_dict, response, user):
  1237. """
  1238. 修改序列号绑定无限流量套餐
  1239. """
  1240. try:
  1241. s_id = request_dict.get('id', None)
  1242. package_id = request_dict.get('packageId', None)
  1243. status = request_dict.get('status', None)
  1244. if not s_id:
  1245. return response.json(444)
  1246. if not package_id and not status:
  1247. return response.json(444)
  1248. s_package_qs = SerialNumberPackage.objects.filter(id=int(s_id))
  1249. if not s_package_qs.exists():
  1250. return response.json(173)
  1251. n_time = int(time.time())
  1252. data = {'updated_time': n_time, 'updated_by': user}
  1253. if package_id:
  1254. data['package_id'] = int(package_id)
  1255. if status:
  1256. data['status'] = int(status)
  1257. s_package_qs.update(**data)
  1258. return response.json(0)
  1259. except Exception as e:
  1260. LOGGER.info('UnicomManageControllerView.serial_number_package_update,'
  1261. 'errLine:{}, errMsg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
  1262. return response.json(500)
  1263. @classmethod
  1264. def transfer_device_package(cls, request_dict, response, user):
  1265. """
  1266. 联通4G订单套餐转移
  1267. @param request_dict: orderId(当前订单套餐id)、targetSerialNumber(目标设备序列号)
  1268. @param response: 响应结果
  1269. @param user: 操作用户
  1270. @return: 转移结果
  1271. """
  1272. try:
  1273. order_id = request_dict.get('orderId')
  1274. target_serial_number = request_dict.get('targetSerialNumber')
  1275. LOGGER.info('UnicomManageControllerView.transfer_device_package,serialNumber:{},orderId:{}'.format(
  1276. target_serial_number, order_id))
  1277. if not all([order_id, target_serial_number]):
  1278. return response.json(444)
  1279. # 查询旧设备订单套餐信息
  1280. order_query_set = Order_Model.objects.filter(orderID=order_id)
  1281. if not order_query_set.exists():
  1282. return response.json(173)
  1283. # 查询目标设备信息是否存在
  1284. u_device_query_set = UnicomDeviceInfo.objects.filter(serial_no=target_serial_number)
  1285. if not u_device_query_set.exists():
  1286. return response.json(173)
  1287. order_data = order_query_set.values().first()
  1288. old_order_id = order_data['orderID']
  1289. desc = '{} 转移后,前orderId:{}'.format(order_data['store_meal_name'], old_order_id)
  1290. order_data['desc'] = desc
  1291. now_order = CommonService.createOrderID()
  1292. uid = CommonService.get_uid_by_serial_number(target_serial_number)
  1293. order_data['orderID'] = now_order
  1294. order_data['UID'] = uid
  1295. order_data['currency'] = 'CNY'
  1296. package_id = int(order_data['unify_combo_id'])
  1297. Order_Model.objects.create(**order_data)
  1298. iccid = u_device_query_set.values('iccid').first()['iccid'] # 目标设备4G iccid
  1299. u_package_query_set = UnicomComboOrderInfo.objects.filter(order_id=old_order_id)
  1300. now_time = int(time.time())
  1301. unicom_api = UnicomObjeect()
  1302. if u_package_query_set.exists(): # 套餐记录存在则直接copy
  1303. package_info = u_package_query_set.values().first()
  1304. package_info.pop('id')
  1305. package_info['iccid'] = iccid
  1306. package_info['order_id'] = now_order
  1307. package_info['activation_time'] = now_time
  1308. package_info['updated_time'] = now_time
  1309. package_info['created_time'] = now_time
  1310. now_package_query_set = UnicomComboOrderInfo.objects.filter(iccid=iccid, status=1)
  1311. if now_package_query_set.exists():
  1312. package_info['status'] = 0
  1313. package_info['flow_total_usage'] = '0'
  1314. else:
  1315. package_info['status'] = 1
  1316. package_info['flow_total_usage'] = unicom_api.get_flow_usage_total(iccid)
  1317. UnicomComboOrderInfo.objects.create(**package_info)
  1318. # 设置旧套餐状态为2
  1319. u_package_query_set.update(status=2, updated_time=int(time.time()))
  1320. else:
  1321. UnicomComboView.create_combo_order_info(now_order, 0, iccid, package_id)
  1322. # 激活新卡
  1323. unicom_api.change_device_to_activate(iccid)
  1324. describe = f'{order_id}套餐转移成功,操作人{user}'
  1325. cls.create_operation_log('unicom/manage/transferDevicePackage', '127.0.0.1', request_dict, describe)
  1326. return response.json(0)
  1327. except Exception as e:
  1328. LOGGER.info('UnicomManageControllerView.transfer_device_package, errLine:{}, errMsg:{}'.format(
  1329. e.__traceback__.tb_lineno, repr(e)))
  1330. return response.json(500)
  1331. def get_dx_package_list(original_data):
  1332. """
  1333. 鼎芯数据处理
  1334. """
  1335. package_list = []
  1336. for package in original_data["data"]:
  1337. new_package = {
  1338. "packageName": package.get("packageName", ""),
  1339. "status": package.get("state"), # Assuming state 2 means 'In Use'
  1340. "flowTotal": package.get("flowTotal", 0),
  1341. "used": package.get("flowTotal", 0) - package.get("flowRemain", 0),
  1342. "activationTime": package.get("startDate", ""),
  1343. "expireTime": package.get("endDate", ""),
  1344. "updatedTime": "" # 没有这个数据接口
  1345. }
  1346. package_list.append(new_package)
  1347. return package_list
  1348. @classmethod
  1349. def update_expiration_date(cls, request_dict, response):
  1350. """
  1351. 更改套餐过期时间
  1352. @param request_dict: 请求参数
  1353. @request_dict id: 套餐id
  1354. @request_dict expireTime: 过期时间
  1355. @request_dict serialNumber: 序列号
  1356. @param response: 响应对象
  1357. @return:
  1358. """
  1359. id = request_dict.get("id", None)
  1360. expire_time = request_dict.get("expireTime", None)
  1361. serial_number = request_dict.get("serialNumber", None)
  1362. if not all([id, serial_number, expire_time]):
  1363. return response.json(444)
  1364. try:
  1365. ud_qs = UnicomDeviceInfo.objects.filter(serial_no=serial_number).values('iccid', 'card_type')
  1366. package_list = []
  1367. if not ud_qs.exists():
  1368. return response.json(0, {'packageList': package_list})
  1369. card_type = ud_qs[0]['card_type']
  1370. if card_type == 0 or card_type == 3:
  1371. UnicomComboOrderInfo.objects.filter(pk=id).update(expire_time=expire_time)
  1372. return response.json(0)
  1373. else:
  1374. return response.json(177, "这个类型的卡不能更改过期时间")
  1375. except Exception as e:
  1376. LOGGER.info('UnicomManageControllerView.update_expiration_date, errLine:{}, errMsg:{}'.format(
  1377. e.__traceback__.tb_lineno, repr(e)))
  1378. return response.json(500)
  1379. @classmethod
  1380. def verify_package_export_excel(cls, request, request_dict, response):
  1381. """
  1382. 验证套餐导出excel
  1383. @param request_dict:
  1384. @param request:
  1385. @param response: 响应对象
  1386. @return:
  1387. """
  1388. try:
  1389. serial_list = []
  1390. file = request.FILES['serialFile']
  1391. opt_type = int(request_dict.get('optType', 1))
  1392. for line in file:
  1393. serial_number = line.decode().strip()[0:9]
  1394. serial_list.append(serial_number)
  1395. total_count = len(serial_list)
  1396. pages = ceil(total_count / 100)
  1397. package_list = []
  1398. # 遍历每一页,使用列表切片处理批次
  1399. for page in range(pages):
  1400. start = page * 100
  1401. end = (page + 1) * 100
  1402. serial_list_batch = serial_list[start:end]
  1403. # 获取设备信息
  1404. pck_qs = SerialNumberPackage.objects.filter(serial_number__in=serial_list_batch) \
  1405. .values('serial_number', 'package_id')
  1406. if not pck_qs.exists():
  1407. return response.json(0)
  1408. for item in pck_qs:
  1409. package_list.append(item)
  1410. if opt_type == 1:
  1411. return response.json(0, {'fileTotal': total_count, 'queryCount': len(package_list)})
  1412. combo_list = list(UnicomCombo.objects.filter(is_del=False).values('id', 'combo_name'))
  1413. # 创建一个新的excel文档
  1414. wb = openpyxl.Workbook()
  1415. # 获取默认的工作表
  1416. sheet = wb.active
  1417. sheet.title = '套餐核对'
  1418. sheet.column_dimensions['A'].width = 20
  1419. sheet.column_dimensions['B'].width = 20
  1420. sheet.column_dimensions['C'].width = 20
  1421. sheet.column_dimensions['D'].width = 20
  1422. for i, item in enumerate(package_list):
  1423. combo_name = next((combo['combo_name'] for combo in combo_list if combo['id'] == item['package_id']),
  1424. None)
  1425. u_device_qs = UnicomDeviceInfo.objects.filter(serial_no=item['serial_number']).values('card_type',
  1426. 'iccid')
  1427. sheet.cell(row=i + 1, column=1, value=item['serial_number'])
  1428. if u_device_qs.exists():
  1429. card_name = ''
  1430. if u_device_qs[0]['card_type'] == 0:
  1431. card_name = '珠海联通'
  1432. elif u_device_qs[0]['card_type'] == 1:
  1433. card_name = '五兴电信'
  1434. sheet.cell(row=i + 1, column=2, value=card_name)
  1435. sheet.cell(row=i + 1, column=3, value=u_device_qs[0]['iccid'])
  1436. sheet.cell(row=i + 1, column=4, value=combo_name)
  1437. filename = '序列号流量套餐核对-{}.xlsx'.format(len(package_list))
  1438. # 创建一个http响应
  1439. res = HttpResponse(content_type='application/vnd.ms-excel')
  1440. # 设置响应头,告诉浏览器文件要下载而不是直接打开
  1441. res['Content-Disposition'] = 'attachment; filename={}'.format(filename)
  1442. # 将excel文档保存到http响应中
  1443. wb.save(res)
  1444. return res
  1445. except Exception as e:
  1446. LOGGER.info('*****UnicomManageController.package_cdk_export_excel:errLine:{}, errMsg:{}'
  1447. .format(e.__traceback__.tb_lineno, repr(e)))
  1448. return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
  1449. @classmethod
  1450. def batch_order_flow_package(cls, request, request_dict, response, user_id):
  1451. serial_number_file = request.FILES.get('serialNumberFile', None)
  1452. package_id = request_dict.get('packageId', None)
  1453. if serial_number_file is None or package_id is None:
  1454. return response.json(444)
  1455. try:
  1456. # 读取序列号文件
  1457. serial_numbers = [line.decode('utf-8').strip() for line in serial_number_file.readlines()]
  1458. if all(len(serial_number) == 9 for serial_number in serial_numbers):
  1459. thread = threading.Thread(target=cls.batch_order_flow,
  1460. args=(serial_numbers, package_id, request, request_dict, user_id))
  1461. thread.start()
  1462. else:
  1463. return response.json(10, "请导入9位序列号")
  1464. return response.json(0)
  1465. except Exception as e:
  1466. LOGGER.info('*****UnicomManageController.batch_order_flow_package:errLine:{}, errMsg:{}'
  1467. .format(e.__traceback__.tb_lineno, repr(e)))
  1468. return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
  1469. @classmethod
  1470. def batch_order_flow(cls, serial_numbers, package_id, request, request_dict, user_id):
  1471. try:
  1472. failures = [] # 记录失败的序列号
  1473. successes = [] # 记录成功的数量
  1474. # 循环添加
  1475. for serial_number in serial_numbers:
  1476. serial_number = serial_number[:9]
  1477. result = UnicomComboView().generate_flow_package(serial_number, int(package_id), user_id)
  1478. LOGGER.info(f'{serial_number} 订购流量套餐包, createdBy:{user_id}, result:{result}')
  1479. if not result:
  1480. failures.append(serial_number)
  1481. else:
  1482. successes.append(serial_number)
  1483. # 写入操作日志
  1484. ip = CommonService.get_ip_address(request)
  1485. content = json.loads(json.dumps(request_dict))
  1486. log = {
  1487. 'ip': ip,
  1488. 'user_id': 1,
  1489. 'status': 200,
  1490. 'time': int(time.time()),
  1491. 'url': 'unicom/manage/batchOrderFlowPackage',
  1492. 'content': json.dumps(content),
  1493. 'operation': f'批量充值流量,序列号{failures}充值失败,序列号{successes}流量充值成功',
  1494. }
  1495. LogModel.objects.create(**log)
  1496. return
  1497. except Exception as e:
  1498. LOGGER.info('*****UnicomManageController.batch_order_flow:errLine:{}, errMsg:{}'
  1499. .format(e.__traceback__.tb_lineno, repr(e)))
  1500. return