保誠-保戶業務員媒合平台
究查 | 歷程 | 修補檔 | 提交 | 提交差異 | 忽略空白
wayne
2022-03-01 4df02e3b839a30ff2c68243820b48734f585baa1 
 pamapi/src/main/java/com/pollex/pam/service/AppointmentService.java


@@ -1,33 +1,36 @@


package com.pollex.pam.service;




import java.time.Instant;


import java.time.LocalDate;


import java.time.ZoneId;


import java.util.Comparator;


import java.util.List;


import java.util.Objects;


import java.util.Optional;


import java.util.stream.Collectors;




import com.pollex.pam.appointment.process.AppointmentProcess;


import com.pollex.pam.config.ApplicationProperties;


import com.pollex.pam.service.dto.AppointmentUpdateDTO;


import com.pollex.pam.service.dto.InterviewRecordDTO;


import com.pollex.pam.config.Constants;


import com.pollex.pam.enums.SatisfactionTypeEnum;


import com.pollex.pam.service.dto.*;


import com.pollex.pam.web.rest.errors.SendEmailFailException;


import com.pollex.pam.web.rest.errors.SendSMSFailException;


import io.jsonwebtoken.lang.Assert;


import org.slf4j.Logger;


import org.slf4j.LoggerFactory;


import org.springframework.beans.BeanUtils;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;




import com.pollex.pam.domain.Appointment;


import com.pollex.pam.domain.AppointmentCustomerView;


import com.pollex.pam.domain.InterviewRecord;


import com.pollex.pam.enums.ContactStatusEnum;


import com.pollex.pam.enums.InterviewRecordStatusEnum;


import com.pollex.pam.repository.AppointmentCustomerViewRepository;


import com.pollex.pam.repository.AppointmentRepository;


import com.pollex.pam.security.SecurityUtils;


import com.pollex.pam.service.dto.AppointmentCreateDTO;


import com.pollex.pam.service.dto.AppointmentCustomerViewDTO;


import com.pollex.pam.service.mapper.AppointmentCustomerViewMapper;


import com.pollex.pam.service.mapper.AppointmentDTOMapper;


import com.pollex.pam.web.rest.errors.AppointmentNotFoundException;


@@ -72,9 +75,15 @@




    @Autowired


    SpringTemplateEngine springTemplateEngine;


    




    @Autowired


    InterviewRecordService interviewRecordService;




    @Autowired


    AppointmentProcess abstractAppointmentProcess;




    @Autowired


    PersonalNotificationService personalNotificationService;




   public Appointment customerCreateAppointment(AppointmentCreateDTO appointmentCreateDTO) {


      Appointment appointment = appointmentDTOMapper.toAppointment(appointmentCreateDTO);


@@ -84,9 +93,9 @@


      return appointmentRepository.save(appointment);


   }




    public void updateAppointment(AppointmentUpdateDTO updateAppointmentDTO) {


    public Appointment updateAppointment(AppointmentUpdateDTO updateAppointmentDTO) {


        Appointment appointment = appointmentRepository.findById(updateAppointmentDTO.getId()).get();




        BeanUtils.copyProperties(updateAppointmentDTO, appointment);


        appointment.setPhone(updateAppointmentDTO.getPhone());


        appointment.setEmail(updateAppointmentDTO.getEmail());


        appointment.setContactType(updateAppointmentDTO.getContactType());


@@ -98,7 +107,7 @@


        appointment.setOtherRequirement(updateAppointmentDTO.getOtherRequirement());


        appointment.setLastModifiedDate(Instant.now());




        appointmentRepository.save(appointment);


        return appointmentRepository.save(appointment);


    }




    public void markAppointmentDeleted(Long appointmentId) {


@@ -107,6 +116,8 @@


        appointment.setLastModifiedDate(Instant.now());


        appointment.setCommunicateStatus(ContactStatusEnum.CANCEL);


        appointmentRepository.save(appointment);


        personalNotificationService.createMarkAppointmentDeletedToConsultant(appointment);




    }




   public List<Appointment> findByAgentNo(String agentNo) {


@@ -142,14 +153,13 @@


            .map(appointmentCustomerView -> {


                AppointmentCustomerViewDTO dto = appointmentCustomerViewMapper.toAppointmentCustomerViewDTO(appointmentCustomerView);


                setSatisfactionScore(dto, appointmentCustomerView.getId());


               


                return dto;


            })


            .collect(Collectors.toList());


    }




    public void setSatisfactionScore(AppointmentCustomerViewDTO dto, Long appointmentId) {


        satisfactionService.getByAppointmentId(appointmentId).ifPresent(satisfaction -> {


        satisfactionService.getByAppointmentIdAndType(appointmentId, SatisfactionTypeEnum.APPOINTMENT).ifPresent(satisfaction -> {


            dto.setSatisfactionScore(satisfaction.getScore());


        });


    }


@@ -190,8 +200,9 @@


    public void sendAppointmentNotify(Appointment appointment) {


        Assert.notNull(appointment, "appointment entity cannot be null");




        log.debug("is need send appointment notify msg? = {}", applicationProperties.isSendNotifyMsg());


        


        log.debug("is need send appointment notify msg? sms = {}, email = {}",


            applicationProperties.getSms().isSendNotifyMsg(), applicationProperties.getEmail().isSendNotifyMsg());




        log.debug("sending appointment notify, appointmentId = {}", appointment.getId());


        sendAppointmentNotifyBySMS(appointment);


        sendAppointmentNotifyByHtmlEmail(appointment);


@@ -256,9 +267,53 @@


    public String getAppointmentDetailUrl(Long appointmentId) {


        return applicationProperties.getFrontEndDomain() + "/myAppointmentList/contactedList?appointmentId=" + appointmentId;


    }


    




    public Appointment findById(Long id) {


       return appointmentRepository.findById(id)


             .orElseThrow(AppointmentNotFoundException::new);


    }




   public void closeAppointment(AppointmentCloseDTO closeDTO) {


      if(closeDTO.getContactStatus() == ContactStatusEnum.DONE) {


         DoneProcessDTO dto = new DoneProcessDTO();


         BeanUtils.copyProperties(closeDTO, dto);


         abstractAppointmentProcess.process(dto);


      }else if(closeDTO.getContactStatus() == ContactStatusEnum.CLOSED){


         ClosedProcessDTO dto = new ClosedProcessDTO();


         BeanUtils.copyProperties(closeDTO, dto);


         abstractAppointmentProcess.process(dto);


      }


   }




    public Long getConsultantPendingAppointmentSum(String agentNo) {


        return appointmentCustomerViewRepository.findAllByCommunicateStatusAndStatus(ContactStatusEnum.RESERVED, AVAILABLE)


                .stream()


                .filter(appointment -> agentNo.equals(appointment.getAgentNo()))


                .filter(appointment -> isAppointmentDateNotInIntervalFromNow(appointment, Constants.APPOINTMENT_PENDING_PHONE_INTERVAL, Constants.APPOINTMENT_PENDING_EMAIL_INTERVAL))


                .count();


    }




    public AppointmentCustomerViewDTO getCustomerNewestExpiringAppointment(Long customerId) {


        return appointmentCustomerViewRepository.findAllByCommunicateStatusAndStatus(ContactStatusEnum.RESERVED, AVAILABLE)


                .stream()


                .filter(appointment -> customerId.equals(appointment.getCustomerId()))


                .filter(appointment -> isAppointmentDateNotInIntervalFromNow(appointment, Constants.APPOINTMENT_EXPIRING_PHONE_INTERVAL, Constants.APPOINTMENT_EXPIRING_EMAIL_INTERVAL))


                .max(Comparator.comparing(AppointmentCustomerView::getAppointmentDate))


                .map(appointmentCustomerView -> appointmentCustomerViewMapper.toAppointmentCustomerViewDTO(appointmentCustomerView))


                .orElse(null);


    }




    public boolean isAppointmentDateNotInIntervalFromNow(AppointmentCustomerView appointment, int phoneInterval, int emailInterval) {


        final boolean isHavePhone = StringUtils.hasText(appointment.getPhone());


        final boolean isHaveEmail = StringUtils.hasText(appointment.getEmail());




        LocalDate appointmentDate = appointment.getAppointmentDate().atZone(ZoneId.systemDefault()).toLocalDate();


        LocalDate nowDate = Instant.now().atZone(ZoneId.systemDefault()).toLocalDate();


        long intervalDays = nowDate.toEpochDay() - appointmentDate.toEpochDay();




        final boolean isAppointmentExpiringByPhone = isHavePhone && intervalDays >= phoneInterval;


        final boolean isAppointmentExpiringByEmail = isHaveEmail && intervalDays >= emailInterval;




        return isAppointmentExpiringByPhone || isAppointmentExpiringByEmail;


    }


}