122 lines
3.7 KiB
Go
122 lines
3.7 KiB
Go
package agent
|
||
|
||
import (
|
||
"context"
|
||
"database/sql"
|
||
"github.com/pkg/errors"
|
||
"github.com/zeromicro/go-zero/core/stores/sqlx"
|
||
"time"
|
||
"tydata-server/app/user/model"
|
||
"tydata-server/common/xerr"
|
||
|
||
"tydata-server/app/user/cmd/api/internal/svc"
|
||
"tydata-server/app/user/cmd/api/internal/types"
|
||
|
||
"github.com/zeromicro/go-zero/core/logx"
|
||
)
|
||
|
||
type ActivateAgentMembershipLogic struct {
|
||
logx.Logger
|
||
ctx context.Context
|
||
svcCtx *svc.ServiceContext
|
||
}
|
||
|
||
func NewActivateAgentMembershipLogic(ctx context.Context, svcCtx *svc.ServiceContext) *ActivateAgentMembershipLogic {
|
||
return &ActivateAgentMembershipLogic{
|
||
Logger: logx.WithContext(ctx),
|
||
ctx: ctx,
|
||
svcCtx: svcCtx,
|
||
}
|
||
}
|
||
|
||
func (l *ActivateAgentMembershipLogic) ActivateAgentMembership(req *types.AgentActivateMembershipReq) (resp *types.AgentActivateMembershipResp, err error) {
|
||
//userID, err := ctxdata.GetUidFromCtx(l.ctx)
|
||
//if err != nil {
|
||
// return nil, errors.Wrapf(xerr.NewErrCode(xerr.SERVER_COMMON_ERROR), "获取用户ID失败: %v", err)
|
||
//}
|
||
userModel, err := l.svcCtx.UserModel.FindOneByMobile(l.ctx, req.Mobile)
|
||
if err != nil {
|
||
return nil, errors.Wrapf(xerr.NewErrCode(xerr.DB_ERROR), "查询代理信息失败: %v", err)
|
||
}
|
||
// 查询用户代理信息
|
||
agentModel, err := l.svcCtx.AgentModel.FindOneByUserId(l.ctx, userModel.Id)
|
||
if err != nil && err != sql.ErrNoRows {
|
||
return nil, errors.Wrapf(xerr.NewErrCode(xerr.DB_ERROR), "查询代理信息失败: %v", err)
|
||
}
|
||
|
||
// 定义等级顺序映射
|
||
levelOrder := map[string]int{
|
||
"": 1,
|
||
model.AgentLeveNameNormal: 1,
|
||
model.AgentLeveNameVIP: 2,
|
||
model.AgentLeveNameSVIP: 3,
|
||
}
|
||
|
||
// 验证请求等级合法性
|
||
if _, valid := levelOrder[req.Type]; !valid {
|
||
return nil, errors.Wrapf(xerr.NewErrCode(xerr.SERVER_COMMON_ERROR), "无效的代理等级: %s", req.Type)
|
||
}
|
||
|
||
// 如果存在代理记录，进行等级验证
|
||
if agentModel != nil {
|
||
currentLevel, exists := levelOrder[agentModel.LevelName]
|
||
if !exists {
|
||
return nil, errors.Wrapf(xerr.NewErrCode(xerr.SERVER_COMMON_ERROR),
|
||
"非法的当前代理等级: %s", agentModel.LevelName)
|
||
}
|
||
|
||
requestedLevel := levelOrder[req.Type]
|
||
if requestedLevel < currentLevel {
|
||
return nil, errors.Wrapf(xerr.NewErrCode(xerr.SERVER_COMMON_ERROR),
|
||
"禁止降级操作（当前等级：%s，请求等级：%s）", agentModel.LevelName, req.Type)
|
||
}
|
||
}
|
||
|
||
err = l.svcCtx.AgentModel.Trans(l.ctx, func(transCtx context.Context, session sqlx.Session) error {
|
||
agentModel.LevelName = req.Type
|
||
agentModel.MembershipExpiryTime = RenewMembership(agentModel.MembershipExpiryTime)
|
||
transErr := l.svcCtx.AgentModel.UpdateWithVersion(transCtx, session, agentModel)
|
||
if transErr != nil {
|
||
return transErr
|
||
}
|
||
agentMembershipRechargeOrder := model.AgentMembershipRechargeOrder{
|
||
AgentId: agentModel.Id,
|
||
UserId: userModel.Id,
|
||
LevelName: req.Type,
|
||
Amount: req.Amount,
|
||
PaymentMethod: req.PaymentMethod,
|
||
TransactionId: req.TransactionId,
|
||
}
|
||
_, transErr = l.svcCtx.AgentMembershipRechargeOrderModel.Insert(transCtx, session, &agentMembershipRechargeOrder)
|
||
if transErr != nil {
|
||
return transErr
|
||
}
|
||
return nil
|
||
})
|
||
if err != nil {
|
||
return nil, errors.Wrapf(xerr.NewErrCode(xerr.SERVER_COMMON_ERROR), "升级代理等级失败: %s", req.Type)
|
||
}
|
||
return &types.AgentActivateMembershipResp{
|
||
MembershipType: req.Type,
|
||
ExpireTime: agentModel.MembershipExpiryTime.Time.Format("2006-01-02 15:04:05"),
|
||
}, nil
|
||
}
|
||
func RenewMembership(expiry sql.NullTime) sql.NullTime {
|
||
// 确定基准时间
|
||
var baseTime time.Time
|
||
if expiry.Valid {
|
||
baseTime = expiry.Time
|
||
} else {
|
||
baseTime = time.Now()
|
||
}
|
||
|
||
// 增加一年（自动处理闰年）
|
||
newTime := baseTime.AddDate(1, 0, 0)
|
||
|
||
// 返回始终有效的 NullTime
|
||
return sql.NullTime{
|
||
Time: newTime,
|
||
Valid: true,
|
||
}
|
||
}
|