网关序列号绑定用户id，app获取用户绑定序列号

Controller/SensorGateway/GatewayDeviceController.py

@@ -22,7 +22,7 @@ from Model.models import FamilyRoomDevice, FamilyRoom, GatewaySubDevice, Device_
 from Object.ResponseObject import ResponseObject
 from Object.TokenObject import TokenObject
 from Service.CommonService import CommonService
-
+from Object.RedisObject import RedisObject
 
 class GatewayDeviceView(View):
 
@@ -57,6 +57,10 @@ class GatewayDeviceView(View):
             return self.my_family_list(user_id, response)
         elif operation == 'location-setting':
             return self.device_location_setting(user_id, request_dict, response)
+        elif operation == 'bind-serial-user':
+            return self.bind_serial_user(user_id, request_dict, response)
+        elif operation == 'get-serial-user':
+            return self.get_serial_user(user_id, request_dict, response)
 
     @classmethod
     def device_location_setting(cls, user_id, request_dict, response):
@@ -429,6 +433,47 @@ class GatewayDeviceView(View):
         data['accumulatedTime'] = socket_power_qs[0]['accumulated_time']
         return data
 
+    @classmethod
+    def bind_serial_user(cls, user_id, request_dict, response):
+        """
+        绑定网关序列号和用户id
+        @param user_id: 用户id
+        @param request_dict: 请求参数字典
+        @param response: 响应对象
+        @return:
+        """
+        serial_number = request_dict.get('serialNumber')
+        if not serial_number:
+            return response.json(444)
+        try:
+            redis_obj = RedisObject()
+            result = redis_obj.set_data(user_id, serial_number, 60)
+            if not result:
+                return response.json(178)
+            return response.json(0)
+        except Exception as e:
+            print(e)
+            return response.json(177, repr(e))
+
+    @classmethod
+    def get_serial_user(cls, user_id, request_dict, response):
+        """
+        获取用户id绑定网关序列号
+        @param user_id: 用户id
+        @param request_dict: 请求参数字典
+        @param response: 响应对象
+        @return:
+        """
+        try:
+            redis_obj = RedisObject()
+            serial_number = redis_obj.get_data(user_id)
+            if not serial_number:
+                return response.json(173)
+            return response.json(0, {'serialNumber': serial_number})
+        except Exception as e:
+            print(e)
+            return response.json(177, repr(e))
+
 #
 #                   ___====-_  _-====___
 #             _--^^^#####//      \\#####^^^--_