| Line 42... |
Line 42... |
| 42 |
import com.mongodb.DBObject;
|
42 |
import com.mongodb.DBObject;
|
| 43 |
import com.spice.profitmandi.common.enumuration.CounterSize;
|
43 |
import com.spice.profitmandi.common.enumuration.CounterSize;
|
| 44 |
import com.spice.profitmandi.common.enumuration.MessageType;
|
44 |
import com.spice.profitmandi.common.enumuration.MessageType;
|
| 45 |
import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
|
45 |
import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
|
| 46 |
import com.spice.profitmandi.common.model.BrandStockPrice;
|
46 |
import com.spice.profitmandi.common.model.BrandStockPrice;
|
| 47 |
import com.spice.profitmandi.common.model.CatalogIdAggregateValue;
|
47 |
import com.spice.profitmandi.common.model.IntegerIdAggregateValue;
|
| 48 |
import com.spice.profitmandi.common.model.CatalogListingModel;
|
48 |
import com.spice.profitmandi.common.model.CatalogListingModel;
|
| 49 |
import com.spice.profitmandi.common.model.CustomRetailer;
|
49 |
import com.spice.profitmandi.common.model.CustomRetailer;
|
| 50 |
import com.spice.profitmandi.common.model.PlannedModel;
|
50 |
import com.spice.profitmandi.common.model.PlannedModel;
|
| 51 |
import com.spice.profitmandi.common.model.SendNotificationModel;
|
51 |
import com.spice.profitmandi.common.model.SendNotificationModel;
|
| 52 |
import com.spice.profitmandi.common.model.StockAllocationModel;
|
52 |
import com.spice.profitmandi.common.model.StockAllocationModel;
|
| Line 664... |
Line 664... |
| 664 |
Collectors.groupingBy(x -> x.getCatalogItemId(), Collectors.mapping(y -> y, Collectors.toList())));
|
664 |
Collectors.groupingBy(x -> x.getCatalogItemId(), Collectors.mapping(y -> y, Collectors.toList())));
|
| 665 |
LOGGER.info("catalogIdItemMap");
|
665 |
LOGGER.info("catalogIdItemMap");
|
| 666 |
|
666 |
|
| 667 |
Map<String, Object> equalsItemJoinMap = new HashMap<>();
|
667 |
Map<String, Object> equalsItemJoinMap = new HashMap<>();
|
| 668 |
equalsItemJoinMap.put("active", 1);
|
668 |
equalsItemJoinMap.put("active", 1);
|
| 669 |
List<CatalogIdAggregateValue> tagListingCatalogIds = itemRepository.selectItems(TagListing.class, "id",
|
669 |
List<IntegerIdAggregateValue> tagListingCatalogIds = itemRepository.selectItems(TagListing.class, "id",
|
| 670 |
"itemId", equalsMap, notEqualsMap, equalsItemJoinMap, notEqualsJoinMap, "tagId");
|
670 |
"itemId", equalsMap, notEqualsMap, equalsItemJoinMap, notEqualsJoinMap, "tagId");
|
| 671 |
LOGGER.info("tagListingCatalogIds");
|
671 |
LOGGER.info("tagListingCatalogIds");
|
| 672 |
for (CatalogIdAggregateValue catalogIdAggregateValue : tagListingCatalogIds) {
|
672 |
for (IntegerIdAggregateValue catalogIdAggregateValue : tagListingCatalogIds) {
|
| 673 |
int catalogId = catalogIdAggregateValue.getCatalogId();
|
673 |
int catalogId = catalogIdAggregateValue.getCatalogId();
|
| 674 |
Item item = catalogIdItemMap.get(catalogId).get(0);
|
674 |
Item item = catalogIdItemMap.get(catalogId).get(0);
|
| 675 |
TagListing tagListing = taglistingMap.get(item.getId());
|
675 |
TagListing tagListing = taglistingMap.get(item.getId());
|
| 676 |
CatalogListingModel catalogListingModel = catalogListingMap.get(catalogId);
|
676 |
CatalogListingModel catalogListingModel = catalogListingMap.get(catalogId);
|
| 677 |
if (!catalogListingMap.containsKey(catalogId)) {
|
677 |
if (!catalogListingMap.containsKey(catalogId)) {
|
| Line 902... |
Line 902... |
| 902 |
Collectors.groupingBy(x -> x.getCatalogItemId(), Collectors.mapping(y -> y, Collectors.toList())));
|
902 |
Collectors.groupingBy(x -> x.getCatalogItemId(), Collectors.mapping(y -> y, Collectors.toList())));
|
| 903 |
LOGGER.info("catalogIdItemMap");
|
903 |
LOGGER.info("catalogIdItemMap");
|
| 904 |
|
904 |
|
| 905 |
Map<String, Object> equalsItemJoinMap = new HashMap<>();
|
905 |
Map<String, Object> equalsItemJoinMap = new HashMap<>();
|
| 906 |
equalsItemJoinMap.put("active", 1);
|
906 |
equalsItemJoinMap.put("active", 1);
|
| 907 |
List<CatalogIdAggregateValue> tagListingCatalogIds = itemRepository.selectItems(TagListing.class, "id",
|
907 |
List<IntegerIdAggregateValue> tagListingCatalogIds = itemRepository.selectItems(TagListing.class, "id",
|
| 908 |
"itemId", equalsMap, notEqualsMap, equalsItemJoinMap, notEqualsJoinMap, "tagId");
|
908 |
"itemId", equalsMap, notEqualsMap, equalsItemJoinMap, notEqualsJoinMap, "tagId");
|
| 909 |
LOGGER.info("tagListingCatalogIds");
|
909 |
LOGGER.info("tagListingCatalogIds");
|
| 910 |
for (CatalogIdAggregateValue catalogIdAggregateValue : tagListingCatalogIds) {
|
910 |
for (IntegerIdAggregateValue catalogIdAggregateValue : tagListingCatalogIds) {
|
| 911 |
int catalogId = catalogIdAggregateValue.getCatalogId();
|
911 |
int catalogId = catalogIdAggregateValue.getCatalogId();
|
| 912 |
Item item = catalogIdItemMap.get(catalogId).get(0);
|
912 |
Item item = catalogIdItemMap.get(catalogId).get(0);
|
| 913 |
TagListing tagListing = taglistingMap.get(item.getId());
|
913 |
TagListing tagListing = taglistingMap.get(item.getId());
|
| 914 |
CatalogListingModel catalogListingModel = catalogListingMap.get(catalogId);
|
914 |
CatalogListingModel catalogListingModel = catalogListingMap.get(catalogId);
|
| 915 |
if (!catalogListingMap.containsKey(catalogId)) {
|
915 |
if (!catalogListingMap.containsKey(catalogId)) {
|
| Line 1495... |
Line 1495... |
| 1495 |
Collectors.groupingBy(x -> x.getCatalogItemId(), Collectors.mapping(y -> y, Collectors.toList())));
|
1495 |
Collectors.groupingBy(x -> x.getCatalogItemId(), Collectors.mapping(y -> y, Collectors.toList())));
|
| 1496 |
LOGGER.info("catalogIdItemMap");
|
1496 |
LOGGER.info("catalogIdItemMap");
|
| 1497 |
|
1497 |
|
| 1498 |
Map<String, Object> equalsItemJoinMap = new HashMap<>();
|
1498 |
Map<String, Object> equalsItemJoinMap = new HashMap<>();
|
| 1499 |
equalsItemJoinMap.put("active", 1);
|
1499 |
equalsItemJoinMap.put("active", 1);
|
| 1500 |
List<CatalogIdAggregateValue> tagListingCatalogIds = itemRepository.selectItems(TagListing.class, "id",
|
1500 |
List<IntegerIdAggregateValue> tagListingCatalogIds = itemRepository.selectItems(TagListing.class, "id",
|
| 1501 |
"itemId", equalsMap, notEqualsMap, equalsItemJoinMap, notEqualsJoinMap, "tagId");
|
1501 |
"itemId", equalsMap, notEqualsMap, equalsItemJoinMap, notEqualsJoinMap, "tagId");
|
| 1502 |
Map<Integer, Integer> ourStockAvailability = new HashMap<>();
|
1502 |
Map<Integer, Integer> ourStockAvailability = new HashMap<>();
|
| 1503 |
Map<Integer, List<SaholicCIS>> itemAvailabilityMap = saholicInventoryService.getSaholicStock()
|
1503 |
Map<Integer, List<SaholicCIS>> itemAvailabilityMap = saholicInventoryService.getSaholicStock()
|
| 1504 |
.get(fofoStore.getWarehouseId());
|
1504 |
.get(fofoStore.getWarehouseId());
|
| 1505 |
|
1505 |
|
| Line 1520... |
Line 1520... |
| 1520 |
Integer catalogItemId = catalogItem.getKey();
|
1520 |
Integer catalogItemId = catalogItem.getKey();
|
| 1521 |
ourStockAvailability.put(catalogItemId, availability);
|
1521 |
ourStockAvailability.put(catalogItemId, availability);
|
| 1522 |
}
|
1522 |
}
|
| 1523 |
LOGGER.info("ourStockAvailability" + ourStockAvailability);
|
1523 |
LOGGER.info("ourStockAvailability" + ourStockAvailability);
|
| 1524 |
|
1524 |
|
| 1525 |
for (CatalogIdAggregateValue catalogIdAggregateValue : tagListingCatalogIds) {
|
1525 |
for (IntegerIdAggregateValue catalogIdAggregateValue : tagListingCatalogIds) {
|
| 1526 |
int catalogId = catalogIdAggregateValue.getCatalogId();
|
1526 |
int catalogId = catalogIdAggregateValue.getCatalogId();
|
| 1527 |
Item item = catalogIdItemMap.get(catalogId).get(0);
|
1527 |
Item item = catalogIdItemMap.get(catalogId).get(0);
|
| 1528 |
TagListing tagListing = taglistingMap.get(item.getId());
|
1528 |
TagListing tagListing = taglistingMap.get(item.getId());
|
| 1529 |
CatalogListingModel catalogListingModel = catalogListingMap.get(catalogId);
|
1529 |
CatalogListingModel catalogListingModel = catalogListingMap.get(catalogId);
|
| 1530 |
if (!catalogListingMap.containsKey(catalogId)) {
|
1530 |
if (!catalogListingMap.containsKey(catalogId)) {
|