修改通道名接口

Controller/EquipmentManagerV3.py

@@ -53,6 +53,8 @@ class EquipmentManagerV3(View):
             return self.test_tool_del_device(request_dict, response)
         elif operation == 'changeDevicePassword':
             return self.change_device_password(request_dict, response)
+        elif operation == 'modifyChannelName':
+            return self.do_modify_channel_name(request_dict, response)
 
         token = request_dict.get('token', None)
         tko = TokenObject(token)
@@ -69,8 +71,6 @@ class EquipmentManagerV3(View):
             return self.do_query(userID, request_dict, response)
         elif operation == 'modify':
             return self.do_modify(userID, request_dict, response, request)
-        elif operation == 'modifyChannelName':
-            return self.do_modify_channel_name(userID, request_dict, response, request)
         elif operation == 'fuzzyQuery':
             return self.do_fuzzy_query(userID, request_dict, response)
         elif operation == 'mainUserDevice':
@@ -754,16 +754,29 @@ class EquipmentManagerV3(View):
 
             return response.json(0, res)
 
-    # 编辑通道名
-    def do_modify_channel_name(self, userID, request_dict, response):
+    @staticmethod
+    def do_modify_channel_name(request_dict, response):
+        """
+        修改通道名
+        @param request_dict:
+        @param response:
+        @return:
+        """
         uid = request_dict.get('uid', None)
         channel = request_dict.get('channel', None)
         channel_name = request_dict.get('channel_name', None)
         if not all([uid, channel, channel_name]):
             return response.json(444)
-        # 更新通道名
-        UidChannelSetModel.objects.filter(uid__uid=uid).update(channel_name=channel_name)
-        return response.json(0)
+        try:
+            # 更新通道名
+            channel = int(channel) + 1
+            uid_channel_set_qs = UidChannelSetModel.objects.filter(uid__uid=uid, channel=channel)
+            if not uid_channel_set_qs.exists():
+                return response.json(173)
+            uid_channel_set_qs.update(channel_name=channel_name)
+            return response.json(0)
+        except Exception as e:
+            return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
 
     def do_query(self, userID, request_dict, response):
         """