Skip to content

Commit 96d22e7

Browse files
committed
fix street_and_number and apartment of volgistics
1 parent edbb0a4 commit 96d22e7

File tree

1 file changed

+8
-4
lines changed

1 file changed

+8
-4
lines changed

src/server/datasource_manager.py

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,11 @@ def volgistics_address(street, index):
7676

7777
if isinstance(street, str):
7878
if " " in street:
79-
result = street.split()[index]
79+
if index == 1:
80+
result = " ".join(street.split()[1:])
81+
else:
82+
result = street.split()[index]
83+
8084

8185
return result
8286

@@ -94,7 +98,7 @@ def normalize_phone_number(number):
9498
"first_name": "first_name",
9599
"last_name": "last_name",
96100
"email": "email",
97-
"mobile": lambda df: df["mobile"].combine_first(df["phone"]).apply(normalize_phone_number),
101+
"mobile": lambda df: df["mobile"].combine_first(df["phone"]),
98102
"street_and_number": "mailing_street",
99103
"apartment": "mailing_street",
100104
"city": "mailing_city",
@@ -116,7 +120,7 @@ def normalize_phone_number(number):
116120
"first_name": "firstname",
117121
"last_name": "lastname",
118122
"email": "email",
119-
"mobile": lambda df: df["phone"].apply(normalize_phone_number),
123+
"mobile": lambda df: df["phone"],
120124
"street_and_number": "street",
121125
"apartment": "apartment",
122126
"city": "city",
@@ -131,7 +135,7 @@ def normalize_phone_number(number):
131135
"first_name": "first_name",
132136
"last_name": "last_name",
133137
"email": "email",
134-
"mobile": lambda df: df["cell"].combine_first(df["home"]).apply(normalize_phone_number),
138+
"mobile": lambda df: df["cell"].combine_first(df["home"]),
135139
"street_and_number": lambda df: df["street_1"].apply(volgistics_address, index=1),
136140
"apartment": lambda df: df["street_1"].apply(volgistics_address, index=0),
137141
"city": "city",

0 commit comments

Comments
 (0)