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

 import com.spice.profitmandi.common.web.client.RestClient;
 import com.spice.profitmandi.dao.Interface.Campaign;
 import com.spice.profitmandi.dao.cart.CartService;
 import com.spice.profitmandi.dao.entity.auth.AuthUser;
 import com.spice.profitmandi.dao.entity.auth.PartnerCollectionRemark;
-import com.spice.profitmandi.dao.entity.catalog.FocusedModel;
-import com.spice.profitmandi.dao.entity.catalog.Item;
+import com.spice.profitmandi.dao.entity.catalog.*;
-import com.spice.profitmandi.dao.entity.catalog.Scheme;
-import com.spice.profitmandi.dao.entity.catalog.TagListing;
+import com.spice.profitmandi.dao.entity.cs.NonSdBuying;
 import com.spice.profitmandi.dao.entity.cs.Position;
 import com.spice.profitmandi.dao.entity.cs.Ticket;
 import com.spice.profitmandi.dao.entity.dtr.User;
 import com.spice.profitmandi.dao.entity.dtr.*;
 import com.spice.profitmandi.dao.entity.fofo.*;
 import com.spice.profitmandi.dao.enumuration.transaction.LoanReferenceType;
 import com.spice.profitmandi.dao.enumuration.transaction.PriceDropImeiStatus;
 import com.spice.profitmandi.dao.enumuration.transaction.SchemePayoutStatus;
 import com.spice.profitmandi.dao.model.*;
 import com.spice.profitmandi.dao.repository.auth.AuthRepository;
+import com.spice.profitmandi.dao.repository.auth.NonSdBuyingRepository;
 import com.spice.profitmandi.dao.repository.auth.PartnerCollectionRemarkRepository;
 import com.spice.profitmandi.dao.repository.catalog.*;
 import com.spice.profitmandi.dao.repository.cs.CsService;
 import com.spice.profitmandi.dao.repository.cs.PartnerRegionRepository;
 import com.spice.profitmandi.dao.repository.cs.PositionRepository;
 import com.spice.profitmandi.dao.repository.warehouse.*;
 import com.spice.profitmandi.dao.service.biuedart.BluedartAuthService;
 import com.spice.profitmandi.dao.service.biuedart.BluedartService;
 import com.spice.profitmandi.dao.service.solr.FofoSolr;
 import com.spice.profitmandi.service.*;
+import com.spice.profitmandi.service.catalog.BrandsService;
 import com.spice.profitmandi.service.integrations.CCAvenuePaymentService;
 import com.spice.profitmandi.service.integrations.RazorpayPaymentService;
 import com.spice.profitmandi.service.integrations.bharti.model.BAGInsuranceModel;
 import com.spice.profitmandi.service.integrations.psismart.PsiSmartService;
 import com.spice.profitmandi.service.integrations.smartping.SmartPingService;
     @Autowired
     private RetailerService retailerService;
     @Autowired
+    private BrandsRepository brandsRepository;
+    @Autowired
     private TransactionService transactionService;
     @Autowired
     private ItemRepository itemRepository;
     @Autowired
     InvoiceService invoiceService;
     public void test() throws Exception {
-        this.setInventoryItemIdToPriceDropImei();
+        // this.setInventoryItemIdToPriceDropImei();
+       // this.reviewNonSdBuyingBrand();
         //fofoSolr.populateTagItems();
         //System.out.println(smartPingService.getAllAgentsByEmail());
         //System.out.println(psiSmartService.getRegistrationEndPoint("9990381569"));
         //migrateValentine();
         //Map<Integer, List<Offer>> offerMap = offerRepository.selectAllPublishedMapByPartner(YearMonth.now());
         sb.append("</tbody></table></body></html>");
         return sb.toString();
+    }
+    private String getMessageForUnauthorizedBuying(List<NonSdBuying> nsb) throws
+            ProfitMandiBusinessException {
+        StringBuilder sb = new StringBuilder();
+        sb.append("<html><body><p>Alert</p><p>Unauthorized Buying-</p>" + "<br/>" +
+                "<table style='border:1px solid black ;padding: 5px';>");
+        sb.append("<tbody>" +
+                "<tr>" +
+                "<th style='border:1px solid black;padding: 5px'>PartnerName</th>" +
+                "<th style='border:1px solid black;padding: 5px'>Brand Name</th>" +
+                "<th style='border:1px solid black;padding: 5px'>Brand Value</th>" +
+                "<th style='border:1px solid black;padding: 5px'>Created At</th>" +
+                "<th style='border:1px solid black;padding: 5px'>Reason</th>" +
+                "</tr>");
+        for (NonSdBuying entry : nsb) {
+            CustomRetailer customRetailer = retailerService.getFofoRetailer(entry.getFofoId());
+            List<Integer> brandIds = Collections.singletonList(entry.getBrandId());
+            BrandCatalog brandsDisplay = brandsRepository.selectByIds(brandIds).get(0);
+            sb.append("<tr>");
+            sb.append("<td style='border:1px solid black;padding: 5px'>" + customRetailer.getBusinessName() + "(" + customRetailer.getCode() + ")" + "</td>");
+            sb.append("<td style='border:1px solid black;padding: 5px'>" + brandsDisplay.getName() + "</td>");
+            sb.append("<td style='border:1px solid black;padding: 5px'>" + entry.getBrandValue() + "</td>");
+            sb.append("<td style='border:1px solid black;padding: 5px'>" + entry.getCreateTimestamp().format(DateTimeFormatter.ofPattern("dd/MM/yyyy")) + "</td>");
+            sb.append("<td style='border:1px solid black;padding: 5px'>" + entry.getReason() + "</td>");
+            sb.append("</tr>");
+        }
+        sb.append("</tbody></table></body></html>");
+        return sb.toString();
+    }
     public void reverseWallet() throws Exception {
         LocalDate localDate = LocalDate.of(2020, 10, 28);
         List<UserWalletHistory> uwhList = userWalletHistoryRepository.selectAllByDateType(localDate.atStartOfDay(), localDate.plusDays(1).atStartOfDay(), Arrays.asList(WalletReferenceType.SCHEME_IN, WalletReferenceType.SCHEME_OUT));
         for (UserWalletHistory uwh : uwhList) {
             if (uwh.getBusinessTimestamp().getMonth().equals(Month.SEPTEMBER)) {
+            }
+        }
+    }
+    @Autowired
+    private NonSdBuyingRepository nonSdBuyingRepository;
+    //Non Sd Buying
+    public void reviewNonSdBuyingBrand() throws
+            ProfitMandiBusinessException, MessagingException, UnsupportedEncodingException {
+        List<NonSdBuying> nonSdByuingActiveList = nonSdBuyingRepository.selectAllActiveNonSDBuyingList(true);
+        Map<Integer, NonSdBuying> unAuthorizedBuyingMap = nonSdByuingActiveList.stream().collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
+        if (!unAuthorizedBuyingMap.isEmpty()) {
+            for (Map.Entry<String, Set<Integer>> storeGuyEntry : csService.getAuthUserPartnerIdMappingByCategoryIds(Arrays.asList(ProfitMandiConstants.TICKET_CATEGORY_RBM, ProfitMandiConstants.TICKET_CATEGORY_SALES), true).entrySet()) {
+                List<NonSdBuying> unAuthorizedfilteredRows = storeGuyEntry.getValue().stream()
+                        .map(x -> unAuthorizedBuyingMap.get(x)).filter(x -> x != null).collect(Collectors.toList());
+                if(!unAuthorizedfilteredRows.isEmpty()){
+                    String subject = "Unauthorized Buying";
+                    String messageText = this.getMessageForUnauthorizedBuying(unAuthorizedfilteredRows);
+                    MimeMessage message = mailSender.createMimeMessage();
+                    MimeMessageHelper helper = new MimeMessageHelper(message, true);
+                    String[] email = new String[]{storeGuyEntry.getKey()};
+                   // String[] email = {"ranu.rajput@smartdukaan.com"};
+                    helper.setSubject(subject);
+                    helper.setText(messageText, true);
+                    helper.setTo(email);
+                    InternetAddress senderAddress = new InternetAddress("noreply@smartdukaan.com", "Smartdukaan Alerts");
+                    helper.setFrom(senderAddress);
+                    mailSender.send(message);
+                    LOGGER.info("unAuthorizedfilteredRows {}", unAuthorizedfilteredRows);
+                }
+            }
+        }
+    }
     @Autowired
     private LoanRepository loanRepository;
     @Autowired
     private LoanStatementRepository loanStatementRepository;
             warehouseInventoryItem.setLastScanType(in.shop2020.warehouse.ScanType.PURCHASE);
             warehouseInventoryItem.setCurrentQuantity(warehouseInventoryItem.getCurrentQuantity() + warehouseScan.getQuantity());
+        }
         for (Order order : orderList) {
-            if(order.getBillingTimestamp()!=null) {
+            if (order.getBillingTimestamp() != null) {
                 order.setStatus(OrderStatus.ACCEPTED);
                 order.setStatusDescription("Submitted for Processing");
                 order.setBillingTimestamp(null);
                 order.setBilledBy(null);
                 order.setSerialNumber(null);

Subversion Repositories SmartDukaan

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