slpa: consolidate the containers, then issue a gate pass for each

tnsw/manifest.json

@@ -3035,6 +3035,186 @@
       "kind": "generic_template",
       "version": "",
       "path": "slpa/4-invoice_payment/paid_message_jsonform.json"
+    },
+    {
+      "id": "slpa-consolidation--done-message",
+      "kind": "generic_template",
+      "version": "",
+      "path": "slpa/5-container_consolidation/done_message_jsonform.json"
+    },
+    {
+      "id": "slpa-consolidation--fetch",
+      "kind": "subtask_template",
+      "version": "",
+      "path": "slpa/5-container_consolidation/fetch.json"
+    },
+    {
+      "id": "slpa-consolidation--problem",
+      "kind": "generic_template",
+      "version": "",
+      "path": "slpa/5-container_consolidation/problem_message_jsonform.json"
+    },
+    {
+      "id": "slpa-consolidation-flow:render",
+      "kind": "generic_template",
+      "version": "",
+      "path": "slpa/5-container_consolidation/render.json"
+    },
+    {
+      "id": "slpa-consolidation--save",
+      "kind": "subtask_template",
+      "version": "",
+      "path": "slpa/5-container_consolidation/save.json"
+    },
+    {
+      "id": "slpa-consolidation--status-message",
+      "kind": "generic_template",
+      "version": "",
+      "path": "slpa/5-container_consolidation/status_message_jsonform.json"
+    },
+    {
+      "id": "slpa-consolidation-flow",
+      "kind": "task_template",
+      "version": "",
+      "path": "slpa/5-container_consolidation/task_template.json"
+    },
+    {
+      "id": "slpa-consolidation-flow",
+      "kind": "workflow",
+      "version": "",
+      "path": "slpa/5-container_consolidation/workflow.json"
+    },
+    {
+      "id": "slpa-gate-pass-branch",
+      "kind": "workflow",
+      "version": "",
+      "path": "slpa/6-gate_pass/branch_workflow.json"
+    },
+    {
+      "id": "slpa-gp--issue",
+      "kind": "subtask_template",
+      "version": "",
+      "path": "slpa/6-gate_pass/issue.json"
+    },
+    {
+      "id": "slpa-gp--issued-message",
+      "kind": "generic_template",
+      "version": "",
+      "path": "slpa/6-gate_pass/issued_message_jsonform.json"
+    },
+    {
+      "id": "slpa-gate-pass-prepare-flow:render",
+      "kind": "generic_template",
+      "version": "",
+      "path": "slpa/6-gate_pass/prepare_render.json"
+    },
+    {
+      "id": "slpa-gate-pass-prepare-flow",
+      "kind": "task_template",
+      "version": "",
+      "path": "slpa/6-gate_pass/prepare_task_template.json"
+    },
+    {
+      "id": "slpa-gate-pass--prepare-transform",
+      "kind": "subtask_template",
+      "version": "",
+      "path": "slpa/6-gate_pass/prepare_transform.json"
+    },
+    {
+      "id": "slpa-gate-pass-prepare-flow",
+      "kind": "workflow",
+      "version": "",
+      "path": "slpa/6-gate_pass/prepare_workflow.json"
+    },
+    {
+      "id": "slpa-gp--refusal",
+      "kind": "generic_template",
+      "version": "",
+      "path": "slpa/6-gate_pass/refusal_jsonform.json"
+    },
+    {
+      "id": "slpa-gate-pass-flow:render",
+      "kind": "generic_template",
+      "version": "",
+      "path": "slpa/6-gate_pass/render.json"
+    },
+    {
+      "id": "slpa-gate-pass-flow",
+      "kind": "task_template",
+      "version": "",
+      "path": "slpa/6-gate_pass/task_template.json"
+    },
+    {
+      "id": "slpa-gp--user-input",
+      "kind": "subtask_template",
+      "version": "",
+      "path": "slpa/6-gate_pass/userinput.json"
+    },
+    {
+      "id": "slpa-gp--user-form",
+      "kind": "generic_template",
+      "version": "",
+      "path": "slpa/6-gate_pass/userinput_jsonform.json"
+    },
+    {
+      "id": "slpa-gate-pass-flow",
+      "kind": "workflow",
+      "version": "",
+      "path": "slpa/6-gate_pass/workflow.json"
+    },
+    {
+      "id": "slpa-consolidation--select",
+      "kind": "subtask_template",
+      "version": "",
+      "path": "slpa/5-container_consolidation/select.json"
+    },
+    {
+      "id": "slpa-consolidation--select-form",
+      "kind": "generic_template",
+      "version": "",
+      "path": "slpa/5-container_consolidation/select_form_jsonform.json"
+    },
+    {
+      "id": "slpa-consolidation--delete",
+      "kind": "subtask_template",
+      "version": "",
+      "path": "slpa/5-container_consolidation/delete.json"
+    },
+    {
+      "id": "slpa-container-branch",
+      "kind": "workflow",
+      "version": "",
+      "path": "slpa/5-container_consolidation/branch_workflow.json"
+    },
+    {
+      "id": "slpa-container-prepare-flow",
+      "kind": "task_template",
+      "version": "",
+      "path": "slpa/5-container_consolidation/prepare_task_template.json"
+    },
+    {
+      "id": "slpa-container-prepare-flow",
+      "kind": "workflow",
+      "version": "",
+      "path": "slpa/5-container_consolidation/prepare_workflow.json"
+    },
+    {
+      "id": "slpa-container--prepare-transform",
+      "kind": "subtask_template",
+      "version": "",
+      "path": "slpa/5-container_consolidation/prepare_transform.json"
+    },
+    {
+      "id": "slpa-container-prepare-flow:render",
+      "kind": "generic_template",
+      "version": "",
+      "path": "slpa/5-container_consolidation/prepare_render.json"
+    },
+    {
+      "id": "slpa-consolidation--resolve",
+      "kind": "subtask_template",
+      "version": "",
+      "path": "slpa/5-container_consolidation/resolve.json"
     }
   ]
 }

tnsw/slpa/5-container_consolidation/branch_workflow.json

@@ -0,0 +1,89 @@
+{
+  "id": "slpa-container-branch",
+  "name": "Consolidate and Gate Pass (one container)",
+  "version": 1,
+  "nodes": [
+    {
+      "id": "start",
+      "type": "START"
+    },
+    {
+      "id": "consolidate",
+      "type": "TASK",
+      "name": "[SLPA 5.0] Container Consolidation",
+      "task_template_id": "slpa-consolidation-flow",
+      "lane": "Trader/CHA",
+      "input_mapping": {
+        "_iter.input.so_container_no?": "so_container_no",
+        "_iter.input.container_label?": "container_label",
+        "_iter.input.cusdec_serial?": "cusdec_serial",
+        "_iter.input.slug?": "slug",
+        "_iter.input.client_key?": "client_key",
+        "_iter.input.cap_container_no?": "cap_container_no"
+      },
+      "output_mapping": {
+        "consolidation.saved?": "cc.saved",
+        "cap_sqid?": "cc.cap_id",
+        "container_no?": "cc.container_no"
+      }
+    },
+    {
+      "id": "gate_pass",
+      "type": "TASK",
+      "name": "[SLPA 6.0] Container Gate Pass",
+      "task_template_id": "slpa-gate-pass-flow",
+      "lane": "Trader/CHA",
+      "input_mapping": {
+        "_iter.input.container_label?": "container_label",
+        "_iter.input.slug?": "slug",
+        "_iter.input.client_key?": "client_key",
+        "cc.cap_id?": "cap_id",
+        "cc.container_no?": "container_no"
+      },
+      "output_mapping": {
+        "gp.gate_pass_no?": "gate_pass_no",
+        "gp.barcode?": "barcode",
+        "gp.issued_at?": "issued_at",
+        "consolidation.deleted?": "deleted",
+        "gp.gate_pass_url?": "gate_pass_url"
+      }
+    },
+    {
+      "id": "gate_pass_check",
+      "type": "GATEWAY",
+      "gateway_type": "EXCLUSIVE_SPLIT"
+    },
+    {
+      "id": "end",
+      "type": "END"
+    }
+  ],
+  "edges": [
+    {
+      "id": "e_start",
+      "source_id": "start",
+      "target_id": "consolidate"
+    },
+    {
+      "id": "e_consolidated",
+      "source_id": "consolidate",
+      "target_id": "gate_pass"
+    },
+    {
+      "id": "e_gp_gw",
+      "source_id": "gate_pass",
+      "target_id": "gate_pass_check"
+    },
+    {
+      "id": "e_redo",
+      "source_id": "gate_pass_check",
+      "target_id": "consolidate",
+      "condition": "deleted == true"
+    },
+    {
+      "id": "e_done",
+      "source_id": "gate_pass_check",
+      "target_id": "end"
+    }
+  ]
+}

tnsw/slpa/5-container_consolidation/delete.json

@@ -0,0 +1,11 @@
+{
+  "id": "slpa-consolidation--delete",
+  "task_type": "SLPA_CONSOLIDATION_DELETE",
+  "output_namespace": "consolidation",
+  "plugin_properties": {
+    "service_id": "slpa",
+    "path": "/api/nsw/v1/export/container-consolidation/{cap_id}",
+    "method": "DELETE",
+    "result_field": "deleted"
+  }
+}

tnsw/slpa/5-container_consolidation/done_message_jsonform.json

@@ -0,0 +1,4 @@
+{
+  "id": "slpa-consolidation--done-message",
+  "template": "### \u2705 Container Consolidated\n\n{{with .consolidation}}{{if .summary}}{{.summary}}\n{{end}}{{if .message}}\n*SLPA: {{.message}}*\n{{end}}{{end}}\nA gate pass can now be issued for this container."
+}

tnsw/slpa/5-container_consolidation/fetch.json

@@ -0,0 +1,11 @@
+{
+  "id": "slpa-consolidation--fetch",
+  "task_type": "SLPA_CONSOLIDATION_FETCH",
+  "output_namespace": "consolidation",
+  "plugin_properties": {
+    "service_id": "slpa",
+    "path": "/api/nsw/v1/export/container-consolidation/fcl",
+    "method": "GET",
+    "result_field": "fetched"
+  }
+}

tnsw/slpa/5-container_consolidation/prepare_render.json

@@ -0,0 +1,6 @@
+{
+  "id": "slpa-container-prepare-flow:render",
+  "type": "SYSTEM",
+  "sections": {},
+  "states": {}
+}

tnsw/slpa/5-container_consolidation/prepare_task_template.json

@@ -0,0 +1,6 @@
+{
+  "id": "slpa-container-prepare-flow",
+  "type": "SYSTEM",
+  "workflow_id": "slpa-container-prepare-flow",
+  "render_config_id": "slpa-container-prepare-flow:render"
+}

tnsw/slpa/5-container_consolidation/prepare_transform.json

@@ -0,0 +1,5 @@
+{
+  "id": "slpa-container--prepare-transform",
+  "task_type": "SLPA_CONTAINER_SPLIT_BUILDER",
+  "plugin_properties": {}
+}

tnsw/slpa/5-container_consolidation/prepare_workflow.json

@@ -0,0 +1,41 @@
+{
+  "id": "slpa-container-prepare-flow",
+  "name": "Prepare SLPA Container Branches",
+  "version": 1,
+  "nodes": [
+    {
+      "id": "start",
+      "type": "START"
+    },
+    {
+      "id": "build_split_items",
+      "type": "TASK",
+      "task_template_id": "slpa-container--prepare-transform",
+      "input_mapping": {
+        "containers?": "containers",
+        "cusdec_serial?": "cusdec_serial",
+        "slug?": "slug",
+        "client_key?": "client_key"
+      },
+      "output_mapping": {
+        "split_items": "split_items"
+      }
+    },
+    {
+      "id": "end",
+      "type": "END"
+    }
+  ],
+  "edges": [
+    {
+      "id": "e1",
+      "source_id": "start",
+      "target_id": "build_split_items"
+    },
+    {
+      "id": "e2",
+      "source_id": "build_split_items",
+      "target_id": "end"
+    }
+  ]
+}

tnsw/slpa/5-container_consolidation/problem_message_jsonform.json

@@ -0,0 +1,4 @@
+{
+  "id": "slpa-consolidation--problem",
+  "template": "{{if .error}}### \u26a0\ufe0f Nothing To Consolidate Yet\n\n{{.error}}\n{{end}}{{if and .summary (not .error)}}### \ud83d\udce6 Containers SLPA Is Holding\n\n{{.summary}}\n\nThe real container numbers and the service order numbers are different by design: SLPA prices the order against placeholder containers, and consolidation is what ties each real container to one of them. This step is for one of them: pick the real container the service order container shown below turns out to be, then submit.\n{{end}}"
+}