Subversion Repositories SmartDukaan

Rev

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

Rev 33025 Rev 33415
Line 284... Line 284...
284 
        whatsappMessage.setDestAddr(phone);
 284 
        whatsappMessage.setDestAddr(phone);
285 
        whatsappMessageRepository.persist(whatsappMessage);
 285 
        whatsappMessageRepository.persist(whatsappMessage);
286 
    }
 286 
    }
287 
 
 287 
 
288 
    @Override
 288 
    @Override
289 
    public boolean isWhatMessageSend(String mobile) {
 289 
    public boolean shouldSendWhatsappMessage(String mobile) {
290 
        String destAddr = "91" + mobile;
 290 
        String destAddr = "91" + mobile;
291 
        boolean isSent = true;
 291 
        boolean shouldSend = true;
292 
        List<WhatsappMessage> whatsappMessages = whatsappMessageRepository.selectByDestAddr(destAddr, LocalDate.now());
 292 
        List<WhatsappMessage> whatsappMessages = whatsappMessageRepository.selectByDestAddr(destAddr, LocalDate.now());
293 
        if (!whatsappMessages.isEmpty()) {
 293 
        if (!whatsappMessages.isEmpty()) {
294 
            long failedCount = whatsappMessages.stream().filter(x -> x.getFailed() != null && x.getFailed().equals("FAILED")).collect(Collectors.counting());
 294 
            long failedCount = whatsappMessages.stream().filter(x -> x.getFailed() != null && x.getFailed().equals("FAILED")).collect(Collectors.counting());
295 
            if (failedCount >= 2) {
 295 
            if (failedCount >= 2) {
296 
                isSent = false;
 296 
                shouldSend = false;
297 
            }
 297 
            }
298 
        }
 298 
        }
299 
        return isSent;
 299 
        return shouldSend;
300 
    }
 300 
    }
301 
}
 301 
}