package cc.mrbird.febs.pay.controller;

import cc.mrbird.febs.common.entity.FebsResponse;
import cc.mrbird.febs.common.enumerates.AgentLevelEnum;
import cc.mrbird.febs.common.enumerates.FlowTypeEnum;
import cc.mrbird.febs.common.enumerates.MoneyFlowTypeEnum;
import cc.mrbird.febs.common.enumerates.OrderStatusEnum;
import cc.mrbird.febs.common.exception.FebsException;
import cc.mrbird.febs.common.utils.LoginUserUtil;
import cc.mrbird.febs.mall.dto.RegisterAppealDto;
import cc.mrbird.febs.mall.entity.*;
import cc.mrbird.febs.mall.mapper.*;
import cc.mrbird.febs.mall.service.IApiMallMemberService;
import cc.mrbird.febs.mall.service.IApiMallMemberWalletService;
import cc.mrbird.febs.mall.service.IMallAchieveService;
import cc.mrbird.febs.mall.service.IMallMoneyFlowService;
import cc.mrbird.febs.pay.model.*;
import cc.mrbird.febs.pay.service.UnipayService;
import cc.mrbird.febs.pay.util.JsonUtil;
import cc.mrbird.febs.rabbit.producter.AgentProducer;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil;
import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

import javax.servlet.http.HttpServletRequest;
import java.math.BigDecimal;
import java.util.Date;
import java.util.List;

/**
 * 平台公钥:MIGfMA0GCSqGSIb3DQEBAQUAA4GNADCBiQKBgQCwSAEXsiC0IYha6a94imKq8VfOkk7WjDRAQWMBRnoKOZeEUeMrHYiblcrqeMYXGpV13288iUOkuyKwkPXkYXyIQK8emvJIbQOhtB5bSlAbodsPgncM9Ney1GFiz+7ogBxyt58mP8AA9UHtMw7u78zZoQ1+dUWwUUowVXml3Q0cVQIDAQAB
 */
@Slf4j
@RestController
@RequestMapping(value = "/api/unipay")
@RequiredArgsConstructor
@Api(value = "ApiMallMemberController", tags = "支付接口类")
public class UnipayController {

    @Autowired
    private MallOrderInfoMapper orderInfoMapper;
    @Autowired
    private IApiMallMemberService memberService;
    @Autowired
    private AgentProducer agentProducer;
    @Autowired
    private MallOrderInfoMapper mallOrderInfoMapper;
    @Autowired
    private MallGoodsMapper mallGoodsMapper;
    @Autowired
    private MallGoodsSkuMapper mallGoodsSkuMapper;
    @Autowired
    private IApiMallMemberWalletService memberWalletService;
    @Autowired
    private IMallAchieveService mallAchieveService;
    @Autowired
    private IMallMoneyFlowService mallMoneyFlowService;
    @Autowired
    private MallMemberMapper memberMapper;
    @Autowired
    private UnipayService unipayService;
    @Autowired
    private MallMemberBankMapper mallMemberBankMapper;
    @Autowired
    private MallMemberBankSignMapper mallMemberBankSignMapper;
    @Autowired
    private MallMemberWithdrawMapper mallMemberWithdrawMapper;
    @Autowired
    private MallMoneyFlowMapper mallMoneyFlowMapper;

    private final IApiMallMemberWalletService iApiMallMemberWalletService;

    @GetMapping(value = "/unipayCallBack")
    public String unipayCallBack(HttpServletRequest request, UniPayCallBackDto uniPayCallBackDto){
        log.info("进入汇聚支付聚合支付回调"+ JSONUtil.parseObj(uniPayCallBackDto));
        String orderNo = uniPayCallBackDto.getR2_OrderNo();
        BigDecimal orderAmount = new BigDecimal(uniPayCallBackDto.getR3_Amount());
        String callBackState = uniPayCallBackDto.getR6_Status();
        String payTradeNo = uniPayCallBackDto.getR7_TrxNo();

        log.info("进入汇聚支付聚合支付回调"+orderNo+";"+orderAmount+";"+payTradeNo+";"+callBackState);
        if("100".equals(callBackState) && StrUtil.isNotBlank(orderNo)){
            MallOrderInfo orderInfo = orderInfoMapper.selectByOrderNo(orderNo);
            if(ObjectUtil.isNotEmpty(orderInfo)){
                Integer status = orderInfo.getStatus();
                if(OrderStatusEnum.WAIT_PAY.getValue() == status){

                    orderInfo.setStatus(OrderStatusEnum.WAIT_SHIPPING.getValue());
                    orderInfo.setPayResult("1");
                    orderInfo.setPayTime(new Date());
                    orderInfo.setPayTradeNo(payTradeNo);
                    orderInfoMapper.updateById(orderInfo);

                    boolean hasTc = false;
                    // 静态倍数
                    List<MallOrderItem> orderItems = mallOrderInfoMapper.getMallOrderItemByOrderId(orderInfo.getId());
                    if (CollUtil.isNotEmpty(orderItems)) {
                        for (MallOrderItem orderItem : orderItems) {
                            MallGoods mallGoods = mallGoodsMapper.selectById(orderItem.getGoodsId());
                            BigDecimal score = BigDecimal.ZERO;
                            MallGoodsSku sku = mallGoodsSkuMapper.selectById(orderItem.getSkuId());
                            if (mallGoods.getIsNormal() == 2) {
                                hasTc = true;
                                score = sku.getPresentPrice().multiply(mallGoods.getStaticMulti()).multiply(new BigDecimal(orderItem.getCnt()));
                                // 普通商品也及时结算，不再10天结算
                            } else {
                                score = sku.getPresentPrice();
                            }

                            if (score.compareTo(BigDecimal.ZERO) > 0) {
                                memberWalletService.add(score, orderInfo.getMemberId(), "score");
                                mallMoneyFlowService.addMoneyFlow(orderInfo.getMemberId(), score, MoneyFlowTypeEnum.STATIC_BONUS.getValue(), orderInfo.getOrderNo(), FlowTypeEnum.SCORE.getValue());

                                // 添加业绩
                                mallAchieveService.add(orderItem.getId());
                            }
                        }
                    }

                    // 购买套餐后，升级为普通会员
                    MallMember mallMember = memberMapper.selectById(orderInfo.getMemberId());
                    if (hasTc) {
                        if (AgentLevelEnum.ZERO_LEVEL.name().equals(mallMember.getLevel())) {
                            mallMember.setLevel(AgentLevelEnum.FIRST_LEVEL.name());
                            memberMapper.updateById(mallMember);
                        }
                    }

                    mallMoneyFlowService.addMoneyFlow(mallMember.getId(), orderInfo.getAmount().negate(), MoneyFlowTypeEnum.PAY.getValue(), orderInfo.getOrderNo(), FlowTypeEnum.BALANCE.getValue());
                }
            }
        }
        return "success";
    }

    @ApiOperation(value = "获取协议支付签约短信", notes = "获取协议支付签约短信")
    @PostMapping(value = "getAgreeMentPaySms")
    public FebsResponse getAgreeMentPaySms(@RequestBody AgreeMentPaySmsDto agreeMentPaySmsDto) {
        String agreeMentPaySms = unipayService.getAgreeMentPaySms(agreeMentPaySmsDto);
        if("JS000000".equals(agreeMentPaySms)){
            return new FebsResponse().success().message("获取成功");
        }else{
            return new FebsResponse().fail().message(agreeMentPaySms);
        }
    }

    @ApiOperation(value = "协议支付签约短信签约", notes = "协议支付签约短信签约")
    @PostMapping(value = "agreeMentPaySmsSign")
    public FebsResponse agreeMentPaySmsSign(@RequestBody AgreementSignDto agreementSignDto) {
        String agreeMentPaySms = unipayService.agreementSign(agreementSignDto);
        if("fail".equals(agreeMentPaySms)){
            return new FebsResponse().fail().message("签约失败，请重新下单");
        }else{
            JSONObject jsonObject = JSONUtil.parseObj(agreeMentPaySms);
            String resultStr = (String) jsonObject.get("biz_code");
            String signData = (String) jsonObject.get("data");
            String signBizMsg = (String) jsonObject.get("biz_msg");
            if(StrUtil.isNotBlank(signData)){
                JSONObject signDatajsonObject = JSONUtil.parseObj(signData);
                String err_msg = (String) signDatajsonObject.get("err_msg");
                if(ObjectUtil.isNotNull(signDatajsonObject.get("err_code"))){
                    return new FebsResponse().fail().message(err_msg+"签约失败，请重新下单");
                }
            }
            if(!"JS000000".equals(resultStr)){
                return new FebsResponse().fail().message(signBizMsg+"签约失败，请重新下单");
            }else{
                MallMember member = LoginUserUtil.getLoginUser();
                Long bankId = agreementSignDto.getBankId();
                MallMemberBank mallMemberBank = mallMemberBankMapper.selectById(bankId);
                String bankNo = mallMemberBank.getBankNo();
                MallMemberBankSign mallMemberBankSign = new MallMemberBankSign();
                mallMemberBankSign.setMemberId(member.getId());
                mallMemberBankSign.setBankCardNo(bankNo);
                mallMemberBankSignMapper.insert(mallMemberBankSign);
                return new FebsResponse().success().message(signBizMsg);
            }
        }
    }

    @PostMapping(value = "/agreeMentPayCallBack")
    public String agreeMentPayCallBack(@RequestBody AgreeMentPayCallBackDto agreeMentPayCallBackDto){
        log.info("进入汇聚支付协议支付回调"+ JSONUtil.parseObj(agreeMentPayCallBackDto));
        String data = agreeMentPayCallBackDto.getData();
        JSONObject jsonObject = JSONUtil.parseObj(data);
        String orderNo = jsonObject.get("mch_order_no").toString();
        String pay_success_time = jsonObject.get("pay_success_time").toString();
        String jp_order_no = jsonObject.get("jp_order_no").toString();
        String biz_code = agreeMentPayCallBackDto.getBiz_code();

        log.info("进入汇聚支付协议支付回调"+orderNo+";"+pay_success_time+";"+biz_code+";"+jp_order_no);
        if("JS000000".equals(biz_code) && StrUtil.isNotBlank(orderNo)){
            MallOrderInfo orderInfo = orderInfoMapper.selectByOrderNo(orderNo);
            if(ObjectUtil.isNotEmpty(orderInfo)){
                Integer status = orderInfo.getStatus();
                if(OrderStatusEnum.WAIT_PAY.getValue() == status){

                    orderInfo.setStatus(OrderStatusEnum.WAIT_SHIPPING.getValue());
                    orderInfo.setPayResult("1");
                    orderInfo.setPayTime(DateUtil.parse(pay_success_time));
                    orderInfo.setPayTradeNo(jp_order_no);
                    orderInfo.setPayOrderNo(orderNo);
                    orderInfoMapper.updateById(orderInfo);

                    boolean hasTc = false;
                    // 静态倍数
                    List<MallOrderItem> orderItems = mallOrderInfoMapper.getMallOrderItemByOrderId(orderInfo.getId());
                    if (CollUtil.isNotEmpty(orderItems)) {
                        for (MallOrderItem orderItem : orderItems) {
                            MallGoods mallGoods = mallGoodsMapper.selectById(orderItem.getGoodsId());
                            BigDecimal score = BigDecimal.ZERO;
                            MallGoodsSku sku = mallGoodsSkuMapper.selectById(orderItem.getSkuId());
                            if (mallGoods.getIsNormal() == 2) {
                                hasTc = true;
                                score = sku.getPresentPrice().multiply(mallGoods.getStaticMulti()).multiply(new BigDecimal(orderItem.getCnt()));
                                // 普通商品也及时结算，不再10天结算
                            } else {
                                score = sku.getPresentPrice();
                            }

                            if (score.compareTo(BigDecimal.ZERO) > 0) {
                                memberWalletService.add(score, orderInfo.getMemberId(), "score");
                                mallMoneyFlowService.addMoneyFlow(orderInfo.getMemberId(), score, MoneyFlowTypeEnum.STATIC_BONUS.getValue(), orderInfo.getOrderNo(), FlowTypeEnum.SCORE.getValue());

                                // 添加业绩
                                mallAchieveService.add(orderItem.getId());
                            }
                        }
                    }

                    // 购买套餐后，升级为普通会员
                    MallMember mallMember = memberMapper.selectById(orderInfo.getMemberId());
                    if (hasTc) {
                        if (AgentLevelEnum.ZERO_LEVEL.name().equals(mallMember.getLevel())) {
                            mallMember.setLevel(AgentLevelEnum.FIRST_LEVEL.name());
                            memberMapper.updateById(mallMember);
                        }
                    }

                    mallMoneyFlowService.addMoneyFlow(mallMember.getId(), orderInfo.getAmount().negate(), MoneyFlowTypeEnum.PAY.getValue(), orderInfo.getOrderNo(), FlowTypeEnum.BALANCE.getValue());
                }
            }
        }
        return "success";
    }

    @PostMapping(value = "/singlePayCallBack")
    public JSONObject singlePayCallBack(@RequestBody SinglePayCallBackDto singlePayCallBackDto){
        log.info("进入汇聚支付代付回调"+ JSONUtil.parseObj(singlePayCallBackDto));
        String status = singlePayCallBackDto.getStatus();
        BigDecimal paidAmount = singlePayCallBackDto.getPaidAmount();
        BigDecimal paidAmountFee = singlePayCallBackDto.getFee();
        String errorCode = singlePayCallBackDto.getErrorCode();
        String errorCodeDesc = singlePayCallBackDto.getErrorCodeDesc();
        String merchantOrderNo = singlePayCallBackDto.getMerchantOrderNo();

        log.info("进入汇聚支付代付回调"+status+";"+paidAmount+";"+paidAmountFee+";");
        if("205".equals(status) && "".equals(errorCode)){
            QueryWrapper<MallMemberWithdraw> objectQueryWrapper = new QueryWrapper<>();
            objectQueryWrapper.eq("withdraw_no",merchantOrderNo);
            MallMemberWithdraw mallMemberWithdraw = mallMemberWithdrawMapper.selectOne(objectQueryWrapper);
            if(ObjectUtil.isNotEmpty(mallMemberWithdraw)){
                mallMemberWithdraw.setStatus(2);
                mallMemberWithdrawMapper.updateById(mallMemberWithdraw);

                QueryWrapper<MallMoneyFlow> flowQueryWrapper = new QueryWrapper<>();
                flowQueryWrapper.eq("order_no",mallMemberWithdraw.getWithdrawNo());
                flowQueryWrapper.eq("type",MoneyFlowTypeEnum.WITHDRAWAL.getValue());
                MallMoneyFlow mallMoneyFlow = mallMoneyFlowMapper.selectOne(flowQueryWrapper);
                if(ObjectUtil.isNotEmpty(mallMoneyFlow)){
                    mallMoneyFlow.setStatus(2);
                    mallMoneyFlowMapper.updateById(mallMoneyFlow);
                }
            }
        }else{
            QueryWrapper<MallMemberWithdraw> objectQueryWrapper = new QueryWrapper<>();
            objectQueryWrapper.eq("withdraw_no",merchantOrderNo);
            MallMemberWithdraw mallMemberWithdraw = mallMemberWithdrawMapper.selectOne(objectQueryWrapper);
            if(ObjectUtil.isNotEmpty(mallMemberWithdraw)){
                mallMemberWithdraw.setRemark(errorCodeDesc);
                mallMemberWithdrawMapper.updateById(mallMemberWithdraw);
            }
        }

        SinglePayCallBackVo singlePayCallBackVo = new SinglePayCallBackVo();
        singlePayCallBackVo.setStatusCode("2001");
        singlePayCallBackVo.setMessage("成功");
        JSONObject jsonObject = JSONUtil.parseObj(singlePayCallBackVo);
        return jsonObject;
    }

}