package com.iplatform.pay.support;

import com.iplatform.model.po.S_pay_notify;
import com.iplatform.model.po.S_pay_order;
import com.iplatform.pay.PlatformOrderCallback;
import com.iplatform.pay.util.NotifyUtils;
import com.iplatform.pay.util.OrderUtils;
import com.walker.infrastructure.utils.JsonUtils;
import com.walker.infrastructure.utils.StringUtils;
import com.walker.pay.CallBackException;
import com.walker.pay.NotifyValue;
import com.walker.pay.Order;
import com.walker.pay.PayStatus;
import com.walker.pay.ResponsePay;
import com.walker.pay.allinpaycloud.Constants;
import com.walker.pay.allinpaycloud.NotifyOrder;
import com.walker.pay.allinpaycloud.generator.OrderResponsePay;
import com.walker.pay.support.BankCardOrder;
import com.walker.pay.support.allinpaycloud.WechatJsOrder;
import com.walker.pay.support.allinpaycloud.WechatMiniProgramOrder;

/**
 * 通商云订单回调业务实现。
 * @author 时克英
 * @date 2023-02-26
 */
public class AllinpayCloudOrderCallback extends PlatformOrderCallback {

    @Override
    public void onOrderPrepare(Order platformOrder, ResponsePay responsePay) {
        OrderResponsePay orderResponsePay = (OrderResponsePay) responsePay;
        logger.debug("保存'通商云订单':{}", orderResponsePay);

        S_pay_order s_pay_order = null;
        //
//        String tradeNo = orderResponsePay.getTradeNo();
        String tradeNo = orderResponsePay.getOrderNo();
        String thirdPayInfo = orderResponsePay.getPayInfo();
        /**
         * {
         * "orderNo":"1632077606083895296",
         * "tradeNo":"{\"sign\":\"\",\"tphtrxcrtime\":\"\",\"tphtrxid\":0,\"trxflag\":\"trx\",\"trxsn\":\"\"}",
         * "validationType":1,
         * "extendInfo":"test",
         * "bizUserId":"shikeying",
         * "bizOrderNo":"8400705969744373"}
         * 返回的通联订单号不是'tradeNo'，而是'orderNo'
         */
        if(platformOrder instanceof BankCardOrder){
            BankCardOrder bankCardOrder = (BankCardOrder) platformOrder;
//            s_pay_order = OrderUtils.acquireBankCardOrder(0, bankCardOrder, orderResponsePay);
            s_pay_order = OrderUtils.acquireBankCardOrder(0, bankCardOrder, tradeNo, thirdPayInfo);
        } else if(platformOrder instanceof WechatJsOrder){
            WechatJsOrder wechatJsOrder = (WechatJsOrder) platformOrder;
            s_pay_order = OrderUtils.acquireWechatJsOrder(0, wechatJsOrder, tradeNo, thirdPayInfo);
        } else if(platformOrder instanceof WechatMiniProgramOrder){
            WechatMiniProgramOrder wechatMiniProgramOrder = (WechatMiniProgramOrder) platformOrder;
            s_pay_order = OrderUtils.acquireWechatJsOrder(0, wechatMiniProgramOrder, tradeNo, thirdPayInfo);
        } else {
            throw new UnsupportedOperationException("未实现保存该类型订单代码: " + platformOrder.getClass().getName());
        }
        this.orderService.insert(s_pay_order);
    }

    @Override
    public void onOrderNotify(NotifyValue<?> notifyValue) throws CallBackException {
        if(!(notifyValue.getData() instanceof NotifyOrder)){
            throw new IllegalArgumentException("notifyValue.getData()必须是 NotifyOrder 对象!");
        }
        this.doNotifyOrderPay((NotifyValue<NotifyOrder>)notifyValue);
    }

    protected void doNotifyOrderPay(NotifyValue<NotifyOrder> notifyValue){
//        logger.info("默认实现: 接收支付通知，notifyValue={}", notifyValue);
        if(StringUtils.isEmpty(notifyValue.getOrderId())){
            throw new IllegalArgumentException("接收订单通知，系统订单'orderId'为空");
        }
        long orderId = Long.parseLong(notifyValue.getOrderId());
//        S_pay_notify exist = this.orderService.get(new S_pay_notify(orderId));
//        if(exist != null){
//            logger.warn("订单通知已经接收，不再重复处理，notifyId = {}", notifyValue.getId());
//            return;
//        }
        S_pay_notify exist = this.getExistNotifyRecord(orderId);
        if(this.isAlreadySuccessNotify(exist)){
            return;
        }
        S_pay_notify s_pay_notify = this.acquirePayNotify(notifyValue);
        if(exist != null){
            // 更新通知，更新订单状态
            this.orderService.execInsertOrderNotify(s_pay_notify, false);
        } else {
            // 写入通知，更新订单状态
            this.orderService.execInsertOrderNotify(s_pay_notify, true);
        }
//        this.orderService.execInsertOrderNotify(s_pay_notify);
        logger.debug("------> 保存新订单通知, orderId = " + orderId);
    }

    private S_pay_notify acquirePayNotify(NotifyValue<NotifyOrder> notifyValue){
//        S_pay_notify s_pay_notify = new S_pay_notify();
//        s_pay_notify.setOrder_id(Long.parseLong(notifyValue.getOrderId()));
//        s_pay_notify.setNotify_id(notifyValue.getId());
//        s_pay_notify.setCreate_time(DateUtils.getDateTimeNumber(System.currentTimeMillis()));
//        s_pay_notify.setNotify_type(notifyValue.getDataType());
//        s_pay_notify.setTrade_no(notifyValue.getTradeNo());

        S_pay_notify s_pay_notify = NotifyUtils.acquireCombineBaseNotify(notifyValue);

        NotifyOrder notifyOrder = notifyValue.getData();
        if(notifyOrder != null){
            if(notifyOrder.getStatus().equals(Constants.SUB_CODE_OK)){
                s_pay_notify.setPay_status(PayStatus.Success.getIndex());
            } else {
                s_pay_notify.setPay_status(PayStatus.Error.getIndex());
            }
            s_pay_notify.setNotify_status(notifyOrder.getStatus());
            s_pay_notify.setNotify_amount(notifyOrder.getAmount());
            s_pay_notify.setNotify_acct(notifyOrder.getAcct());

            try {
                s_pay_notify.setNotify_source(JsonUtils.objectToJsonString(notifyOrder));
            } catch (Exception e) {
                logger.error("NotifyOrder转json错误:" + e.getMessage(), e);
            }
        }
        return s_pay_notify;
    }

//    public void setOrderService(OrderServiceImpl orderService) {
//        this.orderService = orderService;
//    }
//    private OrderServiceImpl orderService;
}