WebSVN – SmartDukaan – Diff – /trunk/profitmandi-dao/src/main/java/com/spice/profitmandi/service/scheme/SchemeServiceImpl.java

 import com.spice.profitmandi.common.util.FormattingUtils;
 import com.spice.profitmandi.common.util.StringUtils;
 import com.spice.profitmandi.common.util.Utils;
 import com.spice.profitmandi.dao.entity.catalog.Item;
 import com.spice.profitmandi.dao.entity.catalog.Scheme;
+import com.spice.profitmandi.dao.entity.catalog.SchemesImeisModel;
 import com.spice.profitmandi.dao.entity.fofo.*;
 import com.spice.profitmandi.dao.entity.transaction.PriceDrop;
 import com.spice.profitmandi.dao.enumuration.catalog.AmountType;
 import com.spice.profitmandi.dao.enumuration.catalog.SchemeType;
 import com.spice.profitmandi.dao.enumuration.fofo.ScanType;
+				}
 				if (amountToCredit > amountCredited + 1f) {
 					for (SchemeInOut sio : sios) {
 						sio.setRolledBackTimestamp(LocalDateTime.now());
 						sio.setStatus(SchemePayoutStatus.REJECTED);
-						sio.setStatusDescription("Partner Category upgraded, new entry added");
+						sio.setStatusDescription("Partner Category upgraded to " + scheme.getPartnerType() + ", new entry for margin added");
+					}
 					actualCredit = amountToCredit - amountCredited;
 				} else {
 					return 0;
+				}
 							"Special support adjusted against overall margin gains for Imei - " + inventoryItem.getSerialNumber(), amountToCredit - schemeInOut.getAmount(),
 							fofoOrder.getCreateTimestamp());
+				}
 				schemeInOut.setStatus(SchemePayoutStatus.REJECTED);
-				schemeInOut.setStatusDescription("Special support changed due to update in total margin");
+				schemeInOut.setStatusDescription("Failed!!, New Margin Entry added");
 				schemeInOut.setRolledBackTimestamp(LocalDateTime.now());
+			}
+		}
 						sioNew.setInventoryItemId(schemeInOut.getInventoryItemId());
 						sioNew.setSchemeId(schemeInOut.getSchemeId());
 						schemeInOutRepository.persist(sioNew);
 						schemeInOut.setStatus(SchemePayoutStatus.REJECTED);
-						schemeInOut.setStatusDescription("Pricedrop processed, new entries added");
+						schemeInOut.setStatusDescription("Change in margins due to price drop");
 						// IF not credited then dont consider any credit/debit for that sio entry
 						if (schemeInOut.getCreditTimestamp() != null) {
 							amountToCredit += sioNew.getAmount();
 							amountToDebit += schemeInOut.getAmount();
+						}
 				} else {
 					walletService.addAmountToWallet(fofoId, orderId, WalletReferenceType.SPECIAL_SUPPORT,
 							"Special Support for " + ii.getItem().getItemDescriptionNoColor() + ", Imei - " + serialNumber, pendingPayout.getAmount(),
 							fofoOrder.getCreateTimestamp());
 					pendingPayout.setStatusDescription("Special support credited");
+				}
 				pendingPayout.setCreditTimestamp(LocalDateTime.now());
 				pendingPayout.setStatus(SchemePayoutStatus.CREDITED);
 			} else {
 				pendingPayout.setStatus(SchemePayoutStatus.REJECTED);
 						"Rejected, activated on " + FormattingUtils.formatDate(activatedImei.getActivationTimestamp()));
+			}
+		}
+	}
+	@Override
+	public void processActivatedImeisForSchemes() throws ProfitMandiBusinessException {
+		List<SchemesImeisModel> schemesImeisModels = schemeRepository.selectSelectUnpaidSchemes();
+		LOGGER.info("Total Size - " + schemesImeisModels.size());
+		List<Integer> orderIds = schemesImeisModels.stream().map(x -> x.getOrderId()).collect(Collectors.toList());
+		List<FofoOrder> fofoOrders = fofoOrderRepository.selectAllByOrderIds(orderIds);
+		Map<Integer, FofoOrder> validOrdersMap = fofoOrders.stream().filter(x -> x.getCancelledTimestamp() == null).collect(Collectors.toMap(x -> x.getId(), x -> x));
+		Map<String, List<SchemesImeisModel>> validImeiSchemesModelMap = schemesImeisModels.stream().filter(x -> validOrdersMap.containsKey(x.getOrderId())).collect(Collectors.groupingBy(x -> x.getImei()));
+		for (Map.Entry<String, List<SchemesImeisModel>> imeiListEntry : validImeiSchemesModelMap.entrySet()) {
+			SchemesImeisModel schemesImeisModel = imeiListEntry.getValue().get(0);
+			List<Integer> schemeIds = imeiListEntry.getValue().stream().map(x -> x.getSchemeId()).collect(Collectors.toList());
+			LOGGER.info("Serial Number  - {}, Scheme IDs - {}", schemesImeisModel.getImei(), schemeIds);
+			InventoryItem inventoryItem = inventoryItemRepository.selectById(schemesImeisModel.getInventoryItemId());
+			List<Scheme> schemes = schemeRepository.selectBySchemeIds(schemeIds);
+			List<Scheme> activationSchemes = schemes.stream().filter(x -> x.getType().equals(SchemeType.ACTIVATION)).collect(Collectors.toList());
+			List<Scheme> supportSchemes = schemes.stream().filter(x -> x.getType().equals(SchemeType.SPECIAL_SUPPORT)).collect(Collectors.toList());
+			for (Scheme scheme : activationSchemes) {
+				this.createSchemeInOut(scheme, inventoryItem);
+			}
+			if (supportSchemes.size() > 0) {
+				FofoOrder fofoOrder = validOrdersMap.get(schemesImeisModel.getOrderId());
+				PartnerType partnerType = partnerTypeChangeService.getTypeOnMonth(fofoOrder.getFofoId(),
+						YearMonth.from(fofoOrder.getCreateTimestamp()));
+				this.processSpecialSupport(fofoOrder, supportSchemes, inventoryItem, partnerType, fofoOrder.getCreateTimestamp());
+			}
+		}
+	}
+}

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-dao/src/main/java/com/spice/profitmandi/service/scheme/SchemeServiceImpl.java – Rev 30796 → 30897