|
@ -20,14 +20,23 @@ package com.elink.esua.epdc.modules.enterprise.service.impl; |
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
|
|
import com.baomidou.mybatisplus.core.metadata.IPage; |
|
|
import com.baomidou.mybatisplus.core.metadata.IPage; |
|
|
import com.elink.esua.epdc.commons.mybatis.service.impl.BaseServiceImpl; |
|
|
import com.elink.esua.epdc.commons.mybatis.service.impl.BaseServiceImpl; |
|
|
|
|
|
import com.elink.esua.epdc.commons.tools.constant.NumConstant; |
|
|
|
|
|
import com.elink.esua.epdc.commons.tools.exception.RenException; |
|
|
import com.elink.esua.epdc.commons.tools.page.PageData; |
|
|
import com.elink.esua.epdc.commons.tools.page.PageData; |
|
|
import com.elink.esua.epdc.commons.tools.utils.ConvertUtils; |
|
|
import com.elink.esua.epdc.commons.tools.utils.ConvertUtils; |
|
|
import com.elink.esua.epdc.commons.tools.constant.FieldConstant; |
|
|
import com.elink.esua.epdc.commons.tools.constant.FieldConstant; |
|
|
|
|
|
import com.elink.esua.epdc.commons.tools.utils.Result; |
|
|
|
|
|
import com.elink.esua.epdc.dto.ParentAndAllDeptDTO; |
|
|
import com.elink.esua.epdc.dto.enterprise.EnterpriseInfoDTO; |
|
|
import com.elink.esua.epdc.dto.enterprise.EnterpriseInfoDTO; |
|
|
|
|
|
import com.elink.esua.epdc.dto.epdc.form.CompleteRequisiteUserInfoDTO; |
|
|
|
|
|
import com.elink.esua.epdc.dto.form.CompleteRequisiteInfoDTO; |
|
|
import com.elink.esua.epdc.modules.enterprise.dao.EnterpriseInfoDao; |
|
|
import com.elink.esua.epdc.modules.enterprise.dao.EnterpriseInfoDao; |
|
|
import com.elink.esua.epdc.modules.enterprise.entity.EnterpriseInfoEntity; |
|
|
import com.elink.esua.epdc.modules.enterprise.entity.EnterpriseInfoEntity; |
|
|
import com.elink.esua.epdc.modules.enterprise.redis.EnterpriseInfoRedis; |
|
|
import com.elink.esua.epdc.modules.enterprise.redis.EnterpriseInfoRedis; |
|
|
import com.elink.esua.epdc.modules.enterprise.service.EnterpriseInfoService; |
|
|
import com.elink.esua.epdc.modules.enterprise.service.EnterpriseInfoService; |
|
|
|
|
|
import com.elink.esua.epdc.modules.feign.AdminFeignClient; |
|
|
|
|
|
import com.elink.esua.epdc.modules.feign.UserFeignClient; |
|
|
|
|
|
import io.seata.spring.annotation.GlobalTransactional; |
|
|
import org.apache.commons.lang3.StringUtils; |
|
|
import org.apache.commons.lang3.StringUtils; |
|
|
import org.springframework.beans.factory.annotation.Autowired; |
|
|
import org.springframework.beans.factory.annotation.Autowired; |
|
|
import org.springframework.stereotype.Service; |
|
|
import org.springframework.stereotype.Service; |
|
@ -49,6 +58,12 @@ public class EnterpriseInfoServiceImpl extends BaseServiceImpl<EnterpriseInfoDao |
|
|
@Autowired |
|
|
@Autowired |
|
|
private EnterpriseInfoRedis enterpriseInfoRedis; |
|
|
private EnterpriseInfoRedis enterpriseInfoRedis; |
|
|
|
|
|
|
|
|
|
|
|
@Autowired |
|
|
|
|
|
private AdminFeignClient adminFeignClient; |
|
|
|
|
|
|
|
|
|
|
|
@Autowired |
|
|
|
|
|
private UserFeignClient userFeignClient; |
|
|
|
|
|
|
|
|
@Override |
|
|
@Override |
|
|
public PageData<EnterpriseInfoDTO> page(Map<String, Object> params) { |
|
|
public PageData<EnterpriseInfoDTO> page(Map<String, Object> params) { |
|
|
IPage<EnterpriseInfoEntity> page = baseDao.selectPage( |
|
|
IPage<EnterpriseInfoEntity> page = baseDao.selectPage( |
|
@ -65,8 +80,8 @@ public class EnterpriseInfoServiceImpl extends BaseServiceImpl<EnterpriseInfoDao |
|
|
return ConvertUtils.sourceToTarget(entityList, EnterpriseInfoDTO.class); |
|
|
return ConvertUtils.sourceToTarget(entityList, EnterpriseInfoDTO.class); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
private QueryWrapper<EnterpriseInfoEntity> getWrapper(Map<String, Object> params){ |
|
|
private QueryWrapper<EnterpriseInfoEntity> getWrapper(Map<String, Object> params) { |
|
|
String id = (String)params.get(FieldConstant.ID_HUMP); |
|
|
String id = (String) params.get(FieldConstant.ID_HUMP); |
|
|
|
|
|
|
|
|
QueryWrapper<EnterpriseInfoEntity> wrapper = new QueryWrapper<>(); |
|
|
QueryWrapper<EnterpriseInfoEntity> wrapper = new QueryWrapper<>(); |
|
|
wrapper.eq(StringUtils.isNotBlank(id), FieldConstant.ID, id); |
|
|
wrapper.eq(StringUtils.isNotBlank(id), FieldConstant.ID, id); |
|
@ -101,4 +116,28 @@ public class EnterpriseInfoServiceImpl extends BaseServiceImpl<EnterpriseInfoDao |
|
|
baseDao.deleteBatchIds(Arrays.asList(ids)); |
|
|
baseDao.deleteBatchIds(Arrays.asList(ids)); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@GlobalTransactional |
|
|
|
|
|
@Override |
|
|
|
|
|
public Result completeRequisiteInfo(CompleteRequisiteInfoDTO fromDto) { |
|
|
|
|
|
//保存到企业数据库
|
|
|
|
|
|
EnterpriseInfoDTO enterpriseInfoDTO = ConvertUtils.sourceToTarget(fromDto, EnterpriseInfoDTO.class); |
|
|
|
|
|
Result<ParentAndAllDeptDTO> parentResult = adminFeignClient.getParentAndAllDept(String.valueOf(fromDto.getDeptId())); |
|
|
|
|
|
if (!parentResult.success() || parentResult.getData() == null) { |
|
|
|
|
|
throw new RenException("获取部门信息失败"); |
|
|
|
|
|
} else { |
|
|
|
|
|
ParentAndAllDeptDTO deptDTO = parentResult.getData(); |
|
|
|
|
|
enterpriseInfoDTO.setAllDeptIds(deptDTO.getAllDeptIds()); |
|
|
|
|
|
enterpriseInfoDTO.setAllDeptNames(deptDTO.getAllDeptNames()); |
|
|
|
|
|
enterpriseInfoDTO.setParentDeptIds(deptDTO.getParentDeptIds()); |
|
|
|
|
|
enterpriseInfoDTO.setParentDeptNames(deptDTO.getParentDeptNames()); |
|
|
|
|
|
} |
|
|
|
|
|
save(enterpriseInfoDTO); |
|
|
|
|
|
//更新用户表数据
|
|
|
|
|
|
CompleteRequisiteUserInfoDTO userInfoDTO = ConvertUtils.sourceToTarget(fromDto, CompleteRequisiteUserInfoDTO.class); |
|
|
|
|
|
userInfoDTO.setDwellingPlace(enterpriseInfoDTO.getEnterpriseAddress()); |
|
|
|
|
|
userInfoDTO.setNickName(parentResult.getData().getGrid()+"-"+ fromDto.getRealName().substring(NumConstant.ZERO, NumConstant.ONE) |
|
|
|
|
|
+ (Integer.parseInt(fromDto.getSex()) == NumConstant.ZERO ? "女士" : "先生")); |
|
|
|
|
|
userFeignClient.completeRequisiteInfo(userInfoDTO); |
|
|
|
|
|
return new Result(); |
|
|
|
|
|
} |
|
|
} |
|
|
} |