renyupeng před 3 roky
rodič
revize
82ed9c4c6d

+ 7 - 0
Apietl/task/BytedanceMaterialFristCostDateUpdate.py

@@ -8,6 +8,8 @@
 # @Tel 1501435553
 import datetime
 import logging
+
+from Apietl.conn.TidbConn import TidbConn
 from Apietl.conn.TidbProConn import TidbProConn
 from Apietl.utlis.Utils import Utils
 
@@ -15,6 +17,7 @@ from Apietl.utlis.Utils import Utils
 class MaterialFristCostDateUpdate:
     def __init__(self):
         self.conn = TidbProConn.get_connection()
+        self.Innerconn = TidbConn.get_connection()
         self.parm = Utils.get_args()
         self.start_time = self.parm[0]
         self.end_time = self.parm[1]
@@ -42,8 +45,12 @@ on a.signature=b.signature
             """.format(start_time=self.start_time, end_time=self.end_time)
             print(sql)
             TidbProConn.upsert(conn=self.conn, sql_buff=sql)
+            TidbConn.upsert(conn=self.Innerconn, sql_buff=sql)
             self.conn.commit()
+            self.Innerconn.commit()
             TidbProConn.conn_close(self.conn)
+            TidbConn.conn_close(self.Innerconn)
+
             return 0
         except Exception as e:
             logging.error(e)

+ 6 - 0
Apietl/task/MaterialFristCostDateUpdate.py

@@ -8,6 +8,8 @@
 # @Tel 1501435553
 import datetime
 import logging
+
+from Apietl.conn.TidbConn import TidbConn
 from Apietl.conn.TidbProConn import TidbProConn
 from Apietl.utlis.Utils import Utils
 
@@ -15,6 +17,7 @@ from Apietl.utlis.Utils import Utils
 class MaterialFristCostDateUpdate:
     def __init__(self):
         self.conn = TidbProConn.get_connection()
+        self.Innerconn = TidbConn.get_connection()
         self.parm = Utils.get_args()
         self.start_time = self.parm[0]
         self.end_time = self.parm[1]
@@ -42,8 +45,11 @@ on a.signature=b.signature
             """.format(start_time=self.start_time, end_time=self.end_time)
             print(sql)
             TidbProConn.upsert(conn=self.conn, sql_buff=sql)
+            TidbConn.upsert(conn=self.Innerconn, sql_buff=sql)
             self.conn.commit()
+            self.Innerconn.commit()
             TidbProConn.conn_close(self.conn)
+            TidbConn.conn_close(self.Innerconn)
             return 0
         except Exception as e:
             logging.error(e)