保誠-保戶業務員媒合平台
Jack
2021-12-22 6c645d811f0c81eca814d56fa651e9088ce6fc13
pamapi/src/main/java/com/pollex/pam/service/ConsultantService.java
@@ -1,8 +1,10 @@
package com.pollex.pam.service;
import com.pollex.pam.config.ApplicationProperties;
import com.pollex.pam.domain.AppointmentCustomerView;
import com.pollex.pam.domain.Consultant;
import com.pollex.pam.domain.CustomerFavoriteConsultant;
import com.pollex.pam.enums.AppointmentStatusEnum;
import com.pollex.pam.enums.ContactStatusEnum;
import com.pollex.pam.enums.LoginResult;
import com.pollex.pam.repository.ConsultantRepository;
@@ -10,7 +12,9 @@
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.ConsultantDTOMapper;
import com.pollex.pam.service.mapper.ConsultantMapper;
import com.pollex.pam.service.util.FileUtil;
import com.pollex.pam.web.rest.errors.ConsultantNotFoundException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -18,11 +22,18 @@
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStream;
import java.time.Instant;
import java.util.Comparator;
import java.util.List;
import java.util.Objects;
import java.util.stream.Collectors;
import static com.pollex.pam.enums.ContactStatusEnum.*;
@Service
public class ConsultantService {
@@ -49,6 +60,12 @@
    @Autowired
    SatisfactionService satisfactionService;
    @Autowired
    ConsultantDTOMapper consultantDTOMapper;
    @Autowired
    ApplicationProperties applicationProperty;
    public List<CustomerFavoriteConsultantDTO> getMyConsultantList() {
        Long customerId = SecurityUtils.getCustomerDBId();
@@ -96,7 +113,11 @@
        if (!appointments.isEmpty()) {
            AppointmentCustomerView latestAvailableAppointment = appointments.get(0);
            customerFavoriteConsultantDTO.setContactStatus(latestAvailableAppointment.getCommunicateStatus());
            if(latestAvailableAppointment.getCommunicateStatus() == RESERVED)
                customerFavoriteConsultantDTO.setContactStatus(RESERVED);
            else
                customerFavoriteConsultantDTO.setContactStatus(PICKED);
        }
    }
@@ -191,4 +212,25 @@
        customerFavoriteConsultantRepository.saveAll(notViewRelation);
    }
   public Consultant editConsultant(ConsultantEditDTO editDTO) {
      Consultant consultant = consultantRepository.findOneByAgentNo(editDTO.getAgentNo())
            .orElseThrow(ConsultantNotFoundException::new);
      consultantDTOMapper.copyToConsultant(editDTO, consultant);
      FileUtil.base64ToFile(editDTO.getPhotoBase64(), editDTO.getPhotoFileName(), applicationProperty.getFileFolderPath());
      return consultantRepository.save(consultant);
   }
   public InputStream getAvatarImage(String agentNo) {
      Consultant consultant = consultantRepository.findOneByAgentNo(agentNo)
            .orElseThrow(ConsultantNotFoundException::new);
      File file = new File(consultant.getPhotoPath());
      try {
         InputStream in = new FileInputStream(file);
         return in;
      } catch (FileNotFoundException e) {
         log.error("agent photo not found , agentNo:"+agentNo,e);
         return null;
      }
   }
}