Skip to content
This repository has been archived by the owner on Aug 15, 2024. It is now read-only.

Commit

Permalink
updated code
Browse files Browse the repository at this point in the history
  • Loading branch information
@praveenrach
praveenrach committed Feb 23, 2023
1 parent 00da813 commit 4a452ab
Showing 1 changed file with 195 additions and 36 deletions.
231 changes: 195 additions & 36 deletions infrastructure/logic-app/rota/hmi-la-rota-session-publisher.json
View file
Original file line number Diff line number Diff line change
Expand Up @@ -563,12 +563,12 @@
"frequency": "Minute",
"interval": 5
},
"type": "Recurrence",
"runtimeConfiguration": {
"concurrency": {
"runs": 1
}
},
"type": "Recurrence"
}
}
},
"actions": {
Expand Down Expand Up @@ -624,56 +624,96 @@
"For_each_schedule_in_session": {
"foreach": "@body('Get_all_schedules_for_session')?['value']",
"actions": {
"Append_to_array_variable_johDataArray": {
"Append_to_array_variable": {
"runAfter": {
"Insert_or_Merge_Entity_CLP": [
"Set_variable_jsonJohs": [
"Succeeded"
]
},
"type": "AppendToArrayVariable",
"inputs": {
"name": "johDataArray",
"name": "testPrepareJohs",
"value": "@variables('jsonJohs')"
}
},
"Get_joh_for_schedule": {
"runAfter": {},
"type": "ApiConnection",
"Append_to_string_variable_2": {
"runAfter": {
"Append_to_array_variable": [
"Succeeded"
]
},
"type": "AppendToStringVariable",
"inputs": {
"host": {
"connection": {
"name": "@parameters('$connections')[concat('azuretables-',rand(1,15))]['connectionId']"
}
},
"method": "get",
"path": "/Tables/@{encodeURIComponent('joh')}/entities(PartitionKey='@{encodeURIComponent(items('For_each_schedule_in_session')?['justice'])}',RowKey='@{encodeURIComponent(items('For_each_schedule_in_session')?['justice'])}')"
"name": "testJOHString",
"value": "@variables('jsonJohs')"
}
},
"Insert_or_Merge_Entity_CLP": {
"Condition": {
"actions": {
"Insert_or_Merge_Entity_CLP": {
"runAfter": {},
"type": "ApiConnection",
"inputs": {
"body": {
"business": "@{items('For_each_Session')?['business']}",
"joh": "@{replace(variables('testJOHString'), '}{', '} , {')}",
"locationId": "@{items('For_each_Session')?['locationId']}",
"panel": "@{items('For_each_Session')?['panel']}",
"session": "@{items('For_each_Session')?['session']}",
"sessionDate": "@{items('For_each_Session')?['sessionDate']}",
"venueId": "@{items('For_each_Session')?['venueId']}",
"welshSpeaking": "@{items('For_each_Session')?['welshSpeaking']}"
},
"host": {
"connection": {
"name": "@parameters('$connections')['azuretables-1']['connectionId']"
}
},
"method": "patch",
"path": "/Tables/@{encodeURIComponent('CLP')}/entities(PartitionKey='@{encodeURIComponent(items('For_each_session')?['PartitionKey'])}',RowKey='@{encodeURIComponent(items('For_each_session')?['RowKey'])}')"
}
}
},
"runAfter": {
"Set_variable_jsonJohs": [
"Append_to_string_variable_2": [
"Succeeded"
]
},
"expression": {
"and": [
{
"equals": [
"@variables('limit')",
"@length(body('Get_all_schedules_for_session')?['value'])"
]
}
]
},
"type": "If"
},
"Get_joh_for_schedule": {
"runAfter": {
"Increment_variable": [
"Succeeded"
]
},
"type": "ApiConnection",
"inputs": {
"body": {
"business": "@{items('For_each_Session')?['business']}",
"joh": "@{items('For_each_Session')?['joh']}@{variables('jsonJohs')}",
"locationId": "@{items('For_each_Session')?['locationId']}",
"panel": "@{items('For_each_Session')?['panel']}",
"session": "@{items('For_each_Session')?['session']}",
"sessionDate": "@{items('For_each_Session')?['sessionDate']}",
"venueId": "@{items('For_each_Session')?['venueId']}",
"welshSpeaking": "@{items('For_each_Session')?['welshSpeaking']}"
},
"host": {
"connection": {
"name": "@parameters('$connections')[concat('azuretables-',rand(1,15))]['connectionId']"
"name": "@parameters('$connections')['azuretables-1']['connectionId']"
}
},
"method": "patch",
"path": "/Tables/@{encodeURIComponent('CLP')}/entities(PartitionKey='@{encodeURIComponent(items('For_each_session')?['PartitionKey'])}',RowKey='@{encodeURIComponent(items('For_each_session')?['RowKey'])}')"
"method": "get",
"path": "/Tables/@{encodeURIComponent('joh')}/entities(PartitionKey='@{encodeURIComponent(items('For_each_schedule_in_session')?['justice'])}',RowKey='@{encodeURIComponent(items('For_each_schedule_in_session')?['justice'])}')"
}
},
"Increment_variable": {
"runAfter": {},
"type": "IncrementVariable",
"inputs": {
"name": "limit",
"value": 1
}
},
"Set_variable_jsonJohs": {
Expand All @@ -685,7 +725,7 @@
"type": "SetVariable",
"inputs": {
"name": "jsonJohs",
"value": "{\n \"isPresiding\": @{tolower(string(equals(items('For_each_schedule_in_session')?['slot'], 'CHAIR')))},\n \"johId\": \"@{body('Get_joh_for_schedule')?['emailAddress']}\",\n \"slot\": \"@{items('For_each_schedule_in_session')?['slot']}\"\n}"
"value": "{\"isPresiding\": @{tolower(string(equals(items('For_each_schedule_in_session')?['slot'], 'CHAIR')))},\"johId\": \"@{body('Get_joh_for_schedule')?['emailAddress']}\",\"slot\": \"@{items('For_each_schedule_in_session')?['slot']}\"}"
}
},
"Set_variable_scheduleErrorBody": {
Expand All @@ -702,7 +742,7 @@
}
},
"runAfter": {
"Get_all_schedules_for_session": [
"Set_variable_schedules_limit": [
"Succeeded"
]
},
Expand Down Expand Up @@ -881,6 +921,42 @@
"value": "{}"
}
},
"Set_variable_schedules_limit": {
"runAfter": {
"Set_variable_test_joh_string": [
"Succeeded"
]
},
"type": "SetVariable",
"inputs": {
"name": "limit",
"value": 0
}
},
"Set_variable_test_joh_string": {
"runAfter": {
"Set_variable_test_prepare_johs": [
"Succeeded"
]
},
"type": "SetVariable",
"inputs": {
"name": "testJOHString",
"value": " "
}
},
"Set_variable_test_prepare_johs": {
"runAfter": {
"Get_all_schedules_for_session": [
"Succeeded"
]
},
"type": "SetVariable",
"inputs": {
"name": "testPrepareJohs",
"value": []
}
},
"Update_session_status_complete": {
"runAfter": {
"Insert_or_Merge_Entity_with_errorMsg": [
Expand Down Expand Up @@ -919,11 +995,16 @@
}
},
"runAfter": {
"Get_entities_with_status_ready": [
"Set_variable_limit1": [
"Succeeded"
]
},
"type": "Foreach"
"type": "Foreach",
"runtimeConfiguration": {
"concurrency": {
"repetitions": 1
}
}
},
"Get_entities_CLP_failed": {
"runAfter": {
Expand Down Expand Up @@ -1113,7 +1194,7 @@
},
"Initialize_jsonJohs": {
"runAfter": {
"Initialize_scheduleErrorBody": [
"Initialize_judgeDataArray": [
"Succeeded"
]
},
Expand All @@ -1127,8 +1208,28 @@
]
}
},
"Initialize_judgeDataArray": {
"runAfter": {
"Initialize_scheduleErrorBody": [
"Succeeded"
]
},
"type": "InitializeVariable",
"inputs": {
"variables": [
{
"name": "judgeArray",
"type": "array"
}
]
}
},
"Initialize_scheduleErrorBody": {
"runAfter": {},
"runAfter": {
"Initialize_variable": [
"Succeeded"
]
},
"type": "InitializeVariable",
"inputs": {
"variables": [
Expand Down Expand Up @@ -1170,6 +1271,64 @@
}
]
}
},
"Initialize_variable": {
"runAfter": {
"Initialize_variable_testPrepareJohs": [
"Succeeded"
]
},
"type": "InitializeVariable",
"inputs": {
"variables": [
{
"name": "testJOHString",
"type": "string"
}
]
}
},
"Initialize_variable_schedules_limit": {
"runAfter": {},
"type": "InitializeVariable",
"inputs": {
"variables": [
{
"name": "limit",
"type": "integer",
"value": 0
}
]
}
},
"Initialize_variable_testPrepareJohs": {
"runAfter": {
"Initialize_variable_schedules_limit": [
"Succeeded"
]
},
"type": "InitializeVariable",
"inputs": {
"variables": [
{
"name": "testPrepareJohs",
"type": "array",
"value": []
}
]
}
},
"Set_variable_limit1": {
"runAfter": {
"Get_entities_with_status_ready": [
"Succeeded"
]
},
"type": "SetVariable",
"inputs": {
"name": "limit",
"value": 0
}
}
},
"outputs": {}
Expand Down

0 comments on commit 4a452ab

Please sign in to comment.