hz/java-servers
1
0
Fork 0
mirror of https://codeup.aliyun.com/67762337eccfc218f6110e0e/per-boe/java-servers.git synced 2025-12-07 01:46:47 +08:00
Code Issues Packages Projects Releases Wiki Activity

增加打印日志

Browse Source
This commit is contained in:
daihh
2022-11-02 23:51:03 +08:00
parent 150e39e36f
commit 52555fba89
2 changed files with 26 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
servers/boe-server-basic/src/main/java/com/xboe/basic/service/impl/BasicDataSyncServiceImpl.java
View File

@@ -160,7 +160,11 @@ public class BasicDataSyncServiceImpl implements IBasicDataSyncService{
Object idObj = orgDao.findField("id", FieldFilters.eq("kid", dto.getOldDepartId()));
if(idObj!=null) {
dto.setDepartId(idObj.toString());
}else {
log.error("用户【"+dto.getKid()+"】"+dto.getName()+"对应的机构的kid【"+dto.getOldDepartId()+"】本地未查到");
}
}else {
log.error("用户【"+dto.getKid()+"】"+dto.getName()+"无关联的机构信息oldDepartId");
}
//同一个用户工号对应 多个kid的情况,所以直接根据kid查询是不对的,所以这里按工号查询,不使用kid
User user = userDao.findOne(FieldFilters.eq("userNo", dto.getUserNo()));
@@ -208,7 +212,6 @@ public class BasicDataSyncServiceImpl implements IBasicDataSyncService{
user.setId(a.getId());
user.setPersonId(person.getId());
user.setEnterpriseId(dto.getEnterpriseId());
user.setDepartId(dto.getDepartId());
user.setDescription(dto.getDescription());
user.setDomainId(dto.getDomainId());
user.setDuty(dto.getDuty());
@@ -260,7 +263,12 @@ public class BasicDataSyncServiceImpl implements IBasicDataSyncService{
user.setOrgNamePath(dto.getOrgNamePath());
user.setOrgTreeType(dto.getOrgTreeType());
user.setEnterpriseId(dto.getEnterpriseId());
user.setDepartId(dto.getDepartId());
if(StringUtils.isNotBlank(dto.getDepartId())) {
user.setDepartId(dto.getDepartId());
}else {
log.error("用户【"+user+"】无机构信息，不更新此字段");
}
user.setRank(dto.getRank());
user.setSassId(dto.getSassId());
user.setTelephoneNo(dto.getTelephoneNo());

18
servers/boe-server-basic/src/main/java/com/xboe/primary/service/impl/MainDbSyncServiceImpl.java
View File

@@ -2,11 +2,13 @@ package com.xboe.primary.service.impl;
import java.time.LocalDateTime;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.xboe.basic.entity.Account;
import com.xboe.basic.service.impl.BasicDataSyncServiceImpl;
import com.xboe.dto.OrganizationDto;
import com.xboe.dto.UserDto;
import com.xboe.primary.dao.MainAccountDao;
@@ -18,9 +20,12 @@ import com.xboe.primary.entity.MainOrganization;
import com.xboe.primary.entity.MainUser;
import com.xboe.primary.service.IMainDbSyncService;
import lombok.extern.slf4j.Slf4j;
/**
* 主数据库同步的实现
*/
@Slf4j
@Service("allService")
public class MainDbSyncServiceImpl implements IMainDbSyncService {
@@ -95,7 +100,12 @@ public class MainDbSyncServiceImpl implements IMainDbSyncService {
//更新用户信息，更新账号信息
user.setSysId(dto.getKid());
user.setName(dto.getName());
user.setDepartId(dto.getDepartId());
if(StringUtils.isNotBlank(dto.getDepartId())) {
user.setDepartId(dto.getDepartId());
}else {
log.error("主库用户【"+user+"】无机构信息，不更新此字段");
}
user.setDescription(dto.getDescription());
user.setDomainId(dto.getDomainId());
user.setDuty(dto.getDuty());
@@ -142,7 +152,11 @@ public class MainDbSyncServiceImpl implements IMainDbSyncService {
user=new MainUser();
//同步过程中一样，可以不一样。因为此系统当前是一致的，所以统一使用一个
user.setId(a.getId());
user.setDepartId(dto.getDepartId());
if(StringUtils.isNotBlank(dto.getDepartId())) {
user.setDepartId(dto.getDepartId());
}else {
log.error("主库新增用户【"+user+"】无机构信息");
}
user.setDescription(dto.getDescription());
user.setDomainId(dto.getDomainId());
user.setDuty(dto.getDuty());