| | |
|---|
| | | }
|
|---|
| | | if (MqttRecvClient.getInstance() != null) {
|
|---|
| | | MqttRecvClient.getInstance().send(requestTopic, encryBytes);
|
|---|
| | | }
|
|---|
| | | if (HDLConnectHelper.isInverterTopic(linkRequest.getCloudTopic())) {
|
|---|
| | | LogUtils.i("远程发送数据：" + linkRequest.getCloudTopic() + "\r\n" + Arrays.toString(byteArrayConvertIntArray(linkRequest.getCloudSendBytes())));
|
|---|
| | | } else {
|
|---|
| | | LogUtils.i("远程发送数据：" + linkRequest.getCloudTopic() + "\r\n" + new String(linkRequest.getCloudSendBytes()));
|
|---|
| | | if (HDLConnectHelper.isInverterTopic(linkRequest.getCloudTopic())) {
|
|---|
| | | LogUtils.i("远程发送数据：" + linkRequest.getCloudTopic() + "\r\n" + Arrays.toString(byteArrayConvertIntArray(linkRequest.getCloudSendBytes())));
|
|---|
| | | } else {
|
|---|
| | | LogUtils.i("远程发送数据：" + linkRequest.getCloudTopic() + "\r\n" + new String(linkRequest.getCloudSendBytes()));
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | //本地TCP
|
|---|
| | | else {
|
|---|
| | | linkRequest.setEncrypt(false);// 2024年01月31日16:34:22 默认明文通讯,因为创建电站,绑定逆变器时，需要设置参数给逆变器,这时候还没有秘钥;
|
|---|
| | | if (!linkRequest.getTopic().endsWith("heartbeat")) {//心跳主题数据过多，过滤下
|
|---|
| | | if (HDLConnectHelper.isInverterTopic(linkRequest.getTopic())) {
|
|---|
| | | LogUtils.i("本地发送数据：\r\n" + Arrays.toString(byteArrayConvertIntArray(linkRequest.getSendBytes())));
|
|---|
