|
|
@@ -0,0 +1,39 @@
|
|
|
+from datetime import timedelta
|
|
|
+
|
|
|
+from db import get_session
|
|
|
+import re
|
|
|
+from sqlalchemy import text
|
|
|
+
|
|
|
+
|
|
|
+def main():
|
|
|
+ db = next(get_session())
|
|
|
+ q = db.execute(text("SELECT * FROM dbo.Forderungen_Kommentar_Rohdaten"))
|
|
|
+
|
|
|
+ for row in q.fetchall():
|
|
|
+ for i, r in enumerate(row.Kommentar.split("\n"), 1):
|
|
|
+ comment_date = row.Timestamp + timedelta(minutes=i)
|
|
|
+ comment_user = row.Benutzer_ID
|
|
|
+ r = r.replace("'", "")
|
|
|
+ db.execute(
|
|
|
+ text(
|
|
|
+ "INSERT INTO dbo.Forderungen_Kommentar "
|
|
|
+ f"VALUES ('{row.Client_DB}', '{row.Beleg_Nr}', '{comment_date}', '{comment_user}', '{r}')"
|
|
|
+ )
|
|
|
+ )
|
|
|
+ # m = re.search(r"(\d\d\.\d\d?)\.?[\/\s](\w+)", r)
|
|
|
+ # if m:
|
|
|
+ # comment_date = m[1]
|
|
|
+ # comment_user = m[2]
|
|
|
+ # else:
|
|
|
+ # if r.startswith("EWB"):
|
|
|
+ # continue
|
|
|
+ # az = re.search(r"^AZ\:?\s(\d+\/\d+)", r)
|
|
|
+ # if az:
|
|
|
+ # continue
|
|
|
+ # print(r)
|
|
|
+
|
|
|
+ db.commit()
|
|
|
+
|
|
|
+
|
|
|
+if __name__ == "__main__":
|
|
|
+ main()
|