Switch to Process Orders API

Author: martinjlowm

META-INF/MANIFEST.MF

@@ -2,7 +2,7 @@ Manifest-Version: 1.0
 Bundle-ManifestVersion: 2
 Bundle-Name: Synchronize Production Plan
 Bundle-SymbolicName: Synchronize_Production_Plan; singleton:=true
-Bundle-Version: 1.0.0
+Bundle-Version: 1.0.1
 SAP-BundleType: RESTAPIProvider
 SAP-NodeType: IFLMAP
 SAP-RuntimeProfile: iflmap
@@ -34,4 +34,3 @@ Import-Package: com.sap.esb.application.services.cxf.interceptor,com.sap
  "
 Origin-Bundle-Name: Synchronize Production Plan
 Origin-Bundle-SymbolicName: Synchronize_Production_Plan
-

README.md

@@ -9,6 +9,10 @@ interface SAP to Factbird.
 
 ## Use cases
 
-Import products
+Common use cases include:
 
-Import Production orders
+- Import products into Factbird
+
+- Import process orders into Factbird
+
+- Manage process order execution from within Factbird (executing and terminating of a process order) ()

metainfo.prop

@@ -1,3 +1,3 @@
 #Store metainfo properties
-#Thu Mar 27 23:54:29 UTC 2025
+#Sun Mar 30 21:58:52 UTC 2025
 description=

src/main/resources/parameters.prop

@@ -1 +1 @@
-#Thu Mar 27 23:48:11 UTC 2025
+#Sun Mar 30 21:58:24 UTC 2025

src/main/resources/scenarioflows/integrationflow/createProduct.iflw

@@ -1,12 +1,12 @@
 import com.sap.gateway.ip.core.customdev.util.Message;
-import java.util.HashMap;
-import groovy.json.*;
+import groovy.json.JsonSlurper;
 
 def Message processData(Message message) {
     def body = message.getBody(String.class);    
     def jsonSlurper = new JsonSlurper();
     def payload = jsonSlurper.parseText(body);
 
     message.setProperty("manufacturingOrder", payload.data.ManufacturingOrder);
+    
     return message;
 }

src/main/resources/script/script1.groovy

@@ -30,34 +30,24 @@ def zipTimestampsIntoMillis(NodeChildren startDates, NodeChildren startTimes) {
 // https://api.cloud.factbird.com/v1/docs/#query-lines or a looped process call
 // against https://api.cloud.factbird.com/v1/docs/#query-linesPaginated (we have
 // not yet stabilized this latter one as of this writing)
-def lineIdMapping = [
-    '1710': 'aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee'
+lineIdMapping = [
+    '1710PACKING': 'aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee'
 ]
 
 def Message processData(Message message) {
-    def productionOrder = new XmlSlurper().parseText(message.getProperty("productionOrder"))
-    def productionOrderSerialNumber = new XmlSlurper().parseText(message.getProperty("productionOrderSerialNumber"))
+    def processOrder = new XmlSlurper().parseText(message.getProperty("processOrder"))
 
     def messageLog = messageLogFactory.getMessageLog(message);
     if (messageLog != null) {
-        messageLog.addAttachmentAsString("productionOrder", message.getProperty("productionOrder"), "application/json");
-        messageLog.addAttachmentAsString("productionOrderSerialNumber", message.getProperty("productionOrderSerialNumber"), "application/json");
+        messageLog.addAttachmentAsString("processOrder", message.getProperty("processOrder"), "application/json");
     }
 
     def builder = new JsonBuilder()
 
     def output = []
 
-    productionOrder.A_ProductionOrder_2Type.each { order ->
-        def serialNumber = productionOrderSerialNumber.children().find { type ->
-            type.ManufacturingOrder.text() == order.ManufacturingOrder.text()
-        }
-
-        if (!serialNumber) {
-            return
-        }
-
-        def released = order.to_ProductionOrderStatus.children().any { status ->
+    processOrder.A_ProcessOrder_2Type.each { order ->
+        def released = order.to_ProcessOrderStatus.children().any { status ->
             status.StatusShortName.text() == "SETC"
             //status.StatusShortName.text() == "REL"
         }
@@ -66,11 +56,11 @@ def Message processData(Message message) {
             return
         }
 
-        def operation = order.to_ProductionOrderOperation.A_ProductionOrderOperation_2Type
-        
-        // Production Orders may propagate from one work center to another - we
+        def operation = order.to_ProcessOrderOperation.A_ProcessOrderOperation_2Type
+
+        // Process Orders may propagate from one work center to another - we
         // simply make the assumption it'll remain at the same location.
-        def initiallyAllocatedWorkCenter = order.WorkCenter[0]
+        def initiallyAllocatedWorkCenter = operation.WorkCenter[0]
 
         // With that same assumption, all operations are expected to take place
         // in order, so for actualStart and actualStop we find the extrema
@@ -86,7 +76,7 @@ def Message processData(Message message) {
         output << [
             externalLineId: order.Plant.text() + initiallyAllocatedWorkCenter.text(),
             batchNumber: order.ManufacturingOrder.text(),
-            itemNumber: serialNumber.Product.text(),
+            itemNumber: order.Material.text(),
             amount: order.TotalQuantity.text(),
             plannedStart: formatTimePair(order.MfgOrderPlannedStartDate.text(), order.MfgOrderPlannedStartTime.text()),
             actualStart: actualStart,
@@ -97,7 +87,7 @@ def Message processData(Message message) {
     def resultXml = new StringWriter()
     def xmlBuilder = new MarkupBuilder(resultXml)
 
-    xmlBuilder.'production-orders' {
+    xmlBuilder.'process-orders' {
         output.each { row ->
             'order'(action: row.actualStop ? 'stop' : (row.actualStart ? 'start' : 'create')) {
                 'line-id'(lineIdMapping[row.externalLineId])
@@ -112,6 +102,6 @@ def Message processData(Message message) {
     }
 
     message.setBody(resultXml.toString())
-    
+
     return message;
 }

src/main/resources/script/script3.groovy

@@ -14,16 +14,16 @@ def Message processData(Message message) {
         operationName: 'CreateBatchByItemNumber',
         variables: [
             input: [
-                lineId: 'test',
+                lineId: orders.order.'line-id'.text(),
+                batchNumber: orders.order.'batch-number'.text(),
                 itemNumber: orders.order.'item-number'.text(),
                 amount: Float.parseFloat(orders.order.'amount'.text()),
-                plannedStart: orders.order.plannedStart.text(),
+                plannedStart: orders.order.'planned-start'.text(),
             ]
         ],
         query: 'mutation CreateBatchByItemNumber($input: CreateBatchByItemNumberInput!) { createBatchByItemNumber(input: $input) { __typename } }',
     ])
 
-    // Set the generated JSON as the message body
     message.setBody(builder.toPrettyString())
 
     return message;

src/main/resources/script/script4.groovy

@@ -14,7 +14,7 @@ def Message processData(Message message) {
         operationName: 'StartBatchByBatchNumber',
         variables: [
             input: [
-                lineId: 'test',
+                lineId: orders.order.'line-id'.text(),
                 batchNumber: orders.order.'production-order'.text(),
                 actualStart: orders.order.'actual-start'.text(),
                 forceStop: true

src/main/resources/script/script5.groovy

@@ -14,7 +14,7 @@ def Message processData(Message message) {
         operationName: 'StopBatchByBatchNumber',
         variables: [
             input: [
-                lineId: 'test',
+                lineId: orders.order.'line-id'.text(),
                 batchNumber: orders.order.'production-order'.text(),
                 actualStop: orders.order.'actual-stop'.text(),
             ]