package com.sandu.ximon.admin.security.order;
|
|
import com.sandu.ximon.admin.utils.SpringContextUtil;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.context.ApplicationEventPublisher;
|
import org.springframework.stereotype.Component;
|
|
import java.util.concurrent.ExecutorService;
|
import java.util.concurrent.Executors;
|
|
@Component("OrderQueryListener")
|
public class OrderQueryListener {
|
|
@Autowired
|
public ApplicationEventPublisher publisher;
|
|
private static final ExecutorService orderEventPool = Executors.newFixedThreadPool(5);
|
|
public static OrderQueryListener getBean(){
|
return (OrderQueryListener) SpringContextUtil.getBean("OrderQueryListener");
|
}
|
|
/**
|
* 启动订单扫描
|
* @param type 0:C3充电桩扫描启动
|
*/
|
public void startScan (Integer type) {
|
// 载入订单扫描
|
orderEventPool.submit(new OrderQueryTask(type));
|
}
|
|
|
// @Scheduled(cron = "0/10 * * * * ? ")
|
// public void orderScan () {
|
// if(isQuery) {
|
// /**
|
// * 获取所有订单，根据订单类型不同进行不同的Query
|
// */
|
// // C3充电桩部分
|
// Set<String> keys = redisUtils.keys(C3mRedisConstant.C3_NO_PAY_ORDER.getCode() + "*");
|
// for (String key : keys) {
|
// C3mOrderEntity c3mOrderEntity = JSON.parseObject(redisUtils.get(key), C3mOrderEntity.class);
|
// LogUtils.error("查询订单：" + JSON.toJSONString(c3mOrderEntity));
|
// publisher.publishEvent(new C3mOrderQueryEvent(this, c3mOrderEntity));
|
// }
|
// }
|
// }
|
|
}
|
