xyj
/
xumu_iotdb
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

update

This commit is contained in:
xyj 2024-01-26 17:35:08 +08:00
parent 90b6da4758
commit 73818d2f8e
1 changed files with 0 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
xumu.py
View File

@ -141,7 +141,6 @@ async def register(request: Request):
payload = json.loads(payload) payload = json.loads(payload)
send_len = payload["l"] send_len = payload["l"]
if receive_len != send_len: if receive_len != send_len:
print(receive_len)
return BaseResponse(code=301, msg=f"data valid error, receive_len:{receive_len}") return BaseResponse(code=301, msg=f"data valid error, receive_len:{receive_len}")
deviceId = payload["d"] deviceId = payload["d"]
iccid = payload["cid"] iccid = payload["cid"]
@ -194,7 +193,6 @@ async def message_publish(data):
payload = json.loads(payload) payload = json.loads(payload)
send_len = payload["l"] send_len = payload["l"]
if receive_len != send_len: if receive_len != send_len:
print("校验错误,收到的消息长度:", receive_len)
return BaseResponse(code=301, msg=f"data valid error,receive_len:{receive_len}") return BaseResponse(code=301, msg=f"data valid error,receive_len:{receive_len}")
m = payload["m"] m = payload["m"]
v = payload["v"] v = payload["v"]
@ -237,7 +235,6 @@ async def message_publish(data):
# 改变设备状态接口 # 改变设备状态接口
async def client_change_status(clientid, status): async def client_change_status(clientid, status):
print(clientid)
try: try:
sql_query = f"select timestamp from root.farm.clientId where clientId='{clientid}'" sql_query = f"select timestamp from root.farm.clientId where clientId='{clientid}'"
r = requests.post(baseHost + queryUri, headers=headers, json={"sql": sql_query}) r = requests.post(baseHost + queryUri, headers=headers, json={"sql": sql_query})