1

server/marketserver/cache/cachemgr.go

@@ -1,7 +1,9 @@
 package cache
 
 import (
+	"f5"
 	"sync"
+	"fmt"
 	"main/common"
 )
 
@@ -18,12 +20,22 @@ func (this *cacheMgr) UnInit() {
 }
 
 func (this *cacheMgr) GetNfts(nfts []*common.NftDto) {
-	/*
 	for _, val := range nfts {
-
+		this.internalGetNft(val)
-	}*/
+	}
 }
 
-func (this *cacheMgr) internalGetNft(netId int32, contractAddress string, tokenId string) *nft {
+func (this *cacheMgr) internalGetNft(dto *common.NftDto) {
-	return nil
+	key := fmt.Sprintf("%d_%s_%s", dto.NetId, dto.ContractAddress, dto.TokenId)
+	if p, ok := this.nftHash.Load(key); ok {
+		dto.NftCache = p.(*nft)
+	} else {
+		l := f5.AllocLock(key)
+		defer f5.ReleaseLock(l)
+		if p, ok := this.nftHash.Load(key); ok {
+			dto.NftCache = p.(*nft)
+		} else {
+
+		}
+	}
 }

server/marketserver/common/types.go

@@ -43,7 +43,7 @@ type StreamPagination struct {
 }
 
 type NftCache interface {
-
+	GetRawData() string
 }
 
 type NftDto struct {