| Line 1087... |
Line 1087... |
| 1087 |
order.statusDescription = "Order Returned to Origin:" + reason
|
1087 |
order.statusDescription = "Order Returned to Origin:" + reason
|
| 1088 |
update_trust_level(order)
|
1088 |
update_trust_level(order)
|
| 1089 |
session.commit()
|
1089 |
session.commit()
|
| 1090 |
try:
|
1090 |
try:
|
| 1091 |
alert_client = AlertClient().get_client()
|
1091 |
alert_client = AlertClient().get_client()
|
| 1092 |
alert_client.endMonitoringEntity(EntityType.COURIER, "orderId = " + order.id)
|
1092 |
alert_client.endMonitoringEntity(EntityType.COURIER, "orderId = " + str(order.id))
|
| 1093 |
except Exception as e:
|
1093 |
except Exception as e:
|
| 1094 |
print "Exception in ending alert in MarkOrderAsRTO method"
|
1094 |
print "Exception in ending alert in MarkOrderAsRTO method"
|
| 1095 |
print e
|
1095 |
print e
|
| 1096 |
|
1096 |
|
| 1097 |
def get_rto_orders(provider_id):
|
1097 |
def get_rto_orders(provider_id):
|
| Line 1150... |
Line 1150... |
| 1150 |
monitoredEntity = MonitoredEntity();
|
1150 |
monitoredEntity = MonitoredEntity();
|
| 1151 |
monitoredEntity.entityType=EntityType.COURIER;
|
1151 |
monitoredEntity.entityType=EntityType.COURIER;
|
| 1152 |
monitoredEntity.eventType=OrderStatus.SHIPPED_TO_DESTINATION_CITY
|
1152 |
monitoredEntity.eventType=OrderStatus.SHIPPED_TO_DESTINATION_CITY
|
| 1153 |
monitoredEntity.entityIdentifier="orderId = " + str(order.id);
|
1153 |
monitoredEntity.entityIdentifier="orderId = " + str(order.id);
|
| 1154 |
#Warn alert time is taken as 23 hrs less than promised delivery time
|
1154 |
#Warn alert time is taken as 23 hrs less than promised delivery time
|
| 1155 |
warn_time = (order.expected_delivery_time-23*3600*1000)
|
1155 |
warn_time = (order.expected_delivery_time-timedelta(hours = 23))
|
| 1156 |
#Critical alert time is taken as 13 hrs less than promised delivery time
|
1156 |
#Critical alert time is taken as 13 hrs less than promised delivery time
|
| 1157 |
critical_time = (order.expected_delivery_time-13*3600*1000)
|
1157 |
critical_time = (order.expected_delivery_time-timedelta(hours = 13))
|
| 1158 |
monitoredEntity.warnExpiryTime = warn_time
|
1158 |
monitoredEntity.warnExpiryTime = int(warn_time.strftime("%s"))*1000
|
| 1159 |
monitoredEntity.criticalExpiryTime = critical_time
|
1159 |
monitoredEntity.criticalExpiryTime = int(critical_time.strftime("%s"))*1000
|
| 1160 |
monitoredEntity.description="providerId = " + str(provider_id) + " destination city " + order.customer_city
|
1160 |
monitoredEntity.description="providerId = " + str(provider_id) + " destination city " + order.customer_city
|
| 1161 |
alert_client = AlertClient().get_client()
|
1161 |
alert_client = AlertClient().get_client()
|
| 1162 |
alert_client.updateMonitoredObject(monitoredEntity)
|
1162 |
alert_client.updateMonitoredObject(monitoredEntity)
|
| 1163 |
except Exception as e:
|
1163 |
except Exception as e:
|
| 1164 |
print "Exception in updating alert in MarkOrderAsLocalConnected method"
|
1164 |
print "Exception in updating alert in MarkOrderAsLocalConnected method"
|
| Line 1184... |
Line 1184... |
| 1184 |
monitoredEntity = MonitoredEntity();
|
1184 |
monitoredEntity = MonitoredEntity();
|
| 1185 |
monitoredEntity.entityType=EntityType.COURIER;
|
1185 |
monitoredEntity.entityType=EntityType.COURIER;
|
| 1186 |
monitoredEntity.eventType=OrderStatus.REACHED_DESTINATION_CITY
|
1186 |
monitoredEntity.eventType=OrderStatus.REACHED_DESTINATION_CITY
|
| 1187 |
monitoredEntity.entityIdentifier="orderId = " + str(order.id);
|
1187 |
monitoredEntity.entityIdentifier="orderId = " + str(order.id);
|
| 1188 |
warn_time = (order.expected_delivery_time)
|
1188 |
warn_time = (order.expected_delivery_time)
|
| 1189 |
critical_time = (order.expected_delivery_time+12*3600*1000)
|
1189 |
critical_time = (order.expected_delivery_time + timedelta(hours=12))
|
| 1190 |
monitoredEntity.warnExpiryTime = warn_time
|
1190 |
monitoredEntity.warnExpiryTime = int(warn_time.strftime("%s"))*1000
|
| 1191 |
monitoredEntity.criticalExpiryTime = critical_time
|
1191 |
monitoredEntity.criticalExpiryTime = int(critical_time.strftime("%s"))*1000
|
| 1192 |
monitoredEntity.description="providerId = " + str(provider_id) + " destination city " + order.customer_city
|
1192 |
monitoredEntity.description="providerId = " + str(provider_id) + " destination city " + order.customer_city
|
| 1193 |
alert_client = AlertClient().get_client()
|
1193 |
alert_client = AlertClient().get_client()
|
| 1194 |
alert_client.updateMonitoredObject(monitoredEntity)
|
1194 |
alert_client.updateMonitoredObject(monitoredEntity)
|
| 1195 |
except Exception as e:
|
1195 |
except Exception as e:
|
| 1196 |
print "Exception in updating alert in MarkOrderAsDestCityReached method"
|
1196 |
print "Exception in updating alert in MarkOrderAsDestCityReached method"
|