package com.dubbo.pay.modular.api.chanel.channel4.notify;

import com.alibaba.fastjson.JSONObject;
import com.dubbo.pay.modular.api.chanel.channel4.consts.Channel4Constent;
import com.dubbo.pay.modular.api.service.IPayNotifyService;
import com.dubbo.pay.modular.api.utils.PayDigestUtil;
import com.dubbo.pay.modular.api.utils.ResponseUtil;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
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 javax.servlet.http.HttpServletResponse;

/**
 * @Description：
 * @Auther： libo
 * @date： 2018/12/8:17:39
 */
@Slf4j
@RestController
public class Channel4NotifyController {

    @Autowired
    IPayNotifyService payNotifyService;

    /**
     * status     订单状态,1:成功，其他失败
     * customerid 商户编号
     * sdpayno    平台订单号
     * sdorderno  商户订单号
     * total_fee  交易金额
     * paytype    支付类型
     * sign       MD5加密验证
     */
    @RequestMapping(value = "/pnotify/channel4", method = RequestMethod.POST, produces = "application/json;charset=UTF-8")
    public void payNotifyRes(@RequestBody JSONObject param, HttpServletResponse response) {
        String status = param.getString("status");
        String sdorderno = param.getString("sdorderno");
        String customerid = param.getString("customerid");
        String sdpayno = param.getString("sdpayno");
        String totalFee = param.getString("total_fee");
        String paytype = param.getString("paytype");
        String sign = param.getString("sign");

        int payResult = 0;
        try {
            //解析参数
            log.info("====== 通道4：接收支付回调通知开始解析参数。param={} ======", param);

            if (sdorderno == null || status == null) {
                log.error("====== 通道4：回调数据解析失败,sdorderno={},status={} ======", sdorderno, status);
                ResponseUtil.write(response, "回调数据解析失败");
                return;
            }

            String signStr = "customerid=" + customerid + "&status=" + status + "&sdpayno=" + sdpayno + "&sdorderno=" + sdorderno + "&total_fee=" + totalFee + "&paytype=" + paytype + "&" + Channel4Constent.KEY;
            if (StringUtils.isBlank(sign) || !sign.equals(PayDigestUtil.md5(signStr))) {
                log.error("====== 通道4：签名验证失败。签名参数：{}，md5加密后实际值：{} ======", sign, PayDigestUtil.md5(signStr));
                ResponseUtil.write(response, "签名验证失败");
                return;
            }

            if ("1".equals(status)) {
                payResult = 1;
                log.info("====== 支付成功 ======");
            }

            if (payNotifyService.payHandler(sdorderno, payResult)) {
                ResponseUtil.write(response, "success");
                return;
            }
        } catch (Exception e) {
            log.error("====== 通道4：回调异常。e={} ======", e);
        }
        ResponseUtil.write(response, "-1");
    }
}

@Value("${spring.datasource.db-name:guns}")