diff --git a/sap/app/app.go b/sap/app/app.go index cbc0897..479c23d 100644 --- a/sap/app/app.go +++ b/sap/app/app.go @@ -109,7 +109,23 @@ func Run(cmd *cobra.Command, args []string) { log.Error("store production order data failed", err, logFields) continue } - case "sap.in.telegramas.z_sms-10002": + case "sap.in.telegramas.z_sms_10002": + co := &types.CustomerOrder{} + if err := json.Unmarshal(buffer.Bytes(), co); err != nil { + log.Error("decode event message data failed", err, logFields) + continue + } + // log info banner + log.Info("received new production data from SAP event", logFields.Add( + logger.LogFields{ + "event_id": event.EventID, + "customer_order": co.COrderNo, + "production_order": co.POrderNo, + })) + if err := storage.StoreCustomerOrder(ctx, co); err != nil { + log.Error("store customer order data failed", err, logFields) + continue + } default: continue }