ネーミング修正

ecs/jskult-batch-daily/src/batch/ultmarc/vjsk_process.py

@@ -1,6 +1,6 @@
 """アルトマークデータ処理"""
 
-from src.aws.s3 import UltmarcBucket, VjskBucket
+from src.aws.s3 import VjskBucket
 from src.batch.common.batch_context import BatchContext
 
 from src.db.database import Database
@@ -10,14 +10,13 @@ import os.path as path
 import csv
 
 logger = get_logger('V実用消化施設データ作成処理')
-ultmarc_bucket = UltmarcBucket()
-batch_context = BatchContext.get_instance()
 
 sql_err_msg = "SQL実行エラーです。"
-vjsk_csv_file_name = 'ComInst.csv'
 
 
 def exec():
+    vjsk_csv_file_name = 'ComInst.csv'
+
     db = Database.get_instance()
     try:
         logger.info('バッチ処理を開始しました。')
@@ -32,11 +31,11 @@ def exec():
             raise e
 
         # CSVファイルの作成用のSQL実行(施設)
-        record_inst_csv = csv_data_inst_select(db)
+        record_inst = select_inst_record(db)
         # CSVファイルの作成用のSQL実行(薬局)
-        record_pharm_csv = csv_data_pharm_select(db)
+        record_pharm = select_pharm_record(db)
         # CSVファイル作成
-        csv_file_path = make_csv_data(record_inst_csv, record_pharm_csv)
+        csv_file_path = make_csv_data(record_inst, record_pharm, vjsk_csv_file_name)
 
         vjsk_bucket = VjskBucket()
         try:
@@ -54,7 +53,7 @@ def exec():
             logger.info('バックアップバケットへCSVデータをコピーできませんでした。')
             raise e
 
-        csv_count = len(record_inst_csv) + len(record_pharm_csv)
+        csv_count = len(record_inst) + len(record_pharm)
         logger.info(f'CSV出力件数: {csv_count}。')
         logger.info('バッチ処理を正常に終了しました。')
     except Exception as e:
@@ -66,8 +65,8 @@ def exec():
     return
 
 
-def csv_data_inst_select(db):
-    # CSVファイルの作成用のSQL実行(施設)
+def select_inst_record(db):
+    # CSVファイル作成用のSQL実行(施設)
     try:
         # 施設テーブル検索SQL
         sql = """\
@@ -144,8 +143,8 @@ def csv_data_inst_select(db):
         raise e
 
 
-def csv_data_pharm_select(db):
-    # CSVファイルの作成用のSQL実行(薬局)
+def select_pharm_record(db):
+    # CSVファイル作成用のSQL実行(薬局)
     try:
         # 薬局テーブル検索SQL
         sql = """\
@@ -222,7 +221,7 @@ def csv_data_pharm_select(db):
         raise e
 
 
-def make_csv_data(record_inst_csv: list, record_pharm_cs: list):
+def make_csv_data(record_inst: list, record_pharm: list, vjsk_csv_file_name: str):
     # 一時ファイルとして保存する(CSVファイル)
     try:
 
@@ -242,7 +241,7 @@ def make_csv_data(record_inst_csv: list, record_pharm_cs: list):
                     'REGIST_PRGM_ID', 'SYS_UPDATE_DATE', 'UPDATE_PRGM_ID']
 
         with open(csv_file_path, mode='w', encoding='cp932') as csv_file:
-            # ヘッダ行書き込み（くくり文字を加えない為にwriteで出力する）
+            # ヘッダ行書き込み（くくり文字をつけない為にwriterowではなく、writeを使用しています）
             csv_file.write(f"{','.join(head_str)}\n")
 
             # Shift-JIS、CRLF、価囲いありで書き込む
@@ -252,13 +251,13 @@ def make_csv_data(record_inst_csv: list, record_pharm_cs: list):
                                 )
 
             # データ部分書き込み(施設)
-            for record_inst_data in record_inst_csv:
+            for record_inst_data in record_inst:
                 record_inst_value = list(record_inst_data.values())
                 csv_data = ['' if n is None else n for n in record_inst_value]
                 writer.writerow(csv_data)
 
             # データ部分書き込み(薬局)
-            for record_pharm_data in record_pharm_cs:
+            for record_pharm_data in record_pharm:
                 record_pharm_value = list(record_pharm_data.values())
                 csv_data = ['' if n is None else n for n in record_pharm_value]
                 writer.writerow(csv_data)

ecs/jskult-batch-daily/src/jobctrl_daily.py

@@ -13,7 +13,7 @@ from src.batch.ultmarc import ultmarc_process
 from src.error.exceptions import BatchOperationException
 from src.logging.get_logger import get_logger
 from src.system_var import constants
-from src.batch.ultmarc import export_vjsk_csv_process
+from src.batch.ultmarc import vjsk_process
 
 logger = get_logger('日次処理コントロール')
 
@@ -80,7 +80,7 @@ def exec():
                 logger.info('アルトマーク取込が行われていないため、V実消化用施設データ作成処理をスキップします。')
                 return
             logger.info('V実消化用施設データ作成処理：起動')
-            export_vjsk_csv_process.exec()
+            vjsk_process.exec()
             logger.info('V実消化用施設データ作成処理：終了')
         except BatchOperationException as e:
             logger.exception(f'V実消化用施設データ作成処理エラー（異常終了）{e}')