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

fix logger

Browse Source
This commit is contained in:
anlicheng 2023-12-25 15:53:51 +08:00
parent 5cc10ee019
commit 4306b94bf0
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
apps/iot/src/consumer/iot_zd_consumer.erl
View File

@ -154,6 +154,12 @@ handle_info({'EXIT', ConnPid, Reason}, State = #state{conn_pid = ConnPid}) ->
{noreply, State#state{conn_pid = undefined}}; {noreply, State#state{conn_pid = undefined}};
handle_info({'EXIT', LoggerPid, Reason}, State = #state{logger_pid = LoggerPid}) ->
lager:warning("[iot_zd_consumer] logger exited with reason: ~p", [Reason]),
{ok, LoggerPid} = iot_logger:start_link("zd_directive_data"),
{noreply, State#state{logger_pid = LoggerPid}};
handle_info({directive_reply, Reply}, State = #state{logger_pid = LoggerPid, flight_num = FlightNum}) -> handle_info({directive_reply, Reply}, State = #state{logger_pid = LoggerPid, flight_num = FlightNum}) ->
FlightInfo = <<"flight_num: ", (integer_to_binary(FlightNum - 1))/binary>>, FlightInfo = <<"flight_num: ", (integer_to_binary(FlightNum - 1))/binary>>,
case Reply of case Reply of
@ -170,8 +176,7 @@ handle_info({directive_reply, Reply}, State = #state{logger_pid = LoggerPid, fli
true -> <<"Unknow error">> true -> <<"Unknow error">>
end, end,
iot_logger:write(LoggerPid, [<<"[error]">>, RawReq, Reason, FlightInfo]) iot_logger:write(LoggerPid, [<<"[error]">>, RawReq, Reason, FlightInfo])
end, end;
iot_logger:write(LoggerPid, [<<"[success]">>, RawReq, DirectiveResult, FlightInfo]);
{error, RawReq, Error} when is_binary(Error) -> {error, RawReq, Error} when is_binary(Error) ->
iot_logger:write(LoggerPid, [<<"[error]">>, RawReq, Error, FlightInfo]) iot_logger:write(LoggerPid, [<<"[error]">>, RawReq, Error, FlightInfo])
end, end,