Subversion Repositories SmartDukaan

Rev

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

Rev 32350 Rev 32384
Line 43... Line 43...
43
import javax.mail.MessagingException;
43
import javax.mail.MessagingException;
44
import javax.mail.internet.InternetAddress;
44
import javax.mail.internet.InternetAddress;
45
import javax.mail.internet.MimeMessage;
45
import javax.mail.internet.MimeMessage;
46
 
46
 
47
import com.smartdukaan.cron.itelImeiActivation.ItelImeiActivationNewService;
47
import com.smartdukaan.cron.itelImeiActivation.ItelImeiActivationNewService;
-
 
48
import com.spice.profitmandi.common.model.*;
-
 
49
import com.spice.profitmandi.dao.entity.warehouse.*;
48
import com.spice.profitmandi.dao.enumuration.transaction.SchemePayoutStatus;
50
import com.spice.profitmandi.dao.enumuration.transaction.SchemePayoutStatus;
-
 
51
import com.spice.profitmandi.dao.enumuration.warehouse.WarehouseInvoiceStatus;
-
 
52
import com.spice.profitmandi.dao.repository.warehouse.*;
49
import com.spice.profitmandi.service.*;
53
import com.spice.profitmandi.service.*;
-
 
54
import com.spice.profitmandi.service.warehouse.PurchaseOrderService;
50
import org.apache.commons.io.output.ByteArrayOutputStream;
55
import org.apache.commons.io.output.ByteArrayOutputStream;
51
import org.apache.commons.lang.StringUtils;
56
import org.apache.commons.lang.StringUtils;
52
import org.apache.http.client.methods.CloseableHttpResponse;
57
import org.apache.http.client.methods.CloseableHttpResponse;
53
import org.apache.http.client.methods.HttpPost;
58
import org.apache.http.client.methods.HttpPost;
54
import org.apache.http.conn.HttpHostConnectException;
59
import org.apache.http.conn.HttpHostConnectException;
Line 81... Line 86...
81
import com.spice.profitmandi.common.enumuration.ActivationType;
86
import com.spice.profitmandi.common.enumuration.ActivationType;
82
import com.spice.profitmandi.common.enumuration.MessageType;
87
import com.spice.profitmandi.common.enumuration.MessageType;
83
import com.spice.profitmandi.common.enumuration.RechargeStatus;
88
import com.spice.profitmandi.common.enumuration.RechargeStatus;
84
import com.spice.profitmandi.common.enumuration.ReporticoProject;
89
import com.spice.profitmandi.common.enumuration.ReporticoProject;
85
import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
90
import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
86
import com.spice.profitmandi.common.model.CustomRetailer;
-
 
87
import com.spice.profitmandi.common.model.FocusedModelShortageModel;
-
 
88
import com.spice.profitmandi.common.model.GstRate;
-
 
89
import com.spice.profitmandi.common.model.InvoicePdfModel;
-
 
90
import com.spice.profitmandi.common.model.ProfitMandiConstants;
-
 
91
import com.spice.profitmandi.common.model.RechargeCredential;
-
 
92
import com.spice.profitmandi.common.model.SendNotificationModel;
-
 
93
import com.spice.profitmandi.common.services.ReporticoService;
91
import com.spice.profitmandi.common.services.ReporticoService;
94
import com.spice.profitmandi.common.services.mandii.AccountStatusResponseOut;
92
import com.spice.profitmandi.common.services.mandii.AccountStatusResponseOut;
95
import com.spice.profitmandi.common.services.mandii.EligibilityStatusEnum;
93
import com.spice.profitmandi.common.services.mandii.EligibilityStatusEnum;
96
import com.spice.profitmandi.common.services.mandii.MandiiService;
94
import com.spice.profitmandi.common.services.mandii.MandiiService;
97
import com.spice.profitmandi.common.util.FileUtil;
95
import com.spice.profitmandi.common.util.FileUtil;
Line 258... Line 256...
258
import com.spice.profitmandi.dao.repository.transaction.TransactionRepository;
256
import com.spice.profitmandi.dao.repository.transaction.TransactionRepository;
259
import com.spice.profitmandi.dao.repository.transaction.UserWalletHistoryRepository;
257
import com.spice.profitmandi.dao.repository.transaction.UserWalletHistoryRepository;
260
import com.spice.profitmandi.dao.repository.transaction.UserWalletRepository;
258
import com.spice.profitmandi.dao.repository.transaction.UserWalletRepository;
261
import com.spice.profitmandi.dao.repository.user.AddressRepository;
259
import com.spice.profitmandi.dao.repository.user.AddressRepository;
262
import com.spice.profitmandi.dao.repository.user.UserRepository;
260
import com.spice.profitmandi.dao.repository.user.UserRepository;
263
import com.spice.profitmandi.dao.repository.warehouse.BilledImeiModel;
-
 
264
import com.spice.profitmandi.dao.repository.warehouse.BrandRegionMappingRepository;
-
 
265
import com.spice.profitmandi.dao.repository.warehouse.WarehouseInventoryItemRepository;
-
 
266
import com.spice.profitmandi.dao.service.solr.FofoSolr;
261
import com.spice.profitmandi.dao.service.solr.FofoSolr;
267
import com.spice.profitmandi.service.integrations.CCAvenuePaymentService;
262
import com.spice.profitmandi.service.integrations.CCAvenuePaymentService;
268
import com.spice.profitmandi.service.integrations.RazorpayPaymentService;
263
import com.spice.profitmandi.service.integrations.RazorpayPaymentService;
269
import com.spice.profitmandi.service.integrations.bharti.model.BAGInsuranceModel;
264
import com.spice.profitmandi.service.integrations.bharti.model.BAGInsuranceModel;
270
import com.spice.profitmandi.service.integrations.toffee.ToffeeService;
265
import com.spice.profitmandi.service.integrations.toffee.ToffeeService;
Line 1149... Line 1144...
1149
        }
1144
        }
1150
    }
1145
    }
1151
 
1146
 
1152
    public void test() throws Exception {
1147
    public void test() throws Exception {
1153
        try {
1148
        try {
1154
            this.sendUnscheduledFollowUpMail();
1149
            this.migrateDebitNote();
1155
            //itelImeiActivationNewService.checkItelImeiActivationNew(LocalDate.now(), 15);
1150
            //itelImeiActivationNewService.checkItelImeiActivationNew(LocalDate.now(), 15);
1156
        } catch (Throwable e) {
1151
        } catch (Throwable e) {
1157
            throw new Exception(e);
1152
            throw new Exception(e);
1158
        }
1153
        }
1159
 
1154
 
Line 1168... Line 1163...
1168
        //this.sendMailForAgeingAlert();
1163
        //this.sendMailForAgeingAlert();
1169
        //System.out.println(brandRegionMappingRepository.getAvailabilityToVendorWarehouse(Arrays.asList(33353), 7720));
1164
        //System.out.println(brandRegionMappingRepository.getAvailabilityToVendorWarehouse(Arrays.asList(33353), 7720));
1170
 
1165
 
1171
    }
1166
    }
1172
 
1167
 
-
 
1168
    @Autowired
-
 
1169
    WarehouseDebitNoteRepository warehouseDebitNoteRepository;
-
 
1170
    @Autowired
-
 
1171
    WarehouseDebitNoteLineRepository warehouseDebitNoteLineRepository;
-
 
1172
 
-
 
1173
    @Autowired
-
 
1174
    WarehouseInvoiceItemRepository warehouseInvoiceItemRepository;
-
 
1175
    @Autowired
-
 
1176
    WarehouseSupplierInvoiceRepository warehouseSupplierInvoiceRepository;
-
 
1177
 
-
 
1178
    @Autowired
-
 
1179
    PurchaseOrderService purchaseOrderService;
-
 
1180
 
-
 
1181
    public void migrateDebitNote() {
-
 
1182
        //Delete all debit notes table and then run this
-
 
1183
        List<WarehouseInvoiceItem> warehouseInvoiceItems = warehouseInvoiceItemRepository.selectAll();
-
 
1184
        List<WarehouseSupplierInvoice> invoices = warehouseSupplierInvoiceRepository.selectAllByIds(warehouseInvoiceItems.stream().map(x -> x.getInvoiceId()).distinct().collect(Collectors.toList()));
-
 
1185
        invoices = invoices.stream().filter(x -> x.getStatus().equals(WarehouseInvoiceStatus.received)).collect(Collectors.toList());
-
 
1186
        invoices.stream().forEach(x -> {
-
 
1187
            GrnModel grnModel = new GrnModel();
-
 
1188
            grnModel.setInvoiceId(x.getId());
-
 
1189
            try {
-
 
1190
                purchaseOrderService.generateDebitNote(Arrays.asList(grnModel));
-
 
1191
            } catch (Exception e) {
-
 
1192
                LOGGER.info("Could not create debit note for invoice - ", x.getInvoiceNumber());
-
 
1193
            }
-
 
1194
        });
-
 
1195
    }
-
 
1196
 
1173
//    private void checkItelImeiActivationNew(LocalDate now, int i) {
1197
//    private void checkItelImeiActivationNew(LocalDate now, int i) {
1174
//    }
1198
//    }
1175
 
1199
 
1176
    @Autowired
1200
    @Autowired
1177
    SessionFactory sessionFactory;
1201
    SessionFactory sessionFactory;
Line 4578... Line 4602...
4578
            vendorCatalogPricingModel.setAuthId(13);
4602
            vendorCatalogPricingModel.setAuthId(13);
4579
            vendorCatalogPricingModel.setDp(vendorItemPricing.getDp());
4603
            vendorCatalogPricingModel.setDp(vendorItemPricing.getDp());
4580
 
4604
 
4581
            vendorCatalogPricingModel.setTp(vendorItemPricing.getTp());
4605
            vendorCatalogPricingModel.setTp(vendorItemPricing.getTp());
4582
            vendorCatalogPricingModel.setMop(vendorItemPricing.getMop());
4606
            vendorCatalogPricingModel.setMop(vendorItemPricing.getMop());
4583
            vendorCatalogPricingModel.setEffectedOn(LocalDate.of(2023,8, 22));
4607
            vendorCatalogPricingModel.setEffectedOn(LocalDate.of(2023, 8, 22));
4584
            vendorCatalogPricingModel.setVendorId(vendorItemPricing.getVendorId());
4608
            vendorCatalogPricingModel.setVendorId(vendorItemPricing.getVendorId());
4585
 
4609
 
4586
 
4610
 
4587
            try {
4611
            try {
4588
                vendorCatalogPricingService.createVendorCatalogPricingLog(vendorCatalogPricingModel);
4612
                vendorCatalogPricingService.createVendorCatalogPricingLog(vendorCatalogPricingModel);