java110-core/src/main/java/com/java110/core/event/center/DataFlowEventPublishing.java
@@ -253,6 +253,14 @@ multicastEvent(new InvokeBusinessSystemEvent("",dataFlow)); } /** * 调用完成业务系统事件 * @param dataFlow 数据流 */ public static void invokeFinishBusinessSystem(IOrderDataFlowContext dataFlow){ multicastEvent(new InvokeFinishBusinessSystemEvent("",dataFlow)); } /** * 调用业务系统成功后事件 java110-core/src/main/java/com/java110/core/event/center/event/InvokeFinishBusinessSystemEvent.java
New file @@ -0,0 +1,21 @@ package com.java110.core.event.center.event; import com.java110.core.context.IOrderDataFlowContext; /** * 调用业务系统事件 * Created by wuxw on 2018/7/2. */ public class InvokeFinishBusinessSystemEvent extends DataFlowEvent { /** * Constructs a prototypical Event. * * @param source The object on which the Event initially occurred. * @param dataFlow * @throws IllegalArgumentException if source is null. */ public InvokeFinishBusinessSystemEvent(Object source, IOrderDataFlowContext dataFlow) { super(source, dataFlow); } } java110-interface/src/main/resources/config/center_event.properties
@@ -1,2 +1,3 @@ java110.event.properties.centerServiceListener=\ dealUserIdListener dealUserIdListener,\ transactionOrderInfoToKafkaListener pom.xml
@@ -16,10 +16,8 @@ <module>java110-service</module> <module>java110-db</module> <module>service-user</module> <module>service-log</module> <module>service-fee</module> <module>service-eureka</module> <module>service-sequence</module> <module>service-store</module> <module>service-order</module> <module>service-api</module> service-log/README.md
File was deleted service-log/bin/start_log.sh
File was deleted service-log/doc/create_table.db
File was deleted service-log/doc/start_logService.sh
File was deleted service-log/docker/Dockerfile
File was deleted service-log/docker/onStart.sh
File was deleted service-log/orderDispatch.pngBinary files differ
service-log/pom.xml
File was deleted service-log/src/main/java/com/java110/log/LogServiceApplicationStart.java
File was deleted service-log/src/main/java/com/java110/log/dao/LogServiceDao.java
File was deleted service-log/src/main/java/com/java110/log/dao/impl/LogServiceDaoImpl.java
File was deleted service-log/src/main/java/com/java110/log/kafka/LogServiceBean.java
File was deleted service-log/src/main/java/com/java110/log/kafka/LogServiceKafka.java
File was deleted service-log/src/main/java/com/java110/log/package-info.java
File was deleted service-log/src/main/java/com/java110/log/smo/ILogServiceSMO.java
File was deleted service-log/src/main/java/com/java110/log/smo/impl/LogServiceSMOImpl.java
File was deleted service-log/src/main/resources/application-dev.yml
File was deleted service-log/src/main/resources/application-prod.yml
File was deleted service-log/src/main/resources/application-test.yml
File was deleted service-log/src/main/resources/application.yml
File was deleted service-log/src/main/resources/banner.txt
File was deleted service-log/src/main/resources/java110.properties
File was deleted service-log/src/test/java/com/java110/log/AppTest.java
File was deleted service-log/src/test/java/com/java110/log/common/PreBoCustAttr.java
File was deleted service-log/src/test/java/com/java110/log/executor/ExecutorTest.java
File was deleted service-log/src/test/java/com/java110/log/executor/PrintInt.java
File was deleted service-log/src/test/java/com/java110/log/jsonpath/CustIdTest.java
File was deleted service-log/src/test/java/com/java110/log/type/AppCustEvent.java
File was deleted service-log/src/test/java/com/java110/log/type/AppEvent.java
File was deleted service-log/src/test/java/com/java110/log/type/AppListener.java
File was deleted service-log/src/test/java/com/java110/log/type/CommonTest.java
File was deleted service-log/src/test/java/com/java110/log/type/CustDispatchListener.java
File was deleted service-log/src/test/java/com/java110/log/type/Ordered.java
File was deleted service-log/src/test/java/com/java110/log/type/TypeTest.java
File was deleted service-order/src/main/java/com/java110/order/listener/TransactionOrderInfoToKafkaListener.java
New file @@ -0,0 +1,52 @@ /* * Copyright 2017-2020 吴学文 and java110 team. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package com.java110.order.listener; import com.java110.core.annotation.Java110Listener; import com.java110.core.context.IOrderDataFlowContext; import com.java110.core.event.app.order.Ordered; import com.java110.core.event.center.event.InvokeFinishBusinessSystemEvent; import com.java110.core.event.center.listener.DataFlowListener; import com.java110.utils.constant.ResponseConstant; import com.java110.utils.exception.ListenerExecuteException; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * 用户ID处理 侦听 * Created by wuxw on 2018/7/2. */ @Java110Listener(name = "transactionOrderInfoToKafkaListener") public class TransactionOrderInfoToKafkaListener implements DataFlowListener<InvokeFinishBusinessSystemEvent>, Ordered { private final static Logger logger = LoggerFactory.getLogger(TransactionOrderInfoToKafkaListener.class); @Override public void soService(InvokeFinishBusinessSystemEvent event) { IOrderDataFlowContext dataFlow = event.getDataFlow(); if (dataFlow == null || dataFlow.getBusinessList() == null || dataFlow.getBusinessList().size() == 0) { throw new ListenerExecuteException(ResponseConstant.RESULT_PARAM_ERROR, "用户ID处理侦听执行异常，没有可处理的business"); } //判断是否存在 "serviceCode": "save.user.info", 业务，如果存在则处理 } @Override public int getOrder() { return 1; } } 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() { service-sequence/Readme.md
File was deleted service-sequence/bin/start_code.sh
File was deleted service-sequence/doc/IdRequest_protocol.json
File was deleted service-sequence/doc/IdResponse_protocol.json
File was deleted service-sequence/doc/start_codeService.sh
File was deleted service-sequence/docker/Dockerfile
File was deleted service-sequence/docker/onStart.sh
File was deleted service-sequence/pom.xml
File was deleted service-sequence/src/main/java/com/java110/code/CodeServiceApplicationStart.java
File was deleted service-sequence/src/main/java/com/java110/code/api/CodeApi.java
File was deleted service-sequence/src/main/java/com/java110/code/dao/ICommonServiceDao.java
File was deleted service-sequence/src/main/java/com/java110/code/dao/IPrimaryKeyServiceDao.java
File was deleted service-sequence/src/main/java/com/java110/code/dao/ISnowflakeldWorker.java
File was deleted service-sequence/src/main/java/com/java110/code/dao/impl/CommonServiceDaoImpl.java
File was deleted service-sequence/src/main/java/com/java110/code/dao/impl/PrimaryKeyServiceDaoImpl.java
File was deleted service-sequence/src/main/java/com/java110/code/dao/impl/SnowflakeIdWorkerImpl.java
File was deleted service-sequence/src/main/java/com/java110/code/package-info.java
File was deleted service-sequence/src/main/java/com/java110/code/smo/ICommonServiceSmo.java
File was deleted service-sequence/src/main/java/com/java110/code/smo/IPrimaryKeyServiceSMO.java
File was deleted service-sequence/src/main/java/com/java110/code/smo/impl/CommonServiceSmoImpl.java
File was deleted service-sequence/src/main/java/com/java110/code/smo/impl/PrimaryKeyServiceSMOImpl.java
File was deleted service-sequence/src/main/resources/application-dev.yml
File was deleted service-sequence/src/main/resources/application-prod.yml
File was deleted service-sequence/src/main/resources/application-test.yml
File was deleted service-sequence/src/main/resources/application.yml
File was deleted service-sequence/src/main/resources/banner.txt
File was deleted service-sequence/src/main/resources/dataSource.yml
File was deleted service-sequence/src/main/resources/java110.properties
File was deleted service-sequence/src/test/java/com/java110/AppTest.java
File was deleted
