add efka client

apps/aircon/src/aircon_mqtt_subscriber.erl

@@ -185,16 +185,14 @@ emqx_opts(ClientSuffix) when is_binary(ClientSuffix) ->
 
 -spec dispatch(DeviceMac :: binary(), Message :: binary()) -> no_return().
 dispatch(DeviceMac, Message) when is_binary(DeviceMac), is_binary(Message) ->
-    logger:notice("[mqtt_subscriber] device_mac: ~p, device_uuid not found", [DeviceMac]),
+    case aircon_args:get_device_uuid(DeviceMac) of
-    ok.
+        error ->
-    %case aircon_args:get_device_uuid(DeviceMac) of
+            logger:notice("[mqtt_subscriber] device_mac: ~p, device_uuid not found", [DeviceMac]);
-    %    error ->
+        {ok, DeviceUUID} ->
-    %        logger:notice("[mqtt_subscriber] device_mac: ~p, device_uuid not found", [DeviceMac]);
+            case aircon_device_sup:ensure_device_started(DeviceUUID) of
-    %    {ok, DeviceUUID} ->
+                {ok, DevicePid} ->
-    %        case aircon_device_sup:ensure_device_started(DeviceUUID) of
+                    aircon_device:metric_data(DevicePid, Message);
-    %            {ok, DevicePid} ->
+                {error, Reason} ->
-    %                aircon_device:metric_data(DevicePid, Message);
+                    logger:notice("[mqtt_subscriber] start device get error: ~p", [Reason])
-    %            {error, Reason} ->
+            end
-    %                logger:notice("[mqtt_subscriber] start device get error: ~p", [Reason])
+    end.
-    %        end
-    %end.

apps/aircon/src/aircon_sup.erl

@@ -36,23 +36,23 @@ init([]) ->
     RegisterName = read_service_name(),
 
     ChildSpecs = [
-        %#{
+        #{
-        %    id => 'efka_client',
+            id => 'efka_client',
-        %    start => {'efka_client', start_link, [RegisterName, Host, Port]},
+            start => {'efka_client', start_link, [RegisterName, Host, Port]},
-        %    restart => permanent,
+            restart => permanent,
-        %    shutdown => 2000,
+            shutdown => 2000,
-        %    type => worker,
+            type => worker,
-        %    modules => ['efka_client']
+            modules => ['efka_client']
-        %},
+        },
 
-        %#{
+        #{
-        %    id => 'aircon_args',
+            id => 'aircon_args',
-        %    start => {'aircon_args', start_link, []},
+            start => {'aircon_args', start_link, []},
-        %    restart => permanent,
+            restart => permanent,
-        %    shutdown => 2000,
+            shutdown => 2000,
-        %    type => worker,
+            type => worker,
-        %    modules => ['aircon_args']
+            modules => ['aircon_args']
-        %},
+        },
 
         #{
             id => aircon_logger,