# Copyright (C) 2022 # # @Time : 2022/7/18 16:16 # @Author : ghl # @Email : Guanhailogn@asj6.wecom.work # @File : UnicomManageController.py # @Software: PyCharm import time from django.db import transaction from django.views.generic.base import View from Model.models import UnicomDeviceInfo, UnicomCombo, Pay_Type, UnicomComboOrderInfo, Device_User from Object.ResponseObject import ResponseObject class UnicomComboView(View): def get(self, request, *args, **kwargs): request.encoding = 'utf-8' operation = kwargs.get('operation') return self.validation(request.GET, request, operation) def post(self, request, *args, **kwargs): request.encoding = 'utf-8' operation = kwargs.get('operation') return self.validation(request.POST, request, operation) def validation(self, request_dict, request, operation): response = ResponseObject() print(request) # 获取套餐详细表 if operation == 'get/deta/info': return self.get_unicom_info(request_dict, response) # 获取支付类型 elif operation == 'get/pay': return self.get_pay_type(response) # 添加和编辑卡套餐 elif operation == 'edit/combo': return self.edit_combo(request_dict, response) # 获取卡用户信息 elif operation == 'get/user': return self.get_user_combo(request_dict, response) # 获取设备套餐信息 elif operation == 'order/info': return self.get_order_info(request_dict, response) # 统计4G套餐 elif operation == 'getComboDataList': return self.combo_list(request_dict, response) # 删除卡套餐 elif operation == 'dele/combo/info': return self.combo_order_info(request_dict, response) # 筛选用户信息 elif operation == 'filter/user': return self.get_user_info(request_dict, response) def get_user_info(self, request_dict, response): # print('request_dict: ', request_dict) # Unicom_comborOrder表查询 status = request_dict.get('status', None) payType = request_dict.get('payType', None) price = request_dict.get('price', None) addTimeRange = request_dict.get('addTimeRange', None) endTimeRange = request_dict.get('endTimeRange', None) # UnicomDevice_info表查询 iccid = request_dict.get('iccid', None) serialNo = request_dict.get('serialNo', None) userID = request_dict.get('userID', None) # Device_user查询 phone = request_dict.get('phone', None) userEmail = request_dict.get('userEmail', None) dataJoined = request_dict.get('dataJoined', None) pageNo = request_dict.get('pageNo', None) pageSize = request_dict.get('pageSize', None) if not all([pageNo, [pageSize]]): return response.json(444) page = int(pageNo) line = int(pageSize) try: unicom_device_qs = UnicomDeviceInfo.objects.all() if iccid: unicom_device_qs = unicom_device_qs.filter(iccid=iccid) if serialNo: unicom_device_qs = unicom_device_qs.filter(serial_no=serialNo) if userID: unicom_device_qs = unicom_device_qs.filter(user_id=userID) # if addTimeRange: # addStartTime, addEndTime = int( # addTimeRange[0][:-3]), int(addTimeRange[1][:-3]) # unicom_combo_order_qs = unicom_combo_order_qs.filter( # activation_time__gte=addStartTime, # activation_time__lte=addEndTime) # if endTimeRange: # endStartTime, endEndTime = int( # endTimeRange[0][:-3]), int(endTimeRange[1][:-3]) # unicom_combo_order_qs = unicom_combo_order_qs.filter( # activation_time__gte=endStartTime, # activation_time__lte=endEndTime) userID_list = [] userID_set_dict = {} if userID and userID != ['']: device_user_qs = Device_User.objects.filter(user_id__in=userID).values('userID', 'phone', 'userEmail', 'data_joined').distinct() for device_user in device_user_qs: userID_list.append(device_user['iccid']) userID_set_dict[device_user['iccid']] = { 'userID': device_user['user_id'], 'phone': device_user['phone'], 'userEmail': device_user['userEmail'], 'dataJoined': device_user['data_joined'].strftime( "%Y-%m-%d %H:%M:%S") } unicom_device_qs = unicom_device_qs.filter(iccid__in=userID_list) else: device_user_qs = Device_User.objects.filter().values('userID', 'phone', 'userEmail', 'data_joined').distinct() for device_user in device_user_qs: userID_list.append(device_user['iccid']) userID_set_dict[device_user['iccid']] = { 'userID': device_user['user_id'], 'phone': device_user['phone'], 'userEmail': device_user['userEmail'], 'dataJoined': device_user['dataJoined'].strftime( "%Y-%m-%d %H:%M:%S") } if not unicom_device_qs.exists(): return response.json(0, []) unicom_combo_order_qs = UnicomComboOrderInfo.objects.filter( order_id__in=unicom_device_qs.values('iccid')).values('status', 'combo__pay_type', 'combo__price', 'activation_time', 'expire_time') if status or payType or addTimeRange or endTimeRange or price: if status: unicom_combo_order_qs = unicom_combo_order_qs.filter(status=status) if payType: unicom_combo_order_qs = unicom_combo_order_qs.filter(combo__pay_type=payType) if price: unicom_combo_order_qs = unicom_combo_order_qs.filter(combo__price=price) if addTimeRange: addStarTime, addEndTime = int( addTimeRange[0][-3]), int(addTimeRange[1][:-3]) unicom_combo_order_qs = unicom_combo_order_qs.filter( activation_time=addStarTime, expire_time=addEndTime ) if endTimeRange: endStartTimem, endEndTiem = int( endTimeRange[0][:-3]),int(endTimeRange[1][:-3]) unicom_combo_order_qs = unicom_combo_order_qs.filter( activation_time=endStartTimem, expire_time=endEndTiem) list_data = [] count = unicom_device_qs.count() unicom_device_qs = unicom_device_qs.order_by('-activation_time')[(page - 1) * line:page * line] for unicom_device in unicom_device_qs: endTime = time.strftime("%Y--%m--%d %H:%M:%S", time.localtime(unicom_device.endTime)) unicom = unicom_device.iccid.upper() data = { 'iccid':unicom_device.iccid, 'serialNo':unicom_device.serial_no, 'userID':unicom_device.user_id } for unicom_combo_order in unicom_combo_order_qs.filter( order_id=unicom_device.iccid).values('status', 'combo__pay_type', 'combo__price', 'combo__combo_name', 'activation_time', 'expire_time'): data['status'] = unicom_combo_order['status'] data['payType'] = unicom_combo_order['combo__pay_type'] data['price'] = unicom_combo_order['combo__price'] data['activationTime'] = unicom_combo_order['activation_time'].strftime( "%Y-%m-%d %H:%M:%S") data['expireTime'] = unicom_combo_order['expire_time'].strftime( "%Y-%m-%d %H:%M:%S") data['comboName'] = unicom_combo_order['combo__combo_name'] if userID in userID_set_dict: data['userID'] = userID_set_dict['userID'] data['phone'] = userID_set_dict['phone'] data['userEmail'] = userID_set_dict['userEmail'] data['dataJoined'] = userID_set_dict['dataJoined'] list_data.append(data) return response.json(0, {'list': list_data, 'total': count}) except Exception as e: print(e) return response.json(500, repr(e)) @staticmethod def get_user_combo(request_dict, response): pageNo = request_dict.get('pageNo', None) pageSize = request_dict.get('pageSize', None) if not all([pageNo, [pageSize]]): return response.json(444) page = int(pageNo) line = int(pageSize) get_info_qs = UnicomComboOrderInfo.objects.filter().values( 'iccid', 'activation_time', 'expire_time', 'status', 'combo__combo_name', 'combo__pay_type__payment', 'combo__price' )[(page - 1) * line:page * line] total = get_info_qs.count() try: res_list = [] for item in get_info_qs: res = { 'userID': '', 'phone': '', 'userEmail': '', 'serialNo': '', 'loginTime': '', 'iccid': '', 'openTime': '', 'endTime': '', 'status': '', 'comboName': '', 'payType': '', 'price': '' } iccid = item['iccid'] res['iccid'] = iccid res['openTime'] = item['activation_time'] res['endTime'] = item['expire_time'] res['status'] = item['status'] res['comboName'] = item['combo__combo_name'] res['payType'] = item['combo__pay_type__payment'] res['price'] = item['combo__price'] serial_no_qs = UnicomDeviceInfo.objects.filter(iccid=iccid).values('serial_no') # serial_no = serial_no_qs[0]['serial_no'] res['serialNo'] = serial_no_qs.first()['serial_no'] user_id_qs = UnicomDeviceInfo.objects.filter(iccid=iccid).values('user_id') user_id = user_id_qs[0]['user_id'] if user_id_qs.exists(): user_info_qs = Device_User.objects.filter(userID=user_id).values( 'userEmail', 'data_joined', 'phone') res['userID'] = user_id res['loginTime'] = user_info_qs.first()['data_joined'].strftime("%Y-%m-%d %H:%M:%S") res['userEmail'] = user_info_qs.first()['userEmail'] res['phone'] = user_info_qs.first()['phone'] res_list.append(res) return response.json(0, {'list': res_list, 'total': total}) except Exception as e: return response.json(500, repr(e)) @staticmethod def get_order_info(request_dict, response): """ 获取卡套餐信息 @param request_dict: @param response: @return: """ serial_no = request_dict.get('serialNo', None) pageNo = request_dict.get('pageNo', None) pageSize = request_dict.get('pageSize', None) if not all([pageSize, pageNo]): return response.json(444) # else: page = int(pageNo) line = int(pageSize) # 参考云端获取设备套餐信息（代码逻辑） # 参考云端多情况（条件）下的查询，返回结果 try: get_info_qs = UnicomDeviceInfo.objects.filter().values('iccid') iccid = get_info_qs[0]['iccid'] if serial_no: get_info_qs = get_info_qs.filter(serial_no__contains=serial_no).values('iccid') iccid = get_info_qs[0]['iccid'] if not get_info_qs.exists(): return response.json(0, []) combo_info_qs = UnicomComboOrderInfo.objects.filter(iccid=iccid).values() combo_info_qs = combo_info_qs.values() combo_info_qs = combo_info_qs.order_by('-created_time') combo_info_qs = combo_info_qs[(page - 1) * line:page * line] total = combo_info_qs.count() return response.json(0, {'list': list(combo_info_qs), 'total': total}) except Exception as e: print(e) return response.json(500, repr(e)) @classmethod def edit_combo(cls, request_dict, response): """ 添加和编辑卡套餐 """ combo_id = request_dict.get('comboID', None) package_id = request_dict.get('packageId', None) combo_name = request_dict.get('comboName', None) status = request_dict.get('status', None) combo_type = request_dict.get('comboType', None) flow_total = request_dict.get('flowTotal', None) expiration_days = request_dict.get('expirationDays', None) expiration_type = request_dict.get('expirationType', None) pay_type = request_dict.get('payType', None) price = request_dict.get('price', None) remark = request_dict.get('remark', None) updated_time = request_dict.get('updatedTime', None) created_time = request_dict.get('createdTime', None) is_show = request_dict.get('show', None) add = request_dict.get('add', None) if not all([add]): return response.json(444) UnicomCombo.objects.filter(id=combo_id).values() try: with transaction.atomic(): re_data = { 'package_id': package_id, 'combo_name': combo_name, 'status': status, 'combo_type': combo_type, 'flow_total': flow_total, 'expiration_days': expiration_days, 'expiration_type': expiration_type, 'price': price, 'remark': remark, 'updated_time': updated_time, 'created_time': created_time, 'is_show': is_show } if add == 1: UnicomCombo.objects.filter(id=combo_id).update(**re_data) UnicomCombo.objects.get(id=combo_id).pay_type.set(pay_type) else: UnicomCombo.objects.filter(id=combo_id).update(**re_data) UnicomCombo.objects.get(id=combo_id).pay_type.set(pay_type) UnicomCombo.objects.create(**re_data).pay_type.set(pay_type) return response.json(0) except Exception as e: return response.json(500, repr(e)) @staticmethod def get_unicom_info(request_dict, response): """ 获取套餐详细表 @param request_dict: @param response: @return: """ pageNo = request_dict.get('pageNo', None) pageSize = request_dict.get('pageSize', None) if not all([pageNo, pageSize]): return response.json(444) page = int(pageNo) line = int(pageSize) try: combo_qs = UnicomCombo.objects.filter(is_del=False) \ .order_by('sort').values('id', 'combo_name', 'flow_total', 'expiration_days', 'expiration_type', 'price', 'remark')[(page - 1) * line:page * line] if not combo_qs.exists(): return response.json(0, []) total = combo_qs.count() combo_list = [] for item in combo_qs: # 获取支付方式列表 pay_type_list = [pay_type['id'] for pay_type in UnicomCombo.objects.get(id=item['id']).pay_type.values('id')] combo_list.append({ 'id': item['id'], 'comboName': item['combo_name'], 'flowTotal': item['flow_total'], 'expirationDays': item['expiration_days'], 'expirationType': item['expiration_type'], 'price': item['price'], 'remark': item['remark'], 'payTypes': pay_type_list, }) return response.json(0, {'list': combo_list, 'total': total}) except Exception as e: return response.json(177, repr(e)) @classmethod def get_pay_type(cls, response): """ 获取支付类型 @param response: @return: """ pay_type_qs = Pay_Type.objects.all().values('id', 'payment') if not pay_type_qs.exists(): return response.json(444) try: pay_type_list = [] for pay_type in pay_type_qs: pay_type_qs.exists() pay_type_list.append(pay_type) return response.json(0, pay_type_list) except Exception as e: return response.json(500, e) @classmethod def combo_order_info(cls, request_doct, response): pass def combo_list(self, request_dict, response): year = request_dict.get('year', None) Jan = int(time.mktime(time.strptime(year + '-1-1 00:00:00', "%Y-%m-%d %H:%M:%S"))) Feb = int(time.mktime(time.strptime(year + '-2-1 00:00:00', "%Y-%m-%d %H:%M:%S"))) Mar = int(time.mktime(time.strptime(year + '-3-1 00:00:00', "%Y-%m-%d %H:%M:%S"))) Apr = int(time.mktime(time.strptime(year + '-4-1 00:00:00', "%Y-%m-%d %H:%M:%S"))) May = int(time.mktime(time.strptime(year + '-5-1 00:00:00', "%Y-%m-%d %H:%M:%S"))) Jun = int(time.mktime(time.strptime(year + '-6-1 00:00:00', "%Y-%m-%d %H:%M:%S"))) Jul = int(time.mktime(time.strptime(year + '-7-1 00:00:00', "%Y-%m-%d %H:%M:%S"))) Aug = int(time.mktime(time.strptime(year + '-8-1 00:00:00', "%Y-%m-%d %H:%M:%S"))) Sep = int(time.mktime(time.strptime(year + '-9-1 00:00:00', "%Y-%m-%d %H:%M:%S"))) Oct = int(time.mktime(time.strptime(year + '-10-1 00:00:00', "%Y-%m-%d %H:%M:%S"))) Nov = int(time.mktime(time.strptime(year + '-11-1 00:00:00', "%Y-%m-%d %H:%M:%S"))) Dec = int(time.mktime(time.strptime(year + '-12-1 00:00:00', "%Y-%m-%d %H:%M:%S"))) Jan_next = int(time.mktime(time.strptime(str(int(year) + 1) + '-1-1 00:00:00', "%Y-%m-%d %H:%M:%S"))) list_data = [] unicom_combo_qs = UnicomCombo.objects.filter().values('id', 'combo_type', 'combo_name') if not unicom_combo_qs.exists(): return response.json(173) try: for unicom_combo in unicom_combo_qs: name = unicom_combo['combo_name'] combo_order = UnicomComboOrderInfo.objects.filter(combo_id=unicom_combo['id']) if not combo_order.exists(): continue Jan_count = combo_order.filter(created_time__range=[Jan, Feb]).count() Feb_count = combo_order.filter(created_time__range=[Feb, Mar]).count() Mar_count = combo_order.filter(created_time__range=[Mar, Apr]).count() Apr_count = combo_order.filter(created_time__range=[Apr, May]).count() May_count = combo_order.filter(created_time__range=[May, Jun]).count() Jun_count = combo_order.filter(created_time__range=[Jun, Jul]).count() Jul_count = combo_order.filter(created_time__range=[Jul, Aug]).count() Aug_count = combo_order.filter(created_time__range=[Aug, Sep]).count() Sep_count = combo_order.filter(created_time__range=[Sep, Oct]).count() Oct_count = combo_order.filter(created_time__range=[Oct, Nov]).count() Nov_count = combo_order.filter(created_time__range=[Nov, Dec]).count() Dec_count = combo_order.filter(created_time__range=[Dec, Jan_next]).count() data = [Jan_count, Feb_count, Mar_count, Apr_count, May_count, Jun_count, Jul_count, Aug_count, Sep_count, Oct_count, Nov_count, Dec_count] cloud_data = { 'name': name, 'type': 'line', 'data': data, } list_data.append(cloud_data) return response.json(0, {'list': list_data}) except Exception as e: print(e) return response.json(500, repr(e))