From 5891a0c46d2e08501ebcf0164a96582fa5461bd4 Mon Sep 17 00:00:00 2001
From: anlicheng <244108715@qq.com>
Date: Wed, 6 Nov 2024 16:12:49 +0800
Subject: [PATCH] fix error

---
 apps/njau_bot/src/njau_bot_database.erl | 20 ++++++++++++++++----
 1 file changed, 16 insertions(+), 4 deletions(-)

diff --git a/apps/njau_bot/src/njau_bot_database.erl b/apps/njau_bot/src/njau_bot_database.erl
index ac86163..b7a078e 100644
--- a/apps/njau_bot/src/njau_bot_database.erl
+++ b/apps/njau_bot/src/njau_bot_database.erl
@@ -39,7 +39,10 @@ insert_equip(Fields = #{<<"equipId">> := EquipId, <<"equipValue">> := EquipValue
         <<"remark">> => maps:get(<<"remark">>, Fields, <<"">>),
         <<"address">> => Address,
         <<"updateTime">> => UpdateTime
-    }, true).
+    }, true);
+insert_equip(Fields) when is_map(Fields) ->
+    Data = iolist_to_binary(jiffy:encode(Fields, [force_utf8])),
+    {error, <<"Invalid equip info: ", Data/binary>>}.
 
 -spec insert_run_status(Fields :: map()) -> {ok, InsertId :: integer()} | {error, Reason :: any()}.
 insert_run_status(Fields = #{<<"equipValue">> := EquipValue, <<"etype">> := EType, <<"status">> := Status, <<"storeId">> := StoreId, <<"updateTime">> := UpdateTime}) ->
@@ -50,7 +53,10 @@ insert_run_status(Fields = #{<<"equipValue">> := EquipValue, <<"etype">> := ETyp
         <<"num">> => maps:get(<<"num">>, Fields, 0),
         <<"storeId">> => StoreId,
         <<"updateTime">> => UpdateTime
-    }, true).
+    }, true);
+insert_run_status(Fields) when is_map(Fields) ->
+    Data = iolist_to_binary(jiffy:encode(Fields, [force_utf8])),
+    {error, <<"Invalid run_status info: ", Data/binary>>}.
 
 -spec insert_equip_status(Fields :: map()) -> {ok, InsertId :: integer()} | {error, Reason :: any()}.
 insert_equip_status(#{<<"equipValue">> := EquipValue, <<"status">> := Status, <<"updateTime">> := UpdateTime}) ->
@@ -58,7 +64,10 @@ insert_equip_status(#{<<"equipValue">> := EquipValue, <<"status">> := Status, <<
         <<"equipValue">> => EquipValue,
         <<"status">> => Status,
         <<"updateTime">> => UpdateTime
-    }, true).
+    }, true);
+insert_equip_status(Fields) when is_map(Fields) ->
+    Data = iolist_to_binary(jiffy:encode(Fields, [force_utf8])),
+    {error, <<"Invalid equip_status info: ", Data/binary>>}.
 
 -spec insert_order(Fields :: map()) -> {ok, InsertId :: integer()} | {error, Reason :: any()}.
 insert_order(Fields = #{
@@ -112,4 +121,7 @@ insert_order(Fields = #{
                            TableFields1
                    end,
 
-    mysql_pool:insert(<<"orders">>, TableFields2, true).
\ No newline at end of file
+    mysql_pool:insert(<<"orders">>, TableFields2, true);
+insert_order(Fields) when is_map(Fields) ->
+    Data = iolist_to_binary(jiffy:encode(Fields, [force_utf8])),
+    {error, <<"Invalid order info: ", Data/binary>>}.
\ No newline at end of file