Add: unpaid_maestro_checker.py

src/web/python/batch/db_manager.py

@@ -11,31 +11,18 @@ class DBConnectParams:
         self.db = 'chocomae'
         self.charset = 'utf8'
 
-    def setHost(self, value):
-        self.host = value
-
-    def setPort(self, value):
-        self.port = value
-
-    def setUser(self, value):
-        self.user = value
-
-    def setPassword(self, value):
-        self.password = value
-
-    def setDB(self, value):
-        self.db = value
-
-    def setCharset(self, value):
-        self.charset = value
-
 
 class DBManager:
     def __init__(self):
+        print('init')
         self.conn = None
         self.curs = None
         super().__init__()
 
+    def close(self):
+        print('close')
+        self.conn.close()
+
     def connect(self, dbParam):
         self.conn = pymysql.connect(
             host=dbParam.host, port=dbParam.port,
@@ -43,6 +30,27 @@ class DBManager:
             db=dbParam.db, charset=dbParam.charset)
         self.curs = self.conn.cursor(pymysql.cursors.DictCursor)
 
+    def select(self, sql):
+        self.curs.execute(sql)
+        rows = self.curs.fetchall()
+        return rows
+
+    def insert(self, sql, params):
+        self.executeSql(sql, params)
+
+
+    def update(self, sql, params):
+        self.executeSql(sql, params)
+
+
+    def delete(self, sql, params):
+        self.executeSql(sql, params)
+
+    def executeSql(self, sql, params):
+        self.curs.execute(sql, params)
+        self.conn.commit()
+
+
     def getWaitingAccountList(self):
         sql = "select * from maestro"
         self.curs.execute(sql)
@@ -63,4 +71,4 @@ class DBManager:
                 unregisteredAccountCount += 1
 
         # print(unregisteredAccountCount)
-        self.conn.close()
+        # self.conn.close()

src/web/python/batch/db_setting.py

@@ -1,9 +1,13 @@
 class DBSetting:
     host = 'localhost'
-    # port = 3306    # service, test server
-    port = 8889    # mac
     user = 'jisangs'
-    # password = '52napark!' # service, test server
-    password = 'Fr12nds95' # mac
     db = 'chocomae'
     charset = 'utf8'
+
+    # service, test server
+    # port = 3306
+    # password = '52napark!'
+
+    # mac
+    port = 8889
+    password = 'Fr12nds95'

src/web/python/batch/test_python.py

@@ -1,11 +1,12 @@
-from db_setting import DBSetting
+from unpaid_maestro_checker import UnpaidMaestroChecker
-from db_manager import DBConnectParams, DBManager
 
-dbParams = DBConnectParams()
+checker = UnpaidMaestroChecker()
-dbParams.setPort(DBSetting.port)
+week1MaestroList = checker.getUnpaid7daysMaestroList()
-dbParams.setUser(DBSetting.user)
+for maestroData in week1MaestroList:
-dbParams.setPassword(DBSetting.password)
+    maestroId = maestroData['MaestroID']
-
+    name = maestroData['Name']
-dbMan = DBManager()
+    email = maestroData['Email']
-dbMan.connect(dbParams)
+    registeredDateTime = maestroData['AcceptClausesDateTime']
-dbMan.getWaitingAccountList()
+    availableDateTime = maestroData['AvailableActivateDateTime']
+    print("{0}, {1}, {2}, {3}, {4}" \
+          .format(maestroId, name, email, availableDateTime, registeredDateTime))

src/web/python/batch/unpaid_maestro_checker.py

@@ -0,0 +1,23 @@
+from db_setting import DBSetting
+from db_manager import DBConnectParams, DBManager
+
+class UnpaidMaestroChecker:
+    dbParams = None
+    dbMan = None
+
+    unpaid7daysSql = "select * from maestro \
+        where DATE(NOW()) - INTERVAL 7 DAY > AcceptClausesDateTime AND ActivateStatus = 0"
+
+    def __init__(self):
+        self.dbParams = DBConnectParams()
+        self.dbParams.port = DBSetting.port
+        self.dbParams.user = DBSetting.user
+        self.dbParams.password = DBSetting.password
+
+        self.dbMan = DBManager()
+        self.dbMan.connect(self.dbParams)
+
+    def getUnpaid7daysMaestroList(self):
+        day7MaestroList = self.dbMan.select(self.unpaid7daysSql)
+        self.dbMan.close()
+        return day7MaestroList