上线修改一键通话状态接口

Controller/EquipmentInfo.py

@@ -53,6 +53,8 @@ class EquipmentInfo(View):
             return self.add_info(request_dict, userID, response)
         elif operation == 'update':
             return self.update_info(request_dict, userID, response)
+        elif operation == 'update-answer-status':
+            return self.update_answer_status(request_dict, userID, response)
         elif operation == 'delete':
             return self.delete_info(request_dict, userID, response)
         elif operation == 'findByTime':
@@ -207,6 +209,25 @@ class EquipmentInfo(View):
             else:
                 return response.json(444)
 
+    @staticmethod
+    def update_answer_status(request_dict, user_id, response):
+        """
+        更新一键通话消息状态为已接听
+        @param request_dict:
+        @param user_id: 用户id
+        @param response:
+        @return:
+        """
+        uid = request_dict.get('uid', None)
+        event_time = request_dict.get('event_time', None)
+        if not all([uid, event_time]):
+            return response.json(444)
+        updated = EquipmentInfoService.update_equipment_answer_status(user_id, uid, event_time)
+        if updated:
+            return response.json(0)
+        else:
+            return response.json(5)
+
     def delete_info(self, request_dict, userID, response):
         id_list = request_dict.getlist('id[]', None)
         if id_list is None or len(id_list) < 1:

Service/EquipmentInfoService.py

@@ -443,3 +443,43 @@ class EquipmentInfoService:
 
         else:
             return ',' + str(event_type) + ','
+
+    @staticmethod
+    def update_equipment_answer_status(user_id, uid, event_time):
+        """
+        更新一键通话消息状态
+        @param user_id: 用户id
+        @param uid: uid
+        @param event_time: 事件时间
+        @return updated_flag: bool
+        """
+        updated_flag = False
+        updated = EquipmentInfoMonday.objects.filter(device_user_id=user_id, device_uid=uid, event_time=event_time,
+                                                     event_type=606).update(answer_status=1)
+        if updated:
+            updated_flag = True
+        updated = EquipmentInfoTuesday.objects.filter(device_user_id=user_id, device_uid=uid, event_time=event_time,
+                                                      event_type=606).update(answer_status=1)
+        if updated:
+            updated_flag = True
+        updated = EquipmentInfoWednesday.objects.filter(device_user_id=user_id, device_uid=uid, event_time=event_time,
+                                                        event_type=606).update(answer_status=1)
+        if updated:
+            updated_flag = True
+        updated = EquipmentInfoThursday.objects.filter(device_user_id=user_id, device_uid=uid, event_time=event_time,
+                                                       event_type=606).update(answer_status=1)
+        if updated:
+            updated_flag = True
+        updated = EquipmentInfoFriday.objects.filter(device_user_id=user_id, device_uid=uid, event_time=event_time,
+                                                     event_type=606).update(answer_status=1)
+        if updated:
+            updated_flag = True
+        updated = EquipmentInfoSaturday.objects.filter(device_user_id=user_id, device_uid=uid, event_time=event_time,
+                                                       event_type=606).update(answer_status=1)
+        if updated:
+            updated_flag = True
+        updated = EquipmentInfoSunday.objects.filter(device_user_id=user_id, device_uid=uid, event_time=event_time,
+                                                     event_type=606).update(answer_status=1)
+        if updated:
+            updated_flag = True
+        return updated_flag