[585] | 1 | import org.gnumims.RichUiCalendarItem |
---|
[533] | 2 | |
---|
| 3 | /** |
---|
[651] | 4 | * Service class that encapsulates the business logic for Task Reports. |
---|
[533] | 5 | */ |
---|
| 6 | class TaskReportService { |
---|
| 7 | |
---|
| 8 | boolean transactional = false |
---|
| 9 | |
---|
| 10 | def authService |
---|
| 11 | def dateUtilService |
---|
| 12 | // def messageSource |
---|
| 13 | |
---|
[544] | 14 | def g = new org.codehaus.groovy.grails.plugins.web.taglib.ApplicationTagLib() |
---|
[533] | 15 | |
---|
| 16 | def paramsMax = 100000 |
---|
| 17 | |
---|
| 18 | /** |
---|
| 19 | * Selects and returns the reactive ratio. |
---|
[542] | 20 | * @param params The request params, may contain params to specify the search. |
---|
[533] | 21 | * @param locale The locale to use when generating result.message. |
---|
| 22 | */ |
---|
| 23 | def getReactiveRatio(params, locale) { |
---|
| 24 | def result = [:] |
---|
| 25 | |
---|
[708] | 26 | def fail = { Map m -> |
---|
| 27 | result.error = [ code: m.code, args: [] ] |
---|
| 28 | return result |
---|
| 29 | } |
---|
| 30 | |
---|
[533] | 31 | def namedParams = [:] |
---|
| 32 | namedParams.startDate = params.startDate ?: dateUtilService.today |
---|
[535] | 33 | namedParams.endDate = params.endDate ?: dateUtilService.today |
---|
[708] | 34 | |
---|
| 35 | if(namedParams.endDate < namedParams.startDate) |
---|
| 36 | return fail(code: "default.end.date.before.start.date") |
---|
| 37 | |
---|
[535] | 38 | namedParams.endDate++ // Start of next day required. |
---|
[708] | 39 | |
---|
[533] | 40 | namedParams.immediateCallout = TaskType.read(1) |
---|
| 41 | namedParams.unscheduledBreakin = TaskType.read(2) |
---|
| 42 | namedParams.preventativeMaintenance = TaskType.read(4) |
---|
[535] | 43 | namedParams.notStarted = TaskStatus.read(1) |
---|
[533] | 44 | |
---|
| 45 | result.taskQuery = "from Task as task \ |
---|
[542] | 46 | where (task.trash = false \ |
---|
| 47 | and task.taskStatus != :notStarted \ |
---|
| 48 | and task.targetStartDate < :endDate \ |
---|
| 49 | and task.targetStartDate >= :startDate \ |
---|
| 50 | and ( \ |
---|
| 51 | task.taskType = :immediateCallout \ |
---|
| 52 | or task.taskType = :unscheduledBreakin \ |
---|
| 53 | or task.taskType = :preventativeMaintenance \ |
---|
| 54 | ) \ |
---|
| 55 | )" |
---|
[533] | 56 | |
---|
[535] | 57 | result.taskQuery = "select distinct task " + result.taskQuery |
---|
| 58 | result.taskList = Task.executeQuery(result.taskQuery, namedParams) |
---|
[533] | 59 | result.taskCount = result.taskList.size() |
---|
| 60 | |
---|
[536] | 61 | // Assets on Tasks Count. |
---|
[535] | 62 | result.totalAssetsOnTasksCount = 0 |
---|
[533] | 63 | result.immediateCalloutCount = 0 |
---|
| 64 | result.unscheduledBreakinCount = 0 |
---|
| 65 | result.preventativeMaintenanceCount = 0 |
---|
| 66 | |
---|
[542] | 67 | // Summary Of Calculations. |
---|
[535] | 68 | result.summaryOfCalculationMethod = 'HQL query: \n\n' |
---|
| 69 | def tempStringArray = result.taskQuery.split(' ') |
---|
| 70 | tempStringArray.each() { |
---|
| 71 | if(it != '') result.summaryOfCalculationMethod += it +'\n' |
---|
| 72 | } |
---|
| 73 | result.summaryOfCalculationMethod += '\n'+'Calculations: '+'\n\n' |
---|
| 74 | |
---|
| 75 | result.summaryOfCalculationMethod += 'totalAssetsOnTasksCount = A count of unique assets on each task. \n' |
---|
[533] | 76 | result.taskList.each() { task -> |
---|
| 77 | if(task.primaryAsset) { |
---|
[535] | 78 | result.totalAssetsOnTasksCount++ |
---|
[533] | 79 | if(task.taskType == namedParams.immediateCallout) result.immediateCalloutCount++ |
---|
| 80 | if(task.taskType == namedParams.unscheduledBreakin) result.unscheduledBreakinCount++ |
---|
| 81 | if(task.taskType == namedParams.preventativeMaintenance) result.preventativeMaintenanceCount++ |
---|
| 82 | } |
---|
| 83 | task.associatedAssets.each() { associatedAsset -> |
---|
| 84 | if(associatedAsset.id != task.primaryAsset?.id) { |
---|
[535] | 85 | result.totalAssetsOnTasksCount++ |
---|
[533] | 86 | if(task.taskType == namedParams.immediateCallout) result.immediateCalloutCount++ |
---|
| 87 | if(task.taskType == namedParams.unscheduledBreakin) result.unscheduledBreakinCount++ |
---|
| 88 | if(task.taskType == namedParams.preventativeMaintenance) result.preventativeMaintenanceCount++ |
---|
| 89 | } |
---|
| 90 | } |
---|
| 91 | } // each() task |
---|
| 92 | |
---|
[536] | 93 | // Percentage of counts. |
---|
[533] | 94 | result.immediateCalloutPercentage = 0 |
---|
| 95 | result.totalPreventativePercentage = 0 |
---|
| 96 | |
---|
[535] | 97 | result.summaryOfCalculationMethod += 'totalPreventativeCount = unscheduledBreakinCount + preventativeMaintenanceCount\n' |
---|
[533] | 98 | result.totalPreventativeCount = result.unscheduledBreakinCount + result.preventativeMaintenanceCount |
---|
| 99 | try { |
---|
[535] | 100 | result.summaryOfCalculationMethod += 'immediateCalloutPercentage = (immediateCalloutCount / totalAssetsOnTasksCount)*100 \n' |
---|
| 101 | result.summaryOfCalculationMethod += 'totalPreventativePercentage = (totalPreventativeCount / totalAssetsOnTasksCount)*100 \n' |
---|
| 102 | result.immediateCalloutPercentage = (result.immediateCalloutCount / result.totalAssetsOnTasksCount)*100 |
---|
| 103 | result.totalPreventativePercentage = (result.totalPreventativeCount / result.totalAssetsOnTasksCount)*100 |
---|
[533] | 104 | } |
---|
| 105 | catch(ArithmeticException e) { |
---|
[708] | 106 | log.info "Could not calculate: Assets on Tasks Percentages: "+e |
---|
[533] | 107 | } |
---|
| 108 | |
---|
[536] | 109 | // Work Done. |
---|
[708] | 110 | result.immediateCalloutWorkDone = [total:0, hours:0, minutes:0, percentage: new BigDecimal(0)] |
---|
[536] | 111 | result.unscheduledBreakinWorkDone = [total:0, hours:0, minutes:0] |
---|
| 112 | result.preventativeMaintenanceWorkDone = [total:0, hours:0, minutes:0] |
---|
[708] | 113 | result.totalPreventativeWorkDone = [total:0, hours:0, minutes:0, percentage: new BigDecimal(0)] |
---|
[536] | 114 | result.totalWorkDone = [total:0, hours:0, minutes:0] |
---|
| 115 | |
---|
| 116 | result.taskList.each() { task -> |
---|
| 117 | task.entries.each() { entry -> |
---|
| 118 | // Has assets assigned and is Work Done. |
---|
| 119 | if( (task.primaryAsset || task.associatedAssets) && entry.entryType.id == 3L ) { |
---|
| 120 | if(task.taskType == namedParams.immediateCallout) |
---|
| 121 | result.immediateCalloutWorkDone.total += (entry.durationHour*60) + entry.durationMinute |
---|
| 122 | if(task.taskType == namedParams.unscheduledBreakin) |
---|
| 123 | result.unscheduledBreakinWorkDone.total += (entry.durationHour*60) + entry.durationMinute |
---|
| 124 | if(task.taskType == namedParams.preventativeMaintenance) |
---|
| 125 | result.preventativeMaintenanceWorkDone.total += (entry.durationHour*60) + entry.durationMinute |
---|
| 126 | } |
---|
| 127 | } // each() entry |
---|
| 128 | } // each() task |
---|
| 129 | |
---|
| 130 | // Work Done hours and minutes. |
---|
| 131 | result.immediateCalloutWorkDone.hours = (result.immediateCalloutWorkDone.total / 60).toInteger() |
---|
| 132 | result.immediateCalloutWorkDone.minutes = result.immediateCalloutWorkDone.total % 60 |
---|
| 133 | |
---|
| 134 | result.unscheduledBreakinWorkDone.hours = (result.unscheduledBreakinWorkDone.total / 60).toInteger() |
---|
| 135 | result.unscheduledBreakinWorkDone.minutes = result.unscheduledBreakinWorkDone.total % 60 |
---|
| 136 | |
---|
| 137 | result.preventativeMaintenanceWorkDone.hours = (result.preventativeMaintenanceWorkDone.total / 60).toInteger() |
---|
| 138 | result.preventativeMaintenanceWorkDone.minutes = result.preventativeMaintenanceWorkDone.total % 60 |
---|
| 139 | |
---|
| 140 | // Work Done Totals. |
---|
| 141 | result.totalPreventativeWorkDone.total = result.unscheduledBreakinWorkDone.total + result.preventativeMaintenanceWorkDone.total |
---|
| 142 | result.totalPreventativeWorkDone.hours = (result.totalPreventativeWorkDone.total / 60).toInteger() |
---|
| 143 | result.totalPreventativeWorkDone.minutes = result.totalPreventativeWorkDone.total % 60 |
---|
| 144 | |
---|
| 145 | result.totalWorkDone.total = result.immediateCalloutWorkDone.total + result.totalPreventativeWorkDone.total |
---|
| 146 | result.totalWorkDone.hours = (result.totalWorkDone.total / 60).toInteger() |
---|
| 147 | result.totalWorkDone.minutes = result.totalWorkDone.total % 60 |
---|
| 148 | |
---|
| 149 | // Work Done Percentages. |
---|
| 150 | try { |
---|
[708] | 151 | result.immediateCalloutWorkDone.percentage = (BigDecimal)(result.immediateCalloutWorkDone.total / result.totalWorkDone.total)*100 |
---|
| 152 | result.totalPreventativeWorkDone.percentage = (BigDecimal)(result.totalPreventativeWorkDone.total / result.totalWorkDone.total)*100 |
---|
[536] | 153 | } |
---|
| 154 | catch(ArithmeticException e) { |
---|
[708] | 155 | log.info "Could not calculate: Work Done Percentages: "+e |
---|
[536] | 156 | } |
---|
| 157 | |
---|
[533] | 158 | // Success. |
---|
| 159 | return result |
---|
| 160 | |
---|
[542] | 161 | } // getReactiveRatio |
---|
[533] | 162 | |
---|
[542] | 163 | /** |
---|
| 164 | * Selects and returns Immediate Callouts, grouped by Asset. |
---|
| 165 | * @param params The request params, may contain params to specify the search. |
---|
| 166 | * @param locale The locale to use when generating result.message. |
---|
| 167 | */ |
---|
| 168 | def getImmediateCallouts(params, locale) { |
---|
| 169 | def result = [:] |
---|
[533] | 170 | |
---|
[709] | 171 | def fail = { Map m -> |
---|
| 172 | result.error = [ code: m.code, args: [] ] |
---|
| 173 | return result |
---|
| 174 | } |
---|
| 175 | |
---|
[542] | 176 | def namedParams = [:] |
---|
| 177 | namedParams.startDate = params.startDate ?: dateUtilService.today |
---|
[709] | 178 | namedParams.endDate = params.endDate ?: dateUtilService.today |
---|
| 179 | |
---|
| 180 | if(namedParams.endDate < namedParams.startDate) |
---|
| 181 | return fail(code: "default.end.date.before.start.date") |
---|
| 182 | |
---|
| 183 | namedParams.endDate++ // Start of next day required. |
---|
| 184 | |
---|
[542] | 185 | namedParams.immediateCallout = TaskType.read(1) |
---|
| 186 | |
---|
| 187 | result.taskQuery = "from Task as task \ |
---|
| 188 | where (task.trash = false \ |
---|
[709] | 189 | and task.targetStartDate < :endDate \ |
---|
[542] | 190 | and task.targetStartDate >= :startDate \ |
---|
| 191 | and task.taskType = :immediateCallout \ |
---|
| 192 | ) \ |
---|
| 193 | )" |
---|
| 194 | |
---|
| 195 | result.taskQuery = "select distinct task " + result.taskQuery |
---|
[544] | 196 | result.taskQueryList = Task.executeQuery(result.taskQuery, namedParams) |
---|
| 197 | result.taskCount = result.taskQueryList.size() |
---|
[542] | 198 | |
---|
| 199 | // Assets on Tasks Count. |
---|
| 200 | result.totalAssetsOnTasksCount = 0 |
---|
[544] | 201 | result.totalDownTime = [total: 0, hours: 0, minutes:0] |
---|
[542] | 202 | result.assetList = [] |
---|
| 203 | |
---|
[544] | 204 | // Task Details |
---|
| 205 | result.taskList = [] |
---|
[542] | 206 | |
---|
[544] | 207 | // Add or update lists. |
---|
| 208 | def addToLists = { asset, task -> |
---|
| 209 | |
---|
[542] | 210 | def downTime = 0 |
---|
| 211 | def faultEntries = Entry.findAllByTaskAndEntryType(task, EntryType.read(1)) |
---|
[544] | 212 | def causeEntries = Entry.findAllByTaskAndEntryType(task, EntryType.read(2)) |
---|
| 213 | def workDoneEntries = Entry.findAllByTaskAndEntryType(task, EntryType.read(3)) |
---|
| 214 | def taskDetails = 'Task #'+task.id+' - '+task.description+'\n' |
---|
| 215 | faultEntries.each(){ |
---|
| 216 | taskDetails += ' Faults: '+it.comment+' - '+it.enteredBy+', '+g.formatDate(format: "EEE, dd-MMM-yyyy", date: it.dateDone)+'.\n' |
---|
| 217 | } |
---|
| 218 | causeEntries.each(){ |
---|
| 219 | taskDetails += ' Causes: '+it.comment+' - '+it.enteredBy+', '+g.formatDate(format: "EEE, dd-MMM-yyyy", date: it.dateDone)+'.\n' |
---|
| 220 | } |
---|
| 221 | workDoneEntries.each(){ |
---|
| 222 | taskDetails += ' Work Done: '+it.comment+' - '+it.enteredBy+', '+g.formatDate(format: "EEE, dd-MMM-yyyy", date: it.dateDone)+'.\n' |
---|
| 223 | } |
---|
| 224 | |
---|
[542] | 225 | faultEntries.each() { downTime += (it.durationHour*60 + it.durationMinute) } |
---|
[544] | 226 | result.totalDownTime.total += downTime |
---|
[542] | 227 | |
---|
| 228 | def assetDetails = result.assetList.find { it.id == asset.id } |
---|
| 229 | if(assetDetails) { |
---|
| 230 | assetDetails.immediateCalloutCount++ |
---|
[544] | 231 | assetDetails.downTime += downTime |
---|
| 232 | assetDetails.tasks += taskDetails |
---|
[542] | 233 | } |
---|
| 234 | else { |
---|
| 235 | assetDetails = [id: asset.id, |
---|
| 236 | name: asset.name, |
---|
| 237 | immediateCalloutCount: 1, |
---|
| 238 | downTime: downTime, |
---|
[544] | 239 | tasks: taskDetails] |
---|
[542] | 240 | |
---|
| 241 | result.assetList << assetDetails |
---|
| 242 | } |
---|
[544] | 243 | } // addAToLists |
---|
[542] | 244 | |
---|
| 245 | // Summary Of Calculations. |
---|
| 246 | result.summaryOfCalculationMethod = 'HQL query: \n\n' |
---|
| 247 | def tempStringArray = result.taskQuery.split(' ') |
---|
| 248 | tempStringArray.each() { |
---|
| 249 | if(it != '') result.summaryOfCalculationMethod += it +'\n' |
---|
| 250 | } |
---|
| 251 | result.summaryOfCalculationMethod += '\n'+'Calculations: '+'\n\n' |
---|
| 252 | |
---|
| 253 | result.summaryOfCalculationMethod += 'totalAssetsOnTasksCount = A count of unique assets on each task. \n' |
---|
[544] | 254 | result.taskQueryList.each() { task -> |
---|
[542] | 255 | if(task.primaryAsset) { |
---|
| 256 | result.totalAssetsOnTasksCount++ |
---|
[544] | 257 | addToLists(task.primaryAsset, task) |
---|
[542] | 258 | } |
---|
| 259 | task.associatedAssets.each() { associatedAsset -> |
---|
| 260 | if(associatedAsset.id != task.primaryAsset?.id) { |
---|
| 261 | result.totalAssetsOnTasksCount++ |
---|
[544] | 262 | addToLists(associatedAsset, task) |
---|
[542] | 263 | } |
---|
| 264 | } |
---|
| 265 | |
---|
| 266 | } // each() task |
---|
| 267 | |
---|
[544] | 268 | // Sort assetList by callout count. |
---|
[542] | 269 | result.assetList.sort {a, b -> b.immediateCalloutCount.compareTo(a.immediateCalloutCount)} |
---|
| 270 | |
---|
[544] | 271 | // Calculate hours and minutes. |
---|
| 272 | result.totalDownTime.hours = (result.totalDownTime.total / 60).toInteger() |
---|
| 273 | result.totalDownTime.minutes = result.totalDownTime.total % 60 |
---|
| 274 | |
---|
[542] | 275 | // Success. |
---|
| 276 | return result |
---|
| 277 | |
---|
| 278 | } // getImmediateCallouts() |
---|
| 279 | |
---|
[585] | 280 | /** |
---|
| 281 | * Builds and returns a list of RichUiCalendarItem's. |
---|
| 282 | * @param params The request params, may contain params to specify the search. |
---|
| 283 | * @param locale The locale to use when generating result.message. |
---|
| 284 | */ |
---|
| 285 | def getWorkLoadSummary(params, locale) { |
---|
[542] | 286 | |
---|
[585] | 287 | def result = [:] |
---|
| 288 | result.displayList = [] |
---|
| 289 | |
---|
| 290 | def listItem |
---|
| 291 | |
---|
| 292 | def dayMap = [:] |
---|
| 293 | def assignedGroupMap = [:] |
---|
| 294 | |
---|
| 295 | params.taskInstanceList.each { task -> |
---|
| 296 | def dayKey = task.targetStartDate /// @todo: make this key more stable. |
---|
| 297 | def assignedTime = 0 |
---|
| 298 | |
---|
| 299 | task.assignedGroups.each{ assignedGroup -> |
---|
| 300 | assignedTime = assignedGroup.estimatedHour*60 + assignedGroup.estimatedMinute |
---|
| 301 | } |
---|
| 302 | |
---|
| 303 | if(dayMap.containsKey(dayKey)) { |
---|
| 304 | if(task.description) { |
---|
| 305 | dayMap[dayKey] = dayMap[dayKey] + assignedTime |
---|
| 306 | } |
---|
| 307 | } |
---|
| 308 | else { |
---|
| 309 | dayMap[(dayKey)] = assignedTime |
---|
| 310 | } |
---|
| 311 | } |
---|
| 312 | |
---|
| 313 | dayMap.each { k, v -> |
---|
| 314 | listItem = new RichUiCalendarItem(date:k, text:('assignedTime: '+v.toString())) |
---|
| 315 | result.displayList << listItem |
---|
| 316 | } |
---|
| 317 | |
---|
| 318 | // Success. |
---|
| 319 | return result |
---|
| 320 | |
---|
| 321 | } // getWorkLoadSummary() |
---|
| 322 | |
---|
[533] | 323 | } // end class |
---|