From 02c48495bf1a0b8a4d9dbe9011a2c9bb861902ad Mon Sep 17 00:00:00 2001 From: anlicheng <244108715@qq.com> Date: Mon, 2 Sep 2024 16:47:58 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E6=8A=A5=E8=AD=A6=E9=80=BB?= =?UTF-8?q?=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- apps/iot/priv/jinzhi_watchdog_pri.key | 1 + apps/iot/src/endpoint/iot_jinzhi_endpoint.erl | 42 +-- apps/iot/src/iot_app.erl | 8 +- apps/iot/src/iot_host.erl | 9 +- apps/iot/src/iot_sup.erl | 9 + apps/iot/src/iot_watchdog.erl | 271 ++++++++++++++++++ apps/iot/src/util/iot_jinzhi_signer.erl | 51 ++++ config/sys-dev.config | 12 + config/sys-prod.config | 11 + config/sys-test.config | 11 + 10 files changed, 381 insertions(+), 44 deletions(-) create mode 100644 apps/iot/priv/jinzhi_watchdog_pri.key create mode 100644 apps/iot/src/iot_watchdog.erl create mode 100644 apps/iot/src/util/iot_jinzhi_signer.erl diff --git a/apps/iot/priv/jinzhi_watchdog_pri.key b/apps/iot/priv/jinzhi_watchdog_pri.key new file mode 100644 index 0000000..d89ce7b --- /dev/null +++ b/apps/iot/priv/jinzhi_watchdog_pri.key @@ -0,0 +1 @@ +MIICdwIBADANBgkqhkiG9w0BAQEFAASCAmEwggJdAgEAAoGBAMthPZx2cBn1bhLr0ezb+sju5+eAaaUW2bnVd6A16kZmbK2HqNoTDVN/0Np2CrzLwDzz+es0NlsVSLlU6VgEXLLheunGfVHQSfOtEjuhMYGue8zYLkGPIulVyz3G/HKKJlvEHWg2AOmxGiTFWkWLhEEAcKuWGRXX531Y1lugDhVXAgMBAAECgYAVGJsZdbefGbQ3RjraRN84pH9tpgZPV5VyD1B/T9hjQRCY12+OX1eMh7+USZZHiyL/r5cG7L2OqSCICOTDeoBa5mYuTwjU1GrOWvcM5KFtffvgJh6CLBt8doy6kvGpI1TtDAYLYnC/kXEj1bTctYJSjik4nNxq2hlKOSMjYQCP4QJBAOypsK7hn70nqlMKWsLrqKiQk/SEnAqZVuyF8ijltmyaiXbbYqgb3uqLsPwLglMixbWudpI9WlEZJ31ZSm1EQnkCQQDb/11/4NdPLLn1R602m1O8SIi5iT/klBg/MwbKcPXrwnyhpXYiQ0MuKjvLY+kqaI8U/cDMiZLC0+WLc47SFaJPAkAFg6KpQHqPVrhCPRCGUCVa4BuCbACSwqXi1vAggdGxUBx513zB+/xCrMSP6ti7hSjkJc9/csyC7TodUpJIX3nJAkEApfSndbYI9eMJjKw7UDwwGJKnAT82AZpuCA7YCpLYELcwCUimKwaOgR6+6Jk/5QvnE7CwZhtJqMrsGBxeGsDTJQJBAOO4xzWNMarCxI8e6/PF04FRU1spvPQqCuHUH2W0obA1p00eSJg/srOSNrsZpvYAVsTtvHc+KMq2lTGixHQlZ3k= \ No newline at end of file diff --git a/apps/iot/src/endpoint/iot_jinzhi_endpoint.erl b/apps/iot/src/endpoint/iot_jinzhi_endpoint.erl index 29cfeb0..276c7a4 100644 --- a/apps/iot/src/endpoint/iot_jinzhi_endpoint.erl +++ b/apps/iot/src/endpoint/iot_jinzhi_endpoint.erl @@ -195,7 +195,7 @@ format_events(LocationCode, DynamicLocationCode, EventType, #{<<"event_code">> : }, ReqData = #{ - <<"sign">> => sign(DeviceInfo, PriKey), + <<"sign">> => iot_jinzhi_signer:sign(DeviceInfo, PriKey), <<"sysId">> => ?SYS_ID, <<"taskId">> => generate_task_id(DynamicLocationCode, EventCode), <<"count">> => 1, @@ -222,42 +222,4 @@ generate_private_key(PriFile) when is_list(PriFile) -> %% 私钥保存解析后的 {ok, PriKeyData} = file:read_file(PriKeyFile), PriDerData = base64:decode(PriKeyData), - public_key:der_decode('PrivateKeyInfo', PriDerData). - -%% 数据签名 --spec sign(M :: #{}, PrivateKey :: public_key:private_key()) -> binary(). -sign(M, PrivateKey) when is_map(M) -> - Json = serialize(M), - Hash = iolist_to_binary(io_lib:format("~64.16.0b", [binary:decode_unsigned(crypto:hash(sha256, Json))])), - RsaEncoded = public_key:encrypt_private(Hash, PrivateKey), - - base64:encode(RsaEncoded). - -%% 简单的序列号，sign签名 --spec serialize(M :: map()) -> JsonString :: binary(). -serialize(M) when is_map(M) -> - L = maps:to_list(M), - L1 = lists:sort(fun({K, _}, {K1, _}) -> K < K1 end, L), - serialize(L1, []). -serialize([], Target) -> - B = iolist_to_binary(lists:join(<<$,>>, lists:reverse(Target))), - <<${, B/binary, $}>>; -serialize([{K, V}|T], Target) -> - V1 = if - is_integer(V) -> - integer_to_binary(V); - is_float(V) -> - float_to_binary(V); - is_binary(V) -> - <<$", V/binary, $">>; - is_boolean(V) andalso V -> - <<"true">>; - is_boolean(V) andalso not V -> - <<"false">>; - is_list(V) -> - Items = lists:map(fun(E) -> serialize(E) end, V), - V0 = iolist_to_binary(lists:join(<<$,>>, Items)), - <<$[, V0/binary, $]>> - end, - Item = <<$", K/binary, $", $:, V1/binary>>, - serialize(T, [Item|Target]). \ No newline at end of file + public_key:der_decode('PrivateKeyInfo', PriDerData). \ No newline at end of file diff --git a/apps/iot/src/iot_app.erl b/apps/iot/src/iot_app.erl index 7bffca8..0732e45 100644 --- a/apps/iot/src/iot_app.erl +++ b/apps/iot/src/iot_app.erl @@ -29,7 +29,13 @@ start(_StartType, _StartArgs) -> %% 创建特殊的buckets SuperDeviceUUIDs = iot_env:get_value(super_device_uuids, []), - influx_client:create_all_buckets(SuperDeviceUUIDs), + case is_list(SuperDeviceUUIDs) andalso length(SuperDeviceUUIDs) > 0 of + true -> + Result = catch influx_client:create_all_buckets(SuperDeviceUUIDs), + lager:debug("[iot_app] create_all_buckets: ~p, result: ~p", [SuperDeviceUUIDs, Result]); + false -> + ok + end, {ok, SupPid}. diff --git a/apps/iot/src/iot_host.erl b/apps/iot/src/iot_host.erl index a1e0683..ec01be3 100644 --- a/apps/iot/src/iot_host.erl +++ b/apps/iot/src/iot_host.erl @@ -32,6 +32,7 @@ -record(state, { host_id :: integer(), + name :: binary(), %% 从数据库里面读取到的数据 uuid :: binary(), %% aes的key, 后续通讯需要基于这个加密 @@ -188,7 +189,7 @@ start_link(Name, UUID) when is_atom(Name), is_binary(UUID) -> %% process to initialize. init([UUID]) -> case host_bo:get_host_by_uuid(UUID) of - {ok, #{<<"id">> := HostId, <<"authorize_status">> := AuthorizeStatus}} -> + {ok, #{<<"id">> := HostId, <<"authorize_status">> := AuthorizeStatus, <<"name">> := Name}} -> %% 通过host_id注册别名, 可以避免通过查询数据库获取HostPid AliasName = get_alias_name(HostId), global:register_name(AliasName, self()), @@ -201,7 +202,7 @@ init([UUID]) -> true -> ?STATE_ACTIVATED; false -> ?STATE_DENIED end, - {ok, StateName, #state{host_id = HostId, uuid = UUID, aes = Aes, has_session = false}}; + {ok, StateName, #state{host_id = HostId, uuid = UUID, aes = Aes, name = Name, has_session = false}}; undefined -> lager:warning("[iot_host] host uuid: ~p, loaded from mysql failed", [UUID]), ignore @@ -393,11 +394,13 @@ handle_event(cast, {handle, {data, Data}}, ?STATE_ACTIVATED, State = #state{aes {keep_state, State}; %% ping的数据是通过aes加密后的，因此需要在有会话的情况下才行 -handle_event(cast, {handle, {ping, CipherMetric}}, ?STATE_ACTIVATED, State = #state{uuid = UUID, aes = AES, has_session = true}) -> +handle_event(cast, {handle, {ping, CipherMetric}}, ?STATE_ACTIVATED, State = #state{uuid = UUID, name = Name, aes = AES, has_session = true}) -> MetricsInfo = iot_cipher_aes:decrypt(AES, CipherMetric), case catch jiffy:decode(MetricsInfo, [return_maps]) of Metrics when is_map(Metrics) -> lager:debug("[iot_host] host_id uuid: ~p, get ping: ~p", [UUID, Metrics]), + %% 检测消息是否需要报警 + iot_watchdog:detection(UUID, Name, Metrics), {keep_state, State#state{metrics = Metrics}}; Other -> lager:warning("[iot_host] host_id: ~p, ping is invalid json: ~p", [UUID, Other]), diff --git a/apps/iot/src/iot_sup.erl b/apps/iot/src/iot_sup.erl index cfdd5b4..61f51cd 100644 --- a/apps/iot/src/iot_sup.erl +++ b/apps/iot/src/iot_sup.erl @@ -28,6 +28,15 @@ start_link() -> init([]) -> SupFlags = #{strategy => one_for_one, intensity => 1000, period => 3600}, Specs = [ + #{ + id => iot_watchdog, + start => {'iot_watchdog', start_link, []}, + restart => permanent, + shutdown => 2000, + type => worker, + modules => ['iot_watchdog'] + }, + #{ id => 'iot_task', start => {'iot_task', start_link, []}, diff --git a/apps/iot/src/iot_watchdog.erl b/apps/iot/src/iot_watchdog.erl new file mode 100644 index 0000000..b8bb9b7 --- /dev/null +++ b/apps/iot/src/iot_watchdog.erl @@ -0,0 +1,271 @@ +%%%------------------------------------------------------------------- +%%% @author anlicheng +%%% @copyright (C) 2024, +%%% @doc +%%% +%%% @end +%%% Created : 30. 8月 2024 17:45 +%%%------------------------------------------------------------------- +-module(iot_watchdog). +-author("anlicheng"). + +-behaviour(gen_server). + +%% API +-export([start_link/0]). +-export([detection/3]). + +-export([test/0]). + +%% gen_server callbacks +-export([init/1, handle_call/3, handle_cast/2, handle_info/2, terminate/2, code_change/3]). + +-define(SERVER, ?MODULE). + +%% 系统id +-define(SYS_ID, <<"ZNWLZJJKXT1">>). + +%% 限制器 +-record(limiter, { + cpu_temperature = 0 :: integer(), + disk = 0 :: integer(), + memory = 0 :: integer() +}). + +-record(state, { + guard_items = [], + logger_pid :: pid(), + report_interval = 60, + url :: string(), + users :: binary(), %% 格式: "S123, S1234" + pri_key :: public_key:private_key(), + %% 消息发送的频率限制，格式: #{uuid => #limiter{}} + limiters = #{} +}). + +test() -> + Metric = #{ + <<"cpu_temperature">> => 90.5, + <<"disk">> => #{ + <<"total">> => 7129, + <<"used">> => 345 + }, + <<"memory">> => #{ + <<"total">> => 990, + <<"used">> => 900 + } + }, + detection(<<"1234">>, <<"test1234">>, Metric). + + +%%%=================================================================== +%%% API +%%%=================================================================== + +-spec detection(HostUUID :: binary(), Name :: binary(), Metric :: map()) -> no_return(). +detection(HostUUID, Name, Metric) when is_binary(HostUUID), is_binary(Name), is_map(Metric) -> + gen_server:cast(?SERVER, {detection, HostUUID, Name, Metric}); +detection(HostUUID, Name, _) when is_binary(HostUUID), is_binary(Name) -> + ok. + +%% @doc Spawns the server and registers the local name (unique) +-spec(start_link() -> + {ok, Pid :: pid()} | ignore | {error, Reason :: term()}). +start_link() -> + gen_server:start_link({local, ?SERVER}, ?MODULE, [], []). + +%%%=================================================================== +%%% gen_server callbacks +%%%=================================================================== + +%% @private +%% @doc Initializes the server +-spec(init(Args :: term()) -> + {ok, State :: #state{}} | {ok, State :: #state{}, timeout() | hibernate} | + {stop, Reason :: term()} | ignore). +init([]) -> + {ok, Opts} = application:get_env(iot, watchdog), + + PriFile = proplists:get_value(pri_key, Opts), + Url = proplists:get_value(url, Opts), + ReportInterval = proplists:get_value(report_interval, Opts, 60), + GuardItems = proplists:get_value(guard_items, Opts), + + Users0 = proplists:get_value(users, Opts), + Users = iolist_to_binary(lists:join(",", Users0)), + + {ok, LoggerPid} = iot_logger:start_link("watchdog_data"), + PriKey = generate_private_key(PriFile), + + {ok, #state{logger_pid = LoggerPid, pri_key = PriKey, report_interval = ReportInterval, url = Url, users = Users, limiters = #{}, guard_items = GuardItems}}. + +%% @private +%% @doc Handling call messages +-spec(handle_call(Request :: term(), From :: {pid(), Tag :: term()}, + State :: #state{}) -> + {reply, Reply :: term(), NewState :: #state{}} | + {reply, Reply :: term(), NewState :: #state{}, timeout() | hibernate} | + {noreply, NewState :: #state{}} | + {noreply, NewState :: #state{}, timeout() | hibernate} | + {stop, Reason :: term(), Reply :: term(), NewState :: #state{}} | + {stop, Reason :: term(), NewState :: #state{}}). +handle_call(_Request, _From, State = #state{}) -> + {reply, ok, State}. + +%% @private +%% @doc Handling cast messages +-spec(handle_cast(Request :: term(), State :: #state{}) -> + {noreply, NewState :: #state{}} | + {noreply, NewState :: #state{}, timeout() | hibernate} | + {stop, Reason :: term(), NewState :: #state{}}). +handle_cast({detection, HostUUID, Name, Metric}, + State = #state{url = Url, users = Users, pri_key = PriKey, limiters = Limiters, guard_items = Config, logger_pid = LoggerPid, report_interval = ReportInterval}) -> + + Limiter = maps:get(HostUUID, Limiters, #limiter{cpu_temperature = 0, disk = 0, memory = 0}), + {Warnings, NLimiter} = lists:foldl(fun(F, {W0, L0}) -> + case F(Metric, Config, ReportInterval, L0) of + ok -> + {W0, L0}; + {error, Msg0, L1} -> + {[Msg0|W0], L1} + end + end, {[], Limiter}, [fun check_cpu_temperature/4, fun check_disk/4, fun check_memory/4]), + + case length(Warnings) > 0 of + true -> + Subject = iolist_to_binary([<<"主机: "/utf8>>, Name, <<"(">>, HostUUID, <<") ">>, lists:join(<<"|">>, lists:reverse(Warnings))]), + Body = format_warn(Subject, Users, PriKey), + case catch do_post(Url, Body) of + {ok, Resp} -> + lager:debug("[iot_watchdog] url: ~p, body: ~ts, resp: ~ts", [Url, Body, Resp]), + iot_logger:write(LoggerPid, [Body, Resp]); + {error, Reason} -> + lager:warning("[iot_watchdog] url: ~p, send body: ~ts, get error: ~p", [Url, Body, Reason]) + end; + false -> + ok + end, + + {noreply, State#state{limiters = maps:put(HostUUID, NLimiter, Limiters)}}. + +%% @private +%% @doc Handling all non call/cast messages +-spec(handle_info(Info :: timeout() | term(), State :: #state{}) -> + {noreply, NewState :: #state{}} | + {noreply, NewState :: #state{}, timeout() | hibernate} | + {stop, Reason :: term(), NewState :: #state{}}). +handle_info(_Info, State = #state{}) -> + {noreply, State}. + +%% @private +%% @doc This function is called by a gen_server when it is about to +%% terminate. It should be the opposite of Module:init/1 and do any +%% necessary cleaning up. When it returns, the gen_server terminates +%% with Reason. The return value is ignored. +-spec(terminate(Reason :: (normal | shutdown | {shutdown, term()} | term()), + State :: #state{}) -> term()). +terminate(_Reason, _State = #state{}) -> + ok. + +%% @private +%% @doc Convert process state when code is changed +-spec(code_change(OldVsn :: term() | {down, term()}, State :: #state{}, + Extra :: term()) -> + {ok, NewState :: #state{}} | {error, Reason :: term()}). +code_change(_OldVsn, State = #state{}, _Extra) -> + {ok, State}. + +%%%=================================================================== +%%% Internal functions +%%%=================================================================== + +-spec format_warn(Subject :: binary(), Users :: binary(), PriKey :: public_key:private_key()) -> binary(). +format_warn(Subject, Users, PriKey) when is_binary(Subject), is_binary(Users) -> + PostParams = #{ + <<"target">> => <<"3">>, + <<"bizId">> => <<"">>, + <<"userId">> => Users, + <<"subject">> => Subject, + <<"mobileUrl">> => <<"">>, + <<"url">> => <<"">>, + <<"applier">> => <<"李睿"/utf8>>, + <<"creatorId">> => <<"S20232026">>, + <<"submitTime">> => format_date(), + <<"sysName">> => <<"后勤监管"/utf8>>, + <<"nodeName">> => <<"主机监控"/utf8>>, + <<"sysId">> => ?SYS_ID + }, + Sign = iot_jinzhi_signer:sign(PostParams, PriKey), + jiffy:encode(PostParams#{<<"sign">> => Sign}, [force_utf8]). + +-spec do_post(Url :: string(), Body :: binary()) -> {ok, Resp :: any()} | {error, Reason :: binary()}. +do_post(Url, Body) when is_list(Url), is_binary(Body) -> + Headers = [ + {<<"content-type">>, <<"application/json">>} + ], + case hackney:request(post, Url, Headers, Body, [{pool, false}, {connect_timeout, 5000}]) of + {ok, 200, _, ClientRef} -> + {ok, RespBody} = hackney:body(ClientRef), + hackney:close(ClientRef), + {ok, RespBody}; + {ok, HttpCode, _, ClientRef} -> + {ok, RespBody} = hackney:body(ClientRef), + hackney:close(ClientRef), + {error, {HttpCode, RespBody}}; + {error, Reason} -> + {error, Reason} + end. + +-spec check_cpu_temperature(map(), Config :: list(), ReportInterval :: integer(), Limiter :: #limiter{}) -> ok | {error, Warn :: binary()}. +check_cpu_temperature(#{<<"cpu_temperature">> := CpuTemperature}, Config, ReportInterval, Limiter = #limiter{cpu_temperature = TTL0}) -> + Threshold = proplists:get_value(cpu_temperature, Config), + Timestamp = iot_util:timestamp_of_seconds(), + case is_number(CpuTemperature) andalso CpuTemperature > Threshold of + true when TTL0 == 0 orelse TTL0 < Timestamp -> + Msg = unicode:characters_to_binary(io_lib:format("CPU温度超过:~p°C", [CpuTemperature])), + {error, Msg, Limiter#limiter{cpu_temperature = Timestamp + ReportInterval}}; + _ -> + ok + end. + +-spec check_disk(map(), Config :: list(), ReportInterval :: integer(), Limiter :: #limiter{}) -> ok | {error, Warn :: binary()}. +check_disk(#{<<"disk">> := #{<<"total">> := Total, <<"used">> := Free}}, Config, ReportInterval, Limiter = #limiter{disk = TTL0}) -> + Threshold = proplists:get_value(disk_used_percentage, Config), + Timestamp = iot_util:timestamp_of_seconds(), + Used = Total - Free, + case Total > 0 andalso (Used / Total) * 100 > Threshold of + true when TTL0 == 0 orelse TTL0 < Timestamp -> + Val = erlang:trunc((Used / Total) * 100), + Msg = unicode:characters_to_binary(io_lib:format("硬盘使用超过:~p%", [Val])), + {error, Msg, Limiter#limiter{disk = Timestamp + ReportInterval}}; + _ -> + ok + end. + +-spec check_memory(map(), Config :: list(), ReportInterval :: integer(), Limiter :: #limiter{}) -> ok | {error, Warn :: binary()}. +check_memory(#{<<"memory">> := #{<<"total">> := Total, <<"used">> := Used}}, Config, ReportInterval, Limiter = #limiter{memory = TTL0}) -> + Threshold = proplists:get_value(memory_used_percentage, Config), + Timestamp = iot_util:timestamp_of_seconds(), + case Total > 0 andalso (Used / Total) * 100 > Threshold of + true when TTL0 == 0 orelse TTL0 < Timestamp -> + Val = erlang:trunc((Used / Total) * 100), + Msg = unicode:characters_to_binary(io_lib:format("内存使用超过:~p%", [Val])), + {error, Msg, Limiter#limiter{memory = Timestamp + ReportInterval}}; + _ -> + ok + end. + +-spec generate_private_key(PriFile :: string()) -> public_key:private_key(). +generate_private_key(PriFile) when is_list(PriFile) -> + PriKeyFile = code:priv_dir(iot) ++ "/" ++ PriFile, + %% 私钥保存解析后的 + {ok, PriKeyData} = file:read_file(PriKeyFile), + PriDerData = base64:decode(PriKeyData), + public_key:der_decode('PrivateKeyInfo', PriDerData). + +-spec format_date() -> binary(). +format_date() -> + {Date, Time} = calendar:now_to_local_time(os:timestamp()), + {{Year, Month, Day}, {Hour, Minute, Second}} = {Date, Time}, + DateTime = io_lib:format("~4..0B-~2..0B-~2..0B ~2..0B:~2..0B:~2..0B", [Year, Month, Day, Hour, Minute, Second]), + list_to_binary(DateTime). \ No newline at end of file diff --git a/apps/iot/src/util/iot_jinzhi_signer.erl b/apps/iot/src/util/iot_jinzhi_signer.erl new file mode 100644 index 0000000..67a6483 --- /dev/null +++ b/apps/iot/src/util/iot_jinzhi_signer.erl @@ -0,0 +1,51 @@ +%%%------------------------------------------------------------------- +%%% @author anlicheng +%%% @copyright (C) 2024, +%%% @doc +%%% 中电的签名逻辑 +%%% @end +%%% Created : 02. 9月 2024 11:28 +%%%------------------------------------------------------------------- +-module(iot_jinzhi_signer). +-author("anlicheng"). + +%% API +-export([sign/2]). + +%% 数据签名 +-spec sign(M :: #{}, PrivateKey :: public_key:private_key()) -> binary(). +sign(M, PrivateKey) when is_map(M) -> + Json = serialize(M), + Hash = iolist_to_binary(io_lib:format("~64.16.0b", [binary:decode_unsigned(crypto:hash(sha256, Json))])), + RsaEncoded = public_key:encrypt_private(Hash, PrivateKey), + + base64:encode(RsaEncoded). + +%% 简单的序列号，sign签名 +-spec serialize(M :: map()) -> JsonString :: binary(). +serialize(M) when is_map(M) -> + L = maps:to_list(M), + L1 = lists:sort(fun({K, _}, {K1, _}) -> K < K1 end, L), + serialize(L1, []). +serialize([], Target) -> + B = iolist_to_binary(lists:join(<<$,>>, lists:reverse(Target))), + <<${, B/binary, $}>>; +serialize([{K, V}|T], Target) -> + V1 = if + is_integer(V) -> + integer_to_binary(V); + is_float(V) -> + float_to_binary(V); + is_binary(V) -> + <<$", V/binary, $">>; + is_boolean(V) andalso V -> + <<"true">>; + is_boolean(V) andalso not V -> + <<"false">>; + is_list(V) -> + Items = lists:map(fun(E) -> serialize(E) end, V), + V0 = iolist_to_binary(lists:join(<<$,>>, Items)), + <<$[, V0/binary, $]>> + end, + Item = <<$", K/binary, $", $:, V1/binary>>, + serialize(T, [Item|Target]). \ No newline at end of file diff --git a/config/sys-dev.config b/config/sys-dev.config index 87fc07d..a57826b 100644 --- a/config/sys-dev.config +++ b/config/sys-dev.config @@ -16,6 +16,18 @@ {api_url, "http://39.98.184.67:8800"}, + {watchdog, [ + {pri_key, "jinzhi_watchdog_pri.key"}, + {url, "http://172.30.37.242:8080/hqtaskcenterapp/sys/taskCenter/taskReceive/sendNotice.do"}, + {users, ["S20232026", "S20232321", "S20232323"]}, + {report_interval, 60}, + {guard_items, [ + {cpu_temperature, 60}, + {disk_used_percentage, 60}, + {memory_used_percentage, 60} + ]} + ]}, + %% 目标服务器地址 {emqx_server, [ {host, {39, 98, 184, 67}}, diff --git a/config/sys-prod.config b/config/sys-prod.config index 682dff3..63efb91 100644 --- a/config/sys-prod.config +++ b/config/sys-prod.config @@ -14,6 +14,17 @@ %% 数据的最大缓存量 {device_cache_size, 200}, + {watchdog, [ + {pri_key, "jinzhi_watchdog_pri.key"}, + {url, "http://172.30.37.242:8080/hqtaskcenterapp/sys/taskCenter/taskReceive/sendNotice.do"}, + {users, ["S20232026", "S20232321", "S20232323"]}, + {guard_items, [ + {cpu_temperature, 60}, + {disk_used_percentage, 60}, + {memory_used_percentage, 60} + ]} + ]}, + %% 权限检验时的预埋token {pre_tokens, [ {<<"test">>, <<"iot2023">>} diff --git a/config/sys-test.config b/config/sys-test.config index ec53f2e..c4152c1 100644 --- a/config/sys-test.config +++ b/config/sys-test.config @@ -14,6 +14,17 @@ %% 数据的最大缓存量 {device_cache_size, 200}, + {watchdog, [ + {pri_key, "jinzhi_watchdog_pri.key"}, + {url, "http://172.30.37.242:8080/hqtaskcenterapp/sys/taskCenter/taskReceive/sendNotice.do"}, + {users, ["S20232026", "S20232321", "S20232323"]}, + {guard_items, [ + {cpu_temperature, 60}, + {disk_used_percentage, 60}, + {memory_used_percentage, 60} + ]} + ]}, + %% 权限检验时的预埋token {pre_tokens, [ {<<"test">>, <<"iot2023">>}