package com.doumee.service.business.impl; 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.Jwt.JwtPayLoad; import com.doumee.config.Jwt.JwtTokenUtil; import com.doumee.core.annotation.excel.ExcelImporter; import com.doumee.core.constants.ResponseStatus; import com.doumee.core.exception.BusinessException; import com.doumee.core.model.LoginUserInfo; import com.doumee.core.model.PageData; import com.doumee.core.model.PageWrap; import com.doumee.core.utils.Constants; import com.doumee.core.utils.HttpsUtil; import com.doumee.core.utils.Utils; 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.business.join.MemberJoinMapper; import com.doumee.dao.business.model.*; import com.doumee.dao.system.model.SystemUser; import com.doumee.dao.web.reqeust.CheckVisitedDTO; import com.doumee.dao.web.response.MemberVO; import com.doumee.dao.web.response.WxAuthorizeVO; import com.doumee.service.business.MemberService; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.github.yulichang.wrapper.MPJLambdaWrapper; import org.apache.commons.collections.CollectionUtils; import org.apache.commons.lang3.StringUtils; import org.apache.shiro.SecurityUtils; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.util.Date; import java.util.List; import java.util.Objects; /** * 人员信息表Service实现 * @author 江蹄蹄 * @date 2023/11/30 15:33 */ @Service public class MemberServiceImpl implements MemberService { @Autowired private MemberMapper memberMapper; @Autowired private MemberJoinMapper memberJoinMapper; @Autowired private TrainTimeMapper trainTimeMapper; @Autowired private SystemDictDataBiz systemDictDataBiz; @Override public Integer create(Member member) { memberMapper.insert(member); return member.getId(); } @Transactional @Override public Integer laborMemberCreate(LaborMemberDTO member) { LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); if (PhoneUtil.isPhone(member.getPhone())){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"电话号码格式有误"); } if (IdcardUtil.isValidCard(member.getIdcardNo())){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"身份证号格式有误"); } if (IdcardUtil.getGenderByIdCard(member.getIdcardNo()) == member.getSex()){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"性别有误"); } //获取出生日期 String birthByIdCard = IdcardUtil.getBirthByIdCard(member.getIdcardNo()); //脱敏操作 String hide = IdcardUtil.hide(member.getIdcardNo(), 5, 14); //转换日期 DateTime yyyyMMdd = DateUtil.parse(birthByIdCard, "yyyyMMdd"); Member insert = new Member(); insert.setCreator(loginUserInfo.getId()); insert.setCreateDate(new Date()); insert.setEditor(loginUserInfo.getId()); insert.setEditDate(new Date()); insert.setIsdeleted(Constants.ZERO); insert.setCompanyId(member.getCompanyId()); insert.setFaceImg(member.getFaceImg()); insert.setImgurl(member.getImgurl()); insert.setType(Constants.ZERO); insert.setName(member.getName()); insert.setBirthday(yyyyMMdd); insert.setPhone(member.getPhone()); insert.setIdcardNo(Utils.Secure.encryptString(member.getIdcardNo())); IdcardUtil.isValidCard(member.getIdcardNo()); insert.setIdcardDecode(hide); insert.setStatus(Constants.ZERO); insert.setParentId(member.getParentId()); memberMapper.insert(insert); TrainTime trainTime = new TrainTime(); trainTime.setCreator(loginUserInfo.getId().toString()); trainTime.setCreateDate(new Date()); trainTime.setEdirot(loginUserInfo.getId().toString()); trainTime.setEditDate(new Date()); trainTime.setIsdeleted(Constants.ZERO); trainTime.setMemberId(insert.getId()); trainTime.setStartTime(Utils.Date.getStart(member.getStartTime())); trainTime.setEndTime(Utils.Date.getDayEnd(member.getEndTime())); // trainTime.setImportStatus(); // trainTime.setImportInfo(); trainTimeMapper.insert(trainTime); return insert.getId(); } @Override public void deleteById(Integer id) { memberMapper.deleteById(id); } @Override public void delete(Member member) { UpdateWrapper deleteWrapper = new UpdateWrapper<>(member); memberMapper.delete(deleteWrapper); } @Override public void deleteByIdInBatch(List ids) { if (CollectionUtils.isEmpty(ids)) { return; } memberMapper.deleteBatchIds(ids); } @Override public void updateById(Member member) { memberMapper.updateById(member); } @Override public void updateStatusById(Member member) { LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); Member update = new Member(); update.setEditDate(new Date()); update.setEditor(loginUserInfo.getId()); update.setStatus(member.getStatus()); memberMapper.updateById(update); } @Override public void updateCanVisitById(Member member) { LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); Member update = new Member(); update.setEditDate(new Date()); update.setEditor(loginUserInfo.getId()); update.setCanVisit(member.getCanVisit()); memberMapper.updateById(update); } @Override public void updateByIdInBatch(List members) { if (CollectionUtils.isEmpty(members)) { return; } for (Member member: members) { this.updateById(member); } } @Override public Member findById(Integer id) { return memberMapper.selectById(id); } @Override public Member findOne(Member member) { QueryWrapper wrapper = new QueryWrapper<>(member); return memberMapper.selectOne(wrapper); } @Override public List findList(Member member) { QueryWrapper wrapper = new QueryWrapper<>(member); return memberMapper.selectList(wrapper); } @Override public PageData findPage(PageWrap pageWrap) { IPage page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); QueryWrapper queryWrapper = new QueryWrapper<>(); Utils.MP.blankToNull(pageWrap.getModel()); if (pageWrap.getModel().getId() != null) { queryWrapper.lambda().eq(Member::getId, pageWrap.getModel().getId()); } if (pageWrap.getModel().getCreator() != null) { queryWrapper.lambda().eq(Member::getCreator, pageWrap.getModel().getCreator()); } if (pageWrap.getModel().getCreateDate() != null) { queryWrapper.lambda().ge(Member::getCreateDate, Utils.Date.getStart(pageWrap.getModel().getCreateDate())); queryWrapper.lambda().le(Member::getCreateDate, Utils.Date.getEnd(pageWrap.getModel().getCreateDate())); } if (pageWrap.getModel().getEditor() != null) { queryWrapper.lambda().eq(Member::getEditor, pageWrap.getModel().getEditor()); } if (pageWrap.getModel().getEditDate() != null) { queryWrapper.lambda().ge(Member::getEditDate, Utils.Date.getStart(pageWrap.getModel().getEditDate())); queryWrapper.lambda().le(Member::getEditDate, Utils.Date.getEnd(pageWrap.getModel().getEditDate())); } if (pageWrap.getModel().getIsdeleted() != null) { queryWrapper.lambda().eq(Member::getIsdeleted, pageWrap.getModel().getIsdeleted()); } if (pageWrap.getModel().getRemark() != null) { queryWrapper.lambda().eq(Member::getRemark, pageWrap.getModel().getRemark()); } if (pageWrap.getModel().getCompanyId() != null) { queryWrapper.lambda().eq(Member::getCompanyId, pageWrap.getModel().getCompanyId()); } if (pageWrap.getModel().getFaceImg() != null) { queryWrapper.lambda().eq(Member::getFaceImg, pageWrap.getModel().getFaceImg()); } if (pageWrap.getModel().getImgurl() != null) { queryWrapper.lambda().eq(Member::getImgurl, pageWrap.getModel().getImgurl()); } if (pageWrap.getModel().getType() != null) { queryWrapper.lambda().eq(Member::getType, pageWrap.getModel().getType()); } if (pageWrap.getModel().getName() != null) { queryWrapper.lambda().eq(Member::getName, pageWrap.getModel().getName()); } if (pageWrap.getModel().getBirthday() != null) { queryWrapper.lambda().ge(Member::getBirthday, Utils.Date.getStart(pageWrap.getModel().getBirthday())); queryWrapper.lambda().le(Member::getBirthday, Utils.Date.getEnd(pageWrap.getModel().getBirthday())); } if (pageWrap.getModel().getPhone() != null) { queryWrapper.lambda().eq(Member::getPhone, pageWrap.getModel().getPhone()); } if (pageWrap.getModel().getIdcardNo() != null) { queryWrapper.lambda().eq(Member::getIdcardNo, pageWrap.getModel().getIdcardNo()); } if (pageWrap.getModel().getIdcardDecode() != null) { queryWrapper.lambda().eq(Member::getIdcardDecode, pageWrap.getModel().getIdcardDecode()); } if (pageWrap.getModel().getCode() != null) { queryWrapper.lambda().eq(Member::getCode, pageWrap.getModel().getCode()); } if (pageWrap.getModel().getClasses() != null) { queryWrapper.lambda().eq(Member::getClasses, pageWrap.getModel().getClasses()); } if (pageWrap.getModel().getStatus() != null) { queryWrapper.lambda().eq(Member::getStatus, pageWrap.getModel().getStatus()); } if (pageWrap.getModel().getParentId() != null) { queryWrapper.lambda().eq(Member::getParentId, pageWrap.getModel().getParentId()); } if (pageWrap.getModel().getOpenid() != null) { queryWrapper.lambda().eq(Member::getOpenid, pageWrap.getModel().getOpenid()); } if (pageWrap.getModel().getFsId() != null) { queryWrapper.lambda().eq(Member::getFsId, pageWrap.getModel().getFsId()); } if (pageWrap.getModel().getFsStatus() != null) { queryWrapper.lambda().eq(Member::getFsStatus, pageWrap.getModel().getFsStatus()); } if (pageWrap.getModel().getFsDate() != null) { queryWrapper.lambda().ge(Member::getFsDate, Utils.Date.getStart(pageWrap.getModel().getFsDate())); queryWrapper.lambda().le(Member::getFsDate, Utils.Date.getEnd(pageWrap.getModel().getFsDate())); } if (pageWrap.getModel().getHkId() != null) { queryWrapper.lambda().eq(Member::getHkId, pageWrap.getModel().getHkId()); } if (pageWrap.getModel().getHkStatus() != null) { queryWrapper.lambda().eq(Member::getHkStatus, pageWrap.getModel().getHkStatus()); } if (pageWrap.getModel().getHkDate() != null) { queryWrapper.lambda().ge(Member::getHkDate, Utils.Date.getStart(pageWrap.getModel().getHkDate())); queryWrapper.lambda().le(Member::getHkDate, Utils.Date.getEnd(pageWrap.getModel().getHkDate())); } if (pageWrap.getModel().getErpId() != null) { queryWrapper.lambda().eq(Member::getErpId, pageWrap.getModel().getErpId()); } if (pageWrap.getModel().getErpDate() != null) { queryWrapper.lambda().ge(Member::getErpDate, Utils.Date.getStart(pageWrap.getModel().getErpDate())); queryWrapper.lambda().le(Member::getErpDate, Utils.Date.getEnd(pageWrap.getModel().getErpDate())); } if (pageWrap.getModel().getErpStatus() != null) { queryWrapper.lambda().eq(Member::getErpStatus, pageWrap.getModel().getErpStatus()); } if (pageWrap.getModel().getDdId() != null) { queryWrapper.lambda().eq(Member::getDdId, pageWrap.getModel().getDdId()); } if (pageWrap.getModel().getDdDate() != null) { queryWrapper.lambda().ge(Member::getDdDate, Utils.Date.getStart(pageWrap.getModel().getDdDate())); queryWrapper.lambda().le(Member::getDdDate, Utils.Date.getEnd(pageWrap.getModel().getDdDate())); } if (pageWrap.getModel().getDdStatus() != null) { queryWrapper.lambda().eq(Member::getDdStatus, pageWrap.getModel().getDdStatus()); } if (pageWrap.getModel().getPassward() != null) { queryWrapper.lambda().eq(Member::getPassward, pageWrap.getModel().getPassward()); } if (pageWrap.getModel().getCanVisit() != null) { queryWrapper.lambda().eq(Member::getCanVisit, pageWrap.getModel().getCanVisit()); } if (pageWrap.getModel().getHighCheckor() != null) { queryWrapper.lambda().eq(Member::getHighCheckor, pageWrap.getModel().getHighCheckor()); } if (pageWrap.getModel().getRoleId() != null) { queryWrapper.lambda().eq(Member::getRoleId, pageWrap.getModel().getRoleId()); } if (pageWrap.getModel().getRoleDate() != null) { queryWrapper.lambda().ge(Member::getRoleDate, Utils.Date.getStart(pageWrap.getModel().getRoleDate())); queryWrapper.lambda().le(Member::getRoleDate, Utils.Date.getEnd(pageWrap.getModel().getRoleDate())); } if (pageWrap.getModel().getErpOrgId() != null) { queryWrapper.lambda().eq(Member::getErpOrgId, pageWrap.getModel().getErpOrgId()); } for(PageWrap.SortData sortData: pageWrap.getSorts()) { if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) { queryWrapper.orderByDesc(sortData.getProperty()); } else { queryWrapper.orderByAsc(sortData.getProperty()); } } return PageData.from(memberMapper.selectPage(page, queryWrapper)); } @Override public PageData findLaborMemberInfoPage(PageWrap pageWrap) { IPage page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); MPJLambdaWrapper queryWrapper = new MPJLambdaWrapper<>(); MemberInfoDTO model = pageWrap.getModel(); Utils.MP.blankToNull(model); 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"); 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(pageWrap.getModel().getTrainTimeEndTime()!=null,"trainTimeEndTime < "+ DateUtil.format(end,"yyyy-MM-dd HH:mm:ss")); IPage memberIPage = memberJoinMapper.selectJoinPage(page, MemberInfoDTO.class,queryWrapper); if (!CollectionUtils.isEmpty(memberIPage.getRecords())){ memberIPage.getRecords().forEach(s->s.setSex(IdcardUtil.getGenderByIdCard(s.getIdcardDecode()))); } return PageData.from(memberIPage); } @Override public long count(Member member) { QueryWrapper wrapper = new QueryWrapper<>(member); return memberMapper.selectCount(wrapper); } @Override public void importMemberBatch(LaborEmpowerDTO laborEmpowerDTO) { try { ExcelImporter ie = new ExcelImporter(laborEmpowerDTO.getFile(),0,0); List dataList = ie.getDataList(LaborEmpowerDTO.LaborMemberEmpower.class,null); if (CollectionUtils.isEmpty(dataList)){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"文件无数据记录"); } } catch (Exception e) { } // } @Override public PageData findMemberInfoPage(PageWrap 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 page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); MPJLambdaWrapper 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()); IPage memberIPage = memberJoinMapper.selectJoinPage(page, MemberInfoDTO.class,queryWrapper); if (!CollectionUtils.isEmpty(memberIPage.getRecords())){ memberIPage.getRecords().forEach(s->s.setSex(IdcardUtil.getGenderByIdCard(s.getIdcardDecode()))); }*/ IPage memberIPage = memberMapper.getPage(pageWrap.toPage(),new QueryWrapper() .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") ); return PageData.from(memberIPage); } /********************************************公众号接口***********************************************************************/ /** * 微信授权接口 * @param code * @return */ @Override public WxAuthorizeVO wxAuthorize(String code){ String appId = systemDictDataBiz.queryByCode(Constants.WX_PLATFORM,Constants.WX_PLATFORM_APPID).getCode(); String appSecret = systemDictDataBiz.queryByCode(Constants.WX_PLATFORM,Constants.WX_PLATFORM_SECRET).getCode(); String getTokenUrl = WXConstant.GET_USER_INFO_URL.replace("CODE", code) .replace("APPID", appId).replace("SECRET", appSecret); JSONObject tokenJson = JSONObject.parseObject(HttpsUtil.get(getTokenUrl,true)); String openId = null; if(!Objects.isNull(tokenJson.get("access_token"))){ openId = tokenJson.getString("openid"); } WxAuthorizeVO wxAuthorizeVO = new WxAuthorizeVO(); wxAuthorizeVO.setOpenid(openId); return wxAuthorizeVO; } @Override public MemberVO getVisitedMember(CheckVisitedDTO checkVisitedDTO){ Integer validType = Integer.valueOf(systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.BEVISITED_USER_VALID).getCode()); if(Objects.isNull(checkVisitedDTO)||StringUtils.isBlank(checkVisitedDTO.getMobile())||(validType.equals(Constants.ONE)&&StringUtils.isBlank(checkVisitedDTO.getName()))){ throw new BusinessException(ResponseStatus.BAD_REQUEST); } Member member = memberMapper.selectOne(new QueryWrapper().lambda() .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::getCanVisit,Constants.ONE) .eq(Member::getType,Constants.memberType.internal) .last(" limit 1 ") ); MemberVO memberVO = new MemberVO(); BeanUtils.copyProperties(member,memberVO); return memberVO; } }