OPC/goauto
2
0
Fork 0
Code Issues 192 Pull Requests Actions Packages Projects Releases Wiki Activity

fix(#52): align SYB sync count columns with MySQL

Browse Source
This commit is contained in:
QiuSW
2026-08-20 16:19:54 +08:00
parent 32edb91a31
commit 903280fada
3 changed files with 23 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
server/app/goauto/migrations/migrate_test.go
+19
View File
@@ -100,6 +100,25 @@ func TestMySQLCompositeIndexesFitInnoDBLimit(t *testing.T) {
}
}
func TestSYBSyncRunCountFieldsKeepExistingMySQLColumnNames(t *testing.T) {
parsed, err := schema.Parse(&models.SYBSyncRun{}, &sync.Map{}, schema.NamingStrategy{})
if err != nil {
t.Fatalf("parse SYB sync run schema: %v", err)
}
for fieldName, wantDBName := range map[string]string{
"Created": "created_count",
"Updated": "updated_count",
} {
field := parsed.LookUpField(fieldName)
if field == nil {
t.Fatalf("SYBSyncRun.%s field missing", fieldName)
}
if field.DBName != wantDBName {
t.Fatalf("SYBSyncRun.%s DBName = %q, want %q", fieldName, field.DBName, wantDBName)
}
}
}
func TestMySQLCheckColumnHasNoExplicitForeignKeyActions(t *testing.T) {
device, ok := reflect.TypeOf(models.CollectionTask{}).FieldByName("Device")
if !ok {
server/app/goauto/models/schema.go
+2 -2
View File
@@ -437,8 +437,8 @@ type SYBSyncRun struct {
DetailCount int `json:"detailCount" gorm:"not null;default:0"`
AcceptedCount int `json:"acceptedCount" gorm:"not null;default:0"`
ShopSkipped int `json:"shopSkipped" gorm:"not null;default:0"`
Created int `json:"created" gorm:"not null;default:0"`
Updated int `json:"updated" gorm:"not null;default:0"`
Created int `json:"created" gorm:"column:created_count;not null;default:0"`
Updated int `json:"updated" gorm:"column:updated_count;not null;default:0"`
ShopFilterHash string `json:"shopFilterHash" gorm:"size:64;not null"`
ShopBreakdownJSON string `json:"-" gorm:"type:text;not null"`
ErrorMessage string `json:"errorMessage" gorm:"size:1000;not null;default:''"`
server/app/goauto/sybimport/sync_run.go
+2 -2
View File
@@ -64,7 +64,7 @@ func (s *SyncRunService) UpdateProgress(ctx context.Context, id uint64, progress
"days_total": progress.DaysTotal, "days_processed": progress.DaysProcessed,
"order_count": progress.Report.OrderCount, "detail_count": progress.Report.DetailCount,
"accepted_count": progress.Report.AcceptedCount, "shop_skipped": progress.Report.ShopSkipped,
"created": progress.Report.Created, "updated": progress.Report.Updated,
"created_count": progress.Report.Created, "updated_count": progress.Report.Updated,
"shop_filter_hash": progress.Report.ShopFilterHash, "shop_breakdown_json": string(breakdown),
}).Error
}
@@ -86,7 +86,7 @@ func (s *SyncRunService) Finish(ctx context.Context, id uint64, status string, r
"status": status, "active_slot": nil, "finished_at": now, "error_message": message,
"order_count": report.OrderCount, "detail_count": report.DetailCount,
"accepted_count": report.AcceptedCount, "shop_skipped": report.ShopSkipped,
"created": report.Created, "updated": report.Updated,
"created_count": report.Created, "updated_count": report.Updated,
"shop_breakdown_json": string(breakdown),
}
if report.ShopFilterHash != "" {