package cc.mrbird.febs.pay.service.impl;

import cc.mrbird.febs.blockchain.entity.MemberCoinAddressEntity;
import cc.mrbird.febs.blockchain.enumerates.CoinTypeEnum;
import cc.mrbird.febs.blockchain.mapper.MemberCoinAddressDao;
import cc.mrbird.febs.blockchain.service.Trc20Service;
import cc.mrbird.febs.common.exception.FebsException;
import cc.mrbird.febs.common.utils.AppContants;
import cc.mrbird.febs.common.utils.LoginUserUtil;
import cc.mrbird.febs.common.utils.MallUtils;
import cc.mrbird.febs.pay.model.AliPayPassbackModel;
import cc.mrbird.febs.pay.properties.AliPayProperties;
import cc.mrbird.febs.pay.service.IPayService;
import cc.mrbird.febs.rabbit.producer.UsdtUpdateProducer;
import cc.mrbird.febs.video.dto.VipBuyDto;
import cc.mrbird.febs.video.entity.DataDictionaryCustom;
import cc.mrbird.febs.video.entity.VideoMemberEntity;
import cc.mrbird.febs.video.entity.VideoVipOrderInfoEntity;
import cc.mrbird.febs.video.mapper.DataDictionaryCustomMapper;
import cc.mrbird.febs.video.mapper.VideoMemberMapper;
import cc.mrbird.febs.video.mapper.VideoVipOrderInfoMapper;
import com.alibaba.fastjson.JSONObject;
import com.alipay.api.AlipayApiException;
import com.alipay.api.domain.AlipayTradeAppPayModel;
import com.alipay.api.response.AlipayTradeAppPayResponse;
import com.ijpay.alipay.AliPayApi;
import lombok.extern.slf4j.Slf4j;
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;

import javax.annotation.Resource;
import java.math.BigDecimal;
import java.util.Date;
import java.util.Map;

/**
 * @author wzy
 * @date 2021-09-27
 **/
@Slf4j
@Service
public class PayServiceImpl implements IPayService {

    @Resource
    private AliPayProperties aliPayProperties;
    @Resource
    private DataDictionaryCustomMapper dataDictionaryCustomMapper;
    @Resource
    private VideoVipOrderInfoMapper videoVipOrderInfoMapper;
    @Resource
    private VideoMemberMapper videoMemberMapper;
    @Resource
    private MemberCoinAddressDao memberCoinAddressDao;
    @Resource
    private UsdtUpdateProducer usdtUpdateProducer;

    @Value("${spring.profiles.active}")
    private String active;

    @Override
    @Transactional(rollbackFor = Exception.class)
    public String aliPay(VipBuyDto vipBuyDto) {
        VideoMemberEntity loginUser = LoginUserUtil.getLoginUser();

        DataDictionaryCustom data = dataDictionaryCustomMapper.selectDataByTypeAndCode(AppContants.DIC_VIP_COST, vipBuyDto.getType());
        if (data == null) {
            throw new FebsException("参数错误");
        }

        VideoVipOrderInfoEntity vipOrderInfo = new VideoVipOrderInfoEntity();
        vipOrderInfo.setOrderNo(MallUtils.getOrderNum());
        vipOrderInfo.setPayType(VideoVipOrderInfoEntity.PAY_TYPE_ALIPAY);
        vipOrderInfo.setStatus(VideoVipOrderInfoEntity.PAY_STATUS_WAIT);
        vipOrderInfo.setMemberId(loginUser.getId());
        vipOrderInfo.setGoodsType(vipBuyDto.getType());
        vipOrderInfo.setAmount(new BigDecimal(data.getValue()));
        videoVipOrderInfoMapper.insert(vipOrderInfo);

        AlipayTradeAppPayModel model = new AlipayTradeAppPayModel();
        model.setSubject("会员支付");
        model.setBody(data.getDescription());
        model.setOutTradeNo(vipOrderInfo.getOrderNo());
        model.setTimeoutExpress("15m");

        if ("dev".equals(active) || "test".equals(active)) {
            model.setTotalAmount("0.01");
        } else {
            model.setTotalAmount(vipOrderInfo.getAmount().toString());
        }

        AliPayPassbackModel passbackModel = new AliPayPassbackModel();
        passbackModel.setOrderId(vipOrderInfo.getId());
        passbackModel.setMemberId(vipOrderInfo.getMemberId());
        model.setPassbackParams(JSONObject.toJSONString(passbackModel));

        model.setProductCode("QUICK_MSECURITY_PAY");
        AlipayTradeAppPayResponse resp = null;
        try {
            resp = AliPayApi.appPayToResponse(model, aliPayProperties.getNoticeUrl());
        } catch (AlipayApiException e) {
            log.error("支付宝支付异常", e);
            throw new FebsException("支付宝支付异常");
        }
        return resp.getBody();
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void aliCallback(Map<String, String> params) {
        String modelStr = params.get("passback_params");

        AliPayPassbackModel passback = JSONObject.parseObject(modelStr, AliPayPassbackModel.class);

        VideoVipOrderInfoEntity orderInfo = videoVipOrderInfoMapper.selectById(passback.getOrderId());
        if (orderInfo.getPayType() != 1) {
            return;
        }

        VideoMemberEntity member = videoMemberMapper.selectById(orderInfo.getMemberId());

        orderInfo.setStatus(VideoVipOrderInfoEntity.PAY_STATUS_PAY);
        orderInfo.setPayTime(new Date());
        orderInfo.setPayTraderNo(params.get("trade_no"));
        videoVipOrderInfoMapper.updateById(orderInfo);
    }

    @Override
    public String findUsdtAddress() {
        VideoMemberEntity loginUser = LoginUserUtil.getLoginUser();

        MemberCoinAddressEntity coinAddress = this.memberCoinAddressDao.selectAddressByMemberIdAndSymbol(loginUser.getId(), CoinTypeEnum.USDT.name());
        if (coinAddress == null) {
            Map<String, String> usdtMap = Trc20Service.createAddress();
            String address = usdtMap.get("address");
            String key = usdtMap.get("privateKey");
            // 发送新增的地址到监听集合
            usdtUpdateProducer.sendAddressMsg(address+","+"TRC20");

            coinAddress = new MemberCoinAddressEntity();
            coinAddress.setAddress(address);
            coinAddress.setIsBiyict(MemberCoinAddressEntity.IS_BIYICT_YES);
            coinAddress.setMemberId(loginUser.getId());
            coinAddress.setPrivateKey(key);
            coinAddress.setSymbol(CoinTypeEnum.USDT.name());
            this.memberCoinAddressDao.insert(coinAddress);

            return address;
        }
        return coinAddress.getAddress();
    }
}