package com.xcong.excoin.utils;
|
|
import com.xcong.excoin.modules.contract.entity.ContractOrderEntity;
|
import com.xcong.excoin.modules.contract.service.impl.OrderWebsocketServiceImpl;
|
import com.xcong.excoin.utils.dingtalk.DingTalkUtils;
|
|
import java.math.BigDecimal;
|
import java.util.concurrent.ExecutorService;
|
import java.util.concurrent.Executors;
|
|
/**
|
* @author wzy
|
* @date 2020-06-01
|
**/
|
public class ThreadPoolUtils {
|
|
public static final ExecutorService EXECUTOR = Executors.newFixedThreadPool(20);
|
|
/**
|
* 计算佣金
|
*
|
* @param id 用户ID
|
* @param price 手续费
|
* @param entity 订单实体
|
* @param type 订单类型
|
*/
|
public static void calReturnMoney(Long id, BigDecimal price, ContractOrderEntity entity, int type) {
|
OrderWebsocketServiceImpl orderWebsocketService = SpringContextHolder.getBean(OrderWebsocketServiceImpl.class);
|
EXECUTOR.execute(new Runnable() {
|
@Override
|
public void run() {
|
orderWebsocketService.calYj(id, price, entity, type);
|
}
|
});
|
}
|
|
/**
|
* 发送钉钉消息
|
*
|
* @param type 类型
|
*/
|
public static void sendDingTalk(int type) {
|
EXECUTOR.execute(new Runnable() {
|
@Override
|
public void run() {
|
// DingTalkUtils.sendActionCard(type);
|
}
|
});
|
}
|
}
|