浏览代码

去掉修改推送开关对推送密钥的判断

locky 2 年之前
父节点
当前提交
e6572e9cf1
共有 1 个文件被更改,包括 3 次插入39 次删除
  1. 3 39
      Controller/DetectControllerV2.py

+ 3 - 39
Controller/DetectControllerV2.py

@@ -1,33 +1,15 @@
-#!/usr/bin/env python3
-# -*- coding: utf-8 -*-
-"""
-@Copyright (C) ansjer cop Video Technology Co.,Ltd.All rights reserved.
-@AUTHOR: ASJRD018
-@NAME: AnsjerFormal
-@software: PyCharm
-@DATE: 2019/1/14 15:57
-@Version: python3.6
-@MODIFY DECORD:ansjer dev
-@file: DetectController.py
-@Contact: chanjunkai@163.com
-"""
 import json
 import json
-import os
 import time
 import time
 
 
-import apns2
 import boto3
 import boto3
 import botocore
 import botocore
-import jpush as jpush
 import oss2
 import oss2
 from botocore import client
 from botocore import client
 from django.http import JsonResponse
 from django.http import JsonResponse
 from django.views.generic.base import View
 from django.views.generic.base import View
-from pyfcm import FCMNotification
 
 
 from Ansjer.config import DETECT_PUSH_DOMAIN, DETECT_PUSH_DOMAINS, DETECT_PUSH_DOMAIN_JIUAN, DETECT_PUSH_DOMAINS_JIUAN, \
 from Ansjer.config import DETECT_PUSH_DOMAIN, DETECT_PUSH_DOMAINS, DETECT_PUSH_DOMAIN_JIUAN, DETECT_PUSH_DOMAINS_JIUAN, \
-    OSS_STS_ACCESS_KEY, OSS_STS_ACCESS_SECRET, AWS_ACCESS_KEY_ID, AWS_SECRET_ACCESS_KEY, \
-    JPUSH_CONFIG, FCM_CONFIG, APNS_CONFIG, BASE_DIR, APNS_MODE, SERVER_TYPE
+    OSS_STS_ACCESS_KEY, OSS_STS_ACCESS_SECRET, AWS_ACCESS_KEY_ID, AWS_SECRET_ACCESS_KEY
 from Ansjer.config import PUSH_REDIS_ADDRESS
 from Ansjer.config import PUSH_REDIS_ADDRESS
 from Model.models import Device_Info, VodHlsModel, Equipment_Info, UidSetModel, UidPushModel, CompanyModel, SysMsgModel, \
 from Model.models import Device_Info, VodHlsModel, Equipment_Info, UidSetModel, UidPushModel, CompanyModel, SysMsgModel, \
     AiService
     AiService
@@ -35,7 +17,6 @@ from Object.ETkObject import ETkObject
 from Object.RedisObject import RedisObject
 from Object.RedisObject import RedisObject
 from Object.ResponseObject import ResponseObject
 from Object.ResponseObject import ResponseObject
 from Object.TokenObject import TokenObject
 from Object.TokenObject import TokenObject
-from Object.UidTokenObject import UidTokenObject
 from Service.CommonService import CommonService
 from Service.CommonService import CommonService
 from Service.EquipmentInfoService import EquipmentInfoService
 from Service.EquipmentInfoService import EquipmentInfoService
 
 
@@ -68,7 +49,6 @@ class DetectControllerViewV2(View):
             userID = tko.userID
             userID = tko.userID
             # 修改推送设置
             # 修改推送设置
             if operation == 'changeStatus':
             if operation == 'changeStatus':
-                print("进入changeStatus")
                 return self.do_change_status(userID, request_dict, response)
                 return self.do_change_status(userID, request_dict, response)
             # 查询推送信息
             # 查询推送信息
             elif operation == 'queryInfo':
             elif operation == 'queryInfo':
@@ -89,11 +69,10 @@ class DetectControllerViewV2(View):
         status = request_dict.get('status', None)
         status = request_dict.get('status', None)
         m_code = request_dict.get('m_code', None)
         m_code = request_dict.get('m_code', None)
         uid = request_dict.get('uid', None)
         uid = request_dict.get('uid', None)
-        # 设备语言
         lang = request_dict.get('lang', 'en')
         lang = request_dict.get('lang', 'en')
         tz = request_dict.get('tz', '0')
         tz = request_dict.get('tz', '0')
         company_secrete = request_dict.get('company_secrete', None)
         company_secrete = request_dict.get('company_secrete', None)
-        region = request_dict.get('region', None)  # app必须传:2:国内 1:国外
+        region = request_dict.get('region', None)  # app必须传:1:国外,2:国内
         electricity_status = request_dict.get('electricity_status', None)
         electricity_status = request_dict.get('electricity_status', None)
         if not region:
         if not region:
             return response.json(444, 'region')
             return response.json(444, 'region')
@@ -121,16 +100,7 @@ class DetectControllerViewV2(View):
         print('push_type:', push_type)
         print('push_type:', push_type)
 
 
         try:
         try:
-            if push_type == '0':
-                if appBundleId not in APNS_CONFIG.keys():
-                    return response.json(904)
-            elif push_type == '1':
-                if appBundleId not in FCM_CONFIG.keys():
-                    return response.json(904)
-            elif push_type == '2':
-                if appBundleId not in JPUSH_CONFIG.keys():
-                    return response.json(904)
-            else:
+            if push_type == '0' or push_type == '1' or push_type == '2':
                 return response.json(173)
                 return response.json(173)
 
 
             # 判断用户是否拥有设备
             # 判断用户是否拥有设备
@@ -227,7 +197,6 @@ class DetectControllerViewV2(View):
                     }
                     }
                     uid_push_qs.update(**uid_push_update_dict)
                     uid_push_qs.update(**uid_push_update_dict)
                 else:
                 else:
-                    # uid_set_id = uid_set_qs[0].id
                     uid_push_create_dict = {
                     uid_push_create_dict = {
                         'uid_set_id': uid_set_id,
                         'uid_set_id': uid_set_id,
                         'userID_id': userID,
                         'userID_id': userID,
@@ -248,9 +217,6 @@ class DetectControllerViewV2(View):
                     self.do_delete_redis(uid, interval)
                     self.do_delete_redis(uid, interval)
                 else:
                 else:
                     self.do_delete_redis(uid)
                     self.do_delete_redis(uid)
-                # utko = UidTokenObject()
-                # # right
-                # utko.generate(data={'uid': uid})
                 etkObj = ETkObject(etk='')
                 etkObj = ETkObject(etk='')
                 etk = etkObj.encrypt(uid)
                 etk = etkObj.encrypt(uid)
 
 
@@ -440,8 +406,6 @@ class DetectControllerViewV2(View):
             print(repr(e))
             print(repr(e))
             return response.json(474)
             return response.json(474)
 
 
-
-
     def do_update_interval(self, userID, request_dict, response):
     def do_update_interval(self, userID, request_dict, response):
         uid = request_dict.get('uid', None)
         uid = request_dict.get('uid', None)
         interval = request_dict.get('interval', None)
         interval = request_dict.get('interval', None)