package com.fzzy.appwx.manager;
|
|
import com.fzzy.appwx.param.WeChatBaseParam;
|
import com.fzzy.appwx.util.WeChatUtil;
|
import com.fzzy.igds.constant.RespCodeEnum;
|
import com.fzzy.igds.data.PageResponse;
|
import com.ruoyi.common.core.domain.entity.SysUser;
|
import com.ruoyi.system.service.ISysUserService;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
@Component
|
public class WeChatManager {
|
|
@Autowired
|
private WeChatUtil weChatUtil;
|
@Autowired
|
private ISysUserService sysUserService;
|
|
|
public String getOpenid(String code) {
|
//根据code获取用户openid
|
return weChatUtil.getOpenid(code);
|
}
|
|
|
public SysUser getUser(String openid) {
|
//根据openid获取用户信息
|
return sysUserService.selectUserByOpenId(openid);
|
}
|
|
//获取用户绑定信息
|
public PageResponse<SysUser> getUserBindInfo(WeChatBaseParam param) {
|
//判断参数
|
if (null == param) {
|
return new PageResponse<SysUser>(RespCodeEnum.CODE_1007.getCode(), "参数不完整，请核查");
|
}
|
|
SysUser user = null;
|
|
//微信公众号
|
if (StringUtils.isEmpty(param.getOpenid())) {
|
return new PageResponse<SysUser>(RespCodeEnum.CODE_1007.getCode(), "参数不完整，请核查");
|
|
}
|
//根据openid查询用户是否已经绑定
|
user = sysUserService.selectUserByOpenId(param.getOpenid());
|
if (user == null) {
|
return new PageResponse<SysUser>(RespCodeEnum.CODE_1008.getCode(), "业务数据返回为空");
|
|
}
|
|
Long deptId = user.getDeptId();
|
if (deptId == null) {
|
deptId = Long.valueOf(user.getCompanyId());
|
user.setDeptId(deptId);
|
}
|
return new PageResponse(RespCodeEnum.CODE_0000.getCode(), "查询成功",user);
|
}
|
|
//绑定openId
|
public PageResponse<String> bandOpenId(WeChatBaseParam param) {
|
|
//判断参数
|
if (null == param || StringUtils.isEmpty(param.getOpenid())) {
|
return new PageResponse<String>(RespCodeEnum.CODE_1007.getCode(), "参数不完整，请核查");
|
|
}
|
if (StringUtils.isEmpty(param.getMobile())) {
|
return new PageResponse<String>(RespCodeEnum.CODE_1007.getCode(), "手机号为空，请填写");
|
|
}
|
// if (StringUtils.isEmpty(param.getMsgCode())) {
|
// return new PageResponse<String>(RespCodeEnum.CODE_1007.getCode(), "验证码不能为空");
|
//
|
// }
|
//
|
// String code = (String) redisService.getCacheObject(WeChatConst.WX_MOBILE_CODE + param.getMobile());
|
// if(StringUtils.isEmpty(code)){
|
// res.put("code","1007");
|
// res.put("msg","验证码已失效，请重新获取");
|
// return res;
|
// }
|
// if(! code.equals(param.getMsgCode())){
|
// res.put("code","1007");
|
// res.put("msg","验证码错误");
|
// return res;
|
// }
|
|
//根据手机号查看用户是否是系统用户
|
SysUser user = sysUserService.selectUserByPhoneNumber(param.getMobile());
|
if(user == null || StringUtils.isEmpty(user.getPhonenumber())){
|
return new PageResponse<String>(RespCodeEnum.CODE_1006.getCode(), "手机号不在系统内，请联系管理员！");
|
}
|
|
//更新数据库，用户信息加入微信认证ID
|
user.setOpenId(param.getOpenid());
|
sysUserService.updateUserInfo(user);
|
|
// redisService.deleteObject(WeChatConst.WX_MOBILE_CODE + param.getMobile());
|
|
return new PageResponse<String>(RespCodeEnum.CODE_0000.getCode(), "请求成功");
|
|
}
|
|
|
//解绑openId
|
public PageResponse<String> unBandOpenId(WeChatBaseParam param) {
|
|
//判断参数
|
if (null == param || StringUtils.isEmpty(param.getOpenid())) {
|
return new PageResponse<String>(RespCodeEnum.CODE_1007.getCode(), "参数不完整，请核查");
|
|
}
|
if (StringUtils.isEmpty(param.getMobile())) {
|
return new PageResponse<String>(RespCodeEnum.CODE_1007.getCode(), "手机号为空，请填写");
|
}
|
if (StringUtils.isEmpty(param.getMsgCode())) {
|
return new PageResponse<String>(RespCodeEnum.CODE_1007.getCode(), "验证码不能为空");
|
|
}
|
|
// String code = (String) redisService.getCacheObject(WeChatConst.WX_MOBILE_CODE + param.getMobile());
|
// if(StringUtils.isEmpty(code)){
|
// res.put("code","1007");
|
// res.put("msg","验证码已失效，请重新获取");
|
// return res;
|
//
|
// }
|
// if(! code.equals(param.getMsgCode())){
|
// res.put("code","1007");
|
// res.put("msg","验证码错误");
|
// return res;
|
// }
|
|
//根据手机号查询用户是否已经绑定
|
SysUser user = sysUserService.selectUserByPhoneNumber(param.getMobile());
|
if(user == null || StringUtils.isEmpty(user.getPhonenumber())){
|
return new PageResponse<String>(RespCodeEnum.CODE_1006.getCode(), "手机号不在系统内，请联系管理员！");
|
|
}
|
|
user.setOpenId("");
|
sysUserService.updateUserInfo(user);
|
|
// redisService.deleteObject(WeChatConst.WX_MOBILE_CODE + param.getMobile());
|
|
return new PageResponse<String>(RespCodeEnum.CODE_0000.getCode(), "请求成功");
|
|
}
|
|
}
|
