瀏覽代碼

移除缓存

zhangdongming 1 年之前
父節點
當前提交
8b2812c495
共有 1 個文件被更改,包括 1 次插入8 次删除
  1. 1 8
      Controller/gatewayController.py

+ 1 - 8
Controller/gatewayController.py

@@ -403,21 +403,14 @@ class GatewayView(View):
         """
         """
         智能插座开关状态推送
         智能插座开关状态推送
         """
         """
-        redis_obj = RedisObject(7)
         try:
         try:
-            switch_key = 'LOOCAM:SOCKET:SERIAL:NUMBER:{}:{}:{}'
             serial_number = request_dict.get('serialNumber', None)
             serial_number = request_dict.get('serialNumber', None)
             device_time = request_dict.get('deviceTime', None)
             device_time = request_dict.get('deviceTime', None)
             status = request_dict.get('status', None)
             status = request_dict.get('status', None)
             if not all([serial_number, status, device_time]):
             if not all([serial_number, status, device_time]):
                 return response.json(444)
                 return response.json(444)
             status = int(status)
             status = int(status)
-            switch_key = switch_key.format(serial_number, status, device_time)
-            switch = redis_obj.get_data(switch_key)
-            if switch and int(switch) == status:
-                return response.json(0, "电源开关状态重复上报")
             now_time = int(device_time) if device_time else int(time.time())
             now_time = int(device_time) if device_time else int(time.time())
-            LOGGER.info('已订阅成功接收:事件类型{},状态:{}'.format(serial_number, status))
             # 获取主用户设备id
             # 获取主用户设备id
             log_dict = {
             log_dict = {
                 'status': status,
                 'status': status,
@@ -425,7 +418,7 @@ class GatewayView(View):
                 'created_time': now_time,
                 'created_time': now_time,
             }
             }
             SceneLog.objects.create(**log_dict)
             SceneLog.objects.create(**log_dict)
-            redis_obj.set_data(switch_key, status, 60 * 10)
+            LOGGER.info('成功接收并保存,插座序列号{},状态:{}'.format(serial_number, status))
             return response.json(0)
             return response.json(0)
         except Exception as e:
         except Exception as e:
             print(repr(e))
             print(repr(e))