From 64b304dec9d029df4ab8ab62c2eb555edb8c1482 Mon Sep 17 00:00:00 2001 From: wayne <wayne8692wayne8692@gmail.com> Date: 星期五, 03 十二月 2021 11:25:23 +0800 Subject: [PATCH] [update] 預約單新增時壓上available --- pamapi/src/main/java/com/pollex/pam/service/ConsultantService.java | 143 +++++++++++++++++++++++++++++++++-------------- 1 files changed, 100 insertions(+), 43 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 ef88b61..7a9c552 100644 --- a/pamapi/src/main/java/com/pollex/pam/service/ConsultantService.java +++ b/pamapi/src/main/java/com/pollex/pam/service/ConsultantService.java @@ -2,10 +2,12 @@ import com.pollex.pam.domain.AppointmentCustomerView; import com.pollex.pam.domain.Consultant; -import com.pollex.pam.domain.CustomFavoriteConsultant; -import com.pollex.pam.repository.AppointmentCustomerViewRepository; +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.CustomFavoriteConsultantRepository; +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; @@ -13,10 +15,13 @@ import com.pollex.pam.web.rest.errors.ConsultantNotFoundException; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; +import java.util.Comparator; import java.util.List; +import java.util.Optional; import java.util.stream.Collectors; @Service @@ -24,36 +29,79 @@ private static final Logger log = LoggerFactory.getLogger(ConsultantService.class); - final ConsultantRepository consultantRepository; - final CustomFavoriteConsultantRepository customFavoriteConsultantRepository; - final ConsultantMapper consultantMapper; - final AppointmentService appointmentService; - final AppointmentCustomerViewRepository appointmentCustomerViewRepository; - final AppointmentCustomerViewMapper appointmentCustomerViewMapper; + @Autowired + ConsultantRepository consultantRepository; - public ConsultantService( - ConsultantRepository consultantRepository, - CustomFavoriteConsultantRepository customFavoriteConsultantRepository, - ConsultantMapper consultantMapper, - UserService userService, - AppointmentService appointmentService, - AppointmentCustomerViewRepository appointmentCustomerViewRepository, - AppointmentCustomerViewMapper appointmentCustomerViewMapper - ) { - this.consultantRepository = consultantRepository; - this.customFavoriteConsultantRepository = customFavoriteConsultantRepository; - this.consultantMapper = consultantMapper; - this.appointmentService = appointmentService; - this.appointmentCustomerViewRepository = appointmentCustomerViewRepository; - this.appointmentCustomerViewMapper = appointmentCustomerViewMapper; + @Autowired + CustomerFavoriteConsultantRepository customerFavoriteConsultantRepository; + + @Autowired + ConsultantMapper consultantMapper; + + @Autowired + AppointmentService appointmentService; + + @Autowired + LoginRecordService loginRecordService; + + @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(); + CustomerFavoriteConsultantDTO dto = consultantMapper.toCustomerFavoriteConsultantDto(consultant); + + dto.setContactStatus(ContactStatusEnum.PICKED); + dto.setLatestAppointmentId(null); + dto.setLatestAppointmentDate(null); + dto.setLatestAppointmentScore(null); + dto.setCreateTime(customerFavoriteConsultantRelation.getLastModifiedDate()); + + setAppointmentInfo( + dto, + appointmentService.findAvailableByAgentNoAndCustomerId(consultant.getAgentNo(), customerId) + ); + + return dto; + + }).collect(Collectors.toList()); } - public List<ConsultantDTO> getMyConsultantList() { - Long userId = SecurityUtils.getCustomerId(); - return customFavoriteConsultantRepository.findAllByCustomerId(userId) - .stream() - .map(consultantMapper::toDto) + 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() { @@ -78,25 +126,30 @@ } 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 = customFavoriteConsultantRepository.findOneByCustomerIdAndConsultant(userId, consultant).isPresent(); + boolean isConsultantInList = customerFavoriteConsultantRepository.findOneByCustomerIdAndConsultant(userId, consultant).isPresent(); if(!isConsultantInList) { - CustomFavoriteConsultant customFavoriteConsultant = new CustomFavoriteConsultant(); - customFavoriteConsultant.setConsultant(consultant); - customFavoriteConsultant.setCustomerId(userId); + CustomerFavoriteConsultant customerFavoriteConsultant = new CustomerFavoriteConsultant(); + customerFavoriteConsultant.setConsultant(consultant); + customerFavoriteConsultant.setCustomerId(userId); - customFavoriteConsultantRepository.save(customFavoriteConsultant); + customerFavoriteConsultantRepository.save(customerFavoriteConsultant); } else { log.info("The consultant is in customer favorite list! customId = {}, consultant AgentNo = {}", userId, consultant.getAgentNo()); @@ -107,20 +160,24 @@ public List<AppointmentCustomerViewDTO> getMyAppointment() { String agentNo = SecurityUtils.getAgentNo(); - List<AppointmentCustomerView> appointmentList = appointmentCustomerViewRepository.findByAgentNo(agentNo); - return appointmentCustomerViewMapper.toAppointmentCustomerViewDTO(appointmentList); + return appointmentService.getConsultantAppointments(agentNo); } public void removeConsultantFromCustomList(String agentNo) { - Long customId = SecurityUtils.getCustomerId(); - Consultant consultant = consultantRepository.findFirstByAgentNo(agentNo).orElseThrow(ConsultantNotFoundException::new); - CustomFavoriteConsultant target = customFavoriteConsultantRepository.findOneByCustomerIdAndConsultant(customId, consultant).orElse(null); + Long customId = SecurityUtils.getCustomerDBId(); + Consultant consultant = consultantRepository.findOneByAgentNo(agentNo).orElseThrow(ConsultantNotFoundException::new); + CustomerFavoriteConsultant target = customerFavoriteConsultantRepository.findOneByCustomerIdAndConsultant(customId, consultant).orElse(null); if(target != null) { - customFavoriteConsultantRepository.delete(target); + customerFavoriteConsultantRepository.delete(target); } else { log.info("this consultant is not in customer list! agentNo = {}, customId = {}", agentNo, customId); } } + + public void recordAllAppointmentsView() { + String agentNo = SecurityUtils.getAgentNo(); + appointmentService.recordAllAppointmentsView(agentNo); + } } -- Gitblit v1.8.0