From 99d1f4d287052d521b4cbb7e2e34464109d791ae Mon Sep 17 00:00:00 2001 From: albert Date: Thu, 3 Oct 2024 00:55:09 +0200 Subject: [PATCH] wip --- sap/app/app.go | 18 +++++++++++++++++- 1 file changed, 17 insertions(+), 1 deletion(-) 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 }