XMPoleManager.git

			@@ -7,6 +7,7 @@
			import com.aliyuncs.iot.model.v20180120.*;
			import com.sandu.common.execption.BusinessException;
			import com.sandu.ximon.admin.dto.DeviceStatus;
			import com.sandu.ximon.admin.localMQTT.util.HexFrameUtils;
			import com.sandu.ximon.admin.localMQTT.util.MqttClientUtil;
			import com.sandu.ximon.admin.manager.iot.frame.IRequestFrame;
			import com.sandu.ximon.admin.manager.iot.frame.inner.BaseResponseInnerFrame;
			@@ -68,7 +69,7 @@
			// Map map = JSON.parseObject(result, Map.class);
			// result = (String) map.get("msg");
			String result = MqttClientUtil.sendMqttMsg(deviceName,invokeParam.getFrame());
			return FrameUtils.transformMessageToFrame(result);
			return HexFrameUtils.transformMessageToFrame(result);
			}

			@Override
			@@ -87,7 +88,7 @@
			String frame = FrameUtils.transformMessageToFrame(iRequestFrame.getEncodeFrame()).toString();
			String result = MqttClientUtil.sendMqttMsg(deviceName,frame);
			log.info("自定义sendRRPC:请求帧：{},\n,响应帧:{}",iRequestFrame.toString(),result);
			return FrameUtils.transformMessageToFrame(result);
			return HexFrameUtils.transformMessageToFrame(result);
			}

			@Override
			@@ -105,7 +106,7 @@
			// result = (String) map.get("msg");
			String frame = FrameUtils.transformMessageToFrame(iRequestFrame.getEncodeFrame()).toString();
			String result = MqttClientUtil.sendMqttMsg(deviceName,frame);
			return FrameUtils.transformMessageToFrame(result);
			return HexFrameUtils.transformMessageToFrame(result);
			}


			@@ -195,10 +196,10 @@
			deviceStatus.setDeviceName(l);

			if (localMqttConnectStatusMap.get(l)!=null &&
			localMqttConnectStatusMap.get(l)== 1){
			deviceStatus.setStatus("ONLINE");
			}else {
			localMqttConnectStatusMap.get(l)== 0){
			deviceStatus.setStatus("OFFLINE");
			}else {
			deviceStatus.setStatus("ONLINE");
			}
			statusList.add(deviceStatus);
			});