From b613b1c082f646e5de9a88ea3f072ad9c5cf898e Mon Sep 17 00:00:00 2001
From: k94314517 <8417338+k94314517@user.noreply.gitee.com>
Date: 星期四, 07 三月 2024 17:52:29 +0800
Subject: [PATCH] ERP接口

---
 server/dmvisit_service/src/main/java/com/doumee/service/business/impl/MemberServiceImpl.java |   80 +++++++++++++++++++++++++++++++++++-----
 1 files changed, 70 insertions(+), 10 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 7f39337..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());
@@ -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())
@@ -698,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
@@ -806,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)
@@ -851,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;
     }
@@ -1004,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