From dcdccd9ac6ba9bf1427eddf6e03dbc30ccf17f8b Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Thu, 27 Jun 2024 16:04:57 +0800 Subject: [PATCH] 1 --- server/backtask/task/webhook.go | 9 +++++++++ server/jccommon/types.go | 5 +++++ 2 files changed, 14 insertions(+) diff --git a/server/backtask/task/webhook.go b/server/backtask/task/webhook.go index 5b623b92..52cb940c 100644 --- a/server/backtask/task/webhook.go +++ b/server/backtask/task/webhook.go @@ -136,6 +136,10 @@ func (this* webHook) orderUpdatedCb(ds *f5.DataSet) bool { endTime := q5.SmartParseTimeToMills(q5.SafeToString(p.Data.EndAt)) createdAt := q5.SmartParseTimeToMills(q5.SafeToString(p.Data.CreatedAt)) updatedAt := q5.SmartParseTimeToMills(q5.SafeToString(p.Data.UpdatedAt)) + srcPriceAmount := p.Data.Buy[0].Amount + srcPriceContractAddress := p.Data.Buy[0].ContractAddress + srcPriceItemType := p.Data.Buy[0].ItemType + currentPrice, price := service.BcCurrency.ExchangeUSD(srcPriceAmount, srcPriceContractAddress, srcPriceItemType) commonFields := [][]string{ {"order_id", p.Data.Id}, {"chain", p.Chain}, @@ -149,6 +153,11 @@ func (this* webHook) orderUpdatedCb(ds *f5.DataSet) bool { {"event_id", p.EventId}, {"event_data", rawData}, {"modifytime", q5.ToString(nowTime)}, + {"src_price_amount", srcPriceAmount}, + {"src_price_contract_address", srcPriceContractAddress}, + {"src_price_item_type", srcPriceItemType}, + {"price", price}, + {"current_price", q5.ToString(currentPrice)}, } updateFields := commonFields[0:] insertFields := commonFields[0:] diff --git a/server/jccommon/types.go b/server/jccommon/types.go index 18b94a4a..8f3b84fd 100644 --- a/server/jccommon/types.go +++ b/server/jccommon/types.go @@ -25,6 +25,11 @@ type OrderUpdatedEvent struct { Chain string `json:"chain"` Data struct { Id string `json:"id"` + Buy [] struct { + Amount string `json:"amount"` + ContractAddress string `json:"contract_address"` + ItemType string `json:"item_type"` + } `json:"buy"` Sell [] struct { TokenId string `json:"token_id"` ItemType string `json:"item_type"`