package com.pollex.pam.aop.logging.audit.strategy;

import com.google.gson.Gson;
import com.pollex.pam.aop.logging.audit.AuditLoggingType;
import com.pollex.pam.domain.AuditLogging;
import com.pollex.pam.repository.AuditLoggingRepository;
import com.pollex.pam.security.SecurityUtils;
import com.pollex.pam.service.dto.SatisfactionCustomerScoreDTO;
import org.aspectj.lang.ProceedingJoinPoint;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional;

import java.util.List;
import java.util.stream.Collectors;

import static com.pollex.pam.aop.logging.audit.AuditLoggingType.CUSTOMER_FILL_SATISFACTION;

@Component
@Transactional
public class LoggingFillSatisfactionStrategy implements AuditLoggingStrategy{

    @Autowired
    AuditLoggingRepository auditLoggingRepository;

    @Override
    public AuditLoggingType getType() {
        return CUSTOMER_FILL_SATISFACTION;
    }

    @Override
    public void auditLogging(ProceedingJoinPoint joinPoint) {
        Object arg = joinPoint.getArgs()[0];

        if(arg instanceof List) {
            List<SatisfactionCustomerScoreDTO> dtos = (List<SatisfactionCustomerScoreDTO>) arg;
            List<AuditLogging> loggings = dtos.stream().map(dto -> {
                AuditLogging auditLogging = new AuditLogging();
                auditLogging.setContent(new Gson().toJson(dto));
                auditLogging.setFunctionalType(getType());
                auditLogging.setCreatedBy(SecurityUtils.getCurrentUserLogin().orElse(null));

                return auditLogging;
            }).collect(Collectors.toList());

            auditLoggingRepository.saveAll(loggings);
        }
        else {
            SatisfactionCustomerScoreDTO dto = (SatisfactionCustomerScoreDTO) arg;
            AuditLogging auditLogging = new AuditLogging();
            auditLogging.setContent(new Gson().toJson(dto));
            auditLogging.setFunctionalType(getType());
            auditLogging.setCreatedBy(SecurityUtils.getCurrentUserLogin().orElse(null));

            auditLoggingRepository.save(auditLogging);
        }
    }
}