WebSVN – SmartDukaan – Diff – /trunk/PyProj/src/shop2020/model/v1/order/impl/DataAccessors.py



                    monitoredEntity.criticalExpiryTime = int(critical_time.strftime("%s"))*1000
                    monitoredEntity.description="warehouseId = " + str(warehouseId) + " providerId = " + str(providerId) + " orderId = "  + str(order.id);
                    alert_client = AlertClient().get_client()
                    alert_client.scheduleAlert(monitoredEntity)
                except Exception as e:
                    print "Exception in scheduling alert in ShippedFromWarehouse method"
                    print e
        session.commit()
        
        try:
            enqueue_shipping_confirmation_email(orders)

            monitoredEntity.criticalExpiryTime = int(critical_time.strftime("%s"))*1000
            monitoredEntity.description="providerId = " + str(provider_id) + "   " + pickup_details
            alert_client = AlertClient().get_client()
            alert_client.updateMonitoredObject(monitoredEntity)
        except Exception as e:
            print "Exception in updating alert in MarkOrdersAsPickedUp method"
            print e
    session.commit()
 
def get_orders_not_picked_up(provider_id):
    current_time = datetime.datetime.now()

            update_trust_level(order)
            try:
                alert_client = AlertClient().get_client()
                alert_client.endMonitoringEntity(EntityType.COURIER, "orderId = " + str(order.id))
            except Exception as e:
                print "Exception in scheduling alert in ShippedFromWarehouse method"
                print e
        timestamp, receiver = detail.split('|')
        if order.first_dlvyatmp_timestamp is None:
            order.first_dlvyatmp_timestamp = timestamp
        order.delivery_timestamp = timestamp

        
    try:
        alert_client = AlertClient().get_client()
        alert_client.endMonitoringEntity(EntityType.COURIER, "orderId = " + str(order.id))
    except Exception as e:
        print "Exception in ending alert in MarkOrderAsDelivered method"
        print e
 
    
def mark_order_as_received_at_store(orderId, deliveryTimestamp):
    order = Order.get_by(id=orderId)

        order.statusDescription = "Order Returned to Origin:" + reason
        update_trust_level(order)
    session.commit()
    try:
        alert_client = AlertClient().get_client()
        alert_client.endMonitoringEntity(EntityType.COURIER, "orderId = " + str(order.id))
    except Exception as e:
        print "Exception in ending alert in MarkOrderAsRTO method"
        print e
 
def get_rto_orders(provider_id):
    current_time = datetime.datetime.now()
    to_datetime = datetime.datetime(current_time.year, current_time.month, current_time.day)

            monitoredEntity = MonitoredEntity();
            monitoredEntity.entityType=EntityType.COURIER;
            monitoredEntity.eventType=OrderStatus.SHIPPED_TO_DESTINATION_CITY
            monitoredEntity.entityIdentifier="orderId = " + str(order.id);
            #Warn alert time is taken as 23 hrs less than promised delivery time
            warn_time = (order.expected_delivery_time-timedelta(hours = 23))
            #Critical alert time is taken as 13 hrs less than promised delivery time                    
            critical_time = (order.expected_delivery_time-timedelta(hours = 13))
            monitoredEntity.warnExpiryTime = int(warn_time.strftime("%s"))*1000
            monitoredEntity.criticalExpiryTime = int(critical_time.strftime("%s"))*1000
            monitoredEntity.description="providerId = " + str(provider_id) + " destination city " + order.customer_city 
            alert_client = AlertClient().get_client()
            alert_client.updateMonitoredObject(monitoredEntity)
        except Exception as e:
            print "Exception in updating alert in MarkOrderAsLocalConnected method"
            print e
        session.commit()
 
def get_orders_not_local_connected(provider_id):
    current_time = datetime.datetime.now()

            monitoredEntity = MonitoredEntity();
            monitoredEntity.entityType=EntityType.COURIER;
            monitoredEntity.eventType=OrderStatus.REACHED_DESTINATION_CITY
            monitoredEntity.entityIdentifier="orderId = " + str(order.id);
            warn_time = (order.expected_delivery_time)
            critical_time = (order.expected_delivery_time + timedelta(hours=12))
            monitoredEntity.warnExpiryTime = int(warn_time.strftime("%s"))*1000
            monitoredEntity.criticalExpiryTime = int(critical_time.strftime("%s"))*1000
            monitoredEntity.description="providerId = " + str(provider_id) + " destination city " + order.customer_city 
            alert_client = AlertClient().get_client()
            alert_client.updateMonitoredObject(monitoredEntity)
        except Exception as e:
            print "Exception in updating alert in MarkOrderAsDestCityReached method"
            print e
    session.commit()
 
def mark_orders_as_firstDeliveryAttempted(provider_id, first_atdl_orders):
    for awb, detail in first_atdl_orders.iteritems():

            monitoredEntity.criticalExpiryTime = int(critical_time.strftime("%s"))*1000
            monitoredEntity.description="providerId = " + str(provider_id) + " first attempt timestamp" + order.first_dlvyatmp_timestamp
            alert_client = AlertClient().get_client()
            alert_client.updateMonitoredObject(monitoredEntity)
        except Exception as e:
            print "Exception in updating alert in MarkOrdersAsFirstDeliveryAttempted method"
            print e
    session.commit()
 
def get_orders_not_met_expected_delivery_date():
    current_time = datetime.datetime.now()

Rev 5797	Rev 5801
Line 891...	Line 891...
891	`monitoredEntity.criticalExpiryTime = int(critical_time.strftime("%s"))*1000`	891	`monitoredEntity.criticalExpiryTime = int(critical_time.strftime("%s"))*1000`
892	`monitoredEntity.description="warehouseId = " + str(warehouseId) + " providerId = " + str(providerId) + " orderId = " + str(order.id);`	892	`monitoredEntity.description="warehouseId = " + str(warehouseId) + " providerId = " + str(providerId) + " orderId = " + str(order.id);`
893	`alert_client = AlertClient().get_client()`	893	`alert_client = AlertClient().get_client()`
894	`alert_client.scheduleAlert(monitoredEntity)`	894	`alert_client.scheduleAlert(monitoredEntity)`
895	`except Exception as e:`	895	`except Exception as e:`
-		896	`print "Exception in scheduling alert in ShippedFromWarehouse method"`
896	`print e`	897	`print e`
897	`session.commit()`	898	`session.commit()`
898		899
899	`try:`	900	`try:`
900	`enqueue_shipping_confirmation_email(orders)`	901	`enqueue_shipping_confirmation_email(orders)`
Line 962...	Line 963...
962	`monitoredEntity.criticalExpiryTime = int(critical_time.strftime("%s"))*1000`	963	`monitoredEntity.criticalExpiryTime = int(critical_time.strftime("%s"))*1000`
963	`monitoredEntity.description="providerId = " + str(provider_id) + " " + pickup_details`	964	`monitoredEntity.description="providerId = " + str(provider_id) + " " + pickup_details`
964	`alert_client = AlertClient().get_client()`	965	`alert_client = AlertClient().get_client()`
965	`alert_client.updateMonitoredObject(monitoredEntity)`	966	`alert_client.updateMonitoredObject(monitoredEntity)`
966	`except Exception as e:`	967	`except Exception as e:`
-		968	`print "Exception in updating alert in MarkOrdersAsPickedUp method"`
967	`print e`	969	`print e`
968	`session.commit()`	970	`session.commit()`
969		971
970	`def get_orders_not_picked_up(provider_id):`	972	`def get_orders_not_picked_up(provider_id):`
971	`current_time = datetime.datetime.now()`	973	`current_time = datetime.datetime.now()`
Line 1003...	Line 1005...
1003	`update_trust_level(order)`	1005	`update_trust_level(order)`
1004	`try:`	1006	`try:`
1005	`alert_client = AlertClient().get_client()`	1007	`alert_client = AlertClient().get_client()`
1006	`alert_client.endMonitoringEntity(EntityType.COURIER, "orderId = " + str(order.id))`	1008	`alert_client.endMonitoringEntity(EntityType.COURIER, "orderId = " + str(order.id))`
1007	`except Exception as e:`	1009	`except Exception as e:`
-		1010	`print "Exception in scheduling alert in ShippedFromWarehouse method"`
1008	`print e`	1011	`print e`
1009	`timestamp, receiver = detail.split('\|')`	1012	`timestamp, receiver = detail.split('\|')`
1010	`if order.first_dlvyatmp_timestamp is None:`	1013	`if order.first_dlvyatmp_timestamp is None:`
1011	`order.first_dlvyatmp_timestamp = timestamp`	1014	`order.first_dlvyatmp_timestamp = timestamp`
1012	`order.delivery_timestamp = timestamp`	1015	`order.delivery_timestamp = timestamp`
Line 1041...	Line 1044...
1041		1044
1042	`try:`	1045	`try:`
1043	`alert_client = AlertClient().get_client()`	1046	`alert_client = AlertClient().get_client()`
1044	`alert_client.endMonitoringEntity(EntityType.COURIER, "orderId = " + str(order.id))`	1047	`alert_client.endMonitoringEntity(EntityType.COURIER, "orderId = " + str(order.id))`
1045	`except Exception as e:`	1048	`except Exception as e:`
-		1049	`print "Exception in ending alert in MarkOrderAsDelivered method"`
1046	`print e`	1050	`print e`
1047		1051
1048		1052
1049	`def mark_order_as_received_at_store(orderId, deliveryTimestamp):`	1053	`def mark_order_as_received_at_store(orderId, deliveryTimestamp):`
1050	`order = Order.get_by(id=orderId)`	1054	`order = Order.get_by(id=orderId)`
Line 1123...	Line 1127...
1123	`order.statusDescription = "Order Returned to Origin:" + reason`	1127	`order.statusDescription = "Order Returned to Origin:" + reason`
1124	`update_trust_level(order)`	1128	`update_trust_level(order)`
1125	`session.commit()`	1129	`session.commit()`
1126	`try:`	1130	`try:`
1127	`alert_client = AlertClient().get_client()`	1131	`alert_client = AlertClient().get_client()`
1128	`alert_client.endMonitoringEntity(EntityType.COURIER, "orderId = " + order.id)`	1132	`alert_client.endMonitoringEntity(EntityType.COURIER, "orderId = " + str(order.id))`
1129	`except Exception as e:`	1133	`except Exception as e:`
-		1134	`print "Exception in ending alert in MarkOrderAsRTO method"`
1130	`print e`	1135	`print e`
1131		1136
1132	`def get_rto_orders(provider_id):`	1137	`def get_rto_orders(provider_id):`
1133	`current_time = datetime.datetime.now()`	1138	`current_time = datetime.datetime.now()`
1134	`to_datetime = datetime.datetime(current_time.year, current_time.month, current_time.day)`	1139	`to_datetime = datetime.datetime(current_time.year, current_time.month, current_time.day)`
Line 1185...	Line 1190...
1185	`monitoredEntity = MonitoredEntity();`	1190	`monitoredEntity = MonitoredEntity();`
1186	`monitoredEntity.entityType=EntityType.COURIER;`	1191	`monitoredEntity.entityType=EntityType.COURIER;`
1187	`monitoredEntity.eventType=OrderStatus.SHIPPED_TO_DESTINATION_CITY`	1192	`monitoredEntity.eventType=OrderStatus.SHIPPED_TO_DESTINATION_CITY`
1188	`monitoredEntity.entityIdentifier="orderId = " + str(order.id);`	1193	`monitoredEntity.entityIdentifier="orderId = " + str(order.id);`
1189	`#Warn alert time is taken as 23 hrs less than promised delivery time`	1194	`#Warn alert time is taken as 23 hrs less than promised delivery time`
1190	`warn_time = (order.expected_delivery_time-2336001000)`	1195	`warn_time = (order.expected_delivery_time-timedelta(hours = 23))`
1191	`#Critical alert time is taken as 13 hrs less than promised delivery time`	1196	`#Critical alert time is taken as 13 hrs less than promised delivery time`
1192	`critical_time = (order.expected_delivery_time-1336001000)`	1197	`critical_time = (order.expected_delivery_time-timedelta(hours = 13))`
1193	`monitoredEntity.warnExpiryTime = warn_time`	1198	`monitoredEntity.warnExpiryTime = int(warn_time.strftime("%s"))*1000`
1194	`monitoredEntity.criticalExpiryTime = critical_time`	1199	`monitoredEntity.criticalExpiryTime = int(critical_time.strftime("%s"))*1000`
1195	`monitoredEntity.description="providerId = " + str(provider_id) + " destination city " + order.customer_city`	1200	`monitoredEntity.description="providerId = " + str(provider_id) + " destination city " + order.customer_city`
1196	`alert_client = AlertClient().get_client()`	1201	`alert_client = AlertClient().get_client()`
1197	`alert_client.updateMonitoredObject(monitoredEntity)`	1202	`alert_client.updateMonitoredObject(monitoredEntity)`
1198	`except Exception as e:`	1203	`except Exception as e:`
-		1204	`print "Exception in updating alert in MarkOrderAsLocalConnected method"`
1199	`print e`	1205	`print e`
1200	`session.commit()`	1206	`session.commit()`
1201		1207
1202	`def get_orders_not_local_connected(provider_id):`	1208	`def get_orders_not_local_connected(provider_id):`
1203	`current_time = datetime.datetime.now()`	1209	`current_time = datetime.datetime.now()`
Line 1218...	Line 1224...
1218	`monitoredEntity = MonitoredEntity();`	1224	`monitoredEntity = MonitoredEntity();`
1219	`monitoredEntity.entityType=EntityType.COURIER;`	1225	`monitoredEntity.entityType=EntityType.COURIER;`
1220	`monitoredEntity.eventType=OrderStatus.REACHED_DESTINATION_CITY`	1226	`monitoredEntity.eventType=OrderStatus.REACHED_DESTINATION_CITY`
1221	`monitoredEntity.entityIdentifier="orderId = " + str(order.id);`	1227	`monitoredEntity.entityIdentifier="orderId = " + str(order.id);`
1222	`warn_time = (order.expected_delivery_time)`	1228	`warn_time = (order.expected_delivery_time)`
1223	`critical_time = (order.expected_delivery_time+1236001000)`	1229	`critical_time = (order.expected_delivery_time + timedelta(hours=12))`
1224	`monitoredEntity.warnExpiryTime = warn_time`	1230	`monitoredEntity.warnExpiryTime = int(warn_time.strftime("%s"))*1000`
1225	`monitoredEntity.criticalExpiryTime = critical_time`	1231	`monitoredEntity.criticalExpiryTime = int(critical_time.strftime("%s"))*1000`
1226	`monitoredEntity.description="providerId = " + str(provider_id) + " destination city " + order.customer_city`	1232	`monitoredEntity.description="providerId = " + str(provider_id) + " destination city " + order.customer_city`
1227	`alert_client = AlertClient().get_client()`	1233	`alert_client = AlertClient().get_client()`
1228	`alert_client.updateMonitoredObject(monitoredEntity)`	1234	`alert_client.updateMonitoredObject(monitoredEntity)`
1229	`except Exception as e:`	1235	`except Exception as e:`
-		1236	`print "Exception in updating alert in MarkOrderAsDestCityReached method"`
1230	`print e`	1237	`print e`
1231	`session.commit()`	1238	`session.commit()`
1232		1239
1233	`def mark_orders_as_firstDeliveryAttempted(provider_id, first_atdl_orders):`	1240	`def mark_orders_as_firstDeliveryAttempted(provider_id, first_atdl_orders):`
1234	`for awb, detail in first_atdl_orders.iteritems():`	1241	`for awb, detail in first_atdl_orders.iteritems():`
Line 1255...	Line 1262...
1255	`monitoredEntity.criticalExpiryTime = int(critical_time.strftime("%s"))*1000`	1262	`monitoredEntity.criticalExpiryTime = int(critical_time.strftime("%s"))*1000`
1256	`monitoredEntity.description="providerId = " + str(provider_id) + " first attempt timestamp" + order.first_dlvyatmp_timestamp`	1263	`monitoredEntity.description="providerId = " + str(provider_id) + " first attempt timestamp" + order.first_dlvyatmp_timestamp`
1257	`alert_client = AlertClient().get_client()`	1264	`alert_client = AlertClient().get_client()`
1258	`alert_client.updateMonitoredObject(monitoredEntity)`	1265	`alert_client.updateMonitoredObject(monitoredEntity)`
1259	`except Exception as e:`	1266	`except Exception as e:`
-		1267	`print "Exception in updating alert in MarkOrdersAsFirstDeliveryAttempted method"`
1260	`print e`	1268	`print e`
1261	`session.commit()`	1269	`session.commit()`
1262		1270
1263	`def get_orders_not_met_expected_delivery_date():`	1271	`def get_orders_not_met_expected_delivery_date():`
1264	`current_time = datetime.datetime.now()`	1272	`current_time = datetime.datetime.now()`

Subversion Repositories SmartDukaan

(root)/trunk/PyProj/src/shop2020/model/v1/order/impl/DataAccessors.py – Rev 5797 → 5801