package com.xcong.excoin.quartz.job;

import com.xcong.excoin.modules.coin.service.OrderCoinService;
import com.xcong.excoin.modules.contract.service.ContractHoldOrderService;
import com.xcong.excoin.modules.home.dao.MemberQuickBuySaleDao;
import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;

/**
 * @author wzy
 * @date 2020-06-08
 **/
@Slf4j
@Component
@ConditionalOnProperty(prefix = "app", name = "loop-job", havingValue = "true")
public class LoopExecutorJob {

    @Resource
    private MemberQuickBuySaleDao memberQuickBuySaleDao;

    @Resource
    private ContractHoldOrderService contractHoldOrderService;

    @Resource
    private OrderCoinService orderCoinService;

    /**
     * 更新快捷充值超时状态
     */
    @Scheduled(cron = "0/5 * * * * ? ")
    @Transactional(rollbackFor = Exception.class)
    public void updateChargeUsdt() {
        try {
            memberQuickBuySaleDao.updateQuickBuySaleTimeOut();
        } catch (Exception e) {
            log.error("更新快捷充值超时状态", e);
        }
    }


    /**
     * 持仓费计算
     */
    @Scheduled(cron = "0 0 16/8 * * ?")
    public void updateDoingPrice() {
        log.info("#持仓费计算#");
        try {
            contractHoldOrderService.calHoldOrderHoldFeeAmount();
        } catch (Exception e) {
            log.error("#持仓费计算错误#", e);
        }
    }

    /**
     * 币币委托单成交
     */
    @Scheduled(cron = "0/5 * * * * ? ")
    public void coinEntrustToDeal() {
        try {
            orderCoinService.dealEntrustCoinOrder();
        } catch (Exception e) {
            log.error("#币币委托单成交错误#", e);
        }
    }
}