|
@@ -4,6 +4,7 @@ import com.github.pagehelper.PageHelper;
|
|
|
import com.github.pagehelper.PageInfo;
|
|
|
import com.hz.employmentsite.filter.exception.BaseException;
|
|
|
import com.hz.employmentsite.mapper.*;
|
|
|
+import com.hz.employmentsite.mapper.cquery.JobHuntCQuery;
|
|
|
import com.hz.employmentsite.mapper.cquery.JobUserCQuery;
|
|
|
import com.hz.employmentsite.mapper.cquery.LabelCQuery;
|
|
|
import com.hz.employmentsite.model.*;
|
|
@@ -11,6 +12,7 @@ import com.hz.employmentsite.services.service.jobUserManager.JobUserService;
|
|
|
import com.hz.employmentsite.services.service.system.DictionaryService;
|
|
|
import com.hz.employmentsite.util.*;
|
|
|
import com.hz.employmentsite.vo.dataMap.JobUserMapVo;
|
|
|
+import com.hz.employmentsite.vo.jobUserManager.JobHuntVo;
|
|
|
import com.hz.employmentsite.vo.jobUserManager.JobUserVo;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.stereotype.Service;
|
|
@@ -61,6 +63,8 @@ public class JobUserServiceImpl implements JobUserService {
|
|
|
private AreaCodeMapper areaCodeMapper;
|
|
|
@Autowired
|
|
|
private LabelCQuery labelCQuery;
|
|
|
+ @Autowired
|
|
|
+ private JobHuntCQuery jobHuntCQuery;
|
|
|
|
|
|
@Override
|
|
|
public PageInfo<JobUserVo> getList(Integer pageIndex, Integer pageSize,
|
|
@@ -944,7 +948,30 @@ public class JobUserServiceImpl implements JobUserService {
|
|
|
public PageInfo<JobUserMapVo> getDataMapList(int pageIndex, int pageSize, Integer keyTypeValue, String regionCode, String labelID, Integer minAge, Integer maxAge) {
|
|
|
PageHelper.startPage(pageIndex, pageSize);
|
|
|
List<JobUserMapVo> dataMapList = jobUserCQuery.getDataMapList(keyTypeValue, regionCode, labelID, minAge, maxAge);
|
|
|
- PageInfo<JobUserMapVo> pageInfo = new PageInfo<>(dataMapList);
|
|
|
- return pageInfo;
|
|
|
+ PageInfo<JobUserMapVo> result = new PageInfo<>(dataMapList);
|
|
|
+
|
|
|
+ // 获取所有的求职人员ID
|
|
|
+ List<String> jobUserIDs = result.getList().stream()
|
|
|
+ .filter(Objects::nonNull)
|
|
|
+ .map(JobUserMapVo::getJobUserID)
|
|
|
+ .filter(Objects::nonNull)
|
|
|
+ .collect(Collectors.toList());
|
|
|
+
|
|
|
+ if (!jobUserIDs.isEmpty()) {
|
|
|
+ // 查询求职意向并映射到求职人员
|
|
|
+ List<JobHuntVo> jobHuntList = jobHuntCQuery.selectJobHuntInCompanyIDs(stringUtils.ListToInSql(jobUserIDs));
|
|
|
+ Map<String, List<JobHuntVo>> jobHuntMap = (jobHuntList != null) ?
|
|
|
+ jobHuntList.stream()
|
|
|
+ .filter(Objects::nonNull)
|
|
|
+ .collect(Collectors.groupingBy(JobHuntVo::getJobUserID))
|
|
|
+ : new HashMap<>();
|
|
|
+ // 填充求职意向数据
|
|
|
+ result.getList().forEach(jobUser -> {
|
|
|
+ if (jobUser != null && jobUser.getJobUserID() != null) {
|
|
|
+ jobUser.setJobHuntList(jobHuntMap.getOrDefault(jobUser.getJobUserID(), new ArrayList<>()));
|
|
|
+ }
|
|
|
+ });
|
|
|
+ }
|
|
|
+ return result;
|
|
|
}
|
|
|
}
|