43 lines
1.4 KiB
Go
43 lines
1.4 KiB
Go
package multitable
|
|
|
|
import (
|
|
"fmt"
|
|
"time"
|
|
|
|
"git.iwork-ai.com/xdc/iqudo-top1/internal/model"
|
|
"gorm.io/gorm"
|
|
"gorm.io/gorm/clause"
|
|
)
|
|
|
|
func EnqueueBackfill(db *gorm.DB) (int, error) {
|
|
resources := []struct {
|
|
name string
|
|
model interface{}
|
|
}{
|
|
{"scenario", &model.Scenario{}},
|
|
{"scenario_field", &model.ScenarioField{}},
|
|
{"scenario_rule", &model.ScenarioRule{}},
|
|
{"sop", &model.SOP{}},
|
|
{"sop_run", &model.SOPRun{}},
|
|
}
|
|
count := 0
|
|
for _, resource := range resources {
|
|
var rows []struct{ ID, TenantID uint64 }
|
|
if err := db.Model(resource.model).Select("id, tenant_id").Scan(&rows).Error; err != nil {
|
|
return count, fmt.Errorf("list %s: %w", resource.name, err)
|
|
}
|
|
for _, row := range rows {
|
|
event := model.MultiTableOutbox{
|
|
TenantID: row.TenantID, Resource: resource.name, ResourceID: row.ID, Action: "backfill",
|
|
Payload: []byte(`{}`), DedupeKey: fmt.Sprintf("backfill:%s:%d", resource.name, row.ID),
|
|
Status: "pending", Attempts: 0, AvailableAt: time.Now(), LastError: "",
|
|
}
|
|
if err := db.Clauses(clause.OnConflict{Columns: []clause.Column{{Name: "dedupe_key"}}, DoUpdates: clause.Assignments(map[string]interface{}{"status": "pending", "attempts": 0, "available_at": time.Now(), "last_error": ""})}).Create(&event).Error; err != nil {
|
|
return count, fmt.Errorf("enqueue %s %d: %w", resource.name, row.ID, err)
|
|
}
|
|
count++
|
|
}
|
|
}
|
|
return count, nil
|
|
}
|