shane/HSBCConverter
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Updating converter to pick up files copied in by nextcloud

Browse Source
This commit is contained in:
Shane Frischkorn
2022-09-23 15:06:20 +10:00
parent ed85763ff5
commit 8512c5eaac
1 changed files with 25 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

45
converter.py
View File

@@ -153,34 +153,39 @@ class Handler(watchdog.events.PatternMatchingEventHandler):
logging.info("file copy has now finished") logging.info("file copy has now finished")
with open(event.src_path, 'r') as file: with open(event.src_path, 'r') as file:
qfx = OfxParser.parse(file, fail_fast=False) try:
statement, acct_name = Handler.get_statement_from_qfx(qfx) qfx = OfxParser.parse(file, fail_fast=False)
statement, acct_name = Handler.get_statement_from_qfx(qfx)
path = Path(event.src_path) path = Path(event.src_path)
path.resolve() path.resolve()
converted_dir = path.parent / CONVERTED_DIR converted_dir = path.parent / CONVERTED_DIR
if not converted_dir.exists(): if not converted_dir.exists():
converted_dir.mkdir() converted_dir.mkdir()
out_file = str(path.parent / CONVERTED_DIR / (acct_name + '-' + qfx.signon.dtserver + '.csv')) out_file = str(path.parent / CONVERTED_DIR / (acct_name + '-' + qfx.signon.dtserver + '.csv'))
Handler.write_csv(statement, out_file) Handler.write_csv(statement, out_file)
#Now move the input file to backup #Now move the input file to backup
archive_file_dir = path.parent / BACKUP_DIR archive_file_dir = path.parent / BACKUP_DIR
archive_file = (path.stem + '{:04d}' + path.suffix) archive_file = (path.stem + '{:04d}' + path.suffix)
destination = Handler.unique_path(archive_file_dir, archive_file) destination = Handler.unique_path(archive_file_dir, archive_file)
if not archive_file_dir.exists(): if not archive_file_dir.exists():
archive_file_dir.mkdir() archive_file_dir.mkdir()
if not destination.exists(): if not destination.exists():
path.replace(destination) path.replace(destination)
except:
logging.info("Failed to process {}".format(event.src_path))
logging.info("Processing successfully finished for {}".format(event.src_path)) logging.info("Processing successfully finished for {}".format(event.src_path))
def on_created(self, event): def on_modified(self, event):
logging.info('{} on {}'.format(event.event_type, event.src_path)) logging.info('Found modified file: {}'.format(event.src_path))
self.on_created(event)
if __name__ == "__main__": if __name__ == "__main__":