| | |
| | | import com.pollex.pam.service.mapper.ConsultantMapper; |
| | | import com.pollex.pam.web.rest.errors.ConsultantNotFoundException; |
| | | import com.pollex.pam.web.rest.errors.NotLoginException; |
| | | import org.slf4j.Logger; |
| | | import org.slf4j.LoggerFactory; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | | |
| | |
| | | |
| | | @Service |
| | | public class ConsultantService { |
| | | |
| | | private static final Logger log = LoggerFactory.getLogger(ConsultantService.class); |
| | | |
| | | private final ConsultantRepository consultantRepository; |
| | | private final CustomFavoriteConsultantRepository customFavoriteConsultantRepository; |
| | |
| | | } |
| | | |
| | | public List<ConsultantDTO> strictQueryConsultant(StrictQueryConsultantParam param) { |
| | | |
| | | |
| | | return Collections.emptyList(); |
| | | return consultantRepository.findAll(ConsultantQuerySpec.getStrictQuerySpec(param)) |
| | | .stream() |
| | | .map(consultantMapper::toDto) |
| | | .collect(Collectors.toList()); |
| | | } |
| | | |
| | | public List<ConsultantDTO> fastQueryConsultant(FastQueryConsultantParam param) { |
| | |
| | | User user = userService.getUserWithAuthorities().orElseThrow(NotLoginException::new); |
| | | |
| | | consultants.forEach(consultant -> { |
| | | CustomFavoriteConsultant customFavoriteConsultant = new CustomFavoriteConsultant(); |
| | | customFavoriteConsultant.setConsultant(consultant); |
| | | customFavoriteConsultant.setCustomId(user.getId()); |
| | | customFavoriteConsultant.setContactStatus(ContactStatusEnum.PICKED); |
| | | boolean isConsultantInList = customFavoriteConsultantRepository.findOneByCustomIdAndConsultant(user.getId(), consultant).isPresent(); |
| | | |
| | | customFavoriteConsultantRepository.save(customFavoriteConsultant); |
| | | if(!isConsultantInList) { |
| | | CustomFavoriteConsultant customFavoriteConsultant = new CustomFavoriteConsultant(); |
| | | customFavoriteConsultant.setConsultant(consultant); |
| | | customFavoriteConsultant.setCustomId(user.getId()); |
| | | customFavoriteConsultant.setContactStatus(ContactStatusEnum.PICKED); |
| | | |
| | | customFavoriteConsultantRepository.save(customFavoriteConsultant); |
| | | } |
| | | else { |
| | | log.info("The consultant is in custom favorite list! customId = {}, consultant AgentNo = {}", user.getId(), consultant.getAgentNo()); |
| | | } |
| | | }); |
| | | |
| | | } |