diff --git a/controllers/importer.go b/controllers/importer.go index 5dc3471..39a9667 100644 --- a/controllers/importer.go +++ b/controllers/importer.go @@ -66,7 +66,7 @@ func Start(w http.ResponseWriter, route *http.Request) { mainImportWG.Add(len(mainCategories)) - errDel := deleteProducts() + errDel := gm.DeleteProducts(baza) if errDel != nil { http.Error(w, errDel.Error(), http.StatusInternalServerError) @@ -88,16 +88,6 @@ func Start(w http.ResponseWriter, route *http.Request) { } -func deleteProducts() error { - //todo delete non ordered & non favorited products - //select distinct ordered and favorited product ids - //todo delete from elastico - //Delete from products where id in (select distinct) - - return baza.Delete(&gm.Product{}).Error - -} - func startImport(dbName string, db *gorm.DB) { defer mainImportWG.Done() diff --git a/gorm_models/product.go b/gorm_models/product.go index 9b8a484..9cb2d4b 100644 --- a/gorm_models/product.go +++ b/gorm_models/product.go @@ -1,6 +1,9 @@ package gorm_models -import "time" +import ( + "gorm.io/gorm" + "time" +) type Product struct { ID uint `gorm:"primary_key"` @@ -86,3 +89,14 @@ type Tabler interface { func (ProductFlat) TableName() string { return "product_flat" } + +func DeleteProducts(db *gorm.DB) error { + //todo delete non ordered & non favorited products + //select distinct ordered and favorited product ids + //todo delete from elastico + //Delete from products where id in (select distinct) + //db.Exec("DELETE FROM products") + + return db.Exec("DELETE FROM products").Error + +}