local time

Dockerfile

@@ -24,4 +24,4 @@ ADD . /app
 WORKDIR /app
 RUN pip install -r requirements.txt
 RUN rm -rf /var/lib/apt/lists/* && rm -rf /root/.cache/pip/
-CMD ["python", "app.py"]
+CMD ["python", "cron-app.py"]
\ No newline at end of file

cron-app.py

-import os
-from collections import namedtuple
-
-os.environ['config'] = '{"MONGO_URI": "mongodb://svc-ilens:svc2345@192.168.0.220:21017", "MONGO_DB":"ilens_wps", ' \
-                       '"MONGO_COLL": "serviceConfiguration"} '
-from scripts.pull_docs_mongo import PullEvents
-from scripts.sqlite_ingestor import SQLiteHandler
-from scripts.cron_job import CRON
-from scripts.common.config import MONGO_DB_OBJ, MONGO_SERVICE_COLL, HOST_CONFIG
-from datetime import datetime, timedelta
-from scripts.common.logsetup import logger
-from scripts.cron_job import *
-
-get_in_out_dt_output = namedtuple("output", "dt_in_time dt_out_time punch_date")
-
-
-def create_db_obj():
-    """Creates and returns the database object
-    also initialise schemas in the data
-    Returns:
-        SQLiteHandler: Database object
-    """
-    db_obj = CRON()
-    return db_obj
-
-
-def insert_records(msserver_obj, data):
-    data = {
-        "job_run_date": datetime.now(),
-        "auto_update": 1,
-        "shift_hours": 8,
-        "group_event_period_seconds": 300,
-        "over_time_hours": 3,
-        "job_interval_minutes": 15
-    }
-
-    x = msserver_obj.insert_records(data)
-    print(x)
-    return x
-
-
-def add(msserver_obj, date):
-    date = datetime.today()
-    msserver_obj.insertConfigTime(date)
-
-
-def main():
-    """main function
-    """
-    msserver_obj = create_db_obj()  # Vamshi
-    insert_records(msserver_obj, '')
-
-
-if __name__ == '__main__':
-    main()
-#
-# msserver_obj = create_db_obj()
-# # get_config(msserver_obj)
-# # insert_records(msserver_obj, '')
-# # msserver_obj.insertConfigTime()
+import os
+from collections import namedtuple
+
+os.environ['config'] = '{"MONGO_URI": "mongodb://svc-ilens:svc2345@192.168.0.220:21017", "MONGO_DB":"ilens_wps", ' \
+                       '"MONGO_COLL": "serviceConfiguration"} '
+from scripts.pull_docs_mongo import PullEvents
+from scripts.sqlite_ingestor import SQLiteHandler
+from scripts.cron_job import CRON
+from scripts.common.config import MONGO_DB_OBJ, MONGO_SERVICE_COLL, HOST_CONFIG
+from datetime import datetime, timedelta
+from scripts.common.logsetup import logger
+from scripts.cron_job import *
+from datetime import datetime
+from dateutil import tz
+
+get_in_out_dt_output = namedtuple("output", "dt_in_time dt_out_time punch_date")
+
+
+def create_db_obj():
+    """Creates and returns the database object
+    also initialise schemas in the data
+    Returns:
+        SQLiteHandler: Database object
+    """
+    db_obj = CRON()
+    return db_obj
+
+
+def insert_records(msserver_obj, data):
+
+    # METHOD 1: Hardcode zones:
+    from_zone = tz.gettz('UTC')
+    to_zone = tz.gettz('Asia/Kolkata')
+    print(to_zone)
+    utc = datetime.utcnow()
+    utc = utc.replace(tzinfo=from_zone)
+    # Convert time zone
+    central = utc.astimezone(to_zone)
+    print(central)
+    data = {
+        "job_run_date": central,
+        "auto_update": 1,
+        "shift_hours": 8,
+        "group_event_period_seconds": 300,
+        "over_time_hours": 3,
+        "job_interval_minutes": 15
+    }
+
+    x = msserver_obj.insert_records(data)
+    print(x)
+    return x
+
+
+def add(msserver_obj, date):
+    date = datetime.today()
+    msserver_obj.insertConfigTime(date)
+
+
+def main():
+    """main function
+    """
+    msserver_obj = create_db_obj()  # Vamshi
+    insert_records(msserver_obj, '')
+
+
+if __name__ == '__main__':
+    main()
+#
+# msserver_obj = create_db_obj()
+# # get_config(msserver_obj)
+# # insert_records(msserver_obj, '')
+# # msserver_obj.insertConfigTime()

requirements.txt

@@ -2,4 +2,6 @@ pymongo
 flask
 flask_cors
 sqlalchemy
-mysqlclient
+mysqlclient
\ No newline at end of file
+pymssql
+python-dateutil

scripts/cron_job.py

@@ -10,7 +10,7 @@ from sqlalchemy.ext.declarative import declarative_base
 from scripts.common.logsetup import logger
 from scripts.common.config import MONGO_DB_OBJ, MONGO_SERVICE_COLL
 from datetime import timedelta
-
+from dateutil import tz
 Base = declarative_base()
 
 MYSQL_CONFIG = MONGO_DB_OBJ[MONGO_SERVICE_COLL].find_one({'configId': 'msserver'}).get('config')
@@ -63,6 +63,7 @@ class CRON:
         return self.config
 
     def insert_records(self, data):
+
         res = self.session.query(configurations).count()
         print(res)
         if res == 0:
@@ -70,10 +71,19 @@ class CRON:
             self.session.commit()
         else:
             data = self.getConfig()
+            from_zone = tz.gettz('UTC')
+            to_zone = tz.gettz('Asia/Kolkata')
+            print(to_zone)
+            utc = datetime.utcnow()
+            utc = utc.replace(tzinfo=from_zone)
+            # Convert time zone
+            localtimenow = utc.astimezone(to_zone)
             print(data)
-            if data['auto_update'] == 1 and (data['job_run_date'] + timedelta(minutes=data['job_interval_minutes'])) < datetime.now():
+            check = (data['job_run_date'] + timedelta(minutes=data['job_interval_minutes'])).astimezone(to_zone)
+            print(check,localtimenow)
+            if data['auto_update'] == 1 and check < localtimenow:
                 print(data['job_run_date'], data['job_interval_minutes'])
-                data['job_run_date'] = datetime.now()
+                data['job_run_date'] = localtimenow
                 self.session.add(self.insert(data))
                 self.session.commit()
         return True