package com.ruoyi.member.service.impl.member;
|
|
import cn.binarywang.wx.miniapp.api.WxMaService;
|
import cn.binarywang.wx.miniapp.bean.WxMaJscode2SessionResult;
|
import cn.binarywang.wx.miniapp.bean.WxMaPhoneNumberInfo;
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.ruoyi.common.core.domain.R;
|
import com.ruoyi.common.core.exception.ServiceException;
|
import com.ruoyi.common.core.utils.uuid.IdUtils;
|
import com.ruoyi.common.security.utils.SecurityUtils;
|
import com.ruoyi.member.domain.dto.AppUserAuthorizeDto;
|
import com.ruoyi.member.domain.dto.MerCashMemberPageDto;
|
import com.ruoyi.member.domain.dto.MerMemberPageDto;
|
import com.ruoyi.member.domain.vo.*;
|
import com.ruoyi.member.mapper.member.MemberMapper;
|
import com.ruoyi.member.service.member.MemberService;
|
import com.ruoyi.member.util.HttpUtils;
|
import com.ruoyi.system.api.RemoteOrderService;
|
import com.ruoyi.system.api.RemoteShopService;
|
import com.ruoyi.system.api.RemoteUserService;
|
import com.ruoyi.system.api.constant.AppErrorConstant;
|
import com.ruoyi.system.api.constant.SecurityConstant;
|
import com.ruoyi.system.api.domain.dto.AppEditUserDto;
|
import com.ruoyi.system.api.domain.dto.AppMemberBindingDto;
|
import com.ruoyi.system.api.domain.poji.member.Member;
|
import com.ruoyi.system.api.domain.poji.shop.Shop;
|
import com.ruoyi.system.api.domain.poji.sys.SysUser;
|
import com.ruoyi.system.api.domain.vo.AppOrderTotalVo;
|
import com.ruoyi.system.api.domain.vo.MerHomeShopTotalVo;
|
import com.ruoyi.system.api.model.AppMiniLoginDto;
|
import com.ruoyi.system.api.model.AppMiniLoginVo;
|
import lombok.extern.log4j.Log4j;
|
import lombok.extern.log4j.Log4j2;
|
import lombok.val;
|
import com.ruoyi.common.core.utils.StringUtils;
|
import org.apache.http.HttpResponse;
|
import org.apache.http.client.HttpClient;
|
import org.apache.http.client.methods.HttpGet;
|
import org.apache.http.util.EntityUtils;
|
import org.springframework.data.redis.core.StringRedisTemplate;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
import java.util.*;
|
import java.util.concurrent.TimeUnit;
|
|
/**
|
* <p>
|
* 小程序用户 服务实现类
|
* </p>
|
*
|
* @author jqs
|
* @since 2023-04-25
|
*/
|
@Service
|
@Log4j2
|
public class MemberServiceImpl extends ServiceImpl<MemberMapper, Member> implements MemberService {
|
|
private static final String ACCESS_TOKEN_HOST = "https://api.weixin.qq.com/cgi-bin/token";
|
|
private static final String WX_APPID = "wxb7f0ea286fc4e535";
|
|
private static final String WX_SECRET = "852a2512a6ab559cafc68bae5d4160ac";
|
|
|
@Resource
|
private RemoteUserService sysUserService;
|
|
@Resource
|
private WxMaService wxMaService;
|
|
@Resource
|
private MemberMapper memberMapper;
|
|
@Resource
|
private StringRedisTemplate stringRedisTemplate;
|
|
@Resource
|
private RemoteShopService shopService;
|
|
@Resource
|
private RemoteOrderService orderService;
|
|
/**
|
* @description: TODO
|
* @author jqs34
|
* @date 2023/4/30 12:40
|
* @version 1.0
|
*/
|
@Override
|
public Member getByUserId(Long userId){
|
Member member = memberMapper.selectMemberByUserId(userId);
|
return member;
|
}
|
|
/**
|
*
|
* @param appMiniLoginDto
|
* @return
|
*/
|
@Override
|
public AppMiniLoginVo getMemberByCode(AppMiniLoginDto appMiniLoginDto){
|
|
AppMiniLoginVo appMiniLoginVo = new AppMiniLoginVo();
|
WxMaJscode2SessionResult session = null;
|
String unionid;
|
String openid;
|
String sessionKey = null;
|
//获取session
|
try {
|
session = wxMaService.getUserService().getSessionInfo(appMiniLoginDto.getCode());
|
} catch (Exception e) {
|
e.printStackTrace();
|
return null;
|
}
|
if(session!=null&& StringUtils.isNotBlank(session.getOpenid())){
|
unionid = session.getUnionid();
|
openid = session.getOpenid();
|
sessionKey = session.getSessionKey();
|
//获取用户
|
Member member = memberMapper.getOneByMiniOpenid(openid);
|
SysUser sysUser;
|
if(member==null){
|
//创建新用户
|
String memberId = IdUtils.simpleUUID();
|
sysUser = new SysUser();
|
sysUser.setUserName(memberId);
|
sysUser.setUserType("03");
|
sysUser.setNickName("微信用户");
|
String password = "hongruitang";
|
sysUser.setPassword(SecurityUtils.encryptPassword(password));
|
sysUser = sysUserService.registerUser(sysUser).getData();
|
log.info("sysUser1"+sysUser.toString());
|
member = new Member();
|
member.setUserId(sysUser.getUserId());
|
member.setDelFlag(0);
|
member.setMemberId(memberId);
|
member.setWxUnionid(unionid);
|
member.setMiniOpenid(openid);
|
member.setBindingFlag(0);
|
member.setCreateTime(new Date());
|
this.save(member);
|
|
}else{
|
log.info("member2"+member.toString());
|
R<SysUser> sysUser1 = sysUserService.getSysUser(member.getUserId());
|
log.info("sysUser1"+ sysUser1.getCode() + " : " + sysUser1.getMsg());
|
sysUser = sysUser1.getData();
|
log.info("sysUser"+sysUser.toString());
|
}
|
appMiniLoginVo.setMiniOpenid(openid);
|
appMiniLoginVo.setWxUnionid(unionid);
|
appMiniLoginVo.setSysUser(sysUser);
|
appMiniLoginVo.setSessionKey(sessionKey);
|
stringRedisTemplate.opsForValue().set(SecurityConstant.SESSION_KEY+openid,sessionKey);
|
}else{
|
log.info("null");
|
return null;
|
}
|
log.info("appMiniLoginVo"+appMiniLoginVo.toString());
|
return appMiniLoginVo;
|
}
|
|
/**
|
* 获取授权信息
|
* @param appUserAuthorizeDto
|
* @return
|
*/
|
@Override
|
public AppUserAuthorizeVo getAppUserAuthorize(AppUserAuthorizeDto appUserAuthorizeDto){
|
Member member = this.getById(appUserAuthorizeDto.getUserId());
|
AppUserAuthorizeVo appUserAuthorizeVo = new AppUserAuthorizeVo();
|
//获取code接口在redis里存放的sessionkey用于解密
|
String sessionkey = stringRedisTemplate.opsForValue().get(SecurityConstant.SESSION_KEY+ member.getMiniOpenid());
|
if(StringUtils.isBlank(sessionkey)){
|
throw new ServiceException(AppErrorConstant.USER_NOT_LOGIN);
|
}
|
String mobile = null;
|
try {
|
//解密微信加密用户信息和手机号
|
/*WxMaPhoneNumberInfo wxPhoneInfo;
|
if(StringUtils.isNotBlank(appUserAuthorizeDto.getPhoneEncryptedData())&&StringUtils.isNotBlank(appUserAuthorizeDto.getPhoneIv())){
|
wxPhoneInfo = wxMaService.getUserService().getPhoneNoInfo(sessionkey, appUserAuthorizeDto.getPhoneEncryptedData(), appUserAuthorizeDto.getPhoneIv());
|
}else{
|
throw new ServiceException(AppErrorConstant.AUTHORIZE_MISS);
|
}
|
if(StringUtils.isBlank(wxPhoneInfo.getPhoneNumber())){
|
throw new ServiceException(AppErrorConstant.AUTHORIZE_FAILED);
|
}
|
mobile = wxPhoneInfo.getPhoneNumber();*/
|
String accessToken = stringRedisTemplate.opsForValue().get("wx_access_token");
|
if (StringUtils.isBlank(accessToken)) {
|
String responseAccessToken = getAccessTokenByWX();
|
JSONObject jsonAccessToken = JSONObject.parseObject(responseAccessToken);
|
accessToken = jsonAccessToken.getString("access_token");
|
String errmsg = jsonAccessToken.getString("errmsg");
|
Long expiresIn = jsonAccessToken.getLong("expires_in");
|
if (StringUtils.isBlank(accessToken)) {
|
throw new ServiceException(errmsg);
|
} else {
|
expiresIn = expiresIn - 100;
|
stringRedisTemplate.opsForValue().set("wx_access_token", accessToken, expiresIn.intValue(), TimeUnit.SECONDS);
|
}
|
}
|
String responseUserPhoneNumber = getMobileByWX(accessToken, appUserAuthorizeDto.getMobileCode());
|
JSONObject jsonUserPhoneNumber = JSONObject.parseObject(responseUserPhoneNumber);
|
String errcode = jsonUserPhoneNumber.getString("errcode");
|
String errmsg = jsonUserPhoneNumber.getString("errmsg");
|
if (!errcode.equals("0")) {
|
throw new ServiceException(errmsg);
|
}
|
String phoneInfo = jsonUserPhoneNumber.getString("phone_info");
|
JSONObject jsonUserPhoneInfo = JSONObject.parseObject(phoneInfo);
|
mobile = jsonUserPhoneInfo.getString("purePhoneNumber");
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
//更新用户手机信息
|
SysUser sysUser = new SysUser();
|
sysUser.setUserId(appUserAuthorizeDto.getUserId());
|
sysUser.setPhonenumber(mobile);
|
sysUserService.updateUserMobile(sysUser);
|
member.setMobile(mobile);
|
member.setRealName(sysUser.getNickName());
|
this.saveOrUpdate(member);
|
appUserAuthorizeVo.setMobile(mobile);
|
appUserAuthorizeVo.setNickName(sysUser.getNickName());
|
appUserAuthorizeVo.setOpenid(member.getMiniOpenid());
|
appUserAuthorizeVo.setUnionid(member.getWxUnionid());
|
return appUserAuthorizeVo;
|
}
|
|
public static String getAccessTokenByWX() throws Exception {
|
String host = ACCESS_TOKEN_HOST + "?appid=" + WX_APPID + "&secret=" + WX_SECRET + "&grant_type=client_credential";
|
Map<String, String> headers = new HashMap<>(8);
|
HttpResponse response = HttpUtils.doGet(host, "", "GET", headers, null);
|
return EntityUtils.toString(response.getEntity());
|
}
|
|
public static String getMobileByWX(String accessToken, String code) throws Exception {
|
String method = "POST";
|
Map<String, String> headers = new HashMap<>(16);
|
headers.put("Content-Type", "application/json");
|
headers.put("Accept", "application/json");
|
Map<String, String> querys = new HashMap<>(16);
|
Map<String, String> bodys = new HashMap<>(16);
|
querys.put("access_token", accessToken );
|
bodys.put("code", code);
|
String body = JSONObject.toJSONString(bodys);
|
String host = "https://api.weixin.qq.com/wxa/business/getuserphonenumber";
|
HttpResponse response = HttpUtils.doPost(host, "", "POST", headers, querys, body);
|
return EntityUtils.toString(response.getEntity());
|
}
|
|
/**
|
* 获取用户信息
|
* @param userId
|
* @return
|
*/
|
@Override
|
public AppUserInfoVo getAppUserInfo(Long userId){
|
AppUserInfoVo appUserInfoVo = new AppUserInfoVo();
|
SysUser sysUser = sysUserService.getSysUser(userId).getData();
|
Member member = this.getByUserId(userId);
|
appUserInfoVo.setUserId(userId);
|
appUserInfoVo.setRelationShopId(member.getRelationShopId());
|
appUserInfoVo.setMemberNo(member.getMemberNo());
|
appUserInfoVo.setNickName(sysUser.getNickName());
|
appUserInfoVo.setPhonenumber(sysUser.getPhonenumber());
|
if(member.getRelationShopId()!=null){
|
Shop shop = shopService.getShop(member.getRelationShopId()).getData();
|
appUserInfoVo.setShopName(shop.getShopName());
|
}
|
appUserInfoVo.setBirthday(member.getBirthday());
|
appUserInfoVo.setGender(member.getGender());
|
appUserInfoVo.setAvatar(sysUser.getAvatar());
|
AppOrderTotalVo appOrderTotalVo = orderService.getAppOrderTotal(userId).getData();
|
appUserInfoVo.setNoPayCount(appOrderTotalVo.getNoPayCount());
|
appUserInfoVo.setNoUseCount(appOrderTotalVo.getNoUseCount());
|
return appUserInfoVo;
|
}
|
|
/**
|
* 修改用户信息
|
* @param appEditUserDto
|
*/
|
@Override
|
public void editAppUserInfo(AppEditUserDto appEditUserDto){
|
//修改类型1.昵称2.头像3.性别4.生日
|
Integer editType = appEditUserDto.getEditType();
|
String editValue = appEditUserDto.getEditValue();
|
Member member = this.getByUserId(appEditUserDto.getUserId());
|
switch (editType){
|
case 1:
|
member.setRealName(editValue);
|
member.setUpdateTime(new Date());
|
member.setUpdateUserId(appEditUserDto.getUserId());
|
this.saveOrUpdate(member);
|
break;
|
case 2:
|
break;
|
case 3:
|
member.setGender(Integer.valueOf(editValue));
|
member.setUpdateTime(new Date());
|
member.setUpdateUserId(appEditUserDto.getUserId());
|
this.saveOrUpdate(member);
|
break;
|
case 4:
|
member.setBirthday(editValue);
|
member.setUpdateTime(new Date());
|
member.setUpdateUserId(appEditUserDto.getUserId());
|
this.saveOrUpdate(member);
|
break;
|
default:
|
break;
|
}
|
sysUserService.editUserInfo(appEditUserDto);
|
}
|
|
/**
|
* 分页获取会员信息
|
* @param merMemberPageDto
|
* @return
|
*/
|
@Override
|
public List<MerMemberPageVo> pageMerMember(Page page, MerMemberPageDto merMemberPageDto){
|
List<MerMemberPageVo> merMemberPageVoList = memberMapper.pageMerMember(page,merMemberPageDto);
|
return merMemberPageVoList;
|
}
|
|
|
/**
|
* @description: TODO
|
* @author jqs34
|
* @date 2023/5/4 22:50
|
* @version 1.0
|
*/
|
@Override
|
public MerMemberInfoVo getMerMemberInfo(Long userId){
|
MerMemberInfoVo merMemberInfoVo = new MerMemberInfoVo();
|
SysUser sysUser = sysUserService.getSysUser(userId).getData();
|
Member member = this.getByUserId(userId);
|
merMemberInfoVo.setUserId(userId);
|
merMemberInfoVo.setNickName(sysUser.getNickName());
|
merMemberInfoVo.setPhonenumber(sysUser.getPhonenumber());
|
merMemberInfoVo.setAvatar(sysUser.getAvatar());
|
//未完成
|
|
return merMemberInfoVo;
|
}
|
|
/**
|
* 分页获取收银用户列表
|
* @param page
|
* @param merCashMemberPageDto
|
* @return
|
*/
|
@Override
|
public List<MerCashMemberPageVo> pageMerCashMember(Page page, MerCashMemberPageDto merCashMemberPageDto){
|
|
List<MerCashMemberPageVo> merCashMemberPageVos = memberMapper.pageMerCashMember(page,merCashMemberPageDto);
|
return merCashMemberPageVos;
|
}
|
|
/**
|
*
|
* @param appMemberBindingDto
|
*/
|
@Override
|
public void updateMemberBinding(AppMemberBindingDto appMemberBindingDto){
|
Member member = this.getByUserId(appMemberBindingDto.getUserId());
|
member.setBindingFlag(appMemberBindingDto.getBindingFlag());
|
member.setRelationShopId(appMemberBindingDto.getShopId());
|
this.saveOrUpdate(member);
|
}
|
}
|
