| Line 24... |
Line 24... |
| 24 |
from shop2020.utils.EmailAttachmentSender import mail
|
24 |
from shop2020.utils.EmailAttachmentSender import mail
|
| 25 |
from shop2020.utils.Utils import to_py_date, to_java_date
|
25 |
from shop2020.utils.Utils import to_py_date, to_java_date
|
| 26 |
from sqlalchemy.orm.exc import MultipleResultsFound, NoResultFound
|
26 |
from sqlalchemy.orm.exc import MultipleResultsFound, NoResultFound
|
| 27 |
from sqlalchemy.sql.expression import and_, func, distinct
|
27 |
from sqlalchemy.sql.expression import and_, func, distinct
|
| 28 |
from sqlalchemy.sql.functions import count
|
28 |
from sqlalchemy.sql.functions import count
|
| - |
|
29 |
from sqlalchemy.sql import or_
|
| 29 |
import calendar
|
30 |
import calendar
|
| 30 |
import datetime
|
31 |
import datetime
|
| 31 |
import sys
|
32 |
import sys
|
| 32 |
import threading
|
33 |
import threading
|
| 33 |
|
34 |
|
| Line 1000... |
Line 1001... |
| 1000 |
if OOSStatus.query.filter_by(item_id = itemId, date = oosDate).first() is None:
|
1001 |
if OOSStatus.query.filter_by(item_id = itemId, date = oosDate).first() is None:
|
| 1001 |
oosStatus = OOSStatus()
|
1002 |
oosStatus = OOSStatus()
|
| 1002 |
oosStatus.item_id = itemId
|
1003 |
oosStatus.item_id = itemId
|
| 1003 |
oosStatus.date = oosDate
|
1004 |
oosStatus.date = oosDate
|
| 1004 |
oosStatus.is_oos = status
|
1005 |
oosStatus.is_oos = status
|
| - |
|
1006 |
order_count = 0
|
| 1005 |
if status == False:
|
1007 |
if status == False:
|
| 1006 |
order_count = 0
|
- |
|
| 1007 |
if orderCountByItemId.has_key(itemId):
|
1008 |
if orderCountByItemId.has_key(itemId):
|
| 1008 |
order_count = orderCountByItemId[itemId]
|
1009 |
order_count = orderCountByItemId[itemId]
|
| 1009 |
oosStatus.num_orders = order_count
|
1010 |
oosStatus.num_orders = order_count
|
| 1010 |
session.commit()
|
1011 |
session.commit()
|
| 1011 |
else:
|
1012 |
else:
|
| Line 1013... |
Line 1014... |
| 1013 |
"""raise InventoryServiceException(101, "OOS Status already exists for ItemID:"+str(itemId) + " & Date:"+oosDate)"""
|
1014 |
"""raise InventoryServiceException(101, "OOS Status already exists for ItemID:"+str(itemId) + " & Date:"+oosDate)"""
|
| 1014 |
|
1015 |
|
| 1015 |
def get_oos_statuses_for_x_days_for_item(itemId, days):
|
1016 |
def get_oos_statuses_for_x_days_for_item(itemId, days):
|
| 1016 |
timestamp = datetime.datetime.now()
|
1017 |
timestamp = datetime.datetime.now()
|
| 1017 |
timestamp = timestamp - datetime.timedelta(days = 6)
|
1018 |
timestamp = timestamp - datetime.timedelta(days = 6)
|
| 1018 |
return OOSStatus.query.filter_by(item_id = itemId).filter(OOSStatus.date > timestamp).all()
|
- |
|
| 1019 |
|
1019 |
return OOSStatus.query.filter_by(item_id = itemId).filter(OOSStatus.date > timestamp).all()
|
| - |
|
1020 |
|
| - |
|
1021 |
def get_non_zero_item_stock_purchase_params():
|
| - |
|
1022 |
return ItemStockPurchaseParams.query.filter(or_("numOfDaysStock!=0","minStockLevel!=0"))
|
| - |
|
1023 |
|
| 1020 |
|
1024 |
|