From b6af77669bb4d4fa8c96cfb70dcaf97a607dbfe5 Mon Sep 17 00:00:00 2001 From: k94314517 <8417338+k94314517@user.noreply.gitee.com> Date: 星期五, 08 三月 2024 13:48:53 +0800 Subject: [PATCH] ERP接口 --- server/dmvisit_service/src/main/java/com/doumee/service/business/impl/MemberServiceImpl.java | 93 ++++++++++++++++++++++++++++++++++++++-------- 1 files changed, 77 insertions(+), 16 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 3f7130e..4587aa1 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 @@ -179,6 +179,24 @@ memberMapper.updateById(member); } + + @Override + public void roleAuthById(Integer id) { + LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); + Member member = memberMapper.selectById(id); + if(member.getIsdeleted().equals(Constants.ONE)){ + throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鍛樺伐淇℃伅宸插垹闄�"); + } + if(!member.getType().equals(Constants.memberType.internal)){ + throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"闈炲唴閮ㄤ汉鍛樻棤娉曡繘琛岃鎿嶄綔"); + } + memberRoleMapper.selectList(new QueryWrapper<MemberRole>().lambda().eq(MemberRole::getMemberId,member.getId())); + + + + } + + @Override public void delete(Member member) { UpdateWrapper<Member> deleteWrapper = new UpdateWrapper<>(member); @@ -198,7 +216,22 @@ member.setEditor(loginUserInfo.getId()); member.setEditDate(new Date()); memberMapper.updateById(member); + + UserAction userAction=new UserAction(); + userAction.setIsdeleted(Constants.ZERO); + userAction.setCreateDate(new Date()); + userAction.setCreator(loginUserInfo.getId()); + userAction.setType(9); + userAction.setRemark("鐢便��"+loginUserInfo.getUsername()+"銆戜簬銆愭搷浣滄椂闂�"+DateUtil.format(new Date(),"yyyy-MM-dd HH:mm:ss")+"銆戯紝杩涜銆愬垹闄ゃ��"); + userAction.setMemberId(s+""); + userActionJoinMapper.insert(userAction); + }); + + + + + /* memberMapper.deleteBatchIds(ids);*/ } @@ -213,7 +246,7 @@ member = memberMapper.selectById(id); if(!Objects.isNull(member)&&member.getStatus()==Constants.ZERO){ UserAction userAction=new UserAction(); - userAction.setBeforeStatus(member.getStatus()); +// userAction.setBeforeStatus(member.getStatus()); member.setStatus(Constants.TWO); member.setEditor(loginUserInfo.getId()); member.setEditDate(new Date()); @@ -224,11 +257,11 @@ userAction.setCreator(loginUserInfo.getId()); if(Constants.equalsInteger(type,Constants.ONE)){ userAction.setType(Constants.ONE); - userAction.setRemark("鐢便��"+loginUserInfo.getUsername()+"銆戜簬銆愭搷浣滄椂闂�"+new Date()+"銆戯紝杩涜銆愬喕缁撱��"); + userAction.setRemark("鐢便��"+loginUserInfo.getUsername()+"銆戜簬銆愭搷浣滄椂闂�"+DateUtil.format(new Date(),"yyyy-MM-dd HH:mm:ss")+"銆戯紝杩涜銆愬喕缁撱��"); } if(Constants.equalsInteger(type,Constants.TWO)){ userAction.setType(Constants.TWO); - userAction.setRemark("鐢便��"+loginUserInfo.getUsername()+"銆戜簬銆愭搷浣滄椂闂�"+new Date()+"銆戯紝杩涜銆愭媺榛戙��"); + userAction.setRemark("鐢便��"+loginUserInfo.getUsername()+"銆戜簬銆愭搷浣滄椂闂�"+DateUtil.format(new Date(),"yyyy-MM-dd HH:mm:ss")+"銆戯紝杩涜銆愭媺榛戙��"); } userAction.setMemberId(id+""); @@ -276,11 +309,11 @@ userAction.setCreator(loginUserInfo.getId()); if(Constants.equalsInteger(result.getType(),Constants.TWO)){ userAction.setType(Constants.ONE); - userAction.setRemark("鐢便��"+loginUserInfo.getUsername()+"銆戜簬銆愭搷浣滄椂闂�"+new Date()+"銆戯紝杩涜銆愬喕缁撱��"); + userAction.setRemark("鐢便��"+loginUserInfo.getUsername()+"銆戜簬銆愭搷浣滄椂闂�"+DateUtil.format(new Date(),"yyyy-MM-dd HH:mm:ss")+"銆戯紝杩涜銆愬喕缁撱��"); } if(Constants.equalsInteger(result.getType(),Constants.ZERO)){ userAction.setType(Constants.TWO); - userAction.setRemark("鐢便��"+loginUserInfo.getUsername()+"銆戜簬銆愭搷浣滄椂闂�"+new Date()+"銆戯紝杩涜銆愭媺榛戙��"); + userAction.setRemark("鐢便��"+loginUserInfo.getUsername()+"銆戜簬銆愭搷浣滄椂闂�"+DateUtil.format(new Date(),"yyyy-MM-dd HH:mm:ss")+"銆戯紝杩涜銆愭媺榛戙��"); } userAction.setMemberId(result.getId()+""); @@ -313,12 +346,13 @@ userAction.setCreator(loginUserInfo.getId()); if(Constants.equalsInteger(result.getType(),Constants.TWO)){ userAction.setType(Constants.ZERO); + userAction.setBeforeStatus(Constants.ONE); } - if(Constants.equalsInteger(result.getType(),Constants.ZERO)){ - userAction.setType(Constants.THREE); + if(Constants.equalsInteger(result.getType(),Constants.ONE)){ + userAction.setBeforeStatus(status); + userAction.setType(Constants.TWO); } userAction.setMemberId(result.getId()+""); - userAction.setBeforeStatus(status); userActionJoinMapper.insert(userAction); }); } @@ -587,6 +621,7 @@ queryWrapper.selectAll(Member.class); queryWrapper.selectAs(Company::getName,Member::getCompanyName); + queryWrapper.select(" ( select count(1) from member_card mc where mc.isdeleted = 0 and mc.member_id = t.id ) as memberCardCount "); 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()) @@ -598,6 +633,7 @@ .isNotNull(!Objects.isNull(pageWrap.getModel().getHasFace())&&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::getStatus,pageWrap.getModel().getStatus()) + .eq(Objects.nonNull(pageWrap.getModel().getHkStatus()),Member::getHkStatus,pageWrap.getModel().getHkStatus()) .eq(Member::getIsdeleted,Constants.ZERO) // .eq(Member::getStatus,Constants.Status.ENABLE.getValue()) .eq(Member::getType,Constants.memberType.internal) @@ -672,8 +708,8 @@ .and(StringUtils.isNotBlank(pageWrap.getModel().getCompanyName()), ms->ms.like(Member::getVisitCompanyName,pageWrap.getModel().getCompanyName()) .or().like(Company::getName,pageWrap.getModel().getCompanyName())) .like(StringUtils.isNotBlank(pageWrap.getModel().getIdcardNo()),Member::getIdcardNo,pageWrap.getModel().getIdcardNo()) - .eq(Objects.isNull(pageWrap.getModel().getStatus()),Member::getStatus,Constants.Status.ENABLE.getValue()) - .eq(!Objects.isNull(pageWrap.getModel().getStatus()),Member::getStatus,pageWrap.getModel().getStatus()) + .eq(Objects.nonNull(pageWrap.getModel().getHkStatus()),Member::getHkStatus,pageWrap.getModel().getHkStatus()) + .eq(Objects.nonNull(pageWrap.getModel().getStatus()),Member::getStatus,pageWrap.getModel().getStatus()) .eq(Member::getType,Constants.memberType.visitor) .eq(Member::getIsdeleted,Constants.ZERO) .orderByDesc(Member::getCreateDate); @@ -697,8 +733,8 @@ .selectAs(Company::getName,MemberInfoDTO::getCompanyName) .select(" (select ua.CREATE_DATE from user_action ua where ua.MEMBER_ID=t.id and ua.ISDELETED=0 order by ua.CREATE_DATE desc limit 1) as optTime") .select(" (select s.REALNAME from user_action uac left join system_user s on uac.CREATOR = s.ID where uac.MEMBER_ID=t.id and uac.ISDELETED=0 order by uac.CREATE_DATE desc limit 1) as creatorName") - .select(" (select STARTTIME from visits v where v.MEMBER_ID=t.id and v.ISDELETED=0 order by CREATE_DATE desc limit 1) as visitsLastDate"); - + .select(" (select STARTTIME from visits v where v.MEMBER_ID=t.id and v.ISDELETED=0 order by CREATE_DATE desc limit 1) as visitsLastDate") + .eq(Member::getIsdeleted,Constants.ZERO); queryWrapper.eq(Objects.nonNull(pageWrap.getModel().getCreaterId()),Member::getEditor,pageWrap.getModel().getCreaterId()); queryWrapper.eq(Objects.nonNull(pageWrap.getModel().getType()),Member::getType,pageWrap.getModel().getType()); queryWrapper @@ -805,6 +841,17 @@ } List<Integer> memberIds = memberList.stream().map(m->m.getId()).collect(Collectors.toList()); + for (Integer id:memberIds) { + UserAction userAction=new UserAction(); + userAction.setIsdeleted(Constants.ZERO); + userAction.setCreateDate(new Date()); + userAction.setType(1); + userAction.setRemark("鐢卞畾鏃朵换鍔′簬銆愭搷浣滄椂闂�"+DateUtil.format(new Date(),"yyyy-MM-dd HH:mm:ss")+"銆戯紝杩涜銆愬喕缁撱��"); + userAction.setMemberId(id+""); + userActionJoinMapper.insert(userAction); + } + + //鍐荤粨鐘舵�� memberMapper.update(null,new UpdateWrapper<Member>() .lambda().set(Member::getStatus,Constants.TWO) @@ -850,24 +897,35 @@ WxAuthorizeVO wxAuthorizeVO = new WxAuthorizeVO(); wxAuthorizeVO.setOpenid(openId); //鏍规嵁openId 鏌ヨ鐢ㄦ埛淇℃伅 - Member member = memberMapper.selectOne(new QueryWrapper<Member>().lambda() + Member member = memberJoinMapper.selectJoinOne(Member.class,new MPJLambdaWrapper<Member>() + .selectAll(Member.class) + .selectAs(Company::getName,Member::getCompanyName) + .leftJoin(Company.class,Company::getId,Member::getCompanyId) .eq(Member::getOpenid,openId) .eq(Member::getIsdeleted,Constants.ZERO) - .ne(Member::getType,Constants.memberType.visitor) + .orderByDesc(Member::getCreateDate) + .last(" limit 1 ") ); //闈炶瀹㈢敤鎴� 杩涜鍒ゆ柇鏄惁瀛樺湪鐢ㄦ埛 - if(!Objects.isNull(member)&&!member.getType().equals(Constants.memberType.visitor)){ + if(!Objects.isNull(member)){ if(member.getIsdeleted() == Constants.ONE){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鐢ㄦ埛宸插垹闄�,璇疯仈绯荤鐞嗗憳"); } if(member.getStatus() != Constants.ZERO){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鐢ㄦ埛宸茬鐢�,璇疯仈绯荤鐞嗗憳"); } + if(StringUtils.isNotBlank(member.getIdcardNo())){ + member.setIdcardDecode(DESUtil.decrypt(Constants.EDS_PWD, member.getIdcardNo())); + } + String prefixUrl = systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_RESOURCE_PATH).getCode() + + systemDictDataBiz.queryByCode(Constants.FTP,Constants.MEMBER_IMG).getCode(); + member.setPrefixUrl(prefixUrl); JwtPayLoad payLoad = new JwtPayLoad(Integer.toString(member.getId())); String token = JwtTokenUtil.generateToken(payLoad); //瀛樺偍token鑷硆edis RedisUtil.addObject(redisTemplate,Constants.RedisKeys.INTERNAL_TOKEN+"_"+member.getId(),token,Constants.RedisKeys.EXPIRE_TIME); wxAuthorizeVO.setToken(token); + wxAuthorizeVO.setMember(member); } return wxAuthorizeVO; } @@ -1003,7 +1061,10 @@ .exists(" select 1 from park_book p where p.origin = 0 and p.car_code = retention.car_no and p.ISDELETED = 0 ") )); stagingHeadVO.setVisitorCarCount(stagingHeadVO.getPresenceCarCount() - stagingHeadVO.getLongCarCount()); - stagingHeadVO.setSupplierCount(companyMapper.selectCount(new QueryWrapper<Company>().lambda().eq(Company::getIsdeleted,Constants.ZERO))); + stagingHeadVO.setSupplierCount(companyMapper.selectCount(new QueryWrapper<Company>().lambda() + .eq(Company::getIsdeleted,Constants.ZERO) + .eq(Company::getType,Constants.ZERO) + )); return stagingHeadVO; } -- Gitblit v1.9.3