| | |
| | | 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 { |
| | |
| | | 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 { |