|
@@ -29,9 +29,9 @@ import com.citu.module.menduner.system.controller.base.job.*;
|
|
|
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.dataobject.job.JobAdvertisedExtendDO;
|
|
|
-import com.citu.module.menduner.system.dal.mysql.enterprise.EnterpriseMapper;
|
|
|
import com.citu.module.menduner.system.dal.mysql.job.JobAdvertisedExtendMapper;
|
|
|
import com.citu.module.menduner.system.dal.mysql.job.JobAdvertisedMapper;
|
|
|
+import com.citu.module.menduner.system.enums.job.JobSourceEnum;
|
|
|
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;
|
|
@@ -105,7 +105,7 @@ public class JobAdvertisedServiceImpl implements JobAdvertisedService {
|
|
|
jobAdvertised.setHire(true);
|
|
|
jobAdvertised.setEnterpriseId(DEFAULT_ENTERPRISE_ID);
|
|
|
jobAdvertised.setUserId(DEFAULT_USER_ID);
|
|
|
- return save(jobAdvertised, DEFAULT_ENTERPRISE_ID, DEFAULT_USER_ID,false);
|
|
|
+ return save(jobAdvertised, DEFAULT_ENTERPRISE_ID, DEFAULT_USER_ID, false);
|
|
|
}
|
|
|
|
|
|
@Override
|
|
@@ -119,7 +119,7 @@ public class JobAdvertisedServiceImpl implements JobAdvertisedService {
|
|
|
updateObj.setHire(jobAdvertised.getHire());
|
|
|
updateObj.setTop(jobAdvertised.getTop());
|
|
|
updateObj.setStatus(jobAdvertised.getStatus());
|
|
|
- save(updateObj, DEFAULT_ENTERPRISE_ID, DEFAULT_USER_ID,false);
|
|
|
+ save(updateObj, DEFAULT_ENTERPRISE_ID, DEFAULT_USER_ID, false);
|
|
|
}
|
|
|
|
|
|
@Override
|
|
@@ -161,6 +161,20 @@ public class JobAdvertisedServiceImpl implements JobAdvertisedService {
|
|
|
return mapper.list(reqVO);
|
|
|
}
|
|
|
|
|
|
+ @Override
|
|
|
+ @DSTransactional
|
|
|
+ public void closeJobAdvertised(String source, Long bizId) {
|
|
|
+ List<JobAdvertisedDO> list = mapper.selectBySourceAndBizId(source, bizId);
|
|
|
+ for (JobAdvertisedDO job : list) {
|
|
|
+ disable(job);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public List<JobAdvertisedDO> getListByEnterpriseIdAndType(Long enterpriseId, List<String> types) {
|
|
|
+ return mapper.selectListByEnterpriseIdAndTypeAndNotHire(enterpriseId, types);
|
|
|
+ }
|
|
|
+
|
|
|
@Override
|
|
|
public PageResult<AppJobAdvertisedHomeRespVO> getRecommendedPage(PageParam pageParam) {
|
|
|
|
|
@@ -298,7 +312,7 @@ public class JobAdvertisedServiceImpl implements JobAdvertisedService {
|
|
|
return;
|
|
|
}
|
|
|
for (AppJobAdvertisedHomeRespVO resp : result.getList()) {
|
|
|
- if(null != resp.getAreaId()) {
|
|
|
+ if (null != resp.getAreaId()) {
|
|
|
resp.setArea(areaService.getById(resp.getAreaId()));
|
|
|
}
|
|
|
}
|
|
@@ -402,7 +416,7 @@ public class JobAdvertisedServiceImpl implements JobAdvertisedService {
|
|
|
JobAdvertisedDO job = JobAdvertisedConvert.INSTANCE.convert3(reqVO);
|
|
|
Long userId = LoginUserContext.getUserId();
|
|
|
Long enterpriseId = LoginUserContext.getEnterpriseId();
|
|
|
- return save(job, enterpriseId, userId,reqVO.isFair());
|
|
|
+ return save(job, enterpriseId, userId, reqVO.isFair());
|
|
|
}
|
|
|
|
|
|
/**
|
|
@@ -425,7 +439,7 @@ public class JobAdvertisedServiceImpl implements JobAdvertisedService {
|
|
|
processNewJob(job, enterpriseId, userId, fair);
|
|
|
} else {
|
|
|
// 修改职位
|
|
|
- processExistingJob(job, enterpriseId, userId,fair);
|
|
|
+ processExistingJob(job, enterpriseId, userId, fair);
|
|
|
}
|
|
|
|
|
|
return job.getId();
|
|
@@ -446,10 +460,18 @@ public class JobAdvertisedServiceImpl implements JobAdvertisedService {
|
|
|
// 扣除额度
|
|
|
vipEntitlementCheckAspect.deductQuota(VipEntitlementCheck.OPERATE_PUBLISH_JOB, triggerVip);
|
|
|
}
|
|
|
+ if (null == job.getSource()) {
|
|
|
+ job.setSource(JobSourceEnum.MANAGER.getType());
|
|
|
+ } else {
|
|
|
+ if (null == job.getBizId() && JobSourceEnum.FAIR.getType().equals(job.getSource())) {
|
|
|
+ throw exception(MDE_JOB_ADVERTISED_SOURCE_ID_NOT_NULL);
|
|
|
+ }
|
|
|
+ }
|
|
|
|
|
|
if (job.getHire() || JobStatusEnum.WAIT_ENABLE.getStatus().equals(job.getStatus())) {
|
|
|
// 众聘职位||待开启,还需要给钱才能开启
|
|
|
job.setStatus(JobStatusEnum.WAIT_ENABLE.getStatus());
|
|
|
+ job.setSource(JobSourceEnum.HIRE.getType());
|
|
|
} else {
|
|
|
//默认开启
|
|
|
job.setStatus(JobStatusEnum.ENABLE.getStatus());
|
|
@@ -552,14 +574,19 @@ public class JobAdvertisedServiceImpl implements JobAdvertisedService {
|
|
|
public void disable(List<Long> ids) {
|
|
|
for (Long id : ids) {
|
|
|
JobAdvertisedDO job = get(id);
|
|
|
- if (JobStatusEnum.DISABLE.getStatus().equals(job.getStatus())) {
|
|
|
- // 已经是关闭状态
|
|
|
- throw exception(MDE_JOB_ADVERTISED_STATUS_CLOSE_ERROR);
|
|
|
- }
|
|
|
- job.setStatus(JobStatusEnum.DISABLE.getStatus());
|
|
|
- mapper.updateById(job);
|
|
|
- jobDataSync(job, SyncConstants.UPDATE);
|
|
|
+ disable(job);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ void disable(JobAdvertisedDO job) {
|
|
|
+ if (JobStatusEnum.DISABLE.getStatus().equals(job.getStatus())) {
|
|
|
+ // 已经是关闭状态
|
|
|
+ throw exception(MDE_JOB_ADVERTISED_STATUS_CLOSE_ERROR);
|
|
|
}
|
|
|
+ job.setStatus(JobStatusEnum.DISABLE.getStatus());
|
|
|
+ mapper.updateById(job);
|
|
|
+ jobDataSync(job, SyncConstants.UPDATE);
|
|
|
}
|
|
|
|
|
|
@Override
|