增加直接读取数据库写入redis

realtime_dispatch.py

@@ -18,12 +18,50 @@ from core.dispatcher import Dispatcher
 from core.schedule import PreSchedule
 from data.dispatchInfo import DispatchInfo
 
+
+def direct2redis():
+    """
+    直接读取数据库写入redis
+    :return: None
+    """
+    # 清空数据库缓存
+    session_mysql.commit()
+    session_mysql.flush()
+
+    # 清空数据库缓存
+    session_postgre.commit()
+    session_postgre.flush()
+
+    truck_disp = {}
+    for item in session_mysql.query(DispatchSetting).all():
+        if item.truck_id not in truck_disp:
+            record = {"truckId": item.truck_id}
+            record["id"] = item.id
+            record["exactorId"] = item.exactor_id
+            record["dumpId"] = item.dump_id
+            record["loadAreaId"] = item.load_area_id
+            record["unloadAreaId"] = item.unload_area_id
+            record["groupId"] = item.group_id
+            record["isdeleted"] = False
+            record["isTemp"] = False
+            record["haulFlag"] = -1
+            record["groupName"] = item.group_id
+
+            logger.info("调度结果")
+            logger.info(record)
+            redis5.set(item.truck_id, str(json.dumps(record)))
+
+
 def process(dispatcher):
     """
     周期调度进程
     :param dispatcher:  (Dispatch Class) 矿卡调度类对象
     :return: None
     """
+
+    # # 直接读取数据库写入redis
+    # direct2redis()
+
     # try:
     # 更新周期参数
     logger.info("#####################################周期更新开始#####################################")