Subversion Repositories SmartDukaan

Rev

Rev 32094 | Rev 32096 | 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
 
93
        Map<Integer, List<Loan>> defaultduedateMap = new HashMap<Integer, List<Loan>>();
94
        Map<Integer, BillingDaysAvg> billingDeliverAvgMap = new HashMap<Integer, BillingDaysAvg>();
95
        Map<Integer, Long> lastPurchaseMap = new HashMap<Integer, Long>();
96
        Map<Integer, Long> lastSaleMap = new HashMap<Integer, Long>();
97
        Map<Integer, PartnerDailyInvestment> partnerDailyInvestmentMap = new HashMap<Integer, PartnerDailyInvestment>();
98
        Map<Integer, Double> secondaryPartner = new HashMap<Integer, Double>();
99
 
100
        Map<Integer, Double> tertiaryPartner = new HashMap<Integer, Double>();
101
 
102
 
103
        if (retailerFilter.isCredit()) {
104
            List<Loan> dueDateLoans = sdCreditServiceImpl.getDueDateCrossLoan();
105
            List<Loan> defaultLoans = sdCreditServiceImpl.getDefaultLoan();
106
 
107
            defaultLoans.addAll(dueDateLoans);
108
            if (!defaultLoans.isEmpty()) {
109
                defaultduedateMap = defaultLoans.stream().collect(Collectors.groupingBy(x -> x.getFofoId()));
110
            }
111
        }
112
 
113
        if (retailerFilter.isBilling()) {
114
            List<BillingDaysAvg> billingDeliveryAvg = orderRepository.selectBillingToDeliverAvg(startDate, LocalDateTime.now());
115
            if (!billingDeliveryAvg.isEmpty()) {
116
                billingDeliverAvgMap = billingDeliveryAvg.stream().filter(x -> x.getAvg() > 1).collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
117
            }
118
        }
119
 
120
 
121
        if (retailerFilter.getSecondaryDays() != null) {
122
            List<LastSaleDateModel> purchaseOrders = orderRepository.getLastOrders();
123
            for (LastSaleDateModel purchaseOrder : purchaseOrders) {
32091 tejbeer 124
                long daysBetween = Duration.between(purchaseOrder.getDateTime().plusDays(1), LocalDateTime.now()).toDays();
32044 tejbeer 125
                if (daysBetween >= retailerFilter.getSecondaryDays()) {
126
                    lastPurchaseMap.put(purchaseOrder.getFofoId(), daysBetween);
127
                }
128
            }
129
        }
130
 
131
 
132
        if (retailerFilter.getTertiaryDays() != null) {
133
            List<LastSaleDateModel> saleOrders = fofoOrderRepository.getLastTertiaryOrders();
134
            for (LastSaleDateModel saleOrder : saleOrders) {
32091 tejbeer 135
                long daysBetween = Duration.between(saleOrder.getDateTime().plusDays(1), LocalDateTime.now()).toDays();
32044 tejbeer 136
                if (daysBetween >= retailerFilter.getTertiaryDays()) {
137
                    lastSaleMap.put(saleOrder.getFofoId(), daysBetween);
138
                }
139
            }
140
        }
141
 
142
 
143
        if (retailerFilter.getInvestmentPct() != null) {
32091 tejbeer 144
            List<PartnerDailyInvestment> partnerDailyInvestments = partnerDailyInvestmentRepository.selectAll(LocalDate.now().minusDays(1));
32044 tejbeer 145
            partnerDailyInvestmentMap = partnerDailyInvestments.stream().filter(x -> (100 - retailerFilter.getInvestmentPct()) <= x.getShortPercentage()).collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
146
        }
147
 
148
 
149
        if (retailerFilter.getMtdsPct() != null) {
150
            Map<Integer, Double> secondaryMtd = orderRepository.selectBillingDatesBetweenSumGroupByRetailerId(curDate.withDayOfMonth(1), curDate.with(LocalTime.MAX));
151
            Map<Integer, Double> secondarylmtd = orderRepository.selectBillingDatesBetweenSumGroupByRetailerId(
152
                    curDate.withDayOfMonth(1).minusMonths(1), curDate.with(LocalTime.MAX).minusMonths(1));
153
 
154
            Set<Integer> fofoIds = new HashSet<>();
155
            fofoIds.addAll(secondaryMtd.keySet());
156
            fofoIds.addAll(secondarylmtd.keySet());
32095 tejbeer 157
            LOGGER.info("fofoIds {}", fofoIds);
158
 
32044 tejbeer 159
 
160
            for (Integer fofoId : fofoIds) {
161
                double mtdVal = 0;
162
                double lmtdVal = 0;
163
                if (secondaryMtd.get(fofoId) != null) {
164
                    mtdVal = secondaryMtd.get(fofoId);
165
                }
166
                if (secondarylmtd.get(fofoId) != null) {
167
                    lmtdVal = secondarylmtd.get(fofoId);
168
                }
169
 
170
                double value = (mtdVal / lmtdVal) * 100;
171
                if (value <= retailerFilter.getMtdsPct()) {
172
                    secondaryPartner.put(fofoId, value);
173
                }
32095 tejbeer 174
 
175
                if (fofoId == 175139178) {
176
                    LOGGER.info("dd {}", mtdVal);
177
                    LOGGER.info("dd {}", lmtdVal);
178
 
179
                    LOGGER.info("dd {}", value);
180
 
181
                }
32044 tejbeer 182
            }
32095 tejbeer 183
 
32044 tejbeer 184
        }
185
 
186
 
32093 tejbeer 187
        if (retailerFilter.getMtdtPct() != null) {
32044 tejbeer 188
            Map<Integer, Double> lmtdSale = fofoOrderItemRepository.selectSumMopGroupByRetailer(
189
                    curDate.withDayOfMonth(1).minusMonths(1), curDate.with(LocalTime.MAX).minusMonths(1), 0, false);
190
            Map<Integer, Double> mtdSale = fofoOrderItemRepository.selectSumMopGroupByRetailer(curDate.withDayOfMonth(1), curDate.with(LocalTime.MAX), 0, false);
191
 
192
            Set<Integer> fofoIds = new HashSet<>();
193
            fofoIds.addAll(lmtdSale.keySet());
194
            fofoIds.addAll(mtdSale.keySet());
195
 
196
            for (Integer fofoId : fofoIds) {
197
                double mtdVal = 0;
198
                double lmtdVal = 0;
199
                if (mtdSale.get(fofoId) != null) {
200
                    mtdVal = mtdSale.get(fofoId);
201
                }
202
                if (lmtdSale.get(fofoId) != null) {
203
                    lmtdVal = lmtdSale.get(fofoId);
204
                }
205
 
206
                double value = (mtdVal / lmtdVal) * 100;
32094 tejbeer 207
                if (value <= retailerFilter.getMtdtPct()) {
32044 tejbeer 208
                    tertiaryPartner.put(fofoId, value);
209
                }
210
            }
211
 
212
 
213
        }
214
 
32091 tejbeer 215
        LOGGER.info("tertiaryPartner {}", tertiaryPartner);
216
 
217
        LOGGER.info("secondaryPartner {}", secondaryPartner);
218
 
219
 
32044 tejbeer 220
        NumberFormat numberformat = NumberFormat.getNumberInstance(new Locale("en", "IN"));
221
 
222
 
223
        for (Entry<Integer, CustomRetailer> customRetailerEntry : customRetailers.entrySet()) {
224
            int fofoId = customRetailerEntry.getKey();
225
            RetailerPeformanceFilterModel retailerPeformanceFilterModel = new RetailerPeformanceFilterModel();
226
            if (retailerFilter.isCredit()) {
227
                if (!defaultduedateMap.isEmpty()) {
228
                    if (defaultduedateMap.containsKey(fofoId)) {
229
                        retailerPeformanceFilterModel.setCredit(true);
230
                    }
231
                }
232
            }
233
 
234
            if (retailerFilter.isBilling()) {
235
                if (!billingDeliverAvgMap.isEmpty()) {
236
                    if (billingDeliverAvgMap.containsKey(fofoId)) {
237
                        retailerPeformanceFilterModel.setBilling(billingDeliverAvgMap.get(fofoId).getAvg());
238
                    }
239
                }
240
            }
241
 
242
            if (retailerFilter.getInvestmentPct() != null) {
243
 
244
                if (!partnerDailyInvestmentMap.isEmpty()) {
245
                    if (partnerDailyInvestmentMap.containsKey(fofoId)) {
246
                        retailerPeformanceFilterModel.setInvestment(100 - partnerDailyInvestmentMap.get(fofoId).getShortPercentage());
247
                    }
248
                }
249
 
250
            }
251
 
252
            if (retailerFilter.getSecondaryDays() != null) {
253
                if (!lastPurchaseMap.isEmpty()) {
254
                    if (lastPurchaseMap.containsKey(fofoId)) {
255
                        retailerPeformanceFilterModel.setSecondaryDays(lastPurchaseMap.get(fofoId));
256
                    }
257
                }
258
 
259
            }
260
 
261
 
262
            if (retailerFilter.getTertiaryDays() != null) {
263
                if (!lastSaleMap.isEmpty()) {
264
                    if (lastSaleMap.containsKey(fofoId)) {
265
                        retailerPeformanceFilterModel.setTertiaryDays(lastSaleMap.get(fofoId));
266
                    }
267
                }
268
            }
269
 
270
 
271
            if (retailerFilter.getMtdsPct() != null) {
272
                if (!secondaryPartner.isEmpty()) {
273
                    if (secondaryPartner.containsKey(fofoId)) {
274
                        retailerPeformanceFilterModel.setMtds(Double.valueOf(numberformat.format(secondaryPartner.get(fofoId))));
275
                    }
276
                }
277
            }
278
 
279
 
280
            if (retailerFilter.getMtdtPct() != null) {
281
                if (!tertiaryPartner.isEmpty()) {
282
                    if (tertiaryPartner.containsKey(fofoId)) {
283
                        retailerPeformanceFilterModel.setMtdt(Double.valueOf(numberformat.format(tertiaryPartner.get(fofoId))));
284
                    }
285
                }
286
            }
287
 
288
            if (retailerPeformanceFilterModel.getBilling() != null || retailerPeformanceFilterModel.getCredit() != null || retailerPeformanceFilterModel.getInvestment() != null || retailerPeformanceFilterModel.getSecondaryDays() != null || retailerPeformanceFilterModel.getTertiaryDays() != null || retailerPeformanceFilterModel.getMtds() != null || retailerPeformanceFilterModel.getMtdt() != null) {
289
 
290
                retailerPeformanceFilterModel.setFofoId(fofoId);
291
                retailerPerPeformanceFilterModels.add(retailerPeformanceFilterModel);
292
            }
293
 
294
 
295
        }
296
 
297
        return retailerPerPeformanceFilterModels;
298
    }
299
 
300
    public void sendPartnerPerformanceEmail(Map<Integer, RetailerPeformanceFilterModel> partnersPerformanceMap, RetailerFilterModel retailerFilterModel, Map<Integer, CustomRetailer> customRetailers) throws Exception {
301
        Map<String, Set<Integer>> storeGuyMap = csService.getAuthUserPartnerIdMapping();
302
 
303
        LOGGER.info("retailerFilterModel {}", retailerFilterModel);
304
        for (Entry<String, Set<Integer>> storeGuyEntry : storeGuyMap.entrySet()) {
305
 
306
            Set<Integer> fofoIds = storeGuyEntry.getValue();
307
            List<List<?>> rows = new ArrayList<>();
308
            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() + "%");
309
 
310
 
311
            LOGGER.info("headers {}", headers);
312
 
313
            for (Integer fofoId : fofoIds) {
314
                RetailerPeformanceFilterModel retailerPerformanceFilterModel = partnersPerformanceMap.get(fofoId);
315
 
316
                LOGGER.info("retailerPerformanceFilterModel {}", retailerPerformanceFilterModel);
317
 
318
                if (retailerPerformanceFilterModel != null) {
319
                    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()));
320
                }
321
 
322
            }
323
            if (!rows.isEmpty()) {
324
                ByteArrayOutputStream baos = FileUtil.getCSVByteStream(headers, rows);
32046 tejbeer 325
                this.sendMailWithAttachment(mailSender, new String[]{storeGuyEntry.getKey()}, null, "Partner Performance", "PFA", "PartnerPerformance.csv", new ByteArrayResource(baos.toByteArray()));
32044 tejbeer 326
            }
327
 
328
        }
329
 
330
 
331
    }
332
 
333
    public void sendMailWithAttachment(JavaMailSender mailSender, String[] emailTo, String[] cc, String subject, String body, String fileName, InputStreamSource inputStreamSource) throws Exception {
334
        MimeMessage message = mailSender.createMimeMessage();
335
        MimeMessageHelper helper = new MimeMessageHelper(message, true);
336
        helper.setSubject(subject);
337
        helper.setText(body);
338
        if (cc != null) {
339
            helper.setCc(cc);
340
        }
341
        helper.setTo(emailTo);
342
        helper.addAttachment(fileName, inputStreamSource);
343
        InternetAddress senderAddress = new InternetAddress("noreply@smartdukaan.com", "SmartDukaan Care");
344
        helper.setFrom(senderAddress);
345
        mailSender.send(message);
346
    }
347
 
348
 
349
    public RetailerFilterModel getRetailerFilterModel() {
350
        List<RetailerFilter> retailerFilters = retailerFilterRepository.selectAll();
351
 
352
        RetailerFilterModel retailerFilterModel = new RetailerFilterModel();
353
 
354
        for (RetailerFilter retailerFilter : retailerFilters) {
355
            if (retailerFilter.getName().equals("BillingToDeliverAvg")) {
356
                retailerFilterModel.setBilling(true);
357
            }
358
 
359
            if (retailerFilter.getName().equals("credit due/default")) {
360
                retailerFilterModel.setCredit(true);
361
            }
362
            if (retailerFilter.getName().equals("Investment")) {
363
                retailerFilterModel.setInvestmentPct(retailerFilter.getValue());
364
            }
365
            if (retailerFilter.getName().equals("Last Secondary")) {
366
                retailerFilterModel.setSecondaryDays(retailerFilter.getValue());
367
            }
368
            if (retailerFilter.getName().equals("Last Tertiary")) {
369
                retailerFilterModel.setTertiaryDays(retailerFilter.getValue());
370
            }
371
            if (retailerFilter.getName().equals("Secondary")) {
372
                retailerFilterModel.setMtdsPct(20);
373
            }
374
            if (retailerFilter.getName().equals("Tertiary")) {
375
                retailerFilterModel.setMtdtPct(20);
376
            }
377
 
378
 
379
        }
380
        return retailerFilterModel;
381
    }
382
 
383
 
384
}