修改更新一键通话消息状态为已接听接口

Controller/EquipmentInfo.py

@@ -218,23 +218,12 @@ class EquipmentInfo(View):
         @param response:
         @return:
         """
-        ei_id = request_dict.getlist('id', None)
-        if ei_id is None:
+        uid = request_dict.get('uid', None)
+        event_time = request_dict.get('event_time', None)
+        if not all([uid, event_time]):
             return response.json(444)
-        count = 0
-        tab_val = int(ei_id[0:1])
-        ei_id = int(ei_id[1:])
-        eq = EquipmentInfoService.get_equipment_info_model('', tab_val)
-        eq = eq.filter(id=ei_id)
-        if not eq.exists():
-            return response.json(173)
-        own_dev = ModelService.check_own_device(user_id, eq[0].device_uid)
-        if own_dev:
-            count += 1
-            eq.update(answer_status=1)
-            return response.json(0, {'update_success': count})
-        else:
-            return response.json(14)
+        EquipmentInfoService.update_equipment_answer_status(user_id, uid, event_time)
+        return response.json(0)
 
     def delete_info(self, request_dict, userID, response):
         id_list = request_dict.getlist('id[]', None)

Service/EquipmentInfoService.py

@@ -424,3 +424,27 @@ class EquipmentInfoService:
         except Exception as e:
             print('推送错误异常,errLine:{}, errMsg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
             return res_list
+
+    @staticmethod
+    def update_equipment_answer_status(user_id, uid, event_time):
+        """
+        更新一键通话消息状态
+        @param user_id: 用户id
+        @param uid: uid
+        @param event_time: 事件时间
+        @return:
+        """
+        EquipmentInfoMonday.objects.filter(device_user_id=user_id, device_uid=uid, event_time=event_time,
+                                           event_type=606).update(answer_status=1)
+        EquipmentInfoTuesday.objects.filter(device_user_id=user_id, device_uid=uid, event_time=event_time,
+                                            event_type=606).update(answer_status=1)
+        EquipmentInfoWednesday.objects.filter(device_user_id=user_id, device_uid=uid, event_time=event_time,
+                                              event_type=606).update(answer_status=1)
+        EquipmentInfoThursday.objects.filter(device_user_id=user_id, device_uid=uid, event_time=event_time,
+                                             event_type=606).update(answer_status=1)
+        EquipmentInfoFriday.objects.filter(device_user_id=user_id, device_uid=uid, event_time=event_time,
+                                           event_type=606).update(answer_status=1)
+        EquipmentInfoSaturday.objects.filter(device_user_id=user_id, device_uid=uid, event_time=event_time,
+                                             event_type=606).update(answer_status=1)
+        EquipmentInfoSunday.objects.filter(device_user_id=user_id, device_uid=uid, event_time=event_time,
+                                           event_type=606).update(answer_status=1)