forked from shaba/openuds
added report for UPC
This commit is contained in:
Adolfo Gómez García
parent
a3ad88b9e6
commit
b5154cbbe9
@ -36,4 +36,5 @@ from .login import StatsReportLogin, StatsReportLoginCSV
|
||||
from .pool_performance import PoolPerformanceReport
|
||||
from .usage_by_pool import UsageByPool
|
||||
from .pools_usage import CountersPoolAssigned
|
||||
from .usage_summary_pool import UsageSummaryByPool
|
||||
|
||||
|
||||
@ -60,7 +60,7 @@ import logging
|
||||
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
__updated__ = '2016-05-17'
|
||||
__updated__ = '2017-05-04'
|
||||
|
||||
# several constants as Width height, margins, ..
|
||||
WIDTH, HEIGHT = 1800, 1000
|
||||
@ -148,7 +148,7 @@ class StatsReportLogin(StatsReport):
|
||||
order=3,
|
||||
label=_('Number of intervals'),
|
||||
length=3,
|
||||
minValue=16,
|
||||
minValue=0,
|
||||
maxValue=128,
|
||||
tooltip=_('Number of sampling points used in charts'),
|
||||
defvalue='64'
|
||||
@ -163,6 +163,13 @@ class StatsReportLogin(StatsReport):
|
||||
def getRangeData(self):
|
||||
start = self.startDate.stamp()
|
||||
end = self.endDate.stamp()
|
||||
if self.samplingPoints.num() < 8:
|
||||
self.samplingPoints.value = (self.endDate.date() - self.startDate.date()).days
|
||||
if self.samplingPoints.num() < 2:
|
||||
self.samplingPoints.value = 2
|
||||
if self.samplingPoints.num() > 128:
|
||||
self.samplingPoints.value = 128
|
||||
|
||||
samplingPoints = self.samplingPoints.num()
|
||||
|
||||
# x axis label format
|
||||
|
||||
@ -64,7 +64,7 @@ import logging
|
||||
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
__updated__ = '2016-05-17'
|
||||
__updated__ = '2017-05-04'
|
||||
|
||||
# several constants as Width height, margins, ..
|
||||
WIDTH, HEIGHT = 1800, 1000
|
||||
@ -162,8 +162,8 @@ class PoolPerformanceReport(StatsReport):
|
||||
order=4,
|
||||
label=_('Number of intervals'),
|
||||
length=3,
|
||||
minValue=2,
|
||||
maxValue=24,
|
||||
minValue=0,
|
||||
maxValue=32,
|
||||
tooltip=_('Number of sampling points used in charts'),
|
||||
defvalue='8'
|
||||
)
|
||||
@ -181,7 +181,16 @@ class PoolPerformanceReport(StatsReport):
|
||||
def getRangeData(self):
|
||||
start = self.startDate.stamp()
|
||||
end = self.endDate.stamp()
|
||||
|
||||
if self.samplingPoints.num() < 2:
|
||||
self.samplingPoints.value = (self.endDate.date() - self.startDate.date()).days
|
||||
if self.samplingPoints.num() < 2:
|
||||
self.samplingPoints.value = 2
|
||||
if self.samplingPoints.num() > 32:
|
||||
self.samplingPoints.value = 32
|
||||
|
||||
samplingPoints = self.samplingPoints.num()
|
||||
|
||||
pools = [(v.id, v.name) for v in ServicePool.objects.filter(uuid__in=self.pools.value)]
|
||||
if len(pools) == 0:
|
||||
raise Exception(_('Select at least a service pool for the report'))
|
||||
|
||||
212
server/src/uds/reports/stats/usage_summary_pool.py
Normal file
212
server/src/uds/reports/stats/usage_summary_pool.py
Normal file
@ -0,0 +1,212 @@
|
||||
# -*- coding: utf-8 -*-
|
||||
|
||||
#
|
||||
# Copyright (c) 2015 Virtual Cable S.L.
|
||||
# All rights reserved.
|
||||
#
|
||||
# Redistribution and use in source and binary forms, with or without modification,
|
||||
# are permitted provided that the following conditions are met:
|
||||
#
|
||||
# * Redistributions of source code must retain the above copyright notice,
|
||||
# this list of conditions and the following disclaimer.
|
||||
# * Redistributions in binary form must reproduce the above copyright notice,
|
||||
# this list of conditions and the following disclaimer in the documentation
|
||||
# and/or other materials provided with the distribution.
|
||||
# * Neither the name of Virtual Cable S.L. nor the names of its contributors
|
||||
# may be used to endorse or promote products derived from this software
|
||||
# without specific prior written permission.
|
||||
#
|
||||
# THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
|
||||
# AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
|
||||
# IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
|
||||
# DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE
|
||||
# FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
|
||||
# DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
|
||||
# SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
|
||||
# CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
|
||||
# OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
|
||||
# OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
||||
|
||||
'''
|
||||
.. moduleauthor:: Adolfo Gómez, dkmaster at dkmon dot com
|
||||
'''
|
||||
from __future__ import unicode_literals
|
||||
|
||||
from django.utils.translation import ugettext, ugettext_lazy as _
|
||||
|
||||
from uds.core.ui.UserInterface import gui
|
||||
from uds.core.reports.tools import UDSGeraldoReport
|
||||
from uds.core.util.stats import events
|
||||
|
||||
|
||||
import StringIO
|
||||
import csv
|
||||
import six
|
||||
|
||||
|
||||
from .base import StatsReport
|
||||
|
||||
from uds.core.util import tools
|
||||
from uds.models import ServicePool
|
||||
from geraldo.generators.pdf import PDFGenerator
|
||||
from geraldo import ReportBand, ObjectValue, Label
|
||||
from reportlab.lib.units import cm, mm
|
||||
|
||||
import datetime
|
||||
import logging
|
||||
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
__updated__ = '2017-05-04'
|
||||
|
||||
# several constants as Width height, margins, ..
|
||||
WIDTH, HEIGHT = 1800, 1000
|
||||
GERALDO_WIDTH = 120 * mm
|
||||
GERALDO_HEIGHT = GERALDO_WIDTH * HEIGHT / WIDTH
|
||||
|
||||
|
||||
class UsersSumaryReport(UDSGeraldoReport):
|
||||
title = ''
|
||||
author = 'UDS'
|
||||
|
||||
header_elements = [
|
||||
Label(text=_('User'), top=2.0 * cm, left=0.5 * cm),
|
||||
Label(text=_('Sessions'), top=2.0 * cm, left=5.5 * cm),
|
||||
Label(text=_('Hours'), top=2.0 * cm, left=7.5 * cm),
|
||||
Label(text=_('Average'), top=2.0 * cm, left=12 * cm),
|
||||
]
|
||||
|
||||
header_height = 2.5 * cm
|
||||
|
||||
|
||||
class band_detail(ReportBand):
|
||||
height = 0.5 * cm
|
||||
elements = (
|
||||
ObjectValue(attribute_name='user', left=0.5 * cm, style={'fontName': 'Helvetica', 'fontSize': 8}),
|
||||
ObjectValue(attribute_name='sessions', left=5.5 * cm, style={'fontName': 'Helvetica', 'fontSize': 8}),
|
||||
ObjectValue(attribute_name='hours', left=7.5 * cm, style={'fontName': 'Helvetica', 'fontSize': 8}),
|
||||
ObjectValue(attribute_name='average', left=12 * cm, style={'fontName': 'Helvetica', 'fontSize': 8}),
|
||||
)
|
||||
|
||||
|
||||
class UsageSummaryByPool(StatsReport):
|
||||
filename = 'pools_usage.pdf'
|
||||
name = _('Summary of pools usage') # Report name
|
||||
description = _('Generates a report with the summary of a pool usage') # Report description
|
||||
uuid = '202c6438-30a8-11e7-80e4-77c1e4cb9e09'
|
||||
|
||||
# Input fields
|
||||
pool = gui.ChoiceField(
|
||||
order=1,
|
||||
label=_('Pool'),
|
||||
tooltip=_('Pool for report'),
|
||||
required=True
|
||||
)
|
||||
|
||||
startDate = gui.DateField(
|
||||
order=2,
|
||||
label=_('Starting date'),
|
||||
tooltip=_('starting date for report'),
|
||||
defvalue=datetime.date.min,
|
||||
required=True
|
||||
)
|
||||
|
||||
endDate = gui.DateField(
|
||||
order=3,
|
||||
label=_('Finish date'),
|
||||
tooltip=_('finish date for report'),
|
||||
defvalue=datetime.date.max,
|
||||
required=True
|
||||
)
|
||||
|
||||
def initialize(self, values):
|
||||
pass
|
||||
|
||||
def initGui(self):
|
||||
logger.debug('Initializing gui')
|
||||
vals = [
|
||||
gui.choiceItem(v.uuid, v.name) for v in ServicePool.objects.all()
|
||||
]
|
||||
self.pool.setValues(vals)
|
||||
|
||||
def getPoolData(self, pool):
|
||||
start = self.startDate.stamp()
|
||||
end = self.endDate.stamp()
|
||||
logger.debug(self.pool.value)
|
||||
|
||||
items = events.statsManager().getEvents(events.OT_DEPLOYED, (events.ET_LOGIN, events.ET_LOGOUT), owner_id=pool.id, since=start, to=end).order_by('stamp')
|
||||
|
||||
logins = {}
|
||||
users = {}
|
||||
for i in items:
|
||||
# if '\\' in i.fld1:
|
||||
# continue
|
||||
username = i.fld4
|
||||
if i.event_type == events.ET_LOGIN:
|
||||
logins[username] = i.stamp
|
||||
else:
|
||||
if username in logins:
|
||||
stamp = logins[username]
|
||||
del logins[username]
|
||||
total = i.stamp - stamp
|
||||
if username not in users:
|
||||
users[username] = { 'sessions': 0, 'time': 0 }
|
||||
users[username]['sessions'] += 1
|
||||
users[username]['time'] += total
|
||||
# data.append({
|
||||
# 'name': i.fld4,
|
||||
# 'date': datetime.datetime.fromtimestamp(stamp),
|
||||
# 'time': total
|
||||
# })
|
||||
|
||||
# Extract different number of users
|
||||
data = []
|
||||
for k, v in six.iteritems(users):
|
||||
|
||||
data.append({
|
||||
'user': k,
|
||||
'sessions': v['sessions'],
|
||||
'hours': '{:.2f}'.format(float(v['time']) / 3600),
|
||||
'average': '{:.2f}'.format(float(v['time']) / 3600 / v['sessions'])
|
||||
})
|
||||
|
||||
return data, pool.name
|
||||
|
||||
def getData(self):
|
||||
return self.getPoolData(ServicePool.objects.get(uuid=self.pool.value))
|
||||
|
||||
|
||||
def generate(self):
|
||||
items, poolName = self.getData()
|
||||
|
||||
output = StringIO.StringIO()
|
||||
|
||||
report = UsersSumaryReport(queryset=items)
|
||||
report.title = _('Users usage list for {}').format(poolName)
|
||||
report.generate_by(PDFGenerator, filename=output)
|
||||
return output.getvalue()
|
||||
|
||||
|
||||
class UsageSummaryByPoolCSV(UsageSummaryByPool):
|
||||
filename = 'usage.csv'
|
||||
mime_type = 'text/csv' # Report returns pdfs by default, but could be anything else
|
||||
uuid = '302e1e76-30a8-11e7-9d1e-6762bbf028ca'
|
||||
encoded = False
|
||||
|
||||
# Input fields
|
||||
pool = UsageSummaryByPool.pool
|
||||
startDate = UsageSummaryByPool.startDate
|
||||
endDate = UsageSummaryByPool.endDate
|
||||
|
||||
def generate(self):
|
||||
output = StringIO.StringIO()
|
||||
writer = csv.writer(output)
|
||||
|
||||
reportData, poolName = self.getData()
|
||||
|
||||
writer.writerow([ugettext('Date'), ugettext('User'), ugettext('Seconds')])
|
||||
|
||||
for v in reportData:
|
||||
writer.writerow([v['date'], v['name'], v['time']])
|
||||
|
||||
return output.getvalue()
|
||||
Loading…
x
Reference in New Issue
Block a user