Compare commits
No commits in common. "ce9f56000e7031a36e6315757ca42c72333242cd" and "6e9141d12392aef4c5ae1dbd21e047eb65243d67" have entirely different histories.
ce9f56000e
...
6e9141d123
|
|
@ -41,7 +41,6 @@ import java.util.ArrayList;
|
||||||
import java.util.Arrays;
|
import java.util.Arrays;
|
||||||
import java.util.Collections;
|
import java.util.Collections;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
import java.util.stream.Collectors;
|
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|
@ -100,32 +99,16 @@ public class UserUpdateExe {
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
;
|
||||||
CorpInfoDO corpInfoDO = corpInfoRepository.getById(userDO.getCorpinfoId());
|
CorpInfoDO corpInfoDO = corpInfoRepository.getById(userDO.getCorpinfoId());
|
||||||
if(corpInfoDO != null){
|
if(corpInfoDO != null){
|
||||||
if(corpInfoDO.getType() == CorpTypeEnum.serviceProvider.getCode()
|
if(corpInfoDO.getType() == CorpTypeEnum.serviceProvider.getCode()
|
||||||
|| corpInfoDO.getType() == CorpTypeEnum.cargoOwner.getCode()
|
|| corpInfoDO.getType() == CorpTypeEnum.cargoOwner.getCode()
|
||||||
|| corpInfoDO.getType() == CorpTypeEnum.portUnit.getCode()){
|
|| corpInfoDO.getType() == CorpTypeEnum.portUnit.getCode()){
|
||||||
// 先把其他相关方的账号找出来
|
// 相关方
|
||||||
List<UserDO> userByPhoneList = userRepository.listByPhone(userDO.getPhone());
|
boolean res = userGateway.updateByPhone(userE);
|
||||||
List<Long> userIds = userByPhoneList.stream().map(UserDO::getId).collect(Collectors.toList());
|
// 保存履职记录
|
||||||
|
if (!res) {
|
||||||
// pc端当前相关方企业修改
|
|
||||||
boolean res = userGateway.update(userE);
|
|
||||||
if(!userE.getPhone().equals(userDO.getPhone())){
|
|
||||||
// 调用底座修改账号
|
|
||||||
userGateway.updateByGBS(userE);
|
|
||||||
// 重置密码
|
|
||||||
UserE u = new UserE();
|
|
||||||
u.resetPassword();
|
|
||||||
for (Long userId : userIds) {
|
|
||||||
userRepository.changePassword(userId, u.getPassword());
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// 相关方同步修改
|
|
||||||
boolean res2 = userGateway.updateByIds(userE, userIds);
|
|
||||||
|
|
||||||
if (!res || !res2) {
|
|
||||||
throw new BizException("修改失败");
|
throw new BizException("修改失败");
|
||||||
}
|
}
|
||||||
}else {
|
}else {
|
||||||
|
|
|
||||||
|
|
@ -4,7 +4,6 @@ package com.zcloud.basic.info.domain.gateway;
|
||||||
import com.alibaba.cola.dto.Response;
|
import com.alibaba.cola.dto.Response;
|
||||||
import com.zcloud.basic.info.domain.model.UserE;
|
import com.zcloud.basic.info.domain.model.UserE;
|
||||||
|
|
||||||
import java.util.List;
|
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|
@ -29,10 +28,6 @@ public interface UserGateway {
|
||||||
|
|
||||||
Boolean updateByPhone(UserE userE);
|
Boolean updateByPhone(UserE userE);
|
||||||
|
|
||||||
Boolean updateByIds(UserE userE, List<Long> ids);
|
|
||||||
|
|
||||||
Boolean updateByGBS(UserE userE);
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 删除
|
* 删除
|
||||||
*/
|
*/
|
||||||
|
|
|
||||||
|
|
@ -1,10 +1,7 @@
|
||||||
package com.zcloud.basic.info.gatewayimpl;
|
package com.zcloud.basic.info.gatewayimpl;
|
||||||
|
|
||||||
import cn.hutool.json.JSONUtil;
|
|
||||||
import com.alibaba.cola.dto.Response;
|
import com.alibaba.cola.dto.Response;
|
||||||
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
|
||||||
import com.jjb.saas.system.client.user.facade.UserFacade;
|
|
||||||
import com.jjb.saas.system.client.user.request.RoleDeptAddCmd;
|
|
||||||
import com.zcloud.basic.info.domain.enums.UserEmploymentFlagEnum;
|
import com.zcloud.basic.info.domain.enums.UserEmploymentFlagEnum;
|
||||||
import com.zcloud.basic.info.domain.gateway.UserGateway;
|
import com.zcloud.basic.info.domain.gateway.UserGateway;
|
||||||
import com.zcloud.basic.info.domain.model.UserE;
|
import com.zcloud.basic.info.domain.model.UserE;
|
||||||
|
|
@ -12,18 +9,13 @@ import com.zcloud.basic.info.persistence.dataobject.UserDO;
|
||||||
import com.zcloud.basic.info.persistence.repository.UserRepository;
|
import com.zcloud.basic.info.persistence.repository.UserRepository;
|
||||||
import com.zcloud.gbscommon.utils.PageQueryHelper;
|
import com.zcloud.gbscommon.utils.PageQueryHelper;
|
||||||
import lombok.AllArgsConstructor;
|
import lombok.AllArgsConstructor;
|
||||||
import org.apache.dubbo.config.annotation.DubboReference;
|
|
||||||
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.BeanUtils;
|
||||||
import org.springframework.stereotype.Service;
|
import org.springframework.stereotype.Service;
|
||||||
import org.springframework.util.ObjectUtils;
|
import org.springframework.util.ObjectUtils;
|
||||||
|
|
||||||
import java.util.Arrays;
|
import java.util.Arrays;
|
||||||
import java.util.Collections;
|
|
||||||
import java.util.List;
|
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
|
|
||||||
import static dm.jdbc.util.DriverUtil.log;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* web-infrastructure
|
* web-infrastructure
|
||||||
* @Author zhangyue
|
* @Author zhangyue
|
||||||
|
|
@ -33,8 +25,6 @@ import static dm.jdbc.util.DriverUtil.log;
|
||||||
@AllArgsConstructor
|
@AllArgsConstructor
|
||||||
public class UserGatewayImpl implements UserGateway {
|
public class UserGatewayImpl implements UserGateway {
|
||||||
private final UserRepository userRepository;
|
private final UserRepository userRepository;
|
||||||
@DubboReference
|
|
||||||
private UserFacade userFacade;
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public Boolean add(UserE userE) {
|
public Boolean add(UserE userE) {
|
||||||
|
|
@ -104,57 +94,6 @@ public class UserGatewayImpl implements UserGateway {
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
|
||||||
public Boolean updateByIds(UserE userE, List<Long> ids) {
|
|
||||||
UserDO d = new UserDO();
|
|
||||||
|
|
||||||
d.setUsername(userE.getPhone());
|
|
||||||
d.setPhone(userE.getPhone());
|
|
||||||
|
|
||||||
d.setUserAvatarUrl(userE.getUserAvatarUrl());
|
|
||||||
d.setName(userE.getName());
|
|
||||||
d.setUserIdCard(userE.getUserIdCard());
|
|
||||||
d.setNation(userE.getNation());
|
|
||||||
d.setNationName(userE.getNationName());
|
|
||||||
d.setCurrentAddress(userE.getCurrentAddress());
|
|
||||||
d.setLocationAddress(userE.getLocationAddress());
|
|
||||||
d.setCulturalLevel(userE.getCulturalLevel());
|
|
||||||
d.setCulturalLevelName(userE.getCulturalLevelName());
|
|
||||||
d.setPoliticalAffiliation(userE.getPoliticalAffiliation());
|
|
||||||
d.setPoliticalAffiliationName(userE.getPoliticalAffiliationName());
|
|
||||||
d.setMaritalStatus(userE.getMaritalStatus());
|
|
||||||
d.setMaritalStatusName(userE.getMaritalStatusName());
|
|
||||||
if(userE.getFlowFlag() != null){
|
|
||||||
d.setFlowFlag(userE.getFlowFlag());
|
|
||||||
}
|
|
||||||
d.setEmail(userE.getEmail());
|
|
||||||
|
|
||||||
UpdateWrapper<UserDO> updateWrapper = new UpdateWrapper<>();
|
|
||||||
updateWrapper.in("id", ids);
|
|
||||||
|
|
||||||
userRepository.update(d, updateWrapper);
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public Boolean updateByGBS(UserE userE) {
|
|
||||||
com.jjb.saas.system.client.user.request.UserUpdateCmd updateCmd = new com.jjb.saas.system.client.user.request.UserUpdateCmd();
|
|
||||||
updateCmd.setId(userE.getId());
|
|
||||||
updateCmd.setAccount(userE.getPhone());
|
|
||||||
updateCmd.setMobile(userE.getPhone());
|
|
||||||
updateCmd.setName(userE.getName());
|
|
||||||
updateCmd.setEmail(userE.getEmail());
|
|
||||||
RoleDeptAddCmd roleDeptAddCmd = new RoleDeptAddCmd();
|
|
||||||
roleDeptAddCmd.setRoleId(userE.getRoleId());
|
|
||||||
roleDeptAddCmd.setDeptId(userE.getDepartmentId());
|
|
||||||
List<RoleDeptAddCmd> roleDeptAddCmdList = Collections.singletonList(roleDeptAddCmd);
|
|
||||||
updateCmd.setRoleDepts(roleDeptAddCmdList);
|
|
||||||
log.info("GBS修改用户开始,用户信息:{}", JSONUtil.toJsonStr(updateCmd));
|
|
||||||
Response response = userFacade.update(updateCmd);
|
|
||||||
log.info("GBS修改用户结束,用户id:{},结果:{}", JSONUtil.toJsonStr(response));
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void deletedUserById(Long id) {
|
public void deletedUserById(Long id) {
|
||||||
userRepository.deleteUserById(id);
|
userRepository.deleteUserById(id);
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue