修改BUG

performance-web/src/main/java/com/clx/performance/component/OrderChildLoanComponent.java

@@ -512,11 +512,11 @@ public class OrderChildLoanComponent {
         if (CollectionUtil.isNotEmpty(fList)) {
             fSize = fList.size();
         }
-        if (vSize > 1
-                && fSize > 1
+        if (vSize >= 1
+                && fSize >= 1
         ) {
             return OwnerLoanRecordEnum.LoanTypeFlag.V_F.getCode();
-        } else if (vSize > 1) {
+        } else if (vSize >= 1) {
             return OwnerLoanRecordEnum.LoanTypeFlag.VIRTUAL_CURRENCY.getCode();
         } else {
             return OwnerLoanRecordEnum.LoanTypeFlag.FUND.getCode();

performance-web/src/main/java/com/clx/performance/listener/LargeScreenListener.java

@@ -46,7 +46,7 @@ public class LargeScreenListener {
 
     private final MongoTemplate mongoTemplate;
 
-    @Transactional(rollbackFor = Exception.class)
+    //@Transactional(rollbackFor = Exception.class)
     @RabbitListener(queues = RabbitKeyConstants.ORDER_LARGE_SCREEN_QUEUE)
     public void onMessage(String message) {
         try {
@@ -66,7 +66,7 @@ public class LargeScreenListener {
             if (CollectionUtil.isNotEmpty(list)) {
                 log.info("当前地址已经记录receiveAddressId{}, sendAddressId{}", receiveAddressId, sendAddressId);
             } else {
-/*                ReceiveAndSendAddressVO feignAddressVO = Optional.of(addressFeign.getSendAndReceiveSystemAddress(sendAddressId, receiveAddressId)).filter(Result::succeed)
+                ReceiveAndSendAddressVO feignAddressVO = Optional.of(addressFeign.getSendAndReceiveSystemAddress(sendAddressId, receiveAddressId)).filter(Result::succeed)
                         .map(Result::getData).orElseThrow(PerformanceResultEnum.DATA_NOT_FIND);
                 log.info("查询出标准地址相关坐标经纬度：{}", JSONUtil.parse(feignAddressVO));
                 BigDecimal sendAddressLatitude = feignAddressVO.getSendAddressVo().getLatitude().setScale(4, RoundingMode.DOWN);
@@ -99,7 +99,7 @@ public class LargeScreenListener {
                         .receiveName(receiveName)
                         .sendName(sendName)
                         .build();
-                largeScreenAddressRouteDao.saveEntity(build);*/
+                largeScreenAddressRouteDao.saveEntity(build);
             }
 
         } catch (Exception e) {