sgj
6 小时以前 e9a9dcebfb754d39270945261e43736c798f4c47
fzzy-igdss-web/src/main/java/com/fzzy/appwx/controller/WeChatController.java
@@ -1,11 +1,15 @@
package com.fzzy.appwx.controller;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.fzzy.appwx.constant.WeChatConst;
import com.fzzy.appwx.manager.WeChatManager;
import com.fzzy.appwx.param.WeChatBaseParam;
import com.fzzy.group.manager.GroupManager;
import com.fzzy.igds.data.ConfigData;
import com.fzzy.igds.data.PageResponse;
import com.fzzy.igds.domain.Dept;
import com.fzzy.igds.domain.SnapReply;
import com.ruoyi.common.core.domain.entity.SysUser;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
@@ -14,7 +18,9 @@
import org.springframework.web.servlet.ModelAndView;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import java.net.URLEncoder;
import java.util.List;
@Slf4j
@Controller
@@ -25,6 +31,8 @@
    private ConfigData configData;
    @Resource
    private WeChatManager weChatManager;
    @Resource
    private GroupManager groupManager;
    /**
@@ -43,7 +51,7 @@
        if (StringUtils.isEmpty(tag)) {
            tag = "home";
        }
//
        String newUrl = WeChatConst.USER_AUTH_UPR
                .replace("APPID", configData.getWxAppId())
                .replace("REDIRECT_URI", URLEncoder.encode(url, "UTF-8"))
@@ -98,8 +106,18 @@
            mv.addObject("userName", userName);
        }
        mv.setViewName("/wx/" + state);
        //验证码类型
        if("bind".equals( state) || "unbind".equals( state)){
            mv.addObject("captchaType", "math");
        }
//        //测试代码开启
        //查询库区信息
        List<Dept> deptList = groupManager.getDeptList();
        mv.addObject("deptList", deptList);
////        //测试代码开启
//        String openid = "testOpenId";
//        mv.addObject("openid", openid);
//        SysUser user = weChatManager.getUser(openid);
@@ -108,7 +126,11 @@
//                userName = user.getUserName();
//            }
//        }
//        //测试代码结束
//
//        if (StringUtils.isNotEmpty(userName)) {
//            mv.addObject("userName", userName);
//        }
////        //测试代码结束
        return mv;
    }
@@ -137,8 +159,8 @@
     */
    @PostMapping(value = "/bandOpenId")
    @ResponseBody
    public PageResponse<String> bandOpenId(  @RequestBody WeChatBaseParam param) {
        return weChatManager.bandOpenId(param);
    public PageResponse<String> bandOpenId(HttpServletRequest httpRequest,  @RequestBody WeChatBaseParam param) {
        return weChatManager.bandOpenId(httpRequest,param);
    }
    /**
@@ -150,8 +172,52 @@
     */
    @PostMapping(value = "/unBandOpenId")
    @ResponseBody
    public PageResponse<String> unBandOpenId(  @RequestBody WeChatBaseParam param) {
        return weChatManager.unBandOpenId(param);
    public PageResponse<String> unBandOpenId( HttpServletRequest httpRequest, @RequestBody WeChatBaseParam param) {
        //在这里调用验证码校验
        return weChatManager.unBandOpenId(httpRequest,param);
    }
    /**
     * 获取出入库告警批复分页数据
     *
     * @param param
     * @author sgj
     * @since 2026/04/11
     */
    @PostMapping(value = "/getSnapReplyPage")
    @ResponseBody
    public PageResponse<Page<SnapReply>> getSnapReplyPage(@RequestBody WeChatBaseParam param) {
        return weChatManager.getSnapReplyPage(param);
    }
    /**
     * 根据id获取告警批复详细内容
     *
     * @param param
     * @author sgj
     * @since 2026/04/11
     */
    @PostMapping(value = "/getSnapReplyInfoById")
    @ResponseBody
    public PageResponse<SnapReply> getSnapReplyInfoById(@RequestBody WeChatBaseParam param) {
        return weChatManager.getSnapReplyInfoById(param);
    }
    /**
     * 根据id获取告警批复详细内容
     *
     * @param param
     * @author sgj
     * @since 2026/04/11
     */
    @PostMapping(value = "/handleSnapReply")
    @ResponseBody
    public PageResponse<String> handleSnapReply(@RequestBody WeChatBaseParam param) {
        return weChatManager.handleSnapReply(param);
    }
}