WebSVN – SmartDukaan – Diff – /trunk/profitmandi-cron/src/main/java/com/smartdukaan/cron/scheduled/ScheduledTasks.java

 import com.spice.profitmandi.dao.repository.transaction.PriceDropRepository;
 import com.spice.profitmandi.dao.repository.transaction.UserWalletHistoryRepository;
 import com.spice.profitmandi.dao.repository.transaction.UserWalletRepository;
 import com.spice.profitmandi.dao.repository.user.AddressRepository;
 import com.spice.profitmandi.service.PartnerInvestmentService;
+import com.spice.profitmandi.service.integrations.toffee.ToffeeService;
 import com.spice.profitmandi.service.inventory.InventoryService;
 import com.spice.profitmandi.service.order.OrderService;
 import com.spice.profitmandi.service.pricing.PriceDropService;
 import com.spice.profitmandi.service.recharge.provider.OxigenRechargeProviderService;
 import com.spice.profitmandi.service.recharge.provider.ThinkWalnutDigitalRechargeProviderService;
 	private PriceDropService priceDropService;
 	@Autowired
 	private CsService csService;
+	@Autowired
+	private ToffeeService toffeeService;
 	@Value("${oxigen.recharge.auth.key}")
 	private String oxigenRechargeAuthKey;
 	@Value("${oxigen.recharge.validation.url}")
 	private String oxigenRechargeValidationUrl;
 	public void grouping() throws Exception {
 		DateTimeFormatter dtf = DateTimeFormatter.ofPattern("MM-dd-yyyy hh:mm");
 		List<PriceDropIMEI> priceDropImeis = priceDropIMEIRepository.selectByStatus(PriceDropImeiStatus.APPROVED);
 		System.out.println(String.join("\t",
 				Arrays.asList("IMEI", "ItemId", "Brand", "Model Name", "Model Number", "Franchise Id", "Franchise Name",
-						"Grn On", "Price Dropped On", "Approved On", "Returned On","Price Drop Paid",  "Is Doa")));
+						"Grn On", "Price Dropped On", "Approved On", "Returned On", "Price Drop Paid", "Is Doa")));
 		Map<Integer, CustomRetailer> retailersMap = retailerService.getFofoRetailers();
 		for (PriceDropIMEI priceDropIMEI : priceDropImeis) {
-			if(priceDropIMEI.getPartnerId()==0) continue;
+			if (priceDropIMEI.getPartnerId() == 0)
+				continue;
 			HashSet<String> imeis = new HashSet<>();
 			PriceDrop priceDrop = priceDropRepository.selectById(priceDropIMEI.getPriceDropId());
 			imeis.add(priceDropIMEI.getImei());
 			List<InventoryItem> inventoryItems = inventoryItemRepository
 					.selectByFofoIdSerialNumbers(priceDropIMEI.getPartnerId(), imeis, false);
-			if(inventoryItems.size() == 0) {
+			if (inventoryItems.size() == 0) {
-				LOGGER.info("Need to investigate partnerId - {} imeis - {}" , priceDropIMEI.getPartnerId(), imeis);
+				LOGGER.info("Need to investigate partnerId - {} imeis - {}", priceDropIMEI.getPartnerId(), imeis);
 				continue;
+			}
 			InventoryItem inventoryItem = inventoryItems.get(0);
 			CustomRetailer customRetailer = retailersMap.get(inventoryItem.getFofoId());
 			if (inventoryItem.getLastScanType().equals(ScanType.DOA_OUT)
 							Arrays.asList(priceDropIMEI.getImei(), inventoryItem.getItemId() + "", item.getBrand(),
 									item.getModelName(), item.getModelNumber(), inventoryItem.getFofoId() + "",
 									customRetailer.getBusinessName(), inventoryItem.getCreateTimestamp().format(dtf),
 									priceDrop.getAffectedOn().format(dtf),
 									priceDropIMEI.getUpdateTimestamp().format(dtf),
-									inventoryItem.getUpdateTimestamp().format(dtf),
+									inventoryItem.getUpdateTimestamp().format(dtf), priceDrop.getPartnerPayout() + "",
-									priceDrop.getPartnerPayout() + "",
 									inventoryItem.getLastScanType().equals(ScanType.DOA_OUT) + "")));
+				}
+			}
+		}
 		/*
 		 * csService.getAuthUserPartnerEmailMapping().entrySet()) {
 		 * System.out.println(storeGuyEntry.getKey() + " = " +
 		 * storeGuyEntry.getValue()); }
 		 */
+	}
+	public void testToffee() throws Exception {
+		LOGGER.info("{}", toffeeService.getAuthToken());
+		LOGGER.info("{}", toffeeService.getProducts());
+		LOGGER.info("{}", toffeeService.getPincodes("36103000PR"));
+	}
+	public void schemeRollback(List<String> schemeIds) throws Exception {
+		List<Integer> schemeIdsInt = schemeIds.stream().map(x -> Integer.parseInt(x)).collect(Collectors.toList());
+		Map<Integer, Scheme> schemesMap = schemeRepository.selectBySchemeIds(schemeIdsInt, 0, 0).stream()
+				.collect(Collectors.toMap(x -> x.getId(), x -> x));
+		List<SchemeInOut> schemeInOuts = schemeInOutRepository.selectBySchemeIds(new HashSet<>(schemeIdsInt));
+		for (SchemeInOut sio : schemeInOuts) {
+			Scheme scheme = schemesMap.get(sio.getSchemeId());
+			if (scheme.getType().equals(SchemeType.IN)) {
+			} else if (scheme.getType().equals(SchemeType.OUT)) {
+				InventoryItem inventoryItem = inventoryItemRepository.selectById(sio.getInventoryItemId());
+				List<ScanRecord> sr = scanRecordRepository.selectByInventoryItemId(sio.getInventoryItemId());
+				ScanRecord scanRecord = sr.stream().filter(x -> x.getType().equals(ScanType.SALE))
+						.max((x1, x2) -> x1.getCreateTimestamp().compareTo(x2.getCreateTimestamp())).get();
+				if (scanRecord.getCreateTimestamp().isAfter(scheme.getEndDateTime())
+						|| scanRecord.getCreateTimestamp().isBefore(scheme.getStartDateTime())) {
+					sio.setRolledBackTimestamp(LocalDateTime.now());
+					FofoOrder fofoOrder = fofoOrderRepository.selectByOrderId(scanRecord.getOrderId());
+					String rollbackReason = "Scheme rolledback twice for "
+							+ itemRepository.selectById(inventoryItem.getItemId()).getItemDescription() + "/"
+							+ fofoOrder.getInvoiceNumber();
+					walletService.rollbackAmountFromWallet(scanRecord.getFofoId(), sio.getAmount(),
+							scanRecord.getOrderId(), WalletReferenceType.SCHEME_OUT, rollbackReason);
+					System.out.printf("Amount %f,SchemeId %d,Reason %s\n", sio.getAmount(), sio.getSchemeId(),
+							rollbackReason);
+				}
+			}
+		}
+		throw new Exception();
+	}
+}

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-cron/src/main/java/com/smartdukaan/cron/scheduled/ScheduledTasks.java – Rev 25616 → 25694