From d7bcd8a8f81d85fe1524c4d785aaed58cd217586 Mon Sep 17 00:00:00 2001 From: wayne <wayne8692wayne8692@gmail.com> Date: 星期五, 03 十二月 2021 14:36:42 +0800 Subject: [PATCH] [update] 更新預約單API調整 --- pamapi/src/main/java/com/pollex/pam/service/AppointmentService.java | 112 +++++++++++++++++++++++++++++++++++++++++++++++++++++--- 1 files changed, 106 insertions(+), 6 deletions(-) diff --git a/pamapi/src/main/java/com/pollex/pam/service/AppointmentService.java b/pamapi/src/main/java/com/pollex/pam/service/AppointmentService.java index 3aba678..8108fc9 100644 --- a/pamapi/src/main/java/com/pollex/pam/service/AppointmentService.java +++ b/pamapi/src/main/java/com/pollex/pam/service/AppointmentService.java @@ -1,37 +1,137 @@ package com.pollex.pam.service; +import java.time.Instant; import java.util.List; +import java.util.Objects; +import java.util.stream.Collectors; +import com.pollex.pam.service.dto.AppointmentUpdateDTO; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; 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.enums.ContactStatusEnum; +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.service.mapper.AppointmentMapper; +import com.pollex.pam.web.rest.errors.AppointmentNotFoundException; + +import static com.pollex.pam.enums.AppointmentStatusEnum.AVAILABLE; +import static com.pollex.pam.enums.AppointmentStatusEnum.DELETED; @Service +@Transactional public class AppointmentService { - + + private static final Logger log = LoggerFactory.getLogger(AppointmentService.class); + @Autowired AppointmentRepository appointmentRepository; - + @Autowired AppointmentDTOMapper appointmentDTOMapper; - - + + @Autowired + ConsultantService consultantService; + + @Autowired + AppointmentCustomerViewMapper appointmentCustomerViewMapper; + + @Autowired + AppointmentCustomerViewRepository appointmentCustomerViewRepository; + + @Autowired + SatisfactionService satisfactionService; + public void customerCreateAppointment(AppointmentCreateDTO appointmentCreateDTO) { Appointment appointment = appointmentDTOMapper.toAppointment(appointmentCreateDTO); - appointment.setCustomerId(SecurityUtils.getCustomerId()); + appointment.setStatus(AVAILABLE); + appointment.setCustomerId(SecurityUtils.getCustomerDBId()); appointment.setCommunicateStatus(ContactStatusEnum.RESERVED); appointmentRepository.save(appointment); } + public void updateAppointment(AppointmentUpdateDTO updateAppointmentDTO) { + Appointment appointment = appointmentRepository.findById(updateAppointmentDTO.getId()).get(); + + appointment.setPhone(updateAppointmentDTO.getPhone()); + appointment.setEmail(updateAppointmentDTO.getEmail()); + appointment.setContactType(updateAppointmentDTO.getContactType()); + appointment.setGender(updateAppointmentDTO.getGender()); + appointment.setAge(updateAppointmentDTO.getAge()); + appointment.setJob(updateAppointmentDTO.getJob()); + appointment.setRequirement(updateAppointmentDTO.getRequirement()); + appointment.setHopeContactTime(updateAppointmentDTO.getHopeContactTime()); + appointment.setOtherRequirement(updateAppointmentDTO.getOtherRequirement()); + + appointmentRepository.save(appointment); + } + + public void markAppointmentDeleted(Long appointmentId) { + Appointment appointment = appointmentRepository.findById(appointmentId).get(); + appointment.setStatus(DELETED); + appointmentRepository.save(appointment); + } public List<Appointment> findByAgentNo(String agentNo) { return appointmentRepository.findByAgentNo(agentNo); } + + public Appointment markAsContacted(Long appointmentId) { + + Appointment appointment = appointmentRepository.findById(appointmentId).get(); + appointment.setCommunicateStatus(ContactStatusEnum.CONTACTED); + appointment.setContactTime(Instant.now()); + return appointmentRepository.save(appointment); + } + + public AppointmentCustomerViewDTO getAppointmentDetail(Long appointmentId) { + AppointmentCustomerView appointment = appointmentCustomerViewRepository.findById(appointmentId) + .orElseThrow(AppointmentNotFoundException::new); + return appointmentCustomerViewMapper.toAppointmentCustomerViewDTO(appointment); + } + + public List<AppointmentCustomerView> findAvailableByAgentNoAndCustomerId(String agentNo, Long customerId) { + return appointmentCustomerViewRepository.findByAgentNoAndCustomerId(agentNo, customerId) + .stream() + .filter(appointmentCustomerView -> appointmentCustomerView.getStatus() == AVAILABLE) + .collect(Collectors.toList()); + } + + public void recordConsultantReadTime(Long appointmentId) { + Appointment appointment = appointmentRepository.findById(appointmentId).get(); + + if(appointment.getConsultantReadTime() == null) { + appointment.setConsultantReadTime(Instant.now()); + appointmentRepository.save(appointment); + } + else { + log.debug("this appointment was read, read time = {}", appointment.getConsultantReadTime()); + } + } + + public void recordAllAppointmentsView(String agentNo) { + List<Appointment> consultantNotViewAppointments = findByAgentNo(agentNo) + .stream() + .filter(appointment -> Objects.isNull(appointment.getConsultantViewTime())) + .collect(Collectors.toList()); + + consultantNotViewAppointments.forEach(appointment -> appointment.setConsultantViewTime(Instant.now())); + appointmentRepository.saveAll(consultantNotViewAppointments); + } + + public List<AppointmentCustomerViewDTO> getConsultantAppointments(String agentNo) { + return appointmentCustomerViewRepository.findByAgentNo(agentNo).stream() + .filter(appointment -> appointment.getStatus() != DELETED) + .map(appointmentCustomerViewMapper::toAppointmentCustomerViewDTO) + .collect(Collectors.toList()); + } } -- Gitblit v1.8.0