| Line 57... |
Line 57... |
| 57 |
import com.spice.profitmandi.dao.entity.fofo.FofoLineItem;
|
57 |
import com.spice.profitmandi.dao.entity.fofo.FofoLineItem;
|
| 58 |
import com.spice.profitmandi.dao.entity.fofo.FofoOrder;
|
58 |
import com.spice.profitmandi.dao.entity.fofo.FofoOrder;
|
| 59 |
import com.spice.profitmandi.dao.entity.fofo.FofoOrderItem;
|
59 |
import com.spice.profitmandi.dao.entity.fofo.FofoOrderItem;
|
| 60 |
import com.spice.profitmandi.dao.entity.fofo.FofoStore;
|
60 |
import com.spice.profitmandi.dao.entity.fofo.FofoStore;
|
| 61 |
import com.spice.profitmandi.dao.entity.fofo.InventoryItem;
|
61 |
import com.spice.profitmandi.dao.entity.fofo.InventoryItem;
|
| - |
|
62 |
import com.spice.profitmandi.dao.entity.fofo.PartnerDailyInvestment;
|
| 62 |
import com.spice.profitmandi.dao.entity.fofo.PartnerType;
|
63 |
import com.spice.profitmandi.dao.entity.fofo.PartnerType;
|
| 63 |
import com.spice.profitmandi.dao.entity.fofo.PrebookingOrder;
|
64 |
import com.spice.profitmandi.dao.entity.fofo.PrebookingOrder;
|
| 64 |
import com.spice.profitmandi.dao.entity.fofo.Purchase;
|
65 |
import com.spice.profitmandi.dao.entity.fofo.Purchase;
|
| 65 |
import com.spice.profitmandi.dao.entity.fofo.PurchaseReturnItem;
|
66 |
import com.spice.profitmandi.dao.entity.fofo.PurchaseReturnItem;
|
| 66 |
import com.spice.profitmandi.dao.entity.fofo.ScanRecord;
|
67 |
import com.spice.profitmandi.dao.entity.fofo.ScanRecord;
|
| Line 105... |
Line 106... |
| 105 |
import com.spice.profitmandi.dao.repository.fofo.FofoLineItemRepository;
|
106 |
import com.spice.profitmandi.dao.repository.fofo.FofoLineItemRepository;
|
| 106 |
import com.spice.profitmandi.dao.repository.fofo.FofoOrderItemRepository;
|
107 |
import com.spice.profitmandi.dao.repository.fofo.FofoOrderItemRepository;
|
| 107 |
import com.spice.profitmandi.dao.repository.fofo.FofoOrderRepository;
|
108 |
import com.spice.profitmandi.dao.repository.fofo.FofoOrderRepository;
|
| 108 |
import com.spice.profitmandi.dao.repository.fofo.InventoryItemRepository;
|
109 |
import com.spice.profitmandi.dao.repository.fofo.InventoryItemRepository;
|
| 109 |
import com.spice.profitmandi.dao.repository.fofo.InvoiceNumberGenerationSequenceRepository;
|
110 |
import com.spice.profitmandi.dao.repository.fofo.InvoiceNumberGenerationSequenceRepository;
|
| - |
|
111 |
import com.spice.profitmandi.dao.repository.fofo.PartnerDailyInvestmentRepository;
|
| 110 |
import com.spice.profitmandi.dao.repository.fofo.PartnerTargetRepository;
|
112 |
import com.spice.profitmandi.dao.repository.fofo.PartnerTargetRepository;
|
| 111 |
import com.spice.profitmandi.dao.repository.fofo.PrebookingOrderRepository;
|
113 |
import com.spice.profitmandi.dao.repository.fofo.PrebookingOrderRepository;
|
| 112 |
import com.spice.profitmandi.dao.repository.fofo.PurchaseRepository;
|
114 |
import com.spice.profitmandi.dao.repository.fofo.PurchaseRepository;
|
| 113 |
import com.spice.profitmandi.dao.repository.fofo.PurchaseReturnItemRepository;
|
115 |
import com.spice.profitmandi.dao.repository.fofo.PurchaseReturnItemRepository;
|
| 114 |
import com.spice.profitmandi.dao.repository.fofo.ScanRecordRepository;
|
116 |
import com.spice.profitmandi.dao.repository.fofo.ScanRecordRepository;
|
| Line 1450... |
Line 1452... |
| 1450 |
order.setFulfilmentWarehouseId(warehouse.getId());
|
1452 |
order.setFulfilmentWarehouseId(warehouse.getId());
|
| 1451 |
|
1453 |
|
| 1452 |
}
|
1454 |
}
|
| 1453 |
|
1455 |
|
| 1454 |
}
|
1456 |
}
|
| - |
|
1457 |
|
| - |
|
1458 |
@Autowired
|
| - |
|
1459 |
PartnerDailyInvestmentRepository partnerDailyInvestmentRepository;
|
| - |
|
1460 |
|
| - |
|
1461 |
public void addInvestment() {
|
| - |
|
1462 |
List<LocalDate> dates = Arrays.asList(LocalDate.of(2021, 7, 13), LocalDate.of(2021, 7, 31));
|
| - |
|
1463 |
for(LocalDate date : dates) {
|
| - |
|
1464 |
LOGGER.info("Date - {}", date);
|
| - |
|
1465 |
Map<Integer, Boolean> investmentMap = partnerDailyInvestmentRepository.selectAll(date.plusDays(1)).stream().collect(Collectors.toMap(x->x.getFofoId(), x->x.getShortPercentage() <= 10));
|
| - |
|
1466 |
List<PartnerDailyInvestment> investments = partnerDailyInvestmentRepository.selectAll(date.minusDays(1));
|
| - |
|
1467 |
for(PartnerDailyInvestment investment : investments) {
|
| - |
|
1468 |
if (investmentMap.get(investment.getFofoId()) == null || (investmentMap.get(investment.getFofoId()) == investment.getShortPercentage() <= 10)) {
|
| - |
|
1469 |
//Do nothing
|
| - |
|
1470 |
} else {
|
| - |
|
1471 |
LOGGER.info("Problem with fofo id => {}", investment.getFofoId());
|
| - |
|
1472 |
}
|
| - |
|
1473 |
}
|
| - |
|
1474 |
}
|
| - |
|
1475 |
}
|
| 1455 |
|
1476 |
|
| 1456 |
}
|
1477 |
}
|
| 1457 |
|
1478 |
|
| 1458 |
//7015845171
|
1479 |
//7015845171
|
| 1459 |
|
1480 |
|