| Line 834... |
Line 834... |
| 834 |
print "Trying to schedule alert"
|
834 |
print "Trying to schedule alert"
|
| 835 |
monitoredEntity = MonitoredEntity();
|
835 |
monitoredEntity = MonitoredEntity();
|
| 836 |
monitoredEntity.entityType=EntityType.COURIER;
|
836 |
monitoredEntity.entityType=EntityType.COURIER;
|
| 837 |
monitoredEntity.eventType=OrderStatus.SHIPPED_FROM_WH;
|
837 |
monitoredEntity.eventType=OrderStatus.SHIPPED_FROM_WH;
|
| 838 |
monitoredEntity.entityIdentifier="orderId = " + str(order.id);
|
838 |
monitoredEntity.entityIdentifier="orderId = " + str(order.id);
|
| - |
|
839 |
adjustedDeliveryDays = adjust_delivery_time(datetime.datetime.now(), 1);
|
| 839 |
seconds_epoch = time.time()
|
840 |
sec = datetime.datetime.now()
|
| 840 |
#Warn alert time is taken as 15 hrs
|
841 |
#Warn alert time is taken as 16 hrs
|
| 841 |
warn_time = (seconds_epoch+15*3600)*1000
|
842 |
warn_time = (sec + timedelta(days=(adjustedDeliveryDays-1)) + timedelta(hours=16))
|
| 842 |
#Critical alert time is taken as 25 hrs
|
843 |
#Critical alert time is taken as 26 hrs
|
| 843 |
critical_time = (seconds_epoch+25*3600)*1000
|
844 |
critical_time = (sec + timedelta(days=(adjustedDeliveryDays-1)) + timedelta(hours=26))
|
| 844 |
monitoredEntity.warnExpiryTime = warn_time
|
845 |
monitoredEntity.warnExpiryTime = int(warn_time.strftime("%s"))*1000
|
| 845 |
monitoredEntity.criticalExpiryTime = critical_time
|
846 |
monitoredEntity.criticalExpiryTime = int(critical_time.strftime("%s"))*1000
|
| 846 |
monitoredEntity.description="warehouseId = " + str(warehouseId) + " providerId = " + str(providerId) + " orderId = " + str(order.id);
|
847 |
monitoredEntity.description="warehouseId = " + str(warehouseId) + " providerId = " + str(providerId) + " orderId = " + str(order.id);
|
| 847 |
print monitoredEntity
|
848 |
print monitoredEntity
|
| 848 |
print monitoredEntity.description
|
849 |
print monitoredEntity.description
|
| 849 |
print monitoredEntity.warnExpiryTime
|
850 |
print monitoredEntity.warnExpiryTime
|
| 850 |
print monitoredEntity.entityIdentifier
|
851 |
print monitoredEntity.entityIdentifier
|
| Line 901... |
Line 902... |
| 901 |
try:
|
902 |
try:
|
| 902 |
monitoredEntity = MonitoredEntity();
|
903 |
monitoredEntity = MonitoredEntity();
|
| 903 |
monitoredEntity.entityType=EntityType.COURIER;
|
904 |
monitoredEntity.entityType=EntityType.COURIER;
|
| 904 |
monitoredEntity.eventType=OrderStatus.SHIPPED_TO_LOGST
|
905 |
monitoredEntity.eventType=OrderStatus.SHIPPED_TO_LOGST
|
| 905 |
monitoredEntity.entityIdentifier="orderId = " + str(order.id);
|
906 |
monitoredEntity.entityIdentifier="orderId = " + str(order.id);
|
| - |
|
907 |
adjustedDeliveryDays = adjust_delivery_time(datetime.datetime.now(), 1);
|
| 906 |
seconds_epoch = time.time()
|
908 |
sec = datetime.datetime.now()
|
| 907 |
#Warn alert time is taken as 15 hrs
|
909 |
#Warn alert time is taken as 16 hrs
|
| 908 |
warn_time = (seconds_epoch+15*3600)*1000
|
910 |
warn_time = (sec + timedelta(days=(adjustedDeliveryDays-1)) + timedelta(hours=16))
|
| 909 |
#Critical alert time is taken as 25 hrs
|
911 |
#Critical alert time is taken as 26 hrs
|
| 910 |
critical_time = (seconds_epoch+25*3600)*1000
|
912 |
critical_time = (sec + timedelta(days=(adjustedDeliveryDays-1)) + timedelta(hours=26))
|
| 911 |
monitoredEntity.warnExpiryTime = warn_time
|
913 |
monitoredEntity.warnExpiryTime = int(warn_time.strftime("%s"))*1000
|
| 912 |
monitoredEntity.criticalExpiryTime = critical_time
|
914 |
monitoredEntity.criticalExpiryTime = int(critical_time.strftime("%s"))*1000
|
| 913 |
monitoredEntity.description="providerId = " + str(provider_id) + " " + pickup_details
|
915 |
monitoredEntity.description="providerId = " + str(provider_id) + " " + pickup_details
|
| 914 |
alert_client = AlertClient().get_client()
|
916 |
alert_client = AlertClient().get_client()
|
| 915 |
alert_client.updateMonitoredObject(monitoredEntity)
|
917 |
alert_client.updateMonitoredObject(monitoredEntity)
|
| 916 |
except Exception as e:
|
918 |
except Exception as e:
|
| 917 |
print e
|
919 |
print e
|
| Line 941... |
Line 943... |
| 941 |
order.delivery_timestamp = timestamp
|
943 |
order.delivery_timestamp = timestamp
|
| 942 |
order.receiver = receiver
|
944 |
order.receiver = receiver
|
| 943 |
update_trust_level(order)
|
945 |
update_trust_level(order)
|
| 944 |
try:
|
946 |
try:
|
| 945 |
alert_client = AlertClient().get_client()
|
947 |
alert_client = AlertClient().get_client()
|
| 946 |
alert_client.endMonitoringEntity(EntityType.COURIER, "orderId = " + order.id)
|
948 |
alert_client.endMonitoringEntity(EntityType.COURIER, "orderId = " + str(order.id))
|
| 947 |
except Exception as e:
|
949 |
except Exception as e:
|
| 948 |
print e
|
950 |
print e
|
| 949 |
|
951 |
|
| 950 |
session.commit()
|
952 |
session.commit()
|
| 951 |
|
953 |
|
| Line 974... |
Line 976... |
| 974 |
# order.cod_reconciliation_timestamp = datetime.datetime.now()
|
976 |
# order.cod_reconciliation_timestamp = datetime.datetime.now()
|
| 975 |
# session.commit()
|
977 |
# session.commit()
|
| 976 |
|
978 |
|
| 977 |
try:
|
979 |
try:
|
| 978 |
alert_client = AlertClient().get_client()
|
980 |
alert_client = AlertClient().get_client()
|
| 979 |
alert_client.endMonitoringEntity(EntityType.COURIER, "orderId = " + order.id)
|
981 |
alert_client.endMonitoringEntity(EntityType.COURIER, "orderId = " + str(order.id))
|
| 980 |
except Exception as e:
|
982 |
except Exception as e:
|
| 981 |
print e
|
983 |
print e
|
| 982 |
|
984 |
|
| 983 |
|
985 |
|
| 984 |
def mark_order_as_received_at_store(orderId, deliveryTimestamp):
|
986 |
def mark_order_as_received_at_store(orderId, deliveryTimestamp):
|
| Line 1113... |
Line 1115... |
| 1113 |
try:
|
1115 |
try:
|
| 1114 |
monitoredEntity = MonitoredEntity();
|
1116 |
monitoredEntity = MonitoredEntity();
|
| 1115 |
monitoredEntity.entityType=EntityType.COURIER;
|
1117 |
monitoredEntity.entityType=EntityType.COURIER;
|
| 1116 |
monitoredEntity.eventType=OrderStatus.SHIPPED_TO_DESTINATION_CITY
|
1118 |
monitoredEntity.eventType=OrderStatus.SHIPPED_TO_DESTINATION_CITY
|
| 1117 |
monitoredEntity.entityIdentifier="orderId = " + str(order.id);
|
1119 |
monitoredEntity.entityIdentifier="orderId = " + str(order.id);
|
| 1118 |
#Warn alert time is taken as 15 hrs
|
1120 |
#Warn alert time is taken as 23 hrs less than promised delivery time
|
| 1119 |
warn_time = (order.promised_delivery_time-23*3600*1000)
|
1121 |
warn_time = (order.promised_delivery_time-23*3600*1000)
|
| 1120 |
#Critical alert time is taken as 25 hrs
|
1122 |
#Critical alert time is taken as 13 hrs less than promised delivery time
|
| 1121 |
critical_time = (order.promised_delivery_time-13*3600*1000)
|
1123 |
critical_time = (order.promised_delivery_time-13*3600*1000)
|
| 1122 |
monitoredEntity.warnExpiryTime = warn_time
|
1124 |
monitoredEntity.warnExpiryTime = warn_time
|
| 1123 |
monitoredEntity.criticalExpiryTime = critical_time
|
1125 |
monitoredEntity.criticalExpiryTime = critical_time
|
| 1124 |
monitoredEntity.description="providerId = " + str(provider_id) + " destination city " + order.customer_city
|
1126 |
monitoredEntity.description="providerId = " + str(provider_id) + " destination city " + order.customer_city
|
| 1125 |
alert_client = AlertClient().get_client()
|
1127 |
alert_client = AlertClient().get_client()
|
| Line 1171... |
Line 1173... |
| 1171 |
try:
|
1173 |
try:
|
| 1172 |
monitoredEntity = MonitoredEntity();
|
1174 |
monitoredEntity = MonitoredEntity();
|
| 1173 |
monitoredEntity.entityType=EntityType.COURIER;
|
1175 |
monitoredEntity.entityType=EntityType.COURIER;
|
| 1174 |
monitoredEntity.eventType=OrderStatus.FIRST_DELIVERY_ATTEMPT_MADE
|
1176 |
monitoredEntity.eventType=OrderStatus.FIRST_DELIVERY_ATTEMPT_MADE
|
| 1175 |
monitoredEntity.entityIdentifier="orderId = " + str(order.id);
|
1177 |
monitoredEntity.entityIdentifier="orderId = " + str(order.id);
|
| - |
|
1178 |
adjustedDeliveryDaysfor1day = adjust_delivery_time(datetime.datetime.now(), 1);
|
| - |
|
1179 |
adjustedDeliveryDaysfor2days = adjust_delivery_time(datetime.datetime.now(), 2);
|
| 1176 |
seconds_epoch = time.time()
|
1180 |
sec = datetime.datetime.now()
|
| 1177 |
#Warn alert time is taken as 15 hrs
|
1181 |
#Warn alert time is taken as 16 hrs
|
| 1178 |
warn_time = (seconds_epoch+24*3600)*1000
|
1182 |
warn_time = (sec + timedelta(days=(adjustedDeliveryDaysfor1day-1)) + timedelta(hours=24))
|
| 1179 |
#Critical alert time is taken as 25 hrs
|
1183 |
#Critical alert time is taken as 26 hrs
|
| 1180 |
critical_time = (seconds_epoch+36*3600)*1000
|
1184 |
critical_time = (sec + timedelta(days=(adjustedDeliveryDaysfor2days-1)) + timedelta(hours=36))
|
| 1181 |
monitoredEntity.warnExpiryTime = warn_time
|
1185 |
monitoredEntity.warnExpiryTime = int(warn_time.strftime("%s"))*1000
|
| 1182 |
monitoredEntity.criticalExpiryTime = critical_time
|
1186 |
monitoredEntity.criticalExpiryTime = int(critical_time.strftime("%s"))*1000
|
| 1183 |
monitoredEntity.description="providerId = " + str(provider_id) + " first attempt timestamp" + order.first_dlvyatmp_timestamp
|
1187 |
monitoredEntity.description="providerId = " + str(provider_id) + " first attempt timestamp" + order.first_dlvyatmp_timestamp
|
| 1184 |
alert_client = AlertClient().get_client()
|
1188 |
alert_client = AlertClient().get_client()
|
| 1185 |
alert_client.updateMonitoredObject(monitoredEntity)
|
1189 |
alert_client.updateMonitoredObject(monitoredEntity)
|
| 1186 |
except Exception as e:
|
1190 |
except Exception as e:
|
| 1187 |
print e
|
1191 |
print e
|