加入eureka docker-compose 管理

吴学文

2019-05-24 4c68289b0ae81e994147430b6ad62e2a4ef908d6

 OrderService/src/main/java/com/java110/order/smo/impl/OrderServiceSMOImpl.java

@@ -2,20 +2,41 @@

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.java110.common.cache.AppRouteCache;
import com.java110.common.cache.MappingCache;
import com.java110.common.constant.*;
import com.java110.common.exception.*;
import com.java110.common.constant.CommonConstant;
import com.java110.common.constant.KafkaConstant;
import com.java110.common.constant.MappingConstant;
import com.java110.common.constant.ResponseConstant;
import com.java110.common.constant.ServiceBusinessConstant;
import com.java110.common.constant.StatusConstant;
import com.java110.common.exception.BusinessException;
import com.java110.common.exception.BusinessStatusException;
import com.java110.common.exception.ConfigDataException;
import com.java110.common.exception.DAOException;
import com.java110.common.exception.DecryptException;
import com.java110.common.exception.InitConfigDataException;
import com.java110.common.exception.NoAuthorityException;
import com.java110.common.exception.NoSupportException;
import com.java110.common.exception.OrdersException;
import com.java110.common.exception.RuleException;
import com.java110.common.exception.SMOException;
import com.java110.common.factory.ApplicationContextFactory;
import com.java110.common.kafka.KafkaFactory;
import com.java110.common.log.LoggerEngine;
import com.java110.common.util.*;
import com.java110.common.util.Assert;
import com.java110.common.util.DateUtil;
import com.java110.common.util.ServiceBusinessUtil;
import com.java110.common.util.StringUtil;
import com.java110.common.util.WebServiceAxisClient;
import com.java110.core.client.RestTemplate;
import com.java110.core.context.*;
import com.java110.core.context.DataFlow;
import com.java110.core.context.IOrderDataFlowContext;
import com.java110.core.context.IOrderNotifyDataFlowContext;
import com.java110.core.context.IOrderResponse;
import com.java110.core.context.OrderDataFlow;
import com.java110.core.context.OrderNotifyDataFlow;
import com.java110.core.factory.AuthenticationFactory;
import com.java110.core.factory.OrderDataFlowContextFactory;
import com.java110.core.factory.GenerateCodeFactory;
import com.java110.entity.center.AppRoute;
import com.java110.entity.center.AppService;
import com.java110.entity.center.DataFlowLinksCost;
import com.java110.entity.order.Business;
@@ -36,7 +57,11 @@
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Service;

import java.util.*;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;


/**
@@ -47,7 +72,7 @@
//@Transactional
public class OrderServiceSMOImpl implements IOrderServiceSMO {

    private final static Logger logger = LoggerFactory.getLogger(OrderServiceSMOImpl.class);
    private static Logger logger = LoggerFactory.getLogger(OrderServiceSMOImpl.class);


    @Autowired
@@ -891,6 +916,8 @@
    private JSONObject doRequestBusinessSystem(IOrderDataFlowContext dataFlow, ServiceBusiness serviceBusiness, JSONObject requestBusinessJson) {
        String responseMessage;

        Assert.notNull(serviceBusiness, "在表c_service_business中未配置当前业务类型");

        Assert.hasLength(serviceBusiness.getInvokeType(), "c_service_business表配置出错，invoke_type 不能为空" + serviceBusiness.getBusinessTypeCd());
        String httpUrl = "";
        if (ServiceBusinessConstant.INVOKE_TYPE_WEBSERVICE.equals(serviceBusiness.getInvokeType())) {//webservice方式