同步汇率

basic/sync.py

@@ -201,7 +201,8 @@ class ExrateSync(DataSync):
                         'date': dt.fromtimestamp(x['date'] / 1000),
                         'close': x['close'],
                     } for x in response['body']['content']]
-                    re.batch_insert(save_dates)
+                    if save_dates:
+                        re.batch_insert(save_dates)
                 except Exception as e:
                     logger.exception(f'url[{url}] store data failed')
                     raise e

basic/test_case.py

 import logging
 import unittest
+from typing import List
 
 import pandas as pd
 from py_jftech import autowired, parse_date, to_str
@@ -34,9 +35,14 @@ class BasicTest(unittest.TestCase):
         sync.do_sync()
 
     @autowired(names={'sync': 'exrate-sync'})
-    def test_navs_sync(self, sync: DataSync = None):
+    def test_exrate_sync(self, sync: DataSync = None):
         sync.do_sync()
 
+    @autowired
+    def test_sync(self, syncs: List[DataSync] = None):
+        for sync in syncs:
+            sync.do_sync()
+
     @autowired(names={'report': 'navs-report'})
     def test_export_navs(self, report: RoboReportor = None):
         result = report.load_report()