locky 2 жил өмнө
parent
commit
1cdb993adb

+ 1 - 0
Ansjer/local_config/config_local.py

@@ -20,6 +20,7 @@ PUSH_BUCKET = 'push'                                # 推送存储桶
 PUSH_INACCURATE_BUCKET = 'push-inaccurate'          # 推送不准确存储桶
 AVATAR_BUCKET = 'avatar-cn'                         # 头像存储桶
 LOG_BUCKET = 'ansjer-statres'                       # 日志存储桶
+PUSH_CLOUD_PHOTO = 'push-cloud-photo'               # 推送云相册存储桶
 
 # redis节点
 SERVER_HOST = '127.0.0.1'

+ 1 - 0
Ansjer/server_urls/kvs_url.py

@@ -8,5 +8,6 @@ from django.urls import re_path
 from Controller.AWS import KVSController
 
 urlpatterns = [
+    re_path(r'^user-related/(?P<operation>.*)$', KVSController.UserRelatedView.as_view()),
     re_path(r'^(?P<operation>.*)$', KVSController.KVSView.as_view()),
 ]

+ 75 - 0
Controller/AWS/KVSController.py

@@ -15,6 +15,81 @@ from Object.AWS.AmazonKinesisVideoUtil import AmazonKinesisVideoObject
 from Object.ResponseObject import ResponseObject
 from Ansjer.config import ACCESS_KEY_ID, SECRET_ACCESS_KEY, REGION_NAME
 
+
+class UserRelatedView(View):
+    def get(self, request, *args, **kwargs):
+        request.encoding = 'utf-8'
+        operation = kwargs.get('operation')
+        return self.validation(request.GET, operation)
+
+    def post(self, request, *args, **kwargs):
+        request.encoding = 'utf-8'
+        operation = kwargs.get('operation')
+        return self.validation(request.POST, operation)
+
+    def validation(self, request_dict, operation):
+        response = ResponseObject()
+        if operation == 'generate-qr-code':  # 网页生成二维码
+            return self.generate_qr_code(request_dict, response)
+        elif operation == 'web-login':  # 网页登录
+            return self.web_login(request_dict, response)
+        elif operation == 'confirm-login':  # app确认登录
+            return self.confirm_login(request_dict, response)
+        else:
+            return response.json(404)
+
+    @staticmethod
+    def generate_qr_code(request_dict, response):
+        """
+        网页生成二维码
+        @param request_dict: 请求参数
+        @request_dict serial_number: 序列号
+        @param response: 响应对象
+        @return: response
+        """
+        serial_number = request_dict.get('serial_number', None)
+
+        try:
+            return response.json(0)
+        except Exception as e:
+            print(e)
+            return response.json(500)
+
+    @staticmethod
+    def web_login(request_dict, response):
+        """
+        网页登录
+        @param request_dict: 请求参数
+        @request_dict serial_number: 序列号
+        @param response: 响应对象
+        @return: response
+        """
+        serial_number = request_dict.get('serial_number', None)
+
+        try:
+            return response.json(0)
+        except Exception as e:
+            print(e)
+            return response.json(500)
+
+    @staticmethod
+    def confirm_login(request_dict, response):
+        """
+        app确认登录
+        @param request_dict: 请求参数
+        @request_dict serial_number: 序列号
+        @param response: 响应对象
+        @return: response
+        """
+        serial_number = request_dict.get('serial_number', None)
+
+        try:
+            return response.json(0)
+        except Exception as e:
+            print(e)
+            return response.json(500)
+
+
 class KVSView(View):
     def get(self, request, *args, **kwargs):
         request.encoding = 'utf-8'