|  |  | 
 |  |  | import com.doumee.core.haikang.model.param.respose.UserAddResponse; | 
 |  |  | import com.doumee.core.haikang.model.param.respose.UserDelResponse; | 
 |  |  | import com.doumee.core.haikang.service.HKService; | 
 |  |  | import com.doumee.core.model.LoginUserInfo; | 
 |  |  | import com.doumee.core.model.PageData; | 
 |  |  | import com.doumee.core.model.PageWrap; | 
 |  |  | import com.doumee.service.business.third.TmsService; | 
 |  |  | import com.doumee.service.business.third.model.LoginUserInfo; | 
 |  |  | import com.doumee.service.business.third.model.PageData; | 
 |  |  | import com.doumee.service.business.third.model.PageWrap; | 
 |  |  | import com.doumee.core.utils.*; | 
 |  |  | import com.doumee.core.wx.WXConstant; | 
 |  |  | import com.doumee.dao.admin.request.LaborEmpowerDTO; | 
 |  |  | 
 |  |  | import com.doumee.service.business.SmsEmailService; | 
 |  |  | import com.doumee.service.business.impl.hksync.HkSyncEmpowerServiceImpl; | 
 |  |  | import com.doumee.service.business.impl.hksync.ferp.HkSyncOrgUserToHKServiceImpl; | 
 |  |  | import com.doumee.service.business.third.model.request.TmsEmployeeListRequest; | 
 |  |  | import com.doumee.service.business.third.model.response.TmsEmployeeListResponse; | 
 |  |  | import com.doumee.service.system.SystemLoginService; | 
 |  |  | import com.github.yulichang.wrapper.MPJLambdaWrapper; | 
 |  |  | import org.apache.commons.collections.CollectionUtils; | 
 |  |  | import org.apache.commons.lang3.RandomStringUtils; | 
 |  |  | import org.apache.commons.lang3.StringUtils; | 
 |  |  | import org.apache.poi.ss.usermodel.CellType; | 
 |  |  | import org.apache.shiro.SecurityUtils; | 
 |  |  | import org.springframework.beans.BeanUtils; | 
 |  |  | import org.springframework.beans.factory.annotation.Autowired; | 
 |  |  | 
 |  |  |     @Autowired | 
 |  |  |     private VisitsMapper visitsMapper; | 
 |  |  |     @Autowired | 
 |  |  |     private TmsService tmsService; | 
 |  |  |     @Autowired | 
 |  |  |     private SystemUserMapper systemUserMapper; | 
 |  |  |     @Autowired | 
 |  |  |     private CarsMapper carsMapper; | 
 |  |  |     @Autowired | 
 |  |  |     private ParkBookMapper parkBookMapper; | 
 |  |  |  | 
 |  |  |     @Autowired | 
 |  |  |     @Lazy | 
 |  |  | 
 |  |  |         user.setSource(Constants.ZERO); | 
 |  |  |         user.setDeleted(Boolean.FALSE); | 
 |  |  |         user.setFixed(Boolean.FALSE); | 
 |  |  |         user.setPinyin(Constants.getChinesePingyin(user.getRealname())); | 
 |  |  |         user.setStatus(Constants.ZERO); | 
 |  |  |         return user; | 
 |  |  |     } | 
 |  |  | 
 |  |  |         insert.setSex(Constants.getSexByCardNo( member.getIdcardNo()));//根据身份证号获取性别 | 
 |  |  |         insert.setJobDate(member.getJobDate()); | 
 |  |  |         insert.setIsDangyuan(member.getIsDangyuan()); | 
 |  |  |         insert.setPinyin(Constants.getChinesePingyin(member.getName())); | 
 |  |  |         insert.setPositionId(member.getPositionId()); | 
 |  |  |         if(StringUtils.isNotBlank(member.getIdcardNo())){ | 
 |  |  |             insert.setBirthday( DateUtil.fromStringToDate("yyyyMMdd",IdcardUtil.getBirthByIdCard(member.getIdcardNo()))); | 
 |  |  | 
 |  |  |                             .set(SystemUser::getUpdateUser,member.getLoginUserInfo().getId()) | 
 |  |  |                             .set(SystemUser::getUpdateTime,new Date()) | 
 |  |  |                             .set(StringUtils.isNotBlank(member.getFaceImg()),SystemUser::getAvatar,member.getFaceImg()) | 
 |  |  |                             .set(StringUtils.isNotBlank(member.getName()),SystemUser::getPinyin,Constants.getChinesePingyin(member.getName())) | 
 |  |  |                             .set(StringUtils.isNotBlank(member.getPhone()),SystemUser::getMobile,member.getPhone()) | 
 |  |  |                             .set(StringUtils.isNotBlank(member.getPhone()),SystemUser::getUsername,member.getPhone()) | 
 |  |  |                             .set(StringUtils.isNotBlank(member.getName()),SystemUser::getRealname,member.getName()) | 
 |  |  | 
 |  |  |             //如果人脸没变化 | 
 |  |  |             member.setFaceImg(null); | 
 |  |  |         } | 
 |  |  |  | 
 |  |  |         member.setPinyin(Constants.getChinesePingyin(member.getName())); | 
 |  |  |         return model; | 
 |  |  |     } | 
 |  |  |  | 
 |  |  | 
 |  |  |     @Override | 
 |  |  |     @Transactional(rollbackFor = {BusinessException.class,Exception.class}) | 
 |  |  |     public void deleteById(Integer id,LoginUserInfo loginUserInfo) { | 
 |  |  |  | 
 |  |  |         Date date =new Date(); | 
 |  |  |         Member member=new Member(); | 
 |  |  |         member.setId(id); | 
 |  |  |         member.setIsdeleted(Constants.ONE); | 
 |  |  |         member.setEditor(loginUserInfo.getId()); | 
 |  |  |         member.setEditDate(new Date()); | 
 |  |  |         member.setEditDate(date); | 
 |  |  |         member.setHkStatus(Constants.ZERO); | 
 |  |  |         member.setRemark("人员已删除,等待删除门禁权限"); | 
 |  |  |         memberMapper.updateById(member); | 
 |  |  | 
 |  |  |                 .set(SystemUser::getUpdateUser,member.getEditor()) | 
 |  |  |                 .set(SystemUser::getUpdateTime,member.getEditDate()) | 
 |  |  |         ); | 
 |  |  |  | 
 |  |  |         saveUserActionBiz(member,loginUserInfo,Constants.UserActionType.DELETE,userActionJoinMapper,JSONObject.toJSONString(member)); | 
 |  |  |         List<Cars> carsList = carsMapper.selectList(new QueryWrapper<Cars>().lambda() | 
 |  |  |                 .eq(Cars::getMemberId,member.getId()) | 
 |  |  |                 .eq(Cars::getIsdeleted,Constants.ONE) | 
 |  |  |                 .eq(Cars::getAuthStatus,Constants.ONE)//已授权包期的车辆 | 
 |  |  |         ); | 
 |  |  |         if ((carsMapper!=null && carsList.size()>0)){ | 
 |  |  |             for(Cars car :carsList){ | 
 |  |  |                if(Constants.equalsInteger(car.getAuthStatus(),Constants.ZERO)){ | 
 |  |  |                    Cars model = new Cars(); | 
 |  |  |                    carsMapper.update(null,new UpdateWrapper<Cars>().lambda() | 
 |  |  |                            .eq(Cars::getId,car.getId()) | 
 |  |  |                            .set(Cars::getStartTime,null) | 
 |  |  |                            .set(Cars::getEndTime,null) | 
 |  |  |                            .set(Cars::getAuthTimeType,null) | 
 |  |  |                            .set(Cars::getAuthStatus,Constants.ZERO) | 
 |  |  |                            .set(Cars::getEditDate,model.getEditDate()) | 
 |  |  |                            .set(Cars::getEdirot,model.getEdirot()) | 
 |  |  |                    ); | 
 |  |  |                    //删除已授权下发的包期授权 | 
 |  |  |                    CarsServiceImpl.dealCancelBookBiz(car.getCode(),date,parkBookMapper); | 
 |  |  |                } | 
 |  |  |             } | 
 |  |  |         } | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |  | 
 |  |  | 
 |  |  |             loginUserInfo = updateMember.getLoginUserInfo(); | 
 |  |  |         } | 
 |  |  |         //校验参数 并且更新systemuser 手机号和工号信息(如果需要修改的话) | 
 |  |  |          Member model =   isMemberUpdateParamValid(updateMember); | 
 |  |  |         Member model =   isMemberUpdateParamValid(updateMember); | 
 |  |  |         updateMember.setEditor(loginUserInfo.getId()); | 
 |  |  |         updateMember.setEditDate(new Date()); | 
 |  |  |         //海康人员新增业务 | 
 |  |  | 
 |  |  |                     .set(StringUtils.isNotBlank(updateMember.getName()),Member::getName,updateMember.getName()) | 
 |  |  |                     .set(Member::getEditDate,updateMember.getEditDate()) | 
 |  |  |                     .set(Member::getEditor,updateMember.getEditor()) | 
 |  |  |                     .set(StringUtils.isNotBlank(updateMember.getName()),Member::getPinyin,Constants.getChinesePingyin(updateMember.getName())) | 
 |  |  |                     .set(StringUtils.isNotBlank(updateMember.getIdcardNo()),Member::getIdcardNo,updateMember.getIdcardNo()) | 
 |  |  |                     .set(StringUtils.isNotBlank(updateMember.getIdcardDecode()),Member::getIdcardDecode,updateMember.getIdcardDecode()) | 
 |  |  |                     .set( Member::getAuthStatus,Constants.ZERO) | 
 |  |  | 
 |  |  |                     .set(StringUtils.isNotBlank(updateMember.getFaceImg()),Member::getFaceImg,updateMember.getFaceImg()) | 
 |  |  |                     .set(updateMember.getFaceId()!=null,Member::getFaceId,updateMember.getFaceId()) | 
 |  |  |                     .set(updateMember.getCompanyId()!=null,Member::getCompanyId,updateMember.getCompanyId()) | 
 |  |  |                     .set(StringUtils.isNotBlank(updateMember.getCode()),Member::getCode,updateMember.getCode()) | 
 |  |  |                     .set(Member::getCode,updateMember.getCode()) | 
 |  |  | //                    .set(StringUtils.isNotBlank(updateMember.getCode()),Member::getCode,updateMember.getCode()) | 
 |  |  |                     .set( updateMember.getPositionId()!=null,Member::getPositionId,updateMember.getPositionId()) | 
 |  |  |                     .set( updateMember.getIsDangyuan()!=null,Member::getIsDangyuan,updateMember.getIsDangyuan()) | 
 |  |  |                     .set( updateMember.getJobDate()!=null,Member::getJobDate,updateMember.getJobDate()) | 
 |  |  |                     .set(StringUtils.isNotBlank(updateMember.getCode()),Member::getCode,updateMember.getCode()) | 
 |  |  |                     .eq(Member::getId,updateMember.getId())); | 
 |  |  |             dealTrainTIme(updateMember,1,loginUserInfo); | 
 |  |  |             cancelAllMemberEmpower(updateMember,memberRoleMapper,empowerMapper); | 
 |  |  | 
 |  |  |  | 
 |  |  |     public static void saveUserActionBiz(Member updateMember,LoginUserInfo user, Constants.UserActionType type,UserActionJoinMapper userActionMapper,String content) { | 
 |  |  |         updateMember.setEditDate(updateMember.getEditDate()==null?new Date():updateMember.getEditDate()); | 
 |  |  |         UserAction userAction=new UserAction(); | 
 |  |  |        UserAction userAction=new UserAction(); | 
 |  |  |         userAction.setIsdeleted(Constants.ZERO); | 
 |  |  |         userAction.setCreateDate(updateMember.getEditDate()); | 
 |  |  |         userAction.setCreator(updateMember.getEditor()); | 
 |  |  | 
 |  |  |         } | 
 |  |  |         queryWrapper.eq(Member::getIsdeleted,Constants.ZERO); | 
 |  |  |         queryWrapper.eq(Member::getWorkStatus,Constants.ZERO); | 
 |  |  |         queryWrapper.orderByAsc(Member::getPinyin); | 
 |  |  |         List<Member> list =  memberJoinMapper.selectJoinList(Member.class,queryWrapper); | 
 |  |  | //        if(list!=null){ | 
 |  |  | //            for(Member m : list){ | 
 |  |  | 
 |  |  |             queryWrapper.eq(Member::getCompanyId,member.getCompanyId()); | 
 |  |  |         } | 
 |  |  |         queryWrapper.eq(Member::getIsdeleted,Constants.ZERO); | 
 |  |  |         queryWrapper.orderByAsc(Member::getPinyin); | 
 |  |  |         List<Member> list =  memberJoinMapper.selectJoinList(Member.class,queryWrapper); | 
 |  |  |         if(list!=null){ | 
 |  |  |             for(Member m : list){ | 
 |  |  | 
 |  |  |             } | 
 |  |  |         } | 
 |  |  |         return  list; | 
 |  |  |     } | 
 |  |  |     @Override | 
 |  |  |     public  void initPinyinTool(){ | 
 |  |  |         MPJLambdaWrapper<Member> queryWrapper = new MPJLambdaWrapper<>(); | 
 |  |  |         List<Member> list =  memberJoinMapper.selectList(queryWrapper); | 
 |  |  |         if(list!=null){ | 
 |  |  |             for(Member m : list){ | 
 |  |  |                if(m.getName()!=null){ | 
 |  |  |                    Member u = new Member(); | 
 |  |  |                    u.setId(m.getId()); | 
 |  |  |                    u.setPinyin(Constants.getChinesePingyin(m.getName())); | 
 |  |  |                    memberMapper.updateById(u); | 
 |  |  |                } | 
 |  |  |             } | 
 |  |  |         } | 
 |  |  |  | 
 |  |  |         MPJLambdaWrapper<SystemUser> q1 = new MPJLambdaWrapper<>(); | 
 |  |  |         List<SystemUser> list1 =  systemUserMapper.selectList(q1); | 
 |  |  |         if(list1!=null){ | 
 |  |  |             for(SystemUser m : list1){ | 
 |  |  |                 if(m.getRealname()!=null){ | 
 |  |  |                     SystemUser u = new SystemUser(); | 
 |  |  |                     u.setId(m.getId()); | 
 |  |  |                     u.setPinyin(Constants.getChinesePingyin(m.getRealname())); | 
 |  |  |                     systemUserMapper.updateById(u); | 
 |  |  |                 } | 
 |  |  |             } | 
 |  |  |         } | 
 |  |  |         MPJLambdaWrapper<Company> q2 = new MPJLambdaWrapper<>(); | 
 |  |  |         List<Company> list2 =  companyMapper.selectList(q2); | 
 |  |  |         if(list2!=null){ | 
 |  |  |             for(Company m : list2){ | 
 |  |  |                 if(m.getName()!=null){ | 
 |  |  |                     Company u = new Company(); | 
 |  |  |                     u.setId(m.getId()); | 
 |  |  |                     u.setPinyin(Constants.getChinesePingyin(m.getName())); | 
 |  |  |                     companyMapper.updateById(u); | 
 |  |  |                 } | 
 |  |  |             } | 
 |  |  |         } | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     @Override | 
 |  |  | 
 |  |  | //                .eq(Member::getStatus,Constants.Status.ENABLE.getValue()) | 
 |  |  | //                .eq(Member::getType,Constants.memberType.internal) | 
 |  |  |                 .eq(pageWrap.getModel().getHkStatus()!=null,Member::getHkStatus,pageWrap.getModel().getHkStatus()) | 
 |  |  |                 .orderByDesc(!Constants.equalsInteger(pageWrap.getModel().getIsdeleted(),Constants.ONE),Member::getCreateDate) | 
 |  |  |                 .orderByAsc(!Constants.equalsInteger(pageWrap.getModel().getIsdeleted(),Constants.ONE),Member::getPinyin) | 
 |  |  |                 .orderByDesc(Constants.equalsInteger(pageWrap.getModel().getIsdeleted(),Constants.ONE),Member::getEditDate); | 
 |  |  |         if(Constants.formatIntegerNum(dataSyncConfig.getOrgUserDataOrigin())==DataSyncConfig.origin.erp){ | 
 |  |  |             queryWrapper.eq( StringUtils.isNotBlank(pageWrap.getModel().getErpOrgId()),Member::getErpOrgId,pageWrap.getModel().getErpOrgId()); | 
 |  |  | 
 |  |  |                 .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); | 
 |  |  |                 .orderByAsc(Member::getPinyin); | 
 |  |  |         if(Constants.formatIntegerNum(dataSyncConfig.getOrgUserDataOrigin())==DataSyncConfig.origin.erp){ | 
 |  |  |             queryWrapper.eq( StringUtils.isNotBlank(pageWrap.getModel().getErpOrgId()),Member::getErpOrgId,pageWrap.getModel().getErpOrgId()); | 
 |  |  |         }else{ | 
 |  |  | 
 |  |  |  | 
 |  |  |         queryWrapper.selectAs(Position::getName,Member::getPositionName); | 
 |  |  |         queryWrapper.leftJoin(Position.class,Position::getId,Member::getPositionId); | 
 |  |  |  | 
 |  |  |         queryWrapper.orderByAsc(Member::getPinyin); | 
 |  |  |         IPage<Member> memberIPage = memberJoinMapper.selectJoinPage(page, Member.class,queryWrapper); | 
 |  |  |         return PageData.from(memberIPage); | 
 |  |  |  | 
 |  |  | 
 |  |  |                 .leftJoin(Company.class,Company::getId,Member::getCompanyId) | 
 |  |  |                 .eq(Member::getIsdeleted,Constants.ZERO) | 
 |  |  |                 .eq(Company::getType,Constants.ZERO) | 
 |  |  |                 .eq(Member::getStatus,Constants.ZERO) | 
 |  |  |                 .eq(Member::getStatus,Constants.ZERO | 
 |  |  |                 ) | 
 |  |  |                 .isNotNull(Member::getHkId) | 
 |  |  |                 .apply("to_days(LAST_VISIT_DATE)+ "+days+" < to_days(now())" )); | 
 |  |  |                 .apply("to_days(LAST_VISIT_DATE)+ "+days+" < to_days(now())" ) | 
 |  |  |                 .orderByAsc(Member::getPinyin)); | 
 |  |  |         if(CollectionUtils.isEmpty(memberList)){ | 
 |  |  |            return; | 
 |  |  |         } | 
 |  |  | 
 |  |  |         } | 
 |  |  |         wxAuthorizeVO.setOpenid(openId); | 
 |  |  |         if(source==1){ | 
 |  |  |             //根据openId 查询用户信息 | 
 |  |  |             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::getType,source) | 
 |  |  |                     .eq(Member::getIsdeleted,Constants.ZERO) | 
 |  |  |                     .orderByDesc(Member::getCreateDate) | 
 |  |  |                     .last(" limit 1 ") | 
 |  |  |             ); | 
 |  |  |             //非访客用户 进行判断是否存在用户 | 
 |  |  |             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); | 
 |  |  |                 wxAuthorizeVO.setMember(member); | 
 |  |  |                 //司机 与 内部人员 提供token | 
 |  |  |                 if(Constants.equalsInteger(source,Constants.ZERO)||Constants.equalsInteger(source,Constants.TWO)){ | 
 |  |  |                     SystemUser systemUser = systemUserMapper.selectOne(new QueryWrapper<SystemUser>().lambda().eq(SystemUser::getMemberId,member.getId()) | 
 |  |  |                             .eq(SystemUser::getStatus,Constants.ZERO).last(" limit 1 ")); | 
 |  |  |                     if(Objects.nonNull(systemUser)){ | 
 |  |  |                         String token = systemLoginService.loginByUserId(systemUser.getId()); | 
 |  |  |                         wxAuthorizeVO.setToken(token); | 
 |  |  |                     } | 
 |  |  |                 } | 
 |  |  |             } | 
 |  |  |             //处理普通访客人员自动授权逻辑 | 
 |  |  |             dealVisitUserAuthBiz(wxAuthorizeVO,openId,source); | 
 |  |  |         }else if(source == 3){ | 
 |  |  |             //处理tms管控人员自动授权逻辑 | 
 |  |  |             dealGkUserAuthBiz(wxAuthorizeVO,openId,source); | 
 |  |  |         }else if(source == 0){ | 
 |  |  |             //如果是司机,则从system_user查询 | 
 |  |  |             dealDriverUserAuthBiz(wxAuthorizeVO,openId,source); | 
 |  |  |         }else{ | 
 |  |  |             //如果是司机或者内部人员,则从system_user查询 | 
 |  |  |             SystemUser user = systemUserMapper.selectOne(new QueryWrapper<SystemUser>().lambda() | 
 |  |  |                     .eq(SystemUser::getOpenid,openId) | 
 |  |  |                     .eq(SystemUser::getType,source) | 
 |  |  |                     .eq(SystemUser::getDeleted,Boolean.FALSE) | 
 |  |  |                     .last(" limit 1 ")); | 
 |  |  |             //非访客用户 进行判断是否存在用户 | 
 |  |  |             if(!Objects.isNull(user)){ | 
 |  |  |                 Member member = memberMapper.selectById(user.getMemberId()); | 
 |  |  |                 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); | 
 |  |  |                 wxAuthorizeVO.setMember(member); | 
 |  |  |                 //司机 与 内部人员 提供token | 
 |  |  |                 String token = systemLoginService.loginByUserId(user.getId()); | 
 |  |  |                 wxAuthorizeVO.setToken(token); | 
 |  |  |             } | 
 |  |  |             //如果是内部人员,则从system_user查询 | 
 |  |  |             dealSystemUserAuthBiz(wxAuthorizeVO,openId,source); | 
 |  |  |         } | 
 |  |  |  | 
 |  |  |  | 
 |  |  |         return wxAuthorizeVO; | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     private void dealSystemUserAuthBiz(WxAuthorizeVO wxAuthorizeVO, String openId, Integer source) { | 
 |  |  |         SystemUser user = systemUserMapper.selectOne(new QueryWrapper<SystemUser>().lambda() | 
 |  |  |                 .eq(SystemUser::getOpenid,openId) | 
 |  |  |                 .in(SystemUser::getType,Constants.memberType.internal) | 
 |  |  |                 .eq(SystemUser::getDeleted,Constants.ZERO) | 
 |  |  |                 .last(" limit 1 ")); | 
 |  |  |         //非访客用户 进行判断是否存在用户 | 
 |  |  |         if(!Objects.isNull(user)){ | 
 |  |  |             Member member = memberMapper.selectById(user.getMemberId()); | 
 |  |  |             if(member == null || member.getIsdeleted() == Constants.ONE){ | 
 |  |  |                 return; | 
 |  |  | //                throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"用户已删除,请联系管理员"); | 
 |  |  |             } | 
 |  |  |             if(member.getStatus() != Constants.ZERO){ | 
 |  |  |                 return; | 
 |  |  | //                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); | 
 |  |  |             wxAuthorizeVO.setMember(member); | 
 |  |  |             //司机 与 内部人员 提供token | 
 |  |  |             String token = systemLoginService.loginByUserId(user.getId()); | 
 |  |  |             wxAuthorizeVO.setToken(token); | 
 |  |  |         } | 
 |  |  |     } | 
 |  |  |     private void dealDriverUserAuthBiz(WxAuthorizeVO wxAuthorizeVO, String openId, Integer source) { | 
 |  |  |         SystemUser user = systemUserMapper.selectOne(new QueryWrapper<SystemUser>().lambda() | 
 |  |  |                 .eq(SystemUser::getOpenid,openId) | 
 |  |  |                 .in(SystemUser::getType,Constants.memberType.internal,Constants.memberType.driver) | 
 |  |  |                 .eq(SystemUser::getDeleted,Constants.ZERO) | 
 |  |  |                 .last(" limit 1 ")); | 
 |  |  |         //非访客用户 进行判断是否存在用户 | 
 |  |  |         if(!Objects.isNull(user)){ | 
 |  |  |             Member member = memberMapper.selectById(user.getMemberId()); | 
 |  |  |             if(member == null || member.getIsdeleted() == Constants.ONE){ | 
 |  |  |                 return; | 
 |  |  | //                throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"用户已删除,请联系管理员"); | 
 |  |  |             } | 
 |  |  |             if(member.getStatus() != Constants.ZERO){ | 
 |  |  |                 return; | 
 |  |  | //                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); | 
 |  |  |             wxAuthorizeVO.setMember(member); | 
 |  |  |             //司机 与 内部人员 提供token | 
 |  |  |             String token = systemLoginService.loginByUserId(user.getId()); | 
 |  |  |             wxAuthorizeVO.setToken(token); | 
 |  |  |         } | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     private void dealGkUserAuthBiz(WxAuthorizeVO wxAuthorizeVO, String openId, Integer source) { | 
 |  |  |         //如果是司机或者内部人员,则从system_user查询 | 
 |  |  |         SystemUser user = systemUserMapper.selectOne(new QueryWrapper<SystemUser>().lambda() | 
 |  |  |                 .eq(SystemUser::getOpenid,openId) | 
 |  |  |                 .eq(SystemUser::getType,source) | 
 |  |  | //                .eq(Objects.nonNull(source)&&Constants.equalsInteger(source,Constants.TWO),SystemUser::getType,source) | 
 |  |  |                 .eq(SystemUser::getDeleted,Constants.ZERO) | 
 |  |  |                 .last(" limit 1 ")); | 
 |  |  |         //非访客用户 进行判断是否存在用户 | 
 |  |  |         if(!Objects.isNull(user)){ | 
 |  |  |             TmsEmployeeListRequest tp = new TmsEmployeeListRequest(); | 
 |  |  |             tp.setTel(user.getMobile()); | 
 |  |  |             TmsEmployeeListResponse response = tmsService.getEmployeeList(tp); | 
 |  |  |             if(response == null || response.getTel()==null){ | 
 |  |  |                 return; | 
 |  |  | //                throw  new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起,该账户人员信息不正确,如有疑问请联系系统管理员查看!"); | 
 |  |  |             } | 
 |  |  |  | 
 |  |  |             Member member = new Member(); | 
 |  |  |             member.setPhone(user.getMobile()); | 
 |  |  | //            member.setId(user.getId()); | 
 |  |  |             wxAuthorizeVO.setMember(member); | 
 |  |  |             //司机 与 内部人员 提供token | 
 |  |  |             String token = systemLoginService.loginByUserId(user.getId()); | 
 |  |  |             wxAuthorizeVO.setToken(token); | 
 |  |  |         } | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     private void dealVisitUserAuthBiz(WxAuthorizeVO wxAuthorizeVO, String openId,Integer source) { | 
 |  |  |         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::getType,source) | 
 |  |  |                 .eq(Member::getIsdeleted,Constants.ZERO) | 
 |  |  |                 .orderByDesc(Member::getCreateDate) | 
 |  |  |                 .last(" limit 1 ") | 
 |  |  |         ); | 
 |  |  |         //非访客用户 进行判断是否存在用户 | 
 |  |  |         if(!Objects.isNull(member)){ | 
 |  |  |             if(member.getIsdeleted() == Constants.ONE){ | 
 |  |  |                 return; | 
 |  |  | //                throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"用户已删除,请联系管理员"); | 
 |  |  |             } | 
 |  |  |             if(member.getStatus() != Constants.ZERO){ | 
 |  |  |                 return; | 
 |  |  | //                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); | 
 |  |  |             wxAuthorizeVO.setMember(member); | 
 |  |  |             //司机 与 内部人员 提供token | 
 |  |  |             if(Constants.equalsInteger(source,Constants.ZERO)||Constants.equalsInteger(source,Constants.TWO)){ | 
 |  |  |                 SystemUser systemUser = systemUserMapper.selectOne(new QueryWrapper<SystemUser>().lambda().eq(SystemUser::getMemberId,member.getId()) | 
 |  |  |                         .eq(SystemUser::getStatus,Constants.ZERO).last(" limit 1 ")); | 
 |  |  |                 if(Objects.nonNull(systemUser)){ | 
 |  |  |                     String token = systemLoginService.loginByUserId(systemUser.getId()); | 
 |  |  |                     wxAuthorizeVO.setToken(token); | 
 |  |  |                 } | 
 |  |  |             } | 
 |  |  |         } | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |  | 
 |  |  |     @Override | 
 |  |  | 
 |  |  |                 .eq(Member::getWorkStatus,Constants.ZERO) | 
 |  |  |                 .eq(Member::getCanVisit,Constants.ONE) | 
 |  |  |                 .eq(Company::getType,Constants.ONE) | 
 |  |  |                 .orderByAsc(Member::getPinyin) | 
 |  |  |         ); | 
 |  |  |         List<MemberVO> memberVOList = new ArrayList<>(); | 
 |  |  |         if (com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(memberList)) { | 
 |  |  | 
 |  |  |             queryWrapper.and(StringUtils.isNotBlank(visitMemberDTO.getName()), ms->ms.like(Member::getPhone,visitMemberDTO.getName()) | 
 |  |  |                     .or().like(Member::getPhone,visitMemberDTO.getName())); | 
 |  |  |         } | 
 |  |  |         queryWrapper.orderByDesc(Visits::getCreateDate); | 
 |  |  |         queryWrapper.orderByAsc(Member::getPinyin); | 
 |  |  | //      queryWrapper.orderByDesc(Visits::getCreateDate); | 
 |  |  |         IPage<MemberVO> result = memberJoinMapper.selectJoinPage(page, MemberVO.class,queryWrapper); | 
 |  |  |  | 
 |  |  |         String prefixUrl = systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_RESOURCE_PATH).getCode() + | 
 |  |  | 
 |  |  |             ExcelImporter ie = null; | 
 |  |  |             List<MemberImport> dataList =null; | 
 |  |  |             try { | 
 |  |  |                 ie = new ExcelImporter(file,2,0); | 
 |  |  |                 ie = new ExcelImporter(file,1,0, CellType.STRING); // 确保单元格类型为字符串); | 
 |  |  |                 dataList = ie.getDataList(MemberImport.class,null); | 
 |  |  |             }  catch (Exception e) { | 
 |  |  |                 e.printStackTrace(); | 
 |  |  | 
 |  |  |             throw  new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"对不起,员工信息导入失败,请稍后重试!"); | 
 |  |  |         } | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     public static void main(String[] args) { | 
 |  |  |         System.out.println(PhoneUtil.isPhone("18156047603")); | 
 |  |  |     } | 
 |  |  |     private Member checkModelParam(MemberImport model, List<Member> newList | 
 |  |  |             ,int index | 
 |  |  |             ,LoginUserInfo loginUserInfo | 
 |  |  | 
 |  |  |     private Company findCompanyFromList(String companyName, List<Company> companyList) { | 
 |  |  |         if(companyList !=null){ | 
 |  |  |             for(Company company : companyList){ | 
 |  |  |                 if(StringUtils.equals(companyName,company.getName())){ | 
 |  |  |                 if(StringUtils.equals(companyName,company.getCompanyNamePath())){ | 
 |  |  |                     return  company; | 
 |  |  |                 } | 
 |  |  |             } | 
 |  |  | 
 |  |  |         } | 
 |  |  |         if(memberMapper.selectCount(new QueryWrapper<Member>().lambda() | 
 |  |  |                 .eq(Member::getIsdeleted,Constants.ZERO) | 
 |  |  |                 .ne(Member::getType,Constants.memberType.visitor) | 
 |  |  |                 .in(Member::getType,Constants.memberType.gkuser,Constants.memberType.visitor) | 
 |  |  |                 .eq(Member::getPhone,registerDriverDTO.getPhone()) | 
 |  |  |         )>Constants.ZERO){ | 
 |  |  |             throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"手机号已注册!"); | 
 |  |  | 
 |  |  |         }; | 
 |  |  |         smsEmailService.validateCode(registerDriverDTO.getValidCode(),registerDriverDTO.getPhone()); | 
 |  |  |         String salt = RandomStringUtils.randomAlphabetic(6); | 
 |  |  |        ; | 
 |  |  |  | 
 |  |  |         Member member = new Member(); | 
 |  |  |         member.setCreateDate(new Date()); | 
 |  |  |         member.setIsdeleted(Constants.ZERO); |