[MINT-2720] Data Exchange Approach

MINT.postman_collection.json

@@ -24,6 +24,7 @@
 									"opsEvalAndLearningID = responseData.opsEvalAndLearning.id",
 									"modelLeadID = responseData.collaborators[0].id",
 									"paymentsID = responseData.payments.id",
+									"dataExchangeApproachID = responseData.dataExchangeApproach.id",
 									"firstOpNeed = responseData.operationalNeeds[0].id",
 									"userID = responseData.createdByUserAccount.id",
 									"",
@@ -36,6 +37,7 @@
 									"pm.collectionVariables.set(\"opsEvalAndLearningID\", opsEvalAndLearningID);",
 									"pm.collectionVariables.set(\"modelLeadID\", modelLeadID);",
 									"pm.collectionVariables.set(\"paymentsID\", paymentsID);",
+									"pm.collectionVariables.set(\"dataExchangeApproachID\", dataExchangeApproachID)",
 									"pm.collectionVariables.set(\"operationalNeedID\", firstOpNeed);",
 									"pm.collectionVariables.set(\"userID\", userID);"
 								],
@@ -50,7 +52,7 @@
 						"body": {
 							"mode": "graphql",
 							"graphql": {
-								"query": "mutation createModelPlan{\n  \n  createModelPlan(modelName:\"Excellent Model\" ){\n    id\n    modelName\n    createdByUserAccount{\n        givenName\n        id\n    }\n    operationalNeeds {\n        id\n        modelPlanID\n        name\n        key\n        nameOther\n        needed\n        section    \n    }  \n    basics{\n        id        \n    }\n    generalCharacteristics {\n        id\n    }\n    participantsAndProviders {\n        id\n    }\n    beneficiaries {\n        id\n    }\n    opsEvalAndLearning {\n        id\n    }\n    collaborators {\n      id\n    }\n    payments{\n        id\n    }\n  }\n}\n  ",
+								"query": "mutation createModelPlan{\n  \n  createModelPlan(modelName:\"Excellent Model\" ){\n    id\n    modelName\n    createdByUserAccount{\n        givenName\n        id\n    }\n    operationalNeeds {\n        id\n        modelPlanID\n        name\n        key\n        nameOther\n        needed\n        section    \n    }  \n    basics{\n        id        \n    }\n    generalCharacteristics {\n        id\n    }\n    participantsAndProviders {\n        id\n    }\n    beneficiaries {\n        id\n    }\n    opsEvalAndLearning {\n        id\n    }\n    collaborators {\n      id\n    }\n    payments{\n        id\n    }\n    dataExchangeApproach{\n        id\n    }\n  }\n}\n  ",
 								"variables": ""
 							}
 						},
@@ -411,6 +413,27 @@
 					},
 					"response": []
 				},
+				{
+					"name": "Update Data Exchange Approach",
+					"request": {
+						"method": "POST",
+						"header": [],
+						"body": {
+							"mode": "graphql",
+							"graphql": {
+								"query": "mutation updatePlanDataExchangeApproach {\n  updatePlanDataExchangeApproach(id: \"{{dataExchangeApproachID}}\", changes: {\n    # Page 1\n    dataToCollectFromParticipants: [CLINICAL_DATA, OTHER]\n    dataToCollectFromParticipantsReportsDetails: \"Detailed reports information\"\n    dataToCollectFromParticipantsOther: \"Additional data to collect from participants\"\n    dataWillNotBeCollectedFromParticipants: false\n    dataToCollectFromParticipantsNote: \"Notes regarding data collection from participants\"\n\n    # Page 2\n    dataToSendToParticipants: [DATA_FEEDBACK_DASHBOARD]\n    dataToSendToParticipantsNote: \"Notes about data being sent to participants\"\n\n    # Page 3\n    doesNeedToMakeMultiPayerDataAvailable: YES\n    anticipatedMultiPayerDataAvailabilityUseCase: MORE_COMPETENT_ALERT_DISCHARGE_TRANSFER_NOTIFICATION\n    doesNeedToMakeMultiPayerDataAvailableNote: \"Notes on multi-payer data availability\"\n\n    doesNeedToCollectAndAggregateMultiSourceData: YES\n    multiSourceDataToCollect: [COMMERCIAL_CLAIMS]\n    multiSourceDataToCollectOther: \"Additional multi-source data to collect\"\n    doesNeedToCollectAndAggregateMultiSourceDataNote: \"Notes on multi-source data collection\"\n\n    # Page 4\n    willImplementNewDataExchangeMethods: YES\n    newDataExchangeMethodsDescription: \"Description of new data exchange methods\"\n    newDataExchangeMethodsNote: \"Notes on new data exchange methods\"\n\n    # Meta\n    isDataExchangeApproachComplete: false\n  }) {\n    # Meta Fields\n    id\n    modelPlanID\n    isDataExchangeApproachComplete\n\n    # Page 1\n    dataToCollectFromParticipants\n    dataToCollectFromParticipantsReportsDetails\n    dataToCollectFromParticipantsOther\n    dataWillNotBeCollectedFromParticipants\n    dataToCollectFromParticipantsNote\n\n    # Page 2\n    dataToSendToParticipants\n    dataToSendToParticipantsNote\n\n    # Page 3\n    doesNeedToMakeMultiPayerDataAvailable\n    anticipatedMultiPayerDataAvailabilityUseCase\n    doesNeedToMakeMultiPayerDataAvailableNote\n    doesNeedToCollectAndAggregateMultiSourceData\n    multiSourceDataToCollect\n    multiSourceDataToCollectOther\n    doesNeedToCollectAndAggregateMultiSourceDataNote\n\n    # Page 4\n    willImplementNewDataExchangeMethods\n    newDataExchangeMethodsDescription\n    newDataExchangeMethodsNote\n    additionalDataExchangeConsiderationsDescription\n    isDataExchangeApproachComplete\n\n    # User Accounts\n    createdBy\n    createdDts\n    modifiedBy\n    modifiedDts\n    markedCompleteDts\n    markedCompleteBy\n    markedCompleteByUserAccount {\n        id\n        email\n    }\n\n    createdByUserAccount {\n      commonName\n    }\n    modifiedByUserAccount {\n      commonName\n    }\n    \n    status\n  }\n}\n",
+								"variables": ""
+							}
+						},
+						"url": {
+							"raw": "{{url}}",
+							"host": [
+								"{{url}}"
+							]
+						}
+					},
+					"response": []
+				},
 				{
 					"name": "Get Plan Payments (Deprecated)",
 					"request": {
@@ -650,7 +673,7 @@
 						"body": {
 							"mode": "graphql",
 							"graphql": {
-								"query": "mutation createDiscussionReply {\n    createDiscussionReply (input: {\n        discussionID: \"{{discussionID}}\"\n        content: \"Let me look into it, ok? <span data-type=\\\"mention\\\" tag-type=\\\"USER_ACCOUNT\\\" class=\\\"mention\\\" data-id=\\\"ADMI\\\" data-label=\\\"ADMI\\\">@Audrey Abrams</span>!\"\n        userRole: SOLUTION_ARCHITECT\n    }) {\n        id\n        discussionID\n        content{\n            rawContent\n            tags{\n                id\n                taggedField\n                taggedContentTable\n                taggedContentID\n                entityUUID\n                entityIntID\n                entity{\n                    __typename\n                    ... on UserAccount{\n                        id\n                        commonName\n                        email\n                    }\n                    ... on PossibleOperationalSolution {\n                        name\n                        key\n                    }\n                }\n            }\n        }\n        isAssessment\n        createdBy\n        createdDts\n        modifiedBy\n        modifiedDts\n        createdByUserAccount \n        {\n            commonName\n        }   \n        modifiedByUserAccount\n        {\n            commonName\n        }             \n    }\n}",
+								"query": "mutation createDiscussionReply {\n    createDiscussionReply (input: {\n        discussionID: \"{{discussionID}}\"\n        content: \"Let me look into it, ok? <span data-type=\\\"mention\\\" tag-type=\\\"USER_ACCOUNT\\\" class=\\\"mention\\\" data-id=\\\"ADMI\\\" data-label=\\\"ADMI\\\">@Audrey Abrams</span>!\"\n        userRole: IT_ARCHITECT\n    }) {\n        id\n        discussionID\n        content{\n            rawContent\n            tags{\n                id\n                taggedField\n                taggedContentTable\n                taggedContentID\n                entityUUID\n                entityIntID\n                entity{\n                    __typename\n                    ... on UserAccount{\n                        id\n                        commonName\n                        email\n                    }\n                    ... on PossibleOperationalSolution {\n                        name\n                        key\n                    }\n                }\n            }\n        }\n        isAssessment\n        createdBy\n        createdDts\n        modifiedBy\n        modifiedDts\n        createdByUserAccount \n        {\n            commonName\n        }   \n        modifiedByUserAccount\n        {\n            commonName\n        }             \n    }\n}",
 								"variables": ""
 							}
 						},
@@ -2656,137 +2679,6 @@
 					"response": []
 				}
 			]
-		},
-		{
-			"name": "ECHIMP",
-			"item": [
-				{
-					"name": "CR Echimp by id",
-					"request": {
-						"method": "POST",
-						"header": [],
-						"body": {
-							"mode": "graphql",
-							"graphql": {
-								"query": "query echimpCR {\n    echimpCR(id: \"FFS3550\") {\n        id\n        versionNum\n        initiator\n        firstName\n        lastName\n        title\n        sensitiveFlag\n        implementationDate\n        crSummary {\n            rawContent\n        }\n        crStatus\n        emergencyCrFlag\n        relatedCrNumbers\n        relatedCrTdlNumbers\n        associatedModelUids\n    }\n}",
-								"variables": ""
-							}
-						},
-						"url": {
-							"raw": "{{url}}",
-							"host": [
-								"{{url}}"
-							]
-						}
-					},
-					"response": []
-				},
-				{
-					"name": "All CR Echimp data",
-					"request": {
-						"method": "POST",
-						"header": [],
-						"body": {
-							"mode": "graphql",
-							"graphql": {
-								"query": "query echimpCR {\n    echimpCRs {\n        id\n        versionNum\n        initiator\n        firstName\n        lastName\n        title\n        sensitiveFlag\n        implementationDate\n        crSummary {\n            rawContent\n        }\n        crStatus\n        emergencyCrFlag\n        relatedCrNumbers\n        relatedCrTdlNumbers\n        associatedModelUids\n    }\n}",
-								"variables": ""
-							}
-						},
-						"url": {
-							"raw": "{{url}}",
-							"host": [
-								"{{url}}"
-							]
-						}
-					},
-					"response": []
-				},
-				{
-					"name": "All Echimp CRS And TDLS",
-					"request": {
-						"method": "POST",
-						"header": [],
-						"body": {
-							"mode": "graphql",
-							"graphql": {
-								"query": "query echimpCRAndTDLS {\n    echimpCRAndTDLS{\n        __typename\n    ... on EChimpCR {\n        id\n        versionNum\n        initiator\n        firstName\n        lastName\n        title\n        sensitiveFlag\n        implementationDate\n        crSummary {\n            rawContent\n        }\n        crStatus\n        emergencyCrFlag\n        relatedCrNumbers\n        relatedCrTdlNumbers\n        associatedModelUids\n    }\n    ... on     EChimpTDL {\n        id\n        versionNum\n        initiator\n        firstName\n        lastName\n        title\n        issuedDate\n        status\n        associatedModelUids\n    }\n    }\n}",
-								"variables": ""
-							}
-						},
-						"url": {
-							"raw": "{{url}}",
-							"host": [
-								"{{url}}"
-							]
-						}
-					},
-					"response": []
-				},
-				{
-					"name": "TDL Echimp by id",
-					"request": {
-						"method": "POST",
-						"header": [],
-						"body": {
-							"mode": "graphql",
-							"graphql": {
-								"query": "query echimpTDL {\n    echimpTDL(id: \"TDL240535\") {\n        id\n        versionNum\n        initiator\n        firstName\n        lastName\n        title\n        issuedDate\n        status\n        associatedModelUids\n    }\n\n}",
-								"variables": ""
-							}
-						},
-						"url": {
-							"raw": "{{url}}",
-							"host": [
-								"{{url}}"
-							]
-						}
-					},
-					"response": []
-				},
-				{
-					"name": "ALL TDL Echimp data",
-					"request": {
-						"method": "POST",
-						"header": [],
-						"body": {
-							"mode": "graphql",
-							"graphql": {
-								"query": "query echimpTDL {\n    echimpTDLs {\n        id\n        versionNum\n        initiator\n        firstName\n        lastName\n        title\n        issuedDate\n        status\n        associatedModelUids\n    }\n\n}",
-								"variables": ""
-							}
-						},
-						"url": {
-							"raw": "{{url}}",
-							"host": [
-								"{{url}}"
-							]
-						}
-					},
-					"response": []
-				}
-			]
-		},
-		{
-			"name": "Get Model Plan with ECHIMP data",
-			"request": {
-				"method": "POST",
-				"header": [],
-				"body": {
-					"mode": "graphql",
-					"graphql": {
-						"query": "query modelPlan ($id: UUID!) {\n    modelPlan (id: $id) {\n        id\n        modelName\n        echimpCRs{\n            title\n        }\n        echimpTDLs{\n            title\n        }\n\n    }\n}",
-						"variables": "{\n  \"id\": \"{{modelPlanID}}\"\n}"
-					}
-				},
-				"url": {
-					"raw": "{{url}}",
-					"host": [
-						"{{url}}"
-					]
-				}
-			},
-			"response": []
 		}
 	],
 	"auth": {
@@ -2842,7 +2734,7 @@
 		},
 		{
 			"key": "modelPlanID",
-			"value": "082b49d3-b548-48cb-9119-77a281bc2a8c"
+			"value": ""
 		},
 		{
 			"key": "basicsID",
@@ -2872,6 +2764,11 @@
 			"key": "paymentsID",
 			"value": ""
 		},
+		{
+			"key": "dataExchangeApproachID",
+			"value": "",
+			"type": "string"
+		},
 		{
 			"key": "operationalNeedID",
 			"value": ""

cmd/dbseed/main.go

@@ -441,10 +441,48 @@ func (s *Seeder) SeedData() {
 			"cmmiGroups":      []string{"PATIENT_CARE_MODELS_GROUP", "SEAMLESS_CARE_MODELS_GROUP"},
 			"completeICIP":    "2020-05-13T20:47:50.12Z",
 			"phasedIn":        true,
-			"clearanceStarts": now.AddDate(0, 3, 0),
+			"clearanceStarts": time.Now().AddDate(0, 3, 0),
 			"highLevelNote":   "Some high level note",
 		},
 	)
+
+	// Send a notification for Data Exchange Approach Completed
+	dataExchangeApproach := models.NewPlanDataExchangeApproach(
+		models.NewCoreTaskListSection(
+			planWithDocuments.CreatedBy,
+			planWithDocuments.ID,
+		),
+	)
+
+	dataExchangeApproach.ID = uuid.MustParse("01020304-0506-0708-090a-0b0c0d0e0f10")
+
+	// create an actor principal for testing notifications
+
+	actorPrincipal := s.getTestPrincipalByUsername("MINT")
+
+	// Use a test user to mark the data exchange approach as complete
+	testUser := s.getTestPrincipalByUsername("BTAL")
+
+	err = resolvers.SendDataExchangeApproachCompletedNotification(
+		s.Config.Context,
+		s.Config.EmailService,
+		s.Config.EmailTemplateService,
+		s.Config.AddressBook,
+		actorPrincipal.UserAccount.ID,
+		s.Config.Store,
+		[]*models.UserAccountAndNotificationPreferences{
+			{
+				UserAccount:     *testUser.UserAccount,
+				PreferenceFlags: models.DefaultUserNotificationPreferencesFlags(),
+			},
+		},
+		planWithDocuments,
+		dataExchangeApproach,
+		testUser.UserAccount.ID,
+	)
+	if err != nil {
+		panic(fmt.Errorf("failed to send data exchange approach completed notification: %w", err))
+	}
 }
 
 func (s *Seeder) SetDefaultUserViews() {

cmd/test_email/main.go

@@ -30,9 +30,11 @@ func main() {
 	//DiscussionReply email
 	sendDiscussionReplyOriginatorTestEmail(emailService, templateService, addressBook)
 
+	// Model plan emails
 	sendModelPlanShareTest(emailService, templateService, addressBook)
 	sendDateChangedEmailsTest(emailService, templateService, addressBook)
 	sendCollaboratorAddedEmailTest(emailService, templateService, addressBook)
+	sendDataExchangeApproachCompletedEmailNotificationTest(emailService, templateService, addressBook)
 	sendFeedbackEmail(emailService, templateService, addressBook)
 	reportAProblemEmail(emailService, templateService, addressBook)
 
@@ -395,6 +397,30 @@ func sendCollaboratorAddedEmailTest(
 	noErr(err)
 }
 
+func sendDataExchangeApproachCompletedEmailNotificationTest(
+	emailService oddmail.EmailService,
+	templateService email.TemplateService,
+	addressBook email.AddressBook,
+) {
+
+	modelPlan := models.NewModelPlan(
+		uuid.Nil,
+		"Retcon Plan",
+	)
+
+	err := resolvers.SendDataExchangeApproachCompletedEmailNotification(
+		emailService,
+		templateService,
+		addressBook,
+		modelPlan,
+		"marty.mcfly@delorean.88",
+		"Doc Brown",
+		true,
+	)
+
+	noErr(err)
+}
+
 func sendFeedbackEmail(
 	emailService oddmail.EmailService,
 	templateService email.TemplateService,