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));
//            }
//        }
//    }

}