83 lines
2.4 KiB
Go
83 lines
2.4 KiB
Go
package check_points_stake
|
|
|
|
import (
|
|
"context"
|
|
"github.com/robfig/cron/v3"
|
|
"github.com/shopspring/decimal"
|
|
"github.com/zeromicro/go-zero/core/logx"
|
|
"github.com/zeromicro/go-zero/core/stores/sqlx"
|
|
"nova_task/internal/consts"
|
|
"nova_task/internal/model"
|
|
"nova_task/internal/pkg/errs"
|
|
"nova_task/internal/svc"
|
|
"time"
|
|
)
|
|
|
|
type Cron struct {
|
|
ctx context.Context
|
|
svcCtx *svc.ServiceContext
|
|
}
|
|
|
|
func NewCron(ctx context.Context, svcCtx *svc.ServiceContext) cron.Job {
|
|
return &Cron{
|
|
ctx: ctx,
|
|
svcCtx: svcCtx,
|
|
}
|
|
}
|
|
|
|
func (c *Cron) Spec() string {
|
|
return "@every 30s"
|
|
}
|
|
|
|
func (c *Cron) Run() {
|
|
ns, err := c.svcCtx.StakePointsModel.FindOverdueList(c.ctx)
|
|
if err != nil {
|
|
logx.Errorw("find overdue list failed", logx.Field("err", err))
|
|
return
|
|
}
|
|
if len(ns) == 0 {
|
|
return
|
|
}
|
|
logx.Debugw("find overdue list", logx.Field("count", len(ns)))
|
|
for _, n := range ns {
|
|
err = c.svcCtx.DBConn.TransactCtx(c.ctx, func(ctx context.Context, session sqlx.Session) error {
|
|
err = c.svcCtx.StakePointsModel.WithSession(session).SetOverdue(ctx, n.Id)
|
|
if err != nil {
|
|
logx.Errorw("set overdue failed", logx.Field("err", err))
|
|
return err
|
|
}
|
|
err = c.svcCtx.AddUserAssetWithSession(c.ctx, session, n.Uid, int64(n.RoleId), consts.AssetType_Points, "", decimal.NewFromInt(int64(n.Points)), "stake point overdue return", 0, 0, false)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
_, err = c.svcCtx.StakePointsLogModel.WithSession(session).Insert(ctx, &model.NhStakePointsLog{
|
|
Uid: n.Uid,
|
|
RoleId: n.RoleId,
|
|
LevelId: n.LevelId,
|
|
Level: n.Level,
|
|
Points: -int(n.Points),
|
|
Action: 4,
|
|
})
|
|
if err != nil {
|
|
logx.Errorw("stake points log error", logx.Field("err", err), logx.Field("role_id", n.RoleId), logx.Field("uid", n.Uid), logx.Field("level_id", n.LevelId), logx.Field("action", 4))
|
|
return errs.New(errs.ErrDatabaseOperate, err)
|
|
}
|
|
_, err = c.svcCtx.GameAction(c.ctx, int64(n.RoleId), consts.GameActionStakePoints, map[string]any{
|
|
"level": n.Level,
|
|
"operation": 4,
|
|
"start_time": time.Now().Unix(),
|
|
"end_time": 0,
|
|
"renew_times": 0,
|
|
})
|
|
if err != nil {
|
|
logx.Errorw("game action failed", logx.Field("err", err), logx.Field("uid", n.Uid), logx.Field("roleId", n.RoleId))
|
|
return errs.New(errs.ErrInternalServer, err)
|
|
}
|
|
return nil
|
|
})
|
|
if err != nil {
|
|
logx.Errorw("SetOverdue points stake", logx.Field("err", err), logx.Field("uid", n.Uid), logx.Field("roleId", n.RoleId))
|
|
}
|
|
}
|
|
}
|