From 0e73f60f5e9acede5438b0c38332183916f9d552 Mon Sep 17 00:00:00 2001 From: Jack <jack.su@pollex.com.tw> Date: 星期五, 03 十二月 2021 16:54:57 +0800 Subject: [PATCH] Merge branch 'master' of ssh://192.168.0.10:29418/pcalife/PAM --- pamapi/src/main/java/com/pollex/pam/service/ConsultantService.java | 65 +++++++++++++++++++++----------- 1 files changed, 42 insertions(+), 23 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..adbb6ab 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,10 @@ 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.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; @@ -20,9 +18,8 @@ import org.springframework.stereotype.Service; 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; @Service @@ -43,23 +40,52 @@ 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(customerFavoriteConsultantRelation -> { + Consultant consultant = customerFavoriteConsultantRelation.getConsultant(); + CustomerFavoriteConsultantDTO dto = consultantMapper.toCustomerFavoriteConsultantDto(consultant); + + dto.setContactStatus(ContactStatusEnum.PICKED); + dto.setCreateTime(customerFavoriteConsultantRelation.getCreatedDate()); + + setAppointmentInfo( + dto, + appointmentService.findAvailableByAgentNoAndCustomerId(consultant.getAgentNo(), customerId) + ); + + return dto; + + }).collect(Collectors.toList()); + } + + private void setAppointmentInfo(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 latestAppointment = appointments.get(0); + customerFavoriteConsultantDTO.setContactStatus(latestAppointment.getCommunicateStatus()); + customerFavoriteConsultantDTO.setUpdateTime(latestAppointment.getLastModifiedDate()); + } } public List<ConsultantDTO> getRecommendConsultantList() { @@ -118,8 +144,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 +162,6 @@ public void recordAllAppointmentsView() { String agentNo = SecurityUtils.getAgentNo(); - List<Appointment> consultantNotViewAppointments = appointmentService.findByAgentNo(agentNo) - .stream() - .filter(appointment -> Objects.isNull(appointment.getConsultantViewTime())) - .collect(Collectors.toList()); - - consultantNotViewAppointments.forEach(appointment -> appointment.setConsultantViewTime(Instant.now())); - appointmentRepository.saveAll(consultantNotViewAppointments); + appointmentService.recordAllAppointmentsView(agentNo); } } -- Gitblit v1.8.0