From 42567b98b186f219b7a923dc3e6daeb5ffa31cfe Mon Sep 17 00:00:00 2001 From: wayne <wayne8692wayne8692@gmail.com> Date: 星期五, 17 十二月 2021 15:29:59 +0800 Subject: [PATCH] [add][todo 132507] 新增發送手機簡訊service --- pamapi/src/main/java/com/pollex/pam/service/AppointmentService.java | 78 +++++++++++++++++++++++++++----------- 1 files changed, 55 insertions(+), 23 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 bbaf4a1..5b5cb33 100644 --- a/pamapi/src/main/java/com/pollex/pam/service/AppointmentService.java +++ b/pamapi/src/main/java/com/pollex/pam/service/AppointmentService.java @@ -3,10 +3,11 @@ import java.time.Instant; import java.util.List; import java.util.Objects; +import java.util.Optional; import java.util.stream.Collectors; -import com.pollex.pam.enums.AppointmentStatusEnum; -import com.pollex.pam.service.dto.AppointmentDTO; +import com.pollex.pam.domain.Satisfaction; +import com.pollex.pam.service.dto.AppointmentUpdateDTO; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; @@ -60,28 +61,77 @@ 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()); + appointment.setLastModifiedDate(Instant.now()); + + appointmentRepository.save(appointment); + } + + public void markAppointmentDeleted(Long appointmentId) { + Appointment appointment = appointmentRepository.findById(appointmentId).get(); + appointment.setStatus(DELETED); + appointment.setLastModifiedDate(Instant.now()); + 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); - return appointmentRepository.save(appointment); + appointment.setContactTime(Instant.now()); + appointment.setLastModifiedDate(Instant.now()); + return appointmentRepository.save(appointment); } public AppointmentCustomerViewDTO getAppointmentDetail(Long appointmentId) { AppointmentCustomerView appointment = appointmentCustomerViewRepository.findById(appointmentId) .orElseThrow(AppointmentNotFoundException::new); - return appointmentCustomerViewMapper.toAppointmentCustomerViewDTO(appointment); + + AppointmentCustomerViewDTO dto = appointmentCustomerViewMapper.toAppointmentCustomerViewDTO(appointment); + setSatisfactionScore(dto, appointmentId); + return dto; } + + public List<AppointmentCustomerViewDTO> getConsultantAvailableAppointments(String agentNo) { + return appointmentCustomerViewRepository.findByAgentNo(agentNo).stream() + .filter(appointment -> appointment.getStatus() == AVAILABLE) + .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 -> { + dto.setSatisfactionScore(satisfaction.getScore()); + }); + } public List<AppointmentCustomerView> findAvailableByAgentNoAndCustomerId(String agentNo, Long customerId) { return appointmentCustomerViewRepository.findByAgentNoAndCustomerId(agentNo, customerId) .stream() .filter(appointmentCustomerView -> appointmentCustomerView.getStatus() == AVAILABLE) .collect(Collectors.toList()); + } + + public Optional<Appointment> findLatestAppointmentByAgentNoAndCustomerId(String agentNo, Long customerId) { + return appointmentRepository.findTopByAgentNoAndCustomerIdOrderByAppointmentDateDesc(agentNo, customerId); } public void recordConsultantReadTime(Long appointmentId) { @@ -96,17 +146,6 @@ } } - public void updateAppointment(AppointmentDTO appointmentDTO) { - Appointment appointment = appointmentDTOMapper.toAppointment(appointmentDTO); - appointmentRepository.save(appointment); - } - - public void markAppointmentDeleted(Long appointmentId) { - Appointment appointment = appointmentRepository.findById(appointmentId).get(); - appointment.setStatus(DELETED); - appointmentRepository.save(appointment); - } - public void recordAllAppointmentsView(String agentNo) { List<Appointment> consultantNotViewAppointments = findByAgentNo(agentNo) .stream() @@ -115,12 +154,5 @@ 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