package com.ishop.mobile.api;

import com.fasterxml.jackson.databind.node.ObjectNode;
import com.iplatform.base.PlatformRuntimeException;
import com.iplatform.base.WechatConstants;
import com.iplatform.base.util.RestTemplateUtils;
import com.ishop.merchant.Constants;
import com.ishop.mobile.BaseApi;
import com.ishop.mobile.util.WechatUtils;
import com.ishop.model.response.WeChatJsSdkConfigResponse;
import com.ishop.model.response.WechatPublicShareResponse;
import com.walker.infrastructure.utils.StringUtils;
import com.walker.infrastructure.utils.UrlUtils;
import com.walker.web.ResponseValue;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

import java.text.MessageFormat;
import java.util.UUID;

@RestController
@RequestMapping("/front/wechat")
public class WechatApi extends BaseApi {

    private RestTemplate restTemplate;

    @Value("${ishop.wechat-js-api-debug}")
    private boolean wechatJsApiDebug = false;

    @Autowired
    public WechatApi(RestTemplate restTemplate){
        this.restTemplate = restTemplate;
    }

    /**
     * 微信公众号分享配置
     * @return
     */
    @RequestMapping(value = "/get/public/share", method = RequestMethod.GET)
    public ResponseValue getPublicShare(){
        WechatPublicShareResponse response = new WechatPublicShareResponse();
        response.setImage(this.getArgumentVariable(Constants.CONFIG_KEY_ADMIN_WECHAT_SHARE_IMAGE).getStringValue());
        response.setTitle(this.getArgumentVariable(Constants.CONFIG_KEY_ADMIN_WECHAT_SHARE_TITLE).getStringValue());
        response.setSynopsis(this.getArgumentVariable(Constants.CONFIG_KEY_ADMIN_WECHAT_SHARE_SYNOPSIS).getStringValue());
        return ResponseValue.success();
    }

    /**
     * 获取微信公众号js配置
     * @param url
     * @return
     */
    @RequestMapping(value = "/get/public/js/config", method = RequestMethod.GET)
    public ResponseValue getPublicJsConfig(String url){
        logger.debug(url);
        url = UrlUtils.decode(url);
        logger.debug("decode_url = {}", url);
        String appId = this.getArgumentVariable(WechatConstants.WECHAT_PUBLIC_APPID).getStringValue();
        if(StringUtils.isEmpty(appId)){
            return ResponseValue.error("请先配置微信参数");
        }
        String ticket = this.getWechatCache().getJsApiTicket();
        if(StringUtils.isEmpty(ticket)){
            logger.debug("缓存未找到微信'ticket',重新调用查询");
//            String accessToken = this.acquirePublicAccessToken(appId, null);
            String accessToken = this.acquirePublicAccessToken();
            String ticketUrl = MessageFormat.format(WechatConstants.WECHAT_PUBLIC_JS_TICKET_URL, accessToken);
            ObjectNode objectNode = RestTemplateUtils.getData(ticketUrl, this.restTemplate);
            if(objectNode == null){
                throw new PlatformRuntimeException("微信平台接口异常，没任何数据返回！");
            }
            logger.debug(objectNode.toString());

            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"));
                    }
                }
                ticket = objectNode.get("ticket").asText();
                this.getWechatCache().putJsApiTicket(ticket);
                logger.info("调用一次微信远程接口获取'ticket'，并缓存：{}", ticket);

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

        WeChatJsSdkConfigResponse response = new WeChatJsSdkConfigResponse();
        response.setUrl(url);
        response.setAppId(appId);
        response.setNonceStr(UUID.randomUUID().toString().replace("-", ""));
        response.setTimestamp(System.currentTimeMillis()/1000);

        String signature = WechatUtils.getJsSdkSign(response.getNonceStr(), ticket, String.valueOf(response.getTimestamp()), url);
        response.setSignature(signature);
        String[] apiArray = StringUtils.commaDelimitedListToStringArray(WechatConstants.PUBLIC_API_JS_API_SDK_LIST);
        response.setJsApiList(StringUtils.asList(apiArray));
        response.setDebug(this.wechatJsApiDebug);
        logger.info("response = {}, ticket = {}", response, ticket);

        return ResponseValue.success(response);
    }

//    private String acquirePublicAccessToken(String appId, String type){
//        String publicAccessToken = this.getWechatCache().getPublicAccessToken();
//        if(StringUtils.isNotEmpty(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, this.restTemplate);
//        if(objectNode == null){
//            throw new PlatformRuntimeException("微信平台接口异常，没任何数据返回！");
//        }
//        logger.debug(objectNode.toString());
//        WeChatAccessTokenVo accessTokenVo = null;
//        try {
////            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"));
//                }
//            }
//            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);
//        }
//    }
}