| | |
| | | }else{ |
| | | throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"对不起,员工信息同步安防平台失败,请稍后重试!"); |
| | | } |
| | | }catch (BusinessException e){ |
| | | //如果发生异常,删除已经创建的人员信息 |
| | | deleteHkUserBiz(new String[]{insert.getHkId()}); |
| | | throw e; |
| | | }catch (Exception e){ |
| | | //如果发生异常,删除已经创建的人员信息 |
| | | e.printStackTrace(); |
| | |
| | | * @return |
| | | */ |
| | | private boolean dealHkUserBiz(Member insert) { |
| | | String path = systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_RESOURCE_PATH).getCode() |
| | | String path = systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_LOCAL_RESOURCE_PATH).getCode() |
| | | +systemDictDataBiz.queryByCode(Constants.FTP,Constants.MEMBER_IMG).getCode(); |
| | | UserAddRequest hkAddRequest = HkSyncOrgUserToHKServiceImpl.getUserAddModel(insert,path,Constants.ZERO); |
| | | if(hkAddRequest == null){ |
| | |
| | | return false; |
| | | } |
| | | private boolean dealHkUserForUpdateBiz(Member update ) { |
| | | String path = systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_RESOURCE_PATH).getCode() |
| | | String path = systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_LOCAL_RESOURCE_PATH).getCode() |
| | | +systemDictDataBiz.queryByCode(Constants.FTP,Constants.MEMBER_IMG).getCode(); |
| | | |
| | | UserAddRequest hkAddRequest = HkSyncOrgUserToHKServiceImpl.getUserAddModel(update,path,Constants.ONE); |
| | |
| | | .ne(Member::getId,member.getId())) >0){ |
| | | throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(), "身份证号【"+member.getIdcardNoNew()+"】已被使用,不能重复"); |
| | | } |
| | | |
| | | member.setSex(Constants.getSexByCardNo( member.getIdcardNoNew()));//根据身份证号获取性别 |
| | | member.setIdcardDecode( Constants.getTuominStr(member.getIdcardNoNew())); |
| | | member.setIdcardNo(encrptNo); |
| | |
| | | wrapper.lambda().ne(Member::getRemark,"人脸已同步最新"); |
| | | List<Member> list =memberMapper.selectList(wrapper); |
| | | if(list!=null){ |
| | | String path = systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_RESOURCE_PATH).getCode() |
| | | String path = systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_LOCAL_RESOURCE_PATH).getCode() |
| | | +systemDictDataBiz.queryByCode(Constants.FTP,Constants.MEMBER_IMG).getCode(); |
| | | for(Member m : list){ |
| | | String faceId= HkSyncOrgUserToHKServiceImpl.dealMemberFace(m,path); |
| | |
| | | .replace("APPID", appId).replace("SECRET", appSecret); |
| | | JSONObject tokenJson = JSONObject.parseObject(HttpsUtil.get(getTokenUrl,true)); |
| | | String openId = ""; |
| | | if(!Objects.isNull(tokenJson.get("access_token"))){ |
| | | if(Objects.nonNull(tokenJson)&&!Objects.isNull(tokenJson.get("access_token"))){ |
| | | openId = tokenJson.getString("openid"); |
| | | } |
| | | WxAuthorizeVO wxAuthorizeVO = new WxAuthorizeVO(); |
| | | wxAuthorizeVO.setOpenid(openId); |
| | | if(StringUtils.isBlank(openId)){ |
| | | return wxAuthorizeVO; |
| | | } |
| | | wxAuthorizeVO.setOpenid(openId); |
| | | if(source==1){ |
| | | //根据openId 查询用户信息 |
| | | Member member = memberJoinMapper.selectJoinOne(Member.class,new MPJLambdaWrapper<Member>() |