package com.nova.sankuai.service.impl;

import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.IdUtil;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.nova.sankuai.domain.api.yangqianguan.YqgUtil;
import com.nova.sankuai.domain.api.yangqianguan.dto.RepayResultReturnDto;
import com.nova.sankuai.domain.entity.YqgRepayOrder;
import com.nova.sankuai.domain.entity.YqgRepayOrderDetail;
import com.nova.sankuai.infra.mapper.YqgRepayOrderDetailMapper;
import com.nova.sankuai.infra.mapper.YqgRepayOrderMapper;
import com.nova.sankuai.service.IYqgRepayOrderService;
import lombok.AllArgsConstructor;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.Date;
import java.util.List;

/**
 * @author weikangdi
 * @create 2022/6/9
 */
@Service
@AllArgsConstructor
public class YqgRepayOrderServiceImpl extends ServiceImpl<YqgRepayOrderMapper, YqgRepayOrder> implements IYqgRepayOrderService {

    private final YqgRepayOrderDetailMapper yqgRepayOrderDetailMapper;

    private final YqgRepayOrderMapper yqgRepayOrderMapper;

    private static final Logger yqgLog = LoggerFactory.getLogger("yqgLogger");

    private static final int CLOSE_LIMIT = 30;

    private final YqgUtil yqgUtil;

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void createRepayOrderDetail(YqgRepayOrder yqgRepayOrder, List<String> termList) {
        for (String term : termList) {
            YqgRepayOrderDetail yqgRepayOrderDetail = new YqgRepayOrderDetail();
            yqgRepayOrderDetail.setOrderNo(yqgRepayOrder.getOrderNo());
            yqgRepayOrderDetail.setCapitalResultId(yqgRepayOrder.getCapitalResultId());
            yqgRepayOrderDetail.setStatus(YqgRepayOrderDetail.STATUS_WAIT);
            yqgRepayOrderDetail.setPeriodNo(term);
            yqgRepayOrderDetail.setRepayApplyNo(yqgRepayOrder.getRepayApplyNo());
            yqgRepayOrderDetail.setRepayNo(yqgRepayOrder.getRepayNo());
            yqgRepayOrderDetail.setCreationDate(new Date());
            yqgRepayOrderDetail.setLastUpdatedDate(new Date());
            yqgRepayOrderDetailMapper.insert(yqgRepayOrderDetail);
        }
    }

    @Override
    public void closeYqgRepayOrder() {
        String logNumber = IdUtil.randomUUID();
        Date date = DateUtil.offsetMinute(new Date(), -CLOSE_LIMIT);
        yqgLog.info(logNumber + "定时关闭洋钱罐过期还款申请订单开始: " + "关闭" + date + "之前创建的初始化还款订单");
        List<YqgRepayOrder> yqgRepayOrders = yqgRepayOrderMapper.selectCloseOrder(date);
        for (YqgRepayOrder yqgRepayOrder : yqgRepayOrders) {
            try {
                yqgRepayOrder.setLastUpdatedDate(new Date());
                yqgRepayOrder.setStatus(YqgRepayOrder.STATUS_FAIL);
                yqgRepayOrder.setRemark("短信校验超时，关闭申请");
                yqgRepayOrderMapper.update(null, Wrappers.<YqgRepayOrder>lambdaUpdate()
                        .set(YqgRepayOrder::getLastUpdatedDate, yqgRepayOrder.getLastUpdatedDate())
                        .set(YqgRepayOrder::getStatus, yqgRepayOrder.getStatus())
                        .set(YqgRepayOrder::getRemark, yqgRepayOrder.getRemark())
                        .eq(YqgRepayOrder::getId, yqgRepayOrder.getId()));
                RepayResultReturnDto feedBackDto = RepayResultReturnDto.parseDto(yqgRepayOrder, null);
                if (feedBackDto != null) {
                    yqgUtil.repayResultFeedBack(feedBackDto, yqgLog, logNumber);
                }
            } catch (Exception e) {
                yqgLog.error(logNumber + "定时关闭洋钱罐过期还款申请订单失败:" + yqgRepayOrder.toString(), e);
            }
        }
        yqgLog.info(logNumber + "定时关闭洋钱罐过期还款申请订单结束");
    }

}