| Line 5... |
Line 5... |
| 5 |
import java.sql.Timestamp;
|
5 |
import java.sql.Timestamp;
|
| 6 |
import java.text.MessageFormat;
|
6 |
import java.text.MessageFormat;
|
| 7 |
import java.time.LocalDate;
|
7 |
import java.time.LocalDate;
|
| 8 |
import java.time.LocalDateTime;
|
8 |
import java.time.LocalDateTime;
|
| 9 |
import java.time.LocalTime;
|
9 |
import java.time.LocalTime;
|
| 10 |
import java.time.temporal.ChronoField;
|
- |
|
| 11 |
import java.time.temporal.ChronoUnit;
|
10 |
import java.time.temporal.ChronoUnit;
|
| 12 |
import java.time.temporal.IsoFields;
|
- |
|
| 13 |
import java.time.temporal.TemporalField;
|
- |
|
| 14 |
import java.util.ArrayList;
|
11 |
import java.util.ArrayList;
|
| 15 |
import java.util.Arrays;
|
12 |
import java.util.Arrays;
|
| 16 |
import java.util.HashMap;
|
13 |
import java.util.HashMap;
|
| 17 |
import java.util.HashSet;
|
14 |
import java.util.HashSet;
|
| 18 |
import java.util.List;
|
15 |
import java.util.List;
|
| Line 21... |
Line 18... |
| 21 |
import java.util.stream.Collectors;
|
18 |
import java.util.stream.Collectors;
|
| 22 |
|
19 |
|
| 23 |
import javax.mail.MessagingException;
|
20 |
import javax.mail.MessagingException;
|
| 24 |
import javax.mail.internet.InternetAddress;
|
21 |
import javax.mail.internet.InternetAddress;
|
| 25 |
import javax.mail.internet.MimeMessage;
|
22 |
import javax.mail.internet.MimeMessage;
|
| 26 |
import javax.persistence.TemporalType;
|
- |
|
| 27 |
|
23 |
|
| 28 |
import org.apache.commons.codec.CharEncoding;
|
24 |
import org.apache.commons.codec.CharEncoding;
|
| 29 |
import org.apache.commons.io.IOUtils;
|
25 |
import org.apache.commons.io.IOUtils;
|
| 30 |
import org.apache.commons.io.output.ByteArrayOutputStream;
|
26 |
import org.apache.commons.io.output.ByteArrayOutputStream;
|
| 31 |
import org.apache.logging.log4j.LogManager;
|
27 |
import org.apache.logging.log4j.LogManager;
|
| Line 488... |
Line 484... |
| 488 |
continue;
|
484 |
continue;
|
| 489 |
}
|
485 |
}
|
| 490 |
float walletAmount = walletService.getUserWallet(fofoStore.getId()).getAmount();
|
486 |
float walletAmount = walletService.getUserWallet(fofoStore.getId()).getAmount();
|
| 491 |
float inStockAmount = inventoryService.getTotalAmountInStock(fofoStore.getId());
|
487 |
float inStockAmount = inventoryService.getTotalAmountInStock(fofoStore.getId());
|
| 492 |
float salesAmount = orderService.getSales(fofoStore.getId(), LocalDateTime.now().minusDays(1).with(LocalTime.MIDNIGHT), LocalDateTime.now());
|
488 |
float salesAmount = orderService.getSales(fofoStore.getId(), LocalDateTime.now().minusDays(1).with(LocalTime.MIDNIGHT), LocalDateTime.now());
|
| 493 |
|
- |
|
| - |
|
489 |
float returnInTransitAmount = 0;
|
| 494 |
float unbilledStockAmount = 0;
|
490 |
float unbilledStockAmount = 0;
|
| 495 |
List<Order> unbilledOrders = transactionService.getInTransitOrders(fofoStore.getId());
|
491 |
List<Order> unbilledOrders = transactionService.getInTransitOrders(fofoStore.getId());
|
| 496 |
for (Order unBilledOrder : unbilledOrders) {
|
492 |
for (Order unBilledOrder : unbilledOrders) {
|
| 497 |
unbilledStockAmount += unBilledOrder.getTotalAmount();
|
493 |
unbilledStockAmount += unBilledOrder.getTotalAmount();
|
| 498 |
}
|
494 |
}
|
| Line 503... |
Line 499... |
| 503 |
LOGGER.info("Grn pending for Order {} and partner {}", grnPendingOrder.getId(),
|
499 |
LOGGER.info("Grn pending for Order {} and partner {}", grnPendingOrder.getId(),
|
| 504 |
grnPendingOrder.getRetailerEmailId());
|
500 |
grnPendingOrder.getRetailerEmailId());
|
| 505 |
grnPendingStockAmount += grnPendingOrder.getTotalAmount();
|
501 |
grnPendingStockAmount += grnPendingOrder.getTotalAmount();
|
| 506 |
}
|
502 |
}
|
| 507 |
float totalInvestedAmount = walletAmount + inStockAmount + unbilledStockAmount + grnPendingStockAmount + salesAmount;
|
503 |
float totalInvestedAmount = walletAmount + inStockAmount + unbilledStockAmount + grnPendingStockAmount + salesAmount;
|
| - |
|
504 |
float shortValue = fofoStore.getMinimumInvestment() - totalInvestedAmount;
|
| - |
|
505 |
|
| 508 |
List<Object> row = Arrays.asList(fofoStore.getCode(), retailer.getBusinessName(), retailer.getEmail(),
|
506 |
List<Object> row = Arrays.asList(fofoStore.getCode(), retailer.getBusinessName(), retailer.getEmail(),
|
| 509 |
retailer.getMobileNumber(), walletAmount, salesAmount, inStockAmount, 0, unbilledStockAmount,
|
507 |
retailer.getMobileNumber(), walletAmount, salesAmount, inStockAmount, 0, unbilledStockAmount,
|
| 510 |
grnPendingStockAmount, fofoStore.getMinimumInvestment(), totalInvestedAmount,
|
508 |
grnPendingStockAmount, fofoStore.getMinimumInvestment(), totalInvestedAmount, shortValue);
|
| 511 |
fofoStore.getMinimumInvestment() - totalInvestedAmount);
|
- |
|
| 512 |
float shortValue = fofoStore.getMinimumInvestment() - totalInvestedAmount;
|
- |
|
| 513 |
try {
|
509 |
try {
|
| 514 |
PartnerDailyInvestment parnterDailyInvestment = new PartnerDailyInvestment();
|
510 |
PartnerDailyInvestment partnerDailyInvestment = new PartnerDailyInvestment();
|
| 515 |
parnterDailyInvestment.setComplete(shortValue <= 0);
|
511 |
partnerDailyInvestment.setDate(yesterDay);
|
| - |
|
512 |
partnerDailyInvestment.setFofoId(fofoStore.getId());
|
| - |
|
513 |
partnerDailyInvestment.setGrnPendingAmount(grnPendingStockAmount);
|
| - |
|
514 |
partnerDailyInvestment.setInStockAmount(inStockAmount);
|
| 516 |
parnterDailyInvestment.setDate(yesterDay);
|
515 |
partnerDailyInvestment.setSalesAmount(salesAmount);
|
| - |
|
516 |
partnerDailyInvestment.setReturnInTransitAmount(returnInTransitAmount);
|
| - |
|
517 |
partnerDailyInvestment.setUnbilledAmount(unbilledStockAmount);
|
| 517 |
parnterDailyInvestment.setFofoId(fofoStore.getId());
|
518 |
partnerDailyInvestment.setWalletAmount(walletAmount);
|
| - |
|
519 |
partnerDailyInvestment.setMinInvestment(fofoStore.getMinimumInvestment());
|
| 518 |
partnerDailyInvestmentRepository.persist(parnterDailyInvestment);
|
520 |
partnerDailyInvestmentRepository.persist(partnerDailyInvestment);
|
| 519 |
} catch(Exception e) {
|
521 |
} catch(Exception e) {
|
| 520 |
e.printStackTrace();
|
522 |
e.printStackTrace();
|
| 521 |
}
|
523 |
}
|
| 522 |
rows.add(row);
|
524 |
rows.add(row);
|
| 523 |
|
525 |
|