优化数字孪生代码

wuxw

2023-11-29 dfe9c74bb3d610f19d1cc0aa2673c996ea773436

优化数字孪生代码

 service-acct/src/main/java/com/java110/acct/payment/business/oweFee/OweFeePaymentBusiness.java

@@ -133,7 +133,7 @@
            }
        }

        String feeName = getFeeName(feeDtos.get(0));
        String feeName = getFeeName(tmpFeeDtos.get(0));

        String orderId = GenerateCodeFactory.getOId();


 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();