f

Ansjer/mqtt/mqtt_client.py

@@ -11,6 +11,29 @@
 @file: mqtt_client.py
 @Contact: chanjunkai@163.com
 """
+
+# encoding: utf-8
+
+
+import paho.mqtt.client as mqtt
+
+
+def on_connect(client, userdata, flags, rc):
+    print("Connected with result code "+str(rc))
+    client.subscribe("chat")
+
+
+def on_message(client, userdata, msg):
+    print(msg.topic+" " + ":" + str(msg.payload))
+
+client = mqtt.Client()
+client.on_connect = on_connect
+client.on_message = on_message
+client.connect("192.168.136.45", 1883, 60)
+client.loop_forever()
+
+
+exit()
 import paho.mqtt.client as mqtt
 
 HOST = "192.168.136.45"

Model/models.py

@@ -446,7 +446,7 @@ class App_Info(models.Model):
     minAppversion = models.CharField(blank=True,default='', max_length=12, verbose_name=u'系统版本')
     bundleVersion = models.CharField(blank=True, max_length=12, verbose_name=u'项目版本')
     content = models.TextField(blank=True, default='', verbose_name=u'更新内容')
-    app_type = models.IntegerField(default='', blank=True, verbose_name=u'app类型')
+    app_type = models.IntegerField(default=0, blank=True, verbose_name=u'app类型')
     add_time = models.DateTimeField(blank=True, null=True, verbose_name=u'加入时间', auto_now_add=True)
     update_time = models.DateTimeField(blank=True, verbose_name=u'更新时间', auto_now=True)
     downloadLink = models.TextField(blank=True, default='', verbose_name='升级')