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

案例同步，对作者只有工号的情况的兼容

Browse Source
This commit is contained in:
daihh
2022-11-22 14:27:12 +08:00
parent e9688a4d35
commit 5875f4215d
3 changed files with 28 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
servers/boe-server-case/src/main/java/com/xboe/casetask/CaseDataSyncRunner.java
View File

@@ -27,6 +27,7 @@ import com.xboe.casetask.entity.CaseSyncCustomize;
import com.xboe.casetask.entity.CaseSyncLog; import com.xboe.casetask.entity.CaseSyncLog;
import com.xboe.casetask.entity.CaseSyncRecord; import com.xboe.casetask.entity.CaseSyncRecord;
import com.xboe.casetask.entity.DictItem; import com.xboe.casetask.entity.DictItem;
import com.xboe.casetask.entity.User;
import com.xboe.casetask.service.ICaseSyncLogService; import com.xboe.casetask.service.ICaseSyncLogService;
import com.xboe.casetask.service.ICaseSyncService; import com.xboe.casetask.service.ICaseSyncService;
import com.xboe.common.utils.StringUtil; import com.xboe.common.utils.StringUtil;
@@ -317,7 +318,7 @@ public class CaseDataSyncRunner {
} }
//用户的转化处理,各处异常处理 //用户的转化处理,各种异常处理
String owner =csr.getCaseOwner(); String owner =csr.getCaseOwner();
if(StringUtils.isNotBlank(owner)) { if(StringUtils.isNotBlank(owner)) {
int leftIdx=owner.indexOf("<"); int leftIdx=owner.indexOf("<");
@@ -336,8 +337,17 @@ public class CaseDataSyncRunner {
} }
}else { }else {
csr.setStatus(1); //这种情况把它当成单独的工号处理
csr.setErrorInfo(csr.getErrorInfo()+",caseOwner数据格式错误【"+owner+"】"); User u= syncService.getByUserNo(owner);
if(u==null) {
csr.setStatus(1);
csr.setErrorInfo(csr.getErrorInfo()+",关联用户失败【"+csr.getCaseOwner()+"】");
}else {
csr.setAuthorId(u.getId());
csr.setAuthorName(u.getName());
}
// csr.setStatus(1);
// csr.setErrorInfo(csr.getErrorInfo()+",caseOwner数据格式错误【"+owner+"】");
} }
}else { }else {
csr.setStatus(1); csr.setStatus(1);

8
servers/boe-server-case/src/main/java/com/xboe/casetask/service/ICaseSyncService.java
View File

@@ -7,6 +7,7 @@ import com.xboe.casetask.entity.CaseSyncCustomize;
import com.xboe.casetask.entity.CaseSyncRecord; import com.xboe.casetask.entity.CaseSyncRecord;
import com.xboe.casetask.entity.Cases; import com.xboe.casetask.entity.Cases;
import com.xboe.casetask.entity.DictItem; import com.xboe.casetask.entity.DictItem;
import com.xboe.casetask.entity.User;
import com.xboe.common.PageList; import com.xboe.common.PageList;
public interface ICaseSyncService { public interface ICaseSyncService {
@@ -18,6 +19,13 @@ public interface ICaseSyncService {
*/ */
String getIdByUserNo(String userNo); String getIdByUserNo(String userNo);
/**
* 根据工号，查询用户信息
* @param userNo
* @return
*/
User getByUserNo(String userNo);
/** /**
* 获得所有的组织领域 * 获得所有的组织领域
* @return * @return

7
servers/boe-server-case/src/main/java/com/xboe/casetask/service/impl/CaseSyncServiceImpl.java
View File

@@ -21,6 +21,7 @@ import com.xboe.casetask.entity.CaseSyncRecord;
import com.xboe.casetask.entity.Cases; import com.xboe.casetask.entity.Cases;
import com.xboe.casetask.entity.CasesMajorType; import com.xboe.casetask.entity.CasesMajorType;
import com.xboe.casetask.entity.DictItem; import com.xboe.casetask.entity.DictItem;
import com.xboe.casetask.entity.User;
import com.xboe.casetask.service.ICaseSyncService; import com.xboe.casetask.service.ICaseSyncService;
import com.xboe.common.OrderCondition; import com.xboe.common.OrderCondition;
import com.xboe.common.PageList; import com.xboe.common.PageList;
@@ -351,4 +352,10 @@ public class CaseSyncServiceImpl implements ICaseSyncService{
return recordDao.findDictItemByName(name1, name2); return recordDao.findDictItemByName(name1, name2);
} }
@Override
public User getByUserNo(String userNo) {
User user=userDao.findOne(FieldFilters.eq("userNo", userNo));
return user;
}
} }