package com.ruoyi.web.controller.api;

import com.alipay.api.AlipayApiException;
import com.alipay.api.internal.util.AlipaySignature;
import com.ruoyi.common.core.domain.R;
import com.ruoyi.system.domain.TCourse;
import com.ruoyi.system.domain.TOrder;
import com.ruoyi.system.service.TCourseService;
import com.ruoyi.system.service.TOrderService;
import com.ruoyi.system.vx.WeChatConfig;
import com.ruoyi.system.vx.WeChatUtil;
import com.ruoyi.web.controller.tool.AlipayTradePagePay;
import com.ruoyi.web.controller.tool.AlipayTradeQuery;
import com.ruoyi.web.controller.tool.PayMoneyUtil;
import com.wechat.pay.java.core.notification.NotificationParser;
import com.wechat.pay.java.service.partnerpayments.app.model.Transaction;
import com.wechat.pay.java.service.refund.RefundService;
import com.wechat.pay.java.service.refund.model.AmountReq;
import com.wechat.pay.java.service.refund.model.CreateRequest;
import com.wechat.pay.java.service.refund.model.Refund;
import io.swagger.annotations.ApiOperation;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import javax.xml.bind.ValidationException;
import java.math.BigDecimal;
import java.time.LocalDateTime;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;

@RestController
@RequestMapping("/call-back")
public class CallBackController {


    @Resource
    private NotificationParser notificationParser;
    @Resource
    private TOrderService orderService;

    @Resource
    private WeChatConfig weChatConfig;
    @Resource
    private RefundService refundService;
    @Resource
    private PayMoneyUtil payMoneyUtil;

    @ApiOperation(value = "支付回调",tags = {"支付宝轮询"})
    @RequestMapping (value = "/ali/buy")
    @Transactional
    public R alipayCallback(Long orderId) throws AlipayApiException {

//            String outTradeNo = stringStringMap.get("out_trade_no");
            TOrder order = orderService.getById(orderId);
        Boolean check = AlipayTradeQuery.check(order.getCode());
        if (check) {
            order.setPaymentStatus(2);
            orderService.updateById(order);
//            if (one.getGoodType()==1){
//                try {
//                    TCourse byId = courseService.getById(one.getGoodId());
//                    byId.setBuyNum(byId.getBuyNum()+1);
//                    courseService.updateById(byId);
//                }catch (Exception e){
//                    e.printStackTrace();
//                }
//
//            }
            return R.ok();
        }else {
            return R.fail("请支付");
        }

    }

    @Resource
    private TCourseService courseService;

    @ApiOperation(value = "支付回调",tags = {"微信支付回调"})
    @RequestMapping (value = "/buy")
    @Transactional
    public R payNotify(HttpServletRequest request) throws Exception{
                System.err.println("======回调开始");
        Transaction transaction;
        transaction = notificationParser.parse(WeChatUtil.handleNodifyRequestParam(request), Transaction.class);
        if (transaction.getTradeState() == Transaction.TradeStateEnum.SUCCESS) {
                    TOrder order = orderService.lambdaQuery().eq(TOrder::getCode, transaction.getOutTradeNo()).one();
                    order.setPaymentStatus(2);
                    order.setSerialNumber(transaction.getTransactionId());
            order.setPayTime(LocalDateTime.now());

            order.setPaymentType(1);
            orderService.updateById(order);
            if (order.getGoodType()==1){
                try {
                    TCourse course = courseService.getById(order.getGoodId());
                    course.setBuyNum(course.getBuyNum()+1);
                    courseService.updateById(course);
                }catch (Exception e){
                    e.printStackTrace();
                }

            }
        }
        return R.ok(null,"SUCCESS");
    }

    @ApiOperation(value = "退款",tags = {"统一退款接口"})
    @PostMapping (value = "/refund")
    @Transactional
    public R refund(@RequestParam Long orderId) {
        TOrder byId = orderService.getById(orderId);
        if (byId.getPaymentType() == 1) {
            try {
                CreateRequest createRequest = new CreateRequest();
                AmountReq amountReq = new AmountReq();
                amountReq.setRefund(byId.getPaymentAmount().multiply(BigDecimal.valueOf(100)).longValue());
                amountReq.setTotal(byId.getPaymentAmount().multiply(BigDecimal.valueOf(100)).longValue());
                amountReq.setCurrency("CNY");
                createRequest.setAmount(amountReq);
                createRequest.setNotifyUrl("https://0ifzoxq2516g.guyubao.com/call-back/buy");
                createRequest.setOutTradeNo(byId.getCode());
                createRequest.setOutRefundNo("TK" + WeChatUtil.generateTradeNumber());

                Refund refund = refundService.create(createRequest);
                byId.setPaymentStatus(3);
                byId.setCancelTime(LocalDateTime.now());
                orderService.updateById(byId);
            }catch (Exception e){
                e.printStackTrace();
                return R.fail("当前服务器异常，请联系客服");
            }

        }else {
            try {
                AlipayTradePagePay.refund(byId.getPaymentAmount().toString(),byId.getCode());
            }catch (Exception e) {
                e.printStackTrace();
                return R.fail("当前服务器异常，请联系客服");
            }finally {
                byId.setPaymentStatus(3);
                orderService.updateById(byId);
            }
        }
        return R.ok();
    }


}