anlicheng/iot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix send directive

Browse Source
This commit is contained in:
anlicheng 2023-12-25 15:32:24 +08:00
parent d33893d7a5
commit b0e7b6599e
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
apps/iot/src/iot_host.erl
View File

@ -121,8 +121,9 @@ publish_directive(Pid, DeviceUUID, DirectiveType, Version, DirectiveParams, Time
<<"directive_type">> => DirectiveType, <<"directive_type">> => DirectiveType,
<<"directive">> => DirectiveParams <<"directive">> => DirectiveParams
}, },
JsonDirective = iolist_to_binary(jiffy:encode(Directive, [force_utf8])),
case gen_statem:call(Pid, {publish_directive, self(), Directive}) of case gen_statem:call(Pid, {publish_directive, self(), JsonDirective}) of
{ok, Ref} -> {ok, Ref} ->
receive receive
{ws_response, Ref} -> {ws_response, Ref} ->
@ -147,7 +148,9 @@ send_directive(Pid, DeviceUUID, DirectiveType, Version, DirectiveParams)
<<"directive_type">> => DirectiveType, <<"directive_type">> => DirectiveType,
<<"directive">> => DirectiveParams <<"directive">> => DirectiveParams
}, },
gen_statem:call(Pid, {send_directive, Directive}). JsonDirective = iolist_to_binary(jiffy:encode(Directive, [force_utf8])),
gen_statem:call(Pid, {send_directive, JsonDirective}).
%% 设备管理相关 %% 设备管理相关