16 lines
1.0 KiB
Python
16 lines
1.0 KiB
Python
from db import connect
|
|
import pathlib,json,decimal,collections
|
|
p=pathlib.Path(__file__).parent
|
|
inserted=json.loads((p/'inserted.json').read_text())
|
|
c=connect();q=c.cursor()
|
|
q.execute("SELECT vin,stat_date,source_key,daily_mileage_km,latest_total_mileage_km FROM vehicle_daily_mileage_source WHERE source_ip='manual-saige-excel' AND stat_date BETWEEN '2026-07-01' AND '2026-08-31'")
|
|
actual={(r['vin'],str(r['stat_date']),r['source_key']):r for r in q.fetchall()}
|
|
months=collections.defaultdict(lambda:dict(rows=0,total_km=decimal.Decimal(0)))
|
|
for r in inserted:
|
|
a=actual[(r['vin'],r['date'],r['source_key'])]
|
|
assert a['daily_mileage_km']==decimal.Decimal(r['km']) and a['latest_total_mileage_km'] is None
|
|
m=months[r['date'][:7]];m['rows']+=1;m['total_km']+=a['daily_mileage_km']
|
|
v=dict(verified_rows=len(inserted),months=dict(months),verified_total_km=sum((m['total_km'] for m in months.values()),decimal.Decimal(0)))
|
|
(p/'verification.json').write_text(json.dumps(v,default=str,ensure_ascii=False,indent=2))
|
|
print(json.dumps(v,default=str,ensure_ascii=False));c.close()
|