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

fix

Browse Source
This commit is contained in:
anlicheng 2023-08-17 14:53:41 +08:00
parent 97571c702d
commit 37123da219
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -21,7 +21,7 @@
handle_request("POST", "/device/reload", _, #{<<"host_id">> := HostId, <<"device_uuid">> := DeviceUUID}) when is_binary(DeviceUUID) -> handle_request("POST", "/device/reload", _, #{<<"host_id">> := HostId, <<"device_uuid">> := DeviceUUID}) when is_binary(DeviceUUID) ->
lager:debug("[device_handler] host_id: ~p, will reload device uuid: ~p", [HostId, DeviceUUID]), lager:debug("[device_handler] host_id: ~p, will reload device uuid: ~p", [HostId, DeviceUUID]),
AliasName = iot_host:get_alias_name(HostId), AliasName = iot_host:get_alias_name(HostId),
case whereis(AliasName) of case global:whereis_name(AliasName) of
undefined -> undefined ->
{ok, 200, iot_util:json_error(404, <<"reload device failed">>)}; {ok, 200, iot_util:json_error(404, <<"reload device failed">>)};
HostPid when is_pid(HostPid) -> HostPid when is_pid(HostPid) ->
@ -37,7 +37,7 @@ handle_request("POST", "/device/reload", _, #{<<"host_id">> := HostId, <<"device
%% 删除对应的主机信息 %% 删除对应的主机信息
handle_request("POST", "/device/delete", _, #{<<"host_id">> := HostId, <<"device_uuid">> := DeviceUUID}) when is_binary(DeviceUUID) -> handle_request("POST", "/device/delete", _, #{<<"host_id">> := HostId, <<"device_uuid">> := DeviceUUID}) when is_binary(DeviceUUID) ->
AliasName = iot_host:get_alias_name(HostId), AliasName = iot_host:get_alias_name(HostId),
case whereis(AliasName) of case global:whereis_name(AliasName) of
undefined -> undefined ->
{ok, 200, iot_util:json_error(404, <<"delete device failed">>)}; {ok, 200, iot_util:json_error(404, <<"delete device failed">>)};
HostPid when is_pid(HostPid) -> HostPid when is_pid(HostPid) ->
@ -48,7 +48,7 @@ handle_request("POST", "/device/delete", _, #{<<"host_id">> := HostId, <<"device
%% 处理主机的授权的激活 %% 处理主机的授权的激活
handle_request("POST", "/device/activate", _, #{<<"host_id">> := HostId, <<"device_uuid">> := DeviceUUID, <<"auth">> := Auth}) when is_binary(DeviceUUID) -> handle_request("POST", "/device/activate", _, #{<<"host_id">> := HostId, <<"device_uuid">> := DeviceUUID, <<"auth">> := Auth}) when is_binary(DeviceUUID) ->
AliasName = iot_host:get_alias_name(HostId), AliasName = iot_host:get_alias_name(HostId),
case whereis(AliasName) of case global:whereis_name(AliasName) of
undefined -> undefined ->
{ok, 200, iot_util:json_error(404, <<"activate device failed">>)}; {ok, 200, iot_util:json_error(404, <<"activate device failed">>)};
HostPid when is_pid(HostPid) -> HostPid when is_pid(HostPid) ->

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

@ -164,7 +164,7 @@ init([UUID]) ->
%% 通过host_id注册别名, 可以避免通过查询数据库获取HostPid %% 通过host_id注册别名, 可以避免通过查询数据库获取HostPid
AliasName = get_alias_name(HostId), AliasName = get_alias_name(HostId),
erlang:register(AliasName, self()), global:register_name(AliasName, self()),
{ok, StateName, #state{host_id = HostId, uuid = UUID, aes = Aes}}; {ok, StateName, #state{host_id = HostId, uuid = UUID, aes = Aes}};
undefined -> undefined ->