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

fix sql

Browse Source
This commit is contained in:
anlicheng 2024-11-06 15:01:25 +08:00
parent 19b469708f
commit 2a2b7d9417
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -27,22 +27,22 @@ insert_store_info(Fields = #{<<"storeId">> := StoreId, <<"name">> := Name, <<"ac
}, true). }, true).
-spec insert_equip(Fields :: map()) -> {ok, InsertId :: integer()} | {error, Reason :: any()}. -spec insert_equip(Fields :: map()) -> {ok, InsertId :: integer()} | {error, Reason :: any()}.
insert_equip(Fields = #{<<"equipId">> := EquipId, <<"equipValue">> := EquipValue, <<"eType">> := EType, <<"address">> := Address, <<"updateTime">> := UpdateTime}) -> insert_equip(Fields = #{<<"equipId">> := EquipId, <<"equipValue">> := EquipValue, <<"etype">> := EType, <<"address">> := Address, <<"updateTime">> := UpdateTime}) ->
mysql_pool:insert(<<"equip">>, #{ mysql_pool:insert(<<"equip">>, #{
<<"equipId">> => EquipId, <<"equipId">> => EquipId,
<<"equipValue">> => EquipValue, <<"equipValue">> => EquipValue,
<<"storeId">> => maps:get(<<"storeId">>, Fields, 0), <<"storeId">> => maps:get(<<"storeId">>, Fields, 0),
<<"eType">> => EType, <<"etype">> => EType,
<<"remark">> => maps:get(<<"remark">>, Fields, <<"">>), <<"remark">> => maps:get(<<"remark">>, Fields, <<"">>),
<<"address">> => Address, <<"address">> => Address,
<<"updateTime">> => UpdateTime <<"updateTime">> => UpdateTime
}, true). }, true).
-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}) ->
mysql_pool:insert(<<"run_status">>, #{ mysql_pool:insert(<<"run_status">>, #{
<<"equipValue">> => EquipValue, <<"equipValue">> => EquipValue,
<<"eType">> => EType, <<"etype">> => EType,
<<"status">> => Status, <<"status">> => Status,
<<"num">> => maps:get(<<"num">>, Fields, 0), <<"num">> => maps:get(<<"num">>, Fields, 0),
<<"storeId">> => StoreId, <<"storeId">> => StoreId,
@ -60,7 +60,7 @@ insert_equip_status(#{<<"equipValue">> := EquipValue, <<"status">> := Status, <<
-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 = #{
<<"outTradeNo">> := OutTradeNo, <<"orderAmount">> := OrderAmount, <<"createTime">> := CreateTime, <<"status">> := Status, <<"outTradeNo">> := OutTradeNo, <<"orderAmount">> := OrderAmount, <<"createTime">> := CreateTime, <<"status">> := Status,
<<"equipValue">> := EquipValue, <<"eType">> := EType, <<"equipValue">> := EquipValue, <<"etype">> := EType,
<<"storeId">> := StoreId, <<"storeName">> := StoreName}) -> <<"storeId">> := StoreId, <<"storeName">> := StoreName}) ->
mysql_pool:insert(<<"order">>, #{ mysql_pool:insert(<<"order">>, #{
@ -72,7 +72,7 @@ insert_order(Fields = #{
<<"payFinishTime">> => maps:get(<<"payFinishTime">>, Fields, <<"0000-00-00 00:00:00">>), <<"payFinishTime">> => maps:get(<<"payFinishTime">>, Fields, <<"0000-00-00 00:00:00">>),
<<"status">> => Status, <<"status">> => Status,
<<"equipValue">> => EquipValue, <<"equipValue">> => EquipValue,
<<"eType">> => EType, <<"etype">> => EType,
<<"num">> => maps:get(<<"num">>, Fields, 0), <<"num">> => maps:get(<<"num">>, Fields, 0),
<<"storeId">> => StoreId, <<"storeId">> => StoreId,