package com.doumee.service.business.impl.hksync;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
|
import com.doumee.biz.system.SystemDictDataBiz;
|
import com.doumee.core.constants.ResponseStatus;
|
import com.doumee.core.erp.model.openapi.request.UserUpdateRequest;
|
import com.doumee.core.erp.model.openapi.request.erp.UserFailRequest;
|
import com.doumee.core.exception.BusinessException;
|
import com.doumee.core.haikang.model.HKConstants;
|
import com.doumee.core.haikang.model.HKTools;
|
import com.doumee.core.haikang.model.param.BaseResponse;
|
import com.doumee.core.haikang.model.param.request.*;
|
import com.doumee.core.haikang.model.param.respose.*;
|
import com.doumee.core.haikang.service.HKService;
|
import com.doumee.core.utils.Constants;
|
import com.doumee.core.utils.DESUtil;
|
import com.doumee.core.utils.DateUtil;
|
import com.doumee.core.utils.ImageBase64Util;
|
import com.doumee.dao.business.*;
|
import com.doumee.dao.business.join.CompanyJoinMapper;
|
import com.doumee.dao.business.join.MemberJoinMapper;
|
import com.doumee.dao.business.model.*;
|
import com.doumee.service.business.ERPSyncService;
|
import com.github.yulichang.query.MPJQueryWrapper;
|
import com.github.yulichang.wrapper.MPJLambdaWrapper;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.collections.CollectionUtils;
|
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 java.util.*;
|
|
/**
|
* 海康组织人员通过步Service实现
|
* @author 江蹄蹄
|
* @date 2023/11/30 15:33
|
*/
|
@Service
|
@Slf4j
|
public class HkSyncOrgUserServiceImpl extends HkSyncBaseServiceImpl {
|
@Autowired
|
private CompanyMapper companyMapper;
|
@Autowired
|
private DeviceRoleMapper deviceRoleMapper;
|
@Autowired
|
private MemberRoleMapper memberRoleMapper;
|
@Autowired
|
private EmpowerMapper empowerMapper;
|
@Autowired
|
private MemberJoinMapper memberMapper;
|
@Autowired
|
private ERPSyncService erpSyncService;
|
@Autowired
|
private DeviceMapper deviceMapper;
|
@Autowired
|
private SystemDictDataBiz systemDictDataBiz;
|
|
/**
|
* 同步海康组织信息,根据erp同步组织结果，定时检查需要下发到海康的组织信息
|
*/
|
@Override
|
public void syncOrgData(){
|
if(Constants.DEALING_HK_ORG){
|
return ;
|
}
|
Constants.DEALING_HK_ORG =true;
|
try {
|
//查询所有需要同步的企业数据
|
String rootOrgId = systemDictDataBiz.queryByCode(Constants.HK_PARAM,Constants.HK_ROOTORG_CODE).getCode();
|
List<Company> list = companyMapper.selectList(new QueryWrapper<Company>()
|
.select("*,(select b.hk_id from company b where company.erp_parent_id = b.erp_id limit 1) as hkParentId")
|
.lambda()
|
.eq(Company::getHkStatus,Constants.ZERO)
|
.orderByAsc(Company::getErpDate));
|
if(list ==null || list.size()==0){
|
return;
|
}
|
Date date = new Date();
|
List<OrgEditRequest> editHkList = new ArrayList<>();
|
List<OrgAddRequest> addList = new ArrayList<>();
|
List<Company> updateList = new ArrayList<>();
|
List<Integer> delIds = new ArrayList<>();
|
List<String> delHKIds = new ArrayList<>();
|
for(Company c : list){
|
if(StringUtils.isBlank(c.getErpParentId())){
|
//如果是erp顶层组织，默认再海康根组织下创建组织
|
c.setHkParentId(rootOrgId);
|
}
|
if(StringUtils.isBlank(c.getHkParentId())){
|
//如果上级海康部门还没同步，则此次不处理
|
continue;
|
}
|
if(StringUtils.isBlank(c.getHkId())){
|
//如果新增同步數據
|
if(Constants.equalsInteger(Constants.ONE,c.getIsdeleted())){
|
//删除的组织，不做处理,海康状态更新为不处理，下次不再处理这个记录
|
c.setHkStatus(Constants.TWO);
|
companyMapper.updateById(c);
|
continue ;
|
}
|
OrgAddRequest m = getOrgAddModel(c,rootOrgId);
|
addList.add(m);
|
c.setHkId(m.getOrgIndexCode());
|
updateList.add(c);
|
}else{
|
if(Constants.equalsInteger(c.getIsdeleted(),Constants.ONE)){
|
//删除的数据，进行删除
|
delIds.add(c.getId());
|
delHKIds.add(c.getHkId());
|
}else{
|
//如果更新
|
editHkList.add(getOrgHkEditModel(c,rootOrgId));
|
}
|
updateList.add(c);
|
}
|
}
|
//处理删除数据
|
doHkDeleteOrg(delIds,delHKIds,date);
|
//处理新增数据
|
doHkAddOrg(updateList,addList,editHkList);
|
}catch (Exception e){
|
e.printStackTrace();
|
}finally {
|
Constants.DEALING_HK_ORG =false;
|
}
|
|
}
|
|
/**
|
* 处理批量新增的海康数据，更新同步数据状态
|
* @param updateList
|
* @param addList
|
*/
|
private void doHkAddOrg(List<Company> updateList, List<OrgAddRequest> addList, List<OrgEditRequest> editHkList) {
|
Date date = new Date();
|
if(addList!=null &&addList.size()>0){
|
//处理新增
|
BaseResponse<OrgOrUserAddResponse> result = HKService.addBatchOrg(addList);
|
if(result !=null && StringUtils.equals(result.getCode(),HKConstants.RESPONSE_SUCCEE)){
|
OrgOrUserAddResponse data = result.getData();
|
if(data.getSuccesses()!=null && data.getSuccesses().size()>0){
|
//处理新增成功的数据，修改海康同步状态
|
for(OrgOrUserAddSuccessResponse r :data.getSuccesses()){
|
Integer index = getCompanyId(updateList,r.getOrgIndexCode());
|
if(index!=null){
|
companyMapper.update(null,new UpdateWrapper<Company>().lambda()
|
.set(Company::getHkStatus,Constants.ONE)
|
.set(Company::getHkDate,date)
|
.set(Company::getHkId,r.getOrgIndexCode())
|
.eq(Company::getId, index) );
|
}
|
}
|
}
|
}
|
}
|
if(editHkList!=null){
|
//执行更新操作
|
List<String> success = new ArrayList<>();
|
List<String> error = new ArrayList<>();
|
for(OrgEditRequest param : editHkList){
|
BaseResponse result = HKService.editOrg(param);
|
if(result !=null && StringUtils.equals(result.getCode(),HKConstants.RESPONSE_SUCCEE)){
|
success.add(param.getOrgIndexCode());
|
}else{
|
error.add(param.getOrgIndexCode());
|
}
|
}
|
if(success.size()>0){
|
companyMapper.update(null,new UpdateWrapper<Company>().lambda()
|
.set(Company::getHkStatus,Constants.ONE)
|
.set(Company::getHkDate,date)
|
.in(Company::getHkId, success) );
|
}
|
if(error.size()>0){
|
companyMapper.update(null,new UpdateWrapper<Company>().lambda()
|
.set(Company::getHkStatus,Constants.TWO)
|
.set(Company::getHkDate,date)
|
.in(Company::getHkId, error) );
|
}
|
}
|
}
|
|
private Integer getCompanyId(List<Company> updateList, String orgIndexCode) {
|
if(updateList!=null && StringUtils.isNotBlank(orgIndexCode)){
|
for(Company c : updateList){
|
if(StringUtils.equals(c.getHkId(),orgIndexCode)){
|
return c.getId();
|
}
|
}
|
}
|
return null;
|
}
|
|
private OrgAddRequest getOrgAddModel(Company c,String rootOrgId) {
|
OrgAddRequest model = new OrgAddRequest();
|
model.setOrgIndexCode(HKConstants.RES_ORG_INDEX+UUID.randomUUID().toString().replace("-",""));
|
model.setOrgName(c.getName()+HKConstants.RES_ORG_NAME_INDEX);
|
// model.setOrgCode(c.getCode());
|
model.setParentIndexCode(c.getHkParentId());
|
return model;
|
|
}
|
private OrgEditRequest getOrgHkEditModel(Company c,String rootOrgId) {
|
OrgEditRequest model = new OrgEditRequest();
|
model.setOrgIndexCode(c.getHkId());
|
model.setOrgName(c.getName());
|
return model;
|
|
}
|
|
/**
|
* 对海康删除组织信息
|
* @param delIds
|
* @param date
|
*/
|
private void doHkDeleteOrg(List<Integer> delIds,List<String> delHkIds, Date date) {
|
if(delHkIds.size() == 0){
|
return;
|
}
|
OrgDelRequest request = new OrgDelRequest();
|
request.setIndexCodes( delHkIds.toArray(new String[]{}));
|
BaseResponse<List<OrgUpdateFailureResponse>> result = HKService.delBatchOrg(request);
|
if(result !=null && StringUtils.equals(result.getCode(),HKConstants.RESPONSE_SUCCEE)){
|
List<String> fIds = new ArrayList<>();
|
if(result.getData()!=null){
|
for(OrgUpdateFailureResponse r : result.getData()){
|
if(!r.getCode().equals("0x00052102")){
|
//不存在的也算删除成功
|
fIds.add(r.getOrgIndexCode());//删除失败的数据集合
|
}
|
}
|
}
|
//标记删除成功的数据（海康对接状态为已同步，，同步失败的仍为待同步，等下一次继续处理，知道全部删除完毕）
|
companyMapper.update(null,new UpdateWrapper<Company>().lambda()
|
.set(Company::getHkStatus,Constants.ONE)
|
.set(Company::getHkDate,date)
|
.set(Company::getHkId,null )
|
.in(Company::getId, delIds)
|
.notIn(fIds.size()>0,Company::getHkId, fIds));
|
companyMapper.update(null,new UpdateWrapper<Company>().lambda()
|
.set(Company::getHkStatus,Constants.TWO)
|
.set(Company::getHkDate,date)
|
.in(Company::getId, delIds)
|
.in(fIds.size()>0,Company::getHkId, fIds));
|
}
|
}
|
|
/**
|
* 同步海康人员信息
|
* @return
|
*/
|
@Override
|
public void syncUserData(){
|
if(Constants.DEALING_HK_USER){
|
return ;
|
}
|
Constants.DEALING_HK_USER =true;
|
try {
|
//查询所有需要同步的企业数据
|
List<Member> list = memberMapper.selectJoinList(Member.class,new MPJLambdaWrapper<Member>()
|
.selectAll(Member.class )
|
.selectAs(Company::getHkId,Member::getCompanyHkId)
|
.isNotNull(Member::getFaceImg)
|
.leftJoin(Company.class,Company::getId,Member::getCompanyId)
|
.eq(Member::getHkStatus,Constants.ZERO)
|
.orderByAsc(Member::getErpDate));
|
if(list ==null || list.size()==0){
|
return;
|
}
|
Date date = new Date();
|
String path = systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_RESOURCE_PATH).getCode()
|
+systemDictDataBiz.queryByCode(Constants.FTP,Constants.MEMBER_IMG).getCode();
|
for(Member c : list){
|
dealMemberInfoBiz(c,date,path) ;
|
}
|
}catch (Exception e){
|
e.printStackTrace();
|
}finally {
|
Constants.DEALING_HK_USER =false;
|
}
|
}
|
private List<Integer> getRoleIdByParam( Member member) {
|
//查询数据库存在的权限
|
List<DeviceRole> deviceRoleList= deviceRoleMapper.selectList(new QueryWrapper<DeviceRole>().lambda()
|
.eq(DeviceRole::getType,Constants.TWO)
|
.exists("(select b.id from member_role b where b.ROLE_ID = device_role.ID and b.MEMBER_ID="+member.getRoleId()+")"));
|
if(CollectionUtils.isNotEmpty(deviceRoleList)){
|
List<MemberRole> memberRoleList = new ArrayList<>();
|
String ids = "";
|
List<Integer> r = new ArrayList<>();
|
for (int i = 0; i < deviceRoleList.size(); i++) {
|
DeviceRole deviceRole =deviceRoleList.get(i);
|
if(i>0){
|
ids += ",";
|
}
|
String doorids =deviceRole.getDoorIds();
|
if(StringUtils.isNotBlank(doorids)){
|
String[] ss = doorids.split(",");
|
try {
|
for(String s :ss){
|
r.add(Integer.parseInt(s));
|
}
|
}catch (Exception e){
|
//脏数据不处理
|
}
|
}
|
}
|
return r;
|
}
|
return null;
|
}
|
@Transactional
|
private boolean dealMemberInfoBiz(Member c, Date date, String path) {
|
if( c.getCompanyId() == null){
|
//如果没有组织不做处理
|
return false;
|
}
|
if(StringUtils.isBlank(c.getHkId())){
|
//如果新增同步數據
|
dealUserHkAddBiz(c,date,path);
|
}else{
|
//如果之前已经和海康同步，则更新用户数据以及人脸数据（可能新增人脸 也可能更新人脸）
|
dealUserHkEditBiz(c,date,path);
|
}
|
return false;
|
}
|
private void dealMemberRoleEmpower(Member member ) {
|
List<Integer> doorIds = getRoleIdByParam(member);
|
if(doorIds==null || doorIds.size() == 0){
|
return;
|
}
|
if(StringUtils.isBlank(member.getFaceImg())){
|
return;
|
}
|
if(Constants.equalsObject(member.getHkStatus(),Constants.ONE)){
|
//如果用户是同步海康成功，添加带下发权限
|
List<Empower> list = new ArrayList<>();
|
List<Device> deviceList = deviceMapper.selectList(new QueryWrapper<Device>().lambda().in(Device::getId,doorIds));
|
if(deviceList == null || deviceList.size() == 0){
|
return;
|
}
|
for (Device deviceRole:deviceList) {
|
Empower model = new Empower();
|
model.setCreateDate(new Date());
|
model.setMemberId(member.getId());
|
model.setIsdeleted(Constants.ZERO);
|
model.setDeviceId(deviceRole.getId());
|
model.setSendStatus(Constants.ZERO);
|
model.setStartTime(member.getStartTime());
|
model.setEndTime(member.getEndTime());
|
//默认给于虚拟卡
|
model.setCardNos(Constants.VIRTUAL_CARD_INDEX+member.getId());
|
model.setSendType(Constants.ZERO);
|
list.add(model);
|
}
|
//导入新增的授权信息
|
empowerMapper.insertBatchSomeColumn(list);
|
}
|
}
|
/**
|
* 如果之前已经和海康同步，则更新用户数据以及人脸数据（可能新增人脸 也可能更新人脸）
|
* @param c
|
* @param date
|
* @param path
|
*/
|
private void dealUserHkEditBiz(Member c, Date date, String path) {
|
c.setHkStatus(Constants.ONE);
|
if(Constants.equalsInteger(Constants.ONE,c.getIsdeleted())){
|
//处理删除数据（删除之前下发的海康人员信息）
|
boolean r = doHkDeleteUser(c.getId(),c.getHkId(),date);
|
c.setHkStatus(r?Constants.ONE:Constants.TWO);
|
c.setRemark(r?null:"删除海康人员信息失败！");
|
}else{
|
//处理修改数据，并且更新人脸
|
UserAddRequest addHkModel = getUserAddModel(c,path,1);//修改
|
//处理新增数据
|
BaseResponse result = HKService.editUser(addHkModel);
|
if(result !=null && StringUtils.equals(result.getCode(),HKConstants.RESPONSE_SUCCEE) ){
|
if(StringUtils.isNotBlank(c.getFaceImg())){
|
//如果有人脸照片，处理人脸照片同步
|
String faceid = dealMemberFace(c,path);
|
if(StringUtils.isBlank(faceid)){
|
noticeErpFail(c,Constants.ZERO,"人脸信息更新失败，请检查人脸照片是否合法！");
|
c.setHkStatus(Constants.TWO);
|
c.setRemark("人脸信息更新失败，请检查人脸照片是否合法！！"+result.getMsg());
|
}else{
|
c.setFaceId(faceid);
|
}
|
}
|
}else{
|
noticeErpFail(c,Constants.ZERO,"人员信息同步安防平台失败，请修正后重试！");
|
c.setHkStatus(Constants.TWO);
|
c.setRemark("人员信息同步安防平台更新失败，请修正后重试！！"+(result!=null?result.getCode()+result.getMsg():""));
|
}
|
//重新下发权限数据
|
dealMemberRoleEmpower(c);
|
}
|
c.setHkDate(date);
|
memberMapper.updateById(c);
|
}
|
|
/**
|
* 新用户同步到海康平台
|
* @param c
|
* @param date
|
* @param path
|
* @return
|
*/
|
private boolean dealUserHkAddBiz(Member c, Date date, String path) {
|
if(Constants.equalsInteger(Constants.ONE,c.getIsdeleted())){
|
//删除的组织，不做处理,海康状态更新为不处理，下次不再处理这个记录
|
c.setHkStatus(Constants.TWO);
|
c.setRemark("未同步数据，直接删除");
|
c.setEditDate(date);
|
c.setErpId(c.getErpOrgId()+"_"+UUID.randomUUID().toString());
|
memberMapper.updateById(c);
|
return false;
|
}
|
UserAddRequest addHkModel = getUserAddModel(c,path,0);//新增
|
if(addHkModel == null){
|
//如果人脸数据不正确，下载失败等原因
|
noticeErpFail(c,Constants.ZERO,"人脸照片不存在，获取失败！");
|
c.setHkStatus(Constants.TWO);
|
c.setRemark("人脸照片不存在，获取失败！");
|
memberMapper.updateById(c);
|
return false;
|
}
|
//处理新增数据
|
BaseResponse<UserAddResponse> result = HKService.addUser(addHkModel);
|
if(result!=null && StringUtils.equals(result.getCode(),HKConstants.RESPONSE_SUCCEE) && result.getData()!=null){
|
c.setFaceId(result.getData().getFaceId());
|
c.setHkStatus(Constants.ONE);
|
c.setHkId(addHkModel.getPersonId());
|
memberMapper.updateById(c);
|
dealMemberRoleEmpower(c);
|
return true;
|
}else{
|
noticeErpFail(c,Constants.ZERO,"人员信息同步安防平台失败，请修正后重试！"+result.getCode()+result.getMsg());
|
c.setHkStatus(Constants.TWO);
|
c.setRemark("人员信息同步安防平台失败，请修正后重试！"+(result!=null?result.getMsg():""));
|
memberMapper.updateById(c);
|
return false;
|
}
|
}
|
|
/**
|
* 处理新增或者修改人脸信息
|
* @param c
|
* @param path
|
* @return
|
*/
|
private String dealMemberFace(Member c,String path) {
|
if(StringUtils.isBlank(c.getFaceId())){
|
BaseResponse<FaceAddOrEditesponse> response = HKService.addFace(getFaceAddModel(c,path));
|
if(response !=null && StringUtils.equals(response.getCode(),HKConstants.RESPONSE_SUCCEE)&& response.getData()!=null ){
|
return response.getData().getFaceId();
|
}
|
}else{
|
BaseResponse response = HKService.editFace(getFaceUpdateModel(c,path));
|
if(StringUtils.equals(response.getCode(),HKConstants.RESPONSE_SUCCEE) ){
|
return c.getFaceId();
|
}
|
}
|
return null;
|
}
|
|
/**
|
* 通知erp系统，人员下发同步信息状态失败
|
* @param c
|
* @param type
|
* @param s
|
*/
|
private void noticeErpFail(Member c, int type, String s) {
|
UserFailRequest r = new UserFailRequest();
|
r.setUserId(c.getErpId());
|
r.setInfo(s);
|
r.setType(type);
|
//通知ERP人脸数据不正确
|
erpSyncService.noticeUserFail(r);
|
}
|
|
/**
|
* 对海康删除组织信息
|
* @param id
|
* @param date
|
*/
|
private boolean doHkDeleteUser(Integer id,String delHkIds, Date date ) {
|
if(StringUtils.isBlank(delHkIds)){
|
return false;
|
}
|
UserDelRequest request = new UserDelRequest();
|
request.setPersonIds(new String[]{delHkIds});
|
BaseResponse<List<UserDelResponse>> result = HKService.delBatchUser(request);
|
if(result !=null && StringUtils.equals(result.getCode(),HKConstants.RESPONSE_SUCCEE)){
|
List<String> fIds = new ArrayList<>();
|
//标记删除成功的数据（海康对接状态为已同步，，同步失败的仍为待同步，等下一次继续处理，知道全部删除完毕）
|
if(result.getData()!=null && result.getData().size()>0){
|
log.info("海康删除用户失败：==============="+result.getData().get(0).getPersonId());
|
memberMapper.update(null,new UpdateWrapper<Member>().lambda()
|
.set(Member::getHkStatus,Constants.TWO)//同步失败
|
.set(Member::getHkDate,date)
|
.in(Member::getId, id));
|
}else{
|
//标记删除成功的数据（海康对接状态为已同步，，同步失败的仍为待同步，等下一次继续处理，知道全部删除完毕）
|
memberMapper.update(null,new UpdateWrapper<Member>().lambda()
|
.set(Member::getHkStatus,Constants.ONE)//同步成功
|
.set(Member::getHkDate,date)
|
.in(Member::getId, id));
|
}
|
return true;
|
}
|
return false;
|
}
|
|
/**
|
* 删除人员所有设备上的权限信息
|
* @param userId
|
* @param allDevice
|
*/
|
private void delUserHkRolle(String userId,List<Device> allDevice) {
|
//创建任务
|
String taskId = hkTaskAddtion();
|
//
|
if(taskId!=null){
|
//删除所有设备上的权限
|
addTaskDataAllDel(userId,taskId,allDevice);
|
startTask(taskId);
|
}
|
}
|
|
private UserAddRequest getUserAddModel(Member c,String path,int type) {
|
UserAddRequest model = new UserAddRequest();
|
model.setOrgIndexCode(c.getCompanyHkId());
|
model.setJobNo(c.getCode());
|
model.setCertificateNo(DESUtil.decrypt(Constants.EDS_PWD, c.getIdcardNo()));
|
model.setCertificateType(HKConstants.CertificateType.SHENFENZHENG.getKey()+"");
|
model.setPersonId(type == 0 ?UUID.randomUUID().toString().replace("-", ""):c.getHkId());
|
model.setGender(Constants.formatIntegerNum(c.getSex())+"");
|
model.setPersonName(c.getName());
|
if(type== 0 && StringUtils.isNotBlank(c.getFaceImg())){
|
model.setFaces(new ArrayList<>());
|
UserAddFaceRequest face = new UserAddFaceRequest();
|
String imageBase = ImageBase64Util.Image2Base64(path+c.getFaceImg());
|
if(imageBase== null){
|
//人脸数据不正确，
|
return null;
|
}
|
face.setFaceData(imageBase);
|
model.getFaces().add(face);
|
|
}
|
return model;
|
}
|
private FaceAddRequest getFaceAddModel(Member c,String path) {
|
FaceAddRequest model = new FaceAddRequest();
|
model.setPersonId(c.getHkId());
|
if(StringUtils.isNotBlank(c.getFaceImg())){
|
String imageBase = ImageBase64Util.Image2Base64(path+c.getFaceImg());
|
if(imageBase == null){
|
//人脸数据不正确，
|
return null;
|
}
|
model.setFaceData(imageBase);
|
}
|
return model;
|
}
|
private FaceEditRequest getFaceUpdateModel(Member c,String path) {
|
FaceEditRequest model = new FaceEditRequest();
|
model.setFaceId(c.getFaceId());
|
if(StringUtils.isNotBlank(c.getFaceImg())){
|
String imageBase = ImageBase64Util.Image2Base64(path+c.getFaceImg());
|
if(imageBase == null){
|
//人脸数据不正确，
|
return null;
|
}
|
model.setFaceData(imageBase);
|
}
|
return model;
|
}
|
|
}
|
