Subversion Repositories SmartDukaan

Rev

Rev 32046 | Rev 32093 | 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());
157
 
158
            for (Integer fofoId : fofoIds) {
159
                double mtdVal = 0;
160
                double lmtdVal = 0;
161
                if (secondaryMtd.get(fofoId) != null) {
162
                    mtdVal = secondaryMtd.get(fofoId);
163
                }
164
                if (secondarylmtd.get(fofoId) != null) {
165
                    lmtdVal = secondarylmtd.get(fofoId);
166
                }
167
 
168
                double value = (mtdVal / lmtdVal) * 100;
169
                if (value <= retailerFilter.getMtdsPct()) {
170
                    secondaryPartner.put(fofoId, value);
171
                }
172
            }
173
        }
174
 
175
 
176
        if (retailerFilter.getMtdsPct() != null) {
177
            Map<Integer, Double> lmtdSale = fofoOrderItemRepository.selectSumMopGroupByRetailer(
178
                    curDate.withDayOfMonth(1).minusMonths(1), curDate.with(LocalTime.MAX).minusMonths(1), 0, false);
179
            Map<Integer, Double> mtdSale = fofoOrderItemRepository.selectSumMopGroupByRetailer(curDate.withDayOfMonth(1), curDate.with(LocalTime.MAX), 0, false);
180
 
181
            Set<Integer> fofoIds = new HashSet<>();
182
            fofoIds.addAll(lmtdSale.keySet());
183
            fofoIds.addAll(mtdSale.keySet());
184
 
185
            for (Integer fofoId : fofoIds) {
186
                double mtdVal = 0;
187
                double lmtdVal = 0;
188
                if (mtdSale.get(fofoId) != null) {
189
                    mtdVal = mtdSale.get(fofoId);
190
                }
191
                if (lmtdSale.get(fofoId) != null) {
192
                    lmtdVal = lmtdSale.get(fofoId);
193
                }
194
 
195
                double value = (mtdVal / lmtdVal) * 100;
196
                if (value <= retailerFilter.getMtdsPct()) {
197
                    tertiaryPartner.put(fofoId, value);
198
                }
199
            }
200
 
201
 
202
        }
203
 
32091 tejbeer 204
        LOGGER.info("tertiaryPartner {}", tertiaryPartner);
205
 
206
        LOGGER.info("secondaryPartner {}", secondaryPartner);
207
 
208
 
32044 tejbeer 209
        NumberFormat numberformat = NumberFormat.getNumberInstance(new Locale("en", "IN"));
210
 
211
 
212
        for (Entry<Integer, CustomRetailer> customRetailerEntry : customRetailers.entrySet()) {
213
            int fofoId = customRetailerEntry.getKey();
214
            RetailerPeformanceFilterModel retailerPeformanceFilterModel = new RetailerPeformanceFilterModel();
215
            if (retailerFilter.isCredit()) {
216
                if (!defaultduedateMap.isEmpty()) {
217
                    if (defaultduedateMap.containsKey(fofoId)) {
218
                        retailerPeformanceFilterModel.setCredit(true);
219
                    }
220
                }
221
            }
222
 
223
            if (retailerFilter.isBilling()) {
224
                if (!billingDeliverAvgMap.isEmpty()) {
225
                    if (billingDeliverAvgMap.containsKey(fofoId)) {
226
                        retailerPeformanceFilterModel.setBilling(billingDeliverAvgMap.get(fofoId).getAvg());
227
                    }
228
                }
229
            }
230
 
231
            if (retailerFilter.getInvestmentPct() != null) {
232
 
233
                if (!partnerDailyInvestmentMap.isEmpty()) {
234
                    if (partnerDailyInvestmentMap.containsKey(fofoId)) {
235
                        retailerPeformanceFilterModel.setInvestment(100 - partnerDailyInvestmentMap.get(fofoId).getShortPercentage());
236
                    }
237
                }
238
 
239
            }
240
 
241
            if (retailerFilter.getSecondaryDays() != null) {
242
                if (!lastPurchaseMap.isEmpty()) {
243
                    if (lastPurchaseMap.containsKey(fofoId)) {
244
                        retailerPeformanceFilterModel.setSecondaryDays(lastPurchaseMap.get(fofoId));
245
                    }
246
                }
247
 
248
            }
249
 
250
 
251
            if (retailerFilter.getTertiaryDays() != null) {
252
                if (!lastSaleMap.isEmpty()) {
253
                    if (lastSaleMap.containsKey(fofoId)) {
254
                        retailerPeformanceFilterModel.setTertiaryDays(lastSaleMap.get(fofoId));
255
                    }
256
                }
257
            }
258
 
259
 
260
            if (retailerFilter.getMtdsPct() != null) {
261
                if (!secondaryPartner.isEmpty()) {
262
                    if (secondaryPartner.containsKey(fofoId)) {
263
                        retailerPeformanceFilterModel.setMtds(Double.valueOf(numberformat.format(secondaryPartner.get(fofoId))));
264
                    }
265
                }
266
            }
267
 
268
 
269
            if (retailerFilter.getMtdtPct() != null) {
270
                if (!tertiaryPartner.isEmpty()) {
271
                    if (tertiaryPartner.containsKey(fofoId)) {
272
                        retailerPeformanceFilterModel.setMtdt(Double.valueOf(numberformat.format(tertiaryPartner.get(fofoId))));
273
                    }
274
                }
275
            }
276
 
277
            if (retailerPeformanceFilterModel.getBilling() != null || retailerPeformanceFilterModel.getCredit() != null || retailerPeformanceFilterModel.getInvestment() != null || retailerPeformanceFilterModel.getSecondaryDays() != null || retailerPeformanceFilterModel.getTertiaryDays() != null || retailerPeformanceFilterModel.getMtds() != null || retailerPeformanceFilterModel.getMtdt() != null) {
278
 
279
                retailerPeformanceFilterModel.setFofoId(fofoId);
280
                retailerPerPeformanceFilterModels.add(retailerPeformanceFilterModel);
281
            }
282
 
283
 
284
        }
285
 
286
        return retailerPerPeformanceFilterModels;
287
    }
288
 
289
    public void sendPartnerPerformanceEmail(Map<Integer, RetailerPeformanceFilterModel> partnersPerformanceMap, RetailerFilterModel retailerFilterModel, Map<Integer, CustomRetailer> customRetailers) throws Exception {
290
        Map<String, Set<Integer>> storeGuyMap = csService.getAuthUserPartnerIdMapping();
291
 
292
        LOGGER.info("retailerFilterModel {}", retailerFilterModel);
293
        for (Entry<String, Set<Integer>> storeGuyEntry : storeGuyMap.entrySet()) {
294
 
295
            Set<Integer> fofoIds = storeGuyEntry.getValue();
296
            List<List<?>> rows = new ArrayList<>();
297
            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() + "%");
298
 
299
 
300
            LOGGER.info("headers {}", headers);
301
 
302
            for (Integer fofoId : fofoIds) {
303
                RetailerPeformanceFilterModel retailerPerformanceFilterModel = partnersPerformanceMap.get(fofoId);
304
 
305
                LOGGER.info("retailerPerformanceFilterModel {}", retailerPerformanceFilterModel);
306
 
307
                if (retailerPerformanceFilterModel != null) {
308
                    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()));
309
                }
310
 
311
            }
312
            if (!rows.isEmpty()) {
313
                ByteArrayOutputStream baos = FileUtil.getCSVByteStream(headers, rows);
32046 tejbeer 314
                this.sendMailWithAttachment(mailSender, new String[]{storeGuyEntry.getKey()}, null, "Partner Performance", "PFA", "PartnerPerformance.csv", new ByteArrayResource(baos.toByteArray()));
32044 tejbeer 315
            }
316
 
317
        }
318
 
319
 
320
    }
321
 
322
    public void sendMailWithAttachment(JavaMailSender mailSender, String[] emailTo, String[] cc, String subject, String body, String fileName, InputStreamSource inputStreamSource) throws Exception {
323
        MimeMessage message = mailSender.createMimeMessage();
324
        MimeMessageHelper helper = new MimeMessageHelper(message, true);
325
        helper.setSubject(subject);
326
        helper.setText(body);
327
        if (cc != null) {
328
            helper.setCc(cc);
329
        }
330
        helper.setTo(emailTo);
331
        helper.addAttachment(fileName, inputStreamSource);
332
        InternetAddress senderAddress = new InternetAddress("noreply@smartdukaan.com", "SmartDukaan Care");
333
        helper.setFrom(senderAddress);
334
        mailSender.send(message);
335
    }
336
 
337
 
338
    public RetailerFilterModel getRetailerFilterModel() {
339
        List<RetailerFilter> retailerFilters = retailerFilterRepository.selectAll();
340
 
341
        RetailerFilterModel retailerFilterModel = new RetailerFilterModel();
342
 
343
        for (RetailerFilter retailerFilter : retailerFilters) {
344
            if (retailerFilter.getName().equals("BillingToDeliverAvg")) {
345
                retailerFilterModel.setBilling(true);
346
            }
347
 
348
            if (retailerFilter.getName().equals("credit due/default")) {
349
                retailerFilterModel.setCredit(true);
350
            }
351
            if (retailerFilter.getName().equals("Investment")) {
352
                retailerFilterModel.setInvestmentPct(retailerFilter.getValue());
353
            }
354
            if (retailerFilter.getName().equals("Last Secondary")) {
355
                retailerFilterModel.setSecondaryDays(retailerFilter.getValue());
356
            }
357
            if (retailerFilter.getName().equals("Last Tertiary")) {
358
                retailerFilterModel.setTertiaryDays(retailerFilter.getValue());
359
            }
360
            if (retailerFilter.getName().equals("Secondary")) {
361
                retailerFilterModel.setMtdsPct(20);
362
            }
363
            if (retailerFilter.getName().equals("Tertiary")) {
364
                retailerFilterModel.setMtdtPct(20);
365
            }
366
 
367
 
368
        }
369
        return retailerFilterModel;
370
    }
371
 
372
 
373
}