feat: 将干扰CSV输出改为GBK
This commit is contained in:
@@ -38,7 +38,11 @@ class PipelineTest(unittest.TestCase):
|
||||
self.assertEqual(result.name, TARGET_KEY)
|
||||
converted = sorted((result / "converted").glob("*.csv"))
|
||||
self.assertEqual(len(converted), 7)
|
||||
with (result / f"interference_summary_{TARGET_KEY}.csv").open(encoding="utf-8-sig", newline="") as file:
|
||||
summary_path = result / f"interference_summary_{TARGET_KEY}.csv"
|
||||
summary_bytes = summary_path.read_bytes()
|
||||
self.assertFalse(summary_bytes.startswith(b"\xef\xbb\xbf"))
|
||||
self.assertIn("小区".encode("gbk"), summary_bytes)
|
||||
with summary_path.open(encoding="gbk", newline="") as file:
|
||||
rows = list(csv.DictReader(file))
|
||||
self.assertEqual(len(rows), 7)
|
||||
self.assertEqual(
|
||||
@@ -94,7 +98,7 @@ class PipelineTest(unittest.TestCase):
|
||||
self.assertEqual(manifest["database"]["metric_time"], "2026-07-31 10:00:00")
|
||||
self.assertEqual(len(store.rows), 7)
|
||||
self.assertEqual(history.path, "/history/2026-07-31/干扰数据处理结果_20260731100000.csv")
|
||||
archived_rows = list(csv.DictReader(io.StringIO(history.payload.decode("utf-8-sig"))))
|
||||
archived_rows = list(csv.DictReader(io.StringIO(history.payload.decode("gbk"))))
|
||||
self.assertEqual(list(archived_rows[0]), list(main.SUMMARY_HEADER))
|
||||
self.assertEqual(len(archived_rows), 7)
|
||||
|
||||
@@ -321,7 +325,7 @@ class PipelineTest(unittest.TestCase):
|
||||
self.assertIsNone(result)
|
||||
self.assertEqual(store.rows_for_time_calls, 1)
|
||||
self.assertEqual(history.path, "/history/2026-07-31/干扰数据处理结果_20260731100000.csv")
|
||||
archived_rows = list(csv.DictReader(io.StringIO(history.payload.decode("utf-8-sig"))))
|
||||
archived_rows = list(csv.DictReader(io.StringIO(history.payload.decode("gbk"))))
|
||||
self.assertEqual(archived_rows, [stored_row])
|
||||
|
||||
def test_api_history_store_creates_date_directory_and_uploads_csv(self) -> None:
|
||||
|
||||
Reference in New Issue
Block a user