自动建立表通过-doris

.gitignore

@@ -0,0 +1 @@
+logs/

gct.sh

@@ -0,0 +1,25 @@
+#!/bin/bash
+
+# 使用命令行参数，如果没有提供则使用默认值
+COMMIT_MSG="${1:-初始提交}"
+TAG_VERSION="${2:-v0.1.0}"
+
+echo "提交信息: $COMMIT_MSG"
+echo "标签版本: $TAG_VERSION"
+
+# 提交和推送
+git add .
+git commit -m "$COMMIT_MSG"
+git push -u origin master
+
+# 创建标签（关键修改在这里）
+# 方法1：使用注释标签（推荐，不会打开编辑器）
+git tag -a "$TAG_VERSION" -m "Release $TAG_VERSION"
+
+# 或者方法2：如果你需要GPG签名，使用这个
+# GIT_EDITOR=true git tag -s "$TAG_VERSION" -m "Release $TAG_VERSION"
+
+# 推送标签
+git push origin "$TAG_VERSION"
+
+echo "完成！"

go.mod

@@ -0,0 +1,17 @@
+module git.x2erp.com/qdy/go-svc-mercury
+
+go 1.25.4
+
+require (
+	git.x2erp.com/qdy/go-base v0.1.70
+	git.x2erp.com/qdy/go-db v0.1.70
+	go-micro.dev/v4 v4.11.0
+)
+
+require (
+	github.com/kr/pretty v0.3.1 // indirect
+	github.com/rogpeppe/go-internal v1.14.1 // indirect
+	gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c // indirect
+)
+
+require gopkg.in/yaml.v2 v2.4.0 // indirect

go.sum

@@ -0,0 +1,14 @@
+git.x2erp.com/qdy/go-base v0.1.44 h1:xHpMppSNj79lqdUc+lmgGXOgEvHyNotUayoe5/hHWr4=
+git.x2erp.com/qdy/go-base v0.1.44/go.mod h1:Q+YLwpCoU8CVSnzATLdz2LAzVMlz/CEGzo8DePf7cug=
+github.com/creack/pty v1.1.9/go.mod h1:oKZEueFk5CKHvIhNR5MUki03XCEU+Q6VDXinZuGJ33E=
+github.com/kr/pretty v0.3.1 h1:flRD4NNwYAUpkphVc1HcthR4KEIFJ65n8Mw5qdRn3LE=
+github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ=
+github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI=
+github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY=
+github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE=
+github.com/rogpeppe/go-internal v1.14.1 h1:UQB4HGPB6osV0SQTLymcB4TgvyWu6ZyliaW0tI/otEQ=
+go-micro.dev/v4 v4.11.0 h1:DZ2xcr0pnZJDlp6MJiCLhw4tXRxLw9xrJlPT91kubr0=
+gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
+gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c h1:Hei/4ADfdWqJk1ZMxUNpqntNwaWcugrBjAiHlqqRiVk=
+gopkg.in/yaml.v2 v2.4.0 h1:D8xgwECY7CYvx+Y2n4sBz93Jn9JRvxdiyyo8CTfuKaY=
+gopkg.in/yaml.v2 v2.4.0/go.mod h1:RDklbk79AGWmwhnvt/jBztapEOGDOx6ZbXqjP6csGnQ=

main.go

@@ -0,0 +1,71 @@
+package main
+
+import (
+	"log"
+
+	"git.x2erp.com/qdy/go-base/bootstraps"
+	"git.x2erp.com/qdy/go-db/factory/database"
+	"git.x2erp.com/qdy/go-db/sqldef"
+	"go-micro.dev/v4/web"
+
+	_ "git.x2erp.com/qdy/go-svc-mercury/tables" // 导入表定义包，触发 init() 函数
+)
+
+var (
+	serviceName    = "svc-configure"
+	serviceVersion = "1"
+)
+
+func main() {
+
+	// 创建服务启动器
+	bootstrapper := bootstraps.NewServiceBootstrapper(serviceName, serviceVersion)
+
+	//加载配置
+	bootstrapper.InitConfig()
+
+	//构建数据库工厂
+	bootstrapper.InitDatabase()
+
+	//创建表到数据库
+	creteTabel(bootstrapper.DbFactory)
+
+	// 启动服务，传入路由注册函数
+	bootstrapper.Run(registerRoutes)
+
+}
+
+// 注册所有路由
+func registerRoutes(webService web.Service, dbFactory *database.DBFactory) {
+
+	// // 查询yaml配置文件
+	// webService.Handle("/api/query/yaml", middleware.JWTAuthMiddleware(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+	// 	myhandle.QueryHandlerMap(w, r, dbFactory, service.QueryYamlConfigure)
+	// })))
+
+	// // 初始化配置模版
+	// webService.Handle("/api/init/config/template", middleware.JWTAuthMiddleware(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+	// 	myhandle.QueryHandlerMap(w, r, dbFactory, service.InitConfigTemplates)
+	// })))
+
+}
+
+func creteTabel(factory *database.DBFactory) {
+
+	// 获取数据库连接和类型
+	db := factory.GetDB()
+	dbType := factory.GetDBType()
+
+	// 创建表同步器
+	syncer, err := sqldef.NewTableSyncer(db, dbType)
+	if err != nil {
+		log.Printf("创建 - 建立器失败: %v", err)
+	}
+
+	// 创建表
+	if err := syncer.CreateTables(); err != nil {
+		log.Printf("建表失败: %v", err)
+	}
+
+	log.Println("数据库表建立完成！")
+}

tables/config_channel.go

@@ -0,0 +1,38 @@
+package tables
+
+import (
+	"time"
+
+	"git.x2erp.com/qdy/go-db/sqldef"
+)
+
+func init() {
+	sqldef.AddRegistration(func(r *sqldef.Registry) {
+		tb := sqldef.NewTable("config_channel", "渠道档案表").
+			ID("channel_id", 32).Comment("渠道编码，主键").End().
+			String("channel_name", 64).NotNull().Comment("渠道名称(如:天猫旗舰店)").End().
+			String("channel_type", 32).NotNull().Comment("渠道类型(如:线上/线下/奥莱)").End().
+			String("store_id", 32).Comment("关联门店/仓库ID，对应ERP编码").End().
+			String("tenant_id", 8).NotNull().Comment("租户ID").End().
+			String("store_group_id", 32).NotNull().Comment("所属店铺组").End().
+			String("creator", 32).NotNull().Comment("创建人").End().
+			DateTime("created_at").NotNull().Default("CURRENT_TIMESTAMP").Comment("创建时间").End()
+		r.RegisterTable(tb.Build())
+	})
+}
+
+// ConfigChannel 渠道档案表结构体
+type ConfigChannel struct {
+	ChannelID    string    `gorm:"column:channel_id;type:varchar(32);primaryKey;not null;comment:渠道编码，主键"`
+	ChannelName  string    `gorm:"column:channel_name;type:varchar(64);not null;comment:渠道名称(如:天猫旗舰店)"`
+	ChannelType  string    `gorm:"column:channel_type;type:varchar(32);not null;comment:渠道类型(如:线上/线下/奥莱)"`
+	StoreID      string    `gorm:"column:store_id;type:varchar(32);comment:关联门店/仓库ID，对应ERP编码"`
+	TenantId     string    `gorm:"column:tenant_id;type:varchar(8);comment:租户ID"`
+	Creator      string    `gorm:"column:creator;type:varchar(32);not null;comment:创建人"`
+	CreatedAt    time.Time `gorm:"column:created_at;not null;default:CURRENT_TIMESTAMP;comment:创建时间"`
+	StoreGroupID string    `gorm:"column:store_group_id;type:varchar(32);comment:所属店铺组"`
+}
+
+func (ConfigChannel) TableName() string {
+	return "config_channel"
+}

tables/decision_task.go

@@ -0,0 +1,52 @@
+package tables
+
+import (
+	"time"
+
+	"git.x2erp.com/qdy/go-db/sqldef"
+)
+
+func init() {
+	sqldef.AddRegistration(func(r *sqldef.Registry) {
+		tb := sqldef.NewTable("decision_task", "决策任务表").
+			ID("task_id", 32).Comment("任务ID，主键").End().
+			String("sku_id", 32).NotNull().Comment("关联商品").End().
+			String("task_type", 32).NotNull().Comment("任务类型(调拨/促销/反单/保持)").End().
+			String("task_status", 32).NotNull().Default("'pending'").Comment("任务状态(pending/approved/rejected/executed)").End().
+			Text("task_content").NotNull().Comment("任务详细内容与参数(JSON格式)").End().
+			Text("diagnosis_basis").NotNull().Comment("诊断依据与数据快照(JSON格式)").End().
+			String("creator", 32).Comment("任务创建人(系统或用户)").End().
+			String("approver", 32).Comment("审批人").End().
+			DateTime("approved_at").Comment("审批时间").End().
+			String("executor", 32).Comment("执行人").End().
+			String("tenant_id", 8).NotNull().Comment("租户ID").End().
+			DateTime("executed_at").Comment("执行时间").End().
+			Text("execution_feedback").Comment("执行反馈(JSON格式)").End().
+			DateTime("created_at").NotNull().Default("CURRENT_TIMESTAMP").Comment("创建时间").End().
+			DateTime("updated_at").NotNull().Default("CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP").Comment("更新时间").End()
+		r.RegisterTable(tb.Build())
+	})
+}
+
+// DecisionTask 决策任务表结构体
+type DecisionTask struct {
+	TaskID            string    `gorm:"column:task_id;type:varchar(32);primaryKey;not null;comment:任务ID，主键"`
+	SkuID             string    `gorm:"column:sku_id;type:varchar(32);not null;comment:关联商品;index"`
+	TaskType          string    `gorm:"column:task_type;type:varchar(32);not null;comment:任务类型(调拨/促销/反单/保持)"`
+	TaskStatus        string    `gorm:"column:task_status;type:varchar(32);not null;default:'pending';comment:任务状态(pending/approved/rejected/executed)"`
+	TaskContent       string    `gorm:"column:task_content;type:text;not null;comment:任务详细内容与参数(JSON格式)"`
+	DiagnosisBasis    string    `gorm:"column:diagnosis_basis;type:text;not null;comment:诊断依据与数据快照(JSON格式)"`
+	Creator           string    `gorm:"column:creator;type:varchar(32);comment:任务创建人(系统或用户)"`
+	Approver          string    `gorm:"column:approver;type:varchar(32);comment:审批人"`
+	ApprovedAt        time.Time `gorm:"column:approved_at;comment:审批时间"`
+	Executor          string    `gorm:"column:executor;type:varchar(32);comment:执行人"`
+	ExecutedAt        time.Time `gorm:"column:executed_at;comment:执行时间"`
+	ExecutionFeedback string    `gorm:"column:execution_feedback;type:text;comment:执行反馈(JSON格式)"`
+	CreatedAt         time.Time `gorm:"column:created_at;not null;default:CURRENT_TIMESTAMP;comment:创建时间"`
+	UpdatedAt         time.Time `gorm:"column:updated_at;not null;default:CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP;comment:更新时间"`
+	TenantId          string    `gorm:"column:tenant_id;type:varchar(8);comment:租户ID"`
+}
+
+func (DecisionTask) TableName() string {
+	return "decision_task"
+}

tables/dim_season.go

@@ -0,0 +1,39 @@
+package tables
+
+import (
+	"time"
+
+	"git.x2erp.com/qdy/go-db/sqldef"
+)
+
+func init() {
+	sqldef.AddRegistration(func(r *sqldef.Registry) {
+		tb := sqldef.NewTable("dim_season", "季节波段档案表").
+			ID("season_id", 32).Comment("季节波段ID，主键").End().
+			String("season_code", 32).NotNull().Unique().Comment("季节编码(如:2024FA)").End().
+			String("season_name", 64).NotNull().Comment("季节名称(如:2024秋冬)").End().
+			Int("year").NotNull().Comment("年份").End().
+			String("phase", 32).NotNull().Comment("季节(春/夏/秋/冬)").End().
+			DateTime("plan_start").NotNull().Comment("季节计划开始日期").End().
+			DateTime("plan_end").NotNull().Comment("季节计划结束日期").End().
+			String("creator", 32).NotNull().Comment("创建人").End().
+			String("tenant_id", 8).NotNull().Comment("租户ID").End().
+			DateTime("created_at").NotNull().Default("CURRENT_TIMESTAMP").Comment("创建时间").End()
+		r.RegisterTable(tb.Build())
+	})
+}
+
+type DimSeason struct {
+	SeasonID   string    `gorm:"column:season_id;type:varchar(32);primaryKey;not null;comment:季节波段ID，主键"`
+	SeasonCode string    `gorm:"column:season_code;type:varchar(32);not null;unique;comment:季节编码(如:2024FA)"`
+	SeasonName string    `gorm:"column:season_name;type:varchar(64);not null;comment:季节名称(如:2024秋冬)"`
+	Year       int       `gorm:"column:year;not null;comment:年份"`
+	Phase      string    `gorm:"column:phase;type:varchar(32);not null;comment:季节(春/夏/秋/冬)"`
+	PlanStart  time.Time `gorm:"column:plan_start;not null;comment:季节计划开始日期"`
+	PlanEnd    time.Time `gorm:"column:plan_end;not null;comment:季节计划结束日期"`
+	Creator    string    `gorm:"column:creator;type:varchar(32);not null;comment:创建人"`
+	CreatedAt  time.Time `gorm:"column:created_at;not null;default:CURRENT_TIMESTAMP;comment:创建时间"`
+	TenantId   string    `gorm:"column:tenant_id;type:varchar(8);comment:租户ID"`
+}
+
+func (DimSeason) TableName() string { return "dim_season" }

tables/dim_store_group.go

@@ -0,0 +1,34 @@
+package tables
+
+import (
+	"time"
+
+	"git.x2erp.com/qdy/go-db/sqldef"
+)
+
+func init() {
+	sqldef.AddRegistration(func(r *sqldef.Registry) {
+		tb := sqldef.NewTable("dim_store_group", "店铺组档案表").
+			ID("group_id", 32).Comment("店铺组ID，主键").End().
+			String("group_code", 32).NotNull().Unique().Comment("店铺组编码").End().
+			String("group_name", 64).NotNull().Comment("店铺组名称(如:华东A类店)").End().
+			String("group_type", 32).NotNull().Comment("分组类型(区域/城市等级/渠道/店铺等级)").End().
+			String("description", 255).Comment("分组描述").End().
+			String("creator", 32).NotNull().Comment("创建人").End().
+			DateTime("created_at").NotNull().Default("CURRENT_TIMESTAMP").Comment("创建时间").End()
+		r.RegisterTable(tb.Build())
+	})
+}
+
+type DimStoreGroup struct {
+	GroupID     string    `gorm:"column:group_id;type:varchar(32);primaryKey;not null;comment:店铺组ID，主键"`
+	GroupCode   string    `gorm:"column:group_code;type:varchar(32);not null;unique;comment:店铺组编码"`
+	GroupName   string    `gorm:"column:group_name;type:varchar(64);not null;comment:店铺组名称(如:华东A类店)"`
+	GroupType   string    `gorm:"column:group_type;type:varchar(32);not null;comment:分组类型(区域/城市等级/渠道/店铺等级)"`
+	Description string    `gorm:"column:description;type:varchar(255);comment:分组描述"`
+	Creator     string    `gorm:"column:creator;type:varchar(32);not null;comment:创建人"`
+	CreatedAt   time.Time `gorm:"column:created_at;not null;default:CURRENT_TIMESTAMP;comment:创建时间"`
+	TenantId    string    `gorm:"column:tenant_id;type:varchar(8);comment:租户ID"`
+}
+
+func (DimStoreGroup) TableName() string { return "dim_store_group" }

tables/fact_campaign_plan.go

@@ -0,0 +1,47 @@
+package tables
+
+import (
+	"time"
+
+	"git.x2erp.com/qdy/go-db/sqldef"
+)
+
+func init() {
+	sqldef.AddRegistration(func(r *sqldef.Registry) {
+		tb := sqldef.NewTable("fact_campaign_plan", "波段作战计划表").
+			ID("plan_id", 32).Comment("计划ID，主键").End().
+			String("season_id", 32).NotNull().Comment("季节波段").End().
+			String("group_id", 32).NotNull().Comment("店铺组").End().
+			String("campaign_tag", 64).NotNull().Comment("波段标签(如:秋一波)").End().
+			Int("campaign_seq").NotNull().Comment("波段序号").End().
+			DateTime("plan_start_date").NotNull().Comment("该组计划上市日期").End().
+			DateTime("plan_end_date").NotNull().Comment("该组计划下市日期").End().
+			Decimal("sales_target", 12, 2).Comment("销售目标金额").End().
+			Int("sales_target_qty").Comment("销售目标件数").End().
+			String("tenant_id", 8).NotNull().Comment("租户ID").End().
+			Text("planned_skus").Comment("计划主推SKU列表(JSON)").End().
+			String("creator", 32).NotNull().Comment("创建人").End().
+			DateTime("created_at").NotNull().Default("CURRENT_TIMESTAMP").Comment("创建时间").End().
+			DateTime("updated_at").NotNull().Default("CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP").Comment("更新时间").End()
+		r.RegisterTable(tb.Build())
+	})
+}
+
+type FactCampaignPlan struct {
+	PlanID         string    `gorm:"column:plan_id;type:varchar(32);primaryKey;not null;comment:计划ID，主键"`
+	SeasonID       string    `gorm:"column:season_id;type:varchar(32);not null;comment:季节波段;index:idx_season_group"`
+	GroupID        string    `gorm:"column:group_id;type:varchar(32);not null;comment:店铺组;index:idx_season_group"`
+	CampaignTag    string    `gorm:"column:campaign_tag;type:varchar(64);not null;comment:波段标签(如:秋一波)"`
+	CampaignSeq    int       `gorm:"column:campaign_seq;not null;comment:波段序号"`
+	PlanStartDate  time.Time `gorm:"column:plan_start_date;not null;comment:该组计划上市日期"`
+	PlanEndDate    time.Time `gorm:"column:plan_end_date;not null;comment:该组计划下市日期"`
+	SalesTarget    float64   `gorm:"column:sales_target;type:decimal(12,2);comment:销售目标金额"`
+	SalesTargetQty int       `gorm:"column:sales_target_qty;comment:销售目标件数"`
+	PlannedSkus    string    `gorm:"column:planned_skus;type:text;comment:计划主推SKU列表(JSON)"`
+	Creator        string    `gorm:"column:creator;type:varchar(32);not null;comment:创建人"`
+	CreatedAt      time.Time `gorm:"column:created_at;not null;default:CURRENT_TIMESTAMP;comment:创建时间"`
+	UpdatedAt      time.Time `gorm:"column:updated_at;not null;default:CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP;comment:更新时间"`
+	TenantId       string    `gorm:"column:tenant_id;type:varchar(8);comment:租户ID"`
+}
+
+func (FactCampaignPlan) TableName() string { return "fact_campaign_plan" }

tables/inventory_snapshot.go

@@ -0,0 +1,36 @@
+package tables
+
+import (
+	"time"
+
+	"git.x2erp.com/qdy/go-db/sqldef"
+)
+
+func init() {
+	sqldef.AddRegistration(func(r *sqldef.Registry) {
+		tb := sqldef.NewTable("inventory_snapshot", "库存快照表").
+			ID("snapshot_id", 32).Comment("快照ID，主键").End().
+			String("sku_id", 32).NotNull().Comment("商品SKU").End().
+			String("channel_id", 32).NotNull().Comment("所在渠道").End().
+			String("tenant_id", 8).NotNull().Comment("租户ID").End().
+			Int("quantity").NotNull().Default("0").Comment("可用库存数量").End().
+			DateTime("snapshot_time").NotNull().Comment("快照时间点").End().
+			DateTime("extracted_at").NotNull().Default("CURRENT_TIMESTAMP").Comment("数据抽取时间").End()
+		r.RegisterTable(tb.Build())
+	})
+}
+
+// InventorySnapshot 库存快照表结构体
+type InventorySnapshot struct {
+	SnapshotID   string    `gorm:"column:snapshot_id;type:varchar(32);primaryKey;not null;comment:快照ID，主键"`
+	SkuID        string    `gorm:"column:sku_id;type:varchar(32);not null;comment:商品SKU;index:idx_sku_channel"`
+	ChannelID    string    `gorm:"column:channel_id;type:varchar(32);not null;comment:所在渠道;index:idx_sku_channel"`
+	Quantity     int       `gorm:"column:quantity;not null;default:0;comment:可用库存数量"`
+	SnapshotTime time.Time `gorm:"column:snapshot_time;not null;comment:快照时间点"`
+	ExtractedAt  time.Time `gorm:"column:extracted_at;not null;default:CURRENT_TIMESTAMP;comment:数据抽取时间"`
+	TenantId     string    `gorm:"column:tenant_id;type:varchar(8);comment:租户ID"`
+}
+
+func (InventorySnapshot) TableName() string {
+	return "inventory_snapshot"
+}

tables/product_sku.go

@@ -0,0 +1,48 @@
+package tables
+
+import (
+	"time"
+
+	"git.x2erp.com/qdy/go-db/sqldef"
+)
+
+func init() {
+	sqldef.AddRegistration(func(r *sqldef.Registry) {
+		tb := sqldef.NewTable("product_sku", "商品档案表").
+			ID("sku_id", 32).Comment("款色码唯一标识，主键").End().
+			String("sku_code", 64).NotNull().Comment("商品款号").End().
+			String("sku_name", 128).NotNull().Comment("商品名称").End().
+			String("category_code", 32).NotNull().Comment("品类编码").End().
+			String("category_name", 64).NotNull().Comment("品类名称").End().
+			String("season_code", 32).NotNull().Comment("季节波段编码").End().
+			String("season_name", 64).NotNull().Comment("季节波段名称").End().
+			String("tenant_id", 8).NotNull().Comment("租户ID").End().
+			DateTime("first_list_date").NotNull().Comment("首次上市日期").End().
+			Decimal("tag_price", 10, 2).NotNull().Comment("吊牌价").End().
+			String("creator", 32).NotNull().Comment("创建人").End().
+			DateTime("created_at").NotNull().Default("CURRENT_TIMESTAMP").Comment("创建时间").End().
+			DateTime("updated_at").NotNull().Default("CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP").Comment("更新时间").End()
+		r.RegisterTable(tb.Build())
+	})
+}
+
+// ProductSku 商品档案表结构体
+type ProductSku struct {
+	SkuID         string    `gorm:"column:sku_id;type:varchar(32);primaryKey;not null;comment:款色码唯一标识，主键"`
+	SkuCode       string    `gorm:"column:sku_code;type:varchar(64);not null;comment:商品款号"`
+	SkuName       string    `gorm:"column:sku_name;type:varchar(128);not null;comment:商品名称"`
+	CategoryCode  string    `gorm:"column:category_code;type:varchar(32);not null;comment:品类编码"`
+	CategoryName  string    `gorm:"column:category_name;type:varchar(64);not null;comment:品类名称"`
+	SeasonCode    string    `gorm:"column:season_code;type:varchar(32);not null;comment:季节波段编码"`
+	SeasonName    string    `gorm:"column:season_name;type:varchar(64);not null;comment:季节波段名称"`
+	FirstListDate time.Time `gorm:"column:first_list_date;not null;comment:首次上市日期"`
+	TagPrice      float64   `gorm:"column:tag_price;type:decimal(10,2);not null;comment:吊牌价"`
+	Creator       string    `gorm:"column:creator;type:varchar(32);not null;comment:创建人"`
+	CreatedAt     time.Time `gorm:"column:created_at;not null;default:CURRENT_TIMESTAMP;comment:创建时间"`
+	UpdatedAt     time.Time `gorm:"column:updated_at;not null;default:CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP;comment:更新时间"`
+	TenantId      string    `gorm:"column:tenant_id;type:varchar(8);comment:租户ID"`
+}
+
+func (ProductSku) TableName() string {
+	return "product_sku"
+}

tables/purchase_receipt.go

@@ -0,0 +1,40 @@
+package tables
+
+import (
+	"time"
+
+	"git.x2erp.com/qdy/go-db/sqldef"
+)
+
+func init() {
+	sqldef.AddRegistration(func(r *sqldef.Registry) {
+		tb := sqldef.NewTable("purchase_receipt", "采购入库表").
+			ID("receipt_id", 32).Comment("入库单ID，主键").End().
+			String("erp_receipt_id", 64).NotNull().Comment("ERP原始入库单号").End().
+			String("sku_id", 32).NotNull().Comment("商品SKU").End().
+			String("channel_id", 32).NotNull().Comment("入库渠道/仓库").End().
+			Int("quantity").NotNull().Default("0").Comment("入库数量").End().
+			String("tenant_id", 8).NotNull().Comment("租户ID").End().
+			DateTime("receipt_time").NotNull().Comment("实际入库时间").End().
+			DateTime("expected_arrival_date").Comment("预计到货日期").End().
+			DateTime("extracted_at").NotNull().Default("CURRENT_TIMESTAMP").Comment("数据抽取时间").End()
+		r.RegisterTable(tb.Build())
+	})
+}
+
+// PurchaseReceipt 采购入库表结构体
+type PurchaseReceipt struct {
+	ReceiptID           string    `gorm:"column:receipt_id;type:varchar(32);primaryKey;not null;comment:入库单ID，主键"`
+	ErpReceiptID        string    `gorm:"column:erp_receipt_id;type:varchar(64);not null;comment:ERP原始入库单号;index"`
+	SkuID               string    `gorm:"column:sku_id;type:varchar(32);not null;comment:商品SKU;index"`
+	ChannelID           string    `gorm:"column:channel_id;type:varchar(32);not null;comment:入库渠道/仓库"`
+	Quantity            int       `gorm:"column:quantity;not null;default:0;comment:入库数量"`
+	ReceiptTime         time.Time `gorm:"column:receipt_time;not null;comment:实际入库时间"`
+	ExpectedArrivalDate time.Time `gorm:"column:expected_arrival_date;comment:预计到货日期"`
+	ExtractedAt         time.Time `gorm:"column:extracted_at;not null;default:CURRENT_TIMESTAMP;comment:数据抽取时间"`
+	TenantId            string    `gorm:"column:tenant_id;type:varchar(8);comment:租户ID"`
+}
+
+func (PurchaseReceipt) TableName() string {
+	return "purchase_receipt"
+}

tables/sales_transaction.go

@@ -0,0 +1,42 @@
+package tables
+
+import (
+	"time"
+
+	"git.x2erp.com/qdy/go-db/sqldef"
+)
+
+func init() {
+	sqldef.AddRegistration(func(r *sqldef.Registry) {
+		tb := sqldef.NewTable("sales_transaction", "销售流水表").
+			ID("transaction_id", 32).Comment("交易流水ID，主键").End().
+			String("erp_order_id", 64).NotNull().Comment("ERP原始订单号").End().
+			String("sku_id", 32).NotNull().Comment("商品SKU").End().
+			String("channel_id", 32).NotNull().Comment("销售渠道").End().
+			String("tenant_id", 8).NotNull().Comment("租户ID").End().
+			Int("quantity").NotNull().Default("0").Comment("销售数量").End().
+			Decimal("original_amount", 12, 2).NotNull().Comment("吊牌价金额").End().
+			Decimal("actual_amount", 12, 2).NotNull().Comment("实收金额").End().
+			DateTime("sale_time").NotNull().Comment("销售时间").End().
+			DateTime("extracted_at").NotNull().Default("CURRENT_TIMESTAMP").Comment("数据抽取时间").End()
+		r.RegisterTable(tb.Build())
+	})
+}
+
+// SalesTransaction 销售流水表结构体
+type SalesTransaction struct {
+	TransactionID  string    `gorm:"column:transaction_id;type:varchar(32);primaryKey;not null;comment:交易流水ID，主键"`
+	ErpOrderID     string    `gorm:"column:erp_order_id;type:varchar(64);not null;comment:ERP原始订单号;index"`
+	SkuID          string    `gorm:"column:sku_id;type:varchar(32);not null;comment:商品SKU;index:idx_sku_channel_time"`
+	ChannelID      string    `gorm:"column:channel_id;type:varchar(32);not null;comment:销售渠道;index:idx_sku_channel_time"`
+	Quantity       int       `gorm:"column:quantity;not null;default:0;comment:销售数量"`
+	OriginalAmount float64   `gorm:"column:original_amount;type:decimal(12,2);not null;comment:吊牌价金额"`
+	ActualAmount   float64   `gorm:"column:actual_amount;type:decimal(12,2);not null;comment:实收金额"`
+	SaleTime       time.Time `gorm:"column:sale_time;not null;comment:销售时间;index:idx_sku_channel_time"`
+	ExtractedAt    time.Time `gorm:"column:extracted_at;not null;default:CURRENT_TIMESTAMP;comment:数据抽取时间"`
+	TenantId       string    `gorm:"column:tenant_id;type:varchar(8);comment:租户ID"`
+}
+
+func (SalesTransaction) TableName() string {
+	return "sales_transaction"
+}