|
| 1 | +package au.org.ala.biocollect |
| 2 | + |
| 3 | +import au.org.ala.biocollect.merit.* |
| 4 | +import grails.converters.JSON |
| 5 | +import grails.web.servlet.mvc.GrailsParameterMap |
| 6 | + |
| 7 | +import java.time.Instant |
| 8 | + |
| 9 | +class ReferenceAssessmentController { |
| 10 | + UserService userService |
| 11 | + ProjectActivityService projectActivityService |
| 12 | + ActivityService activityService |
| 13 | + |
| 14 | + |
| 15 | + private def createAssessmentRecordFromReference(Object referenceActivity, Object assessProjectActivity, boolean deIdentify) { |
| 16 | + def refDoc = referenceActivity.documents[0] |
| 17 | + |
| 18 | + def baseUrl = '' |
| 19 | + if (!refDoc["url"].startsWith('http')) { |
| 20 | + baseUrl = grailsApplication.config.getProperty("grails.serverURL", String) |
| 21 | + } |
| 22 | + |
| 23 | + def assessPhoto = [ |
| 24 | + licence: refDoc["licence"], |
| 25 | + notes: refDoc["notes"], |
| 26 | + filesize: refDoc["filesize"], |
| 27 | + staged: true, |
| 28 | + url: baseUrl + refDoc["url"], |
| 29 | + filename: refDoc["filename"], |
| 30 | + attribution: referenceActivity.outputs[0].data["imageAttribution"], |
| 31 | + name: refDoc["name"], |
| 32 | + documentId: '', |
| 33 | + contentType: refDoc["contentType"], |
| 34 | + dateTaken: refDoc["dateTaken"], |
| 35 | + formattedSize: refDoc["formattedSize"], |
| 36 | + thumbnailUrl: baseUrl + refDoc["thumbnailUrl"], |
| 37 | + status: "active" |
| 38 | + ] |
| 39 | + |
| 40 | + def assessActivity = [ |
| 41 | + outputs: [ |
| 42 | + [ |
| 43 | + outputId: "", |
| 44 | + outputNotCompleted: false, |
| 45 | + data: [ |
| 46 | + recordedBy: userService.getCurrentUserDisplayName(), |
| 47 | + upperConditionBound: "0", |
| 48 | + lowerConditionBound: "0", |
| 49 | + overallConditionBestEstimate: "0", |
| 50 | + mvgGroup: referenceActivity.outputs[0].data.vegetationStructureGroup, |
| 51 | + huchinsonGroup: referenceActivity.outputs[0].data.huchinsonGroup, |
| 52 | + sitePhoto: [assessPhoto], |
| 53 | + deIdentify: deIdentify ? "Yes" : "No" |
| 54 | + ], |
| 55 | + name: assessProjectActivity["pActivityFormName"] |
| 56 | + ] |
| 57 | + ], |
| 58 | + projectActivityId: assessProjectActivity["projectActivityId"], |
| 59 | + userId: userService.getCurrentUserId(), |
| 60 | + projectStage: "", |
| 61 | + embargoed: false, |
| 62 | + type: assessProjectActivity["pActivityFormName"], |
| 63 | + projectId: assessProjectActivity["projectId"], |
| 64 | + mainTheme: "" |
| 65 | + ] |
| 66 | + |
| 67 | + // Create the new assessment activity record |
| 68 | + activityService.update("", assessActivity) |
| 69 | + |
| 70 | + // Update the numTimesReferenced field on the reference record |
| 71 | + referenceActivity.outputs[0].data.numTimesReferenced = |
| 72 | + referenceActivity.outputs[0].data.numTimesReferenced as Integer + 1 |
| 73 | + activityService.update(referenceActivity.activityId, referenceActivity) |
| 74 | + |
| 75 | + // Return the assessment activity |
| 76 | + assessActivity |
| 77 | + } |
| 78 | + |
| 79 | + def requestRecords() { |
| 80 | + def config = grailsApplication.config.getProperty("refAssess", Map) |
| 81 | + def body = request.JSON |
| 82 | + def result |
| 83 | + |
| 84 | + // Ensure BioCollect is configured for reference assessment projects |
| 85 | + if (!config) { |
| 86 | + response.status = 500 |
| 87 | + result = [message: 'The application is not configured for reference assessment projects'] |
| 88 | + render result as JSON |
| 89 | + return |
| 90 | + } |
| 91 | + |
| 92 | + // Ensure the body of the request contains the required fields |
| 93 | + if (!body['vegetationStructureGroups'] || !body['climateGroups'] || !body.keySet().contains('deIdentify')) { |
| 94 | + response.status = 400 |
| 95 | + result = [message: 'Please ensure the assessment record request contains all relevant fields'] |
| 96 | + render result as JSON |
| 97 | + return |
| 98 | + } |
| 99 | + |
| 100 | + // Ensure the user is authenticated |
| 101 | + if (!userService.getCurrentUserId()) { |
| 102 | + response.status = 403 |
| 103 | + result = [message: 'User is not authenticated'] |
| 104 | + render result as JSON |
| 105 | + return |
| 106 | + } |
| 107 | + |
| 108 | + // Get the activity records for the reference survey |
| 109 | + def refActivitiesSearch = activityService.search([ |
| 110 | + projectActivityId: config.reference.projectActivityId |
| 111 | + ]) |
| 112 | + def refActivities = refActivitiesSearch.resp.activities |
| 113 | + def maxRecordsToCreate = config.assessment.maxRecordsToCreate as Integer |
| 114 | + |
| 115 | + // Ensure the reference records exist |
| 116 | + def numRefActivities = refActivities?.size() |
| 117 | + if (numRefActivities == 0) { |
| 118 | + response.status = 404 |
| 119 | + result = [message: 'No reference records found in reference survey'] |
| 120 | + render result as JSON |
| 121 | + return |
| 122 | + } |
| 123 | + |
| 124 | + // Filter out any records without data or documents |
| 125 | + refActivities = refActivities.findAll { |
| 126 | + it.outputs[0].keySet().contains('data') && |
| 127 | + it.documents.size() > 0 |
| 128 | + } |
| 129 | + |
| 130 | + // Filter out reference activities by the supplied vegetation structure groups & climate groups |
| 131 | + refActivities = refActivities.findAll { |
| 132 | + body["vegetationStructureGroups"].contains(it.outputs[0].data["vegetationStructureGroup"]) && |
| 133 | + body["climateGroups"].contains(it.outputs[0].data["huchinsonGroup"]) |
| 134 | + } |
| 135 | + |
| 136 | + // Split & sort the reference activities into: |
| 137 | + // Priority records (assessed <= 3 times), prioritising records assessed the MOST |
| 138 | + // Other records (assessed > 3 times), prioritising records assessed the LEAST |
| 139 | + |
| 140 | + def priorityRecords = refActivities |
| 141 | + .findAll { it.outputs[0].data.numTimesReferenced as Integer <= 3 } |
| 142 | + .sort{ -(it.outputs[0].data.numTimesReferenced as Integer) } |
| 143 | + def otherRecords = refActivities |
| 144 | + .findAll { it.outputs[0].data.numTimesReferenced as Integer > 3 } |
| 145 | + .sort{ it.outputs[0].data.numTimesReferenced as Integer } |
| 146 | + |
| 147 | + // Combine the two lists |
| 148 | + refActivities = priorityRecords + otherRecords |
| 149 | + |
| 150 | + // Ensure there are reference records after filtering |
| 151 | + if (refActivities.size() == 0) { |
| 152 | + response.status = 400 |
| 153 | + result = [message: "No reference images matching your criteria could be found."] |
| 154 | + render result as JSON |
| 155 | + return |
| 156 | + } |
| 157 | + |
| 158 | + def assessProjectActivity = projectActivityService.get(config.assessment.projectActivityId) |
| 159 | + def assessActivities = [] |
| 160 | + for ( |
| 161 | + int projectIndex = 0; |
| 162 | + projectIndex < Math.min(maxRecordsToCreate, refActivities.size()); |
| 163 | + projectIndex++ |
| 164 | + ) { |
| 165 | + assessActivities.push( |
| 166 | + createAssessmentRecordFromReference( |
| 167 | + refActivities[projectIndex], |
| 168 | + assessProjectActivity, |
| 169 | + body['deIdentify'] |
| 170 | + ) |
| 171 | + ) |
| 172 | + } |
| 173 | + |
| 174 | + response.status = 200 |
| 175 | + result = [message: "Found ${assessActivities.size()} images for assessment, please standby..."] |
| 176 | + render result as JSON |
| 177 | + } |
| 178 | +} |
0 commit comments