From 2b30df90a4e281c2a37c2933a7389ea0c149ffcc Mon Sep 17 00:00:00 2001 From: value <z1292839451@163.com> Date: 星期五, 17 五月 2024 03:28:16 +0800 Subject: [PATCH] 人事对接 --- user-server/src/main/java/com/yuanchu/mom/service/impl/UserServiceImp.java | 61 ++++++++++++++++++++++++++++-- 1 files changed, 57 insertions(+), 4 deletions(-) diff --git a/user-server/src/main/java/com/yuanchu/mom/service/impl/UserServiceImp.java b/user-server/src/main/java/com/yuanchu/mom/service/impl/UserServiceImp.java index 92bf542..0952c4e 100644 --- a/user-server/src/main/java/com/yuanchu/mom/service/impl/UserServiceImp.java +++ b/user-server/src/main/java/com/yuanchu/mom/service/impl/UserServiceImp.java @@ -9,10 +9,12 @@ import com.yuanchu.mom.dto.PersonDto; import com.yuanchu.mom.dto.UserPageDto; import com.yuanchu.mom.exception.ErrorException; +import com.yuanchu.mom.mapper.DepartmentsMapper; import com.yuanchu.mom.mapper.UserMapper; +import com.yuanchu.mom.pojo.Departments; import com.yuanchu.mom.pojo.User; import com.yuanchu.mom.service.UserService; -import com.yuanchu.mom.utils.Jwt; +import com.yuanchu.mom.util.HeaderToken; import com.yuanchu.mom.utils.QueryWrappers; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; @@ -22,6 +24,7 @@ import java.util.HashMap; import java.util.List; import java.util.Map; +import java.util.concurrent.atomic.AtomicReference; @Service public class UserServiceImp implements UserService { @@ -29,11 +32,13 @@ @Resource UserMapper userMapper; @Resource - Jwt jwt; - @Resource private GetLook getLook; + @Resource + private DepartmentsMapper departmentsMapper; + @Resource + private HeaderToken headerToken; @Override public User selectUserByPwd(String account, String password) { @@ -109,7 +114,55 @@ @Override @Transactional(rollbackFor = Exception.class) public int addPersonUser(PersonDto personDto) { - System.out.println(personDto); + AtomicReference<String> departId = new AtomicReference<>(""); + AtomicReference<String> companyName = new AtomicReference<>(); + personDto.getCompany().forEach(company->{ + Departments department = departmentsMapper.selectOne(Wrappers.<Departments>lambdaQuery().eq(Departments::getCompanyId, company.getCompanyId())); + if(BeanUtil.isEmpty(department)){ + department = new Departments(); + department.setName(company.getCompanyName()); + department.setCompanyId(company.getCompanyId()); + Departments department2 = departmentsMapper.selectOne(Wrappers.<Departments>lambdaQuery().eq(Departments::getCompanyId, company.getParentCompanyId())); + if(BeanUtil.isEmpty(department2)){ + department.setFatherId(1); + }else{ + department.setFatherId(department2.getId()); + } + departmentsMapper.insert(department); + } + departId.set(departId.get()+department.getId()+","); + companyName.set(department.getName()); + }); + personDto.getPerson().forEach(person -> { + User user = userMapper.selectOne(Wrappers.<User>lambdaQuery().eq(User::getAccount, person.getEmployeeID())); + if(BeanUtil.isEmpty(user)){ + user = new User(); + user.setName(person.getName()); + user.setNameEn("not write"); + user.setAccount(person.getEmployeeID()); + user.setPhone(person.getPhoneNumber()); + user.setEmail(person.getCompanyEmail()); + user.setIsCustom(person.getCompanyId().equals("SC2463")?0:1); + user.setDepartId(departId.get()); +// user.setPassword(DigestUtils.md5DigestAsHex(headerToken.getPassword(person.getEmployeeID()).getBytes())); + user.setPassword(DigestUtils.md5DigestAsHex("123456".getBytes())); + user.setCompany(companyName.get()); + user.setAddress("鏈~鍐�"); + userMapper.insert(user); + }else{ + user.setName(person.getName()); + user.setPhone(person.getPhoneNumber()); + user.setEmail(person.getCompanyEmail()); + user.setIsCustom(person.getCompanyId().equals("SC2463")?0:1); + user.setDepartId(departId.get()); + user.setCompany(companyName.get()); + user.setCreateUser(null); + user.setCreateTime(null); + user.setUpdateUser(null); + user.setUpdateTime(null); + userMapper.updateById(user); + } + }); return 1; } } -- Gitblit v1.9.3