package com.fzzy.appwx.controller;
|
|
|
import com.fzzy.appwx.constant.WeChatConst;
|
import com.fzzy.appwx.manager.WeChatManager;
|
import com.fzzy.appwx.param.WeChatBaseParam;
|
import com.fzzy.igds.data.ConfigData;
|
import com.fzzy.igds.data.PageResponse;
|
import com.ruoyi.common.core.domain.entity.SysUser;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.stereotype.Controller;
|
import org.springframework.web.bind.annotation.*;
|
import org.springframework.web.servlet.ModelAndView;
|
|
import javax.annotation.Resource;
|
import java.net.URLEncoder;
|
|
@Slf4j
|
@Controller
|
@RequestMapping("/wx")
|
public class WeChatController {
|
|
@Resource
|
private ConfigData configData;
|
@Resource
|
private WeChatManager weChatManager;
|
|
|
/**
|
* 微信菜单重定向获取code
|
*
|
* @param tag
|
* @return
|
* @throws Exception
|
*/
|
@RequestMapping
|
public String redirect(
|
@RequestParam(value = "tag", required = false) String tag) throws Exception {
|
|
String url = configData.getWxServeUrl() + "/wx/view-gateway";
|
|
if (StringUtils.isEmpty(tag)) {
|
tag = "home";
|
}
|
//
|
String newUrl = WeChatConst.USER_AUTH_UPR
|
.replace("APPID", configData.getWxAppId())
|
.replace("REDIRECT_URI", URLEncoder.encode(url, "UTF-8"))
|
.replace("STATE", tag);
|
|
return "redirect:" + newUrl;
|
// return "redirect:" + url + "?state=" + tag;
|
}
|
|
|
/**
|
* 页面分发
|
*
|
* @param
|
* @return
|
*/
|
@RequestMapping("/view-gateway")
|
public ModelAndView viewGateway(
|
@RequestParam(value = "code", required = false) String code,
|
@RequestParam(value = "state") String state,
|
@RequestParam(value = "id", required = false) String id,
|
@RequestParam(value = "companyId", required = false) String companyId,
|
@RequestParam(value = "loginType", required = false) String loginType,
|
@RequestParam(value = "userName", required = false) String userName) {
|
|
ModelAndView mv = new ModelAndView();
|
|
//code不为空则获取openid
|
if (StringUtils.isNotEmpty(code)) {
|
String openid = weChatManager.getOpenid(code);
|
mv.addObject("openid", openid);
|
SysUser user = weChatManager.getUser(openid);
|
if (StringUtils.isEmpty(userName)) {
|
if (user != null) {
|
userName = user.getUserName();
|
}
|
}
|
|
}
|
|
if (StringUtils.isNotEmpty(id)) {
|
mv.addObject("id", id);
|
mv.addObject("companyId", companyId);
|
}
|
//判断是公众号还是APP,默认为公众号
|
if (StringUtils.isEmpty(loginType)) {
|
loginType = WeChatConst.LOGIN_TYPE_WECHAT;
|
}
|
mv.addObject("loginType", loginType);
|
|
if (StringUtils.isNotEmpty(userName)) {
|
mv.addObject("userName", userName);
|
}
|
mv.setViewName("/wx/" + state);
|
|
// //测试代码开启
|
// String openid = "testOpenId";
|
// mv.addObject("openid", openid);
|
// SysUser user = weChatManager.getUser(openid);
|
// if (StringUtils.isEmpty(userName)) {
|
// if (user != null) {
|
// userName = user.getUserName();
|
// }
|
// }
|
// //测试代码结束
|
|
return mv;
|
}
|
|
|
/**
|
* 获取用户的绑定信息
|
*
|
* @param param
|
* @author sgj
|
* @since 2026/04/11
|
*/
|
@PostMapping(value = "/getUserBindInfo")
|
@ResponseBody
|
public PageResponse<SysUser> getUserBindInfo( @RequestBody WeChatBaseParam param) {
|
return weChatManager.getUserBindInfo(param);
|
}
|
|
|
/**
|
* 绑定openId
|
*
|
* @param param
|
* @author sgj
|
* @since 2026/04/11
|
*/
|
@PostMapping(value = "/bandOpenId")
|
@ResponseBody
|
public PageResponse<String> bandOpenId( @RequestBody WeChatBaseParam param) {
|
return weChatManager.bandOpenId(param);
|
}
|
|
/**
|
* 解绑openId
|
*
|
* @param param
|
* @author sgj
|
* @since 2026/04/11
|
*/
|
@PostMapping(value = "/unBandOpenId")
|
@ResponseBody
|
public PageResponse<String> unBandOpenId( @RequestBody WeChatBaseParam param) {
|
return weChatManager.unBandOpenId(param);
|
}
|
|
}
|
