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

fix error

Browse Source
This commit is contained in:
anlicheng 2024-11-06 16:12:49 +08:00
parent 0d9d097907
commit 5891a0c46d
1 changed files with 16 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
apps/njau_bot/src/njau_bot_database.erl
View File

@ -39,7 +39,10 @@ insert_equip(Fields = #{<<"equipId">> := EquipId, <<"equipValue">> := EquipValue
<<"remark">> => maps:get(<<"remark">>, Fields, <<"">>), <<"remark">> => maps:get(<<"remark">>, Fields, <<"">>),
<<"address">> => Address, <<"address">> => Address,
<<"updateTime">> => UpdateTime <<"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()}. -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}) -> 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), <<"num">> => maps:get(<<"num">>, Fields, 0),
<<"storeId">> => StoreId, <<"storeId">> => StoreId,
<<"updateTime">> => UpdateTime <<"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()}. -spec insert_equip_status(Fields :: map()) -> {ok, InsertId :: integer()} | {error, Reason :: any()}.
insert_equip_status(#{<<"equipValue">> := EquipValue, <<"status">> := Status, <<"updateTime">> := UpdateTime}) -> insert_equip_status(#{<<"equipValue">> := EquipValue, <<"status">> := Status, <<"updateTime">> := UpdateTime}) ->
@ -58,7 +64,10 @@ insert_equip_status(#{<<"equipValue">> := EquipValue, <<"status">> := Status, <<
<<"equipValue">> => EquipValue, <<"equipValue">> => EquipValue,
<<"status">> => Status, <<"status">> => Status,
<<"updateTime">> => UpdateTime <<"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()}. -spec insert_order(Fields :: map()) -> {ok, InsertId :: integer()} | {error, Reason :: any()}.
insert_order(Fields = #{ insert_order(Fields = #{
@ -112,4 +121,7 @@ insert_order(Fields = #{
TableFields1 TableFields1
end, end,
mysql_pool:insert(<<"orders">>, TableFields2, true). 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>>}.