Selaa lähdekoodia

更新连接通道接口

locky 1 kuukausi sitten
vanhempi
commit
45ad5fa656
2 muutettua tiedostoa jossa 21 lisäystä ja 0 poistoa
  1. 20 0
      Controller/EquipmentManagerV3.py
  2. 1 0
      Model/models.py

+ 20 - 0
Controller/EquipmentManagerV3.py

@@ -55,6 +55,8 @@ class EquipmentManagerV3(View):
             return self.change_device_password(request_dict, response)
             return self.change_device_password(request_dict, response)
         elif operation == 'modifyChannelName':
         elif operation == 'modifyChannelName':
             return self.do_modify_channel_name(request_dict, response)
             return self.do_modify_channel_name(request_dict, response)
+        elif operation == 'updateLinkedChannel':
+            return self.update_linked_channel(request_dict, response)
 
 
         token = request_dict.get('token', None)
         token = request_dict.get('token', None)
         tko = TokenObject(token)
         tko = TokenObject(token)
@@ -778,6 +780,24 @@ class EquipmentManagerV3(View):
         except Exception as e:
         except Exception as e:
             return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
             return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
 
 
+    @staticmethod
+    def update_linked_channel(request_dict, response):
+        """
+        更新连接通道
+        @param request_dict:
+        @param response:
+        @return:
+        """
+        uid = request_dict.get('uid', None)
+        linked_channel = request_dict.get('linked_channel', None)
+        if not all([uid, linked_channel]):
+            return response.json(444)
+        try:
+            UidSetModel.objects.filter(uid=uid).update(using_channel=linked_channel)
+            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):
     def do_query(self, userID, request_dict, response):
         """
         """
         首页查询设备列表
         首页查询设备列表

+ 1 - 0
Model/models.py

@@ -2298,6 +2298,7 @@ class UidSetModel(models.Model):
     id = models.AutoField(primary_key=True, verbose_name=u'自增标记ID')
     id = models.AutoField(primary_key=True, verbose_name=u'自增标记ID')
     uid = models.CharField(max_length=20, db_index=True, unique=True, verbose_name='设备UID')
     uid = models.CharField(max_length=20, db_index=True, unique=True, verbose_name='设备UID')
     channel = models.SmallIntegerField(default=0, verbose_name='通道数量')  #
     channel = models.SmallIntegerField(default=0, verbose_name='通道数量')  #
+    linked_channel = models.IntegerField(default=0, verbose_name='连接通道')
     detect_status = models.SmallIntegerField(default=0, verbose_name='推送开关')  # 状态[0:关闭,1:开启,2:用户解绑]
     detect_status = models.SmallIntegerField(default=0, verbose_name='推送开关')  # 状态[0:关闭,1:开启,2:用户解绑]
     detect_interval = models.IntegerField(verbose_name='推送间隔', default=60)  # 秒
     detect_interval = models.IntegerField(verbose_name='推送间隔', default=60)  # 秒
     addTime = models.IntegerField(verbose_name='添加时间', default=0, db_index=True)
     addTime = models.IntegerField(verbose_name='添加时间', default=0, db_index=True)