package com.fzzy.order.ordersx2023;

import com.fzzy.api.entity.ApiConfs;
import com.fzzy.api.view.pr.ApiConfsPR;
import com.fzzy.order.ordersx2023.data.OrderSxReq;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.BeansException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;

import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * @Description 指令下发入口
 * @Author CZT
 * @Date 2024/4/23 11:36
 */
@Slf4j
@Component(OrderSxManager.BEAN_ID)
public class OrderSxManager implements ApplicationContextAware {
    public static final String BEAN_ID = "order.orderSxManager";

    private static Map<String, OrderSxService> serviceMap;

    @Autowired
    private ApiConfsPR apiConfsPR;

    @Override
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
        Map<String, OrderSxService> map = applicationContext.getBeansOfType(OrderSxService.class);
        serviceMap = new HashMap<>();
        for (String key : map.keySet()) {
            serviceMap.put(map.get(key).getProtocol(), map.get(key));
        }
    }

    @Async
    public void execute(OrderSxReq req){

        try{
            //获取配置信息
            List<ApiConfs> apiConfList = apiConfsPR.listAll();
            if(null == apiConfList || apiConfList.isEmpty()){
                log.error("陕西省平台：收到指令，未获取到库区配置信息，不执行！");
                return;
            }
            //根据配置信息执行
            OrderSxService service;
            for (ApiConfs conf : apiConfList) {
                service = serviceMap.get(conf.getPushProtocol());
                if(null == service){
                    log.error("陕西省平台：收到指令，未获取到协议，不执行！");
                    continue;
                }
                service.execute(req, conf);
            }
        } catch (Exception e) {
            log.error("陕西省平台：指令执行失败，错误={}", e.getLocalizedMessage());
        }
    }
}