package com.panzhihua.service_community.service.impl;

import cn.hutool.core.date.DateUnit;
import cn.hutool.core.date.DateUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.panzhihua.common.model.dtos.property.CommonPage;
import com.panzhihua.common.model.vos.R;
import com.panzhihua.common.model.vos.community.rentHouse.RentingHourseOrderVO;
import com.panzhihua.common.model.vos.community.rentHouse.WxPayNotifyOrderVO;
import com.panzhihua.common.model.vos.community.rentHouse.WxPayOrderVO;
import com.panzhihua.common.utlis.DateUtils;
import com.panzhihua.common.utlis.Snowflake;
import com.panzhihua.common.utlis.WxPayUtils;
import com.panzhihua.common.utlis.WxUtil;
import com.panzhihua.service_community.dao.RentingHoursePayingOrderDao;
import com.panzhihua.service_community.dao.RentingHoursePreOrderDao;
import com.panzhihua.service_community.dao.RentingHourseRegisterDao;
import com.panzhihua.service_community.entity.RentingHourseOrder;
import com.panzhihua.service_community.dao.RentingHourseOrderDao;
import com.panzhihua.service_community.entity.RentingHoursePayingOrder;
import com.panzhihua.service_community.entity.RentingHoursePreOrder;
import com.panzhihua.service_community.entity.RentingHourseRegister;
import com.panzhihua.service_community.service.RentingHourseOrderService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;

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

/**
 * 房屋租赁-房屋订单表(RentingHourseOrder)表服务实现类
 *
 * @author makejava
 * @since 2021-11-23 10:46:57
 */
@Slf4j
@Service
public class RentingHourseOrderServiceImpl extends ServiceImpl<RentingHourseOrderDao, RentingHourseOrder> implements RentingHourseOrderService {

    @Resource
    private RentingHoursePreOrderDao rentingHoursePreOrderDao;
    @Resource
    private RentingHourseOrderDao rentingHourseOrderDao;
    @Resource
    private RentingHoursePayingOrderDao rentingHoursePayingOrderDao;
    @Resource
    private RentingHourseRegisterDao rentingHourseRegisterDao;
    @Resource
    private RabbitTemplate rabbitTemplate;
    @Value("${min.app.isTest}")
    private Boolean isTest;
    @Value("${min.app.appid}")
    private String appid;
    @Value("${min.app.payKey}")
    private String payKey;
    @Value("${min.app.mchId}")
    private String mchId;
    @Value("${min.app.notifyUrl}")
    private String notifyUrl;
    @Override
    public R pageList(CommonPage commonPage) {
        return R.ok(rentingHourseOrderDao.pageList(new Page(commonPage.getPage(), commonPage.getSize()),commonPage));
    }

    @Override
    public R createOrder(RentingHourseOrderVO rentingHourseOrderVO) {
        RentingHourseOrder rentingHourseOrder=new RentingHourseOrder();
        BeanUtils.copyProperties(rentingHourseOrderVO,rentingHourseOrder);
        RentingHourseRegister rentingHourseRegister=rentingHourseRegisterDao.selectById(rentingHourseOrderVO.getRegisterId());
        if(rentingHourseRegister==null){
            return R.fail("未查询到该租房信息");
        }
        if(rentingHourseRegister.getStatus()!=RentingHourseRegister.Status.dcz&&rentingHourseRegister.getDetailStatus()!=3){
            return R.fail("该房屋状态不可出租");
        }
        rentingHourseOrder.setVillageId(rentingHourseRegister.getVillageId());
        rentingHourseOrder.setVillageName(rentingHourseRegister.getVillageName());
        rentingHourseOrder.setStreetId(rentingHourseRegister.getStreetId());
        rentingHourseOrder.setCreateDate(new Date());
        rentingHourseOrder.setId(Snowflake.getId());
        rentingHourseOrder.setOrderSn(DateUtils.getCurrentDateTimeStamp()+"");
        rentingHourseOrder.setStatus(RentingHourseOrder.status.wzf);
        rentingHourseOrder.setOrderType(RentingHourseOrder.orderType.pt);
        if(rentingHourseOrderDao.insert(rentingHourseOrder)>0){
            return R.ok(rentingHourseOrder.getOrderSn());
        }
        return R.fail("添加失败");
    }

    /**
     * 支付回调  判断订单类型并进行相应的逻辑处理
     * @param wxPayNotifyOrderVO
     * @return
     */
    @Override
    public R wxPayNotify(WxPayNotifyOrderVO wxPayNotifyOrderVO) {
        RentingHoursePayingOrder rentingHoursePayingOrder=new RentingHoursePayingOrder();
        BeanUtils.copyProperties(wxPayNotifyOrderVO,rentingHoursePayingOrder);
        rentingHoursePayingOrder.setId(Snowflake.getId());
        rentingHoursePayingOrderDao.insert(rentingHoursePayingOrder);
        RentingHourseOrder rentingHourseOrder=rentingHourseOrderDao.selectOne(new QueryWrapper<RentingHourseOrder>().lambda().eq(RentingHourseOrder::getOrderSn,wxPayNotifyOrderVO.getOrderSn()));
        RentingHoursePreOrder rentingHoursePreOrder=rentingHoursePreOrderDao.selectOne(new QueryWrapper<RentingHoursePreOrder>().lambda().eq(RentingHoursePreOrder::getOrderSn,wxPayNotifyOrderVO.getOrderSn()));
        if(rentingHourseOrder!=null){
            rentingHourseOrder.setStatus(RentingHourseOrder.status.yzf);
            rentingHourseOrder.setPaySn(rentingHoursePayingOrder.getId());
            rentingHourseOrderDao.updateById(rentingHourseOrder);
            RentingHourseRegister rentingHourseRegister=rentingHourseRegisterDao.selectById(rentingHourseOrder.getRegisterId());
            rentingHourseRegister.setStatus(2);
            rentingHourseRegister.setDetailStatus(4);
            rentingHourseRegisterDao.updateById(rentingHourseRegister);
            rabbitTemplate.convertAndSend("huacheng.order.exchange", "huacheng.order.key", rentingHourseOrder, message -> {
                message.getMessageProperties().setHeader("x-delay", dateToSecond(DateUtil.endOfDay(DateUtil.date())) * 1000 * 3600);
                return message;
            });
        }
        if(rentingHoursePreOrder!=null){
            rentingHoursePreOrder.setStatus(RentingHoursePreOrder.status.yjl);
            rentingHoursePreOrder.setPaySn(rentingHoursePayingOrder.getId());
            rentingHoursePreOrderDao.updateById(rentingHoursePreOrder);
            RentingHourseRegister rentingHourseRegister=rentingHourseRegisterDao.selectById(rentingHourseOrder.getRegisterId());
            rentingHourseRegister.setStatus(2);
            rentingHourseRegister.setDetailStatus(4);
            rentingHourseRegisterDao.updateById(rentingHourseRegister);
            rabbitTemplate.convertAndSend("huacheng.preOrder.exchange", "huacheng.preOrder.key", rentingHoursePreOrder, message -> {
                message.getMessageProperties().setHeader("x-delay", dateToSecond(rentingHoursePreOrder.getExpireDate()) * 1000 * 3600);
                return message;
            });
        }
        return R.ok();
    }

    @Override
    public R wxPay(WxPayOrderVO wxPayOrderVO) {
        RentingHourseOrder rentingHourseOrder=rentingHourseOrderDao.selectOne(new QueryWrapper<RentingHourseOrder>().lambda().eq(RentingHourseOrder::getOrderSn,wxPayOrderVO.getOrderSn()));
        RentingHoursePreOrder rentingHoursePreOrder=rentingHoursePreOrderDao.selectOne(new QueryWrapper<RentingHoursePreOrder>().lambda().eq(RentingHoursePreOrder::getOrderSn,wxPayOrderVO.getOrderSn()));
        if(rentingHourseOrder!=null){
            try {
                BigDecimal money = rentingHourseOrder.getTotalAccount();
                if (isTest) {
                    money = BigDecimal.valueOf(0.01);
                }
                // 调用wx支付
                WxPayUtils.getUnifiedorder(appid, mchId, payKey, notifyUrl, "签订租房合同", wxPayOrderVO.getOpenId(),
                        wxPayOrderVO.getOrderSn(), money,null);
                return R.ok();
            } catch (Exception e) {
                log.error("调用微信支付异常,异常原因：" + e.getMessage());
            }
        }
        if(rentingHoursePreOrder!=null){
            try {
                BigDecimal money = rentingHoursePreOrder.getDingMoney();
                if (isTest) {
                    money = BigDecimal.valueOf(0.01);
                }
                // 调用wx支付
                WxPayUtils.getUnifiedorder(appid, mchId, payKey, notifyUrl, "定金支付", wxPayOrderVO.getOpenId(),
                        wxPayOrderVO.getOrderSn(), money,null);
                return R.ok();
            } catch (Exception e) {
                log.error("调用微信支付异常,异常原因：" + e.getMessage());
            }
        }
        return R.fail("订单信息异常");
    }

    @Override
    public R statics(RentingHourseOrderVO rentingHourseOrderVO) {
        return R.ok(this.rentingHourseOrderDao.orderStatics(rentingHourseOrderVO));
    }

    private Long dateToSecond(Date expireTime){
        return DateUtil.between(new Date(),expireTime, DateUnit.MS);
    }
}