添加数据库连接判断

base/BaseCore.py

@@ -5,6 +5,7 @@ import socket
 import sys
 import time
 
+import MySQLdb
 import logbook
 import logbook.more
 import openpyxl
@@ -280,6 +281,13 @@ class BaseCore:
             charset='utf8mb4'
         )
 
+    def check_mysql_conn(self,conn):
+        try:
+            conn.ping()
+            return True
+        except:
+            return False
+
     def close(self):
         try:
             self.cursor.close()