From 475b7d9a14d7ec6d2239fb77b8f039e7232c3d11 Mon Sep 17 00:00:00 2001 From: jiangping <jp@doumee.com> Date: 星期四, 21 十二月 2023 09:08:56 +0800 Subject: [PATCH] 海康接口对接开发 --- server/dmvisit_service/src/main/java/com/doumee/service/business/impl/MemberServiceImpl.java | 83 +++++++++++++++++++++++++++++++++-------- 1 files changed, 66 insertions(+), 17 deletions(-) diff --git a/server/dmvisit_service/src/main/java/com/doumee/service/business/impl/MemberServiceImpl.java b/server/dmvisit_service/src/main/java/com/doumee/service/business/impl/MemberServiceImpl.java index 9677c71..86b5e37 100644 --- a/server/dmvisit_service/src/main/java/com/doumee/service/business/impl/MemberServiceImpl.java +++ b/server/dmvisit_service/src/main/java/com/doumee/service/business/impl/MemberServiceImpl.java @@ -14,6 +14,7 @@ import com.doumee.core.annotation.excel.ExcelImporter; import com.doumee.core.constants.ResponseStatus; import com.doumee.core.exception.BusinessException; +import com.doumee.core.haikang.model.HKConstants; import com.doumee.core.model.LoginUserInfo; import com.doumee.core.model.PageData; import com.doumee.core.model.PageWrap; @@ -167,13 +168,35 @@ Member member=new Member(); ids.stream().forEach(s ->{ member.setId(s); - member.setIsdeleted(Constants.ZERO); + member.setIsdeleted(Constants.ONE); member.setEditor(loginUserInfo.getId()); member.setEditDate(new Date()); memberMapper.updateById(member); }); /* memberMapper.deleteBatchIds(ids);*/ } + + @Override + public void batchBlock(List<Integer> ids) { + if (CollectionUtils.isEmpty(ids)) { + return; + } + LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); + Member member=new Member(); + for (Integer id:ids) { + member = memberMapper.selectById(id); + if(!Objects.isNull(member)&&member.getStatus()==Constants.ZERO){ + member.setStatus(Constants.TWO); + member.setEditor(loginUserInfo.getId()); + member.setEditDate(new Date()); + memberMapper.updateById(member); + } + } + /* memberMapper.deleteBatchIds(ids);*/ + } + + + @Override public void updateById(Member member) { @@ -296,6 +319,24 @@ IPage<Member> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); QueryWrapper<Member> queryWrapper = new QueryWrapper<>(); Utils.MP.blankToNull(pageWrap.getModel()); + if (pageWrap.getModel().getKeyword() != null) { + queryWrapper.lambda().and( ms->ms.like(Member::getName,pageWrap.getModel().getKeyword()) + .or().like(Member::getPhone,pageWrap.getModel().getKeyword()) + .or().like(Member::getCode,pageWrap.getModel().getKeyword())); + } + if(pageWrap.getModel().getType() != null){ + if(pageWrap.getModel().getType().equals(Constants.memberType.visitor)){ + queryWrapper.select(" * , (select v.COMPANY_NAME from visits v where v.MEMBER_ID = member.id and v.STATUS = 2 order by v.CREATE_DATE desc limit 1 ) as companyName , " + + " (select v.STARTTIME from visits v where v.MEMBER_ID = member.id and v.STATUS = 2 order by v.CREATE_DATE desc limit 1 ) as lastVisitDate , " + + " (select count(1) from visits v where v.MEMBER_ID = member.id and v.STATUS = 2 ) as visitTimes "); + } + } + + if (pageWrap.getModel().getIsFace() != null) { + queryWrapper.lambda().isNull(pageWrap.getModel().getIsFace()==Constants.ZERO,Member::getFaceImg); + queryWrapper.lambda().isNotNull(pageWrap.getModel().getIsFace()==Constants.ONE,Member::getFaceImg); + } + if (pageWrap.getModel().getId() != null) { queryWrapper.lambda().eq(Member::getId, pageWrap.getModel().getId()); } @@ -463,7 +504,8 @@ @Override public long count(Member member) { - QueryWrapper<Member> wrapper = new QueryWrapper<>(member); + QueryWrapper<Member> wrapper = new QueryWrapper<Member>(member); + wrapper.lambda().like(StringUtils.isNotBlank(member.getRoleIdParam()), Member::getRoleId, member.getRoleIdParam()); return memberMapper.selectCount(wrapper); } @@ -524,27 +566,32 @@ if (!CollectionUtils.isEmpty(memberIPage.getRecords())){ memberIPage.getRecords().forEach(s->s.setSex(IdcardUtil.getGenderByIdCard(s.getIdcardDecode()))); }*/ - IPage<MemberInfoDTO> memberIPage = memberMapper.getPage(pageWrap.toPage(),new QueryWrapper<MemberInfoDTO>() - .in(Objects.nonNull(pageWrap.getModel().getCompanyIds())&&pageWrap.getModel().getCompanyIds().size()>0,"m.COMPANY_ID",pageWrap.getModel().getCompanyIds()) - .and(StringUtils.isNotBlank(pageWrap.getModel().getKeyWords()),ms->ms.like("m.ohone",pageWrap.getModel().getKeyWords()) - .or().like("m.name",pageWrap.getModel().getKeyWords()) - .or().like("m.code",pageWrap.getModel().getKeyWords())) - .isNull(Constants.equalsInteger(pageWrap.getModel().getHasFace(),Constants.ZERO),"m.FACE_ID") - .isNotNull(Constants.equalsInteger(pageWrap.getModel().getHasFace(),Constants.ONE),"m.FACE_ID") - .eq(Objects.nonNull(pageWrap.getModel().getCanVisit()),"m.CAN_VISIT",pageWrap.getModel().getCanVisit()) - .eq(Objects.nonNull(pageWrap.getModel().getStatus()),"m.CAN_VISIT",pageWrap.getModel().getStatus()) - .eq("m.ISDELETED",0) - .orderByDesc("m.CREATE_DATE") - ); + IPage<Member> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); + MPJLambdaWrapper<Member> queryWrapper = new MPJLambdaWrapper<>(); + queryWrapper.selectAll(Member.class); + queryWrapper.leftJoin(Company.class,Company::getId,Member::getCompanyId); + queryWrapper.in(Objects.nonNull(pageWrap.getModel().getCompanyIds())&&pageWrap.getModel().getCompanyIds().size()>0, + Member::getCompanyId,pageWrap.getModel().getCompanyIds()) + .and(StringUtils.isNotBlank(pageWrap.getModel().getKeyWords()),ms->ms.like(Member::getPhone,pageWrap.getModel().getKeyWords()) + .or().like(Member::getName,pageWrap.getModel().getKeyWords()) + .or().like(Member::getCode,pageWrap.getModel().getKeyWords())) + .isNull(Constants.equalsInteger(pageWrap.getModel().getHasFace(),Constants.ZERO),Member::getFaceId) + .isNotNull(Constants.equalsInteger(pageWrap.getModel().getHasFace(),Constants.ONE),Member::getFaceId) + .eq(Objects.nonNull(pageWrap.getModel().getCanVisit()),Member::getCanVisit,pageWrap.getModel().getCanVisit()) + .eq(Objects.nonNull(pageWrap.getModel().getStatus()),Member::getCanVisit,pageWrap.getModel().getStatus()) + .eq(Member::getIsdeleted,Constants.ZERO) + .eq(Member::getStatus,Constants.Status.ENABLE.getValue()) + .eq(Member::getType,Constants.memberType.internal) + .orderByDesc(Member::getCreateDate); + + IPage<MemberInfoDTO> memberIPage = memberJoinMapper.selectJoinPage(page, MemberInfoDTO.class,queryWrapper); return PageData.from(memberIPage); } @Override public PageData<MemberInfoDTO> findVisitPage(PageWrap<MemberQuery> pageWrap) { - - IPage<Member> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); MPJLambdaWrapper<Member> queryWrapper = new MPJLambdaWrapper<>(); queryWrapper.leftJoin(Company.class,Company::getId,Member::getCompanyId); @@ -557,7 +604,9 @@ .like(StringUtils.isNotBlank(pageWrap.getModel().getPhone()),Member::getPhone,pageWrap.getModel().getPhone()) .like(StringUtils.isNotBlank(pageWrap.getModel().getCompanyName()),Company::getName,pageWrap.getModel().getCompanyName()) .like(StringUtils.isNotBlank(pageWrap.getModel().getIdcardNo()),Member::getIdcardNo,pageWrap.getModel().getIdcardNo()) - .eq(Member::getStatus,Constants.Status.FREEZE) + .eq(Member::getStatus,Constants.Status.ENABLE.getValue()) + .eq(Member::getType,Constants.memberType.visitor) + .eq(Member::getIsdeleted,Constants.ZERO) .orderByDesc(Member::getCreateDate); -- Gitblit v1.9.3