package com.pollex.pam.service;

import java.time.Instant;
import java.util.List;

import javax.management.Notification;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.StringUtils;

import com.pollex.pam.domain.Appointment;
import com.pollex.pam.domain.Consultant;
import com.pollex.pam.domain.Customer;
import com.pollex.pam.domain.PersonalNotification;
import com.pollex.pam.domain.Satisfaction;
import com.pollex.pam.enums.NotificationTypeEnum;
import com.pollex.pam.enums.PersonalNotificationRoleEnum;
import com.pollex.pam.repository.CustomerRepository;
import com.pollex.pam.repository.PersonalNotificationRepository;
import com.pollex.pam.security.SecurityUtils;
import com.pollex.pam.service.dto.AppointmentUpdateDTO;

@Service
@Transactional
public class PersonalNotificationService {

	@Autowired
	PersonalNotificationRepository personalNotificationRepository;

	@Autowired
	ConsultantService consultantService;

	@Autowired
	AppointmentService appointmentService;

	@Autowired
	CustomerService customerService;

	@Autowired
	CustomerRepository customerRepository;

	@Autowired
	SatisfactionService satisfactionService;

	public List<PersonalNotification> getMyPersonalNotification(Long ownerId, PersonalNotificationRoleEnum role) {
		return personalNotificationRepository.findAllByOwnerRoleAndOwnerId(role, ownerId);
	}

	public void createSendSatisfactionToClientToCustomer(Appointment appointment) {
		PersonalNotification entity = new PersonalNotification();
		Consultant consultant = consultantService.findByAgentNo(appointment.getAgentNo());
		String content = consultant.getName()+"顧問請您填寫滿意度評比";
		entity.setContent(content);
		entity.setNotificationType(NotificationTypeEnum.ACTIVITY);
		entity.setOwnerId(appointment.getCustomerId());
		entity.setOwnerRole(PersonalNotificationRoleEnum.CUSTOMER);
		entity.setTitle("填寫滿意度");
		personalNotificationRepository.save(entity);
	}

	public void createSendNoticeToCustomer(Long appointmentId) {
		Appointment appointment = appointmentService.findById(appointmentId);
		PersonalNotification entity = new PersonalNotification();
		Consultant consultant = consultantService.findByAgentNo(appointment.getAgentNo());
		String content = "您有 "+consultant.getName()+"顧問的約訪通知";
		entity.setContent(content);
		entity.setNotificationType(NotificationTypeEnum.ACTIVITY);
		entity.setOwnerId(appointment.getCustomerId());
		entity.setOwnerRole(PersonalNotificationRoleEnum.CUSTOMER);
		entity.setTitle("顧問約訪通知");
		personalNotificationRepository.save(entity);
	}

    public void createNotFillAppointmentSatisfactionNumberToCustomer(Long customerId, int notFillSatisfactionSum) {
        PersonalNotification entity = new PersonalNotification();

        String content = "您有 "+notFillSatisfactionSum+" 筆顧問的滿意度需要填寫";
        entity.setContent(content);
        entity.setNotificationType(NotificationTypeEnum.ACTIVITY);
        entity.setOwnerId(customerId);
        entity.setOwnerRole(PersonalNotificationRoleEnum.CUSTOMER);
        entity.setTitle("客戶滿意度");
        personalNotificationRepository.save(entity);
    }

	public void createEditConsultantToConsultant(Consultant consultant) {
		PersonalNotification entity = new PersonalNotification();
		String content = "您的個人帳號設定已進行更新";
		entity.setContent(content);
		entity.setNotificationType(NotificationTypeEnum.ACTIVITY);
		entity.setOwnerId(consultant.getId());
		entity.setOwnerRole(PersonalNotificationRoleEnum.CONSULTANT);
		entity.setTitle("變更帳號資料");
		personalNotificationRepository.save(entity);
	}

	public void createMarkAppointmentDeletedToConsultant(Appointment appointment) {
		PersonalNotification entity = new PersonalNotification();
		Customer customer = customerRepository.findById(appointment.getCustomerId()).get();
		Consultant consultant = consultantService.findByAgentNo(appointment.getAgentNo());
		String content = customer.getName()+"客戶已取消您的預約";
		entity.setContent(content);
		entity.setNotificationType(NotificationTypeEnum.ACTIVITY);
		entity.setOwnerId(consultant.getId());
		entity.setOwnerRole(PersonalNotificationRoleEnum.CONSULTANT);
		entity.setTitle("取消預約提醒");
		personalNotificationRepository.save(entity);
	}

	public void createUpdateAppointmentToConsultant(Appointment appointment) {
		PersonalNotification entity = new PersonalNotification();
		Customer customer = customerRepository.findById(appointment.getCustomerId()).get();
		Consultant consultant = consultantService.findByAgentNo(appointment.getAgentNo());
		String content = customer.getName()+"客戶已更新您的預約資訊";
		entity.setContent(content);
		entity.setNotificationType(NotificationTypeEnum.ACTIVITY);
		entity.setOwnerId(consultant.getId());
		entity.setOwnerRole(PersonalNotificationRoleEnum.CONSULTANT);
		entity.setTitle("更新預約提醒");
		personalNotificationRepository.save(entity);
	}

	public void createScorefactionToConsultant(Satisfaction satisfaction) {
		PersonalNotification entity = new PersonalNotification();
		Appointment appointment = appointmentService.findById(satisfaction.getAppointmentId());
		Customer customer = customerRepository.findById(appointment.getCustomerId()).get();
		Consultant consultant = consultantService.findByAgentNo(appointment.getAgentNo());
		String content = customer.getName()+"客戶已對您進行滿意度評比";
		entity.setContent(content);
		entity.setNotificationType(NotificationTypeEnum.ACTIVITY);
		entity.setOwnerId(consultant.getId());
		entity.setOwnerRole(PersonalNotificationRoleEnum.CONSULTANT);
		entity.setTitle("客戶滿意度");
		personalNotificationRepository.save(entity);
	}

	public void readAllMyNotification() {
		if(StringUtils.hasText(SecurityUtils.getAgentNo())) {
			Long consultantId = consultantService.findByAgentNo(SecurityUtils.getAgentNo()).getId();
			readAllNotification(PersonalNotificationRoleEnum.CONSULTANT, consultantId);
		}else if(SecurityUtils.getCustomerDBId()!=null){
			readAllNotification(PersonalNotificationRoleEnum.CUSTOMER, SecurityUtils.getCustomerDBId());
		}
	}

	public void readAllNotification(PersonalNotificationRoleEnum ownerRole
			, Long ownerId) {
		List<PersonalNotification> allNotification = personalNotificationRepository.findAllByOwnerRoleAndOwnerId(ownerRole, ownerId);
		Instant today = Instant.now();
		allNotification.stream()
		.filter(notification ->  notification.getReadDate()==null)
		.forEach(notification ->{
			notification.setReadDate(today);
			personalNotificationRepository.saveAll(allNotification);
		});
	}
}