网关设备推送

Controller/gatewayController.py

@@ -6,10 +6,12 @@
 @IDE ：PyCharm
 """
 import logging
+import time
 
 from django.views.generic.base import View
 
 from Object.ResponseObject import ResponseObject
+from Service.EquipmentInfoService import EquipmentInfoService
 
 
 class GatewayView(View):
@@ -26,24 +28,34 @@ class GatewayView(View):
     def validation(self, request_dict, request, operation):
         response = ResponseObject()
         if operation == 'gatewayPush':  # 网关推送
-            return self.gatewayPush(request_dict, response)
+            return self.gateway_push(request_dict, response)
         else:
             return response.json(414)
 
-    def gatewayPush(self, request_dict, response):
+    def gateway_push(self, request_dict, response):
         logger = logging.getLogger('info')
-        serial_number = request_dict.get('serial_number', None)
-        zbsrc = request_dict.get('zbsrc', None)
-        zbstatus = request_dict.get('zbstatus', None)
-        time_stamp = request_dict.get('time_stamp', None)
-        time_stamp_token = request_dict.get('time_stamp_token', None)
-        logger.info(
-            '---调用网关推送接口--- zbsrc:{},zbstatus:{},time_stamp:{},time_stamp_token:{}'.format(
-                zbsrc,
-                zbstatus,
-                time_stamp,
-                time_stamp_token))
+        src_addr = request_dict.get('src_addr', None)
+        event_type = request_dict.get('event_type', None)
+        alarm = request_dict.get('alarm', None)
+        logger.info('---调用网关推送接口--- request_dict:{}'.format(request_dict))
+        if not all([src_addr, event_type, alarm]):
+            return response.json(444)
+
+        equipment_info_list = []
+        now_time = int(time.time())
+        device_user_id = '160879593527813800138000'
         try:
+            equipment_info_list.append(EquipmentInfoService.get_equipment_info_obj(
+                now_time,
+                add_time=now_time,
+                event_time=now_time,
+                receive_time=now_time,
+                device_uid=src_addr,
+                event_type=event_type,
+                alarm=alarm,
+                device_nick_name=src_addr,
+                device_user_id=device_user_id,
+            ))
             return response.json(0)
         except Exception as e:
             return response.json(500, repr(e))