junte/Model
1
0
Fork 0
mirror of https://github.com/Hestia-Homes/Model.git synced 2026-06-30 13:10:47 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

adding new logic to land registry match

Browse source
This commit is contained in:
Khalim Conn-Kowlessar 2024-07-28 15:33:57 +01:00
parent 2174a85a8b
commit b63ab89e89
1 changed files with 26 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

26
etl/customers/goldman/property_ownership.py
View file

@ -689,6 +689,15 @@ def app():
lr_filtered["saon_match2"] = lr_filtered["saon"].apply( lr_filtered["saon_match2"] = lr_filtered["saon"].apply(
lambda x: False if pd.isnull(x) else house_number_match(x, match["house_number"]) lambda x: False if pd.isnull(x) else house_number_match(x, match["house_number"])
) )
# We check if we have a flat
match_flat_number = re.match("flat (\d+)", match["epc_address1"].lower())
lr_filtered["saon_match3"] = False
if match_flat_number is not None:
# Get out the match
match_flat_number = "flat " + match_flat_number.group(1)
lr_filtered["saon_match3"] = lr_filtered["saon"].apply(
lambda x: False if pd.isnull(x) else x == match_flat_number
)
if all_paon_equal and all_saon_equal and all_street_equal: if all_paon_equal and all_saon_equal and all_street_equal:
# Take the newest record # Take the newest record
@ -705,6 +714,23 @@ def app():
continue continue
elif any(lr_filtered["saon_match2"]): elif any(lr_filtered["saon_match2"]):
lr_filtered = lr_filtered[lr_filtered["saon_match2"]] lr_filtered = lr_filtered[lr_filtered["saon_match2"]]
all_saon_equal, all_paon_equal, all_street_equal = check_equalities(lr_filtered)
if all_paon_equal and all_saon_equal and all_street_equal:
# Filter on the newest record
lr_filtered = lr_filtered.sort_values("date_of_transfer", ascending=False)
lr_filtered = lr_filtered.head(1)
if lr_filtered.shape[0] == 1:
land_registry_matches.append(
{
"uprn": match["UPRN"],
"transaction_id": lr_filtered['transaction_id'].values[0],
"price": lr_filtered["price"].values[0],
"date_of_transfer": lr_filtered["date_of_transfer"].values[0],
}
)
continue
elif any(lr_filtered["saon_match3"]):
lr_filtered = lr_filtered[lr_filtered["saon_match3"]]
if lr_filtered.shape[0] == 1: if lr_filtered.shape[0] == 1:
land_registry_matches.append( land_registry_matches.append(
{ {