| | |
| | | import com.pollex.pam.domain.AppointmentCustomerView; |
| | | import com.pollex.pam.domain.Consultant; |
| | | import com.pollex.pam.domain.CustomerFavoriteConsultant; |
| | | import com.pollex.pam.repository.AppointmentCustomerViewRepository; |
| | | 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 org.springframework.stereotype.Service; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | | |
| | | import java.util.Comparator; |
| | | import java.util.List; |
| | | import java.util.stream.Collectors; |
| | | |
| | |
| | | AppointmentService appointmentService; |
| | | |
| | | @Autowired |
| | | AppointmentCustomerViewRepository appointmentCustomerViewRepository; |
| | | LoginRecordService loginRecordService; |
| | | |
| | | @Autowired |
| | | AppointmentCustomerViewMapper appointmentCustomerViewMapper; |
| | | |
| | | public List<ConsultantDTO> getMyConsultantList() { |
| | | Long userId = SecurityUtils.getCustomerId(); |
| | | return customerFavoriteConsultantRepository.findAllByCustomerId(userId) |
| | | @Autowired |
| | | SatisfactionService satisfactionService; |
| | | |
| | | 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() { |
| | |
| | | } |
| | | |
| | | public ConsultantDetailDTO getConsultantDetail(String agentNo) { |
| | | Consultant consultant = consultantRepository.findFirstByAgentNo(agentNo).orElseThrow(ConsultantNotFoundException::new); |
| | | return consultantMapper.toDetailDto(consultant); |
| | | Consultant consultant = consultantRepository.findOneByAgentNo(agentNo).orElseThrow(ConsultantNotFoundException::new); |
| | | ConsultantDetailDTO consultantDetailDTO = consultantMapper.toDetailDto(consultant); |
| | | |
| | | loginRecordService.findLatestLoginRecord(agentNo, LoginResult.SUCCESS) |
| | | .ifPresent(loginRecord -> consultantDetailDTO.setLatestLoginTime(loginRecord.getLoginDate())); |
| | | |
| | | return consultantDetailDTO; |
| | | } |
| | | |
| | | @Transactional |
| | | public void addConsultantToCustomList(AddConsultantParam param) { |
| | | List<String> agentNoList = param.getAgentNoList(); |
| | | List<Consultant> consultants = consultantRepository.findAllByAgentNoIn(agentNoList); |
| | | Long userId = SecurityUtils.getCustomerId(); |
| | | Long userId = SecurityUtils.getCustomerDBId(); |
| | | |
| | | consultants.forEach(consultant -> { |
| | | boolean isConsultantInList = customerFavoriteConsultantRepository.findOneByCustomerIdAndConsultant(userId, consultant).isPresent(); |
| | |
| | | |
| | | 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) { |
| | | Long customId = SecurityUtils.getCustomerId(); |
| | | Consultant consultant = consultantRepository.findFirstByAgentNo(agentNo).orElseThrow(ConsultantNotFoundException::new); |
| | | Long customId = SecurityUtils.getCustomerDBId(); |
| | | Consultant consultant = consultantRepository.findOneByAgentNo(agentNo).orElseThrow(ConsultantNotFoundException::new); |
| | | CustomerFavoriteConsultant target = customerFavoriteConsultantRepository.findOneByCustomerIdAndConsultant(customId, consultant).orElse(null); |
| | | |
| | | if(target != null) { |
| | |
| | | log.info("this consultant is not in customer list! agentNo = {}, customId = {}", agentNo, customId); |
| | | } |
| | | } |
| | | |
| | | public void recordAllAppointmentsView() { |
| | | String agentNo = SecurityUtils.getAgentNo(); |
| | | appointmentService.recordAllAppointmentsView(agentNo); |
| | | } |
| | | } |