Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/MdmProductCodeServiceImpl.java

@@ -85,8 +85,8 @@
   private FormulaServiceImpl formulaService;

   // 注入事务管理器
   @Autowired
   private TransactionTemplate transactionTemplate;
//   @Autowired
//   private TransactionTemplate transactionTemplate;

   @Override
   @Transactional(rollbackFor = Exception.class)
@@ -273,9 +273,9 @@
               codeAllCodeService.updateBatchById(editCodeDOs);
            }
            // 获取事务定义
            DefaultTransactionDefinition def = new DefaultTransactionDefinition();
            //DefaultTransactionDefinition def = new DefaultTransactionDefinition();
            // 开始事务
            TransactionStatus status = transactionTemplate.getTransactionManager().getTransaction(def);
            //TransactionStatus status = transactionTemplate.getTransactionManager().getTransaction(def);
            if(!CollectionUtils.isEmpty(addCodeDOs)){
               Map<String, String> statusMap = addCodeDOs.stream().collect(Collectors.toMap(s -> s.getOid(), s -> s.getLcStatus()));
               addCodeDOs.stream().filter(s -> StringUtils.equalsIgnoreCase("codeallcode",s.getBtmname())).forEach(s -> {
@@ -318,14 +318,14 @@
               codeAllCodeService.saveBatch(addCodeDOs);
            }

            try {
               mdmEngineService.insertBatchByType(dataCBOList.get(0).getBtmname(),dataCBOList);
//            try {
            mdmEngineService.insertBatchByType(dataCBOList.get(0).getBtmname(),dataCBOList);
               // 提交事务
               transactionTemplate.getTransactionManager().commit(status);
            }catch (Exception e){
               // 出现异常时回滚事务
               transactionTemplate.getTransactionManager().rollback(status);
            }
               //transactionTemplate.getTransactionManager().commit(status);
//            }catch (Exception e){
//               // 出现异常时回滚事务
//               transactionTemplate.getTransactionManager().rollback(status);
//            }

         }
         return codeList;