mirror of
https://github.com/yunionio/cloudpods.git
synced 2026-08-31 01:35:56 +08:00
fix(cloudevent): skip cloudevent init data
This commit is contained in:
@@ -288,47 +288,3 @@ func (manager *SCloudeventManager) GetPropertyDistinctField(ctx context.Context,
|
||||
}
|
||||
return jsonutils.Marshal(ret), nil
|
||||
}
|
||||
|
||||
func (manager *SCloudeventManager) initDistinctField() error {
|
||||
fileds, err := db.DistinctFieldManager.GetObjectDistinctFields(manager.Keyword())
|
||||
if err != nil {
|
||||
return errors.Wrapf(err, "GetObjectDistinctFields")
|
||||
}
|
||||
if len(fileds) > 0 {
|
||||
return nil
|
||||
}
|
||||
for _, key := range []string{"service", "resource_type", "action", "account", "manager", "provider", "brand"} {
|
||||
values, err := db.FetchDistinctField(manager, key)
|
||||
if err != nil {
|
||||
return errors.Wrapf(err, "db.FetchDistinctField")
|
||||
}
|
||||
for _, value := range values {
|
||||
if len(value) > 0 {
|
||||
err = db.DistinctFieldManager.InsertOrUpdate(nil, manager, key, value)
|
||||
if err != nil {
|
||||
return errors.Wrapf(err, "DistinctFieldManager.InsertOrUpdate(%s, %s)", key, value)
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (manager *SCloudeventManager) InitializeData() error {
|
||||
events := []SCloudevent{}
|
||||
q := manager.Query().IsNullOrEmpty("brand")
|
||||
err := db.FetchModelObjects(manager, q, &events)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
for i := range events {
|
||||
_, err = db.Update(&events[i], func() error {
|
||||
events[i].Brand = events[i].Provider
|
||||
return nil
|
||||
})
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
}
|
||||
return manager.initDistinctField()
|
||||
}
|
||||
|
||||
@@ -33,7 +33,6 @@ func InitDB() error {
|
||||
proxy.ProxySettingManager,
|
||||
|
||||
CloudproviderManager,
|
||||
CloudeventManager,
|
||||
} {
|
||||
err := manager.InitializeData()
|
||||
if err != nil {
|
||||
|
||||
Reference in New Issue
Block a user