| | |
| | | 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.domain.Satisfaction; |
| | | import com.pollex.pam.enums.ContactStatusEnum; |
| | | import com.pollex.pam.enums.LoginResult; |
| | | import com.pollex.pam.repository.ConsultantRepository; |
| | | import com.pollex.pam.repository.CustomerFavoriteConsultantRepository; |
| | | import com.pollex.pam.security.SecurityUtils; |
| | | import com.pollex.pam.service.dto.*; |
| | | import com.pollex.pam.service.mapper.AppointmentCustomerViewMapper; |
| | | import com.pollex.pam.service.mapper.ConsultantMapper; |
| | | import com.pollex.pam.web.rest.errors.ConsultantNotFoundException; |
| | | import org.slf4j.Logger; |
| | |
| | | @Autowired |
| | | LoginRecordService loginRecordService; |
| | | |
| | | public List<ConsultantDTO> getMyConsultantList() { |
| | | Long customerId = SecurityUtils.getCustomerDBId(); |
| | | @Autowired |
| | | AppointmentCustomerViewMapper appointmentCustomerViewMapper; |
| | | |
| | | @Autowired |
| | | SatisfactionService satisfactionService; |
| | | |
| | | public List<CustomerFavoriteConsultantDTO> getMyConsultantList() { |
| | | Long customerId = SecurityUtils.getCustomerDBId(); |
| | | |
| | | return customerFavoriteConsultantRepository.findAllByCustomerId(customerId) |
| | | .stream() |
| | | .map(customerFavoriteConsultantRelation -> { |
| | | Consultant consultant = customerFavoriteConsultantRelation.getConsultant(); |
| | | ConsultantDTO dto = consultantMapper.toDto(consultant); |
| | | CustomerFavoriteConsultantDTO dto = consultantMapper.toCustomerFavoriteConsultantDto(consultant); |
| | | |
| | | final Optional<Appointment> latestAppointmentOptional = appointmentService.findByAgentNoAndCustomerId(consultant.getAgentNo(), customerId) |
| | | .stream() |
| | | .max(Comparator.comparing(Appointment::getAppointmentDate)); |
| | | |
| | | if(latestAppointmentOptional.isPresent()) { |
| | | Appointment latestAppointment = latestAppointmentOptional.get(); |
| | | dto.setContactStatus(latestAppointment.getCommunicateStatus()); |
| | | dto.setLatestAppointmentId(latestAppointment.getId()); |
| | | dto.setUpdateTime(latestAppointment.getAppointmentDate()); |
| | | } |
| | | else { |
| | | dto.setContactStatus(ContactStatusEnum.PICKED); |
| | | dto.setLatestAppointmentId(null); |
| | | dto.setUpdateTime(customerFavoriteConsultantRelation.getLastModifiedDate()); |
| | | } |
| | | dto.setLatestAppointmentDate(null); |
| | | dto.setLatestAppointmentScore(null); |
| | | dto.setCreateTime(customerFavoriteConsultantRelation.getLastModifiedDate()); |
| | | |
| | | setAppointmentInfo( |
| | | dto, |
| | | appointmentService.findAvailableByAgentNoAndCustomerId(consultant.getAgentNo(), customerId) |
| | | ); |
| | | |
| | | return dto; |
| | | |
| | | }).collect(Collectors.toList()); |
| | | } |
| | | |
| | | private void setAppointmentInfo(CustomerFavoriteConsultantDTO dto, List<AppointmentCustomerView> appointmentList) { |
| | | List<AppointmentCustomerView> appointments = appointmentList.stream() |
| | | .sorted(Comparator.comparing(AppointmentCustomerView::getAppointmentDate).reversed()) |
| | | .collect(Collectors.toList()); |
| | | |
| | | dto.setAppointments(appointmentCustomerViewMapper.toAppointmentCustomerViewDTO(appointments)); |
| | | |
| | | if (!appointments.isEmpty()) { |
| | | AppointmentCustomerView latestAppointment = appointments.get(0); |
| | | dto.setContactStatus(latestAppointment.getCommunicateStatus()); |
| | | dto.setLatestAppointmentId(latestAppointment.getId()); |
| | | dto.setLatestAppointmentDate(latestAppointment.getAppointmentDate()); |
| | | dto.setUpdateTime(latestAppointment.getLastModifiedDate()); |
| | | |
| | | setLatestAppointmentScore(dto, latestAppointment); |
| | | } |
| | | } |
| | | |
| | | private void setLatestAppointmentScore(CustomerFavoriteConsultantDTO dto, AppointmentCustomerView latestAppointment) { |
| | | Optional<Satisfaction> satisfactionOptional = satisfactionService.getByAppointmentId(latestAppointment.getId()); |
| | | if(satisfactionOptional.isPresent()) { |
| | | Satisfaction satisfaction = satisfactionOptional.get(); |
| | | dto.setLatestAppointmentScore(satisfaction.getScore()); |
| | | } |
| | | else { |
| | | dto.setLatestAppointmentScore(null); |
| | | } |
| | | } |
| | | |
| | | public List<ConsultantDTO> getRecommendConsultantList() { |
| | | return consultantRepository.findAllByRecommendIsTrue() |
| | | .stream() |