fix routers

This commit is contained in:
安礼成 2023-03-01 17:52:35 +08:00
parent b4a07fe273
commit e7b96b3cd5

View File

@ -11,7 +11,7 @@
-include("iot.hrl").
%% API
-export([insert_hosts/0, insert_services/1, insert_terminals/1]).
-export([insert_hosts/0, insert_services/1, insert_terminals/1, insert_routers/1]).
-export([rsa_encode/1]).
insert_hosts() ->
@ -71,6 +71,18 @@ insert_terminals(HostId) ->
terminal_model:add_terminal(Terminal)
end, lists:seq(1, 100)).
insert_routers(HostId) ->
lists:foreach(fun(Id0) ->
R = #router{
router_id = Id0,
name = <<"计费电表"/utf8>>,
rule = <<"测试规则"/utf8>>,
endpoint = #http_endpoint{url = <<"http://127.0.0.1:8080/data">>},
status = 0
},
router_model:add_router(R)
end, lists:seq(1, 100)).
rsa_encode(Data) when is_binary(Data) ->
%%
@ -107,27 +119,3 @@ rsa_decode(EncData) when is_binary(EncData) ->
lager:debug("plain data is: ~p", [PlainData]),
ok.
scan_and(Tokens) ->
scan_and(Tokens, [], [], 0).
%%
scan_and([], [], Acc, 0) ->
lists:reverse(Acc);
%%
scan_and([], Expr, Acc, 0) ->
lists:reverse([{simple, lists:reverse(Expr)}|Acc]);
%% OR关键词, 0
scan_and([32, $O, $R, 32|Tokens], Expr, Acc, 0) ->
scan_and(Tokens, [], [{simple, lists:reverse(Expr)}|Acc], 0);
%% && Level > 0; Expr需要更多的字符
scan_and([Token|Tokens], Expr, Acc, Level) when Token == $( ->
scan_and(Tokens, [Token|Expr], Acc, Level + 1);
%% && Level == 1; Expr表达式的内部嵌套的子串扫描完成
scan_and([Token|Tokens], Expr, Acc, 1) when Token == $) ->
scan_and(Tokens, [Token|Expr], Acc, 0);
%% && Level > 1; Expr表达式的内部嵌套的子串扫描完成Level的值减1
scan_and([Token|Tokens], Expr, Acc, Level) when Token == $) ->
scan_and(Tokens, [Token|Expr], Acc, Level - 1);
%%
scan_and([Token|Tokens], Expr, Acc, Level) ->
scan_and(Tokens, [Token|Expr], Acc, Level).