darkhelm/notifications-api
1
0
Fork 0
mirror of https://github.com/GSA/notifications-api.git synced 2026-02-01 15:46:07 -05:00
Code Issues Packages Projects Releases Wiki Activity

start InboundSmsDao

Browse Source
This commit is contained in:
Kenneth Kehl
2024-10-17 12:58:35 -07:00
parent 0f1d70f593
commit af22cbcab9
1 changed files with 9 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
app/dao/inbound_sms_dao.py
View File

@@ -1,5 +1,5 @@
from flask import current_app from flask import current_app
from sqlalchemy import and_, desc, select from sqlalchemy import and_, desc, func, select
from sqlalchemy.dialects.postgresql import insert from sqlalchemy.dialects.postgresql import insert
from sqlalchemy.orm import aliased from sqlalchemy.orm import aliased
@@ -60,12 +60,16 @@ def dao_get_paginated_inbound_sms_for_service_for_public_api(
def dao_count_inbound_sms_for_service(service_id, limit_days): def dao_count_inbound_sms_for_service(service_id, limit_days):
stmt = select(InboundSms).filter( stmt = (
InboundSms.service_id == service_id, select(func.count())
InboundSms.created_at >= midnight_n_days_ago(limit_days), .select_from(InboundSms)
.filter(
InboundSms.service_id == service_id,
InboundSms.created_at >= midnight_n_days_ago(limit_days),
)
) )
result = db.session.execute(stmt).scalar() result = db.session.execute(stmt).scalar()
return result.rowcount return result
def _insert_inbound_sms_history(subquery, query_limit=10000): def _insert_inbound_sms_history(subquery, query_limit=10000):