|
@@ -17,6 +17,7 @@ from Service.CommonService import CommonService
|
|
|
from Service.EquipmentInfoService import EquipmentInfoService
|
|
|
from Service.HuaweiPushService.HuaweiPushService import HuaweiPushObject
|
|
|
from Service.PushService import PushObject
|
|
|
+LOGGER = logging.getLogger('info')
|
|
|
|
|
|
|
|
|
class GatewayView(View):
|
|
@@ -36,6 +37,8 @@ class GatewayView(View):
|
|
|
return self.gateway_push(request_dict, response)
|
|
|
elif operation == 'sceneLogPush': # 场景日志推送
|
|
|
return self.scene_log_push(request_dict, response)
|
|
|
+ elif operation == 'socket-push': # 插座推送
|
|
|
+ return self.socket_msg_push(request_dict, response)
|
|
|
else:
|
|
|
return response.json(414)
|
|
|
|
|
@@ -293,3 +296,10 @@ class GatewayView(View):
|
|
|
except Exception as e:
|
|
|
logger.info('---场景日志推送接口异常--- {}'.format(repr(e)))
|
|
|
return response.json(500, repr(e))
|
|
|
+
|
|
|
+ @classmethod
|
|
|
+ def socket_msg_push(cls, request_dict, response):
|
|
|
+ event_type = request_dict.get('type', None)
|
|
|
+ status = request_dict.get('status', None)
|
|
|
+ LOGGER.info('已订阅成功接收:事件类型{},状态:{}'.format(event_type, status))
|
|
|
+ return response.json(0)
|