From 1468caa107e455ea0f0201ca5e560fcba5a7622b Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期一, 07 十二月 2020 15:35:37 +0800
Subject: [PATCH] 调整和整合架构，日志和序列文件迁移
---
service-order/src/main/java/com/java110/order/smo/impl/OrderServiceSMOImpl.java | 58 +++++++++++++++++++---------------------------------------
1 files changed, 19 insertions(+), 39 deletions(-)
diff --git a/service-order/src/main/java/com/java110/order/smo/impl/OrderServiceSMOImpl.java b/service-order/src/main/java/com/java110/order/smo/impl/OrderServiceSMOImpl.java
index 3ad5b3b..bcdde29 100644
--- a/service-order/src/main/java/com/java110/order/smo/impl/OrderServiceSMOImpl.java
+++ b/service-order/src/main/java/com/java110/order/smo/impl/OrderServiceSMOImpl.java
@@ -2,22 +2,23 @@
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
+import com.java110.core.client.RestTemplate;
+import com.java110.core.context.*;
+import com.java110.core.event.center.DataFlowEventPublishing;
+import com.java110.core.factory.AuthenticationFactory;
+import com.java110.core.factory.OrderDataFlowContextFactory;
+import com.java110.core.log.LogAgent;
+import com.java110.entity.center.AppService;
+import com.java110.entity.center.DataFlowLinksCost;
+import com.java110.entity.order.Business;
+import com.java110.entity.order.ServiceBusiness;
+import com.java110.order.dao.ICenterServiceDAO;
+import com.java110.order.smo.IOrderServiceSMO;
+import com.java110.service.init.ServiceInfoListener;
+import com.java110.service.smo.IQueryServiceSMO;
import com.java110.utils.cache.MappingCache;
-import com.java110.utils.constant.CommonConstant;
-import com.java110.utils.constant.KafkaConstant;
-import com.java110.utils.constant.MappingConstant;
-import com.java110.utils.constant.ResponseConstant;
-import com.java110.utils.constant.StatusConstant;
-import com.java110.utils.exception.BusinessException;
-import com.java110.utils.exception.BusinessStatusException;
-import com.java110.utils.exception.DAOException;
-import com.java110.utils.exception.DecryptException;
-import com.java110.utils.exception.InitConfigDataException;
-import com.java110.utils.exception.NoAuthorityException;
-import com.java110.utils.exception.NoSupportException;
-import com.java110.utils.exception.OrdersException;
-import com.java110.utils.exception.RuleException;
-import com.java110.utils.exception.SMOException;
+import com.java110.utils.constant.*;
+import com.java110.utils.exception.*;
import com.java110.utils.factory.ApplicationContextFactory;
import com.java110.utils.kafka.KafkaFactory;
import com.java110.utils.log.LoggerEngine;
@@ -25,25 +26,6 @@
import com.java110.utils.util.ServiceBusinessUtil;
import com.java110.utils.util.StringUtil;
import com.java110.utils.util.WebServiceAxisClient;
-import com.java110.core.client.RestTemplate;
-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.entity.center.AppService;
-import com.java110.entity.center.DataFlowLinksCost;
-import com.java110.entity.order.Business;
-import com.java110.entity.order.ServiceBusiness;
-import com.java110.core.event.center.DataFlowEventPublishing;
-import com.java110.core.log.LogAgent;
-import com.java110.order.dao.ICenterServiceDAO;
-import com.java110.order.smo.IOrderServiceSMO;
-import com.java110.service.init.ServiceInfoListener;
-import com.java110.service.smo.IQueryServiceSMO;
import org.apache.commons.lang3.math.NumberUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -69,8 +51,6 @@
public class OrderServiceSMOImpl extends AbstractOrderServiceSMOImpl implements IOrderServiceSMO {
private static Logger logger = LoggerFactory.getLogger(OrderServiceSMOImpl.class);
-
-
@Autowired
@@ -106,6 +86,9 @@
//6.0 璋冪敤涓嬫父绯荤粺
DataFlowEventPublishing.invokeBusinessSystem(dataFlow);
invokeBusinessSystem(dataFlow);
+
+ // 涓氬姟璋冪敤瀹屾垚
+ DataFlowEventPublishing.invokeFinishBusinessSystem(dataFlow);
//鑳藉鎵ц鍒拌繖涓�姝� 璁や负鏄兘鎴愬姛浜�
refreshOrderDataFlowResJson(dataFlow);
@@ -320,7 +303,6 @@
//OrderDataFlowContextFactory.addCostTime(dataFlow, "updateOrderAndBusinessError", "璁㈠崟鐘舵�佹敼涓哄け璐ヨ�楁椂", startDate);
}
-
/**
@@ -647,7 +629,6 @@
}
-
/**
* 澶勭悊寮傛涓氬姟
*
@@ -742,7 +723,6 @@
logger.error("鎶ラ敊鏃ュ織鍑洪敊浜嗭紝", e);
}
}
-
public ICenterServiceDAO getCenterServiceDaoImpl() {
--
Gitblit v1.8.0