# 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, Device_Info from Object.ResponseObject import ResponseObject from Service.CommonService import CommonService class UnicomManageControllerView(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 == 'order/info': return self.get_order_info(request_dict, response) # 统计4G套餐 elif operation == 'getComboDataList': return self.static_info(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): """ 获取/筛选卡用户信息 @param request_dict: @param response: @return: NickName:用户昵称 phone: 电话 serial_no: 设备序列号 """ NickName = request_dict.get('NickName', None) phone = request_dict.get('phone', None) iccid = request_dict.get('iccid', None) serial_no = request_dict.get('serialNo', None) status = request_dict.get('status') pageSize = request_dict.get('pageSize', None) pageNo = request_dict.get('pageNo', None) if not all({pageNo, pageSize}): return response.json(444) page = int(pageNo) line = int(pageSize) try: unicom_device_qs = UnicomDeviceInfo.objects.all().order_by('-updated_time') device_user_qs = Device_User.objects.filter().values( 'userID', 'NickName', 'phone') if status: unicom_device_qs = unicom_device_qs.filter(status=status) if iccid: unicom_device_qs = unicom_device_qs.filter(iccid__icontains=iccid) if serial_no: unicom_device_qs = unicom_device_qs.filter(serial_no__icontains=serial_no) if NickName: device_user_qs = device_user_qs.filter(NickName__icontains=NickName) if not device_user_qs.exists(): return response.json(0, []) userID = device_user_qs.first()['userID'] unicom_device_qs = unicom_device_qs.filter(user_id=userID) if phone: device_user_qs = device_user_qs.filter(phone=phone) if not device_user_qs.exists(): return response.json(0, []) userID = device_user_qs.first()['userID'] unicom_device_qs = unicom_device_qs.filter(user_id=userID) total = unicom_device_qs.count() unicom_device_qs = unicom_device_qs[(page - 1) * line:page * line] list_data = [] for unicom_device in unicom_device_qs: data = { 'iccid': unicom_device.iccid, 'serialNo': unicom_device.serial_no, 'userID': unicom_device.user_id, 'cardType': unicom_device.card_type, 'status': unicom_device.status, 'mainCard': unicom_device.main_card, 'createdTime': unicom_device.created_time, 'updatedTime': unicom_device.updated_time } device_user_qs = Device_User.objects.filter(userID=unicom_device.user_id).values('username', 'NickName', 'phone') data['userName'] = device_user_qs[0]['username'] if device_user_qs.exists() else '' data['NickName'] = device_user_qs[0]['NickName'] if device_user_qs.exists() else '' data['phone'] = device_user_qs[0]['phone'] if device_user_qs.exists() else '' list_data.append(data) return response.json(0, {'list': list_data, 'total': total}) except Exception as e: print(e) return response.json(500, repr(e)) @staticmethod def get_order_info(request_dict, response): """ 获取/筛选4G流量卡订单信息 @param request_dict: @param response: @return: serial_no 设备序列号 """ UID = request_dict.get('uid', None) serial_no = request_dict.get('serialNo', None) status = request_dict.get('status', 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: combo_order_info_qs = UnicomComboOrderInfo.objects.all() # 序列号查询 if serial_no: unicom_device_qs = UnicomDeviceInfo.objects.filter(serial_no__icontains=serial_no).values('serial_no', 'user_id', 'iccid') if not unicom_device_qs.exists(): return response.json(0, []) combo_order_info_qs = combo_order_info_qs.filter(iccid__icontains=unicom_device_qs[0]['iccid']) # UID查询 if UID: device_qs = Device_Info.objects.filter(UID=UID).values('serial_number').distinct() if not device_qs.exists(): return response.json(0, []) unicom_device_qs = UnicomDeviceInfo.objects.filter( serial_no__icontains=device_qs[0]['serial_number']).values('serial_no', 'user_id', 'iccid') if not unicom_device_qs.exists(): return response.json(0, []) combo_order_info_qs = combo_order_info_qs.filter(iccid__icontains=unicom_device_qs[0]['iccid']) # 状态查询 if status: status = int(status) combo_order_info_qs = combo_order_info_qs.filter(status=status) if not combo_order_info_qs.exists(): return response.json(0, []) total = combo_order_info_qs.count() combo_order_info_qs = combo_order_info_qs.order_by('-created_time')[(page - 1) * line:page * line] data_list = [] for combo_order in combo_order_info_qs: data = {'userName': '', 'price': '', 'UID': '', 'iccid': combo_order.iccid, 'status': combo_order.status, 'order_id': combo_order.order_id, 'flow_total_usage': combo_order.flow_total_usage, 'next_month_activate': combo_order.next_month_activate, 'activationTime': combo_order.activation_time, 'expireTime': combo_order.expire_time, 'createdTime': combo_order.created_time, 'updated_time': combo_order.updated_time} unicom_combo_qs = UnicomCombo.objects.filter(id=combo_order.combo_id).values('combo_name') data['comboName'] = unicom_combo_qs[0]['combo_name'] if unicom_combo_qs.exists() else '' unicom_device_qs = UnicomDeviceInfo.objects.filter(iccid__icontains=combo_order.iccid).values('user_id', 'serial_no') userID = unicom_device_qs[0]['user_id'] if unicom_device_qs.exists() else '' data['serialNo'] = unicom_device_qs[0]['serial_no'] if unicom_device_qs.exists() else '' serial_no = data['serialNo'] device_info_qs = Device_Info.objects.filter(userID__userID=userID, serial_number=serial_no).values( 'userID__username', 'UID') if device_info_qs.exists(): nick_name = device_info_qs[0]['userID__username'] data['userName'] = nick_name if data['serialNo'] != '': data['UID'] = CommonService.query_serial_with_uid(data['serialNo']) data_list.append(data) return response.json(0, {'list': data_list, 'total': total}) except Exception as e: print(e) return response.json(500, repr(e)) @classmethod def edit_combo(cls, request_dict, response): """ 添加和编辑卡套餐 @param request_dict: @param response: @return: """ combo_id = request_dict.get('id', 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( 'payTypes', '')[ 1:-1].split(',') # '[1,2]' -> ['1','2'] sort = request_dict.get('sort', None) price = request_dict.get('price', None) remark = request_dict.get('remark', None) is_show = request_dict.get('isShow', None) virtualPrice = request_dict.get('virtualPrice', None) if not all([pay_type, price, is_show, status, combo_type, flow_total, expiration_days, expiration_type]): return response.json(444) flow_total = int(flow_total) expiration_days = int(expiration_days) expiration_type = int(expiration_type) status = int(status) combo_type = int(combo_type) is_show = int(is_show) sort = int(sort) if combo_type == 1: combo_type_qs = UnicomCombo.objects.filter(combo_type=1, is_del=False) if combo_type_qs.exists(): if combo_id: combo_id = int(combo_id) combo_id_qs = combo_type_qs.first().id if combo_id != combo_id_qs: return response.json(174) else: return response.json(174) unicom_combo_qs = UnicomCombo.objects.all() try: with transaction.atomic(): re_data = { 'combo_name': combo_name, 'status': status, 'combo_type': combo_type, 'flow_total': flow_total, 'expiration_days': expiration_days, 'expiration_type': expiration_type, 'price': price, 'sort': sort, 'remark': remark if remark else '', 'is_show': is_show, 'virtual_price': virtualPrice, } if unicom_combo_qs.filter(id=combo_id).exists(): re_data['updated_time'] = int(time.time()) UnicomCombo.objects.filter(id=combo_id).update(**re_data) UnicomCombo.objects.get(id=combo_id).pay_type.set(pay_type) else: re_data['updated_time'] = int(time.time()) re_data['created_time'] = int(time.time()) UnicomCombo.objects.create(**re_data).pay_type.set(pay_type) return response.json(0) except Exception as e: print(repr(e)) return response.json(500) @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', 'status', 'combo_name', 'flow_total', 'combo_type', 'expiration_days', 'expiration_type', 'price', 'is_unlimited', 'updated_time', 'created_time', 'remark', 'is_show', 'sort', 'virtual_price')[ (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'], 'status': item['status'], 'comboType': item['combo_type'], 'comboName': item['combo_name'], 'flowTotal': item['flow_total'], 'expirationDays': item['expiration_days'], 'expirationType': item['expiration_type'], 'price': item['price'], 'sort': item['sort'], 'isUnlimited': item['is_unlimited'], 'updatedTime': item['updated_time'], 'createdTime': item['created_time'], 'remark': item['remark'], 'isShow': item['is_show'], 'payTypes': pay_type_list, 'virtualPrice': item['virtual_price'] }) 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_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_dict, response): """ 删除卡套餐信息（修改状态） @param request_dict @param response @return: """ combo_id = request_dict.get('id', None) if not combo_id: return response.json(444) try: combo_qs = UnicomCombo.objects.filter(id=combo_id) if combo_qs.exists(): combo_qs.update(is_del=True) return response.json(0) except Exception as e: print(e) return response.json(500, repr(e)) def static_info(self, request_dict, response): """ 统计联通套餐 @param request_dict:请求参数 @param response: 响应对象 @param return: """ 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))