| | |
|---|
| | | // 服务器地址（协议+地址+端口号） |
|---|
| | | String uri = "tcp://" + SettingConfig.getInstance().MQTT_IP+":"+SettingConfig.getInstance().MQTT_PORT;; |
|---|
| | | LogUtils.i(uri); |
|---|
| | | client = new MqttAndroidClient(this, uri, CacheDiskUtils.getInstance().getString(SettingConfig.getInstance().Cache_Device_Code)); |
|---|
| | | client = new MqttAndroidClient(this, uri, CacheDiskUtils.getInstance().getString(SettingConfig.getInstance().Cache_Device_Code)+"houping"); |
|---|
| | | // 设置MQTT监听并且接受消息 |
|---|
| | | client.setCallback(mqttCallback); |
|---|
| | | conOpt = new MqttConnectOptions(); |
|---|
| | |
|---|
| | | dvmessage.setDeviceType(DeviceType.CANGUI.ordinal()); |
|---|
| | | dvmessage.setMessageByte(command); |
|---|
| | | EventBus.getDefault().post(dvmessage); |
|---|
| | | //判断是否是取餐的，如果是取餐的，需要将这个订单从本地删除掉 |
|---|
| | | String qucan = json.getString("qucan"); |
|---|
| | | if (qucan!=null && "1".equals(qucan)){ |
|---|
| | | SqlliteDbManage.getInstance().deleteFromOrderByGridNo(grid); |
|---|
| | | SqlliteDbManage.getInstance().updateGridByStr(grid,0); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
