Merge branch 'yifan' of ASJ_ADS/sync_amz_data into master

sync_amz_data/public/sp_api_client.py

@@ -1381,6 +1381,8 @@ class SpApiRequest:
         decom_df['seller_id'] = seller_id
         decom_df['country_code'] = country_code
         decom_df['insert_time'] = datetime.now()
+        decom_df['Order date'] = decom_df['Order date'].map(lambda x:'' if pd.isna(x) or x=='' else parse(x))
+        decom_df['Return request date'] = decom_df['Return request date'].map(lambda x:'' if pd.isna(x) or x=='' else parse(x))
         client = get_client(host='3.93.43.158', port=8123, username='root',
                             password='6f0eyLuiVn3slzbGWpzI')
 
@@ -1414,8 +1416,7 @@ class SpApiRequest:
         except Exception as e:
             print(e)
         client.close()
-        # print(decom_df.columns)
-        # print(decom_df)
+
         return reportid
 
     # def GET_FLAT_FILE_RETURNS_DATA_BY_RETURN_DATE(self, refresh_token,seller_id,days=-1,**kwargs):
@@ -1560,9 +1561,8 @@ class SpApiRequest:
         return base_product.get_product_pricing_for_asins(asin)
 
 if __name__ == '__main__':
-    # for days in range(-35,-2):
-    days=2
-    SpApiRequest.get_allShops("GET_SELLER_FEEDBACK_DATA",days=-days,**{})
+    for days in range(-35,-2):
+        SpApiRequest.get_allShops("GET_FLAT_FILE_RETURNS_DATA_BY_RETURN_DATE",days=days,**{})
     # SpApiRequest.listing_infoTable()
     # rel = SpApiRequest.get_catelog(account_name='AM-ZOSI-US',country=Marketplaces.US,asin='B0B8CPHSL4')
     # print(rel)