计算时间段的平均汇率

Question

在 Django 中我有类似于这个例子的模型：

class Currency(models.Model):
    name = models.CharField(max_length=3, unique=True)
    full_name = models.CharField(max_length=20)


class ExchangeRate(models.Model):
    currency = models.ForeignKey('Currency')
    start_date = models.DateFiled()
    end_date = models.DateField()
    exchange_rate = models.DecimalField(max_digits=12, decimal_places=4)

让我们简化一下，假设我们只有一种货币并且 ExchangeRate table 看起来像：

+---------------------+-------------------+------------+------------+---------------+
| currency_from__name | currency_to__name | start_date |  end_date  | exchange_rate |
+---------------------+-------------------+------------+------------+---------------+
|        PLN          |        USD        | 2014-03-01 | 2014-08-01 |    3.00000    |
|        PLN          |        USD        | 2014-08-01 | 2014-12-01 |    6.00000    |
+---------------------+-------------------+------------+------------+---------------+

注意这是简化数学运算的例子！

在此table数据密度为每月一次，一个月有效记录例如当start_date = 2014.03.01和end_date = 2014.04.01时，所以start_date包含并且end_date独享

我想计算时间段的平均汇率：

这意味着： and

在 Django 中我写：

start_date = date(2014, 6, 1)
end_date = date(2014, 9, 1)

ExchangeRate.objects.all().filter(
        (
            Q(start_date__lt=start_date) & 
            Q(end_date__gt=start_date)
        ) | (
            Q(start_date__gte=start_date) & 
            Q(start_date__lt=end_date) & 
            Q(end_date__gt=start_date) 
        )
).annotate(
    currency_from_name = 'currency_from__name', 
    currency_to_name = 'currency_to__name'
).values(  # GROUP BY
    'currency_from_name',
    'currency_to_name'
).aggregate(
    F('currency_from_name'), 
    F('currency_to_name'), 
    Avg('exchange_rate')
)

此查询后我收到值 4.5000，从数学原因来看这是正确的，但当您需要注意时间范围时是错误的。
正确答案是 4.000.

我只是想出这个解决方案来用这个公式注释额外的列，然后从这个列计算平均值：

其中：

Abs是绝对值的函数abs()
months 是计算两个日期之间月份的函数 months_between()
greater、smaller 是从参数中相应地选择更大和更小值的函数 - greatest(), least()
ER 表示来自 ExchangeRate 的列 - 例如F('exchange_rate')

我正在使用 9.3 PostgreSQL DB 和 Django 1.8.4.

也许有一个简单的功能？
也许我把这个复杂化了？

Answer 1

您应该将其视为加权平均值，因此您要做的是计算每行的权重，然后将它们相加。

我对 Django 的了解还不够多，无法在这方面为您提供帮助，但在 SQL 中，这将是（我现在无法对此进行测试，但我认为它给出了正确的想法）：

SELECT SUM((LEAST(end_date, @end_date) - GREATEST(start_date, @start_date)) * exchange_rate) / (@end_date - @start_date) AS weighted_avg
FROM 
  ExchangeRate
WHERE
  (start_date, end_date) OVERLAPS (@start_date, @end_date)

这使用 OVERLAPS 运算符来查看周期是否重叠。我不确定权重计算中是否存在 of by 1 错误，但认为这应该在输入变量的定义中处理 (@end_date = @end_date - 1)

Answer 2

您的应用程序的问题在于您选择存储汇率的方式。所以，回答你的问题：是的，你把这个复杂化了。

"The Math" 告诉你平均汇率是 4.5 因为

(3 + 6) /2 == 4.5

无论您选择什么开始日期或结束日期，系统都会为您提供相同的值。

为了解决根本原因，让我们尝试不同的方法。（为简单起见，我将保留外键和其他与获取特定日期范围内的平均值无关的细节，您可以稍后将它们添加回来）

使用此模型：

class ExchangeRate(models.Model):
    currency1 = models.CharField(max_length=3)
    currency2 = models.CharField(max_length=3)
    start_date = models.DateField()
    exchange_rate = models.DecimalField(max_digits=12, decimal_places=4)

和此数据：

INSERT INTO exchange_rate_exchangerate(currency1, currency2, start_date, exchange_rate) VALUES ('PLN', 'USD', '2014-03-01', 3);
INSERT INTO exchange_rate_exchangerate(currency1, currency2, start_date, exchange_rate) VALUES ('PLN', 'USD', '2014-04-01', 3);
INSERT INTO exchange_rate_exchangerate(currency1, currency2, start_date, exchange_rate) VALUES ('PLN', 'USD', '2014-05-01', 3);
INSERT INTO exchange_rate_exchangerate(currency1, currency2, start_date, exchange_rate) VALUES ('PLN', 'USD', '2014-06-01', 3);
INSERT INTO exchange_rate_exchangerate(currency1, currency2, start_date, exchange_rate) VALUES ('PLN', 'USD', '2014-07-01', 3);
INSERT INTO exchange_rate_exchangerate(currency1, currency2, start_date, exchange_rate) VALUES ('PLN', 'USD', '2014-08-01', 6);
INSERT INTO exchange_rate_exchangerate(currency1, currency2, start_date, exchange_rate) VALUES ('PLN', 'USD', '2014-09-01', 6);
INSERT INTO exchange_rate_exchangerate(currency1, currency2, start_date, exchange_rate) VALUES ('PLN', 'USD', '2014-10-01', 6);
INSERT INTO exchange_rate_exchangerate(currency1, currency2, start_date, exchange_rate) VALUES ('PLN', 'USD', '2014-11-01', 6);

我们可以执行这个查询：

from django.db.models import Avg
from datetime import date

first_date = date(2014, 6, 1)
last_date = date(2014, 9, 1)
er.models.ExchangeRate.objects.filter(
    start_date__gte = first_date,
    start_date__lt = last_date

).aggregate(Avg('exchange_rate'))

要获得此输出：

{'exchange_rate__avg': 4.0}

Answer 3

1。 `months_between()`:

create function months_of(interval)
 returns int strict immutable language sql as $$
  select extract(years from )::int * 12 + extract(month from )::int
$$;

create function months_between(date, date)
 returns int strict immutable language sql as $$
   select months_of(age(, ))
$$;

2。 `average_weight():`

create function average_weight(numeric, date, date, date, date)
 returns numeric(9,2) strict immutable language sql as $$
   select abs(months_between(GREATEST(, ), LEAST(, ))/months_between(, ))*
$$;

3。 `AverageWeight:`

from django.db.models.aggregates import Func
from django.db.models.fields import FloatField

class AverageWeight(Func):
    function = 'average_weight'

    def __init__(self, *expressions):
        super(AverageWeight, self).__init__(*expressions, output_field=FloatField())

在您看来：

ExchangeRate.objects.all().filter(
        (
            Q(start_date__lt=start_date) & 
            Q(end_date__gt=start_date)
        ) | (
            Q(start_date__gte=start_date) & 
            Q(start_date__lt=end_date) & 
            Q(end_date__gt=start_date) 
        )
).annotate(
    currency_from_name = 'currency_from__name', 
    currency_to_name = 'currency_to__name',
    weight_exchange = AverageWeight(
        F('exchange_rate'),
        start_date,
        end_date,
        F('start_date'),
        F('end_date'),
    )
).values(  # GROUP BY
    'currency_from_name',
    'currency_to_name'
).aggregate(
    F('currency_from_name'), 
    F('currency_to_name'), 
    Avg('weight_exchange')
)

计算时间段的平均汇率

Calculate average exchange rate for time period

django

postgresql

django-models

django-queryset

django-aggregation

1。 `months_between()`:

2。 `average_weight():`

3。 `AverageWeight:`

在您看来：

计算时间段的平均汇率

Calculate average exchange rate for time period

django

postgresql

django-models

django-queryset

django-aggregation

1。 months_between():

2。 average_weight():

3。 AverageWeight:

在您看来：

1。 `months_between()`:

2。 `average_weight():`

3。 `AverageWeight:`