Skip to content

Commit

Permalink
limit positions to set elevation for to last 10 days
Browse files Browse the repository at this point in the history
  • Loading branch information
swiffer committed Sep 28, 2024
1 parent 6871ef7 commit 1c4860a
Showing 1 changed file with 26 additions and 14 deletions.
40 changes: 26 additions & 14 deletions lib/teslamate/log.ex
Original file line number Diff line number Diff line change
Expand Up @@ -173,25 +173,37 @@ defmodule TeslaMate.Log do
def get_positions_without_elevation(min_id \\ 0, opts \\ []) do
limit = Keyword.get(opts, :limit, 100)

date_earliest =
cond do
min_id == 0 ->
DateTime.add(DateTime.utc_now(), -10, :day)

true ->
DateTime.from_iso8601("2003-07-01T00:00:00Z")
end

non_streamed_drives =
Repo.all(
from d in subquery(
from p in Position,
select: %{
drive_id: p.drive_id,
streamed_count:
count()
|> filter(not is_nil(p.odometer) and is_nil(p.ideal_battery_range_km))
},
where: not is_nil(p.drive_id),
group_by: p.drive_id
),
select: d.drive_id,
where: d.streamed_count == 0
from p in Position,
select: %{
drive_id: p.drive_id
},
join: d in assoc(p, :drive),
where:
p.date > ^date_earliest and
d.start_date > ^date_earliest,
having:
count()
|> filter(not is_nil(p.odometer) and is_nil(p.ideal_battery_range_km)) > 0,
group_by: p.drive_id
)

Position
|> where([p], p.id > ^min_id and is_nil(p.elevation) and p.drive_id in ^non_streamed_drives)
|> where(
[p],
p.id > ^min_id and is_nil(p.elevation) and p.drive_id in ^non_streamed_drives and
p.date > ^date_earliest
)
|> order_by(asc: :id)
|> limit(^limit)
|> Repo.all()
Expand Down

0 comments on commit 1c4860a

Please sign in to comment.