HC_YFZX
/
LASAPlatform
13
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

提交注册

Browse Source
main
zhangbin 3 months ago
parent 65f4a4eff9
commit 6491118b44
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File

10
OpenAuth.WebApi/Model/mqtt/ThingRequestHandler.cs
Unescape Escape View File

@ -23,7 +23,7 @@ namespace OpenAuth.WebApi.Model.mqtt
public bool CanHandle(string topic) public bool CanHandle(string topic)
{ {
return topic.Contains("/requests1"); return topic.Contains("/requests");
} }
string bid, tid, previousgateway; string bid, tid, previousgateway;
long timestamp; long timestamp;
@ -63,7 +63,7 @@ namespace OpenAuth.WebApi.Model.mqtt
} }
}; };
string payloadreq = JsonSerializer.Serialize(requestData); string payloadreq = JsonSerializer.Serialize(requestData);
await _mqttClientManager.PublishAsync($"thing/product/{gateway}/requests1_reply", payloadreq); await _mqttClientManager.PublishAsync($"thing/product/{gateway}/requests_reply", payloadreq);
await _app.UpdateGateway(gateway, tid); await _app.UpdateGateway(gateway, tid);
} }
if (payload.Contains("airport_bind_status")) if (payload.Contains("airport_bind_status"))
@ -108,7 +108,7 @@ namespace OpenAuth.WebApi.Model.mqtt
}; };
string payloadreq = JsonSerializer.Serialize(requestData); string payloadreq = JsonSerializer.Serialize(requestData);
string getway = topic.Split('/')[2]; string getway = topic.Split('/')[2];
await _mqttClientManager.PublishAsync($"thing/product/{getway}/requests1_reply", payloadreq); await _mqttClientManager.PublishAsync($"thing/product/{getway}/requests_reply", payloadreq);
} }
if (payload.Contains("airport_organization_get"))// if (payload.Contains("airport_organization_get"))//
@ -132,7 +132,7 @@ namespace OpenAuth.WebApi.Model.mqtt
}; };
string payloadreq = JsonSerializer.Serialize(requestData); string payloadreq = JsonSerializer.Serialize(requestData);
string getway = topic.Split('/')[2]; string getway = topic.Split('/')[2];
await _mqttClientManager.PublishAsync($"thing/product/{getway}/requests1_reply", payloadreq); await _mqttClientManager.PublishAsync($"thing/product/{getway}/requests_reply", payloadreq);
} }
if (payload.Contains("airport_organization_bind")) if (payload.Contains("airport_organization_bind"))
@ -206,7 +206,7 @@ namespace OpenAuth.WebApi.Model.mqtt
}; };
string payloadreq = JsonSerializer.Serialize(requestData); string payloadreq = JsonSerializer.Serialize(requestData);
string getway = topic.Split('/')[2]; string getway = topic.Split('/')[2];
await _mqttClientManager.PublishAsync($"thing/product/{getway}/requests1_reply", payloadreq); await _mqttClientManager.PublishAsync($"thing/product/{getway}/requests_reply", payloadreq);
} }
} }
} }

Write Preview
Loading…
Cancel
Save