| | |
| | | |
| | | import cn.hutool.core.convert.Convert; |
| | | import cn.hutool.core.text.CharSequenceUtil; |
| | | import cn.hutool.crypto.SecureUtil; |
| | | import cn.hutool.crypto.digest.MD5; |
| | | import cn.lili.base.Result; |
| | | import cn.lili.cache.Cache; |
| | | import cn.lili.cache.CachePrefix; |
| | |
| | | import cn.lili.modules.connect.entity.dto.ConnectAuthUser; |
| | | import cn.lili.modules.connect.service.ConnectService; |
| | | import cn.lili.modules.lmk.domain.entity.VideoAccount; |
| | | import cn.lili.modules.lmk.domain.form.MemberTagForm; |
| | | import cn.lili.modules.lmk.service.MemberTagService; |
| | | import cn.lili.modules.lmk.service.VideoAccountService; |
| | | import cn.lili.modules.member.aop.annotation.PointLogPoint; |
| | | import cn.lili.modules.member.entity.dos.Member; |
| | |
| | | import cn.lili.mybatis.util.PageUtil; |
| | | import cn.lili.rocketmq.RocketmqSendCallbackBuilder; |
| | | import cn.lili.rocketmq.tags.MemberTagsEnum; |
| | | import cn.lili.utils.COSUtil; |
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
| | | import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; |
| | | import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; |
| | | import com.baomidou.mybatisplus.core.metadata.IPage; |
| | | import com.baomidou.mybatisplus.core.toolkit.CollectionUtils; |
| | | import com.baomidou.mybatisplus.core.toolkit.Wrappers; |
| | | import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
| | | import org.apache.catalina.security.SecurityUtil; |
| | | import org.apache.rocketmq.spring.core.RocketMQTemplate; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.context.ApplicationEventPublisher; |
| | |
| | | |
| | | @Autowired |
| | | private VideoAccountService videoAccountService; |
| | | |
| | | @Autowired |
| | | private MemberTagService memberTagService; |
| | | |
| | | @Autowired |
| | | private COSUtil cosUtil; |
| | | |
| | | @Override |
| | | public Member findByUsername(String userName) { |
| | |
| | | throw new ServiceException(ResultCode.USER_NOT_EXIST); |
| | | } |
| | | //判断密码是否输入正确 |
| | | |
| | | if (!new BCryptPasswordEncoder().matches(password, member.getPassword())) { |
| | | throw new ServiceException(ResultCode.USER_PASSWORD_ERROR); |
| | | } |
| | |
| | | |
| | | @Override |
| | | @Transactional |
| | | public Member autoRegister(ConnectAuthUser authUser) { |
| | | public Member autoRegister(ConnectAuthUser authUser,Boolean encryptTwice) { |
| | | |
| | | if (CharSequenceUtil.isEmpty(authUser.getNickname())) { |
| | | authUser.setNickname(CommonUtil.getSpecialStr("用户")); |
| | | } |
| | | if (CharSequenceUtil.isEmpty(authUser.getAvatar())) { |
| | | authUser.setAvatar("https://i.loli.net/2020/11/19/LyN6JF7zZRskdIe.png"); |
| | | authUser.setAvatar(""); |
| | | } |
| | | try { |
| | | // String username = UuidUtils.getUUID(); |
| | | Member member = new Member(authUser.getUsername(), UuidUtils.getUUID(), authUser.getAvatar(), authUser.getNickname(), |
| | | authUser.getGender() != null ? Convert.toInt(authUser.getGender().getCode()) : 0, authUser.getPhone()); |
| | | member.setPassword(DEFAULT_PASSWORD); |
| | | if(encryptTwice){ |
| | | member.setPassword( new BCryptPasswordEncoder().encode(SecureUtil.md5(DEFAULT_PASSWORD))); |
| | | }else { |
| | | member.setPassword( new BCryptPasswordEncoder().encode(DEFAULT_PASSWORD)); |
| | | } |
| | | member.setUuId(authUser.getUuid()); |
| | | // 发送会员注册信息 |
| | | registerHandler(member); |
| | |
| | | * @param member |
| | | */ |
| | | @Transactional |
| | | @Override |
| | | public void registerHandler(Member member) { |
| | | member.setId(SnowFlake.getIdStr()); |
| | | //保存会员 |
| | |
| | | } |
| | | |
| | | @Override |
| | | @Transactional |
| | | public Member updateMember(ManagerMemberEditDTO managerMemberEditDTO) { |
| | | //过滤会员昵称敏感词 |
| | | if (CharSequenceUtil.isNotBlank(managerMemberEditDTO.getNickName())) { |
| | |
| | | //传递修改会员信息 |
| | | BeanUtil.copyProperties(managerMemberEditDTO, member); |
| | | this.updateById(member); |
| | | if (managerMemberEditDTO.getTags() != null && !CollectionUtils.isEmpty(managerMemberEditDTO.getTags())) { |
| | | MemberTagForm memberTagForm = new MemberTagForm(); |
| | | memberTagForm.setMemberId(member.getId()); |
| | | memberTagForm.setTagIds(managerMemberEditDTO.getTags()); |
| | | memberTagForm.setCreateType("MANAGER"); |
| | | memberTagService.addMemberTag(memberTagForm); |
| | | } |
| | | return member; |
| | | } |
| | | |
| | | @Override |
| | | public Result resetPassword(String id) { |
| | | String password = "123456"; |
| | | String password = "111111"; |
| | | Member member = this.getById(id); |
| | | member.setPassword(new BCryptPasswordEncoder().encode(password)); |
| | | this.updateById(member); |
| | |
| | | |
| | | @Override |
| | | public MemberVO getMember(String id) { |
| | | return new MemberVO(this.getById(id)); |
| | | MemberVO member = baseMapper.getVoById(id); |
| | | if (Objects.nonNull(member)) { |
| | | member.setFace(cosUtil.getPreviewUrl(member.getFace())); |
| | | } |
| | | return member; |
| | | } |
| | | |
| | | @Override |
| | |
| | | } |
| | | } |
| | | |
| | | public static void main(String[] args) { |
| | | System.err.println(SecureUtil.md5("111111")); |
| | | } |
| | | |
| | | } |