zcloud_gbs
/
zcloud_gbs_basic_info_gwj
16
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

大华口门对接1.0 

(cherry picked from commit 65ad2b538e)
dahua_koumen
zhangxiongfeng 2026-08-04 16:32:38 +08:00
parent c227c8def6
commit 285764928c
4 changed files with 18 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
web-app/src/main/java/com/zcloud/basic/info/command/UserAddExe.java
View File

@ -100,7 +100,7 @@ public class UserAddExe {
private final UserExpandInfoRepository userExpandInfoRepository; private final UserExpandInfoRepository userExpandInfoRepository;
private final ImgFilesRepository imgFilesRepository; private final ImgFilesRepository imgFilesRepository;
private final DaHuaConfig daHuaConfig; private final DaHuaConfig daHuaConfig;
@DubboReference @DubboReference(version = "1.0.0", group = "primeport")
private ZcloudDaHuaFacade zcloudDaHuaFacade; private ZcloudDaHuaFacade zcloudDaHuaFacade;
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
@ -448,13 +448,16 @@ public class UserAddExe {
List<DaHuaPersonSyncCmd.PersonBiosignature> bioList = (List<DaHuaPersonSyncCmd.PersonBiosignature>) biosObj; List<DaHuaPersonSyncCmd.PersonBiosignature> bioList = (List<DaHuaPersonSyncCmd.PersonBiosignature>) biosObj;
cmd.setPersonBiosignatures(bioList); cmd.setPersonBiosignatures(bioList);
} }
log.info("Dubbo调用primeport.zcloudDaHuaFacade.syncPerson, name={}, departmentId(corpId)={}",
cmd.getName(), cmd.getDepartmentId());
SingleResponse<Object> syncResp = zcloudDaHuaFacade.syncPerson(cmd);
String maskedIdCard = plainIdCard; String maskedIdCard = plainIdCard;
if (plainIdCard != null && plainIdCard.length() >= 14) { if (plainIdCard != null && plainIdCard.length() >= 14) {
maskedIdCard = plainIdCard.substring(0, 6) + "********" + plainIdCard.substring(plainIdCard.length() - 4); maskedIdCard = plainIdCard.substring(0, 6) + "********" + plainIdCard.substring(plainIdCard.length() - 4);
} }
log.info("Dubbo调用primeport.zcloudDaHuaFacade.syncPerson, name={}, departmentId(corpId)={}, idCardMask={}",
cmd.getName(), cmd.getDepartmentId(), maskedIdCard);
if (cmd.getPersonBiosignatures() != null) {
log.info("Dubbo调用携带人脸生物特征, size={}", cmd.getPersonBiosignatures().size());
}
SingleResponse<Object> syncResp = zcloudDaHuaFacade.syncPerson(cmd);
result.setDahuaCode(plainIdCard); result.setDahuaCode(plainIdCard);
userE.setDahuaCode(plainIdCard); userE.setDahuaCode(plainIdCard);
if (syncResp == null || !syncResp.isSuccess()) { if (syncResp == null || !syncResp.isSuccess()) {

2
web-app/src/main/java/com/zcloud/basic/info/command/UserRemoveExe.java
View File

@ -55,7 +55,7 @@ public class UserRemoveExe {
private final ZcloudRedisUtil zcloudRedisUtil; private final ZcloudRedisUtil zcloudRedisUtil;
private final UserCorpRecordRepository userCorpRecordRepository; private final UserCorpRecordRepository userCorpRecordRepository;
private final DaHuaConfig daHuaConfig; private final DaHuaConfig daHuaConfig;
@DubboReference @DubboReference(version = "1.0.0", group = "primeport")
private ZcloudDaHuaFacade zcloudDaHuaFacade; private ZcloudDaHuaFacade zcloudDaHuaFacade;
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)

11
web-app/src/main/java/com/zcloud/basic/info/command/UserUpdateExe.java
View File

@ -78,7 +78,7 @@ public class UserUpdateExe {
@DubboReference @DubboReference
private ZcloudRiskFacade zcloudRiskFacade; private ZcloudRiskFacade zcloudRiskFacade;
private final DaHuaConfig daHuaConfig; private final DaHuaConfig daHuaConfig;
@DubboReference @DubboReference(version = "1.0.0", group = "primeport")
private ZcloudDaHuaFacade zcloudDaHuaFacade; private ZcloudDaHuaFacade zcloudDaHuaFacade;
@ -465,13 +465,16 @@ public class UserUpdateExe {
List<DaHuaPersonSyncCmd.PersonBiosignature> bioList = (List<DaHuaPersonSyncCmd.PersonBiosignature>) biosObj; List<DaHuaPersonSyncCmd.PersonBiosignature> bioList = (List<DaHuaPersonSyncCmd.PersonBiosignature>) biosObj;
cmd.setPersonBiosignatures(bioList); cmd.setPersonBiosignatures(bioList);
} }
log.info("Dubbo调用primeport.zcloudDaHuaFacade.updatePerson, name={}, departmentId(corpId)={}",
cmd.getName(), cmd.getDepartmentId());
SingleResponse<Boolean> updateResp = zcloudDaHuaFacade.updatePerson(cmd);
String maskedIdCard = plainIdCard; String maskedIdCard = plainIdCard;
if (plainIdCard != null && plainIdCard.length() >= 14) { if (plainIdCard != null && plainIdCard.length() >= 14) {
maskedIdCard = plainIdCard.substring(0, 6) + "********" + plainIdCard.substring(plainIdCard.length() - 4); maskedIdCard = plainIdCard.substring(0, 6) + "********" + plainIdCard.substring(plainIdCard.length() - 4);
} }
log.info("Dubbo调用primeport.zcloudDaHuaFacade.updatePerson, name={}, departmentId(corpId)={}, idCardMask={}",
cmd.getName(), cmd.getDepartmentId(), maskedIdCard);
if (cmd.getPersonBiosignatures() != null) {
log.info("Dubbo调用携带人脸生物特征, size={}", cmd.getPersonBiosignatures().size());
}
SingleResponse<Boolean> updateResp = zcloudDaHuaFacade.updatePerson(cmd);
if (updateResp == null || !updateResp.isSuccess()) { if (updateResp == null || !updateResp.isSuccess()) {
String errCode = updateResp == null ? "" : updateResp.getErrCode(); String errCode = updateResp == null ? "" : updateResp.getErrCode();
String errMessage = updateResp == null ? "大华Dubbo返回为空" : updateResp.getErrMessage(); String errMessage = updateResp == null ? "大华Dubbo返回为空" : updateResp.getErrMessage();

6
web-infrastructure/src/main/java/com/zcloud/basic/info/gatewayimpl/UserGatewayImpl.java
View File

@ -39,7 +39,7 @@ public class UserGatewayImpl implements UserGateway {
private UserFacade userFacade; private UserFacade userFacade;
@Override @Override
@Transactional(rollbackFor = Exception.class, propagation = org.springframework.transaction.annotation.Propagation.REQUIRES_NEW) @Transactional(rollbackFor = Exception.class)
public Boolean add(UserE userE) { public Boolean add(UserE userE) {
UserDO d = new UserDO(); UserDO d = new UserDO();
BeanUtils.copyProperties(userE, d); BeanUtils.copyProperties(userE, d);
@ -49,7 +49,7 @@ public class UserGatewayImpl implements UserGateway {
} }
@Override @Override
@Transactional(rollbackFor = Exception.class, propagation = org.springframework.transaction.annotation.Propagation.REQUIRES_NEW) @Transactional(rollbackFor = Exception.class)
public Boolean addYanshi(UserE userE) { public Boolean addYanshi(UserE userE) {
UserDO d = new UserDO(); UserDO d = new UserDO();
BeanUtils.copyProperties(userE, d); BeanUtils.copyProperties(userE, d);
@ -68,7 +68,7 @@ public class UserGatewayImpl implements UserGateway {
} }
@Override @Override
@Transactional(rollbackFor = Exception.class, propagation = org.springframework.transaction.annotation.Propagation.REQUIRES_NEW) @Transactional(rollbackFor = Exception.class)
public boolean addXgf(UserE userE) { public boolean addXgf(UserE userE) {
UserDO d = new UserDO(); UserDO d = new UserDO();
// 新增用户默认在职 // 新增用户默认在职