From 006c7dcf1dd4561a07cf5858fec22c25f23f7c5e Mon Sep 17 00:00:00 2001 From: zl Date: Thu, 31 Mar 2022 17:21:30 +0800 Subject: [PATCH] fix update deal status on mysql not working --- models/mysql/storage_deal.go | 13 ++++++++----- 1 file changed, 8 insertions(+), 5 deletions(-) diff --git a/models/mysql/storage_deal.go b/models/mysql/storage_deal.go index 5dd629f3..6e5602f9 100644 --- a/models/mysql/storage_deal.go +++ b/models/mysql/storage_deal.go @@ -365,21 +365,24 @@ func (sdr *storageDealRepo) GetDealByAddrAndStatus(ctx context.Context, addr add } func (sdr *storageDealRepo) UpdateDealStatus(ctx context.Context, proposalCid cid.Cid, status storagemarket.StorageDealStatus, pieceState types.PieceStatus) error { - updataColumns := make(map[string]interface{}) + updateColumns := make(map[string]interface{}) if status != storagemarket.StorageDealUnknown { - updataColumns["state"] = status + updateColumns["state"] = status } if len(pieceState) != 0 { - updataColumns["piece_status"] = pieceState + updateColumns["piece_status"] = pieceState } - if len(updataColumns) == 0 { + if len(updateColumns) == 0 { return nil } + + updateColumns["updated_at"] = time.Now().Unix() + return sdr.WithContext(ctx).Model(storageDeal{}).Where("proposal_cid = ?", DBCid(proposalCid).String()). - UpdateColumns(map[string]interface{}{"state": status, "updated_at": time.Now().Unix()}).Error + UpdateColumns(updateColumns).Error } func (sdr *storageDealRepo) ListDealByAddr(ctx context.Context, miner address.Address) ([]*types.MinerDeal, error) {