From ad6dfb8323ab40ca8fe4fed94722c755d89c3203 Mon Sep 17 00:00:00 2001
From: jiangping <jp@doumee.com>
Date: 星期三, 28 二月 2024 15:14:47 +0800
Subject: [PATCH] 整理

---
 server/dmvisit_service/src/main/java/com/doumee/service/business/impl/MemberServiceImpl.java |  661 +++++++++++++++++++++++++++++++++++++++++++++++++-----
 1 files changed, 590 insertions(+), 71 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 0de6db9..7f39337 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
@@ -2,13 +2,11 @@
 
 import cn.hutool.core.date.DateTime;
 import cn.hutool.core.date.DateUtil;
-import cn.hutool.core.lang.PatternPool;
-import cn.hutool.core.lang.Validator;
 import cn.hutool.core.util.IdcardUtil;
 import cn.hutool.core.util.PhoneUtil;
-import cn.hutool.core.util.ReUtil;
 import com.alibaba.fastjson.JSONObject;
 import com.doumee.biz.system.SystemDictDataBiz;
+import com.doumee.config.DataSyncConfig;
 import com.doumee.config.Jwt.JwtPayLoad;
 import com.doumee.config.Jwt.JwtTokenUtil;
 import com.doumee.core.annotation.excel.ExcelImporter;
@@ -18,19 +16,25 @@
 import com.doumee.core.model.PageData;
 import com.doumee.core.model.PageWrap;
 import com.doumee.core.utils.Constants;
+import com.doumee.core.utils.DESUtil;
 import com.doumee.core.utils.HttpsUtil;
 import com.doumee.core.utils.Utils;
+import com.doumee.core.utils.redis.RedisUtil;
 import com.doumee.core.wx.WXConstant;
 import com.doumee.dao.admin.request.LaborEmpowerDTO;
 import com.doumee.dao.admin.request.LaborMemberDTO;
 import com.doumee.dao.admin.request.MemberQuery;
 import com.doumee.dao.admin.response.MemberInfoDTO;
-import com.doumee.dao.business.MemberMapper;
-import com.doumee.dao.business.TrainTimeMapper;
+import com.doumee.dao.admin.response.StagingDataVO;
+import com.doumee.dao.business.*;
 import com.doumee.dao.business.join.MemberJoinMapper;
+import com.doumee.dao.business.join.RetentionJoinMapper;
+import com.doumee.dao.business.join.UserActionJoinMapper;
 import com.doumee.dao.business.model.*;
-import com.doumee.dao.system.model.SystemUser;
+import com.doumee.dao.system.model.SystemDictData;
+import com.doumee.dao.web.reqeust.AccountLoginDTO;
 import com.doumee.dao.web.reqeust.CheckVisitedDTO;
+import com.doumee.dao.web.reqeust.VisitMemberDTO;
 import com.doumee.dao.web.response.MemberVO;
 import com.doumee.dao.web.response.WxAuthorizeVO;
 import com.doumee.service.business.MemberService;
@@ -44,11 +48,12 @@
 import org.apache.shiro.SecurityUtils;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
-import java.util.Date;
-import java.util.List;
-import java.util.Objects;
+
+import java.util.*;
+import java.util.stream.Collectors;
 
 /**
  * 浜哄憳淇℃伅琛⊿ervice瀹炵幇
@@ -67,9 +72,37 @@
     @Autowired
     private TrainTimeMapper trainTimeMapper;
 
+    @Autowired
+    private MemberRoleMapper memberRoleMapper;
+
+    @Autowired
+    private DeviceRoleMapper deviceRoleMapper;
+
+    @Autowired
+    private EmpowerMapper empowerMapper;
+
+    @Autowired
+    private DeviceMapper deviceMapper;
 
     @Autowired
     private SystemDictDataBiz systemDictDataBiz;
+    @Autowired
+    private UserActionJoinMapper userActionJoinMapper;
+
+    @Autowired
+    private CompanyMapper companyMapper;
+
+    @Autowired
+    private RedisTemplate<String, Object> redisTemplate;
+    @Autowired
+    private DataSyncConfig dataSyncConfig;
+
+    @Autowired
+    private RetentionJoinMapper retentionJoinMapper;
+
+    @Autowired
+    private VisitsMapper visitsMapper;
+
 
     @Override
     public Integer create(Member member) {
@@ -119,7 +152,7 @@
         insert.setParentId(member.getParentId());
         memberMapper.insert(insert);
 
-        TrainTime trainTime = new TrainTime();
+    /*    TrainTime trainTime = new TrainTime();
         trainTime.setCreator(loginUserInfo.getId().toString());
         trainTime.setCreateDate(new Date());
         trainTime.setEdirot(loginUserInfo.getId().toString());
@@ -130,13 +163,20 @@
         trainTime.setEndTime(Utils.Date.getDayEnd(member.getEndTime()));
 //        trainTime.setImportStatus();
 //        trainTime.setImportInfo();
-        trainTimeMapper.insert(trainTime);
+        trainTimeMapper.insert(trainTime);*/
         return insert.getId();
     }
 
     @Override
     public void deleteById(Integer id) {
-        memberMapper.deleteById(id);
+        LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
+
+        Member member=new Member();
+        member.setId(id);
+        member.setIsdeleted(Constants.ZERO);
+        member.setEditor(loginUserInfo.getId());
+        member.setEditDate(new Date());
+        memberMapper.updateById(member);
     }
 
     @Override
@@ -150,8 +190,57 @@
         if (CollectionUtils.isEmpty(ids)) {
             return;
         }
-        memberMapper.deleteBatchIds(ids);
+        LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
+        Member member=new Member();
+        ids.stream().forEach(s ->{
+            member.setId(s);
+            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,Integer type) {
+        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){
+                UserAction userAction=new UserAction();
+                userAction.setBeforeStatus(member.getStatus());
+                member.setStatus(Constants.TWO);
+                member.setEditor(loginUserInfo.getId());
+                member.setEditDate(new Date());
+                memberMapper.updateById(member);
+
+                userAction.setIsdeleted(Constants.ZERO);
+                userAction.setCreateDate(new Date());
+                userAction.setCreator(loginUserInfo.getId());
+                if(Constants.equalsInteger(type,Constants.ONE)){
+                    userAction.setType(Constants.ONE);
+                    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()+"銆戜簬銆愭搷浣滄椂闂�"+DateUtil.format(new Date(),"yyyy-MM-dd HH:mm:ss")+"銆戯紝杩涜銆愭媺榛戙��");
+
+                }
+                userAction.setMemberId(id+"");
+
+                userActionJoinMapper.insert(userAction);
+            }
+        }
+        /*  memberMapper.deleteBatchIds(ids);*/
+    }
+
+
+
 
     @Override
     public void updateById(Member member) {
@@ -167,6 +256,74 @@
         update.setStatus(member.getStatus());
         memberMapper.updateById(update);
     }
+
+
+    @Override
+    public void updateVisitsStatusById(Member member) {
+        LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
+        Member result=memberMapper.selectById(member.getId());
+        Integer status=result.getStatus();
+        Member update = new Member();
+        update.setEditDate(new Date());
+        update.setEditor(loginUserInfo.getId());
+        update.setStatus(Constants.Status.FREEZE.getValue());
+        update.setId(member.getId());
+        memberMapper.updateById(update);
+
+        UserAction userAction=new UserAction();
+        userAction.setIsdeleted(Constants.ZERO);
+        userAction.setCreateDate(new Date());
+        userAction.setCreator(loginUserInfo.getId());
+        if(Constants.equalsInteger(result.getType(),Constants.TWO)){
+            userAction.setType(Constants.ONE);
+            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()+"銆戜簬銆愭搷浣滄椂闂�"+DateUtil.format(new Date(),"yyyy-MM-dd HH:mm:ss")+"銆戯紝杩涜銆愭媺榛戙��");
+
+        }
+        userAction.setMemberId(result.getId()+"");
+        userAction.setBeforeStatus(status);
+        userActionJoinMapper.insert(userAction);
+    }
+
+
+    @Override
+    public void updateRemoveStatusById(List<Member> members) {
+        LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
+
+        Date date=new Date();
+        members.stream().forEach(s ->{
+            Member result=memberMapper.selectById(s.getId());
+            Integer status=result.getStatus();
+            Member update = new Member();
+            update.setEditDate(date);
+            update.setEditor(loginUserInfo.getId());
+            update.setStatus(Constants.Status.ENABLE.getValue());
+            update.setId(s.getId());
+            memberMapper.updateById(update);
+
+            //瑙e喕涓氬姟 澶勭悊鐢ㄦ埛鎺堟潈瀵煎叆璁板綍
+            this.thawMember(result);
+
+            UserAction userAction=new UserAction();
+            userAction.setIsdeleted(Constants.ZERO);
+            userAction.setCreateDate(new Date());
+            userAction.setCreator(loginUserInfo.getId());
+            if(Constants.equalsInteger(result.getType(),Constants.TWO)){
+                userAction.setType(Constants.ZERO);
+            }
+            if(Constants.equalsInteger(result.getType(),Constants.ZERO)){
+                userAction.setType(Constants.THREE);
+            }
+            userAction.setMemberId(result.getId()+"");
+            userAction.setBeforeStatus(status);
+            userActionJoinMapper.insert(userAction);
+        });
+    }
+
+
 
 
     @Override
@@ -203,6 +360,10 @@
     @Override
     public List<Member> findList(Member member) {
         QueryWrapper<Member> wrapper = new QueryWrapper<>(member);
+        if(null != member.getType()) {
+            wrapper.lambda().eq(Member::getType,member.getType());
+        }
+        wrapper.lambda().eq(Member::getIsdeleted,Constants.ZERO);
         return memberMapper.selectList(wrapper);
     }
 
@@ -212,6 +373,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());
         }
@@ -353,22 +532,23 @@
         MPJLambdaWrapper<Member> queryWrapper = new MPJLambdaWrapper<>();
         MemberInfoDTO model = pageWrap.getModel();
         Utils.MP.blankToNull(model);
-        Date end = Utils.Date.getEnd(pageWrap.getModel().getTrainTimeEndTime());
-        queryWrapper.leftJoin(Company.class,Company::getId,Member::getCompanyId)
-                .leftJoin(TrainTime.class,TrainTime::getMemberId,Member::getId)
-                .leftJoin(Empower.class,Empower::getMemberId,Member::getId);
+        Date end =pageWrap.getModel().getTrainTimeEndTime() !=null? Utils.Date.getEnd(pageWrap.getModel().getTrainTimeEndTime()):new Date();
+        queryWrapper.leftJoin(Company.class,Company::getId,Member::getCompanyId);
+              /*  .leftJoin(TrainTime.class,TrainTime::getMemberId,Member::getId)
+                .leftJoin(Empower.class,Empower::getMemberId,Member::getId);*/
 
         queryWrapper.selectAll(Member.class)
                     .selectAs(Company::getName,MemberInfoDTO::getCompanyName)
                     .selectAs(Company::getLinkName,MemberInfoDTO::getLinkName)
-                    .select("Max(t1.endTime)","trainTimeEndTime")
-                    .select("Max(t2.endTime)","empowerEndTime");
+                /*.select(" (select Max(tt.END_TIME) from train_time tt where tt.ISDELETED=0 and tt.MEMBER_ID=t.id) as trainTimeEndTime")*/
+                .select(" (select Max(e.END_TIME) from empower e where e.ISDELETED=0 and e.MEMBER_ID=t.id) as empowerEndTime");
 
+        queryWrapper.eq(Member::getType,Constants.ZERO);
         queryWrapper.eq(Objects.nonNull(model.getCompanyId()),Member::getCompanyId,model.getCompanyId())
                     .like(StringUtils.isNotBlank(model.getName()),Member::getName,model.getName())
                     .like(StringUtils.isNotBlank(model.getPhone()),Member::getPhone,model.getPhone())
                     .like(StringUtils.isNotBlank(model.getIdcardDecode()),Member::getIdcardDecode,model.getIdcardDecode())
-                    .having("trainTimeEndTime < "+ DateUtil.format(end,"yyyy-MM-dd HH:mm:ss"));
+                    .having(pageWrap.getModel().getTrainTimeEndTime()!=null,"trainTimeEndTime < "+ DateUtil.format(end,"yyyy-MM-dd HH:mm:ss"));
         IPage<MemberInfoDTO> memberIPage = memberJoinMapper.selectJoinPage(page, MemberInfoDTO.class,queryWrapper);
         if (!CollectionUtils.isEmpty(memberIPage.getRecords())){
             memberIPage.getRecords().forEach(s->s.setSex(IdcardUtil.getGenderByIdCard(s.getIdcardDecode())));
@@ -378,7 +558,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);
     }
 
@@ -396,67 +577,259 @@
         } catch (Exception e) {
 
         }
-//
 
     }
 
     @Override
     public PageData<MemberInfoDTO> findMemberInfoPage(PageWrap<MemberQuery> pageWrap) {
-  /*      //鏄惁鏄暟瀛�
-        boolean number = Validator.isNumber(pageWrap.getModel().getKeyWords());
-        //鏄惁鍖呭惈涓枃
-        boolean b = Validator.hasChinese(pageWrap.getModel().getKeyWords());
-        //鏄惁鍖呭惈鑻辨枃
-        boolean hasWord = ReUtil.contains(PatternPool.WORD, pageWrap.getModel().getKeyWords());*/
-
-      /*  IPage<Member> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
+        IPage<Member> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
         MPJLambdaWrapper<Member> queryWrapper = new MPJLambdaWrapper<>();
-        MemberQuery model = pageWrap.getModel();
-        Utils.MP.blankToNull(model);
 
-        queryWrapper.leftJoin(Company.class,Company::getId,Member::getCompanyId)
-                .leftJoin(DeviceRole.class,DeviceRole::getId,Member::getRoleId);
-              *//*  .leftJoin(MemberCard.class,MemberCard::getMemberId,Member::getId);*//*
-
-        queryWrapper.selectAll(Member.class)
-                .selectAs(Company::getName,MemberInfoDTO::getCompanyName)
-                .selectAs(DeviceRole::getName,MemberInfoDTO::getRoleName)
-             *//*   .select("count(t3.id) as memberCardCount ");*//*
-                .select("");
-
-        queryWrapper.in(Objects.nonNull(model.getCompanyIds()),Member::getCompanyId,model.getCompanyIds())
-              *//*      .like(number,Member::getPhone,model.getKeyWords())
-                    .like((b||hasWord),Member::getPhone,model.getKeyWords())*//*
-                     .and(StringUtils.isNotBlank(pageWrap.getModel().getKeyWords()),ms->ms.like(Member::getPhone,model.getKeyWords())
-                     .or().like(Member::getName,model.getKeyWords())
-                     .or().like(Member::getCode,model.getKeyWords()))
-
-                    .isNull(Constants.equalsInteger(model.getHasFace(),Constants.ZERO),Member::getFaceId)
-                    .isNotNull(Constants.equalsInteger(model.getHasFace(),Constants.ONE),Member::getFaceId)
-                    .eq(Objects.nonNull(model.getCanVisit()),Member::getCanVisit,model.getCanVisit())
-                    .eq(Objects.nonNull(model.getStatus()),Member::getStatus,model.getStatus());
+        queryWrapper.selectAll(Member.class);
+        queryWrapper.selectAs(Company::getName,Member::getCompanyName);
+        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().getKeyword()),ms->ms
+                        .like(Member::getPhone,pageWrap.getModel().getKeyword())
+                        .or().like(Member::getName,pageWrap.getModel().getKeyword())
+                        .or().like(Member::getCode,pageWrap.getModel().getKeyword()))
+                .isNull(!Objects.isNull(pageWrap.getModel().getHasFace())&&Constants.equalsInteger(pageWrap.getModel().getHasFace(),Constants.ZERO),Member::getFaceId)
+                .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)
+                .orderByDesc(Member::getCreateDate);
+        if(Constants.formatIntegerNum(dataSyncConfig.getOrgUserDataOrigin())==DataSyncConfig.origin.erp){
+            queryWrapper.eq( StringUtils.isNotBlank(pageWrap.getModel().getErpOrgId()),Member::getErpOrgId,pageWrap.getModel().getErpOrgId());
+        }else{
+            queryWrapper.eq(StringUtils.isNotBlank(pageWrap.getModel().getCompanyId()),Member::getCompanyId,pageWrap.getModel().getCompanyId());
+        }
         IPage<MemberInfoDTO> memberIPage = memberJoinMapper.selectJoinPage(page, MemberInfoDTO.class,queryWrapper);
-        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")
-        );
 
+        if(CollectionUtils.isNotEmpty(memberIPage.getRecords())){
+            //FTP鏂囦欢璁块棶鍓嶇紑
+            String prefixUrl = systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_RESOURCE_PATH).getCode() +
+                    systemDictDataBiz.queryByCode(Constants.FTP,Constants.MEMBER_IMG).getCode();
+            //闂ㄧ缁勪俊鎭�
+            List<DeviceRole> deviceRoleList = deviceRoleMapper.selectList(new QueryWrapper<DeviceRole>().lambda()
+                            .select(DeviceRole::getId,DeviceRole::getName)
+                    .eq(DeviceRole::getIsdeleted,Constants.ZERO));
+            for (MemberInfoDTO memberInfoDTO:memberIPage.getRecords()) {
+                //鑾峰緱闂ㄧ缁勫悕绉版暟缁�
+                memberInfoDTO.setRoleNames(this.dealRoleDatas(memberInfoDTO.getRoleId(),deviceRoleList));
+                //鎷兼帴鍓嶇紑
+                if(StringUtils.isNotBlank(memberInfoDTO.getFaceImg())){
+                    memberInfoDTO.setFaceImg(prefixUrl + memberInfoDTO.getFaceImg());
+                }
+                if(StringUtils.isNotBlank(memberInfoDTO.getImgurl())){
+                    memberInfoDTO.setImgurl(prefixUrl + memberInfoDTO.getImgurl());
+                }
+            }
+        }
         return PageData.from(memberIPage);
     }
 
-    /********************************************鍏紬鍙锋帴鍙�***********************************************************************/
 
+    public List<String>  dealRoleDatas(String roleIds,List<DeviceRole> deviceRoleList){
+        List<String> stringList = new ArrayList<>();
+        if(StringUtils.isNotBlank(roleIds)){
+            roleIds = roleIds.replace("[","").replace("]","");
+            List<String> ids = Arrays.asList(roleIds.split(","));
+            ids.forEach(i->{
+//                DeviceRole deviceRole = deviceRoleList.stream().filter(m->m.getId().toString().equals(i)).findFirst().get();
+                DeviceRole deviceRole = findRoleById(deviceRoleList,i);
+                if(!Objects.isNull(deviceRole)){
+                    stringList.add(deviceRole.getName());
+                }
+            });
+        }
+        return stringList;
+    }
+
+    private DeviceRole findRoleById(List<DeviceRole> deviceRoleList, String id) {
+        for(DeviceRole role  : deviceRoleList){
+            if(StringUtils.equals(role.getId().toString(),id)){
+                return role;
+            }
+        }
+        return null;
+    }
+
+    @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);
+        queryWrapper.selectAll(Member.class)
+                .selectAs(Company::getName,MemberInfoDTO::getCompanyName)
+                .selectAs(Member::getLastVisitDate,MemberInfoDTO::getVisitsLastDate)
+                .select(" (select count(v.id) from visits v where v.MEMBER_ID=t.id and v.ISDELETED=0 and v.status  in (7,8) ) as visitsCount");
+        queryWrapper.like(StringUtils.isNotBlank(pageWrap.getModel().getName()),Member::getName,pageWrap.getModel().getName())
+                .like(StringUtils.isNotBlank(pageWrap.getModel().getPhone()),Member::getPhone,pageWrap.getModel().getPhone())
+                .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.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);
+        if(Constants.formatIntegerNum(dataSyncConfig.getOrgUserDataOrigin())==DataSyncConfig.origin.erp){
+            queryWrapper.eq( StringUtils.isNotBlank(pageWrap.getModel().getErpOrgId()),Member::getErpOrgId,pageWrap.getModel().getErpOrgId());
+        }else{
+            queryWrapper.eq(StringUtils.isNotBlank(pageWrap.getModel().getCompanyId()),Member::getCompanyId,pageWrap.getModel().getCompanyId());
+        }
+        IPage<MemberInfoDTO> memberIPage = memberJoinMapper.selectJoinPage(page, MemberInfoDTO.class,queryWrapper);
+        return PageData.from(memberIPage);
+
+    }
+
+
+    @Override
+    public PageData<MemberInfoDTO> findUnusualPage(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);
+        queryWrapper.selectAll(Member.class)
+                .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");
+
+                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
+                .and(StringUtils.isNotBlank(pageWrap.getModel().getName()),ms->ms.like(Member::getPhone,pageWrap.getModel().getName())
+                        .or().like(Member::getName,pageWrap.getModel().getName()))
+                .and(StringUtils.isNotBlank(pageWrap.getModel().getCompanyName()),
+                        ms->ms.like(Company::getName,pageWrap.getModel().getCompanyName())
+                        .or().like(Member::getVisitCompanyName,pageWrap.getModel().getCompanyName()))
+                .like(StringUtils.isNotBlank(pageWrap.getModel().getIdcardNo()),Member::getIdcardNo,pageWrap.getModel().getIdcardNo())
+                .eq(Member::getStatus,Constants.Status.FREEZE.getValue())
+                .eq(StringUtils.isNotBlank(pageWrap.getModel().getCompanyId()),Company::getId,pageWrap.getModel().getCompanyId())
+                .eq(Objects.nonNull(pageWrap.getModel().getCode()),Member::getCode,pageWrap.getModel().getCode())
+                .orderByDesc(Member::getCreateDate);
+
+
+        IPage<MemberInfoDTO> memberIPage = memberJoinMapper.selectJoinPage(page, MemberInfoDTO.class,queryWrapper);
+        return PageData.from(memberIPage);
+
+    }
+
+
+    /**
+     * 鐢ㄦ埛瑙e喕 娣诲姞鎺堟潈瀵煎叆璁板綍
+     * @param member
+     */
+    public void thawMember(Member member){
+        //鐢ㄦ埛瑙掕壊缁�
+        List<MemberRole> memberRoleList =  memberRoleMapper.selectList(new QueryWrapper<MemberRole>().lambda().eq(MemberRole::getMemberId,member.getId()));
+        if(CollectionUtils.isNotEmpty(memberRoleList)){
+            List<Integer> roleIds = memberRoleList.stream().map(m->m.getId()).collect(Collectors.toList());
+            //瑙掕壊缁勮澶囨潈闄�
+            List<DeviceRole> deviceRoleList= deviceRoleMapper.selectList(new QueryWrapper<DeviceRole>().lambda()
+                    .eq(DeviceRole::getType,Constants.TWO)
+                    .in(DeviceRole::getId,roleIds));
+
+            if(CollectionUtils.isNotEmpty(deviceRoleList)){
+                String ids = "";
+                List<Integer> r = new ArrayList<>();
+                for (int i = 0; i < deviceRoleList.size(); i++) {
+                    DeviceRole deviceRole =deviceRoleList.get(i);
+                    if(i>0){
+                        ids += ",";
+                    }
+                    Integer id =deviceRole.getId();
+                    ids += "["+id+"]";
+                    String doorids =deviceRole.getDoorIds();
+                    if(StringUtils.isNotBlank(doorids)){
+                        String[] ss = doorids.split(",");
+                        try {
+                            for(String s :ss){
+                                r.add(Integer.parseInt(s));
+                            }
+                        }catch (Exception e){
+                            //鑴忔暟鎹笉澶勭悊
+                        }
+                    }
+                }
+
+                if(CollectionUtils.isNotEmpty(r)){
+                    List<Empower> list = new ArrayList<>();
+                    List<Device> deviceList = deviceMapper.selectList(new QueryWrapper<Device>().lambda().in(Device::getId,r));
+                    if(deviceList == null || deviceList.size() == 0){
+                        return;
+                    }
+                    for (Device deviceRole:deviceList) {
+                        Empower model = new Empower();
+                        model.setCreateDate(new Date());
+                        model.setMemberId(member.getId());
+                        model.setIsdeleted(Constants.ZERO);
+                        model.setDeviceId(deviceRole.getId());
+                        model.setSendStatus(Constants.ZERO);
+                        model.setSendType(Constants.ZERO);
+                        list.add(model);
+                    }
+                    //瀵煎叆鏂板鐨勬巿鏉冧俊鎭�
+                    empowerMapper.insertBatchSomeColumn(list);
+                }
+            }
+        }
+    }
+
+
+
+    /**
+     * 瀹氭椂鍐荤粨鍐呴儴浜哄憳
+     */
+    @Override
+    public void memberFreeze(){
+        SystemDictData systemDictData = systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.TIMEOUT_FREEZE);
+        if(Objects.isNull(systemDictData)||
+                StringUtils.isBlank(systemDictData.getCode())
+        ){
+            return;
+        }
+        List<Member> memberList = memberMapper.selectList(new QueryWrapper<Member>()
+                .lambda().eq(Member::getIsdeleted,Constants.ZERO)
+                .eq(Member::getType,Constants.memberType.internal)
+                .eq(Member::getStatus,Constants.ZERO)
+                .isNotNull(Member::getHkId)
+                .exists(" SELECT 1 FROM device_event b WHERE b.ext_event_person_no =  HK_ID AND TO_DAYS( NOW()) - TO_DAYS( b.CREATE_DATE ) > "+systemDictData.getCode()+"  ")
+        );
+        if(CollectionUtils.isEmpty(memberList)){
+           return;
+        }
+        List<Integer> memberIds = memberList.stream().map(m->m.getId()).collect(Collectors.toList());
+
+        //鍐荤粨鐘舵��
+        memberMapper.update(null,new UpdateWrapper<Member>()
+                .lambda().set(Member::getStatus,Constants.TWO)
+                .set(Member::getEditDate,new Date())
+                .in(Member::getId,memberIds)
+        );
+        //澶勭悊涓嬪彂鏁版嵁
+        empowerMapper.update(null,new UpdateWrapper<Empower>()
+                .lambda()
+                .set(Empower::getIsdeleted,Constants.ONE)
+                .set(Empower::getSendStatus,Constants.ZERO)
+                .set(Empower::getEditDate,new Date())
+                .in(Empower::getMemberId,memberIds)
+        );
+    }
+
+
+
+
+
+
+
+
+    /********************************************鍏紬鍙锋帴鍙�***********************************************************************/
 
 
     /**
@@ -477,8 +850,30 @@
         }
         WxAuthorizeVO wxAuthorizeVO = new WxAuthorizeVO();
         wxAuthorizeVO.setOpenid(openId);
+        //鏍规嵁openId 鏌ヨ鐢ㄦ埛淇℃伅
+        Member member = memberMapper.selectOne(new QueryWrapper<Member>().lambda()
+                .eq(Member::getOpenid,openId)
+                .eq(Member::getIsdeleted,Constants.ZERO)
+                .ne(Member::getType,Constants.memberType.visitor)
+        );
+        //闈炶瀹㈢敤鎴� 杩涜鍒ゆ柇鏄惁瀛樺湪鐢ㄦ埛
+        if(!Objects.isNull(member)&&!member.getType().equals(Constants.memberType.visitor)){
+            if(member.getIsdeleted() == Constants.ONE){
+                throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鐢ㄦ埛宸插垹闄�,璇疯仈绯荤鐞嗗憳");
+            }
+            if(member.getStatus() != Constants.ZERO){
+                throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鐢ㄦ埛宸茬鐢�,璇疯仈绯荤鐞嗗憳");
+            }
+            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);
+        }
         return wxAuthorizeVO;
     }
+
+
 
 
     @Override
@@ -491,23 +886,147 @@
                 .eq(Member::getPhone,checkVisitedDTO.getMobile())
                 .eq(validType.equals(Constants.ONE),Member::getName,checkVisitedDTO.getName())
                 .eq(Member::getIsdeleted,Constants.ZERO)
-                .eq(Member::getStatus,Constants.ZERO)
+//                .eq(Member::getStatus,Constants.ZERO)
                 .eq(Member::getCanVisit,Constants.ONE)
                 .eq(Member::getType,Constants.memberType.internal)
                 .last(" limit 1 ")
         );
         MemberVO memberVO = new MemberVO();
-        BeanUtils.copyProperties(member,memberVO);
+        if(!Objects.isNull(member)){
+            if(!member.getStatus().equals(Constants.ZERO)){
+                throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"琚浜鸿处鍙峰紓甯革紝璇风‘璁ゅ悗鍐嶈瘯");
+            }
+            BeanUtils.copyProperties(member,memberVO);
+        }else{
+            throw new BusinessException(ResponseStatus.DATA_EMPTY);
+        }
         return memberVO;
     }
 
 
 
 
+    @Override
+    public PageData<MemberVO> getVisitedMemberList(PageWrap<VisitMemberDTO> param) {
+        VisitMemberDTO visitMemberDTO = param.getModel();
+        IPage<Member> page = new Page<>(param.getPage(), param.getCapacity());
+        MPJLambdaWrapper<Member> queryWrapper = new MPJLambdaWrapper<>();
+        Utils.MP.blankToNull(visitMemberDTO);
+
+        queryWrapper.selectAs(Member::getId,MemberVO::getId);
+        queryWrapper.selectAs(Member::getName,MemberVO::getName);
+        queryWrapper.selectAs(Member::getPhone,MemberVO::getPhone);
+        queryWrapper.selectAs(Member::getCompanyId,MemberVO::getCompanyId);
+        queryWrapper.selectAs(Member::getFaceImg,MemberVO::getFaceImg);
+
+        queryWrapper.eq(Member::getIsdeleted,Constants.ZERO);
+        queryWrapper.eq(Member::getStatus,Constants.ZERO);
+        queryWrapper.eq(Member::getCanVisit,Constants.ONE);
+        queryWrapper.eq(Member::getType,Constants.memberType.internal);
+        if(!Objects.isNull(visitMemberDTO)){
+            queryWrapper.and(StringUtils.isNotBlank(visitMemberDTO.getName()), ms->ms.like(Member::getPhone,visitMemberDTO.getName())
+                    .or().like(Member::getPhone,visitMemberDTO.getName()));
+        }
+        queryWrapper.orderByDesc(Visits::getCreateDate);
+        IPage<MemberVO> result = memberJoinMapper.selectJoinPage(page, MemberVO.class,queryWrapper);
+
+        String prefixUrl = systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_RESOURCE_PATH).getCode() +
+                systemDictDataBiz.queryByCode(Constants.FTP,Constants.MEMBER_IMG).getCode();
+        result.getRecords().forEach(i->{
+            i.setPrefixUrl(prefixUrl);
+        });
+
+        return PageData.from(result);
+    }
 
 
 
 
+    @Override
+    public WxAuthorizeVO accountLogin(AccountLoginDTO accountLoginDTO){
+        if(accountLoginDTO.getAccount().length()!=18
+            //&&!IdcardUtil.isValidCard(accountLoginDTO.getAccount())
+        ){
+            throw  new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "瀵逛笉璧凤紝韬唤璇佸彿鐮佹湁璇紝璇锋牳瀹炲悗閲嶈瘯锛�");
+        }
+        Member member = memberMapper.selectOne(new QueryWrapper<Member>().lambda()
+                .eq(Member::getIdcardNo, DESUtil.encrypt(Constants.EDS_PWD, accountLoginDTO.getAccount()))
+                .ne(Member::getType,Constants.memberType.visitor)
+        );
+        if(Objects.isNull(member)){
+            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鏈煡璇㈠埌鐢ㄦ埛,璇疯仈绯荤鐞嗗憳");
+        }
+        if(member.getIsdeleted() == Constants.ONE){
+            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鐢ㄦ埛宸插垹闄�,璇疯仈绯荤鐞嗗憳");
+        }
+        if(member.getStatus() != Constants.ZERO){
+            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鐢ㄦ埛宸茬鐢�,璇疯仈绯荤鐞嗗憳");
+        }
+        String md5Password = DESUtil.encrypt(Constants.EDS_PWD, accountLoginDTO.getPassword());
+        if(!md5Password.equals(member.getPassward())){
+            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"璐︽埛瀵嗙爜閿欒!");
+        }
+        if(StringUtils.isNotBlank(accountLoginDTO.getOpenId())){
+            //鍏堟竻绌哄師鏈夎瀹㈢殑openid缁戝畾鍏崇郴
+            memberMapper.update(null, new UpdateWrapper<Member>().lambda()
+                    .ne(Member::getType,Constants.memberType.visitor)
+                    .eq(Member::getOpenid,accountLoginDTO.getOpenId())
+                    .set(Member::getOpenid,null)
+            );
+            //鏇存柊褰撳墠鐧诲綍鐢ㄦ埛 openId
+            member.setOpenid(accountLoginDTO.getOpenId());
+            memberMapper.updateById(member);
+        }
+        WxAuthorizeVO wxAuthorizeVO = new WxAuthorizeVO();
+        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);
+        return wxAuthorizeVO;
+    }
+
+
+
+    @Override
+    public StagingDataVO stagingHead(StagingDataVO stagingHeadVO){
+        //浜哄憳淇℃伅
+        List<Member> memberList = memberMapper.selectList(new QueryWrapper<Member>().lambda().eq(Member::getIsdeleted,Constants.ZERO));
+        if(CollectionUtils.isNotEmpty(memberList)){
+            stagingHeadVO.setWorkerCount(memberList.stream().filter(m->m.getType().equals(Constants.memberType.internal)).count());
+            stagingHeadVO.setLwCount(memberList.stream().filter(m->m.getType().equals(Constants.memberType.lw_visitor)).count());
+            stagingHeadVO.setVisitorCount(memberList.stream().filter(m->m.getType().equals(Constants.memberType.visitor)).count());
+        }
+        //鍦ㄥ満杞﹁締
+        stagingHeadVO.setPresenceCarCount(retentionJoinMapper.selectCount(new QueryWrapper<Retention>().lambda().eq(Retention::getType,3)));
+        //闀挎湡杞﹁締
+        stagingHeadVO.setLongCarCount(retentionJoinMapper.selectCount(new QueryWrapper<Retention>().lambda().eq(Retention::getType,3)
+                .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)));
+        return stagingHeadVO;
+    }
+
+
+    @Override
+    public StagingDataVO stagingBody(StagingDataVO stagingHeadVO){
+        List<Map<String,Object>> companyMaps = memberJoinMapper.selectJoinMaps(
+                new MPJLambdaWrapper<Member>()
+                        .select("count(1) as memberCount, t1.name as companyName")
+                        .leftJoin(Company.class,Company::getId,Member::getCompanyId)
+                        .eq(Member::getType,Constants.memberType.lw_visitor)
+                        .groupBy(Company::getId,Company::getName)
+        );
+        List<Map<String,Object>> retentionMaps = retentionJoinMapper.selectMaps(new MPJLambdaWrapper<Retention>()
+                        .select(" count(1) as memberCount, type as memberType ")
+                        .ne(Retention::getType,3)
+                .groupBy(Retention::getType)
+        );
+        stagingHeadVO.setCompanyUsers(companyMaps);
+        stagingHeadVO.setRetentionUsers(retentionMaps);
+        return stagingHeadVO;
+    }
 
 
 

--
Gitblit v1.9.3