diff --git a/apps/enm/services.py b/apps/enm/services.py
index 8a483b3a..c6aa039b 100644
--- a/apps/enm/services.py
+++ b/apps/enm/services.py
@@ -181,7 +181,7 @@ def cache_mpoints(mpointId: str = ''):
     # print(cache.get('mpoint_K_IP2_MM_SC_IW14'))
 
 test_data = {"PNs":{"1":"V","2":"T","3":"Q"},"PVs":{"1":-725,"2":"2024-04-08 13:43:53.140","3":192},"Objs":[{"N":"IP2_MM_IW3"},{"N":"IP2_MM_IW4","1":-6386},{"N":"IP2_MM_IW5","1":-7835},{"N":"IP2_MM_IW7","1":-6864},{"N":"IP2_MM_IW15","1":29},{"N":"IP2_MM_SC_IW3","1":337},{"N":"IP2_MM_SC_IW13","1":-5511,"2":24},{"N":"IP2_MM_SC_IW14","1":-4640,"2":24},{"N":"IP2_MM_SC_IW15","1":-5586,"2":24},{"N":"IP2_MM_SC_IW16","1":-6634,"2":24},{"N":"IP2_MM_SC_IW17","1":-2768,"2":24},{"N":"IP2_MM_SC_IW18","1":-2946,"2":24},{"N":"IP2_MM_SC_IW19","1":-2550,"2":24},{"N":"IP2_MM_SC_IW20","1":-1512,"2":24},{"N":"IP2_MM_SC_IW21","1":-1775,"2":24},{"N":"IP2_MM_SC_IW22","1":-194,"2":24},{"N":"IP2_MM_SC_IW23","1":-366,"2":24},{"N":"IP2_MM_SC_IW24","1":-9291,"2":24},{"N":"IP2_MM_SC_IW25","1":-6888,"2":24},{"N":"IP2_MM_SC_IW26","1":-2360,"2":24},{"N":"IP2_MM_SC_IW29","1":164,"2":24},{"N":"IP2_MM_SC_IW30","1":914,"2":24},{"N":"IP2_MM_SC_IW31","1":849,"2":24},{"N":"IP2_MM_SC_IW37","1":-125,"2":24},{"N":"IP2_MM_SC_IW38","1":-3009,"2":24},{"N":"IP2_MM_SC_IW40","1":-1394,"2":24},{"N":"IP2_MM_SC_IW43","1":758,"2":24},{"N":"IP3_SC_IW1","1":11557,"2":107},{"N":"IP3_SC_IW2","1":7624,"2":107},{"N":"IP3_SC_IW6","1":11159,"2":107},{"N":"IP3_SC_IW7","1":8073,"2":107},{"N":"IP3_SC_IW9","1":4490,"2":107},{"N":"IP3_SC_IW10","1":5437,"2":107},{"N":"IP3_SC_IW11","1":9244,"2":107},{"N":"IP3_SC_IW12","1":7886,"2":107},{"N":"IP3_SC_IW13","1":-2962,"2":107},{"N":"IP3_SC_IW14","1":-159,"2":107},{"N":"IP3_SC_IW26","1":15,"2":107},{"N":"IP3_SC_IW27","1":15,"2":107}]}
-def insert_mplogx_from_king_realdata(data: dict, is_offset=True):
+def insert_mplogx_from_king_mqtt(data: dict, is_offset=True):
     """
     从king mqtt数据插入超表
     """
@@ -198,13 +198,13 @@ def insert_mplogx_from_king_realdata(data: dict, is_offset=True):
             start = i * chunk_size
             end = min(start + chunk_size, len_objs)
             chunk = objs[start:end]
-            futures.append(executor.submit(insert_mplogx_from_king_realdata_chunk, chunk, pvs, is_offset))
+            futures.append(executor.submit(insert_mplogx_from_king_mqtt_chunk, chunk, pvs, is_offset))
         concurrent.futures.wait(futures)
         # for future in futures:
         #     print(future.result(), end=', ')
 
 @auto_log('亚控存库')
-def insert_mplogx_from_king_realdata_chunk(objs: list, pvs: dict, is_offset=True):
+def insert_mplogx_from_king_mqtt_chunk(objs: list, pvs: dict, is_offset=True):
     """
     分批存库,  亚控 38.00,00000.11011 版本偏移只是时间戳偏移。另外其实可以不在乎
     """
diff --git a/apps/mqtt/client.py b/apps/mqtt/client.py
index c1bf6b96..775e1634 100644
--- a/apps/mqtt/client.py
+++ b/apps/mqtt/client.py
@@ -6,7 +6,7 @@ import logging
 import json
 from django.conf import settings
 import traceback
-from apps.enm.services import insert_mplogx_from_king_realdata
+from apps.enm.services import insert_mplogx_from_king_mqtt
 
 BASE_DIR = os.path.dirname(os.path.dirname(os.path.dirname(os.path.abspath(__file__))))
 sys.path.insert(0, BASE_DIR)
@@ -29,7 +29,7 @@ def on_message(mqttc: mqtt, userdata, msg):
     topic = msg.topic
     if topic == 'datachange_S_KIO_Project':
         payload = json.loads(msg.payload)
-        insert_mplogx_from_king_realdata(payload, settings.KING_MQTT_OFFSET)
+        insert_mplogx_from_king_mqtt(payload, settings.KING_MQTT_OFFSET)
 
 def start_mqtt():
     if settings.MQTT_ENABLED: