package com.iplatform.base;

import com.fasterxml.jackson.databind.node.ObjectNode;
import com.iplatform.base.util.NotificationUtils;
import com.iplatform.base.util.RestTemplateUtils;
import com.iplatform.core.BeanContextAware;
import com.iplatform.model.vo.NotificationTemplateVo;
import com.iplatform.model.vo.WeChatAccessTokenVo;
import com.walker.infrastructure.arguments.Variable;
import com.walker.infrastructure.utils.StringUtils;
import com.walker.push.Notification;
import org.springframework.web.client.RestTemplate;

import java.text.MessageFormat;
import java.util.List;

public abstract class WechatBaseController extends PlatformAdapterController{

//    public void setRestTemplate(RestTemplate restTemplate) {
//        this.restTemplate = restTemplate;
//    }
//    private RestTemplate restTemplate;

    /**
     * 平台统一根据模板，发送提醒通知。
     * @param mark 通知标识，如：发货、订单等，从：sf_notification 表查询
     * @param variableList 业务数据，key，value
     * @param userId 用户ID
     * @date 2023-08-25
     */
    protected void pushNotificationWithTemplate(String mark, List<Variable> variableList, long userId){
        if(StringUtils.isEmpty(mark)){
            throw new IllegalArgumentException("必须输入通知模板标记：mark");
        }
        if(StringUtils.isEmptyList(variableList)){
            throw new IllegalArgumentException("必须输入推送消息业务数据：variableList");
        }
        NotificationTemplateVo templateVo = this.getNotificationTemplateCache().get(mark);
        if(templateVo == null){
            logger.error("通知模板缓存不存在，mark={}", mark);
            return;
        }

        // 1:存在微信公众号推送方式
        if(templateVo.getWechat()){
            String openId = this.getUser(userId).getWx_open_id();
            if(StringUtils.isEmpty(openId)){
                logger.error("用户openId为空，无法发送微信公众号通知, userId={}", userId);
                return;
            }
            String accessToken = this.acquirePublicAccessToken();
            if(StringUtils.isEmpty(accessToken)){
                logger.error("推送公众号消息失败，accessToken获取为空，mark={}, userId={}", mark, userId);
                return;
            }

            Notification notification = NotificationUtils.acquireWechatNotification(accessToken
                    , templateVo.getWechatTempId(), openId, variableList);
            this.getPushManager().push(notification, null);
        }

        // 2:存在短信推送
        if(templateVo.getSms()){
            String userPhone = this.getUser(userId).getPhonenumber();
            if(StringUtils.isEmpty(userPhone)){
                logger.error("用户手机号为空，无法发送短信通知, userId={}", userId);
                return;
            }
            Notification smsNotification = NotificationUtils.acquireSmsNotification(templateVo.getSmsTempId(), userPhone, variableList, "短信通知");
            this.getPushManager().push(smsNotification, null);
        }

        // 3:存在微信小程序推送方式
        if(templateVo.getRoutine()){
            throw new UnsupportedOperationException("未实现微信小程序消息通知");
        }
    }

    /**
     * 获取微信小程序（access_token），并设置缓存。
     * @return
     * @date 2023-09-16
     */
    protected String acquireMiniAccessToken(){
        String appId = this.getArgumentVariable(WechatConstants.WECHAT_MINI_APPID).getStringValue();
        if(StringUtils.isEmpty(appId)){
            throw new PlatformRuntimeException("请先配置微信参数:小程序appid");
        }
        String miniAccessToken = this.getWechatCache().getMiniAccessToken();
        if(StringUtils.isNotEmpty(miniAccessToken)){
            logger.debug("缓存中已有'access_token'：{}", miniAccessToken);
            return miniAccessToken;
        }

        String secret = this.getArgumentVariable(WechatConstants.WECHAT_MINI_APPSECRET).getStringValue();
        if (StringUtils.isEmpty(secret)) {
            throw new PlatformRuntimeException("微信小程序secret未设置");
        }
//        String url = MessageFormat.format(WechatConstants.WECHAT_ACCESS_TOKEN_URL, appId, secret);
//        logger.debug("url = {}", url);
//        ObjectNode objectNode = RestTemplateUtils.getData(url, BeanContextAware.getBeanByType(RestTemplate.class));
//        if(objectNode == null){
//            throw new PlatformRuntimeException("微信平台接口异常，没任何数据返回！");
//        }
//        logger.debug(objectNode.toString());
        ObjectNode objectNode = this.acquireAccessTokenNode(appId, secret);
        WeChatAccessTokenVo accessTokenVo = null;

        try {
//            if (objectNode.has("errcode") && !objectNode.get("errcode").asText().equals("0")) {
//                if (objectNode.has("errmsg")) {
//                    // 保存到微信异常表
////                    wxExceptionDispose(data, StrUtil.format("微信获取accessToken异常，{}端", type));
//                    throw new PlatformRuntimeException("微信接口调用失败：" + objectNode.get("errcode") + objectNode.get("errmsg"));
//                }
//            }
            this.checkStatusError(objectNode);
            accessTokenVo = new WeChatAccessTokenVo();
            accessTokenVo.setAccessToken(objectNode.get("access_token").asText());
            accessTokenVo.setExpiresIn(objectNode.get("expires_in").asInt());
//            accessTokenVo = JsonUtils.jsonStringToObject(result, WeChatAccessTokenVo.class);
            this.getWechatCache().putMiniAccessToken(accessTokenVo.getAccessToken(), accessTokenVo.getExpiresIn().longValue() - 1800L);
            logger.info("调用一次微信远程接口获取'mini_accessToken'，并缓存：{}", accessTokenVo.getAccessToken());
            return accessTokenVo.getAccessToken();

        } catch (Exception e) {
            throw new RuntimeException("json字符串转对象错误：" + objectNode, e);
        }
    }

    /**
     * 获取微信公众号（普通）access_token
     * @return
     * @date 2023-08-23
     */
    protected String acquirePublicAccessToken(
//            String appId, String type
    ){
        String appId = this.getArgumentVariable(WechatConstants.WECHAT_PUBLIC_APPID).getStringValue();
        if(StringUtils.isEmpty(appId)){
            throw new PlatformRuntimeException("请先配置微信参数:公众号appid");
        }
        String publicAccessToken = this.getWechatCache().getPublicAccessToken();
        if(StringUtils.isNotEmpty(publicAccessToken)){
            logger.debug("缓存中已有'access_token'：{}", publicAccessToken);
            return publicAccessToken;
        }
        String secret = this.getArgumentVariable(WechatConstants.WECHAT_PUBLIC_APPSECRET).getStringValue();
        if (StringUtils.isEmpty(secret)) {
            throw new PlatformRuntimeException("微信公众号secret未设置");
        }

//        String url = MessageFormat.format(WechatConstants.WECHAT_ACCESS_TOKEN_URL, appId, secret);
//        logger.debug("url = {}", url);
//        ObjectNode objectNode = RestTemplateUtils.getData(url, BeanContextAware.getBeanByType(RestTemplate.class));
//        if(objectNode == null){
//            throw new PlatformRuntimeException("微信平台接口异常，没任何数据返回！");
//        }
//        logger.debug(objectNode.toString());
        ObjectNode objectNode = this.acquireAccessTokenNode(appId, secret);
        WeChatAccessTokenVo accessTokenVo = null;
        try {
//            if (objectNode.has("errcode") && !objectNode.get("errcode").asText().equals("0")) {
//                if (objectNode.has("errmsg")) {
//                    // 保存到微信异常表
////                    wxExceptionDispose(data, StrUtil.format("微信获取accessToken异常，{}端", type));
//                    throw new PlatformRuntimeException("微信接口调用失败：" + objectNode.get("errcode") + objectNode.get("errmsg"));
//                }
//            }
            this.checkStatusError(objectNode);
            accessTokenVo = new WeChatAccessTokenVo();
            accessTokenVo.setAccessToken(objectNode.get("access_token").asText());
            accessTokenVo.setExpiresIn(objectNode.get("expires_in").asInt());
//            accessTokenVo = JsonUtils.jsonStringToObject(result, WeChatAccessTokenVo.class);
            this.getWechatCache().putPublicAccessToken(accessTokenVo.getAccessToken(), accessTokenVo.getExpiresIn().longValue() - 1800L);
            logger.info("调用一次微信远程接口获取'public_accessToken'，并缓存：{}", accessTokenVo.getAccessToken());
            return accessTokenVo.getAccessToken();

        } catch (Exception e) {
            throw new RuntimeException("json字符串转对象错误：" + objectNode, e);
        }
    }

    private ObjectNode acquireAccessTokenNode(String appId, String secret){
        String url = MessageFormat.format(WechatConstants.WECHAT_ACCESS_TOKEN_URL, appId, secret);
        logger.debug("url = {}", url);
        ObjectNode objectNode = RestTemplateUtils.getData(url, BeanContextAware.getBeanByType(RestTemplate.class));
        if(objectNode == null){
            throw new PlatformRuntimeException("微信平台接口异常，没任何数据返回！");
        }
        logger.debug(objectNode.toString());
        return objectNode;
    }

    private void checkStatusError(ObjectNode objectNode){
        //            ObjectNode objectNode = JsonUtils.jsonStringToObjectNode(result);
        if (objectNode.has("errcode") && !objectNode.get("errcode").asText().equals("0")) {
            if (objectNode.has("errmsg")) {
                // 保存到微信异常表
//                    wxExceptionDispose(data, StrUtil.format("微信获取accessToken异常，{}端", type));
                throw new PlatformRuntimeException("微信接口调用失败：" + objectNode.get("errcode") + objectNode.get("errmsg"));
            } else {
                throw new PlatformRuntimeException("微信接口调用失败：" + objectNode.get("errcode"));
            }
        }
    }

    /**
     * 返回微信基础配置缓存对象。
     * @return
     * @date 2023-08-23
     */
    protected WechatCacheProvider getWechatCache(){
        return BeanContextAware.getBeanByType(WechatCacheProvider.class);
    }

}