万家乐热水器接入求助 - 『瀚思彼岸』» 智能家居技术论坛

<div class="blockcode"><blockquote>import socket
import time
class Wanjiale:
def __init__(self, ip, port):
# 创建套接字对象，进行TCP连接
self.tcp_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
self.ip = ip
self.port = port
self.server_address = (ip, port)
self.tcp_socket.connect(self.server_address)
def send_data(self, data):
'''发送所需的数据'''
payload = bytes.fromhex(data)
self.tcp_socket.send(payload)
response = self.tcp_socket.recv(1024)
return response
def close(self):
'''关闭连接'''
self.tcp_socket.close()
if __name__ == '__main__':
# TCP数据载荷
# len: 87
open_data1 = 'aabb1100120050831186ec120f228fa7122007211b6e411b9b55a8327a87b2eac97af267c0ddb935989f42ce010a9eead64027a800e526810974579b8502efb932a9fb60b75b2a1d22d1ca5d84ac72b915bf745ed6a520'
# len: 103
open_data2 = 'aabb1100a10060da3d2c9f6100b1db77b42d5806d8aa91dbf152e085bcf9f1de37d79159294299fdf6a3b4aa208fe1399f27858f4344a3f1d3f4d26c76e0ab81e0f8daa95254d89d2f7d3b025e7f3ddfd886b5fd3a8bf6a42c39253b936067b4eb1688228e7d44'
# len: 87
open_data3 = 'aabb1100470050edfb116b8f410efdaed5a855daef8a81fc709740e5e1cfb0825a529b31a5d626598d91c0531679a4ca6327444f8e93c0520b8db763349ace3bf4cf39fb50fce3adaa9991dd1f6ec73b70a796f485d7bb'
# len: 190
open_data4 = 'aabb11007f00504a82630c8ee49d52a26ef489fddd00fd4ab63ad13fd350a51ff77c6facfcada9bc32101f0e7f0677733078319dbf63bdee3c688bd0a14cfcdbf39c1b6b2c5a980ac2b2b019ecd7521370b99727e47138aabb1100a300604feafe5e61b80a70f2edfc6d0602d9894f615e7ea1ba7a9cd70c637b1bced3113cab31a6b8e1464c91a801f1e19c40f1fa31808055c55c72a3d931f2bda71fc85429d9f1717308ea88c4ed7860703f204e1523b28349765541de08af29b732ea'
wanjiale = Wanjiale('192.168.3.245', 7681)
response1 = wanjiale.send_data(open_data1)
print(response1)
time.sleep(1)
response2 = wanjiale.send_data(open_data2)
print(response2)
time.sleep(3)
response3 = wanjiale.send_data(open_data3)
print(response3)
time.sleep(1)
response4 = wanjiale.send_data(open_data4)
print(response4)
time.sleep(1)
wanjiale.close()

复制代码

const net = global.get('net');
async function sendTcpMessages(messages) {
const client = new net.Socket();
try {
node.status({ fill: "yellow", shape: "ring", text: "正在连接…" });
// 连接到服务器
await new Promise((resolve, reject) => {
client.connect(7681, '192.168.31.59', () => resolve());
client.on('error', reject);
node.status({ fill: "red", shape: "dot", text: "连接失败" });
});
// 按顺序发送消息
for (const message of messages) {
await new Promise((resolve, reject) => {
client.write(Buffer.from(message, "hex"), (err) => {
if (err) reject(err);
else resolve();
});
});
node.log(`Sent: ${message}`);
// console.log(`Sent: ${message}`);
}
node.status({ fill: "green", shape: "dot", text: "发送完成" });
} catch (error) {
node.error('Error:', error);
node.status({ fill: "red", shape: "dot", text: "发送出现错误" });
// console.error('Error:', error);
} finally {
client.end();
}
}
// 使用示例
const messages = [
"aabb08028c00106f54faf4c95c8e6572c9eba9bee63e5d9e99",
"aabb11006700408882f42408bd03b25cedcad29f5ecf00f28393903783fba9826067ca6a6337fd441a30f7c4864bf6b5f1a85f688c35c05a783f3951d934d2269e5e46c8042f75",
"aabb1100310050e7dd5f1b35d9f21d5afa1dbf8e64fcb91491878ef4bf076ba332c24f7ba677daf97903e1bcbedfe477aaab8267cb3d49bc2f17d3628dd49cd127349a657d2dcd486f5e329475db8f95298534fa0b0cc9",
"aabb11006e0050d3a985bb41087e7e0ec3a2d43533037f9b83432fcb329251a0fb9fbd2d77b910016cf0abd946643dde06f91cb1878922b4dab6d07542979681c8609a8bc3152ebf02b0c9c710422fefe97681c94f8f30",
"aabb11009a0050f06078aaf3d779dbe62ecb0a83c8987ee3453534e6ba8b6900c86c902900ea8c387147e3b0bacd4ef72716a5a27ecf9af77b5655bd6c9fb7504de2e97ec232d56ce0f02a5bec384e2d0b02b1101abf8f",
"aabb1100d900504e027faf1525b7ac53ac07f40b05c8dd3af33a5a00dd1eabb05b1d84d6750f2aee02b37127ae9df87a048df425ebeba647d9076fd10dac916c264bdb41be0cecc8cdfafe874665cbffcab8d699b34541aabb1100a20050512385d3dd30f022adb6b709baec18a2cd4fb5d9c3e17d5a6b2a4b23f13c9e5a792e25d782bad1008d39f72e79778fd4aa69ee3aae75f4b81955c6ab694d2669e09ad3c780745ed0aab35cbdb012f2c0"
];
sendTcpMessages(messages);

复制代码