wip

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
 			}