test/dgiot
1
0
Fork 0
mirror of https://gitee.com/dgiiot/dgiot.git synced 2024-12-02 04:08:54 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

feat: sql(template)

Browse Source
This commit is contained in:
h7ml 2022-05-10 17:46:39 +08:00
parent d82a80e524
commit d0ebc9355c
1 changed files with 13 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
apps/dgiot_bridge/src/handler/dgiot_rule_handler.erl
View File

@ -454,40 +454,40 @@ generateFrom(Trigger) ->
case Uri of
<<"trigger/product/property">> ->
case Params of
#{<<"productKey">> := ProductId, <<"deviceName">> := Devaddr} ->
case Devaddr of
#{<<"productKey">> := ProductId, <<"deviceName">> := DeviceId} ->
case DeviceId of
<<"">> ->
<<"$dg/alarm/", ProductId/binary, "/", Devaddr/binary>>;
<<"$dg/alarm/", ProductId/binary, "/#">>;
<<"#">> ->
<<"$dg/alarm/", ProductId/binary, "/">>;
<<"$dg/alarm/", ProductId/binary, "/#">>;
_ ->
<<"$dg/alarm/", ProductId/binary, "/", Devaddr/binary, "/#">>
<<"$dg/alarm/", ProductId/binary, "/", DeviceId/binary, "/#">>
end;
_ ->
<<"$dg/alarm/", "test/#">>
end;
<<"trigger/product/event">> ->
case Params of
#{<<"productKey">> := ProductId, <<"deviceName">> := Devaddr} ->
case Devaddr of
#{<<"productKey">> := ProductId, <<"deviceName">> := DeviceId} ->
case DeviceId of
<<"">> ->
<<"$dg/alarm/", ProductId/binary, "/", Devaddr/binary>>;
<<"$dg/alarm/", ProductId/binary, "/#">>;
<<"#">> ->
<<"$dg/alarm/", ProductId/binary, "/">>;
<<"$dg/alarm/", ProductId/binary, "/#">>;
_ ->
<<"$dg/alarm/", ProductId/binary, "/", Devaddr/binary, "/#">>
<<"$dg/alarm/", ProductId/binary, "/", DeviceId/binary, "/#">>
end;
_ ->
<<"$dg/alarm/", "test/#">>
end;
<<"trigger/mqtt/event">> ->
case Params of
#{<<"productKey">> := ProductId, <<"mqtt">> := Mqtt, <<"deviceName">> := Devaddr} ->
#{<<"productKey">> := ProductId, <<"mqtt">> := Mqtt, <<"deviceName">> := DeviceId} ->
case ProductId of
<<"">> ->
<<"$events/", Mqtt/binary, "/", ProductId/binary, "/", Devaddr/binary>>;
<<"$events/", Mqtt/binary, "/", ProductId/binary, "/", DeviceId/binary>>;
_ ->
<<"$events/", Mqtt/binary, "/", ProductId/binary, "/", Devaddr/binary, "/#">>
<<"$events/", Mqtt/binary, "/", ProductId/binary, "/", DeviceId/binary, "/#">>
end;
_ ->
<<"$dg/alarm/", "test/#">>