Subversion Repositories SmartDukaan

Rev

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

Rev 32415 Rev 32417
Line 59... Line 59...
59 
    private RestClient restClient;
 59 
    private RestClient restClient;
60 
    @Value("${prod}")
 60 
    @Value("${prod}")
61 
    private boolean isProd;
 61 
    private boolean isProd;
62 
 
 62 
 
63 
    @Autowired
 63 
    @Autowired
64 
    private WhatsappMessageRepository messageRepository;
 64 
    private WhatsappMessageRepository whatsappMessageRepository;
65 
 
 65 
 
66 
    @Autowired
 66 
    @Autowired
67 
    private WhatsappMessageService whatsappMessageService;
 67 
    private WhatsappMessageService whatsappMessageService;
68 
 
 68 
 
69 
    @Override
 69 
    @Override
Line 275... Line 275...
275 
 
 275 
 
276 
            WhatsappMessage whatsappMessage = new WhatsappMessage();
 276 
            WhatsappMessage whatsappMessage = new WhatsappMessage();
277 
            whatsappMessage.setCreatedTimestamp(LocalDateTime.now());
 277 
            whatsappMessage.setCreatedTimestamp(LocalDateTime.now());
278 
            whatsappMessage.setExternalId(externalId);
 278 
            whatsappMessage.setExternalId(externalId);
279 
            whatsappMessage.setDestAddr(phone);
 279 
            whatsappMessage.setDestAddr(phone);
280 
            messageRepository.persist(whatsappMessage);
 280 
            whatsappMessageRepository.persist(whatsappMessage);
281 
        }
 281 
        }
282 
 
 282 
 
283 
    }
 283 
    }
284 
 
 284 
 
285 
    @Override
 285 
    @Override
286 
    public boolean isWhatMessageSend(String mobile) {
 286 
    public boolean isWhatMessageSend(String mobile) {
287 
        String destAddr = "91" + mobile;
 287 
        String destAddr = "91" + mobile;
288 
        boolean isSent = true;
 288 
        boolean isSent = true;
289 
        List<WhatsappMessage> whatsappMessages = messageRepository.selectByDestAddr(destAddr);
 289 
        List<WhatsappMessage> whatsappMessages = whatsappMessageRepository.selectByDestAddr(destAddr);
290 
        if (!whatsappMessages.isEmpty()) {
 290 
        if (!whatsappMessages.isEmpty()) {
291 
 
 291 
 
292 
            long failedCount = whatsappMessages.stream().filter(x -> x.getFailed().equals("FAILED")).collect(Collectors.counting());
 292 
            long failedCount = whatsappMessages.stream().filter(x -> x.getFailed().equals("FAILED")).collect(Collectors.counting());
293 
 
 293 
 
294 
 
 294