| Line 1170... |
Line 1170... |
| 1170 |
lines = session.query(OOSStatus.item_id, func.sum(OOSStatus.num_orders)/func.count(OOSStatus.num_orders)).filter(OOSStatus.date >= oosDate).filter(OOSStatus.sourceId == 1).filter(OOSStatus.is_oos == 0).group_by(OOSStatus.item_id).all()
|
1170 |
lines = session.query(OOSStatus.item_id, func.sum(OOSStatus.num_orders)/func.count(OOSStatus.num_orders)).filter(OOSStatus.date >= oosDate).filter(OOSStatus.sourceId == 1).filter(OOSStatus.is_oos == 0).group_by(OOSStatus.item_id).all()
|
| 1171 |
for line in lines:
|
1171 |
for line in lines:
|
| 1172 |
item_id = line[0]
|
1172 |
item_id = line[0]
|
| 1173 |
quantity = math.ceil(max(1,3*int(line[1])))
|
1173 |
quantity = math.ceil(max(1,3*int(line[1])))
|
| 1174 |
itemCountMap[item_id] = quantity
|
1174 |
itemCountMap[item_id] = quantity
|
| 1175 |
cl = CatalogClient().get_client()
|
1175 |
cl = CatalogClient('catalog_service_server_host_prod','catalog_service_server_port').get_client()
|
| 1176 |
cl.updateItemHoldInventory(itemCountMap)
|
1176 |
cl.updateItemHoldInventory(itemCountMap)
|
| 1177 |
|
1177 |
|
| 1178 |
def get_oos_statuses_for_x_days_for_item(itemId, sourceId, days):
|
1178 |
def get_oos_statuses_for_x_days_for_item(itemId, sourceId, days):
|
| 1179 |
timestamp = datetime.datetime.now()
|
1179 |
timestamp = datetime.datetime.now()
|
| 1180 |
timestamp = timestamp - datetime.timedelta(days = days)
|
1180 |
timestamp = timestamp - datetime.timedelta(days = days)
|