refactor(user): 移除未使用的trial订阅激活逻辑
All checks were successful
Build docker and publish / build (20.15.1) (push) Successful in 6m59s
All checks were successful
Build docker and publish / build (20.15.1) (push) Successful in 6m59s
This commit is contained in:
parent
842edad966
commit
e02e1d1f37
@ -12,7 +12,6 @@ import (
|
|||||||
"github.com/perfect-panel/server/internal/types"
|
"github.com/perfect-panel/server/internal/types"
|
||||||
"github.com/perfect-panel/server/pkg/constant"
|
"github.com/perfect-panel/server/pkg/constant"
|
||||||
"github.com/perfect-panel/server/pkg/logger"
|
"github.com/perfect-panel/server/pkg/logger"
|
||||||
"github.com/perfect-panel/server/pkg/tool"
|
|
||||||
"github.com/perfect-panel/server/pkg/uuidx"
|
"github.com/perfect-panel/server/pkg/uuidx"
|
||||||
"github.com/perfect-panel/server/pkg/xerr"
|
"github.com/perfect-panel/server/pkg/xerr"
|
||||||
"github.com/pkg/errors"
|
"github.com/pkg/errors"
|
||||||
@ -141,54 +140,3 @@ func (l *UnbindDeviceLogic) UnbindDevice(req *types.UnbindDeviceRequest) error {
|
|||||||
|
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
func (l *UnbindDeviceLogic) activeTrial(userId int64, tx *gorm.DB) error {
|
|
||||||
sub, err := l.svcCtx.SubscribeModel.FindOne(l.ctx, l.svcCtx.Config.Register.TrialSubscribe)
|
|
||||||
if err != nil {
|
|
||||||
l.Errorw("failed to find trial subscription template",
|
|
||||||
logger.Field("user_id", userId),
|
|
||||||
logger.Field("trial_subscribe_id", l.svcCtx.Config.Register.TrialSubscribe),
|
|
||||||
logger.Field("error", err.Error()),
|
|
||||||
)
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
startTime := time.Now()
|
|
||||||
expireTime := tool.AddTime(l.svcCtx.Config.Register.TrialTimeUnit, l.svcCtx.Config.Register.TrialTime, startTime)
|
|
||||||
subscribeToken := uuidx.SubscribeToken(fmt.Sprintf("Trial-%v", userId))
|
|
||||||
subscribeUUID := uuidx.NewUUID().String()
|
|
||||||
|
|
||||||
userSub := &user.Subscribe{
|
|
||||||
UserId: userId,
|
|
||||||
OrderId: 0,
|
|
||||||
SubscribeId: sub.Id,
|
|
||||||
StartTime: startTime,
|
|
||||||
ExpireTime: expireTime,
|
|
||||||
Traffic: sub.Traffic,
|
|
||||||
Download: 0,
|
|
||||||
Upload: 0,
|
|
||||||
Token: subscribeToken,
|
|
||||||
UUID: subscribeUUID,
|
|
||||||
Status: 1,
|
|
||||||
}
|
|
||||||
|
|
||||||
if err := tx.Create(userSub).Error; err != nil {
|
|
||||||
l.Errorw("failed to insert trial subscription",
|
|
||||||
logger.Field("user_id", userId),
|
|
||||||
logger.Field("error", err.Error()),
|
|
||||||
)
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
l.Infow("trial subscription activated successfully",
|
|
||||||
logger.Field("user_id", userId),
|
|
||||||
logger.Field("subscribe_id", sub.Id),
|
|
||||||
logger.Field("expire_time", expireTime),
|
|
||||||
logger.Field("traffic", sub.Traffic),
|
|
||||||
)
|
|
||||||
if clearErr := l.svcCtx.NodeModel.ClearServerAllCache(l.ctx); clearErr != nil {
|
|
||||||
l.Errorf("ClearServerAllCache error: %v", clearErr.Error())
|
|
||||||
}
|
|
||||||
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user