文件名从 src/main/java/com/fzzy/order/OrderManager.java 修改 |
| | |
| | | package com.fzzy.order; |
| | | package com.fzzy.order.common; |
| | | |
| | | import com.alibaba.fastjson.JSONObject; |
| | | import com.fzzy.api.entity.ApiConfs; |
| | | import com.fzzy.api.view.pr.ApiConfsPR; |
| | | import com.fzzy.order.data.OrderData; |
| | | import com.fzzy.order.data.OrderReq; |
| | | import com.fzzy.order.common.data.OrderCommonData; |
| | | import com.fzzy.order.common.data.OrderCommonReq; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springframework.beans.BeansException; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | |
| | | * @date 2023/8/17 |
| | | */ |
| | | @Slf4j |
| | | @Component(OrderManager.BEAN_ID) |
| | | public class OrderManager implements ApplicationContextAware { |
| | | @Component(OrderCommonManager.BEAN_ID) |
| | | public class OrderCommonManager implements ApplicationContextAware { |
| | | public static final String BEAN_ID = "order.orderManager"; |
| | | |
| | | private static Map<String, OrderApiService> serviceMap; |
| | | private static Map<String, OrderCommonService> serviceMap; |
| | | |
| | | @Autowired |
| | | private ApiConfsPR apiConfsPR; |
| | | |
| | | @Override |
| | | public void setApplicationContext(ApplicationContext applicationContext) throws BeansException { |
| | | Map<String, OrderApiService> map = applicationContext.getBeansOfType(OrderApiService.class); |
| | | Map<String, OrderCommonService> map = applicationContext.getBeansOfType(OrderCommonService.class); |
| | | serviceMap = new HashMap<>(); |
| | | for (String key : map.keySet()) { |
| | | serviceMap.put(map.get(key).getProtocol(), map.get(key)); |
| | |
| | | * @param req |
| | | */ |
| | | @Async |
| | | public void execute(OrderReq<JSONObject> req){ |
| | | public void execute(OrderCommonReq<JSONObject> req){ |
| | | |
| | | try{ |
| | | //鑾峰彇閰嶇疆淇℃伅 |
| | |
| | | if(null == apiConfList || apiConfList.isEmpty()){ |
| | | return; |
| | | } |
| | | OrderData data = JSONObject.parseObject(req.getData().toString(), OrderData.class); |
| | | OrderCommonData data = JSONObject.parseObject(req.getData().toString(), OrderCommonData.class); |
| | | data.setOrderid(req.getOrderid()); |
| | | //鏍规嵁閰嶇疆淇℃伅鎵ц |
| | | OrderApiService service; |
| | | OrderCommonService service; |
| | | for (ApiConfs conf : apiConfList) { |
| | | |
| | | service = serviceMap.get(conf.getPushProtocol()); |