新增重置通知的定时调度
This commit is contained in:
parent
5e434a4d32
commit
8ac2a856b2
|
|
@ -75,6 +75,7 @@ public class MonitorTradeModelImpl extends AbstractMonitor {
|
||||||
logger.error("尚未配置系统参数【goods_Price_Increase_Rate】.");
|
logger.error("尚未配置系统参数【goods_Price_Increase_Rate】.");
|
||||||
}else {
|
}else {
|
||||||
goodsPriceIncreaseRate = new BigDecimal(goodsPriceIncreaseRateStr.trim());
|
goodsPriceIncreaseRate = new BigDecimal(goodsPriceIncreaseRateStr.trim());
|
||||||
|
logger.info("初始化参数:【"+TradeConstants.GOODS_PRICE_INCREASE_RATE+"】值:【"+goodsPriceIncreaseRateStr.trim()+"】");
|
||||||
}
|
}
|
||||||
|
|
||||||
//2.设置放量比
|
//2.设置放量比
|
||||||
|
|
@ -83,6 +84,7 @@ public class MonitorTradeModelImpl extends AbstractMonitor {
|
||||||
logger.error("尚未配置系统参数【goods_Volumes_Increase_Rate】.");
|
logger.error("尚未配置系统参数【goods_Volumes_Increase_Rate】.");
|
||||||
}else {
|
}else {
|
||||||
goodsVolumesIncreaseRate = new BigDecimal(goodsVolumesIncreaseRateStr.trim());
|
goodsVolumesIncreaseRate = new BigDecimal(goodsVolumesIncreaseRateStr.trim());
|
||||||
|
logger.info("初始化参数:【"+TradeConstants.GOODS_VOLUMES_INCREASE_RATE+"】值:【"+goodsVolumesIncreaseRateStr.trim()+"】");
|
||||||
}
|
}
|
||||||
//3.风控比
|
//3.风控比
|
||||||
String moneyPoolLossRateStr = sysConfigService.selectConfigByKey(TradeConstants.MONEY_POOL_LOSS_RATE) ;
|
String moneyPoolLossRateStr = sysConfigService.selectConfigByKey(TradeConstants.MONEY_POOL_LOSS_RATE) ;
|
||||||
|
|
@ -90,6 +92,7 @@ public class MonitorTradeModelImpl extends AbstractMonitor {
|
||||||
logger.error("尚未配置系统参数【money_Pool_Loss_Rate】.");
|
logger.error("尚未配置系统参数【money_Pool_Loss_Rate】.");
|
||||||
}else {
|
}else {
|
||||||
moneyPoolLossRate = new BigDecimal(moneyPoolLossRateStr.trim());
|
moneyPoolLossRate = new BigDecimal(moneyPoolLossRateStr.trim());
|
||||||
|
logger.info("初始化参数:【"+TradeConstants.MONEY_POOL_LOSS_RATE+"】值:【"+moneyPoolLossRateStr.trim()+"】");
|
||||||
}
|
}
|
||||||
//4.交易次数
|
//4.交易次数
|
||||||
String moneyPoolTradeNumsStr = sysConfigService.selectConfigByKey(TradeConstants.MONEY_POOL_TRADE_NUMS) ;
|
String moneyPoolTradeNumsStr = sysConfigService.selectConfigByKey(TradeConstants.MONEY_POOL_TRADE_NUMS) ;
|
||||||
|
|
@ -97,6 +100,7 @@ public class MonitorTradeModelImpl extends AbstractMonitor {
|
||||||
logger.error("尚未配置系统参数【money_Pool_Trade_Nums】.");
|
logger.error("尚未配置系统参数【money_Pool_Trade_Nums】.");
|
||||||
}else {
|
}else {
|
||||||
moneyPoolTradeNums = new BigDecimal(moneyPoolTradeNumsStr.trim());
|
moneyPoolTradeNums = new BigDecimal(moneyPoolTradeNumsStr.trim());
|
||||||
|
logger.info("初始化参数:【"+TradeConstants.MONEY_POOL_TRADE_NUMS+"】值:【"+moneyPoolTradeNumsStr.trim()+"】");
|
||||||
}
|
}
|
||||||
//4.交易份额
|
//4.交易份额
|
||||||
String goodsTradeMinAmountStr = sysConfigService.selectConfigByKey(TradeConstants.GOODS_TRADE_MIN_AMOUNT) ;
|
String goodsTradeMinAmountStr = sysConfigService.selectConfigByKey(TradeConstants.GOODS_TRADE_MIN_AMOUNT) ;
|
||||||
|
|
@ -104,8 +108,8 @@ public class MonitorTradeModelImpl extends AbstractMonitor {
|
||||||
logger.error("尚未配置系统参数【goods_trade_min_amount】.");
|
logger.error("尚未配置系统参数【goods_trade_min_amount】.");
|
||||||
}else {
|
}else {
|
||||||
goodsTradeMinAmount = Integer.parseInt(goodsTradeMinAmountStr) ;
|
goodsTradeMinAmount = Integer.parseInt(goodsTradeMinAmountStr) ;
|
||||||
|
logger.info("初始化参数:【"+TradeConstants.GOODS_TRADE_MIN_AMOUNT+"】值:【"+goodsTradeMinAmountStr.trim()+"】");
|
||||||
}
|
}
|
||||||
logger.info("完成初始化模型监控参数");
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|
|
||||||
|
|
@ -7,21 +7,14 @@ import org.slf4j.Logger;
|
||||||
import org.slf4j.LoggerFactory;
|
import org.slf4j.LoggerFactory;
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
import org.springframework.beans.factory.annotation.Qualifier;
|
import org.springframework.beans.factory.annotation.Qualifier;
|
||||||
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
|
|
||||||
import org.springframework.context.annotation.ComponentScan;
|
|
||||||
import org.springframework.test.context.ContextConfiguration;
|
|
||||||
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
|
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
|
||||||
import org.springframework.test.context.web.WebAppConfiguration;
|
|
||||||
|
|
||||||
import com.cronie.mengyu.monitor.impl.ResetTradeModelInsMailNoticeImpl;
|
|
||||||
import com.ruoyi.system.mapper.SysUserMapper;
|
|
||||||
import com.ruoyi.system.service.impl.SysUserServiceImpl;
|
|
||||||
|
|
||||||
@RunWith(SpringJUnit4ClassRunner.class)
|
@RunWith(SpringJUnit4ClassRunner.class)
|
||||||
@EnableAutoConfiguration
|
//@EnableAutoConfiguration
|
||||||
@ContextConfiguration(classes={ ResetTradeModelInsMailNoticeImpl.class})
|
//@ContextConfiguration(classes={ ResetTradeModelInsMailNoticeImpl.class})
|
||||||
@WebAppConfiguration
|
//@WebAppConfiguration
|
||||||
@ComponentScan({"com.ruoyi.*","com.cronie.*"})
|
//@ComponentScan({"com.ruoyi.*","com.cronie.*"})
|
||||||
|
//@SpringApplicationConfiguration
|
||||||
public class ResetTradeModelInsMailNoticeImplTest {
|
public class ResetTradeModelInsMailNoticeImplTest {
|
||||||
|
|
||||||
private static final Logger logger = LoggerFactory.getLogger(ResetTradeModelInsMailNoticeImplTest.class);
|
private static final Logger logger = LoggerFactory.getLogger(ResetTradeModelInsMailNoticeImplTest.class);
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue