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;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.servlet.ModelAndView;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import java.util.List;

@Slf4j
@Controller
@RequestMapping("/wx")
public class WeChatController {

    @Resource
    private ConfigData configData;
    @Resource
    private WeChatManager weChatManager;
    @Resource
    private GroupManager groupManager;


    /**
     * 微信菜单重定向获取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);
        //验证码类型
        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);
        if (StringUtils.isEmpty(userName)) {
            if (user != null) {
                userName = user.getUserName();
            }
        }

        if (StringUtils.isNotEmpty(userName)) {
            mv.addObject("userName", userName);
        }
//        //测试代码结束

        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(HttpServletRequest httpRequest,  @RequestBody WeChatBaseParam param) {
        return weChatManager.bandOpenId(httpRequest,param);
    }

    /**
     * 解绑openId
     *
     * @param param
     * @author sgj
     * @since 2026/04/11
     */
    @PostMapping(value = "/unBandOpenId")
    @ResponseBody
    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);
    }

}