| Line 504... |
Line 504... |
| 504 |
rechargeProviders.stream().forEach(x -> {
|
504 |
rechargeProviders.stream().forEach(x -> {
|
| 505 |
Map<LocalDate, List<RechargeProviderCreditWalletHistory>> dateWiseProviderCreditsMap = allCreditHistory
|
505 |
Map<LocalDate, List<RechargeProviderCreditWalletHistory>> dateWiseProviderCreditsMap = allCreditHistory
|
| 506 |
.stream().filter(z -> z.getProviderId() == x.getId())
|
506 |
.stream().filter(z -> z.getProviderId() == x.getId())
|
| 507 |
.collect(Collectors.groupingBy(x1 -> x1.getReceiveTimestamp().toLocalDate()));
|
507 |
.collect(Collectors.groupingBy(x1 -> x1.getReceiveTimestamp().toLocalDate()));
|
| 508 |
|
508 |
|
| 509 |
LOGGER.info("dateWiseProviderCreditsMap -- {}", dateWiseProviderCreditsMap);
|
509 |
LOGGER.info("dateWiseProviderCreditsMap -{}", dateWiseProviderCreditsMap);
|
| 510 |
LocalDate endDate = LocalDate.now().plusDays(1);
|
510 |
LocalDate endDate = LocalDate.now().plusDays(1);
|
| 511 |
float previousDayClosing = 0;
|
511 |
float previousDayClosing = 0;
|
| 512 |
LocalDate date = LocalDate.of(2018, 4, 6);
|
512 |
LocalDate date = LocalDate.of(2018, 4, 6);
|
| 513 |
while (date.isBefore(endDate)) {
|
513 |
while (date.isBefore(endDate)) {
|
| 514 |
List<RechargeTransaction> dateWiseRechargeTransactions = rechargeTransactionRepository
|
514 |
List<RechargeTransaction> dateWiseRechargeTransactions = rechargeTransactionRepository
|
| Line 808... |
Line 808... |
| 808 |
}
|
808 |
}
|
| 809 |
|
809 |
|
| 810 |
}
|
810 |
}
|
| 811 |
}
|
811 |
}
|
| 812 |
}
|
812 |
}
|
| - |
|
813 |
|
| 813 |
public void rollOutUpgardedMargins() throws Exception {
|
814 |
public void rollOutUpgardedMargins() throws Exception {
|
| 814 |
LocalDate today = LocalDate.now();
|
815 |
LocalDate today = LocalDate.now();
|
| 815 |
LocalDate yesterday = today.minusDays(1);
|
816 |
LocalDate yesterday = today.minusDays(1);
|
| 816 |
int upgradedCount = 0;
|
817 |
int upgradedCount = 0;
|
| 817 |
List<FofoStore> stores = fofoStoreRepository.selectActiveStores();
|
818 |
List<FofoStore> stores = fofoStoreRepository.selectActiveStores();
|
| 818 |
StringBuilder sb = new StringBuilder();
|
819 |
StringBuilder sb = new StringBuilder();
|
| 819 |
for (FofoStore store : stores) {
|
820 |
for (FofoStore store : stores) {
|
| 820 |
int fofoId = store.getId();
|
821 |
int fofoId = store.getId();
|
| 821 |
|
822 |
|
| 822 |
PartnerType yesterdayPartnerType = partnerTypeChangeService.getTypeOnDate(fofoId, yesterday);
|
823 |
PartnerType yesterdayPartnerType = partnerTypeChangeService.getTypeOnDate(fofoId, yesterday);
|
| 823 |
PartnerType todayPartnerType = partnerTypeChangeService.getTypeOnDate(fofoId, today);
|
824 |
PartnerType todayPartnerType = partnerTypeChangeService.getTypeOnDate(fofoId, today);
|
| 824 |
if (!yesterdayPartnerType.nextPartnerTypes().contains(todayPartnerType)) {
|
825 |
if (!yesterdayPartnerType.nextPartnerTypes().contains(todayPartnerType)) {
|
| 825 |
continue;
|
826 |
continue;
|
| 826 |
}
|
827 |
}
|
| 827 |
if (!yesterdayPartnerType.equals(todayPartnerType)) {
|
828 |
if (!yesterdayPartnerType.equals(todayPartnerType)) {
|
| 828 |
upgradedCount++;
|
829 |
upgradedCount++;
|
| 829 |
sb.append(String.format("Partner Type has been changed for code %s from %s to %s", store.getCode(), yesterdayPartnerType.toString(), todayPartnerType.toString()));
|
830 |
sb.append(String.format("Partner Type has been changed for code %s from %s to %s", store.getCode(),
|
| - |
|
831 |
yesterdayPartnerType.toString(), todayPartnerType.toString()));
|
| 830 |
sb.append("<br>");
|
832 |
sb.append("<br>");
|
| 831 |
LOGGER.info("Partner Type has been changed for code {} from {} to {}", store.getCode(),
|
833 |
LOGGER.info("Partner Type has been changed for code {} from {} to {}", store.getCode(),
|
| 832 |
yesterdayPartnerType, todayPartnerType);
|
834 |
yesterdayPartnerType, todayPartnerType);
|
| 833 |
List<FofoOrder> fofoOrders = fofoOrderRepository.selectByFofoId(fofoId,
|
835 |
List<FofoOrder> fofoOrders = fofoOrderRepository.selectByFofoId(fofoId,
|
| 834 |
yesterday.withDayOfMonth(1).atStartOfDay(), yesterday.atStartOfDay(), 0, 0);
|
836 |
yesterday.withDayOfMonth(1).atStartOfDay(), yesterday.atStartOfDay(), 0, 0);
|
| 835 |
for (FofoOrder fofoOrder : fofoOrders) {
|
837 |
for (FofoOrder fofoOrder : fofoOrders) {
|
| 836 |
schemeService.processSchemeOut(fofoOrder.getId(), fofoId);
|
838 |
schemeService.processSchemeOut(fofoOrder.getId(), fofoId);
|
| 837 |
}
|
839 |
}
|
| 838 |
|
840 |
|
| 839 |
}
|
841 |
}
|
| 840 |
}
|
842 |
}
|
| 841 |
if(upgradedCount > 0) {
|
843 |
if (upgradedCount > 0) {
|
| - |
|
844 |
sendMailHtmlFormat(
|
| 842 |
sendMailHtmlFormat(new String[] {"amit.gupta@smartdukaan.com", "tarun.verma@smartdukaan.com", "neeraj.gupta@smartdukaan.com"}, sb.toString(), null, "Few Partners Category have been Upgraded");
|
845 |
new String[] { "amit.gupta@smartdukaan.com", "tarun.verma@smartdukaan.com",
|
| - |
|
846 |
"neeraj.gupta@smartdukaan.com" },
|
| - |
|
847 |
sb.toString(), null, "Few Partners Category have been Upgraded");
|
| 843 |
} else {
|
848 |
} else {
|
| - |
|
849 |
sendMailHtmlFormat(
|
| 844 |
sendMailHtmlFormat(new String[] {"amit.gupta@smartdukaan.com", "tarun.verma@smartdukaan.com", "neeraj.gupta@smartdukaan.com"}, sb.toString(), null, "No partners Category have been upgraded today");
|
850 |
new String[] { "amit.gupta@smartdukaan.com", "tarun.verma@smartdukaan.com",
|
| - |
|
851 |
"neeraj.gupta@smartdukaan.com" },
|
| - |
|
852 |
sb.toString(), null, "No partners Category have been upgraded today");
|
| 845 |
}
|
853 |
}
|
| 846 |
}
|
854 |
}
|
| 847 |
|
855 |
|
| 848 |
private class SaleRoles {
|
856 |
private class SaleRoles {
|
| 849 |
|
857 |
|
| Line 2970... |
Line 2978... |
| 2970 |
public void getVendorWarehouses(int warehouseId) {
|
2978 |
public void getVendorWarehouses(int warehouseId) {
|
| 2971 |
LOGGER.info("Warehouses - {}", warehouseRepository.getVendorWarehouses().get(warehouseId));
|
2979 |
LOGGER.info("Warehouses - {}", warehouseRepository.getVendorWarehouses().get(warehouseId));
|
| 2972 |
|
2980 |
|
| 2973 |
}
|
2981 |
}
|
| 2974 |
|
2982 |
|
| - |
|
2983 |
public void checkCancellationMargin() throws Exception {
|
| - |
|
2984 |
LocalDateTime startDate = LocalDate.of(2021, 4, 1).atStartOfDay();
|
| - |
|
2985 |
List<FofoOrder> fofoOrders = fofoOrderRepository.selectCancelledBetweenSaleDate(startDate, LocalDateTime.now());
|
| - |
|
2986 |
LOGGER.info("Total Orders = {}", fofoOrders.size());
|
| - |
|
2987 |
for(FofoOrder fofoOrder : fofoOrders) {
|
| - |
|
2988 |
List<UserWalletHistory> history = userWalletHistoryRepository.selectAllByreferenceIdandreferenceType(fofoOrder.getId(), WalletReferenceType.SCHEME_OUT);
|
| - |
|
2989 |
history.addAll(userWalletHistoryRepository.selectAllByreferenceIdandreferenceType(fofoOrder.getId(), WalletReferenceType.ACTIVATION_SCHEME));
|
| - |
|
2990 |
int walletSum = history.stream().mapToInt(x->x.getAmount()).sum();
|
| - |
|
2991 |
if(Math.abs(walletSum) > 1) {
|
| - |
|
2992 |
//LOGGER.info("Cancelled invoice {}, Order Id = {}, = havent rolledback, Value = {}", fofoOrder.getInvoiceNumber(), fofoOrder.getId(), walletSum);
|
| - |
|
2993 |
List<FofoOrderItem> fofoOrderItems = fofoOrderItemRepository.selectByOrderId(fofoOrder.getId());
|
| - |
|
2994 |
List<FofoLineItem> flis = fofoLineItemRepository.selectByFofoOrderItemId(fofoOrderItems.get(0).getId());
|
| - |
|
2995 |
FofoLineItem fli = flis.get(0);
|
| - |
|
2996 |
if(StringUtils.isEmpty(fli.getSerialNumber())) continue;
|
| - |
|
2997 |
List<SchemeInOut> schemeInOuts = schemeInOutRepository.selectByInventoryItemIds(new HashSet<>(Arrays.asList(fli.getInventoryItemId())));
|
| - |
|
2998 |
InventoryItem inventoryItem = inventoryItemRepository.selectById(fli.getInventoryItemId());
|
| - |
|
2999 |
double schemeSum = schemeInOuts.stream().filter(x->x.getRolledBackTimestamp()==null).mapToDouble(x->x.getAmount()).sum();
|
| - |
|
3000 |
/*if(inventoryItem.getGoodQuantity()==1) {
|
| - |
|
3001 |
LOGGER.info("GoodQty, Serial Number {}, InventoryItem = {}, Billed on {}", inventoryItem.getSerialNumber(), inventoryItem.getId(), inventoryItem.getUpdateTimestamp());
|
| - |
|
3002 |
} else if(inventoryItem.getBadQuantity()==1){
|
| - |
|
3003 |
LOGGER.info("Bad Qty, Serial Number {}, InventoryItem = {}, Billed on {}", inventoryItem.getSerialNumber(), inventoryItem.getId(), inventoryItem.getUpdateTimestamp());
|
| - |
|
3004 |
} else if (inventoryItem.getLastScanType().equals(ScanType.SALE)) {
|
| - |
|
3005 |
LOGGER.info("Problem Sold, Serial Number {}, InventoryItem = {}, Billed on {}", inventoryItem.getSerialNumber(), inventoryItem.getId(), inventoryItem.getUpdateTimestamp());
|
| - |
|
3006 |
}*/
|
| - |
|
3007 |
if (inventoryItem.getLastScanType().equals(ScanType.SALE) || inventoryItem.getLastScanType().equals(ScanType.SALE_RET)) {
|
| - |
|
3008 |
Map<String, Double> map = schemeInOuts.stream().collect(Collectors.groupingBy(x -> DateTimeFormatter.ofPattern("yyyyMMddHH").format(x.getCreateTimestamp()) + "- " + x.getSchemeId(), Collectors.summingDouble(x->x.getAmount())));
|
| - |
|
3009 |
for(Map.Entry<String, Double> entry : map.entrySet()) {
|
| - |
|
3010 |
LOGGER.info("{} = {}", entry.getKey(), entry.getValue());
|
| - |
|
3011 |
}
|
| - |
|
3012 |
LOGGER.info("id- {}, imei- {}, lastScan = {}, Scheme sum - {}", inventoryItem.getId(), inventoryItem.getSerialNumber(), inventoryItem.getLastScanType(), schemeSum);
|
| - |
|
3013 |
}
|
| - |
|
3014 |
}
|
| - |
|
3015 |
}
|
| - |
|
3016 |
|
| - |
|
3017 |
}
|
| - |
|
3018 |
|
| 2975 |
}
|
3019 |
}
|
| 2976 |
//2284
|
3020 |
//2284
|
| 2977 |
|
3021 |
|