From dfe9c74bb3d610f19d1cc0aa2673c996ea773436 Mon Sep 17 00:00:00 2001
From: wuxw <928255095@qq.com>
Date: 星期三, 29 十一月 2023 09:42:37 +0800
Subject: [PATCH] 优化数字孪生代码

---
 service-job/src/main/java/com/java110/job/smo/impl/DataBusInnerServiceSMOImpl.java |   11 ++++++++---
 1 files changed, 8 insertions(+), 3 deletions(-)

diff --git a/service-job/src/main/java/com/java110/job/smo/impl/DataBusInnerServiceSMOImpl.java b/service-job/src/main/java/com/java110/job/smo/impl/DataBusInnerServiceSMOImpl.java
index 11ea6fb..ea59b24 100755
--- a/service-job/src/main/java/com/java110/job/smo/impl/DataBusInnerServiceSMOImpl.java
+++ b/service-job/src/main/java/com/java110/job/smo/impl/DataBusInnerServiceSMOImpl.java
@@ -203,16 +203,21 @@
      * @param databusDtos databus
      */
     private void doExchange(Business business, List<Business> businesses, List<BusinessDatabusDto> databusDtos) {
-        // IDatabusAdapt databusAdaptImpl = null;
+         IDatabusAdapt databusAdaptImpl = null;
         for (BusinessDatabusDto databusDto : databusDtos) {
             try {
                 if (!business.getBusinessTypeCd().equals(databusDto.getBusinessTypeCd())) {
                     continue;
                 }
+                //todo 鏀舵嵁鍚屾鍘绘墦鍗板鐞嗭紝涓嶇劧鍓嶅彴绛変笉鍙�
+                if(databusDto.getBeanName().equals("payFeeReceiptAdapt")){
+                    databusAdaptImpl = ApplicationContextFactory.getBean(databusDto.getBeanName(), IDatabusAdapt.class);
+                    databusAdaptImpl.execute(business, businesses);
+                    continue;
+                }
                 //todo 瀛樻斁闃熷垪涓�
                 DatabusDataQueue.addMsg(new DatabusQueueDataDto(databusDto.getBeanName(), business, businesses));
-//                    databusAdaptImpl = ApplicationContextFactory.getBean(databusDto.getBeanName(), IDatabusAdapt.class);
-//                    databusAdaptImpl.execute(business, businesses);
+
             } catch (Exception e) {
                 logger.error("鎵цdatabus澶辫触", e);
                 LogSystemErrorPo logSystemErrorPo = new LogSystemErrorPo();

--
Gitblit v1.8.0