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 0/8 * * ?")
|
public void updateDoingPrice() {
|
log.info("#持仓费计算#");
|
try {
|
contractHoldOrderService.calHoldFeeAmountForBondAmount();
|
} catch (Exception e) {
|
log.error("#持仓费计算错误#", e);
|
}
|
}
|
|
/**
|
* 币币委托单成交
|
*/
|
@Scheduled(cron = "0/5 * * * * ? ")
|
public void coinEntrustToDeal() {
|
try {
|
orderCoinService.dealEntrustCoinOrder();
|
} catch (Exception e) {
|
log.error("#币币委托单成交错误#", e);
|
}
|
}
|
}
|
