(eid, messageID int64, requestID string, step ProcessStep)
| 48 | } |
| 49 | |
| 50 | func saveProcessStepRecord(eid, messageID int64, requestID string, step ProcessStep) error { |
| 51 | record := &model.MessageProcessStep{ |
| 52 | Eid: eid, |
| 53 | MessageID: messageID, |
| 54 | RequestID: requestID, |
| 55 | StepCode: step.StepCode, |
| 56 | Name: step.Name, |
| 57 | Status: step.Status, |
| 58 | Message: step.Message, |
| 59 | StepTimestamp: step.Timestamp, |
| 60 | } |
| 61 | if err := record.SetDataMap(step.Data); err != nil { |
| 62 | return err |
| 63 | } |
| 64 | return messageProcessStepSaver(record) |
| 65 | } |
| 66 | |
| 67 | func recordProcessStepForHistory(ctx context.Context, eid int64, messageStatus *MessageStatsInfo, requestID string, step ProcessStep) { |
| 68 | if messageStatus == nil || eid <= 0 { |
no test coverage detected