From 9b53dde3b53a9e4593f16d52da8b5b5a7c96019f Mon Sep 17 00:00:00 2001 From: wayne <wayne8692wayne8692@gmail.com> Date: 星期五, 17 十二月 2021 15:33:18 +0800 Subject: [PATCH] [fix] 修正簡訊不需帶入subject --- pamapi/src/main/java/com/pollex/pam/service/ConsultantService.java | 89 +++++++++++++++++++++++++++++++++++--------- 1 files changed, 71 insertions(+), 18 deletions(-) diff --git a/pamapi/src/main/java/com/pollex/pam/service/ConsultantService.java b/pamapi/src/main/java/com/pollex/pam/service/ConsultantService.java index acc8f33..8c109fe 100644 --- a/pamapi/src/main/java/com/pollex/pam/service/ConsultantService.java +++ b/pamapi/src/main/java/com/pollex/pam/service/ConsultantService.java @@ -1,12 +1,11 @@ package com.pollex.pam.service; -import com.pollex.pam.domain.Appointment; import com.pollex.pam.domain.AppointmentCustomerView; import com.pollex.pam.domain.Consultant; import com.pollex.pam.domain.CustomerFavoriteConsultant; +import com.pollex.pam.enums.AppointmentStatusEnum; +import com.pollex.pam.enums.ContactStatusEnum; import com.pollex.pam.enums.LoginResult; -import com.pollex.pam.repository.AppointmentCustomerViewRepository; -import com.pollex.pam.repository.AppointmentRepository; import com.pollex.pam.repository.ConsultantRepository; import com.pollex.pam.repository.CustomerFavoriteConsultantRepository; import com.pollex.pam.security.SecurityUtils; @@ -21,9 +20,12 @@ import org.springframework.transaction.annotation.Transactional; import java.time.Instant; +import java.util.Comparator; import java.util.List; import java.util.Objects; import java.util.stream.Collectors; + +import static com.pollex.pam.enums.ContactStatusEnum.*; @Service public class ConsultantService { @@ -43,23 +45,66 @@ AppointmentService appointmentService; @Autowired - AppointmentRepository appointmentRepository; - - @Autowired - AppointmentCustomerViewRepository appointmentCustomerViewRepository; + LoginRecordService loginRecordService; @Autowired AppointmentCustomerViewMapper appointmentCustomerViewMapper; @Autowired - LoginRecordService loginRecordService; + SatisfactionService satisfactionService; - public List<ConsultantDTO> getMyConsultantList() { - Long userId = SecurityUtils.getCustomerDBId(); - return customerFavoriteConsultantRepository.findAllByCustomerId(userId) + public List<CustomerFavoriteConsultantDTO> getMyConsultantList() { + Long customerId = SecurityUtils.getCustomerDBId(); + + return customerFavoriteConsultantRepository.findAllByCustomerId(customerId) .stream() - .map(consultantMapper::toDto) + .map(relation -> { + Consultant consultant = relation.getConsultant(); + CustomerFavoriteConsultantDTO dto = consultantMapper.toCustomerFavoriteConsultantDto(consultant); + + dto.setContactStatus(ContactStatusEnum.PICKED); + dto.setCreateTime(relation.getCreatedDate()); + dto.setUpdateTime(relation.getCreatedDate()); + dto.setCustomerViewTime(relation.getViewTime()); + + setAvailableAppointmentInfo( + dto, + appointmentService.findAvailableByAgentNoAndCustomerId(consultant.getAgentNo(), customerId) + ); + + appointmentService.findLatestAppointmentByAgentNoAndCustomerId(consultant.getAgentNo(), customerId) + .ifPresent(latestAppointment -> { + dto.setUpdateTime(latestAppointment.getLastModifiedDate()); + }); + + if(dto.getUpdateTime().isBefore(relation.getCreatedDate())) { + dto.setUpdateTime(relation.getCreatedDate()); + } + + return dto; + + }).collect(Collectors.toList()); + } + + private void setAvailableAppointmentInfo(CustomerFavoriteConsultantDTO customerFavoriteConsultantDTO, List<AppointmentCustomerView> appointmentList) { + List<AppointmentCustomerView> appointments = appointmentList.stream() + .sorted(Comparator.comparing(AppointmentCustomerView::getAppointmentDate).reversed()) .collect(Collectors.toList()); + + List<AppointmentCustomerViewDTO> appointmentCustomerViewDTOS = appointmentCustomerViewMapper.toAppointmentCustomerViewDTO(appointments); + appointmentCustomerViewDTOS.forEach(appointmentCustomerViewDTO -> { + appointmentService.setSatisfactionScore(appointmentCustomerViewDTO, appointmentCustomerViewDTO.getId()); + }); + customerFavoriteConsultantDTO.setAppointments(appointmentCustomerViewDTOS); + + if (!appointments.isEmpty()) { + AppointmentCustomerView latestAvailableAppointment = appointments.get(0); + + if(latestAvailableAppointment.getCommunicateStatus() == RESERVED) + customerFavoriteConsultantDTO.setContactStatus(RESERVED); + else + customerFavoriteConsultantDTO.setContactStatus(PICKED); + } } public List<ConsultantDTO> getRecommendConsultantList() { @@ -118,8 +163,7 @@ public List<AppointmentCustomerViewDTO> getMyAppointment() { String agentNo = SecurityUtils.getAgentNo(); - List<AppointmentCustomerView> appointmentList = appointmentCustomerViewRepository.findByAgentNo(agentNo); - return appointmentCustomerViewMapper.toAppointmentCustomerViewDTO(appointmentList); + return appointmentService.getConsultantAvailableAppointments(agentNo); } public void removeConsultantFromCustomList(String agentNo) { @@ -137,12 +181,21 @@ public void recordAllAppointmentsView() { String agentNo = SecurityUtils.getAgentNo(); - List<Appointment> consultantNotViewAppointments = appointmentService.findByAgentNo(agentNo) + appointmentService.recordAllAppointmentsView(agentNo); + } + + public void recordMyConsultantListView() { + Long customerId = SecurityUtils.getCustomerDBId(); + List<CustomerFavoriteConsultant> notViewRelation = customerFavoriteConsultantRepository + .findAllByCustomerId(customerId) .stream() - .filter(appointment -> Objects.isNull(appointment.getConsultantViewTime())) + .filter(relation -> Objects.isNull(relation.getViewTime())) .collect(Collectors.toList()); - consultantNotViewAppointments.forEach(appointment -> appointment.setConsultantViewTime(Instant.now())); - appointmentRepository.saveAll(consultantNotViewAppointments); + notViewRelation.forEach(relation -> { + relation.setViewTime(Instant.now()); + }); + + customerFavoriteConsultantRepository.saveAll(notViewRelation); } } -- Gitblit v1.8.0