| | |
| | | import com.hdl.sdk.link.common.utils.ThreadToolUtils;
|
| | | import com.hdl.sdk.link.core.bean.LinkRequest;
|
| | | import com.hdl.sdk.link.core.bean.LinkResponse;
|
| | | import com.hdl.sdk.link.core.bean.ModbusResponse;
|
| | | import com.hdl.sdk.link.core.bean.ZigbeeResponse;
|
| | | import com.hdl.sdk.link.core.bean.gateway.GatewayBean;
|
| | | import com.hdl.sdk.link.core.config.HDLLinkConfig;
|
| | |
| | | */
|
| | | if (code == null || code.intValue() == 200 || code.intValue() == 0) {
|
| | | notifySucceed(msg);
|
| | | }else {
|
| | | } else {
|
| | | notifyFailure(ErrorUtils.getByCode(code));
|
| | | }
|
| | | }
|
| | | else if (msg instanceof ZigbeeResponse) {
|
| | | } else if (msg instanceof ZigbeeResponse) {
|
| | | ZigbeeResponse linkResponse = (ZigbeeResponse) msg;
|
| | | //TODO 如果配置从网关的信息,通过主网关转达,这里oid要判断下
|
| | | if (replyTopic.equals(linkResponse.getTopic())) {
|
| | | notifySucceed(linkResponse.getData());
|
| | | }
|
| | | else{
|
| | | } else {
|
| | | notifyFailure(HDLLinkCode.HDL_TOPIC_NOT_RIGHT);
|
| | | }
|
| | | }
|
| | | else{
|
| | | } else if (msg instanceof ModbusResponse) {
|
| | | ModbusResponse response = (ModbusResponse) msg;
|
| | | if (replyTopic.equals(response.getTopic())) {
|
| | | notifySucceed(response.getData());
|
| | | } else {
|
| | | notifyFailure(HDLLinkCode.HDL_TOPIC_NOT_RIGHT);
|
| | | }
|
| | | } else {
|
| | | notifyFailure(new HDLLinkCode(HDLLinkCode.HDL_OBJECT_NOT_SUPPORT.getCode(), "Object Name:" + msg));
|
| | | }
|
| | | } catch (Exception e) {
|
| | |
| | | * @param mac 设备mac
|
| | | */
|
| | | public HDLConnectHelper(Long sendAwaitTime, int maxRetry, String ipAddress, int port,
|
| | | LinkRequest linkRequest, HdlSocketListener listener, boolean isTcp,String mac) {
|
| | | this(sendAwaitTime,maxRetry,ipAddress,port,linkRequest,listener,isTcp);
|
| | | LinkRequest linkRequest, HdlSocketListener listener, boolean isTcp, String mac) {
|
| | | this(sendAwaitTime, maxRetry, ipAddress, port, linkRequest, listener, isTcp);
|
| | | this.mac = mac;
|
| | | }
|
| | |
|
| | |
| | | * @param mac 设备mac
|
| | | */
|
| | | public HDLConnectHelper(String ipAddress,
|
| | | LinkRequest linkRequest, HdlSocketListener listener, boolean isTcp,String mac) {
|
| | | this(DEF_SEND_TIMEOUT, DEF_MAX_RETRY, ipAddress, isTcp ? TCP_PORT : UDP_PORT, linkRequest, listener, isTcp,mac);
|
| | | LinkRequest linkRequest, HdlSocketListener listener, boolean isTcp, String mac) {
|
| | | this(DEF_SEND_TIMEOUT, DEF_MAX_RETRY, ipAddress, isTcp ? TCP_PORT : UDP_PORT, linkRequest, listener, isTcp, mac);
|
| | | }
|
| | |
|
| | |
|
| | |
|
| | | /**
|
| | |
| | | * @param linkRequest 发送对象
|
| | | * @param isTcp 是否TCP
|
| | | */
|
| | | public HDLConnectHelper(Long timeout,String ipAddress, LinkRequest linkRequest, boolean isTcp) {
|
| | | public HDLConnectHelper(Long timeout, String ipAddress, LinkRequest linkRequest, boolean isTcp) {
|
| | | this(timeout, DEF_SEND_ONE, ipAddress, isTcp ? TCP_PORT : UDP_PORT, linkRequest, null, isTcp);
|
| | | }
|
| | |
|
| | |
|
| | |
|
| | | /**
|
| | |
| | | byte[] encryBytes = null;
|
| | | GatewayBean gatewayBean = HDLLinkLocalGateway.getInstance().getLocalGateway(mac);
|
| | | if (gatewayBean != null && getGatewayTypeList().contains(gatewayBean.getGatewayType())) {
|
| | | //毫米波远程mqtt秘钥不一样
|
| | | //逆变器远程mqtt秘钥不一样
|
| | | encryBytes = EncryptUtil.encryBytes(linkRequest.getCloudSendBytes(), gatewayBean.getAesKey());
|
| | | } else {
|
| | | encryBytes = EncryptUtil.encryBytes(linkRequest.getCloudSendBytes(), HDLLinkConfig.getInstance().getAesKey());
|
| | |
| | | */
|
| | | public static List<String> getGatewayTypeList() {
|
| | | List<String> typeList = new ArrayList<>();
|
| | | typeList.add("sensor.mmv_sleep");//睡眠毫米波spk
|
| | | typeList.add("sensor.mmv_pose");//姿态毫米波spk
|
| | | // typeList.add("sensor.mmv_sleep");//睡眠毫米波spk
|
| | | // typeList.add("sensor.mmv_pose");//姿态毫米波spk
|
| | | typeList.add("energy.hdl_inverter");//逆变器spk
|
| | | return typeList;
|
| | | }
|
| | |
|