Subversion Repositories SmartDukaan

Rev

Rev 32095 | Rev 32102 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
32044 tejbeer 1
package com.spice.profitmandi.service;
2
 
3
import java.text.DecimalFormat;
4
import java.text.NumberFormat;
5
import java.time.Duration;
6
import java.time.LocalDate;
7
import java.time.LocalDateTime;
8
import java.time.LocalTime;
9
import java.util.ArrayList;
10
import java.util.Arrays;
11
import java.util.HashMap;
12
import java.util.HashSet;
13
import java.util.List;
14
import java.util.Locale;
15
import java.util.Map;
16
import java.util.Map.Entry;
17
import java.util.Set;
18
import java.util.stream.Collectors;
19
 
20
import javax.mail.internet.InternetAddress;
21
import javax.mail.internet.MimeMessage;
22
 
23
import org.apache.commons.io.output.ByteArrayOutputStream;
24
import org.apache.logging.log4j.LogManager;
25
import org.apache.logging.log4j.Logger;
26
import org.springframework.beans.factory.annotation.Autowired;
27
import org.springframework.core.io.ByteArrayResource;
28
import org.springframework.core.io.InputStreamSource;
29
import org.springframework.mail.javamail.JavaMailSender;
30
import org.springframework.mail.javamail.MimeMessageHelper;
31
import org.springframework.stereotype.Component;
32
 
33
import com.spice.profitmandi.common.model.CustomRetailer;
34
import com.spice.profitmandi.common.util.FileUtil;
35
import com.spice.profitmandi.dao.entity.fofo.PartnerDailyInvestment;
36
import com.spice.profitmandi.dao.entity.fofo.RetailerFilter;
37
import com.spice.profitmandi.dao.entity.transaction.Loan;
38
import com.spice.profitmandi.dao.model.BillingDaysAvg;
39
import com.spice.profitmandi.dao.model.LastSaleDateModel;
40
import com.spice.profitmandi.dao.model.RetailerFilterModel;
41
import com.spice.profitmandi.dao.model.RetailerPeformanceFilterModel;
42
import com.spice.profitmandi.dao.repository.cs.CsService;
43
import com.spice.profitmandi.dao.repository.dtr.RetailerFilterRepository;
44
import com.spice.profitmandi.dao.repository.fofo.FofoOrderItemRepository;
45
import com.spice.profitmandi.dao.repository.fofo.FofoOrderRepository;
46
import com.spice.profitmandi.dao.repository.fofo.PartnerDailyInvestmentRepository;
47
import com.spice.profitmandi.dao.repository.transaction.OrderRepository;
48
import com.spice.profitmandi.service.transaction.SDCreditServiceImpl;
49
import com.spice.profitmandi.service.user.RetailerService;
50
 
51
@Component
52
public class PerformanceServiceImpl implements PerformanceService {
53
 
54
 
55
    @Autowired
56
    private PartnerDailyInvestmentRepository partnerDailyInvestmentRepository;
57
 
58
    @Autowired
59
    private OrderRepository orderRepository;
60
 
61
    @Autowired
62
    private FofoOrderRepository fofoOrderRepository;
63
 
64
    @Autowired
65
    private FofoOrderItemRepository fofoOrderItemRepository;
66
 
67
    @Autowired
68
    private SDCreditServiceImpl sdCreditServiceImpl;
69
 
70
    @Autowired
71
    private RetailerService retailerService;
72
 
73
    @Autowired
74
    private CsService csService;
75
 
76
    @Autowired
77
    private JavaMailSender mailSender;
78
 
79
    @Autowired
80
    private RetailerFilterRepository retailerFilterRepository;
81
 
82
 
83
    private static final Logger LOGGER = LogManager.getLogger(PerformanceServiceImpl.class);
84
 
85
 
86
    @Override
87
    public List<RetailerPeformanceFilterModel> getPerformance(RetailerFilterModel retailerFilter, Map<Integer, CustomRetailer> customRetailers) {
88
        LocalDateTime curDate = LocalDate.now().atStartOfDay();
89
        LocalDateTime startDate = curDate.minusMonths(3);
90
        List<RetailerPeformanceFilterModel> retailerPerPeformanceFilterModels = new ArrayList<RetailerPeformanceFilterModel>();
91
        DecimalFormat decimalFormatter = new DecimalFormat("0.#");
92
 
32096 tejbeer 93
        Map<Integer, List<Loan>> duedateMap = new HashMap<Integer, List<Loan>>();
94
 
95
        Map<Integer, List<Loan>> defaultdateMap = new HashMap<Integer, List<Loan>>();
96
 
32044 tejbeer 97
        Map<Integer, BillingDaysAvg> billingDeliverAvgMap = new HashMap<Integer, BillingDaysAvg>();
98
        Map<Integer, Long> lastPurchaseMap = new HashMap<Integer, Long>();
99
        Map<Integer, Long> lastSaleMap = new HashMap<Integer, Long>();
100
        Map<Integer, PartnerDailyInvestment> partnerDailyInvestmentMap = new HashMap<Integer, PartnerDailyInvestment>();
101
        Map<Integer, Double> secondaryPartner = new HashMap<Integer, Double>();
102
 
103
        Map<Integer, Double> tertiaryPartner = new HashMap<Integer, Double>();
104
 
105
 
106
        if (retailerFilter.isCredit()) {
107
            List<Loan> dueDateLoans = sdCreditServiceImpl.getDueDateCrossLoan();
108
            List<Loan> defaultLoans = sdCreditServiceImpl.getDefaultLoan();
109
 
110
            if (!defaultLoans.isEmpty()) {
32096 tejbeer 111
                defaultdateMap = defaultLoans.stream().collect(Collectors.groupingBy(x -> x.getFofoId()));
32044 tejbeer 112
            }
32096 tejbeer 113
            if (!dueDateLoans.isEmpty()) {
114
                duedateMap = dueDateLoans.stream().collect(Collectors.groupingBy(x -> x.getFofoId()));
115
            }
32044 tejbeer 116
        }
117
 
32096 tejbeer 118
 
32044 tejbeer 119
        if (retailerFilter.isBilling()) {
120
            List<BillingDaysAvg> billingDeliveryAvg = orderRepository.selectBillingToDeliverAvg(startDate, LocalDateTime.now());
121
            if (!billingDeliveryAvg.isEmpty()) {
122
                billingDeliverAvgMap = billingDeliveryAvg.stream().filter(x -> x.getAvg() > 1).collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
123
            }
124
        }
125
 
126
 
127
        if (retailerFilter.getSecondaryDays() != null) {
128
            List<LastSaleDateModel> purchaseOrders = orderRepository.getLastOrders();
129
            for (LastSaleDateModel purchaseOrder : purchaseOrders) {
32091 tejbeer 130
                long daysBetween = Duration.between(purchaseOrder.getDateTime().plusDays(1), LocalDateTime.now()).toDays();
32044 tejbeer 131
                if (daysBetween >= retailerFilter.getSecondaryDays()) {
132
                    lastPurchaseMap.put(purchaseOrder.getFofoId(), daysBetween);
133
                }
134
            }
135
        }
136
 
137
 
138
        if (retailerFilter.getTertiaryDays() != null) {
139
            List<LastSaleDateModel> saleOrders = fofoOrderRepository.getLastTertiaryOrders();
140
            for (LastSaleDateModel saleOrder : saleOrders) {
32091 tejbeer 141
                long daysBetween = Duration.between(saleOrder.getDateTime().plusDays(1), LocalDateTime.now()).toDays();
32044 tejbeer 142
                if (daysBetween >= retailerFilter.getTertiaryDays()) {
143
                    lastSaleMap.put(saleOrder.getFofoId(), daysBetween);
144
                }
145
            }
146
        }
147
 
148
 
149
        if (retailerFilter.getInvestmentPct() != null) {
32091 tejbeer 150
            List<PartnerDailyInvestment> partnerDailyInvestments = partnerDailyInvestmentRepository.selectAll(LocalDate.now().minusDays(1));
32044 tejbeer 151
            partnerDailyInvestmentMap = partnerDailyInvestments.stream().filter(x -> (100 - retailerFilter.getInvestmentPct()) <= x.getShortPercentage()).collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
152
        }
153
 
154
 
155
        if (retailerFilter.getMtdsPct() != null) {
156
            Map<Integer, Double> secondaryMtd = orderRepository.selectBillingDatesBetweenSumGroupByRetailerId(curDate.withDayOfMonth(1), curDate.with(LocalTime.MAX));
157
            Map<Integer, Double> secondarylmtd = orderRepository.selectBillingDatesBetweenSumGroupByRetailerId(
158
                    curDate.withDayOfMonth(1).minusMonths(1), curDate.with(LocalTime.MAX).minusMonths(1));
159
 
160
            Set<Integer> fofoIds = new HashSet<>();
161
            fofoIds.addAll(secondaryMtd.keySet());
162
            fofoIds.addAll(secondarylmtd.keySet());
163
 
32096 tejbeer 164
 
32044 tejbeer 165
            for (Integer fofoId : fofoIds) {
166
                double mtdVal = 0;
167
                double lmtdVal = 0;
168
                if (secondaryMtd.get(fofoId) != null) {
169
                    mtdVal = secondaryMtd.get(fofoId);
170
                }
171
                if (secondarylmtd.get(fofoId) != null) {
172
                    lmtdVal = secondarylmtd.get(fofoId);
173
                }
174
 
175
                double value = (mtdVal / lmtdVal) * 100;
176
                if (value <= retailerFilter.getMtdsPct()) {
177
                    secondaryPartner.put(fofoId, value);
178
                }
32095 tejbeer 179
 
180
 
32044 tejbeer 181
            }
32095 tejbeer 182
 
32044 tejbeer 183
        }
184
 
185
 
32093 tejbeer 186
        if (retailerFilter.getMtdtPct() != null) {
32044 tejbeer 187
            Map<Integer, Double> lmtdSale = fofoOrderItemRepository.selectSumMopGroupByRetailer(
188
                    curDate.withDayOfMonth(1).minusMonths(1), curDate.with(LocalTime.MAX).minusMonths(1), 0, false);
189
            Map<Integer, Double> mtdSale = fofoOrderItemRepository.selectSumMopGroupByRetailer(curDate.withDayOfMonth(1), curDate.with(LocalTime.MAX), 0, false);
190
 
191
            Set<Integer> fofoIds = new HashSet<>();
192
            fofoIds.addAll(lmtdSale.keySet());
193
            fofoIds.addAll(mtdSale.keySet());
194
 
195
            for (Integer fofoId : fofoIds) {
196
                double mtdVal = 0;
197
                double lmtdVal = 0;
198
                if (mtdSale.get(fofoId) != null) {
199
                    mtdVal = mtdSale.get(fofoId);
200
                }
201
                if (lmtdSale.get(fofoId) != null) {
202
                    lmtdVal = lmtdSale.get(fofoId);
203
                }
204
 
205
                double value = (mtdVal / lmtdVal) * 100;
32094 tejbeer 206
                if (value <= retailerFilter.getMtdtPct()) {
32044 tejbeer 207
                    tertiaryPartner.put(fofoId, value);
208
                }
209
            }
210
 
211
 
212
        }
213
 
32091 tejbeer 214
        LOGGER.info("tertiaryPartner {}", tertiaryPartner);
215
 
216
        LOGGER.info("secondaryPartner {}", secondaryPartner);
217
 
218
 
32044 tejbeer 219
        NumberFormat numberformat = NumberFormat.getNumberInstance(new Locale("en", "IN"));
220
 
221
 
222
        for (Entry<Integer, CustomRetailer> customRetailerEntry : customRetailers.entrySet()) {
223
            int fofoId = customRetailerEntry.getKey();
224
            RetailerPeformanceFilterModel retailerPeformanceFilterModel = new RetailerPeformanceFilterModel();
225
            if (retailerFilter.isCredit()) {
32096 tejbeer 226
 
227
                if (!duedateMap.isEmpty()) {
228
                    retailerPeformanceFilterModel.setCredit("Due");
32044 tejbeer 229
                }
32096 tejbeer 230
                if (!defaultdateMap.isEmpty()) {
231
                    retailerPeformanceFilterModel.setCredit("Default");
232
 
233
                }
32044 tejbeer 234
            }
235
 
236
            if (retailerFilter.isBilling()) {
237
                if (!billingDeliverAvgMap.isEmpty()) {
238
                    if (billingDeliverAvgMap.containsKey(fofoId)) {
239
                        retailerPeformanceFilterModel.setBilling(billingDeliverAvgMap.get(fofoId).getAvg());
240
                    }
241
                }
242
            }
243
 
244
            if (retailerFilter.getInvestmentPct() != null) {
245
 
246
                if (!partnerDailyInvestmentMap.isEmpty()) {
247
                    if (partnerDailyInvestmentMap.containsKey(fofoId)) {
248
                        retailerPeformanceFilterModel.setInvestment(100 - partnerDailyInvestmentMap.get(fofoId).getShortPercentage());
249
                    }
250
                }
251
 
252
            }
253
 
254
            if (retailerFilter.getSecondaryDays() != null) {
255
                if (!lastPurchaseMap.isEmpty()) {
256
                    if (lastPurchaseMap.containsKey(fofoId)) {
257
                        retailerPeformanceFilterModel.setSecondaryDays(lastPurchaseMap.get(fofoId));
258
                    }
259
                }
260
 
261
            }
262
 
263
 
264
            if (retailerFilter.getTertiaryDays() != null) {
265
                if (!lastSaleMap.isEmpty()) {
266
                    if (lastSaleMap.containsKey(fofoId)) {
267
                        retailerPeformanceFilterModel.setTertiaryDays(lastSaleMap.get(fofoId));
268
                    }
269
                }
270
            }
271
 
272
 
273
            if (retailerFilter.getMtdsPct() != null) {
274
                if (!secondaryPartner.isEmpty()) {
275
                    if (secondaryPartner.containsKey(fofoId)) {
276
                        retailerPeformanceFilterModel.setMtds(Double.valueOf(numberformat.format(secondaryPartner.get(fofoId))));
277
                    }
278
                }
279
            }
280
 
281
 
282
            if (retailerFilter.getMtdtPct() != null) {
283
                if (!tertiaryPartner.isEmpty()) {
284
                    if (tertiaryPartner.containsKey(fofoId)) {
285
                        retailerPeformanceFilterModel.setMtdt(Double.valueOf(numberformat.format(tertiaryPartner.get(fofoId))));
286
                    }
287
                }
288
            }
289
 
290
            if (retailerPeformanceFilterModel.getBilling() != null || retailerPeformanceFilterModel.getCredit() != null || retailerPeformanceFilterModel.getInvestment() != null || retailerPeformanceFilterModel.getSecondaryDays() != null || retailerPeformanceFilterModel.getTertiaryDays() != null || retailerPeformanceFilterModel.getMtds() != null || retailerPeformanceFilterModel.getMtdt() != null) {
291
 
292
                retailerPeformanceFilterModel.setFofoId(fofoId);
293
                retailerPerPeformanceFilterModels.add(retailerPeformanceFilterModel);
294
            }
295
 
296
 
297
        }
298
 
299
        return retailerPerPeformanceFilterModels;
300
    }
301
 
302
    public void sendPartnerPerformanceEmail(Map<Integer, RetailerPeformanceFilterModel> partnersPerformanceMap, RetailerFilterModel retailerFilterModel, Map<Integer, CustomRetailer> customRetailers) throws Exception {
303
        Map<String, Set<Integer>> storeGuyMap = csService.getAuthUserPartnerIdMapping();
304
 
305
        LOGGER.info("retailerFilterModel {}", retailerFilterModel);
306
        for (Entry<String, Set<Integer>> storeGuyEntry : storeGuyMap.entrySet()) {
307
 
308
            Set<Integer> fofoIds = storeGuyEntry.getValue();
309
            List<List<?>> rows = new ArrayList<>();
310
            List<String> headers = Arrays.asList("Partner Name", "Code", "Credit- Due/Default", "Billing To Deliver", "Investment- Lower Than " + retailerFilterModel.getInvestmentPct() + "%", "Last Secondary-" + retailerFilterModel.getSecondaryDays() + "days", "Last Tertiary-" + retailerFilterModel.getTertiaryDays() + "days", "MTD Secondary < LMTD-" + retailerFilterModel.getMtdsPct() + "%", "MTD Tertiary < LMTD-" + retailerFilterModel.getMtdtPct() + "%");
311
 
312
 
313
            LOGGER.info("headers {}", headers);
314
 
315
            for (Integer fofoId : fofoIds) {
316
                RetailerPeformanceFilterModel retailerPerformanceFilterModel = partnersPerformanceMap.get(fofoId);
317
 
318
                LOGGER.info("retailerPerformanceFilterModel {}", retailerPerformanceFilterModel);
319
 
320
                if (retailerPerformanceFilterModel != null) {
321
                    rows.add(Arrays.asList(customRetailers.get(fofoId).getBusinessName(), customRetailers.get(fofoId).getCode(), retailerPerformanceFilterModel.getCredit(), retailerPerformanceFilterModel.getBilling(), retailerPerformanceFilterModel.getInvestment(), retailerPerformanceFilterModel.getSecondaryDays(), retailerPerformanceFilterModel.getTertiaryDays(), retailerPerformanceFilterModel.getMtds(), retailerPerformanceFilterModel.getMtdt()));
322
                }
323
 
324
            }
325
            if (!rows.isEmpty()) {
326
                ByteArrayOutputStream baos = FileUtil.getCSVByteStream(headers, rows);
32046 tejbeer 327
                this.sendMailWithAttachment(mailSender, new String[]{storeGuyEntry.getKey()}, null, "Partner Performance", "PFA", "PartnerPerformance.csv", new ByteArrayResource(baos.toByteArray()));
32044 tejbeer 328
            }
329
 
330
        }
331
 
332
 
333
    }
334
 
335
    public void sendMailWithAttachment(JavaMailSender mailSender, String[] emailTo, String[] cc, String subject, String body, String fileName, InputStreamSource inputStreamSource) throws Exception {
336
        MimeMessage message = mailSender.createMimeMessage();
337
        MimeMessageHelper helper = new MimeMessageHelper(message, true);
338
        helper.setSubject(subject);
339
        helper.setText(body);
340
        if (cc != null) {
341
            helper.setCc(cc);
342
        }
343
        helper.setTo(emailTo);
344
        helper.addAttachment(fileName, inputStreamSource);
345
        InternetAddress senderAddress = new InternetAddress("noreply@smartdukaan.com", "SmartDukaan Care");
346
        helper.setFrom(senderAddress);
347
        mailSender.send(message);
348
    }
349
 
350
 
351
    public RetailerFilterModel getRetailerFilterModel() {
352
        List<RetailerFilter> retailerFilters = retailerFilterRepository.selectAll();
353
 
354
        RetailerFilterModel retailerFilterModel = new RetailerFilterModel();
355
 
356
        for (RetailerFilter retailerFilter : retailerFilters) {
357
            if (retailerFilter.getName().equals("BillingToDeliverAvg")) {
358
                retailerFilterModel.setBilling(true);
359
            }
360
 
361
            if (retailerFilter.getName().equals("credit due/default")) {
362
                retailerFilterModel.setCredit(true);
363
            }
364
            if (retailerFilter.getName().equals("Investment")) {
365
                retailerFilterModel.setInvestmentPct(retailerFilter.getValue());
366
            }
367
            if (retailerFilter.getName().equals("Last Secondary")) {
368
                retailerFilterModel.setSecondaryDays(retailerFilter.getValue());
369
            }
370
            if (retailerFilter.getName().equals("Last Tertiary")) {
371
                retailerFilterModel.setTertiaryDays(retailerFilter.getValue());
372
            }
373
            if (retailerFilter.getName().equals("Secondary")) {
374
                retailerFilterModel.setMtdsPct(20);
375
            }
376
            if (retailerFilter.getName().equals("Tertiary")) {
377
                retailerFilterModel.setMtdtPct(20);
378
            }
379
 
380
 
381
        }
382
        return retailerFilterModel;
383
    }
384
 
385
 
386
}