| | |
| | | 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 |
| | | } |
| | | 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 |
| | | } |
| | | } |
| | | } else { |
| | | if err = model.NewOrderSearch(db).Create(&orderRecord); err != nil { |
| | | logx.Errorf(" save task message error err3: %v", err) |
| | | return err |
| | | } |
| | | return model.NewProceduresSearch(db).CreateBatch(procedureRecords) |
| | | if err = model.NewProceduresSearch(db).CreateBatch(procedureRecords); err != nil { |
| | | logx.Errorf(" save task message error err4: %v", err) |
| | | return err |
| | | } |
| | | } |
| | | return nil |
| | | }) |