| Line 868... |
Line 868... |
| 868 |
public void processPd(int priceDropId) throws ProfitMandiBusinessException {
|
868 |
public void processPd(int priceDropId) throws ProfitMandiBusinessException {
|
| 869 |
priceDropService.processPriceDrop(priceDropId);
|
869 |
priceDropService.processPriceDrop(priceDropId);
|
| 870 |
}
|
870 |
}
|
| 871 |
|
871 |
|
| 872 |
public void fixScheme() throws Exception {
|
872 |
public void fixScheme() throws Exception {
|
| - |
|
873 |
LOGGER.info("Partner Types found\tPartnerType To Remove\tAmout to Rollback");
|
| 873 |
final Map<Integer, Scheme> schemesMap = schemeRepository.selectAll().stream()
|
874 |
final Map<Integer, Scheme> schemesMap = schemeRepository.selectAll().stream()
|
| 874 |
.collect(Collectors.toMap(x -> x.getId(), x -> x));
|
875 |
.collect(Collectors.toMap(x -> x.getId(), x -> x));
|
| 875 |
List<SchemeInOut> sios = schemeInOutRepository.selectAllByCreateDate(LocalDate.of(2019, 9, 1).atTime(0, 0),
|
876 |
List<SchemeInOut> sios = schemeInOutRepository.selectAllByCreateDate(LocalDate.of(2019, 9, 1).atTime(0, 0),
|
| 876 |
LocalDateTime.now());
|
877 |
LocalDateTime.now());
|
| 877 |
Map<SioTuple, Map<PartnerType, List<SchemeInOut>>> schemeTupleMap = sios.stream().filter(x -> x.getRolledBackTimestamp() == null)
|
878 |
Map<SioTuple, Map<PartnerType, List<SchemeInOut>>> schemeTupleMap = sios.stream().filter(x -> x.getRolledBackTimestamp() == null)
|
| Line 879... |
Line 880... |
| 879 |
.collect(Collectors.groupingBy(
|
880 |
.collect(Collectors.groupingBy(
|
| 880 |
x -> new SioTuple(x.getInventoryItemId(), schemesMap.get(x.getSchemeId()).getType()),
|
881 |
x -> new SioTuple(x.getInventoryItemId(), schemesMap.get(x.getSchemeId()).getType()),
|
| 881 |
Collectors.groupingBy(x->schemesMap.get(x.getSchemeId()).getPartnerType(),
|
882 |
Collectors.groupingBy(x->schemesMap.get(x.getSchemeId()).getPartnerType(),
|
| 882 |
Collectors.mapping(x->x, Collectors.toList()))));
|
883 |
Collectors.mapping(x->x, Collectors.toList()))));
|
| 883 |
|
884 |
|
| 884 |
LOGGER.info("Partner Types found\tPartnerType To Remove\tAmout to Rollback");
|
- |
|
| 885 |
schemeTupleMap.entrySet().stream().filter(x->x.getValue().size()>1).forEach(x->{
|
885 |
schemeTupleMap.entrySet().stream().filter(x->x.getValue().size()>1).forEach(x->{
|
| 886 |
Map<PartnerType, List<SchemeInOut>> partnerTypeSchemeMap = x.getValue();
|
886 |
Map<PartnerType, List<SchemeInOut>> partnerTypeSchemeMap = x.getValue();
|
| 887 |
PartnerType partnerTypeToRemove = partnerTypeSchemeMap.keySet().stream().min(
|
887 |
PartnerType partnerTypeToRemove = partnerTypeSchemeMap.keySet().stream().min(
|
| 888 |
Comparator.comparing(y->PartnerType.PartnerTypeRankMap.get(y))).get();
|
888 |
Comparator.comparing(y->PartnerType.PartnerTypeRankMap.get(y))).get();
|
| 889 |
LOGGER.info("Partner Type to remove {}", partnerTypeToRemove);
|
889 |
LOGGER.info("Partner Type to remove {}", partnerTypeToRemove);
|