package com.ishop.mobile.api;

import com.iplatform.base.PlatformRuntimeException;
import com.iplatform.base.WechatConstants;
import com.ishop.merchant.Constants;
import com.ishop.merchant.OrderConstants;
import com.ishop.merchant.PayConstants;
import com.ishop.merchant.util.PayUtils;
import com.ishop.mobile.BaseApi;
import com.ishop.mobile.util.WechatUtils;
import com.ishop.model.po.EbRechargeOrder;
import com.ishop.model.request.UserRechargeRequest;
import com.ishop.model.response.OrderPayResultResponse;
import com.ishop.model.response.RechargeItemResponse;
import com.ishop.model.response.RechargePackageResponse;
import com.ishop.model.vo.WxPayJsResultVo;
import com.walker.infrastructure.utils.DateUtils;
import com.walker.infrastructure.utils.MD5;
import com.walker.infrastructure.utils.NumberGenerator;
import com.walker.infrastructure.utils.StringUtils;
import com.walker.pay.Order;
import com.walker.pay.PayEngineManager;
import com.walker.pay.exception.OrderException;
import com.walker.pay.wechat.v2.H5ResponsePay;
import com.walker.web.ResponseValue;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;

import java.util.HashMap;
import java.util.List;
import java.util.Map;

@RestController
@RequestMapping("/front/recharge")
public class RechargeApi extends BaseApi {

    private PayEngineManager payEngineManager;

    @Autowired
    public RechargeApi(PayEngineManager payEngineManager){
        this.payEngineManager = payEngineManager;
    }

    /**
     * 获取用户充值说明。
     * @return
     * @date 2023-09-11
     */
    @RequestMapping(value = "/get/user/package", method = RequestMethod.GET)
    public ResponseValue acquireRechargePackage(){
        RechargePackageResponse userRechargeResponse = new RechargePackageResponse();
        List<RechargeItemResponse> list = this.acquireGroupDataList(Constants.GROUP_DATA_ID_RECHARGE_PACKAGE, true, RechargeItemResponse.class, null);
        userRechargeResponse.setPackageList(list);

        String rechargeAttention = this.getArgumentVariable(Constants.CONFIG_RECHARGE_ATTENTION).getStringValue();
        if(StringUtils.isNotEmpty(rechargeAttention)){
            List<String> attentionList = StringUtils.asList(StringUtils.delimitedListToStringArray(rechargeAttention, "\n"));
            userRechargeResponse.setNoticeList(attentionList);
        }
        return ResponseValue.success(userRechargeResponse);
    }

    /**
     * 生成用户充值订单
     * @return
     */
    @RequestMapping(value = "/user/create", method = RequestMethod.POST)
    public ResponseValue userCreate(@RequestBody UserRechargeRequest request){
        if(request == null || (request.getPrice() == null && request.getGroupDataId() == null)){
            return ResponseValue.error("请选择充值套餐或填写自定义充值金额");
        }

        double rechargePrice = 0;   // 充值金额
        double gainPrice = 0;       // 赠送金额

        if(request.getPrice() != null){
            // 输入金额
            rechargePrice = request.getPrice();
            if(rechargePrice <= 0){
                return ResponseValue.error("充值金额必须大于0");
            }

        } else {
            // 选择套餐
            RechargeItemResponse rechargePackage = this.acquireGroupDataNormal(request.getGroupDataId(), RechargeItemResponse.class, null);
            if(rechargePackage == null){
                return ResponseValue.error("您选择的充值方式已下架");
            }
            rechargePrice = Double.parseDouble(rechargePackage.getPrice());
            gainPrice = Double.parseDouble(rechargePackage.getGiveMoney());
        }

        double rechargeMinAmount = this.getArgumentVariable(Constants.USER_RECHARGE_MIN_AMOUNT).getDoubleValue();
        if(rechargePrice < rechargeMinAmount){
            return ResponseValue.error("充值金额小于最低充值金额");
        }

        long userId = this.getCurrentUserId();

        // 生成充值订单号
        String rechargeNo = new StringBuilder(OrderConstants.RECHARGE_ORDER_PREFIX)
                .append(System.currentTimeMillis()).append(StringUtils.generateRandomNumber(6)).toString();

        EbRechargeOrder rechargeOrder = new EbRechargeOrder(NumberGenerator.getLongSequenceNumber());
        rechargeOrder.setOrderNo(rechargeNo);
        rechargeOrder.setCreateTime(DateUtils.getDateTimeNumber());
        rechargeOrder.setUid(userId);
        rechargeOrder.setPrice(rechargePrice);
        rechargeOrder.setGivePrice(gainPrice);

        OrderPayResultResponse response = new OrderPayResultResponse();
        response.setOrderNo(rechargeNo);
        response.setPayType(request.getPayType());
        response.setPayChannel(request.getPayChannel());

        if (request.getPayType().equals(PayConstants.PAY_TYPE_WE_CHAT)) {
            String userOpenId = this.getCurrentUser().getWx_open_id();
            //~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
            // 2023-08-28 不知道为啥openId字符串会带双引号，
            // 目前没找到原因，先直接剔除，后面要找到（初步估计是redis取出来带的）
            //~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
            if(StringUtils.isNotEmpty(userOpenId) && userOpenId.indexOf("\"") >= 0){
                userOpenId = userOpenId.replaceAll("\"", StringUtils.EMPTY_STRING);
            }
            //~~~~~~~~~~~~~~~~~~~~~~~ end ~~~~~~~~~~~~~~~~~~~~~~~
            if(StringUtils.isEmpty(userOpenId)){
                return ResponseValue.error("您还未授权（绑定）微信登录，无法完成微信支付");
            }

            WxPayJsResultVo vo = null;

            // 生成第三方支付使用的订单编号
            rechargeOrder.setOutTradeNo(PayUtils.acquirePayOutTradeNo(PayConstants.PAY_TYPE_WE_CHAT));
            if(request.getPayChannel().equals(PayConstants.PAY_CHANNEL_WECHAT_PUBLIC)
                    || request.getPayChannel().equals(PayConstants.PAY_CHANNEL_H5)){
                rechargeOrder.setPayType(PayConstants.PAY_TYPE_WE_CHAT);
                rechargeOrder.setPayChannel(request.getPayChannel());
                vo = this.wechatH5Recharge(rechargeOrder, userOpenId);

            } else {
                throw new UnsupportedOperationException("还未实现微信其他支付方式：" + request.getPayChannel());
            }
            response.setStatus(true);
            response.setJsConfig(vo);
            logger.debug("微信（充值）预下单成功");
            this.getUserRechargeService().insert(rechargeOrder);

        } else if (request.getPayType().equals(PayConstants.PAY_TYPE_ALI_PAY)) {
            throw new UnsupportedOperationException("未实现支付宝充值代码");
        }

        return ResponseValue.success(response);
    }

    private WxPayJsResultVo wechatH5Recharge(EbRechargeOrder order, String userOpenId){
        String apiDomain = this.getArgumentVariable(Constants.CONFIG_KEY_API_URL).getStringValue();
        String siteName = this.getArgumentVariable(Constants.CONFIG_KEY_SITE_NAME).getStringValue();
        String signKey = this.getArgumentVariable(WechatConstants.WECHAT_PAY_PUBLIC_KEY).getStringValue();
        String attach = PayConstants.PAY_SERVICE_TYPE_RECHARGE + "," + order.getUid();

        double payPriceFen = order.getPrice().doubleValue() * 100;
        Order platformPayOrder = PayUtils.acquirePlatformOrderH5WechatV2((long)payPriceFen
                , order.getId(), siteName, attach, "127.0.0.1", apiDomain + PayConstants.WX_PAY_NOTIFY_API_URI, userOpenId);

        H5ResponsePay responsePay = null;
        try {
            responsePay = (H5ResponsePay) this.payEngineManager.generatePrepareOrder(platformPayOrder);
        } catch (OrderException e) {
            throw new PlatformRuntimeException("发起微信预订单（充值）错误:" + e.getMessage() + ", orderId=" + e.getOrderId(), e);
        }
        if(!responsePay.getStatus()){
            throw new PlatformRuntimeException("微信支付H5订单（充值）返回错误：" + responsePay.getMessage(), null);
        }

        Map<String, String> map = new HashMap<>();
        map.put("appId", responsePay.getAppId());
        map.put("nonceStr", responsePay.getAppId());
        map.put("package", "prepay_id=" + responsePay.getPrepayId());
        map.put("signType", MD5.MD5_NAME);
        map.put("timeStamp", String.valueOf(System.currentTimeMillis()/1000));

        WxPayJsResultVo vo = new WxPayJsResultVo();
        vo.setAppId(responsePay.getAppId());
        vo.setNonceStr(responsePay.getAppId());
        vo.setPackages("prepay_id=" + responsePay.getPrepayId());
        vo.setSignType(MD5.MD5_NAME);
        vo.setTimeStamp(String.valueOf(System.currentTimeMillis()/1000));
        vo.setMwebUrl(responsePay.getCodeUrl());
        try {
            vo.setPaySign(WechatUtils.getSign(map, signKey));
        } catch (Exception e) {
            throw new PlatformRuntimeException("设置返回值签名错误：" + e.getMessage(), e);
        }
        return vo;
    }
}