package com.iotechn.unimall.app.api.vip;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.dobbinsoft.fw.core.exception.AppServiceException;
import com.dobbinsoft.fw.core.exception.ServiceException;
import com.dobbinsoft.fw.core.util.GeneratorUtil;
import com.dobbinsoft.fw.pay.enums.PayChannelType;
import com.dobbinsoft.fw.pay.enums.PayPlatformType;
import com.dobbinsoft.fw.pay.exception.MatrixPayException;
import com.dobbinsoft.fw.pay.model.request.MatrixPayUnifiedOrderRequest;
import com.dobbinsoft.fw.pay.service.pay.MatrixPayService;
import com.dobbinsoft.fw.support.component.MachineComponent;
import com.dobbinsoft.fw.support.model.Page;
import com.dobbinsoft.fw.support.properties.FwWxPayProperties;
import com.dobbinsoft.fw.support.service.BaseService;
import com.iotechn.unimall.biz.util.PaySelector;
import com.iotechn.unimall.data.domain.VipOrderDO;
import com.iotechn.unimall.data.domain.VipTemplateDO;
import com.iotechn.unimall.data.dto.AdminDTO;
import com.iotechn.unimall.data.dto.UserDTO;
import com.iotechn.unimall.data.enums.VipOrderStatusType;
import com.iotechn.unimall.data.exception.ExceptionDefinition;
import com.iotechn.unimall.data.mapper.VipOrderMapper;
import com.iotechn.unimall.data.mapper.VipTemplateMapper;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

@Service
public class VipOrderServiceImpl extends BaseService<UserDTO, AdminDTO> implements VipOrderService {

    @Autowired
    private VipTemplateMapper templateMapper;

    @Autowired
    private VipOrderMapper vipOrderMapper;

    @Autowired
    private MatrixPayService matrixPayService;

    @Autowired
    private FwWxPayProperties fwWxPayProperties;

    @Autowired
    private MachineComponent machineComponent;

    @Value("${com.dobbinsoft.fw.env}")
    private String ENV;

    @Autowired
    private PaySelector paySelector;

    private static final Logger logger = LoggerFactory.getLogger(VipOrderServiceImpl.class);

    @Override
    @Transactional(rollbackFor = Exception.class)
    public Object prepay(Integer payPlatform, String payChannel, Long templateId, String ip, Long userId) throws ServiceException {
        VipTemplateDO vipTemplateDO = templateMapper.selectById(templateId);
        if (vipTemplateDO == null || 1 != vipTemplateDO.getDisplay().intValue()) {
            throw new AppServiceException(ExceptionDefinition.VIP_TEMPLATE_NULL_OR_NOT_DISPLAY);
        }
        String orderNo = GeneratorUtil.genOrderId(this.machineComponent.getMachineNo() + "", this.ENV);
        VipOrderDO vipOrderDO = new VipOrderDO();
        vipOrderDO.setDayNum(vipTemplateDO.getDayNum());
        vipOrderDO.setPrice(vipTemplateDO.getPrice());
        vipOrderDO.setStatus(VipOrderStatusType.WAIT_BUY.getCode());
        vipOrderDO.setTemplateId(vipTemplateDO.getId());
        vipOrderDO.setOrderNo(orderNo);
        vipOrderDO.setUserId(userId);
        vipOrderDO.setTitle(vipTemplateDO.getTitle());
        vipOrderDO.setDescription(vipTemplateDO.getDescription());
        vipOrderMapper.insert(vipOrderDO);
        try {
            // 前端来决定支付方式
            MatrixPayUnifiedOrderRequest orderRequest = new MatrixPayUnifiedOrderRequest();
            paySelector.packPayChannel(orderRequest, payPlatform, payChannel);
            orderRequest.setNotifyUrl(fwWxPayProperties.getNotifyUrl() + "/vip");
            // 区分回调 直接通过 S 来判断
            orderRequest.setOutTradeNo(orderNo);
            orderRequest.setOpenid(sessionUtil.getUser().getWxMpOpenId());
            orderRequest.setBody("vip_" + orderNo);
            orderRequest.setTotalFee(vipOrderDO.getPrice());
            orderRequest.setSpbillCreateIp(ip);
            orderRequest.setPayPlatform(PayPlatformType.getByCode(payPlatform));
            orderRequest.setPayChannel(PayChannelType.getByCode(payChannel));
            Object object = matrixPayService.createOrder(orderRequest);
            return object;
        } catch (MatrixPayException e) {
            logger.error("[Matrix支付] 异常", e);
            throw new AppServiceException(e.getErrCodeDes(), ExceptionDefinition.THIRD_PART_SERVICE_EXCEPTION.getCode());
        } catch (Exception e) {
            logger.error("[预付款异常]", e);
            throw new AppServiceException(ExceptionDefinition.ORDER_UNKNOWN_EXCEPTION);
        }
    }

    @Override
    public Page<VipOrderDO> queryVipOrder(Integer status, Integer pageNo, Integer limit, Long userId) throws ServiceException {
        QueryWrapper<VipOrderDO> wrapper = new QueryWrapper<>();
        wrapper.eq("user_id", userId);
        if (status != null) {
            wrapper.eq("status", status);
        }
        return vipOrderMapper.selectPage(Page.div(pageNo, limit, VipOrderDO.class), wrapper);
    }

}