| Line 1651... |
Line 1651... |
| 1651 |
try:
|
1651 |
try:
|
| 1652 |
monitoredEntity = MonitoredEntity();
|
1652 |
monitoredEntity = MonitoredEntity();
|
| 1653 |
monitoredEntity.entityType=EntityType.COURIER;
|
1653 |
monitoredEntity.entityType=EntityType.COURIER;
|
| 1654 |
monitoredEntity.eventType=OrderStatus.SHIPPED_TO_LOGST
|
1654 |
monitoredEntity.eventType=OrderStatus.SHIPPED_TO_LOGST
|
| 1655 |
monitoredEntity.entityIdentifier="orderId = " + str(order.id);
|
1655 |
monitoredEntity.entityIdentifier="orderId = " + str(order.id);
|
| 1656 |
adjustedDeliveryDays = adjust_delivery_time(datetime.datetime.now(), 1);
|
1656 |
adjustedDeliveryDays = adjust_delivery_time(datetime.datetime.now(), 2);
|
| 1657 |
sec = datetime.datetime.now()
|
1657 |
sec = datetime.datetime.now()
|
| 1658 |
#Warn alert time is taken as 16 hrs
|
1658 |
#Warn alert time is taken as 26 hrs
|
| 1659 |
warn_time = (sec + timedelta(days=(adjustedDeliveryDays-1)) + timedelta(hours=15))
|
1659 |
warn_time = (sec + timedelta(days=(adjustedDeliveryDays-2)) + timedelta(hours=26))
|
| 1660 |
#Critical alert time is taken as 26 hrs
|
1660 |
#Critical alert time is taken as 36 hrs
|
| 1661 |
critical_time = (sec + timedelta(days=(adjustedDeliveryDays-1)) + timedelta(hours=20))
|
1661 |
critical_time = (sec + timedelta(days=(adjustedDeliveryDays-1)) + timedelta(hours=36))
|
| 1662 |
monitoredEntity.warnExpiryTime = int(warn_time.strftime("%s"))*1000
|
1662 |
monitoredEntity.warnExpiryTime = int(warn_time.strftime("%s"))*1000
|
| 1663 |
monitoredEntity.criticalExpiryTime = int(critical_time.strftime("%s"))*1000
|
1663 |
monitoredEntity.criticalExpiryTime = int(critical_time.strftime("%s"))*1000
|
| 1664 |
monitoredEntity.description="providerId = " + str(provider_id)
|
1664 |
monitoredEntity.description="providerId = " + str(provider_id)
|
| 1665 |
alert_client = AlertClient().get_client()
|
1665 |
alert_client = AlertClient().get_client()
|
| 1666 |
alert_client.updateMonitoredObject(monitoredEntity)
|
1666 |
alert_client.updateMonitoredObject(monitoredEntity)
|
| Line 1881... |
Line 1881... |
| 1881 |
try:
|
1881 |
try:
|
| 1882 |
monitoredEntity = MonitoredEntity();
|
1882 |
monitoredEntity = MonitoredEntity();
|
| 1883 |
monitoredEntity.entityType=EntityType.COURIER;
|
1883 |
monitoredEntity.entityType=EntityType.COURIER;
|
| 1884 |
monitoredEntity.eventType=OrderStatus.SHIPPED_TO_DESTINATION_CITY
|
1884 |
monitoredEntity.eventType=OrderStatus.SHIPPED_TO_DESTINATION_CITY
|
| 1885 |
monitoredEntity.entityIdentifier="orderId = " + str(order.id);
|
1885 |
monitoredEntity.entityIdentifier="orderId = " + str(order.id);
|
| - |
|
1886 |
|
| - |
|
1887 |
sec = datetime.datetime.now()
|
| 1886 |
#Warn alert time is taken as 23 hrs less than promised delivery time
|
1888 |
#Warn alert time is taken as 14 hrs less than expected delivery time
|
| 1887 |
warn_time = (order.expected_delivery_time-timedelta(hours = 15))
|
1889 |
warn_time1 = (order.expected_delivery_time-timedelta(hours = 14))
|
| - |
|
1890 |
warn_time2 = sec + timedelta(order.expected_delivery_time - order.expected_shipping_timestamp) - timedelta(sec - order.shipping_time)
|
| - |
|
1891 |
warn_time = max(warn_time1, warn_time2)
|
| - |
|
1892 |
|
| 1888 |
#Critical alert time is taken as 13 hrs less than promised delivery time
|
1893 |
#Critical alert time is taken as 13 hrs less than promised delivery time
|
| 1889 |
critical_time = (order.expected_delivery_time-timedelta(hours = 10))
|
1894 |
critical_time1 = (order.expected_delivery_time-timedelta(hours = 10))
|
| - |
|
1895 |
critical_time2 = sec + timedelta(order.expected_delivery_time - order.expected_shipping_timestamp) - timedelta(sec - order.shipping_time) + timedelta(hours = 5)
|
| - |
|
1896 |
critical_time = max(critical_time1, critical_time2)
|
| - |
|
1897 |
|
| 1890 |
monitoredEntity.warnExpiryTime = int(warn_time.strftime("%s"))*1000
|
1898 |
monitoredEntity.warnExpiryTime = int(warn_time.strftime("%s"))*1000
|
| 1891 |
monitoredEntity.criticalExpiryTime = int(critical_time.strftime("%s"))*1000
|
1899 |
monitoredEntity.criticalExpiryTime = int(critical_time.strftime("%s"))*1000
|
| 1892 |
monitoredEntity.description="providerId = " + str(provider_id) + " destination city " + order.customer_city
|
1900 |
monitoredEntity.description="providerId = " + str(provider_id) + " destination city " + order.customer_city
|
| 1893 |
alert_client = AlertClient().get_client()
|
1901 |
alert_client = AlertClient().get_client()
|
| 1894 |
alert_client.updateMonitoredObject(monitoredEntity)
|
1902 |
alert_client.updateMonitoredObject(monitoredEntity)
|
| Line 1915... |
Line 1923... |
| 1915 |
try:
|
1923 |
try:
|
| 1916 |
monitoredEntity = MonitoredEntity();
|
1924 |
monitoredEntity = MonitoredEntity();
|
| 1917 |
monitoredEntity.entityType=EntityType.COURIER;
|
1925 |
monitoredEntity.entityType=EntityType.COURIER;
|
| 1918 |
monitoredEntity.eventType=OrderStatus.REACHED_DESTINATION_CITY
|
1926 |
monitoredEntity.eventType=OrderStatus.REACHED_DESTINATION_CITY
|
| 1919 |
monitoredEntity.entityIdentifier="orderId = " + str(order.id);
|
1927 |
monitoredEntity.entityIdentifier="orderId = " + str(order.id);
|
| - |
|
1928 |
|
| - |
|
1929 |
sec = datetime.datetime.now()
|
| - |
|
1930 |
#Warn alert time is taken as expected delivery time
|
| 1920 |
warn_time = (order.expected_delivery_time)
|
1931 |
warn_time1 = (order.expected_delivery_time)
|
| - |
|
1932 |
warn_time2 = sec + timedelta(order.expected_delivery_time - order.expected_shipping_timestamp) - timedelta(sec - order.shipping_time)
|
| - |
|
1933 |
warn_time = max(warn_time1, warn_time2)
|
| - |
|
1934 |
|
| - |
|
1935 |
#Critical alert time is taken as 13 hrs less than promised delivery time
|
| 1921 |
critical_time = (order.expected_delivery_time + timedelta(hours=12))
|
1936 |
critical_time1 = (order.expected_delivery_time + timedelta(hours = 5))
|
| - |
|
1937 |
critical_time2 = sec + timedelta(order.expected_delivery_time - order.expected_shipping_timestamp) - timedelta(sec - order.shipping_time) + timedelta(hours = 5)
|
| - |
|
1938 |
critical_time = max(critical_time1, critical_time2)
|
| - |
|
1939 |
|
| 1922 |
monitoredEntity.warnExpiryTime = int(warn_time.strftime("%s"))*1000
|
1940 |
monitoredEntity.warnExpiryTime = int(warn_time.strftime("%s"))*1000
|
| 1923 |
monitoredEntity.criticalExpiryTime = int(critical_time.strftime("%s"))*1000
|
1941 |
monitoredEntity.criticalExpiryTime = int(critical_time.strftime("%s"))*1000
|
| 1924 |
monitoredEntity.description="providerId = " + str(provider_id) + " destination city " + order.customer_city
|
1942 |
monitoredEntity.description="providerId = " + str(provider_id) + " destination city " + order.customer_city
|
| 1925 |
alert_client = AlertClient().get_client()
|
1943 |
alert_client = AlertClient().get_client()
|
| 1926 |
alert_client.updateMonitoredObject(monitoredEntity)
|
1944 |
alert_client.updateMonitoredObject(monitoredEntity)
|
| Line 5874... |
Line 5892... |
| 5874 |
amazonOrders = AmazonOrder.query.filter(AmazonOrder.amazonOrderCode == amazonId).all()
|
5892 |
amazonOrders = AmazonOrder.query.filter(AmazonOrder.amazonOrderCode == amazonId).all()
|
| 5875 |
for amazonOrder in amazonOrders:
|
5893 |
for amazonOrder in amazonOrders:
|
| 5876 |
orderIds.append(amazonOrder.orderId)
|
5894 |
orderIds.append(amazonOrder.orderId)
|
| 5877 |
return get_order_list(orderIds)
|
5895 |
return get_order_list(orderIds)
|
| 5878 |
|
5896 |
|
| - |
|
5897 |
def update_freebie_item(orderId, newFreebieItemId):
|
| - |
|
5898 |
order = Order.get_by(id = orderId)
|
| - |
|
5899 |
order.freebieItemId = newFreebieItemId
|
| - |
|
5900 |
session.commit()
|
| 5879 |
|
5901 |
return order
|
| 5880 |
|
5902 |
|
| 5881 |
if __name__ == '__main__':
|
5903 |
if __name__ == '__main__':
|
| 5882 |
print get_orders_by_mobile_number("9650889334")
|
5904 |
print get_orders_by_mobile_number("9650889334")
|
| 5883 |
|
5905 |
|