删除或改造gorm v1不支持的批量保存方法

zhangqian

2023-10-20 50fdb4bc0545136c14b7b1b50c55430e5c8d970a

删除或改造gorm v1不支持的批量保存方法

 model/device_plc.go

@@ -109,17 +109,6 @@
    return nil
}

// CreateBatch 批量插入
func (slf *DevicePlcSearch) CreateBatch(records []*DevicePlc) error {
    var db = slf.build()

    if err := db.Create(&records).Error; err != nil {
        return fmt.Errorf("create batch err: %v, records: %+v", err, records)
    }

    return nil
}

func (slf *DevicePlcSearch) Save(record *DevicePlc) error {
    var db = slf.build()


 model/production_progress.go

@@ -133,17 +133,6 @@
    return nil
}

// CreateBatch 批量插入
func (slf *ProductionProgressSearch) CreateBatch(records []*ProductionProgress) error {
    var db = slf.build()

    if err := db.Create(&records).Error; err != nil {
        return fmt.Errorf("create batch err: %v, records: %+v", err, records)
    }

    return nil
}

func (slf *ProductionProgressSearch) Save(record *ProductionProgress) error {
    var db = slf.build()


 model/work_order.go

@@ -161,17 +161,6 @@
    return nil
}

// CreateBatch 批量插入
func (slf *OrderSearch) CreateBatch(records []*Order) error {
    var db = slf.build()

    if err := db.Create(&records).Error; err != nil {
        return fmt.Errorf("create batch err: %v, records: %+v", err, records)
    }

    return nil
}

func (slf *OrderSearch) Updates(record *Order) error {
    var db = slf.build()


 nsq/msg_handler.go

@@ -82,31 +82,22 @@
            var err error
            if oldWorkOrder != nil && oldWorkOrder.WorkOrderID != "" {
                if err = model.NewOrderSearch(db).SetId(oldWorkOrder.ID).Updates(&orderRecord); err != nil {
                    logx.Errorf(" save task message error err1: %v", err)
                    return err
                }
                logx.Errorf(" save task message error no err1: %v", err)
                for _, procedure := range procedureRecords {
                    err = model.NewProceduresSearch(db).SetWorkOrderId(procedure.WorkOrderID).SetProcedureId(procedure.ProcedureID).Upsert(procedure)
                    if err != nil {
                        logx.Errorf(" save task message error err2: %v", err)
                        return err
                    }
                }
                logx.Errorf(" save task message error no err2: %v", err)
            } else {
                if err = model.NewOrderSearch(db).Create(&orderRecord); err != nil {
                    logx.Errorf(" save task message error err3: %v", err)
                    return err
                }
                logx.Errorf(" save task message error no err3: %v", err)
                if err = model.NewProceduresSearch(db).CreateBatch(procedureRecords); err != nil {
                    logx.Errorf(" save task message error err4: %v", err)
                    return err
                }
                logx.Errorf(" save task message error no err4: %v", err)
            }
            logx.Errorf(" save task message error no err5: %v", err)
            return nil
        })
        if err != nil {