Merge branch 'test' into pzb

Ansjer/config.py

@@ -37,7 +37,7 @@ OAUTH_ACCESS_TOKEN_SECRET = 'a+jbgnw%@1%zy^=@dn62%'
 OAUTH_REFRESH_TOKEN_SECRET = 'r+jbgnw%@1%zy^=@dn62%'
 # access_token超时
 # OAUTH_ACCESS_TOKEN_TIME = datetime.timedelta(hours=1)
-OAUTH_ACCESS_TOKEN_TIME = datetime.timedelta(days=7)
+OAUTH_ACCESS_TOKEN_TIME = datetime.timedelta(days=30)
 # refresh_token超时
 OAUTH_REFRESH_TOKEN_TIME = datetime.timedelta(days=30)
 # 腾讯验证,短信发送

Ansjer/urls.py

@@ -2,10 +2,11 @@ from django.conf.urls import url
 from django.urls import path, re_path
 
 from Controller import FeedBack, EquipmentOTA, EquipmentInfo, EquipmentSensor, StreamMedia, AdminManage, AppInfo, \
-    AccessLog, Test, MealManage, DeviceManage, EquipmentStatus, SysManage, DeviceLog, LogAccess, AppColophon,\
-    EquipmentManager, LogManager, PermissionManager, OTAEquipment, UidappController, shareUserPermission, \
+    AccessLog, Test, MealManage, DeviceManage, EquipmentStatus, SysManage, DeviceLog, LogAccess, AppColophon, \
+    EquipmentManager, LogManager, PermissionManager, OTAEquipment, shareUserPermission, \
     UserManger, CheckUserData, \
-    UserController, CloudVod, OrderContrller, VodBucket, DetectController,DeviceShare,UserBrandController,StsOssController,UIDPreview,SysMsg
+    UserController, CloudVod, OrderContrller, VodBucket, DetectController, DeviceShare, UserBrandController, \
+    StsOssController, UIDPreview, SysMsg
 
 urlpatterns = [
     url(r'^account/authcode$', UserController.authCodeView.as_view()),
@@ -73,7 +74,7 @@ urlpatterns = [
     url(r'^adminManage/manage', AdminManage.AdminManage.as_view()),  # 管理员专属view
     url(r'^equipment/OTA', EquipmentOTA.EquipmentOTA.as_view()),  # OTA重构类
     # url(r'^feedbackInfo', FeedBackInfo.FeedBackInfo.as_view()),  # 用户反馈信息
-    url(r'^userbrandinfo/(?P<operation>.*)$',UserBrandController.UserBrandInfo.as_view()), # 用户登录的手机端品牌记录统计信息表
+    url(r'^userbrandinfo/(?P<operation>.*)$', UserBrandController.UserBrandInfo.as_view()),  # 用户登录的手机端品牌记录统计信息表
 
     url(r'^appInfo', AppInfo.AppInfo.as_view()),  # app版本信息
     url(r'^accesslog', AccessLog.AccessLog.as_view()),
@@ -117,7 +118,7 @@ urlpatterns = [
     url(r'^cloudVod/(?P<operation>.*)$', CloudVod.CloudVodView.as_view()),
     url(r'^meal/(?P<operation>.*)$', MealManage.MealView.as_view()),
     url(r'^order/(?P<operation>.*)$', OrderContrller.OrderView.as_view()),
-    url(r'^uidApp/(?P<operation>.*)$', UidappController.UidappView.as_view()),
+    # url(r'^uidApp/(?P<operation>.*)$', UidappController.UidappView.as_view()),
     url(r'^appCol/(?P<operation>.*)$', AppColophon.AppColView.as_view()),
     url(r'^vodBucket/(?P<operation>.*)$', VodBucket.VodBucketView.as_view()),
     url(r'^UIDBucket/(?P<operation>.*)$', VodBucket.UidBucketView.as_view()),
@@ -130,7 +131,7 @@ urlpatterns = [
     url(r'^getTZ$', EquipmentStatus.getTZ),
 
     # oss授权
-    url(r'^stsOss/(?P<operation>.*)$',StsOssController.StsOssView.as_view()),
+    url(r'^stsOss/(?P<operation>.*)$', StsOssController.StsOssView.as_view()),
 
     # 用户反馈信息
     url(r'^feedback/(?P<operation>.*)$', FeedBack.FeedBackView.as_view()),

Controller/DetectController.py

@@ -26,7 +26,7 @@ from django.views.generic.base import View
 from Ansjer.config import OSS_STS_ACCESS_KEY, OSS_STS_ACCESS_SECRET
 from Ansjer.config import BASE_DIR
 from Ansjer.config import SERVER_DOMAIN
-from Model.models import Device_Info, VodHlsModel, UID_App, Equipment_Info, UidSetModel, UidPushModel
+from Model.models import Device_Info, VodHlsModel, Equipment_Info, UidSetModel, UidPushModel
 from Object.ResponseObject import ResponseObject
 from Object.TokenObject import TokenObject
 from Object.UidTokenObject import UidTokenObject
@@ -130,72 +130,6 @@ class DetectControllerView(View):
             res.append(p)
         return response.json(0, {'datas': res, 'count': count})
 
-    def do_change_status11(self, userID, request_dict, response):
-        uid = request_dict.get('uid', None)
-        token_val = request_dict.get('token_val', None)
-        appBundleId = request_dict.get('appBundleId', None)
-        app_type = request_dict.get('app_type', None)
-        push_type = request_dict.get('push_type', None)
-        status = request_dict.get('status', None)
-        m_code = request_dict.get('m_code', None)
-        # interval = request_dict.get('interval', None)
-        print('status:' + status)
-        if not status:
-            return response.json(444, 'status')
-        # 关闭推送
-        if status == '0':
-            if not all([app_type, appBundleId, uid, m_code]):
-                return response.json(444, 'app_type,appBundleId,uid,m_code')
-            uid_app_qs = UID_App.objects.filter(appBundleId=appBundleId, userID_id=userID, m_code=m_code, uid=uid,
-                                                app_type=app_type)
-            if uid_app_qs.exists():
-                uid_app_qs.update(status=0)
-                return response.json(0)
-            else:
-                return response.json(173)
-        # 开启推
-        elif status == '1':
-            if not all([appBundleId, app_type, token_val, uid, m_code]):
-                return response.json(444, 'appBundleId,app_type,token_val,uid,m_code')
-            dvqs = Device_Info.objects.filter(userID_id=userID, UID=uid)
-
-            if dvqs.exists():
-                now_time = int(time.time())
-                try:
-                    uid_app_qs = UID_App.objects.filter(appBundleId=appBundleId, userID_id=userID, token_val=token_val,
-                                                        uid=uid, m_code=m_code)
-                    print(uid_app_qs)
-                    if uid_app_qs.exists():
-                        update_dict = {'status': 1}
-                        # if interval:
-                        #     update_dict['interval'] = int(interval)
-                        uid_app_qs.update(**update_dict)
-                    else:
-                        create_dict = {
-                            'uid': uid,
-                            'userID_id': userID,
-                            'appBundleId': appBundleId,
-                            'app_type': app_type,
-                            'push_type': push_type,
-                            'token_val': token_val,
-                            'status': 1,
-                            'm_code': m_code,
-                            'addTime': now_time,
-                            'updTime': now_time}
-                        # if interval:
-                        #     create_dict['interval'] = int(interval)
-                        UID_App.objects.create(**create_dict)
-                except Exception as e:
-                    print(repr(e))
-                    return response.json(10, repr(e))
-                else:
-                    utko = UidTokenObject()
-                    utko.generate(data={'uid': uid})
-                    detectUrl = "{SERVER_DOMAIN}notify/push?uidToken={uidToken}". \
-                        format(uidToken=utko.token, SERVER_DOMAIN=SERVER_DOMAIN)
-                    return response.json(0, {'detectUrl': detectUrl})
-            else:
-                return response.json(173)
 
     def do_change_status(self, userID, request_dict, response):
         uid = request_dict.get('uid', None)
@@ -319,55 +253,49 @@ class NotificationView(View):
         if uid_set_qs.exists():
             uid_set_id = uid_set_qs[0].id
             uid_push_qs = UidPushModel.objects.filter(uid_set__id=uid_set_id).values('token_val', 'app_type',
-                                                                                     'appBundleId', 'push_type', 'uid',
-                                                                                     'userID_id', 'userID__NickName',
-                                                                                     'interval')
+                                                                                     'appBundleId', 'push_type',
+                                                                                     'userID_id', 'userID__NickName')
             if uid_set_qs.exists():
-                pass
+                redisObj = RedisObject(db=6)
+                pkey = '{uid}_{channel}_ptl'.format(uid=uid, channel=channel)
+                if redisObj.get_data(key=pkey):
+                    res_data = {'code': 0, 'msg': 'success,!'}
+                    return JsonResponse(status=200, data=res_data)
+                else:
+                    detect_interval = uid_set_qs[0].detect_interval
+                    if detect_interval:
+                        redisObj.set_data(key=pkey, val=1, expire=detect_interval)
+                auth = oss2.Auth(OSS_STS_ACCESS_KEY, OSS_STS_ACCESS_SECRET)
+                bucket = oss2.Bucket(auth, 'oss-cn-shenzhen.aliyuncs.com', 'apg')
+                for up in uid_push_qs:
+                    push_type = up['push_type']
+                    # ios apns
+                    if push_type == 0:
+                        self.do_apns(request_dict, up, response, uid)
+                    # android gcm
+                    elif push_type == 1:
+                        self.do_gmc(request_dict, up, response, uid)
+                    # android jpush
+                    elif push_type == 2:
+                        self.do_jpush(request_dict, up, response, uid)
+                    # self.do_save_equipment_info(ua, n_time, channel, event_type, is_st)
+                # 需求不一样，所以这么做的
+                self.do_bulk_create_info(uid_push_qs, n_time, channel, event_type, is_st, uid)
+                if is_st == '0' or is_st == '2':
+                    return JsonResponse(status=200, data={'code': 0, 'msg': 'success'})
+                else:
+                    # Endpoint以杭州为例，其它Region请按实际情况填写。
+                    obj = '{uid}/{channel}/{filename}.jpeg'.format(uid=uid, channel=channel, filename=n_time)
+                    # 设置此签名URL在60秒内有效。
+                    url = bucket.sign_url('PUT', obj, 7200)
+                    res_data = {'code': 0, 'img_push': url, 'msg': 'success'}
+                    return JsonResponse(status=200, data=res_data)
             else:
                 return JsonResponse(status=200, data={'code': 404, 'msg': 'data is not exist'})
         else:
             return JsonResponse(status=200, data={'code': 404, 'msg': 'data is not exist'})
 
-        # if uaqs.exists():
-        #     redisObj = RedisObject(db=6)
-        #
-        #     auth = oss2.Auth(OSS_STS_ACCESS_KEY, OSS_STS_ACCESS_SECRET)
-        #     bucket = oss2.Bucket(auth, 'oss-cn-shenzhen.aliyuncs.com', 'apg')
-        #
-        #     for ua in uaqs:
-        #         push_type = ua['push_type']
-        #         pkey = '{uid}_{channel}_ptl'.format(uid=uid, channel=channel)
-        #         if redisObj.get_data(key=pkey):
-        #             res_data = {'code': 0, 'msg': 'success,!'}
-        #             return JsonResponse(status=200, data=res_data)
-        #         else:
-        #             if ua['interval']:
-        #                 redisObj.set_data(key=pkey, val=1, expire=ua['interval'])
-        #         # ios apns
-        #         if push_type == 0:
-        #             self.do_apns(request_dict, ua, response)
-        #         # android gcm
-        #         elif push_type == 1:
-        #             self.do_gmc(request_dict, ua, response)
-        #         # android jpush
-        #         elif push_type == 2:
-        #             self.do_jpush(request_dict, ua, response)
-        #
-        #         # self.do_save_equipment_info(ua, n_time, channel, event_type, is_st)
-        #     # 需求不一样，所以这么做的
-        #     self.do_bulk_create_info(uaqs, n_time, channel, event_type, is_st)
-        #     if is_st == '0' or is_st == '2':
-        #         return JsonResponse(status=200, data={'code': 0, 'msg': 'success'})
-        #     else:
-        #         # Endpoint以杭州为例，其它Region请按实际情况填写。
-        #         obj = '{uid}/{channel}/{filename}.jpeg'.format(uid=uid, channel=channel, filename=n_time)
-        #         # 设置此签名URL在60秒内有效。
-        #         url = bucket.sign_url('PUT', obj, 7200)
-        #         res_data = {'code': 0, 'img_push': url, 'msg': 'success'}
-        #         return JsonResponse(status=200, data=res_data)
-
-    def do_jpush(self, request_dict, uaql, response):
+    def do_jpush(self, request_dict, uaql, response, uid):
         event_type = request_dict.get('event_type', None)
         jpush_config = {
             'com.ansjer.accloud_ab': {
@@ -407,7 +335,6 @@ class NotificationView(View):
         n_time = request_dict.get('n_time', None)
         appBundleId = uaql['appBundleId']
         token_val = uaql['token_val']
-        uid = uaql['uid']
 
         response = ResponseObject()
         app_key = jpush_config[appBundleId]['Key']
@@ -433,12 +360,11 @@ class NotificationView(View):
         else:
             return response.json(0)
 
-    def do_gmc(self, request_dict, uaql, response):
+    def do_gmc(self, request_dict, uaql, response, uid):
 
         n_time = request_dict.get('n_time')
         appBundleId = uaql['appBundleId']
         token_val = uaql['token_val']
-        uid = uaql['uid']
         gcm_config = {
             'com.ansjer.zccloud_a': 'AAAAb9YP3rk:APA91bHu8u-CTpcd0g6lKPo0WNVqCi8jZub1cPPbSAY9AucT1HxlF65ZDUko9iG8q2ch17bwu9YWHpK1xI1gHSRXCslLvZlXEmHZC0AG3JKg15XuUvlFKACIajUFV-pOeGRT8tM6-31I',
             'com.ansjer.loocamccloud_a': 'AAAAb9YP3rk:APA91bFCgd-kbVmpK4EVpfdHH_PJZQCYTkOGnTZdIuBWEz2r7aMRsJYHOH3sB-rwcbaRWgnufTyjX9nGQxb6KxQbWVk4ah_H-M3IqGh6Mb60WQQAuR33V6g_Jes5pGL6ViuIxGHqVMaR',
@@ -466,11 +392,10 @@ class NotificationView(View):
         req = requests.post(url, data, headers=headers)
         return response.json(0)
 
-    def do_apns(self, request_dict, uaql, response):
+    def do_apns(self, request_dict, uaql, response, uid):
         token_val = uaql['token_val']
         n_time = request_dict.get('n_time')
         appBundleId = uaql['appBundleId']
-        uid = uaql['uid']
         apns_config = {
             'appbundleId': {'pem_path': 'xxxx', 'topic': 'topic', 'password': 'password'}
         }
@@ -494,29 +419,19 @@ class NotificationView(View):
         except Exception as e:
             return response.json(10, repr(e))
 
-    def do_save_equipment_info(self, uaql, n_time, channel, event_type, is_st):
-        Equipment_Info.objects.create(
-            userID_id=uaql['userID_id'],
-            eventTime=n_time,
-            eventType=event_type,
-            devUid=uaql['uid'],
-            devNickName=uaql['userID__NickName'],
-            Channel=channel,
-            alarm='0',
-            is_st=int(is_st),
-            receiveTime=n_time)
-
-    def do_bulk_create_info(self, uaqs, n_time, channel, event_type, is_st):
+    def do_bulk_create_info(self, uaqs, n_time, channel, event_type, is_st, uid):
         #
         qs_list = []
         nowTime = int(time.time())
+        # 设备昵称
+
         for dv in uaqs:
             add_data = {
                 'userID_id': dv["userID_id"],
                 'eventTime': n_time,
                 'eventType': event_type,
-                'devUid': dv['uid'],
-                'devNickName': dv['userID__NickName'],
+                'devUid': uid,
+                'devNickName': uid,
                 'Channel': channel,
                 'alarm': 'Motion \tChannel:{channel}'.format(channel=channel),
                 'is_st': int(is_st),

Controller/EquipmentManager.py

@@ -4,7 +4,7 @@ import traceback
 
 import simplejson as json
 from django.utils import timezone
-from Model.models import Device_User, Device_Info, UID_Bucket, UID_App, UID_Preview
+from Model.models import Device_User, Device_Info, UID_Bucket, UID_Preview, UidSetModel
 from django.db.models import Q
 from Object.ResponseObject import ResponseObject
 from Object.TokenObject import TokenObject
@@ -581,7 +581,7 @@ def queryInterface(request):
         dvql = dvqs[(page - 1) * line:page * line].values('id', 'userID', 'NickName', 'UID', 'View_Account',
                                                           'View_Password', 'ChannelIndex', 'Type', 'isShare',
                                                           'primaryUserID', 'primaryMaster', 'data_joined', 'version',
-                                                          'isVod', 'isExist','NotificationMode')
+                                                          'isVod', 'isExist', 'NotificationMode')
         dvls = CommonService.qs_to_list(dvql)
         uid_list = []
         for dvl in dvls:
@@ -629,12 +629,11 @@ def uid_status(request):
     response.lang = tko.lang
     if tko.code != 0:
         return response.json(tko.code)
-    qs = UID_App.objects.filter(uid=uid, userID_id=tko.userID).values('uid', 'status', 'interval')
-    print(qs)
+    qs = UidSetModel.objects.filter(uid=uid).values('uid', 'detect_status', 'detect_interval')
     if qs.exists():
         data = {
-            'push_status': qs[0]['status'],
-            'push_interval': qs[0]['interval']  # 推送间隔
+            'push_status': qs[0]['detect_status'],
+            'push_interval': qs[0]['detect_interval']  # 推送间隔
         }
         ubqs = UID_Bucket.objects.filter(uid=uid). \
             values('bucket__content', 'status', 'channel', 'endTime', 'uid')

Controller/StsOssController.py

@@ -63,8 +63,8 @@ class StsOssView(View):
         req.set_RoleArn(OSS_ROLE_ARN)
         req.set_RoleSessionName(userID)
         req.set_DurationSeconds(3600)
-        Resource_access = "acs:oss:*:*:{bucket_name}/{userID}*".format(bucket_name=bucket_name,
-                                                                       userID=userID)
+        Resource_access = "acs:oss:*:*:{bucket_name}/{userID}*".\
+            format(bucket_name=bucket_name,userID=userID)
         policys = {
             "Version": "1",
             "Statement": [

Controller/UidappController.py

@@ -1,157 +0,0 @@
-import time
-import traceback
-
-import simplejson as json
-from django.utils.decorators import method_decorator
-from django.views.decorators.csrf import csrf_exempt
-from django.views.generic.base import View
-
-from Model.models import UID_App
-from Object.ResponseObject import ResponseObject
-from Object.TokenObject import TokenObject
-from Service.CommonService import CommonService
-from Service.ModelService import ModelService
-
-'''
-# 管理员获取信息
-http://192.168.136.39:8000/uidApp/adminQuery?token=local&page=1&line=10
-  管理员删除信息
-http://192.168.136.39:8000/uidApp/adminDelete?token=local&id=2
-  管理员添加信息
-http://192.168.136.39:8000/uidApp/adminAdd?token=local&uid=JW3684H8BSHG9TTM111A&appBundleId=com.ansjer.accloud&app_type=2&token_val=ertewtwetrewrt
-  管理员编辑信息
-http://192.168.136.39:8000/uidApp/adminEdit?token=local&id=6&content={"token_val":"9999"}
-'''
-
-
-# 设备信息添加
-class UidappView(View):
-    @method_decorator(csrf_exempt)
-    def dispatch(self, *args, **kwargs):
-        return super(UidappView, self).dispatch(*args, **kwargs)
-
-    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()
-        if operation is None:
-            return response.json(444, 'error path')
-        token = request_dict.get('token', None)
-        # 设备主键uid
-        tko = TokenObject(token)
-        response.lang = tko.lang
-        if tko.code != 0:
-            return response.json(tko.code)
-        userID = tko.userID
-        if operation == 'adminDelete':
-            return self.do_admin_delete(request_dict, userID, response)
-        elif operation == 'adminQuery':
-            return self.do_admin_query(request_dict, userID, response)
-        elif operation == 'adminAdd':
-            return self.do_admin_add(request_dict, userID, response)
-        elif operation == 'adminEdit':
-            return self.do_admin_edit(request_dict, userID, response)
-        else:
-            return response.json(444, 'error path')
-
-    # 管理员删除
-    def do_admin_delete(self, request_dict, userID, response):
-        own_perm = ModelService.check_perm(userID, 20)
-        if own_perm is True:
-            id = request_dict.get('id')
-            try:
-                list = UID_App.objects.filter(id=id)
-                if list.exists():
-                    list.delete()
-                    return response.json(0)
-                else:
-                    return response.json(173)
-            except Exception as e:
-                print(repr(e))
-                return response.json(424, repr(e))
-        else:
-            return response.json(404)
-
-    # 管理员查询接口
-    def do_admin_query(self, request_dict, userID, response):
-        own_perm = ModelService.check_perm(userID, 20)
-        if own_perm is True:
-            page = request_dict.get('page', None)
-            line = request_dict.get('line', None)
-            page = int(page)
-            line = int(line)
-            omqs = UID_App.objects.filter()
-            if not omqs.exists():
-                return response.json(0, [])
-            count = omqs.count()
-            order_ql = omqs[(page - 1) * line:page * line].values("id", "uid", "app_type","appBundleId","push_type", "token_val", "addTime", "updTime","status", "userID__username")
-
-            order_list = list(order_ql)
-            print (order_list)
-            return response.json(0, {'data': order_list, 'count': count})
-
-        else:
-            return response.json(404)
-
-    # 管理员的添加
-    def do_admin_add(self, request_dict, userID, response):
-        own_perm = ModelService.check_perm(userID=userID, permID=40)
-        if own_perm is not True:
-            return response.json(404)
-        uid = request_dict.get('uid', None)
-        appBundleId = request_dict.get('appBundleId', None)
-        app_type = request_dict.get('app_type', None)
-        token_val = request_dict.get('token_val', None)
-        timestamp = int(time.time())
-        param_flag = CommonService.get_param_flag(
-            data=[uid, appBundleId, app_type, token_val])
-        if param_flag is not True:
-            return response.json(444)
-        try:
-            Uidapp = UID_App(
-                uid=uid,
-                appBundleId=appBundleId,
-                app_type=app_type,
-                token_val=token_val,
-                addTime=timestamp,
-                updTime=timestamp)
-            Uidapp.save()
-            return response.json(0)
-        except Exception:
-            errorInfo = traceback.format_exc()
-            print(errorInfo)
-            return response.json(500, {'details': errorInfo})
-
-    # 管理员的编辑
-    def do_admin_edit(self, request_dict, userID, response):
-        own_perm = ModelService.check_perm(userID=userID, permID=50)
-        if own_perm is not True:
-            return response.json(404)
-        deviceContent = request_dict.get('content', None)
-        id = request_dict.get('id', None)
-        if not deviceContent or not id:
-            return response.json(444, 'content,id')
-        try:
-            timestamp = int(time.time())
-            deviceData = json.loads(deviceContent)
-            uid_app = UID_App.objects.filter(id=id)
-            if uid_app.exists():
-                uid_app.update(updTime=timestamp, **deviceData)
-                return response.json(0)
-            else:
-                return response.json(173)
-        except Exception:
-            errorInfo = traceback.format_exc()
-            print(errorInfo)
-            return response.json(500, {'details': errorInfo})
-
-
-

Controller/UserController.py

@@ -26,7 +26,7 @@ from ratelimit.decorators import ratelimit
 
 from Ansjer.config import AuthCode_Expire, SERVER_DOMAIN
 from Controller.CheckUserData import DataValid, date_handler, RandomStr
-from Model.models import Device_User, Role, UID_App, SysMsgModel
+from Model.models import Device_User, Role,  SysMsgModel
 from Object.AWS.SesClassObject import SesClassObject
 from Object.AliSmsObject import AliSmsObject
 from Object.RedisObject import RedisObject
@@ -302,10 +302,11 @@ class LogoutView(TemplateView):
             m_code = request_dict.get('m_code', None)
             if m_code:
                 userID = tko.userID
-                uid_app = UID_App.objects.filter(userID_id=userID, m_code=m_code, status=1)
-                print(uid_app)
-                if uid_app.exists():
-                    uid_app.update(status=2)
+                #
+                # uid_app = UID_App.objects.filter(userID_id=userID, m_code=m_code, status=1)
+                # print(uid_app)
+                # if uid_app.exists():
+                #     uid_app.update(status=2)
             return response.json(0)
         else:
             return response.json(tko.code)
@@ -1129,19 +1130,20 @@ class InitInfoView(View):
         tko = TokenObject(token)
         if tko.code == 0:
             userID = tko.userID
-            return self.init_uid_app(request_dict, userID, response)
+            return self.init_uid(request_dict, userID, response)
         else:
             return response.json(tko.code)
 
     # 初始化设备token
-    def init_uid_app(self, request_dict, userID, response):
+    def init_uid(self, request_dict, userID, response):
         token_val = request_dict.get('token_val', None)
         m_code = request_dict.get('m_code', None)
-        uid_app = UID_App.objects.filter(userID_id=userID, token_val=token_val, status=2, m_code=m_code)
-        if uid_app.exists():
-            uid_app.update(status=1)
-        else:
-            pass
+        # uid_app = UID_App.objects.filter(userID_id=userID, token_val=token_val, status=2, m_code=m_code)
+        #
+        # if uid_app.exists():
+        #     uid_app.update(status=1)
+        # else:
+        #     pass
         sm_count = SysMsgModel.objects.filter(userID_id=userID, status=0).count()
         res = {
             'usmsg': sm_count

Model/models.py

@@ -614,25 +614,25 @@ class UID_Bucket(models.Model):
 
 
 # 推送uid绑定 app —— token_id
-class UID_App(models.Model):
-    id = models.AutoField(primary_key=True, verbose_name=u'自增标记ID')
-    userID = models.ForeignKey(Device_User, to_field='userID', on_delete=models.CASCADE)
-    uid = models.CharField(max_length=20, verbose_name='设备UID')
-    appBundleId = models.CharField(blank=True, max_length=32, verbose_name=u'appID')
-    app_type = models.IntegerField(default=0, verbose_name=u'app类型 1:ios,2:安卓')
-    push_type = models.IntegerField(default=0, verbose_name=u'推送类型')  # 0,apns 1,安卓gcm 2,极光
-    token_val = models.CharField(default='', max_length=160, verbose_name=u'设备验证令牌')
-    status = models.SmallIntegerField(default=0, verbose_name='状态[0:关闭,1:开启,2:用户解绑]')
-    m_code = models.CharField(default='', max_length=64, verbose_name='手机唯一标识')
-    interval = models.IntegerField(verbose_name='推送间隔', default=0)  # 秒
-    addTime = models.IntegerField(verbose_name='添加时间', default=0)
-    updTime = models.IntegerField(verbose_name='更新时间', default=0)
-
-    class Meta:
-        db_table = 'uid_app'
-        verbose_name = u'设备关联APP表'
-        verbose_name_plural = verbose_name
-        ordering = ('id',)
+# class UID_App(models.Model):
+#     id = models.AutoField(primary_key=True, verbose_name=u'自增标记ID')
+#     userID = models.ForeignKey(Device_User, to_field='userID', on_delete=models.CASCADE)
+#     uid = models.CharField(max_length=20, verbose_name='设备UID')
+#     appBundleId = models.CharField(blank=True, max_length=32, verbose_name=u'appID')
+#     app_type = models.IntegerField(default=0, verbose_name=u'app类型 1:ios,2:安卓')
+#     push_type = models.IntegerField(default=0, verbose_name=u'推送类型')  # 0,apns 1,安卓gcm 2,极光
+#     token_val = models.CharField(default='', max_length=160, verbose_name=u'设备验证令牌')
+#     status = models.SmallIntegerField(default=0, verbose_name='状态[0:关闭,1:开启,2:用户解绑]')
+#     m_code = models.CharField(default='', max_length=64, verbose_name='手机唯一标识')
+#     interval = models.IntegerField(verbose_name='推送间隔', default=0)  # 秒
+#     addTime = models.IntegerField(verbose_name='添加时间', default=0)
+#     updTime = models.IntegerField(verbose_name='更新时间', default=0)
+#
+#     class Meta:
+#         db_table = 'uid_app'
+#         verbose_name = u'设备关联APP表'
+#         verbose_name_plural = verbose_name
+#         ordering = ('id',)
 
 
 class UID_Preview(models.Model):