| Line 105... |
Line 105... |
| 105 |
import com.spice.profitmandi.dao.entity.fofo.RazorPay;
|
105 |
import com.spice.profitmandi.dao.entity.fofo.RazorPay;
|
| 106 |
import com.spice.profitmandi.dao.entity.fofo.ScanRecord;
|
106 |
import com.spice.profitmandi.dao.entity.fofo.ScanRecord;
|
| 107 |
import com.spice.profitmandi.dao.entity.fofo.SchemeInOut;
|
107 |
import com.spice.profitmandi.dao.entity.fofo.SchemeInOut;
|
| 108 |
import com.spice.profitmandi.dao.entity.inventory.SaholicCIS;
|
108 |
import com.spice.profitmandi.dao.entity.inventory.SaholicCIS;
|
| 109 |
import com.spice.profitmandi.dao.entity.inventory.SaholicPOItem;
|
109 |
import com.spice.profitmandi.dao.entity.inventory.SaholicPOItem;
|
| 110 |
import com.spice.profitmandi.dao.entity.inventory.State;
|
- |
|
| 111 |
import com.spice.profitmandi.dao.entity.transaction.Order;
|
110 |
import com.spice.profitmandi.dao.entity.transaction.Order;
|
| 112 |
import com.spice.profitmandi.dao.entity.transaction.PriceDrop;
|
111 |
import com.spice.profitmandi.dao.entity.transaction.PriceDrop;
|
| 113 |
import com.spice.profitmandi.dao.entity.transaction.PriceDropIMEI;
|
112 |
import com.spice.profitmandi.dao.entity.transaction.PriceDropIMEI;
|
| 114 |
import com.spice.profitmandi.dao.entity.transaction.UserWallet;
|
113 |
import com.spice.profitmandi.dao.entity.transaction.UserWallet;
|
| 115 |
import com.spice.profitmandi.dao.entity.transaction.UserWalletHistory;
|
114 |
import com.spice.profitmandi.dao.entity.transaction.UserWalletHistory;
|
| Line 181... |
Line 180... |
| 181 |
import com.spice.profitmandi.dao.repository.transaction.PriceDropRepository;
|
180 |
import com.spice.profitmandi.dao.repository.transaction.PriceDropRepository;
|
| 182 |
import com.spice.profitmandi.dao.repository.transaction.UserWalletHistoryRepository;
|
181 |
import com.spice.profitmandi.dao.repository.transaction.UserWalletHistoryRepository;
|
| 183 |
import com.spice.profitmandi.dao.repository.transaction.UserWalletRepository;
|
182 |
import com.spice.profitmandi.dao.repository.transaction.UserWalletRepository;
|
| 184 |
import com.spice.profitmandi.dao.repository.user.AddressRepository;
|
183 |
import com.spice.profitmandi.dao.repository.user.AddressRepository;
|
| 185 |
import com.spice.profitmandi.dao.repository.user.UserRepository;
|
184 |
import com.spice.profitmandi.dao.repository.user.UserRepository;
|
| 186 |
import com.spice.profitmandi.service.EmailService;
|
- |
|
| 187 |
import com.spice.profitmandi.service.NotificationService;
|
185 |
import com.spice.profitmandi.service.NotificationService;
|
| 188 |
import com.spice.profitmandi.service.PartnerInvestmentService;
|
186 |
import com.spice.profitmandi.service.PartnerInvestmentService;
|
| 189 |
import com.spice.profitmandi.service.integrations.RazorpayPaymentService;
|
187 |
import com.spice.profitmandi.service.integrations.RazorpayPaymentService;
|
| 190 |
import com.spice.profitmandi.service.integrations.toffee.ToffeeService;
|
188 |
import com.spice.profitmandi.service.integrations.toffee.ToffeeService;
|
| 191 |
import com.spice.profitmandi.service.inventory.InventoryService;
|
189 |
import com.spice.profitmandi.service.inventory.InventoryService;
|
| Line 2586... |
Line 2584... |
| 2586 |
|
2584 |
|
| 2587 |
return sb.toString();
|
2585 |
return sb.toString();
|
| 2588 |
}
|
2586 |
}
|
| 2589 |
|
2587 |
|
| 2590 |
public void notifyLead() throws Exception {
|
2588 |
public void notifyLead() throws Exception {
|
| 2591 |
List<Lead> leadsToNotify = leadRepository.selectLeadsScheduledBetweenDate(LocalDateTime.now().minusDays(15),
|
2589 |
List<Lead> leadsToNotify = leadRepository.selectLeadsScheduledBetweenDate(null, LocalDateTime.now().minusDays(15),
|
| 2592 |
LocalDateTime.now().plusHours(4));
|
2590 |
LocalDateTime.now().plusHours(4));
|
| 2593 |
Map<Integer, String> authUserEmailMap = authRepository.selectAllActiveUser().stream()
|
2591 |
Map<Integer, String> authUserEmailMap = authRepository.selectAllActiveUser().stream()
|
| 2594 |
.collect(Collectors.toMap(x -> x.getId(), x -> x.getEmailId()));
|
2592 |
.collect(Collectors.toMap(x -> x.getId(), x -> x.getEmailId()));
|
| 2595 |
LOGGER.info("authUserEmailMap {}", authUserEmailMap);
|
2593 |
LOGGER.info("authUserEmailMap {}", authUserEmailMap);
|
| 2596 |
Map<String, Integer> dtrEmailMap = dtrUserRepository
|
2594 |
Map<String, Integer> dtrEmailMap = dtrUserRepository
|