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

fix device handler

Browse Source
This commit is contained in:
anlicheng 2025-04-08 16:03:12 +08:00
parent ba6b7d9f43
commit 5d0f931d24
1 changed files with 3 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
apps/iot/src/http_handler/device_handler.erl
View File

@ -12,7 +12,7 @@
%% API %% API
-export([handle_request/4]). -export([handle_request/4]).
-export([test/1]). -export([test/2]).
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%% %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
%% helper methods %% helper methods
@ -94,12 +94,9 @@ handle_request(_, Path, _, _) ->
{ok, 200, iot_util:json_error(-1, <<"url: ", Path1/binary, " not found">>)}. {ok, 200, iot_util:json_error(-1, <<"url: ", Path1/binary, " not found">>)}.
test(DeviceUUID) when is_binary(DeviceUUID) -> test(HostUUID, DeviceUUID) when is_binary(HostUUID), is_binary(DeviceUUID) ->
Timeout = 10, Timeout = 10,
HostUUID = <<"0356e898adc51ac449b215627b7d8e55">>,
lager:debug("[device_handler] host_id: ~p, will query_edge_status uuid: ~p", [HostUUID, DeviceUUID]), lager:debug("[device_handler] host_id: ~p, will query_edge_status uuid: ~p", [HostUUID, DeviceUUID]),
case iot_host:get_pid(HostUUID) of case iot_host:get_pid(HostUUID) of
undefined -> undefined ->
{ok, 200, iot_util:json_error(404, <<"query_edge_status failed">>)}; {ok, 200, iot_util:json_error(404, <<"query_edge_status failed">>)};
@ -109,7 +106,7 @@ test(DeviceUUID) when is_binary(DeviceUUID) ->
iot_device_poll_task:poll_task(TaskPid, Ref, HostPid, self(), DeviceUUID, Timeout), iot_device_poll_task:poll_task(TaskPid, Ref, HostPid, self(), DeviceUUID, Timeout),
receive receive
{poll_task_reply, Ref, {ok, EdgeStatus}} -> {poll_task_reply, Ref, {ok, EdgeStatus}} ->
% {ok, _} = device_bo:change_edge_status(DeviceUUID, EdgeStatus), {ok, _} = device_bo:change_edge_status(DeviceUUID, EdgeStatus),
{ok, 200, iot_util:json_data(#{<<"edge_status">> => EdgeStatus})}; {ok, 200, iot_util:json_data(#{<<"edge_status">> => EdgeStatus})};
{poll_task_reply, Ref, {error, Reason}} -> {poll_task_reply, Ref, {error, Reason}} ->
lager:debug("[device_handler] query_edge_status device: ~p, get error: ~p", [DeviceUUID, Reason]), lager:debug("[device_handler] query_edge_status device: ~p, get error: ~p", [DeviceUUID, Reason]),