diff --git a/ecs/jskult-batch-daily/src/batch/dcf_inst_merge/integrate_dcf_inst_merge.py b/ecs/jskult-batch-daily/src/batch/dcf_inst_merge/integrate_dcf_inst_merge.py
index 20ac5fcc..832cc20c 100644
--- a/ecs/jskult-batch-daily/src/batch/dcf_inst_merge/integrate_dcf_inst_merge.py
+++ b/ecs/jskult-batch-daily/src/batch/dcf_inst_merge/integrate_dcf_inst_merge.py
@@ -40,7 +40,7 @@ def _set_enabled_dct_inst_merge(db: Database) -> list[dict]:
     if _update_dcf_inst_merge(db, 0) > 0:
         # DCF施設統合マスタの過去分の洗い替え
         for row in enabled_dst_inst_merge_records:
-            _update_dcf_inst_cd_new(db, row['dup_opp_cd'], row['dcf_inst_cd'])
+            _update_dcf_inst_cd_new(db, row['dup_opp_cd'], row['dcf_inst_cd'], 0)
 
     return enabled_dst_inst_merge_records
 
@@ -52,7 +52,7 @@ def _set_disabled_dct_inst_merge(db: Database):
     if _update_dcf_inst_merge(db, 1) > 0:
         # DCF施設統合マスタの過去分の洗い替え
         for row in disabled_dst_inst_merge_records:
-            _update_dcf_inst_cd_new(db, row['dcf_inst_cd'], row['dup_opp_cd'])
+            _update_dcf_inst_cd_new(db, row['dcf_inst_cd'], row['dup_opp_cd'], 1)
 
 
 def _add_ult_ident_presc(db: Database, enabled_dst_inst_merge_records: list[dict]):
@@ -356,15 +356,16 @@ def _update_dcf_inst_merge(db: Database, muko_flg: int) -> int:
         logging_sql(logger, sql)
         logger.info(f'DCF施設統合マスタの有効データを{log_message} 成功, {res.rowcount} 行更新 ({elapsed_time.of})')
     except Exception as e:
-        logger.debug(f'DCF施設統合マスタの{log_message} 失敗')
+        logger.debug(f'DCF施設統合マスタの有効データを{log_message} 失敗')
         raise e
 
     return res.rowcount
 
 
-def _update_dcf_inst_cd_new(db: Database, dcf_inst_cd_new_after: str, dcf_inst_cd_new_before: str):
+def _update_dcf_inst_cd_new(db: Database, dcf_inst_cd_new_after: str, dcf_inst_cd_new_before: str, muko_flg: int):
     # dcf_inst_mergeをUPDATE
     try:
+        log_message = '' if muko_flg == 0 else '戻し'
         elapsed_time = ElapsedTime()
         sql = """
             UPDATE
@@ -384,9 +385,9 @@ def _update_dcf_inst_cd_new(db: Database, dcf_inst_cd_new_after: str, dcf_inst_c
         }
         res = db.execute(sql, params)
         logging_sql(logger, sql)
-        logger.info(f'移行先DCF施設コードの更新に成功, {res.rowcount} 行更新 ({elapsed_time.of})')
+        logger.info(f'移行先DCF施設コードの{log_message}更新に成功, {res.rowcount} 行更新 ({elapsed_time.of})')
     except Exception as e:
-        logger.debug('移行先DCF施設コードの更新に失敗')
+        logger.debug(f'移行先DCF施設コードの{log_message}更新に失敗')
         raise e