aaa
nidapeng
2024-03-17 864918cd96b6eec16598dc00a71a3372367545a1
server/dmvisit_service/src/main/java/com/doumee/service/business/impl/hksync/ferp/HkSyncOrgUserToHKServiceImpl.java
@@ -49,6 +49,8 @@
    @Autowired
    private EmpowerMapper empowerMapper;
    @Autowired
    private ParkBookMapper bookMapper;
    @Autowired
    private MemberCardMapper memberCardMapper;
    @Autowired
    private MemberJoinMapper memberMapper;
@@ -209,7 +211,6 @@
        model.setOrgIndexCode(c.getHkId());
        model.setOrgName(c.getName());
        return  model;
    }
    /**
@@ -228,7 +229,7 @@
            List<String> fIds = new ArrayList<>();
            if(result.getData()!=null){
                for(OrgUpdateFailureResponse r : result.getData()){
                    if(!r.getCode().equals("0x00052102")){
                    if(r.getCode().equals("0x00052102")){
                        //不存在的也算删除成功
                        fIds.add(r.getOrgIndexCode());//删除失败的数据集合
                    }
@@ -269,6 +270,7 @@
                    .eq(Member::getHkStatus,Constants.ZERO)
                    .eq(Member::getStatus,Constants.ZERO)
                    .eq(Member::getType,Constants.memberType.internal)
                    .notExists("select d.id from empower d where d.member_id=t.id and d.send_status in (1,5)")//排除有正在同步下发任务的数据
                    .orderByAsc(Member::getErpDate));
            if(list ==null || list.size()==0){
                return;
@@ -332,9 +334,16 @@
    }
    private int dealDelMemberRoleEmpower(Member member ) {
        //待移除权限的设备数据授权记录(针对删除和更新丢失的权限,需要同步下发删除权限)
            bookMapper.update(null,new UpdateWrapper<ParkBook>().lambda()
                .eq(ParkBook::getMemberId,member.getId())
                .set(ParkBook::getRemark,"等待同步删除安防平台")
                .set(ParkBook::getIsdeleted,Constants.ONE)
                .eq(ParkBook::getIsdeleted,Constants.ZERO)
                .set(ParkBook::getHkStatus,Constants.ZERO));
            return  empowerMapper.update(null,new UpdateWrapper<Empower>().lambda()
                        .eq(Empower::getMemberId,member.getId())
                        .set(Empower::getIsdeleted,Constants.ONE)
                        .set(Empower::getRemark,"等待同步删除安防平台")
                        .eq(Empower::getIsdeleted,Constants.ZERO)
                        .set(Empower::getSendStatus,Constants.ZERO));
    }
@@ -350,6 +359,12 @@
        }
        List<Integer> doorIds = getRoleIdByParam(member,deviceRoleMapper);
        if(doorIds==null || doorIds.size() == 0){
            //如果权限清空,则清空人员授权的权限数据
            empowerMapper.update(null,new UpdateWrapper<Empower>().lambda()
                    .eq(Empower::getMemberId,member.getId())
                    .set(Empower::getIsdeleted,Constants.ONE)
                    .eq(Empower::getIsdeleted,Constants.ZERO)
                    .set(Empower::getSendStatus,Constants.ZERO));
            return;
        }
        if(StringUtils.isBlank(member.getFaceImg())){