开发工作流

第一步：定义TL模式

tl
// 文件: specs/mtproto.tl

// 请求/响应类型
premium.getStatus#d0b5e0f2 user_id:long = PremiumStatus;
premium.purchase#8f8c0e1c userid:long planid:int payment_method:string = Bool;

// 对象类型
premiumStatus#9a4f3e2d userid:long status:int expiresat:long = PremiumStatus;

命名规范：

• - 方法：category.actionName（驼峰命名）
• 构造器ID：#8位十六进制（随机或顺序）
• 类型：帕斯卡命名

第二步：生成Go代码

bash

从TL模式生成

或

输出文件：

app/mtproto/premiumgetstatus.go

app/mtproto/premium_purchase.go

app/mtproto/premium_status.go

第三步：创建数据库模式

sql
-- 文件: data/schema/premium.sql

CREATE TABLE user_premium (
id BIGINT PRIMARY KEY AUTO_INCREMENT,
user_id BIGINT NOT NULL,
status TINYINT DEFAULT 0 COMMENT 0=无, 1=基础, 2=高级,
plan_id INT DEFAULT 0,
expires_at BIGINT DEFAULT 0,
createdat TIMESTAMP DEFAULT CURRENTTIMESTAMP,
updatedat TIMESTAMP DEFAULT CURRENTTIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
UNIQUE KEY ukuserid (user_id),
INDEX idxexpires (expiresat)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

CREATE TABLE premium_transactions (
id BIGINT PRIMARY KEY AUTO_INCREMENT,
user_id BIGINT NOT NULL,
plan_id INT NOT NULL,
amount DECIMAL(10,2) NOT NULL,
currency VARCHAR(3) DEFAULT USD,
payment_method VARCHAR(50),
status TINYINT DEFAULT 0 COMMENT 0=待处理, 1=成功, 2=失败,
transaction_id VARCHAR(255),
createdat TIMESTAMP DEFAULT CURRENTTIMESTAMP,
INDEX idxuserid (user_id),
INDEX idxcreatedat (created_at)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

第四步：实现DAO层

go
// 文件: app/service/biz/internal/dao/premium_dao.go

package dao

import (
context
database/sql
time

github.com/teamgram/teamgram-server/app/service/biz/internal/model
github.com/zeromicro/go-zero/core/stores/sqlx
)

type PremiumDAO struct {
db sqlx.SqlConn
}

func NewPremiumDAO(db sqlx.SqlConn) *PremiumDAO {
return &PremiumDAO{db: db}
}

// GetPremiumStatus 获取用户会员状态
func (d PremiumDAO) GetPremiumStatus(ctx context.Context, userID int64) (model.UserPremium, error) {
var m model.UserPremium
query := SELECT * FROM userpremium WHERE userid = ?
err := d.db.QueryRowCtx(ctx, &m, query, userID)
if err == sqlx.ErrNotFound {
// 返回默认状态（非会员）
return &model.UserPremium{UserID: userID, Status: 0}, nil
}
return &m, err
}

// CreateOrUpdatePremium 创建或更新会员状态
func (d *PremiumDAO) CreateOrUpdatePremium(ctx context.Context, userID int64, status int32, planID int, expiresAt int64) error {
query :=
INSERT INTO userpremium (userid, status, planid, expiresat)
VALUES (?, ?, ?, ?)
ON DUPLICATE KEY UPDATE
status = VALUES(status),
planid = VALUES(planid),
expiresat = VALUES(expiresat)

_, err := d.db.ExecCtx(ctx, query, userID, status, planID, expiresAt)
return err
}

// CreateTransaction 创建交易记录
func (d PremiumDAO) CreateTransaction(ctx context.Context, txn model.PremiumTransaction) (int64, error) {
query :=
INSERT INTO premium_transactions
(userid, planid, amount, currency, paymentmethod, status, transactionid)
VALUES (?, ?, ?, ?, ?, ?, ?)

result, err := d.db.ExecCtx(ctx, query,
txn.UserID, txn.PlanID, txn.Amount, txn.Currency,
txn.PaymentMethod, txn.Status, txn.TransactionID,
)
if err != nil {
return 0, err
}
return result.LastInsertId()
}

// UpdateTransactionStatus 更新交易状态
func (d *PremiumDAO) UpdateTransactionStatus(ctx context.Context, txnID int64, status int32) error {
query := UPDATE premium_transactions SET status = ? WHERE id = ?
_, err := d.db.ExecCtx(ctx, query, status, txnID)
return err
}

第五步：实现核心逻辑

go
// 文件: app/service/biz/internal/core/premium_core.go

package core

import (
context
errors
time

github.com/teamgram/teamgram-server/app/service/biz/internal/dao
github.com/teamgram/teamgram-server/app/service/biz/internal/model
github.com/teamgram/teamgram-server/app/service/biz/internal/svc
)

var (
ErrInvalidPlan = errors.New(无效的高级会员套餐)
ErrPaymentFailed = errors.New(支付处理失败)
)

type PremiumCore struct {
svcCtx *svc.ServiceContext
dao *dao.Premium