| | |
| | | package com.doumee.service.business.impl; |
| | | |
| | | import cn.hutool.core.date.DateTime; |
| | | import cn.hutool.core.date.DateUtil; |
| | | import cn.hutool.core.util.IdcardUtil; |
| | | import cn.hutool.core.util.PhoneUtil; |
| | | import com.alibaba.fastjson.JSONObject; |
| | | 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.doumee.biz.system.SystemDictDataBiz; |
| | | import com.doumee.config.DataSyncConfig; |
| | | import com.doumee.config.Jwt.JwtPayLoad; |
| | |
| | | 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.DESUtil; |
| | | import com.doumee.core.utils.HttpsUtil; |
| | | import com.doumee.core.utils.Utils; |
| | | import com.doumee.core.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.admin.response.StagingDataVO; |
| | | import com.doumee.dao.business.*; |
| | | import com.doumee.dao.business.dao.CompanyMapper; |
| | |
| | | import com.doumee.dao.business.join.UserActionJoinMapper; |
| | | import com.doumee.dao.business.model.*; |
| | | import com.doumee.dao.system.SystemUserMapper; |
| | | import com.doumee.dao.system.model.SystemDepartment; |
| | | import com.doumee.dao.system.model.SystemDepartmentUser; |
| | | import com.doumee.dao.system.model.SystemDictData; |
| | | import com.doumee.dao.system.model.SystemUser; |
| | | import com.doumee.dao.web.reqeust.AccountLoginDTO; |
| | |
| | | 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.doumee.service.business.impl.hksync.HkSyncEmpowerServiceImpl; |
| | | import com.doumee.service.business.impl.hksync.ferp.HkSyncOrgUserToHKServiceImpl; |
| | | import com.github.yulichang.wrapper.MPJLambdaWrapper; |
| | |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | | |
| | | import java.util.Date; |
| | | import java.util.*; |
| | | import java.util.stream.Collectors; |
| | | |
| | |
| | | insert.setCode(member.getCode()); |
| | | insert.setType(Constants.TWO); |
| | | insert.setHkDate(new Date()); |
| | | insert.setWorkStatus(Constants.ONE);//é»è®¤å¨è |
| | | insert.setCanVisit(Constants.ZERO);//é»è®¤ä¸å¯è®¿é® |
| | | insert.setAuthStatus(Constants.ZERO); |
| | | insert.setName(member.getName()); |
| | | insert.setHkStatus(Constants.ONE); |
| | | insert.setSex(IdcardUtil.getGenderByIdCard(member.getIdcardNo()) ==1?Constants.TWO:Constants.ONE);//æ ¹æ®èº«ä»½è¯å·è·åæ§å« |
| | | insert.setBirthday( DateUtil.parse(IdcardUtil.getBirthByIdCard(member.getIdcardNo()), "yyyyMMdd")); |
| | | insert.setSex(Constants.getSexByCardNo( member.getIdcardNo()));//æ ¹æ®èº«ä»½è¯å·è·åæ§å« |
| | | insert.setBirthday( DateUtil.fromStringToDate("yyyyMMdd",IdcardUtil.getBirthByIdCard(member.getIdcardNo()))); |
| | | insert.setPhone(member.getPhone()); |
| | | insert.setIdcardNo(DESUtil.encrypt(Constants.EDS_PWD, member.getIdcardNo()));//身份è¯å·å å¯ |
| | | insert.setIdcardDecode( Constants.getTuominStr(member.getIdcardNo())); |
| | |
| | | } |
| | | return false; |
| | | } |
| | | private boolean dealHkUserForUpdateBiz(Member update ) { |
| | | String path = systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_RESOURCE_PATH).getCode() |
| | | +systemDictDataBiz.queryByCode(Constants.FTP,Constants.MEMBER_IMG).getCode(); |
| | | |
| | | UserAddRequest hkAddRequest = HkSyncOrgUserToHKServiceImpl.getUserAddModel(update,path,Constants.ONE); |
| | | |
| | | //å¤çæ°å¢æ°æ® |
| | | BaseResponse<UserAddResponse> result = HKService.editUser(hkAddRequest); |
| | | if(result!=null && StringUtils.equals(result.getCode(),HKConstants.RESPONSE_SUCCEE) ){ |
| | | update.setHkStatus(Constants.ONE);//已忥 |
| | | update.setRemark("人åä¿¡æ¯å·²åæ¥æå"); |
| | | if(StringUtils.isNotBlank(update.getFaceImg()) && Constants.equalsInteger(update.getFaceStatus(),Constants.ZERO)){ |
| | | //妿æäººè¸ç
§çï¼å¤ç人è¸ç
§ç忥 |
| | | String faceid = HkSyncOrgUserToHKServiceImpl.dealMemberFace(update,path); |
| | | if(StringUtils.isBlank(faceid)){ |
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对ä¸èµ·ï¼å工人è¸ä¿¡æ¯ä¸åæ ¼ï¼è¯·æ´æ¢äººè¸ç
§çéè¯ï¼"); |
| | | }else{ |
| | | update.setFaceId(faceid); |
| | | update.setFaceStatus(Constants.ONE); |
| | | //å¦æäººè¸è·ä½ ï¼éæ°ä¸åæéæ°æ® |
| | | update.setRemark("人åå人è¸ä¿¡æ¯åæ¥æå"+result.getMsg()); |
| | | //éæ°ææè®¾å¤æé |
| | | // HkSyncOrgUserToHKServiceImpl.dealMemberRoleEmpowerDo(null,update,deviceRoleMapper,empowerMapper,deviceMapper); |
| | | } |
| | | } |
| | | update.setHkDate(update.getEditDate()); |
| | | return true; |
| | | }else if(result!=null ){ |
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对ä¸èµ·ï¼åæ¥å®é²å¹³å°å¤±è´¥ã"+result.getMsg()+"ãï¼è¯·è系管çåï¼"); |
| | | } |
| | | return false; |
| | | } |
| | | |
| | | /** |
| | | * æ¸
é¤åå·¥çè®¾å¤æé |
| | | * @param member |
| | | */ |
| | | private void cancelAllMemberEmpower(Member member) { |
| | | //å é¤å
¨é¨æé |
| | | memberRoleMapper.update(null,new UpdateWrapper<MemberRole>().lambda() |
| | | .eq(MemberRole::getMemberId,member.getId()) |
| | | .set(MemberRole::getIsdeleted,Constants.ONE) |
| | | .set(MemberRole::getEdirot,member.getEditor()) |
| | | .set(MemberRole::getEditDate,member.getEditDate())); |
| | | //æææå¾
ä¸åç任塿¹æ 已忶 |
| | | empowerMapper.update(null,new UpdateWrapper<Empower>().lambda() |
| | | .eq(Empower::getMemberId,member.getId()) |
| | | .eq(Empower::getIsdeleted,Constants.ZERO) |
| | | .eq(Empower::getSendStatus,Constants.EmpowerStatus.wait) |
| | | .set(Empower::getIsdeleted,Constants.ONE) |
| | | .set(Empower::getSendStatus,Constants.EmpowerStatus.cancel)); |
| | | //ææä¸åè¿çä»»å¡ï¼æ¹ä¸ºå¾
å 餿é |
| | | empowerMapper.update(null,new UpdateWrapper<Empower>().lambda() |
| | | .eq(Empower::getMemberId,member.getId()) |
| | | .set(Empower::getIsdeleted,Constants.ONE) |
| | | .notIn(Empower::getSendStatus,Constants.EmpowerStatus.fail) |
| | | .set(Empower::getRemark,"çå¾
忥å é¤å®é²å¹³å°") |
| | | .eq(Empower::getIsdeleted,Constants.ZERO) |
| | | .eq(Empower::getIsdeleted,Constants.ZERO) |
| | | .set(Empower::getSendStatus,Constants.ZERO)); |
| | | } |
| | | |
| | | private void isMemberParamValid(Member member) { |
| | | if (!PhoneUtil.isPhone(member.getPhone())){ |
| | | if (StringUtils.isBlank(member.getPhone())||!PhoneUtil.isPhone(member.getPhone())){ |
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"çµè¯å·ç æ ¼å¼æè¯¯"); |
| | | } |
| | | if (!IdcardUtil.isValidCard(member.getIdcardNo())){ |
| | | if (StringUtils.isBlank(member.getIdcardNo())||!IdcardUtil.isValidCard(member.getIdcardNo())){ |
| | | if(memberMapper.selectCount(new QueryWrapper<Member>().lambda() |
| | | .eq(Member::getIdcardNo,DESUtil.encrypt(Constants.EDS_PWD, member.getIdcardNo())) |
| | | .eq(Member::getIsdeleted,Constants.ZERO) |
| | | .ne(Member::getId,member.getId())) >0){ |
| | | throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(), "身份è¯å·ã"+member.getIdcardNo()+"ã已被使ç¨ï¼ä¸è½éå¤"); |
| | | } |
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"身份è¯å·æ ¼å¼æè¯¯"); |
| | | } |
| | | |
| | | SystemUser systemUser = new SystemUser(); |
| | | SystemUser queryUserDto = new SystemUser(); |
| | | queryUserDto.setUsername(member.getPhone()); |
| | | queryUserDto.setDeleted(Boolean.FALSE); |
| | | SystemUser user = systemUserMapper.selectOne(new QueryWrapper<>(queryUserDto).last("limit 1")); |
| | | if (user != null) { |
| | | throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(), "ææºå·ã"+systemUser.getUsername()+"ã已被使ç¨ï¼ä¸è½éå¤"); |
| | | throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(), "ææºå·ã"+queryUserDto.getUsername()+"ã已被使ç¨ï¼ä¸è½éå¤"); |
| | | } |
| | | // éªè¯å·¥å· |
| | | if (StringUtils.isNotBlank(member.getCode())) { |
| | |
| | | throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(), "å·¥å·ã"+member.getCode()+"ãå·²åå¨"); |
| | | } |
| | | } |
| | | } |
| | | private Member isMemberUpdateParamValid(Member member) { |
| | | Member model = memberMapper.selectById(member.getId()); |
| | | if(model ==null ||Constants.equalsInteger(member.getIsdeleted(),Constants.ONE)){ |
| | | throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"对ä¸èµ·ï¼è¯¥å工信æ¯ä¸åå¨ï¼è¯·å·æ°é¡µé¢éè¯ï¼"); |
| | | } |
| | | if (StringUtils.isNotBlank(member.getPhone()) && !PhoneUtil.isPhone(member.getPhone())){ |
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"çµè¯å·ç æ ¼å¼æè¯¯"); |
| | | } |
| | | if (StringUtils.isNotBlank(member.getIdcardNoNew())){ |
| | | String encrptNo = (DESUtil.encrypt(Constants.EDS_PWD, member.getIdcardNoNew()));//身份è¯å·å å¯ |
| | | if( !StringUtils.equals(model.getIdcardNo(),encrptNo)&& !IdcardUtil.isValidCard(member.getIdcardNoNew())){ |
| | | //妿åçæ¹åï¼å¹¶ä¸ä¸åæ³ï¼æç¤ºå¼å¸¸ |
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"ä¿®æ¹çæ°èº«ä»½è¯å·æ ¼å¼æè¯¯"); |
| | | } |
| | | if( !StringUtils.equals(model.getIdcardNo(),encrptNo) ){ |
| | | if(memberMapper.selectCount(new QueryWrapper<Member>().lambda() |
| | | .eq(Member::getIdcardNo,encrptNo) |
| | | .eq(Member::getIsdeleted,Constants.ZERO) |
| | | .ne(Member::getId,member.getId())) >0){ |
| | | throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(), "身份è¯å·ã"+member.getIdcardNoNew()+"ã已被使ç¨ï¼ä¸è½éå¤"); |
| | | } |
| | | |
| | | member.setSex(Constants.getSexByCardNo( member.getIdcardNoNew()));//æ ¹æ®èº«ä»½è¯å·è·åæ§å« |
| | | member.setIdcardDecode( Constants.getTuominStr(member.getIdcardNoNew())); |
| | | member.setIdcardNo(encrptNo); |
| | | } |
| | | } |
| | | boolean isNeedUpdateUser = false; |
| | | if(StringUtils.isNotBlank(member.getPhone()) && StringUtils.equals(member.getPhone(),model.getPhone())){ |
| | | // å¦æææºå·åçä¿®æ¹ï¼æ ¡éªå¯ä¸æ§ |
| | | SystemUser queryUserDto = new SystemUser(); |
| | | queryUserDto.setUsername(member.getPhone()); |
| | | queryUserDto.setDeleted(Boolean.FALSE); |
| | | SystemUser user = systemUserMapper.selectOne(new QueryWrapper<SystemUser>(queryUserDto).lambda() |
| | | .ne(SystemUser::getMemberId,model.getId()).last("limit 1")); |
| | | if (user != null) { |
| | | throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(), "ææºå·ã" + queryUserDto.getUsername() + "ã已被使ç¨ï¼ä¸è½éå¤"); |
| | | } |
| | | isNeedUpdateUser = true; |
| | | } |
| | | if(StringUtils.isNotBlank(member.getCode()) && StringUtils.equals(member.getPhone(),model.getCode())){ |
| | | // éªè¯å·¥å· |
| | | SystemUser queryUserDto = new SystemUser(); |
| | | queryUserDto = new SystemUser(); |
| | | queryUserDto.setDeleted(Boolean.FALSE); |
| | | queryUserDto.setEmpNo(member.getCode()); |
| | | SystemUser user = systemUserMapper.selectOne(new QueryWrapper<SystemUser>(queryUserDto).lambda() |
| | | .ne(SystemUser::getMemberId,model.getId()).last("limit 1")); |
| | | if (user != null) { |
| | | throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(), "å·¥å·ã"+member.getCode()+"ãå·²åå¨"); |
| | | } |
| | | isNeedUpdateUser = true; |
| | | } |
| | | if(member.getCompanyId()!=null && !Constants.equalsInteger(member.getCompanyId(),model.getCompanyId())){ |
| | | //妿ç»ç»åçåå |
| | | Company company = companyMapper.selectById(member.getCompanyId()); |
| | | if(company == null || Constants.equalsInteger(company.getIsdeleted(),Constants.ONE)){ |
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对ä¸èµ·ï¼è¯¥ç»ç»ä¿¡æ¯å·²è¢«å é¤ï¼è¯·å·æ°é¡µé¢éè¯ï¼"); |
| | | } |
| | | if(StringUtils.isBlank(company.getHkId())){ |
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对ä¸èµ·ï¼è¯¥ç»ç»ä¿¡æ¯æªåæ¥å®é²å¹³å°ï¼è¯·å
åå¾ãç»ç»ç®¡çãèåè¿è¡ç»´æ¤ï¼"); |
| | | } |
| | | member.setHkOrgId(company.getHkId()); |
| | | isNeedUpdateUser = true; |
| | | } |
| | | if(isNeedUpdateUser){ |
| | | //æ´æ°ç³»ç»ç¨æ·è´¦å·ä¿¡æ¯ |
| | | systemUserMapper.update(null,new UpdateWrapper<SystemUser>().lambda() |
| | | .set(SystemUser::getUpdateUser,member.getLoginUserInfo().getId()) |
| | | .set(SystemUser::getUpdateTime,new Date()) |
| | | .set(StringUtils.isNotBlank(model.getPhone()),SystemUser::getMobile,member.getPhone()) |
| | | .set(StringUtils.isNotBlank(model.getName()),SystemUser::getRealname,member.getName()) |
| | | .set(model.getCompanyId() !=null,SystemUser::getCompanyId,member.getCompanyId()) |
| | | .set(StringUtils.isNotBlank(model.getCode()),SystemUser::getEmpNo,member.getCode()) |
| | | .eq(SystemUser::getMemberId,model.getId())); |
| | | } |
| | | member.setHkId(model.getHkId()); |
| | | member.setFaceId(model.getFaceId());//人è¸ç¼ç |
| | | return model; |
| | | } |
| | | |
| | | @Transactional |
| | |
| | | //è±ææä½ |
| | | 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.setImgurl(member.getImgurl()); |
| | | insert.setType(Constants.ZERO); |
| | | insert.setName(member.getName()); |
| | | insert.setBirthday(yyyyMMdd); |
| | | insert.setBirthday(DateUtil.fromStringToDate("yyyyMMdd",birthByIdCard)); |
| | | insert.setPhone(member.getPhone()); |
| | | insert.setIdcardNo(Utils.Secure.encryptString(member.getIdcardNo())); |
| | | IdcardUtil.isValidCard(member.getIdcardNo()); |
| | |
| | | } |
| | | |
| | | @Override |
| | | public void deleteById(Integer id) { |
| | | public void deleteById(Integer id,LoginUserInfo user) { |
| | | LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); |
| | | |
| | | Member member=new Member(); |
| | |
| | | member.setIsdeleted(Constants.ZERO); |
| | | member.setEditor(loginUserInfo.getId()); |
| | | member.setEditDate(new Date()); |
| | | member.setHkStatus(Constants.ZERO); |
| | | member.setRemark("人åå·²å é¤ï¼çå¾
å é¤é¨ç¦æé"); |
| | | memberMapper.updateById(member); |
| | | saveUserActionBiz(member,loginUserInfo,Constants.UserActionType.DELETE,userActionJoinMapper); |
| | | } |
| | | |
| | | |
| | |
| | | } |
| | | |
| | | @Override |
| | | public void deleteByIdInBatch(List<Integer> ids) { |
| | | @Transactional(rollbackFor = {BusinessException.class,Exception.class}) |
| | | public void deleteByIdInBatch(List<Integer> ids,LoginUserInfo loginUserInfo) { |
| | | if (CollectionUtils.isEmpty(ids)) { |
| | | return; |
| | | } |
| | | LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); |
| | | Member member=new Member(); |
| | | ids.stream().forEach(s ->{ |
| | | member.setId(s); |
| | | member.setIsdeleted(Constants.ONE); |
| | | member.setHkStatus(Constants.ZERO); |
| | | member.setRemark("人åå·²å é¤ï¼çå¾
å é¤é¨ç¦æé"); |
| | | member.setEditor(loginUserInfo.getId()); |
| | | member.setEditDate(new Date()); |
| | | memberMapper.updateById(member); |
| | | |
| | | UserAction userAction=new UserAction(); |
| | | userAction.setIsdeleted(Constants.ZERO); |
| | | userAction.setCreateDate(new Date()); |
| | | userAction.setCreator(loginUserInfo.getId()); |
| | | userAction.setType(9); |
| | | userAction.setRemark("ç±ã"+loginUserInfo.getUsername()+"ãäºãæä½æ¶é´"+DateUtil.format(new Date(),"yyyy-MM-dd HH:mm:ss")+"ãï¼è¿è¡ãå é¤ã"); |
| | | userAction.setMemberId(s+""); |
| | | userActionJoinMapper.insert(userAction); |
| | | |
| | | saveUserActionBiz(member,loginUserInfo,Constants.UserActionType.DELETE,userActionJoinMapper); |
| | | }); |
| | | |
| | | |
| | | |
| | | |
| | | |
| | | /* memberMapper.deleteBatchIds(ids);*/ |
| | | } |
| | | |
| | | /** |
| | | * æé»æè
å»ç»åå·¥ä¿¡æ¯ |
| | | * @param ids |
| | | * @param type |
| | | * @param loginUserInfo |
| | | */ |
| | | @Override |
| | | public void batchBlock(List<Integer> ids,Integer type) { |
| | | @Transactional(rollbackFor = {BusinessException.class,Exception.class}) |
| | | public void batchBlock(List<Integer> ids,Integer type,LoginUserInfo loginUserInfo) { |
| | | if (CollectionUtils.isEmpty(ids)) { |
| | | return; |
| | | } |
| | | LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); |
| | | Member member=new Member(); |
| | | for (Integer id:ids) { |
| | | member = memberMapper.selectById(id); |
| | | Member 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()); |
| | | member.setAuthStatus(Constants.ZERO);//æªææ |
| | | memberMapper.updateById(member); |
| | | Date date = new Date(); |
| | | member.setEditDate(date); |
| | | member.setEditor(loginUserInfo.getId()); |
| | | //å é¤åå·¥é¨ç¦æé |
| | | cancelAllMemberEmpower(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")+"ãï¼è¿è¡ãå»ç»ã"); |
| | | saveUserActionBiz(member,loginUserInfo,Constants.UserActionType.FREEZE,userActionJoinMapper); |
| | | } |
| | | 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); |
| | | saveUserActionBiz(member,loginUserInfo,Constants.UserActionType.BLACKLIST,userActionJoinMapper); |
| | | } |
| | | } |
| | | /* memberMapper.deleteBatchIds(ids);*/ |
| | | } |
| | | } |
| | | /** |
| | | * æé»æè
å»ç»åå·¥ä¿¡æ¯ |
| | | * @param ids |
| | | * @param type |
| | | * @param loginUserInfo |
| | | */ |
| | | @Override |
| | | @Transactional(rollbackFor = {BusinessException.class,Exception.class}) |
| | | public void batchRemoveBlock(List<Integer> ids,Integer type,LoginUserInfo loginUserInfo) { |
| | | if (CollectionUtils.isEmpty(ids)) { |
| | | return; |
| | | } |
| | | for (Integer id:ids) { |
| | | Member member = memberMapper.selectById(id); |
| | | if(!Objects.isNull(member)&&member.getStatus()==Constants.ZERO){ |
| | | member.setStatus(Constants.ONE);//æ¢å¤æ£å¸¸ç¶æ |
| | | member.setEditor(loginUserInfo.getId()); |
| | | member.setEditDate(new Date()); |
| | | member.setAuthStatus(Constants.ZERO);//æªææ |
| | | memberMapper.updateById(member); |
| | | Date date = new Date(); |
| | | member.setEditDate(date); |
| | | member.setEditor(loginUserInfo.getId()); |
| | | if(Constants.equalsInteger(type,Constants.ONE)){ |
| | | saveUserActionBiz(member,loginUserInfo,Constants.UserActionType.CANCEL_FREEZE,userActionJoinMapper); |
| | | } |
| | | if(Constants.equalsInteger(type,Constants.TWO)){ |
| | | saveUserActionBiz(member,loginUserInfo,Constants.UserActionType.CANCEL_BLACKLIST,userActionJoinMapper); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | | @Override |
| | | public void updateById(Member member) { |
| | | memberMapper.updateById(member); |
| | | @Transactional(rollbackFor = {BusinessException.class,Exception.class}) |
| | | public void updateById(Member updateMember) { |
| | | LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); |
| | | if(loginUserInfo == null){ |
| | | loginUserInfo = updateMember.getLoginUserInfo(); |
| | | } |
| | | //æ ¡éªåæ° å¹¶ä¸æ´æ°systemuser ææºå·åå·¥å·ä¿¡æ¯ï¼å¦æéè¦ä¿®æ¹çè¯ï¼ |
| | | Member model = isMemberUpdateParamValid(updateMember); |
| | | updateMember.setEditor(loginUserInfo.getId()); |
| | | updateMember.setEditDate(new Date()); |
| | | //æµ·åº·äººåæ°å¢ä¸å¡ |
| | | if(dealHkUserForUpdateBiz(updateMember)){ |
| | | updateMember.setHkId(null); |
| | | updateMember.setAuthStatus(Constants.ZERO); |
| | | memberMapper.update(null,new UpdateWrapper<Member>().lambda() |
| | | .set(Member::getStartTime,null) |
| | | .set(Member::getEndTime,null) |
| | | .set(StringUtils.isNotBlank(updateMember.getPhone()),Member::getPhone,updateMember.getPhone()) |
| | | .set(StringUtils.isNotBlank(updateMember.getName()),Member::getName,updateMember.getName()) |
| | | .set(Member::getEditDate,updateMember.getEditDate()) |
| | | .set(Member::getEditor,updateMember.getEditor()) |
| | | .set(StringUtils.isNotBlank(updateMember.getIdcardNo()),Member::getIdcardNo,updateMember.getIdcardNo()) |
| | | .set(StringUtils.isNotBlank(updateMember.getIdcardDecode()),Member::getIdcardDecode,updateMember.getIdcardDecode()) |
| | | .set(updateMember.getAuthStatus()!=null,Member::getAuthStatus,updateMember.getAuthStatus()) |
| | | .set(updateMember.getHkStatus()!=null,Member::getHkStatus,updateMember.getHkStatus()) |
| | | .set(updateMember.getSex()!=null,Member::getSex,updateMember.getSex()) |
| | | .set(updateMember.getFaceStatus()!=null,Member::getFaceStatus,updateMember.getFaceStatus()) |
| | | .set(updateMember.getHkDate()!=null,Member::getHkDate,updateMember.getHkDate()) |
| | | .set(StringUtils.isNotBlank(updateMember.getRemark()),Member::getRemark,updateMember.getRemark()) |
| | | .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()) |
| | | .eq(Member::getId,updateMember.getId())); |
| | | cancelAllMemberEmpower(updateMember); |
| | | //è®°å½æä½æ¥å¿ |
| | | saveUserActionBiz(updateMember,loginUserInfo,Constants.UserActionType.EDIT,userActionJoinMapper); |
| | | }else{ |
| | | throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"对ä¸èµ·ï¼å工信æ¯åæ¥å®é²å¹³å°å¤±è´¥ï¼è¯·ç¨åéè¯ï¼"); |
| | | } |
| | | } |
| | | |
| | | private void saveUserActionBiz(Member updateMember,LoginUserInfo user, Constants.UserActionType type,UserActionJoinMapper userActionMapper) { |
| | | UserAction userAction=new UserAction(); |
| | | userAction.setIsdeleted(Constants.ZERO); |
| | | userAction.setCreateDate(updateMember.getEditDate()); |
| | | userAction.setCreator(updateMember.getEditor()); |
| | | userAction.setType(type.getKey()); |
| | | String info = type.getInfo(); |
| | | userAction.setRemark(info.replace("${param1}",user!=null?user.getRealname():"").replace("${param2}", com.doumee.core.utils.DateUtil.getPlusTime2(updateMember.getEditDate()))); |
| | | userAction.setMemberId(updateMember.getId()+""); |
| | | userActionMapper.insert(userAction); |
| | | } |
| | | |
| | | @Override |
| | | public boolean updateFace(Member member) { |
| | | QueryWrapper<Member> wrapper = new QueryWrapper<>(member); |
| | |
| | | } |
| | | HkSyncEmpowerServiceImpl.doHkDeleteUser(model.getId(),model.getHkId(),new Date(),memberMapper,memberCardMapper); |
| | | } |
| | | @Override |
| | | public void updateHead(Member member) { |
| | | Member model =memberMapper.selectById(member.getId()); |
| | | if(model ==null) { |
| | | throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"对ä¸èµ·ï¼äººåä¿¡æ¯ä¸åå¨ï¼"); |
| | | } |
| | | if(model.getCompanyId()!=null) { |
| | | if(Constants.equalsObject(member.getHeadStatus(),Constants.ONE)){ |
| | | //妿æ¯åæ¶ä¸»ç®¡ |
| | | companyMapper.update(null,new UpdateWrapper<Company>().lambda() |
| | | .eq(Company::getId,model.getCompanyId()) |
| | | .set(Company::getHeadId,member.getId())); |
| | | }else{ |
| | | //妿æ¯è®¾ä¸ºä¸»ç®¡ |
| | | companyMapper.update(null,new UpdateWrapper<Company>().lambda() |
| | | .eq(Company::getId,model.getCompanyId()) |
| | | .set(Company::getHeadId,null) |
| | | ); |
| | | } |
| | | } |
| | | } |
| | | |
| | | @Override |
| | | public void updateStatusById(Member member) { |
| | | Member model =memberMapper.selectById(member.getId()); |
| | | if(model ==null) { |
| | | throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"对ä¸èµ·ï¼äººåä¿¡æ¯ä¸åå¨ï¼"); |
| | | } |
| | | LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); |
| | | if(loginUserInfo == null){ |
| | | loginUserInfo = member.getLoginUserInfo(); |
| | | } |
| | | Member update = new Member(); |
| | | update.setEditDate(new Date()); |
| | | update.setEditor(loginUserInfo.getId()); |
| | | update.setStatus(member.getStatus()); |
| | | memberMapper.updateById(update); |
| | | } |
| | | |
| | | |
| | | @Override |
| | | public void updateVisitsStatusById(Member member) { |
| | | @Transactional(rollbackFor = {BusinessException.class,Exception.class}) |
| | | public void updateWorkStatus(Member member) { |
| | | Member model =memberMapper.selectById(member.getId()); |
| | | if(model ==null) { |
| | | throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"对ä¸èµ·ï¼äººåä¿¡æ¯ä¸åå¨ï¼"); |
| | | } |
| | | LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); |
| | | Member result=memberMapper.selectById(member.getId()); |
| | | Integer status=result.getStatus(); |
| | | if(loginUserInfo == null){ |
| | | loginUserInfo = member.getLoginUserInfo(); |
| | | } |
| | | Member update = new Member(); |
| | | update.setId(member.getId()); |
| | | update.setEditDate(new Date()); |
| | | update.setEditor(loginUserInfo.getId()); |
| | | update.setStatus(Constants.Status.FREEZE.getValue()); |
| | | update.setId(member.getId()); |
| | | update.setWorkStatus(Constants.equalsInteger(member.getWorkStatus(),Constants.ONE)?Constants.ONE:Constants.ZERO); |
| | | if(Constants.equalsInteger(member.getWorkStatus(),Constants.ONE)){ |
| | | //妿æ¯ç¦»è |
| | | cancelAllMemberEmpower(update); |
| | | } |
| | | update.setAuthStatus(Constants.ZERO); |
| | | 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")+"ãï¼è¿è¡ãå»ç»ã"); |
| | | //è®°å½æä½æ¥å¿ |
| | | saveUserActionBiz(member,loginUserInfo,Constants.equalsInteger(member.getWorkStatus(),Constants.ONE)?Constants.UserActionType.WORK_OFF:Constants.UserActionType.WORK_ON,userActionJoinMapper); |
| | | } |
| | | 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); |
| | | |
| | | //è§£å»ä¸å¡ å¤çç¨æ·ææå¯¼å
¥è®°å½ |
| | | 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); |
| | | userAction.setBeforeStatus(Constants.ONE); |
| | | } |
| | | if(Constants.equalsInteger(result.getType(),Constants.ONE)){ |
| | | userAction.setBeforeStatus(status); |
| | | userAction.setType(Constants.TWO); |
| | | } |
| | | userAction.setMemberId(result.getId()+""); |
| | | userActionJoinMapper.insert(userAction); |
| | | }); |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | | @Override |
| | | @Transactional(rollbackFor = {BusinessException.class,Exception.class}) |
| | | public void updateCanVisitById(Member member) { |
| | | LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); |
| | | if(loginUserInfo == null){ |
| | | loginUserInfo = member.getLoginUserInfo(); |
| | | } |
| | | Member model =memberMapper.selectById(member.getId()); |
| | | if(model ==null) { |
| | | throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"对ä¸èµ·ï¼äººåä¿¡æ¯ä¸åå¨ï¼"); |
| | | } |
| | | if(Constants.equalsInteger(member.getCanVisit(),model.getCanVisit())){ |
| | | //å¦ææ²¡æåçååï¼ç´æ¥è¿å |
| | | return; |
| | | } |
| | | Member update = new Member(); |
| | | update.setEditDate(new Date()); |
| | | update.setId(member.getId()); |
| | | update.setEditor(loginUserInfo.getId()); |
| | | update.setCanVisit(member.getCanVisit()); |
| | | memberMapper.updateById(update); |
| | | //è®°å½æä½æ¥å¿ |
| | | saveUserActionBiz(member,loginUserInfo,Constants.equalsInteger(member.getCanVisit(),Constants.ONE)?Constants.UserActionType.CANVISIT:Constants.UserActionType.CANCEL_VISIT,userActionJoinMapper); |
| | | } |
| | | |
| | | @Override |
| | |
| | | MPJLambdaWrapper<Member> queryWrapper = new MPJLambdaWrapper<>(); |
| | | queryWrapper.leftJoin(Company.class,Company::getId,Member::getCompanyId); |
| | | queryWrapper.selectAll(Member.class) |
| | | .selectAs(Company::getName,MemberInfoDTO::getCompanyName) |
| | | .selectAs(Company::getLinkName,MemberInfoDTO::getLinkName); |
| | | .selectAs(Company::getName,Member::getCompanyName) ; |
| | | |
| | | if(null != member.getType()) { |
| | | queryWrapper.eq(Member::getType,member.getType()); |
| | |
| | | } |
| | | |
| | | @Override |
| | | public PageData<MemberInfoDTO> findLaborMemberInfoPage(PageWrap<MemberInfoDTO> pageWrap) { |
| | | IPage<Member> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); |
| | | MPJLambdaWrapper<Member> 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(" (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(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()) ==1?Constants.TWO:Constants.ONE)); |
| | | } |
| | | return PageData.from(memberIPage); |
| | | } |
| | | |
| | | @Override |
| | | public long count(Member member) { |
| | | QueryWrapper<Member> wrapper = new QueryWrapper<Member>(member); |
| | | wrapper.lambda().like(StringUtils.isNotBlank(member.getRoleIdParam()), Member::getRoleId, member.getRoleIdParam()); |
| | |
| | | } |
| | | |
| | | @Override |
| | | public PageData<MemberInfoDTO> findMemberInfoPage(PageWrap<MemberQuery> pageWrap) { |
| | | public PageData<Member> findMemberInfoPage(PageWrap<MemberQuery> pageWrap) { |
| | | IPage<Member> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); |
| | | MPJLambdaWrapper<Member> queryWrapper = new MPJLambdaWrapper<>(); |
| | | |
| | | queryWrapper.selectAll(Member.class); |
| | | queryWrapper.selectAs(Company::getName,Member::getCompanyName); |
| | | queryWrapper.selectAs(SystemUser::getRealname,Member::getEditorName); |
| | | queryWrapper.selectAs(Company::getType,Member::getCompanyType); |
| | | queryWrapper.selectAs(Company::getHeadId,Member::getHeadId); |
| | | queryWrapper.selectAs(Company::getCompanyNamePath,Member::getCompanyNamePath); |
| | | queryWrapper.selectAs(Company::getCompanyPath,Member::getCompanyPath); |
| | | queryWrapper.select(" ( select count(1) from member_card mc where mc.isdeleted = 0 and mc.member_id = t.id ) as memberCardCount "); |
| | | queryWrapper.leftJoin(SystemUser.class,SystemUser::getId,Member::getEditor); |
| | | queryWrapper.leftJoin(Company.class,Company::getId,Member::getCompanyId); |
| | | queryWrapper.eq(Member::getType,pageWrap.getModel().getType()); |
| | | // queryWrapper.eq(Objects.nonNull(model.getCompanyId()),Member::getCompanyId,model.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 |
| | |
| | | .eq(Objects.nonNull(pageWrap.getModel().getIsdeleted()),Member::getIsdeleted,pageWrap.getModel().getIsdeleted()) |
| | | .like(StringUtils.isNotBlank(pageWrap.getModel().getCompanyName()),Company::getName,pageWrap.getModel().getCompanyName()) |
| | | // .eq(Member::getStatus,Constants.Status.ENABLE.getValue()) |
| | | .eq(Member::getType,Constants.memberType.internal) |
| | | // .eq(Member::getType,Constants.memberType.internal) |
| | | .eq(pageWrap.getModel().getHkStatus()!=null,Member::getHkStatus,pageWrap.getModel().getHkStatus()) |
| | | .orderByDesc(!Constants.equalsObject(pageWrap.getModel().getIsdeleted(),Constants.ONE),Member::getCreateDate) |
| | | .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()); |
| | | }else{ |
| | | queryWrapper.eq(StringUtils.isNotBlank(pageWrap.getModel().getCompanyId()),Member::getCompanyId,pageWrap.getModel().getCompanyId()); |
| | | // queryWrapper.eq(StringUtils.isNotBlank(pageWrap.getModel().getCompanyId()),Member::getCompanyId,pageWrap.getModel().getCompanyId()); |
| | | } |
| | | IPage<MemberInfoDTO> memberIPage = memberJoinMapper.selectJoinPage(page, MemberInfoDTO.class,queryWrapper); |
| | | if(pageWrap.getModel().getCompanyId()!=null){ |
| | | if(pageWrap.getModel().getIncludeChild()!=null &&pageWrap.getModel().getIncludeChild() ){ |
| | | //妿å
å«ä¸çº§ç»ç» |
| | | Company company = companyMapper.selectById(pageWrap.getModel().getCompanyId());//æ¥è¯¢ç»ç»ä¿¡æ¯ |
| | | queryWrapper.likeRight(Company::getCompanyPath,company.getCompanyPath()); |
| | | }else{ |
| | | //ä¸å
å«ä¸çº§ç»ç» |
| | | queryWrapper.eq(Company::getId,pageWrap.getModel().getCompanyId()); |
| | | } |
| | | } |
| | | IPage<Member> memberIPage = memberJoinMapper.selectJoinPage(page, Member.class,queryWrapper); |
| | | |
| | | if(CollectionUtils.isNotEmpty(memberIPage.getRecords())){ |
| | | //FTPæä»¶è®¿é®åç¼ |
| | |
| | | List<DeviceRole> deviceRoleList = deviceRoleMapper.selectList(new QueryWrapper<DeviceRole>().lambda() |
| | | .select(DeviceRole::getId,DeviceRole::getName) |
| | | .eq(DeviceRole::getIsdeleted,Constants.ZERO)); |
| | | for (MemberInfoDTO memberInfoDTO:memberIPage.getRecords()) { |
| | | for (Member memberInfoDTO:memberIPage.getRecords()) { |
| | | //è·å¾é¨ç¦ç»åç§°æ°ç» |
| | | memberInfoDTO.setCanVisit(Constants.formatIntegerNum(memberInfoDTO.getCanVisit())); |
| | | memberInfoDTO.setWorkStatus(Constants.formatIntegerNum(memberInfoDTO.getWorkStatus())); |
| | | memberInfoDTO.setHeadStatus(Constants.equalsInteger(memberInfoDTO.getHeadId(),memberInfoDTO.getId())?Constants.ONE:Constants.ZERO); |
| | | memberInfoDTO.setRoleNames(this.dealRoleDatas(memberInfoDTO.getRoleId(),deviceRoleList)); |
| | | //æ¼æ¥åç¼ |
| | | if(StringUtils.isNotBlank(memberInfoDTO.getFaceImg())){ |
| | |
| | | } |
| | | |
| | | @Override |
| | | public PageData<MemberInfoDTO> findVisitPage(PageWrap<MemberQuery> pageWrap) { |
| | | public PageData<Member> 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) |
| | | .selectAs(Company::getName,Member::getCompanyName) |
| | | .selectAs(Member::getLastVisitDate,Member::getLastVisitDate) |
| | | .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()) |
| | |
| | | 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()); |
| | | queryWrapper.eq((pageWrap.getModel().getCompanyId())!=null,Member::getCompanyId,pageWrap.getModel().getCompanyId()); |
| | | } |
| | | IPage<MemberInfoDTO> memberIPage = memberJoinMapper.selectJoinPage(page, MemberInfoDTO.class,queryWrapper); |
| | | IPage<Member> memberIPage = memberJoinMapper.selectJoinPage(page, Member.class,queryWrapper); |
| | | return PageData.from(memberIPage); |
| | | |
| | | } |
| | | |
| | | |
| | | @Override |
| | | public PageData<MemberInfoDTO> findUnusualPage(PageWrap<MemberQuery> pageWrap) { |
| | | public PageData<Member> 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) |
| | | .selectAs(Company::getName,Member::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") |
| | |
| | | .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((pageWrap.getModel().getCompanyId())!=null,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); |
| | | IPage<Member> memberIPage = memberJoinMapper.selectJoinPage(page, Member.class,queryWrapper); |
| | | return PageData.from(memberIPage); |
| | | |
| | | } |
| | |
| | | return; |
| | | } |
| | | List<Integer> memberIds = memberList.stream().map(m->m.getId()).collect(Collectors.toList()); |
| | | |
| | | Date date = new Date(); |
| | | for (Integer id:memberIds) { |
| | | UserAction userAction=new UserAction(); |
| | | userAction.setIsdeleted(Constants.ZERO); |
| | | userAction.setCreateDate(new Date()); |
| | | userAction.setType(1); |
| | | userAction.setRemark("ç±å®æ¶ä»»å¡äºãæä½æ¶é´"+DateUtil.format(new Date(),"yyyy-MM-dd HH:mm:ss")+"ãï¼è¿è¡ãå»ç»ã"); |
| | | userAction.setMemberId(id+""); |
| | | userActionJoinMapper.insert(userAction); |
| | | Member updateMember = new Member(); |
| | | updateMember.setId(id); |
| | | updateMember.setEditDate(date); |
| | | saveUserActionBiz(updateMember,null,Constants.UserActionType.FREEZE,userActionJoinMapper); |
| | | } |
| | | |
| | | |