Changeset 542 for trunk/grails-app/services

Timestamp:

May 23, 2010, 4:43:44 PM (15 years ago)

Author:

gav

Message:

Start Immediate Callout report.

File:

• trunk/grails-app/services/TaskReportService.groovy (modified) (5 diffs)

trunk/grails-app/services/TaskReportService.groovy

@@ -10 +10 @@
     def authService
     def dateUtilService
+    def sessionFactory
 //     def messageSource
 
@@ -18 +19 @@
     /**
     * Selects and returns the reactive ratio.
-    * @param params The request params, may contain param to specify the search.
+    * @param params The request params, may contain params to specify the search.
     * @param locale The locale to use when generating result.message.
     */
@@ -34 +35 @@
 
         result.taskQuery = "from Task as task \
-                                        where (task.trash = false \
-                                                    and task.taskStatus != :notStarted \
-                                                    and task.targetStartDate < :endDate \
-                                                    and task.targetStartDate >= :startDate \
-                                                    and ( \
-                                                        task.taskType = :immediateCallout \
-                                                        or task.taskType = :unscheduledBreakin \
-                                                        or task.taskType = :preventativeMaintenance \
-                                                    ) \
-                                        )"
+                                            where (task.trash = false \
+                                                        and task.taskStatus != :notStarted \
+                                                        and task.targetStartDate < :endDate \
+                                                        and task.targetStartDate >= :startDate \
+                                                        and ( \
+                                                            task.taskType = :immediateCallout \
+                                                            or task.taskType = :unscheduledBreakin \
+                                                            or task.taskType = :preventativeMaintenance \
+                                                        ) \
+                                            )"
 
         result.taskQuery = "select distinct task " + result.taskQuery
@@ -55 +56 @@
         result.preventativeMaintenanceCount = 0
 
+        // Summary Of Calculations.
         result.summaryOfCalculationMethod = 'HQL query: \n\n'
         def tempStringArray = result.taskQuery.split('    ')
@@ -148 +150 @@
         return result
 
-    } // getQuickSearch
+    } // getReactiveRatio
+
+    /**
+    * Selects and returns Immediate Callouts, grouped by Asset.
+    * @param params The request params, may contain params to specify the search.
+    * @param locale The locale to use when generating result.message.
+    */
+    def getImmediateCallouts(params, locale) {
+        def result = [:]
+
+        def namedParams = [:]
+        namedParams.startDate = params.startDate ?: dateUtilService.today
+        namedParams.endDatePlusOne = (params.endDate ?: dateUtilService.today)+1
+        namedParams.immediateCallout = TaskType.read(1)
+
+        result.taskQuery = "from Task as task \
+                                            where (task.trash = false \
+                                                        and task.targetStartDate < :endDatePlusOne \
+                                                        and task.targetStartDate >= :startDate \
+                                                        and task.taskType = :immediateCallout \
+                                                        ) \
+                                            )"
+
+        result.taskQuery = "select distinct task " + result.taskQuery
+        result.taskList = Task.executeQuery(result.taskQuery, namedParams)
+        result.taskCount = result.taskList.size()
+
+        // Assets on Tasks Count.
+        result.totalAssetsOnTasksCount = 0
+        result.assetList = []
+
+        // Add or update asset details in assetList.
+        def addAssetToList = { asset, task ->
+
+            def downTime = 0
+            def faultEntries = Entry.findAllByTaskAndEntryType(task, EntryType.read(1))
+            faultEntries.each() { downTime += (it.durationHour*60 + it.durationMinute) }
+
+            def assetDetails = result.assetList.find { it.id == asset.id }
+            if(assetDetails) {
+                assetDetails.immediateCalloutCount++
+                assetDetails.immediateCalloutTaskList.add(task.toString())
+            }
+            else {
+                assetDetails = [id: asset.id,
+                                            name: asset.name,
+                                            immediateCalloutCount: 1,
+                                            downTime: downTime,
+                                            immediateCalloutTaskList: [task.toString()]]
+
+                result.assetList << assetDetails
+            }
+        } // addAssetToList
+
+        // Summary Of Calculations.
+        result.summaryOfCalculationMethod = 'HQL query: \n\n'
+        def tempStringArray = result.taskQuery.split('    ')
+        tempStringArray.each() {
+            if(it != '') result.summaryOfCalculationMethod += it +'\n'
+        }
+        result.summaryOfCalculationMethod += '\n'+'Calculations: '+'\n\n'
+
+        result.summaryOfCalculationMethod += 'totalAssetsOnTasksCount = A count of unique assets on each task. \n'
+        result.taskList.each() { task ->
+            if(task.primaryAsset) {
+                result.totalAssetsOnTasksCount++
+                addAssetToList(task.primaryAsset, task)
+            }
+            task.associatedAssets.each() { associatedAsset ->
+                if(associatedAsset.id != task.primaryAsset?.id) {
+                    result.totalAssetsOnTasksCount++
+                    addAssetToList(associatedAsset, task)
+                }
+            }
+
+        } // each() task
+
+        // Sort by callout count.
+        result.assetList.sort {a, b -> b.immediateCalloutCount.compareTo(a.immediateCalloutCount)}
+
+        // Success.
+        return result
+
+    } // getImmediateCallouts()