Alireza Ahmadi
47 lines
873 B
Go
47 lines
873 B
Go
package service
|
|
|
|
import (
|
|
"encoding/json"
|
|
"s-ui/database"
|
|
"s-ui/database/model"
|
|
|
|
"gorm.io/gorm"
|
|
)
|
|
|
|
type InDataService struct {
|
|
}
|
|
|
|
func (s *InDataService) GetAll() ([]model.InboundData, error) {
|
|
db := database.GetDB()
|
|
inData := []model.InboundData{}
|
|
err := db.Model(model.InboundData{}).Scan(&inData).Error
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return inData, nil
|
|
}
|
|
|
|
func (s *InDataService) Save(tx *gorm.DB, changes []model.Changes) error {
|
|
var err error
|
|
for _, change := range changes {
|
|
inData := model.InboundData{}
|
|
err = json.Unmarshal(change.Obj, &inData)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
switch change.Action {
|
|
case "new":
|
|
err = tx.Create(&inData).Error
|
|
case "del":
|
|
err = tx.Where("id = ?", change.Index).Delete(model.InboundData{}).Error
|
|
default:
|
|
err = tx.Save(inData).Error
|
|
}
|
|
if err != nil {
|
|
return err
|
|
}
|
|
}
|
|
return err
|
|
}
|