fix
zhangqian
2023-09-26 47d9937507004599d14b1e02f479f753cb229901
fix
2个文件已修改
15 ■■■■■ 已修改文件
model/procedures.go 13 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
nsq/msg_handler.go 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
model/procedures.go
@@ -7,6 +7,7 @@
    "encoding/json"
    "fmt"
    "gorm.io/gorm"
    "gorm.io/gorm/clause"
)
type (
@@ -215,6 +216,18 @@
    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()
nsq/msg_handler.go
@@ -84,7 +84,7 @@
                    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
                    }