|
@@ -13,8 +13,6 @@ import com.citu.module.menduner.common.util.LoginUserContext;
|
|
|
import com.citu.module.menduner.system.api.python.GraphApi;
|
|
|
import com.citu.module.menduner.system.api.python.GraphQueryPageDTO;
|
|
|
import com.citu.module.menduner.system.api.python.GraphSendDTO;
|
|
|
-import com.citu.module.menduner.system.controller.app.jobhunt.job.vo.AppEnterpriseJobHomeRespVO;
|
|
|
-import com.citu.module.menduner.system.controller.app.jobhunt.job.vo.AppJobAdvertisedDetailRespVO;
|
|
|
import com.citu.module.menduner.system.controller.app.jobhunt.job.vo.AppJobAdvertisedHomeRespVO;
|
|
|
import com.citu.module.menduner.system.controller.app.jobhunt.job.vo.AppJobAdvertisedPageReqVO;
|
|
|
import com.citu.module.menduner.system.controller.app.recruit.job.vo.AppRecruitJobSaveReqVO;
|
|
@@ -22,8 +20,6 @@ import com.citu.module.menduner.system.controller.app.recruit.job.vo.AppRecruitJ
|
|
|
import com.citu.module.menduner.system.controller.base.CommonRespVO;
|
|
|
import com.citu.module.menduner.system.controller.base.analysis.RecruitAnalysisReqVO;
|
|
|
import com.citu.module.menduner.system.controller.base.analysis.RecruitJobAnalysisRespVO;
|
|
|
-import com.citu.module.menduner.system.controller.base.contact.EnterpriseUserContactRespVO;
|
|
|
-import com.citu.module.menduner.system.controller.base.enterprise.vo.EnterpriseBaseSimpleRespVO;
|
|
|
import com.citu.module.menduner.system.controller.base.job.JobAdvertisedPageReqVO;
|
|
|
import com.citu.module.menduner.system.controller.base.job.JobAdvertisedReqVO;
|
|
|
import com.citu.module.menduner.system.controller.base.job.JobAdvertisedRespVO;
|
|
@@ -31,13 +27,10 @@ import com.citu.module.menduner.system.controller.base.job.JobAdvertisedSaveReqV
|
|
|
import com.citu.module.menduner.system.convert.JobAdvertisedConvert;
|
|
|
import com.citu.module.menduner.system.dal.dataobject.job.JobAdvertisedDO;
|
|
|
import com.citu.module.menduner.system.dal.mysql.job.JobAdvertisedMapper;
|
|
|
-import com.citu.module.menduner.system.dal.mysql.job.JobInterestedMapper;
|
|
|
import com.citu.module.menduner.system.enums.job.JobStatusEnum;
|
|
|
import com.citu.module.menduner.system.enums.sync.SyncConstants;
|
|
|
import com.citu.module.menduner.system.mq.producer.ESProducer;
|
|
|
import com.citu.module.menduner.system.mq.producer.GraphProducer;
|
|
|
-import com.citu.module.menduner.system.service.enterprise.EnterpriseService;
|
|
|
-import com.citu.module.menduner.system.service.enterprise.bind.EnterpriseUserBindService;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
import org.springframework.scheduling.annotation.Async;
|
|
|
import org.springframework.stereotype.Service;
|
|
@@ -70,12 +63,6 @@ public class JobAdvertisedServiceImpl implements JobAdvertisedService {
|
|
|
@Resource
|
|
|
private JobAdvertisedMapper mapper;
|
|
|
|
|
|
- @Resource
|
|
|
- private EnterpriseService enterpriseService;
|
|
|
-
|
|
|
- @Resource
|
|
|
- private EnterpriseUserBindService userBindService;
|
|
|
-
|
|
|
@Resource
|
|
|
private ESProducer esProducer;
|
|
|
|
|
@@ -255,56 +242,6 @@ public class JobAdvertisedServiceImpl implements JobAdvertisedService {
|
|
|
return mapper.selectPage(pageReqVO);
|
|
|
}
|
|
|
|
|
|
- @Override
|
|
|
- public PageResult<AppEnterpriseJobHomeRespVO> getHotEnterpriseJobPage(PageParam pageParam) {
|
|
|
- PageResult<AppEnterpriseJobHomeRespVO> result =
|
|
|
- mapper.getHotEnterpriseJobPage(pageParam);
|
|
|
- if (result.getList().isEmpty()) {
|
|
|
- return result;
|
|
|
- }
|
|
|
- // 企业 id 集合
|
|
|
- List<Long> idList = result.getList().stream().map(c -> c.getEnterprise().getId())
|
|
|
- .collect(Collectors.toList());
|
|
|
-
|
|
|
- // 一次性获取相关企业的数据
|
|
|
- Map<Long, List<JobAdvertisedDO>> jobMap = mapper
|
|
|
- .selectByEnterpriseIdList(idList)
|
|
|
- .stream()
|
|
|
- .collect(Collectors.groupingBy(JobAdvertisedDO::getEnterpriseId));
|
|
|
-
|
|
|
- result.getList().forEach(resp -> {
|
|
|
- resp.setJobList(
|
|
|
- // 填充
|
|
|
- JobAdvertisedConvert.INSTANCE.convertListSimple(
|
|
|
- jobMap.get(resp.getEnterprise().getId())
|
|
|
- )
|
|
|
- );
|
|
|
- });
|
|
|
- return result;
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public AppJobAdvertisedDetailRespVO detail(Long id) {
|
|
|
- JobAdvertisedDO job = mapper.selectById(id);
|
|
|
- if (null == job) {
|
|
|
- throw exception(MDE_JOB_ADVERTISED_NOT_EXISTS);
|
|
|
- }
|
|
|
- // 转换
|
|
|
- AppJobAdvertisedDetailRespVO respVO = JobAdvertisedConvert.INSTANCE.convert(job);
|
|
|
- // 设置招聘职位数量
|
|
|
- respVO.setJobAdvertisedNum(mapper.countByEnterpriseId(job.getEnterpriseId()));
|
|
|
-
|
|
|
- // 查询企业信息
|
|
|
- EnterpriseBaseSimpleRespVO enterprise = enterpriseService.
|
|
|
- getEnterpriseSimple(job.getEnterpriseId());
|
|
|
- respVO.setEnterprise(enterprise);
|
|
|
-
|
|
|
- // 查询联系人信息
|
|
|
- EnterpriseUserContactRespVO contactRespVO = userBindService.
|
|
|
- getContact(enterprise.getId(), respVO.getUserId());
|
|
|
- respVO.setContact(contactRespVO);
|
|
|
- return respVO;
|
|
|
- }
|
|
|
|
|
|
@Override
|
|
|
public List<CommonRespVO> getJobPositionCountByEnterpriseId(Long enterpriseId) {
|
|
@@ -354,7 +291,7 @@ public class JobAdvertisedServiceImpl implements JobAdvertisedService {
|
|
|
JobAdvertisedReqVO.builder().status(JobStatusEnum.ENABLE.getStatus()).build()
|
|
|
);
|
|
|
List<JobAdvertisedRespVO> respList = JobAdvertisedConvert.INSTANCE.convertList7(list);
|
|
|
- if(CollUtil.isNotEmpty(respList)) {
|
|
|
+ if (CollUtil.isNotEmpty(respList)) {
|
|
|
graphApi.receiveData(GraphQueryPageDTO.builder().type(SyncConstants.JOB).build()).getCheckedData();
|
|
|
}
|
|
|
for (JobAdvertisedRespVO resp : respList) {
|