|
@@ -3,7 +3,6 @@ package com.citu.module.menduner.system.old;
|
|
import com.citu.framework.common.util.date.DateUtils;
|
|
import com.citu.framework.common.util.date.DateUtils;
|
|
import com.citu.framework.mybatis.core.query.LambdaQueryWrapperX;
|
|
import com.citu.framework.mybatis.core.query.LambdaQueryWrapperX;
|
|
import com.citu.framework.tenant.core.db.TenantBaseDO;
|
|
import com.citu.framework.tenant.core.db.TenantBaseDO;
|
|
-import com.citu.framework.tenant.core.util.TenantUtils;
|
|
|
|
import com.citu.module.menduner.system.dal.dataobject.cvattachment.CvAttachmentDO;
|
|
import com.citu.module.menduner.system.dal.dataobject.cvattachment.CvAttachmentDO;
|
|
import com.citu.module.menduner.system.dal.dataobject.eduexp.EduExpDO;
|
|
import com.citu.module.menduner.system.dal.dataobject.eduexp.EduExpDO;
|
|
import com.citu.module.menduner.system.dal.dataobject.enterprise.EnterpriseDO;
|
|
import com.citu.module.menduner.system.dal.dataobject.enterprise.EnterpriseDO;
|
|
@@ -36,10 +35,10 @@ import lombok.extern.slf4j.Slf4j;
|
|
import org.springframework.scheduling.annotation.Async;
|
|
import org.springframework.scheduling.annotation.Async;
|
|
import org.springframework.security.crypto.password.PasswordEncoder;
|
|
import org.springframework.security.crypto.password.PasswordEncoder;
|
|
import org.springframework.stereotype.Component;
|
|
import org.springframework.stereotype.Component;
|
|
|
|
+import org.springframework.util.StringUtils;
|
|
|
|
|
|
import javax.annotation.Resource;
|
|
import javax.annotation.Resource;
|
|
import java.math.BigDecimal;
|
|
import java.math.BigDecimal;
|
|
-import java.util.Collections;
|
|
|
|
import java.util.HashMap;
|
|
import java.util.HashMap;
|
|
import java.util.List;
|
|
import java.util.List;
|
|
import java.util.Map;
|
|
import java.util.Map;
|
|
@@ -119,18 +118,18 @@ public class MdeOldSyncService {
|
|
@Async
|
|
@Async
|
|
public void run() {
|
|
public void run() {
|
|
// 同步职位信息
|
|
// 同步职位信息
|
|
- // syncPosition();
|
|
|
|
|
|
+ syncPosition();
|
|
// 同步用户信息
|
|
// 同步用户信息
|
|
- // syncUser();
|
|
|
|
|
|
+ syncUser();
|
|
// 同步发布职位
|
|
// 同步发布职位
|
|
- // syncJob();
|
|
|
|
|
|
+ syncJob();
|
|
// 同步人才工作经历、教育经历
|
|
// 同步人才工作经历、教育经历
|
|
syncPersonExtend();
|
|
syncPersonExtend();
|
|
// 同步人才简历附件、投递简历
|
|
// 同步人才简历附件、投递简历
|
|
syncCv();
|
|
syncCv();
|
|
}
|
|
}
|
|
|
|
|
|
-
|
|
|
|
|
|
+ @Async
|
|
public void syncPosition() {
|
|
public void syncPosition() {
|
|
|
|
|
|
// 部门 or 职位类型
|
|
// 部门 or 职位类型
|
|
@@ -226,7 +225,7 @@ public class MdeOldSyncService {
|
|
.id(oldMdeUser.getUserCode())
|
|
.id(oldMdeUser.getUserCode())
|
|
.username(oldMdeUser.getIdentityFlag().equals("0") ? oldMdeUser.getUserName() : oldMdeUser.getEntPhone())
|
|
.username(oldMdeUser.getIdentityFlag().equals("0") ? oldMdeUser.getUserName() : oldMdeUser.getEntPhone())
|
|
// 重置密码手机号后6位
|
|
// 重置密码手机号后6位
|
|
- .password(passwordEncoder.encode("123456"))
|
|
|
|
|
|
+ .password(passwordEncoder.encode("147258369"))
|
|
.email(oldMdeUser.getEmail())
|
|
.email(oldMdeUser.getEmail())
|
|
// 有座机,大坑
|
|
// 有座机,大坑
|
|
// 个人用户getUserName是手机号,企业用户是邮箱,所以企业用户取getEntPhone
|
|
// 个人用户getUserName是手机号,企业用户是邮箱,所以企业用户取getEntPhone
|
|
@@ -298,8 +297,7 @@ public class MdeOldSyncService {
|
|
.contact(oldMdeUser.getEntContacts())
|
|
.contact(oldMdeUser.getEntContacts())
|
|
.phone(oldMdeUser.getEntPhone())
|
|
.phone(oldMdeUser.getEntPhone())
|
|
.logoUrl(null == oldMdeUser.getHeadPortrait() ? null : url + oldMdeUser.getHeadPortrait())
|
|
.logoUrl(null == oldMdeUser.getHeadPortrait() ? null : url + oldMdeUser.getHeadPortrait())
|
|
- // 营业执照暂时放这
|
|
|
|
- .albumList(null == oldMdeUser.getImage() ? null : Collections.singletonList(url + oldMdeUser.getImage()))
|
|
|
|
|
|
+ .businessUrl(null == oldMdeUser.getImage() ? null : url + oldMdeUser.getImage())
|
|
.status(MendunerStatusEnum.ENABLE.getStatus())
|
|
.status(MendunerStatusEnum.ENABLE.getStatus())
|
|
.build();
|
|
.build();
|
|
|
|
|
|
@@ -329,6 +327,7 @@ public class MdeOldSyncService {
|
|
|
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+
|
|
public void syncJob() {
|
|
public void syncJob() {
|
|
// 职位信息
|
|
// 职位信息
|
|
List<OldMdeJobAdvertised> jobList = oldJobAdvertisedMapper.selectList(OldMdeJobAdvertised::getDelFlag, 0);
|
|
List<OldMdeJobAdvertised> jobList = oldJobAdvertisedMapper.selectList(OldMdeJobAdvertised::getDelFlag, 0);
|
|
@@ -368,6 +367,7 @@ public class MdeOldSyncService {
|
|
|
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+ @Async
|
|
public void syncPersonExtend() {
|
|
public void syncPersonExtend() {
|
|
// 人才教育经历、工作经历
|
|
// 人才教育经历、工作经历
|
|
List<OldMdeEducationExperience> eduList =
|
|
List<OldMdeEducationExperience> eduList =
|
|
@@ -413,6 +413,7 @@ public class MdeOldSyncService {
|
|
|
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+ @Async
|
|
public void syncCv() {
|
|
public void syncCv() {
|
|
// 人才投递的简历、附件
|
|
// 人才投递的简历、附件
|
|
List<OldMdeUserCv> cvList = oldUserCvMapper.selectList(OldMdeUserCv::getDelFlag, 0);
|
|
List<OldMdeUserCv> cvList = oldUserCvMapper.selectList(OldMdeUserCv::getDelFlag, 0);
|
|
@@ -430,9 +431,11 @@ public class MdeOldSyncService {
|
|
|
|
|
|
List<OldPositionCvRelDO> cvRelDOList = oldPositionCvRelDOMapper.selectList(new LambdaQueryWrapperX<OldPositionCvRelDO>()
|
|
List<OldPositionCvRelDO> cvRelDOList = oldPositionCvRelDOMapper.selectList(new LambdaQueryWrapperX<OldPositionCvRelDO>()
|
|
.eq(OldPositionCvRelDO::getDelFlag, 0)
|
|
.eq(OldPositionCvRelDO::getDelFlag, 0)
|
|
- .isNotNull(OldPositionCvRelDO::getCvUrl)
|
|
|
|
);
|
|
);
|
|
cvRelDOList.forEach(e -> {
|
|
cvRelDOList.forEach(e -> {
|
|
|
|
+ if (!StringUtils.hasText(e.getCvUrl())) {
|
|
|
|
+ return;
|
|
|
|
+ }
|
|
JobCvRelDO cvDO = jobCvRelMapper.selectOne(JobCvRelDO::getId, e.getIntvId());
|
|
JobCvRelDO cvDO = jobCvRelMapper.selectOne(JobCvRelDO::getId, e.getIntvId());
|
|
// 根据职位查询企业ID
|
|
// 根据职位查询企业ID
|
|
JobAdvertisedDO advertisedDO = jobAdvertisedMapper.selectOne(JobAdvertisedDO::getId, e.getPosId());
|
|
JobAdvertisedDO advertisedDO = jobAdvertisedMapper.selectOne(JobAdvertisedDO::getId, e.getPosId());
|
|
@@ -441,6 +444,7 @@ public class MdeOldSyncService {
|
|
}
|
|
}
|
|
JobCvRelDO insertionDO = JobCvRelDO.builder()
|
|
JobCvRelDO insertionDO = JobCvRelDO.builder()
|
|
.id(null == cvDO ? e.getIntvId() : cvDO.getId())
|
|
.id(null == cvDO ? e.getIntvId() : cvDO.getId())
|
|
|
|
+ .type("0")
|
|
.enterpriseId(advertisedDO.getEnterpriseId())
|
|
.enterpriseId(advertisedDO.getEnterpriseId())
|
|
.jobId(advertisedDO.getId())
|
|
.jobId(advertisedDO.getId())
|
|
.publishUserId(Long.valueOf(e.getPublisher()))
|
|
.publishUserId(Long.valueOf(e.getPublisher()))
|