@AllArgsConstructor
@EzyConfigurationAfter
public class AdminEcommerceMailConfig implements EzyBeanConfig {

    private final EzyInputStreamLoader inputStreamLoader;
    private final AdminContentTemplateService contentTemplateService;

    @Override
    public void config() {
        addMailTemplates();
    }

    @SuppressWarnings("MethodLength")
    private void addMailTemplates() {
        contentTemplateService.addTemplateIfAbsent(
            ContentTemplateType.MAIL.toString(),
            TEMPLATE_NEW_ORDERS_FOR_MANAGERS,
            () -> AddContentTemplateModel.builder()
                .templateName(TEMPLATE_NEW_ORDERS_FOR_MANAGERS)
                .titleTemplate("${orders} new orders need to review")
                .contentTemplate(
                    readMailTemplateContentOrDefault(
                        TEMPLATE_NEW_ORDERS_FOR_MANAGERS,
                        "${orders} new orders need to review"
                    )
                )
                .status(ContentTemplateStatus.COMPLETED.toString())
                .build()
        );
    }

    private String readMailTemplateContentOrDefault(
        String templateName,
        String defaultContent
    ) {
        try {
            String templateFullName = getMailTemplateFullName(
                templateName
            );
            return EzyInputStreams.toStringUtf8(
                inputStreamLoader.load(
                    "ecommerce/" + templateFullName + ".html"
                )
            );
        } catch (IOException e) {
            return defaultContent;
        }
    }
}

@EzySingleton
public class AdminNewOrdersMailAppender extends
    AdminDataAppender<Order, Order, Void> {

    private final AdminMailServiceProxy mailServiceProxy;
    private final AdminEventHandlerManager eventHandlerManager;
    private final AdminEcommerceSettingService ecommerceSettingService;
    private final AdminSettingService settingService;
    private final AdminOrderRepository orderRepository;
    private final AtomicLong lastSendMailTime = new AtomicLong(
        System.currentTimeMillis()
    );

    public AdminNewOrdersMailAppender(
        AdminMailServiceProxy mailServiceProxy,
        AdminEventHandlerManager eventHandlerManager,
        ObjectMapper objectMapper,
        AdminEcommerceSettingService ecommerceSettingService,
        AdminSettingService settingService,
        AdminOrderRepository orderRepository
    ) {
        super(objectMapper, settingService);
        this.mailServiceProxy = mailServiceProxy;
        this.eventHandlerManager = eventHandlerManager;
        this.ecommerceSettingService = ecommerceSettingService;
        this.settingService = settingService;
        this.orderRepository = orderRepository;
    }

    @Override
    protected void doAppend() {
        int period = ecommerceSettingService.getNotifyNewOrdersPeriod();
        long sendMailTime = lastSendMailTime.get() + period * 60 * 1000L;
        long now = System.currentTimeMillis();
        if (sendMailTime > now) {
            return;
        }
        long lastOrderId = ecommerceSettingService
            .getLastNotifiedNewOrderId();
        if (lastOrderId == 0) {
            Order lastOrder = orderRepository.findLast();
            lastOrderId = lastOrder != null ? lastOrder.getId() : 0L;
        }
        List<Order> orders = orderRepository.findByIdGtOrStatus(
            lastOrderId,
            OrderStatus.WAITING_FOR_CONFIRMATION.toString(),
            Next.limit(LIMIT_300_RECORDS)
        );
        if (orders.isEmpty()) {
            return;
        }
        long waitingForConfirmationOrders = orders
            .stream()
            .filter(it -> it
                .getStatus()
                .equals(OrderStatus.WAITING_FOR_CONFIRMATION.toString())
            )
            .count();
        int ordersSize = orders.size();
        long newOrders = ordersSize - waitingForConfirmationOrders;
        Map<String, Object> parameters = EzyMapBuilder.mapBuilder()
            .put("orders", ordersSize)
            .put("newOrders", newOrders)
            .put("waitingForConfirmationOrders", waitingForConfirmationOrders)
            .put("adminUrl", settingService.getAdminUrl())
            .toMap();
        Collection<String> orderManagementEmails = ecommerceSettingService
            .getOrderManagementEmails();
        if (orderManagementEmails.size() > 0) {
            mailServiceProxy.send(
                AdminMailModel.builder()
                    .templateName(TEMPLATE_NEW_ORDERS_FOR_MANAGERS)
                    .to(orderManagementEmails)
                    .parameters(parameters)
                    .build()
            );
        }
        eventHandlerManager.handleEvent(
            INTERNAL_EVENT_NAME_NEW_ORDERS_APPEND,
            parameters
        );
        lastSendMailTime.set(now);
        ecommerceSettingService.setLastNotifiedNewOrderId(now);
        long newLastOrderId = last(orders).getId();
        if (newLastOrderId > lastOrderId) {
            ecommerceSettingService.setLastNotifiedNewOrderId(
                newLastOrderId
            );
        }
    }

    @Override
    protected List<Order> getValueList(Void unused) {
        throw new UnsupportedOperationException("unused");
    }

    @Override
    protected Void extractNewLastPageToken(List<Order> list, Void unused) {
        throw new UnsupportedOperationException("unused");
    }

    @Override
    protected String getAppenderNamePrefix() {
        return TEMPLATE_NEW_ORDERS_FOR_MANAGERS;
    }

    @Override
    protected Void defaultPageToken() {
        throw new UnsupportedOperationException("unused");
    }

    @Override
    protected Class<Void> pageTokenType() {
        return Void.class;
    }
}