Subversion Repositories SmartDukaan

Rev

Rev 24271 | Rev 24284 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 24271 Rev 24277
Line 49... Line 49...
49 
import com.spice.profitmandi.dao.entity.dtr.RechargeProviderCreditWalletHistory;
 49 
import com.spice.profitmandi.dao.entity.dtr.RechargeProviderCreditWalletHistory;
50 
import com.spice.profitmandi.dao.entity.dtr.RechargeTransaction;
 50 
import com.spice.profitmandi.dao.entity.dtr.RechargeTransaction;
51 
import com.spice.profitmandi.dao.entity.fofo.FofoOrder;
 51 
import com.spice.profitmandi.dao.entity.fofo.FofoOrder;
52 
import com.spice.profitmandi.dao.entity.fofo.FofoStore;
 52 
import com.spice.profitmandi.dao.entity.fofo.FofoStore;
53 
import com.spice.profitmandi.dao.entity.fofo.InventoryItem;
 53 
import com.spice.profitmandi.dao.entity.fofo.InventoryItem;
- 
 
 54 
import com.spice.profitmandi.dao.entity.fofo.PartnerDailyInvestment;
54 
import com.spice.profitmandi.dao.entity.fofo.PartnerTargetDetails;
 55 
import com.spice.profitmandi.dao.entity.fofo.PartnerTargetDetails;
55 
import com.spice.profitmandi.dao.entity.fofo.Purchase;
 56 
import com.spice.profitmandi.dao.entity.fofo.Purchase;
56 
import com.spice.profitmandi.dao.entity.fofo.SaleHeadDetails;
 57 
import com.spice.profitmandi.dao.entity.fofo.SaleHeadDetails;
57 
import com.spice.profitmandi.dao.entity.fofo.ScanRecord;
 58 
import com.spice.profitmandi.dao.entity.fofo.ScanRecord;
58 
import com.spice.profitmandi.dao.entity.fofo.SchemeInOut;
 59 
import com.spice.profitmandi.dao.entity.fofo.SchemeInOut;
Line 66... Line 67...
66 
import com.spice.profitmandi.dao.repository.dtr.RechargeProviderCreditWalletHistoryRepository;
 67 
import com.spice.profitmandi.dao.repository.dtr.RechargeProviderCreditWalletHistoryRepository;
67 
import com.spice.profitmandi.dao.repository.dtr.RechargeProviderRepository;
 68 
import com.spice.profitmandi.dao.repository.dtr.RechargeProviderRepository;
68 
import com.spice.profitmandi.dao.repository.dtr.RechargeTransactionRepository;
 69 
import com.spice.profitmandi.dao.repository.dtr.RechargeTransactionRepository;
69 
import com.spice.profitmandi.dao.repository.fofo.FofoOrderRepository;
 70 
import com.spice.profitmandi.dao.repository.fofo.FofoOrderRepository;
70 
import com.spice.profitmandi.dao.repository.fofo.InventoryItemRepository;
 71 
import com.spice.profitmandi.dao.repository.fofo.InventoryItemRepository;
- 
 
 72 
import com.spice.profitmandi.dao.repository.fofo.PartnerDailyInvestmentRepository;
71 
import com.spice.profitmandi.dao.repository.fofo.PartnerTargetRepository;
 73 
import com.spice.profitmandi.dao.repository.fofo.PartnerTargetRepository;
72 
import com.spice.profitmandi.dao.repository.fofo.PurchaseRepository;
 74 
import com.spice.profitmandi.dao.repository.fofo.PurchaseRepository;
73 
import com.spice.profitmandi.dao.repository.fofo.ScanRecordRepository;
 75 
import com.spice.profitmandi.dao.repository.fofo.ScanRecordRepository;
74 
import com.spice.profitmandi.dao.repository.fofo.SchemeInOutRepository;
 76 
import com.spice.profitmandi.dao.repository.fofo.SchemeInOutRepository;
75 
import com.spice.profitmandi.dao.repository.transaction.OrderRepository;
 77 
import com.spice.profitmandi.dao.repository.transaction.OrderRepository;
Line 133... Line 135...
133 
 
 135 
 
134 
	@Autowired
 136 
	@Autowired
135 
	private OrderService orderService;
 137 
	private OrderService orderService;
136 
 
 138 
 
137 
	@Autowired
 139 
	@Autowired
- 
 
 140 
	private PartnerDailyInvestmentRepository partnerDailyInvestmentRepository;
- 
 
 141 
 
- 
 
 142 
	@Autowired
138 
	private SchemeInOutRepository schemeInOutRepository;
 143 
	private SchemeInOutRepository schemeInOutRepository;
139 
 
 144 
 
140 
	@Autowired
 145 
	@Autowired
141 
	private RechargeTransactionRepository rechargeTransactionRepository;
 146 
	private RechargeTransactionRepository rechargeTransactionRepository;
142 
 
 147 
 
Line 461... Line 466...
461 
		}
 466 
		}
462 
		LOGGER.info("Cashbacks for Recharge processed Successfully");
 467 
		LOGGER.info("Cashbacks for Recharge processed Successfully");
463 
	}
 468 
	}
464 
 
 469 
 
465 
	public void sendPartnerInvestmentDetails(List<String> sendTo) throws Exception {
 470 
	public void sendPartnerInvestmentDetails(List<String> sendTo) throws Exception {
- 
 
 471 
		LocalDate yesterDay = LocalDate.now().minusDays(1);
466 
		List<FofoStore> fofoStores = fofoStoreRepository.selectAll();
 472 
		List<FofoStore> fofoStores = fofoStoreRepository.selectAll();
467 
		Map<Integer, CustomRetailer> customRetailerMap = retailerService
 473 
		Map<Integer, CustomRetailer> customRetailerMap = retailerService
468 
				.getFofoRetailers(fofoStores.stream().map(x -> x.getId()).collect(Collectors.toList()));
 474 
				.getFofoRetailers(fofoStores.stream().map(x -> x.getId()).collect(Collectors.toList()));
469 
 
 475 
 
470 
		List<String> headers = Arrays.asList("Code", "StoreName", "Email", "Mobile", "Wallet Amount",
 476 
		List<String> headers = Arrays.asList("Code", "StoreName", "Email", "Mobile", "Wallet Amount",
Line 497... Line 503...
497 
			float totalInvestedAmount = walletAmount + inStockAmount + unbilledStockAmount + grnPendingStockAmount;
 503 
			float totalInvestedAmount = walletAmount + inStockAmount + unbilledStockAmount + grnPendingStockAmount;
498 
			List<Object> row = Arrays.asList(fofoStore.getCode(), retailer.getBusinessName(), retailer.getEmail(),
 504 
			List<Object> row = Arrays.asList(fofoStore.getCode(), retailer.getBusinessName(), retailer.getEmail(),
499 
					retailer.getMobileNumber(), salesAmount, walletAmount, inStockAmount, 0, unbilledStockAmount,
 505 
					retailer.getMobileNumber(), salesAmount, walletAmount, inStockAmount, 0, unbilledStockAmount,
500 
					grnPendingStockAmount, fofoStore.getMinimumInvestment(), totalInvestedAmount,
 506 
					grnPendingStockAmount, fofoStore.getMinimumInvestment(), totalInvestedAmount,
501 
					fofoStore.getMinimumInvestment() - totalInvestedAmount);
 507 
					fofoStore.getMinimumInvestment() - totalInvestedAmount);
- 
 
 508 
			float shortValue = fofoStore.getMinimumInvestment() - totalInvestedAmount;
- 
 
 509 
			try {
- 
 
 510 
				PartnerDailyInvestment parnterDailyInvestment = new PartnerDailyInvestment();
- 
 
 511 
				parnterDailyInvestment.setComplete(shortValue <= 0);
- 
 
 512 
				parnterDailyInvestment.setDate(yesterDay);
- 
 
 513 
				parnterDailyInvestment.setFofoId(fofoStore.getId());
- 
 
 514 
				partnerDailyInvestmentRepository.persist(parnterDailyInvestment);
- 
 
 515 
			} catch(Exception e) {
- 
 
 516 
				e.printStackTrace();
- 
 
 517 
			}
502 
			rows.add(row);
 518 
			rows.add(row);
503 
 
 519 
 
504 
		}
 520 
		}
505 
		String fileName = "InvestmentSummary-" + FormattingUtils.formatDate(LocalDateTime.now()) + ".csv";
 521 
		String fileName = "InvestmentSummary-" + FormattingUtils.formatDate(LocalDateTime.now()) + ".csv";
506 
		ByteArrayOutputStream baos = FileUtil.getCSVByteStream(headers, rows);
 522 
		ByteArrayOutputStream baos = FileUtil.getCSVByteStream(headers, rows);