czt
2024-04-23 f55b2623f09b0b902f991c701c67a2a6f2577057
src/main/java/com/fzzy/order/common/OrderCommonManager.java
文件名从 src/main/java/com/fzzy/order/OrderManager.java 修改
@@ -1,10 +1,10 @@
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;
@@ -23,18 +23,18 @@
 * @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));
@@ -47,7 +47,7 @@
     * @param req
     */
    @Async
    public void execute(OrderReq<JSONObject> req){
    public void execute(OrderCommonReq<JSONObject> req){
        try{
            //鑾峰彇閰嶇疆淇℃伅
@@ -55,10 +55,10 @@
            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());