| | |
| | | "encoding/json" |
| | | "fmt" |
| | | "gorm.io/gorm" |
| | | "gorm.io/gorm/clause" |
| | | ) |
| | | |
| | | type ( |
| | |
| | | return nil |
| | | } |
| | | |
| | | func (slf *ProceduresSearch) Upsert(record *Procedures) error { |
| | | var db = slf.build() |
| | | |
| | | if err := db.Clauses(clause.OnConflict{ |
| | | UpdateAll: true, |
| | | }).Create(&record).Error; err != nil { |
| | | return fmt.Errorf("save err: %v, record: %+v", err, record) |
| | | } |
| | | |
| | | return nil |
| | | } |
| | | |
| | | func (slf *ProceduresSearch) Updates(record *Procedures) error { |
| | | var db = slf.build() |
| | | |
| | |
| | | return err |
| | | } |
| | | for _, procedure := range procedureRecords { |
| | | err = model.NewProceduresSearch(db).SetWorkOrderId(procedure.WorkOrderID).SetProcedureId(procedure.ProcedureID).Updates(procedure) |
| | | err = model.NewProceduresSearch(db).SetWorkOrderId(procedure.WorkOrderID).SetProcedureId(procedure.ProcedureID).Upsert(procedure) |
| | | if err != nil { |
| | | return err |
| | | } |