feat: 共通処理を作り変えたため、いらないモジュールを削除

ecs/jskult-transfer-receive-file/src/batch/batch_functions.py

@@ -1,100 +0,0 @@
-"""バッチ処理の共通関数"""
-from datetime import datetime
-
-from src.db.database import Database
-from src.error.exceptions import BatchOperationException, DBException
-from src.system_var import constants
-
-
-def get_batch_statuses() -> tuple[str, str, str]:
-    """日付テーブルから、以下を取得して返す。
-    - 日次バッチ処理中フラグ
-    - dump取得状況区分
-    - 処理日（YYYY/MM/DD）
-
-    Raises:
-        BatchOperationException: 日付テーブルが取得できないとき、何らかのエラーが発生したとき
-
-    Returns:
-        tuple[str, str]: [0]日次バッチ処理中フラグ、dump取得状況区分
-    """
-    db = Database.get_instance()
-    sql = 'SELECT bch_actf, dump_sts_kbn, src07.get_syor_date() AS syor_date FROM src07.hdke_tbl'
-    try:
-        db.connect()
-        hdke_tbl_result = db.execute_select(sql)
-    except DBException as e:
-        raise BatchOperationException(e)
-    finally:
-        db.disconnect()
-
-    if len(hdke_tbl_result) == 0:
-        raise BatchOperationException('日付テーブルが取得できませんでした')
-
-    # 必ず1件取れる
-    hdke_tbl_record = hdke_tbl_result[0]
-    batch_processing_flag = hdke_tbl_record['bch_actf']
-    dump_status_kbn = hdke_tbl_record['dump_sts_kbn']
-    syor_date = hdke_tbl_record['syor_date']
-    # 処理日を文字列に変換する
-    syor_date_str = datetime.strftime(syor_date, '%Y/%m/%d')
-
-    return batch_processing_flag, dump_status_kbn, syor_date_str
-
-
-def update_batch_processing_flag_in_processing() -> None:
-    """バッチ処理中フラグを処理中に更新する
-
-    Raises:
-        BatchOperationException: DB操作の何らかのエラー
-    """
-    db = Database.get_instance()
-    sql = """\
-    UPDATE src07.hdke_tbl
-    SET
-        bch_actf = :in_processing,
-        updater = CURRENT_USER(),
-        update_date = NOW()
-    """
-    try:
-        db.connect()
-        db.to_jst()
-        db.execute(
-            sql, {'in_processing': constants.BATCH_ACTF_BATCH_IN_PROCESSING})
-    except DBException as e:
-        raise BatchOperationException(e)
-    finally:
-        db.disconnect()
-
-    return
-
-
-def update_batch_process_complete() -> None:
-    """バッチ処理を完了とし、処理日、バッチ処理中フラグ、dump処理状態区分を更新する
-
-    Raises:
-        BatchOperationException: DB操作の何らかのエラー
-    """
-    db = Database.get_instance()
-    sql = """\
-    UPDATE src07.hdke_tbl
-    SET
-        bch_actf = :batch_complete,
-        dump_sts_kbn = :dump_unprocessed,
-        syor_date = DATE_FORMAT((src07.get_syor_date() + interval 1 day), '%Y%m%d'), -- +1日
-        updater = CURRENT_USER(),
-        update_date = NOW()
-    """
-    try:
-        db.connect()
-        db.to_jst()
-        db.execute(sql, {
-            'batch_complete': constants.BATCH_ACTF_BATCH_UNPROCESSED,
-            'dump_unprocessed': constants.DUMP_STATUS_KBN_UNPROCESSED
-        })
-    except DBException as e:
-        raise BatchOperationException(e)
-    finally:
-        db.disconnect()
-
-    return