This commit is contained in:
安礼成 2023-02-16 16:32:34 +08:00
parent 8b4c149651
commit 5d98da77fa
2 changed files with 13 additions and 7 deletions

View File

@ -12,7 +12,7 @@
-include_lib("stdlib/include/qlc.hrl"). -include_lib("stdlib/include/qlc.hrl").
%% API %% API
-export([get_all_hosts/0, insert/4, change_status/2]). -export([get_all_hosts/0, insert/4, change_status/2, delete/1, table_size/0]).
%% app信息 %% app信息
get_all_hosts() -> get_all_hosts() ->
@ -22,6 +22,7 @@ get_all_hosts() ->
end, end,
case mnesia:transaction(Fun) of case mnesia:transaction(Fun) of
{atomic, Items} when is_list(Items) -> {atomic, Items} when is_list(Items) ->
%%
Stat = lists:foldl(fun(#host{status = Status}, Acc) -> Stat = lists:foldl(fun(#host{status = Status}, Acc) ->
Num = maps:get(Status, Acc, 0), Num = maps:get(Status, Acc, 0),
Acc#{Status => Num + 1} Acc#{Status => Num + 1}
@ -37,7 +38,6 @@ insert(Id, Name, Model, CellId) ->
name = Name, name = Name,
model = Model, model = Model,
cell_id = CellId, cell_id = CellId,
terminal_num = 0,
update_ts = 0, update_ts = 0,
status = ?HOST_STATUS_INACTIVE status = ?HOST_STATUS_INACTIVE
}, },
@ -49,11 +49,11 @@ insert(Id, Name, Model, CellId) ->
{error, Error} {error, Error}
end. end.
change_status(Id, Status) -> change_status(HostId, Status) when is_binary(HostId), is_integer(Status) ->
Fun = fun() -> Fun = fun() ->
case mnesia:read(host, Id) of case mnesia:read(host, HostId) of
[] -> [] ->
mnesia:abort(<<"appinfo not found">>); mnesia:abort(<<"host not found">>);
[Host] -> [Host] ->
NHost = Host#host{status = Status}, NHost = Host#host{status = Status},
mnesia:write(host, NHost, write) mnesia:write(host, NHost, write)
@ -66,8 +66,8 @@ change_status(Id, Status) ->
{error, Reason} {error, Reason}
end. end.
delete(Id) -> delete(HostId) when is_binary(HostId) ->
case mnesia:transaction(fun() -> mnesia:delete(host, Id, write) end) of case mnesia:transaction(fun() -> mnesia:delete(host, HostId, write) end) of
{atomic, ok} -> {atomic, ok} ->
ok; ok;
{aborted, Reason} -> {aborted, Reason} ->

View File

@ -26,6 +26,12 @@ get_all_terminals() ->
{error, Reason} {error, Reason}
end. end.
get_status_groups() ->
ok.
insert(Id, HostId, Name, ProductId, VendorId, Model, CellId) -> insert(Id, HostId, Name, ProductId, VendorId, Model, CellId) ->
Terminal = #terminal{ Terminal = #terminal{
id = Id, id = Id,