jager/novatask
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

手动结算和更新nft持有者接口改为后台执行

Browse Source
This commit is contained in:
lianghuanjie
2025-01-08 11:59:01 +08:00
parent e7a802efdb
commit 6dea53e53c
2 changed files with 11 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
internal/logic/admin/nft_holder_update_logic.go
View File

@@ -2,6 +2,7 @@ package admin
import ( import (
"context" "context"
"github.com/zeromicro/go-zero/core/threading"
"nova_task/internal/logic/nft" "nova_task/internal/logic/nft"
"nova_task/internal/pkg/errs" "nova_task/internal/pkg/errs"
@@ -15,7 +16,6 @@ type NftHolderUpdateLogic struct {
svcCtx *svc.ServiceContext svcCtx *svc.ServiceContext
} }
// NFT持有者更新
func NewNftHolderUpdateLogic(ctx context.Context, svcCtx *svc.ServiceContext) *NftHolderUpdateLogic { func NewNftHolderUpdateLogic(ctx context.Context, svcCtx *svc.ServiceContext) *NftHolderUpdateLogic {
return &NftHolderUpdateLogic{ return &NftHolderUpdateLogic{
Logger: logx.WithContext(ctx), Logger: logx.WithContext(ctx),
@@ -25,7 +25,9 @@ func NewNftHolderUpdateLogic(ctx context.Context, svcCtx *svc.ServiceContext) *N
} }
func (l *NftHolderUpdateLogic) NftHolderUpdate() error { func (l *NftHolderUpdateLogic) NftHolderUpdate() error {
lg := nft.NewHolderUpdateLogic(l.ctx, l.svcCtx) threading.GoSafe(func() {
lg.HolderUpdate() lg := nft.NewHolderUpdateLogic(context.Background(), l.svcCtx)
lg.HolderUpdate()
})
return errs.Success() return errs.Success()
} }

8
internal/logic/admin/stake_settle_logic.go
View File

@@ -3,6 +3,7 @@ package admin
import ( import (
"context" "context"
"github.com/zeromicro/go-zero/core/logx" "github.com/zeromicro/go-zero/core/logx"
"github.com/zeromicro/go-zero/core/threading"
"nova_task/internal/logic/nft" "nova_task/internal/logic/nft"
"nova_task/internal/pkg/errs" "nova_task/internal/pkg/errs"
"nova_task/internal/svc" "nova_task/internal/svc"
@@ -24,7 +25,10 @@ func NewStakeSettleLogic(ctx context.Context, svcCtx *svc.ServiceContext) *Stake
} }
func (l *StakeSettleLogic) StakeSettle() error { func (l *StakeSettleLogic) StakeSettle() error {
lg := nft.NewStakeSettleLogic(l.ctx, l.svcCtx) threading.GoSafe(func() {
lg.StakeSettle() lg := nft.NewStakeSettleLogic(context.Background(), l.svcCtx)
lg.StakeSettle()
})
return errs.Success() return errs.Success()
} }