Workflow Manager Plugin

9min
This plugin will read the current event data from the config files, and then it will decide which job workflow to be used and what is the input data for that workflow.
Use case
The plugin helps in deciding what job workflow and input data to use for which work order.
Input
Input for this plugin is totally configurable and depends on what the configuration file needs in its logic.

Input required for current configuration file - 
paymentType
amount
Output
Job workflow id
Job workflow input
customData
Logic 
This plugin uses a configuration file to give output. The configuration file is an array of configs and a single configuration has the following structure - 
Logic - JSON logic, if true, should return the output.
Output - Consists of a combination of actual value and a JSON path pointing to a value in the input.
Current Configuration
Rule
Create a new job
Create a new job
{
	"name": "Create a new job",
	"event": "WorkOrderCreatedEvent",
	"pluginWorkflowId": "plugin-workflow:da9eb6dc-ee81-51e5-aed1-100244711ba6",
	"serviceName": "orchestrator"
}
{
	"name": "Create a new job",
	"event": "WorkOrderCreatedEvent",
	"pluginWorkflowId": "plugin-workflow:da9eb6dc-ee81-51e5-aed1-100244711ba6",
	"serviceName": "orchestrator"
}
﻿
Create a job after the previous one fails.
Create a job after the previous one fails
{
    "name": "Complete Job Failure",
    "event": "CompleteJobEvent",
    "pluginWorkflowId": "plugin-workflow:da9eb6dc-ee81-51e5-aed1-100244711ba6",
    "serviceName": "orchestrator",
    "logic": {
        "!=": [
            "$.reason",
            "R-0065"
        ]
    }
}
{
    "name": "Complete Job Failure",
    "event": "CompleteJobEvent",
    "pluginWorkflowId": "plugin-workflow:da9eb6dc-ee81-51e5-aed1-100244711ba6",
    "serviceName": "orchestrator",
    "logic": {
        "!=": [
            "$.reason",
            "R-0065"
        ]
    }
}
﻿
Plugin Workflow
Create a new job
Create a new job
{
	"name": "CreateJobWfV10",
	"description": "workflow for order creation",
	"tag": [{
		"name": "workOrderCreated",
		"value": "workflow"
	}],
	"pre": {
		"plugins": [
			"fetchData"
		]
	},
	"main": {
		"plugins": [
			"workflowManagerPluginV4"
			"jobManagerPluginV10"
		]
	}
}
{
	"name": "CreateJobWfV10",
	"description": "workflow for order creation",
	"tag": [{
		"name": "workOrderCreated",
		"value": "workflow"
	}],
	"pre": {
		"plugins": [
			"fetchData"
		]
	},
	"main": {
		"plugins": [
			"workflowManagerPluginV4"
			"jobManagerPluginV10"
		]
	}
}
﻿
Create a job after the previous one fails.
Create a job after the previous one fails
{
    "name": "JobFailureWorkflow",
    "description": "workflow for job failure",
    "pre": {
        "plugins": [
            "fetchData"
        ]
    },
    "main": {
        "plugins": [
            "jobManagerPluginV10"
        ]
    }
}
{
    "name": "JobFailureWorkflow",
    "description": "workflow for job failure",
    "pre": {
        "plugins": [
            "fetchData"
        ]
    },
    "main": {
        "plugins": [
            "jobManagerPluginV10"
        ]
    }
}
﻿
Plugin
JSON
{
    "name": "workflowManagerPluginV4",
    "httpUrl": "https://delhivery.preprod.fxtrt.io/core/api/v1/workflowManager/",
    "httpMethod": "POST",
    "httpHeaders": {
        "plugin": "workflowManager"
    },
    "httpRequestBodyTemplate": [
        {
            "outputJsonPath": {
                "tenantId": "$.tenantId",
                "pickupLocation": "$.workOrders[0].pickupDetails.location",
                "deliverLocation": "$.dropDetails.location",
                "pickupContact": "$.workOrders[0].pickupDetails.contact",
                "deliverContact": "$.dropDetails.contact",
                "containers": "$.workOrders[0].containers",
                "clientDetails": "$.clientDetails",
                "orderSummary": "$.orderSummary",
                "attributes": "$.workOrders[0].attributes"
            }
        },
        {
            "entity": "location",
            "input": {
                "tenant_id": "$.tenantId",
                "location_id": "$.dropDetails.location"
            },
            "outputJsonPath": {
                "geolocation": "$.geolocation"
            }
        }
    ],
    "dlqOnFailure": true,
    "requestTimeout": 5,
    "callbackTimeout": 5,
    "responseType": "ASYNC",
    "secretKey": "SECRET_KEY",
    "protocol": "HTTP"
}
{
    "name": "workflowManagerPluginV4",
    "httpUrl": "https://delhivery.preprod.fxtrt.io/core/api/v1/workflowManager/",
    "httpMethod": "POST",
    "httpHeaders": {
        "plugin": "workflowManager"
    },
    "httpRequestBodyTemplate": [
        {
            "outputJsonPath": {
                "tenantId": "$.tenantId",
                "pickupLocation": "$.workOrders[0].pickupDetails.location",
                "deliverLocation": "$.dropDetails.location",
                "pickupContact": "$.workOrders[0].pickupDetails.contact",
                "deliverContact": "$.dropDetails.contact",
                "containers": "$.workOrders[0].containers",
                "clientDetails": "$.clientDetails",
                "orderSummary": "$.orderSummary",
                "attributes": "$.workOrders[0].attributes"
            }
        },
        {
            "entity": "location",
            "input": {
                "tenant_id": "$.tenantId",
                "location_id": "$.dropDetails.location"
            },
            "outputJsonPath": {
                "geolocation": "$.geolocation"
            }
        }
    ],
    "dlqOnFailure": true,
    "requestTimeout": 5,
    "callbackTimeout": 5,
    "responseType": "ASYNC",
    "secretKey": "SECRET_KEY",
    "protocol": "HTTP"
}
﻿
Try Workflow Manager Plugin API.
Updated 03 Aug 2023
Did this page help you?
Work Order Manager Plugin
Cancellation Manager Plugin