fix cache

apps/efka/include/efka_service.hrl

@@ -1,10 +0,0 @@
-%%%-------------------------------------------------------------------
-%%% @author anlicheng
-%%% @copyright (C) 2025, <COMPANY>
-%%% @doc
-%%%
-%%% @end
-%%% Created : 26. 8月 2025 14:42
-%%%-------------------------------------------------------------------
--author("anlicheng").
-

apps/efka/include/efka_tables.hrl

@@ -20,12 +20,6 @@
     status = 0
 }).
 
-%% 数据缓存
--record(cache, {
-    id = 0 :: integer(),
-    data :: binary()
-}).
-
 %% 数据缓存
 -record(task_log, {
     task_id = 0 :: integer(),

apps/efka/src/efka_remote_agent.erl

@@ -226,7 +226,7 @@ handle_event(info, {auth_reply, Reply}, ?STATE_AUTH, State = #state{transport_pi
 %% 将缓存中的数据推送到服务器端
 handle_event(info, flush_cache, ?STATE_ACTIVATED, State = #state{transport_pid = TransportPid}) ->
     case cache_model:fetch_next() of
-        {ok, #cache{id = Id, data = Packet}} ->
+        {ok, {Id, Packet}} ->
             efka_transport:send(TransportPid, Packet),
             cache_model:delete(Id),
             {keep_state, State, [{next_event, info, flush_cache}]};

apps/efka/src/models/cache_model.erl

@@ -32,8 +32,7 @@
 
 -spec insert(Data :: binary()) -> ok | {error, Reason :: any()}.
 insert(Data) when is_binary(Data) ->
-    Cache = #cache{id = generate_id(), data = Data},
+    gen_server:call(?SERVER, {insert, {generate_id(), Data}}).
-    gen_server:call(?SERVER, {insert, Cache}).
 
 fetch_next() ->
     gen_server:call(?SERVER, fetch_next).
@@ -41,7 +40,7 @@ fetch_next() ->
 delete(Id) when is_integer(Id) ->
     gen_server:call(?SERVER, {delete, Id}).
 
--spec get_all_cache() -> [#cache{}].
+-spec get_all_cache() -> [binary()].
 get_all_cache() ->
     gen_server:call(?SERVER, get_all_cache).
 
@@ -63,7 +62,7 @@ start_link() ->
 init([]) ->
     {ok, DetsDir} = application:get_env(efka, dets_dir),
     File = DetsDir ++ "cache.dets",
-    {ok, ?TAB} = dets:open_file(?TAB, [{file, File}, {type, bag}, {keypos, 2}]),
+    {ok, ?TAB} = dets:open_file(?TAB, [{file, File}, {type, bag}, {keypos, 1}]),
     {ok, #state{}}.
 
 %% @private