fix: 基础平台服务

1.一卡通账户变更不再发kafka同步至校内
2.充值、退款再发kafka同步至校内

ruoyi-modules/ruoyi-backstage/src/main/java/org/dromara/backstage/business/card/CardBusiness.java

@@ -206,9 +206,10 @@ public class CardBusiness {
             if (result) {
                 // 回收成功，将回收后的卡片信息发kafka
                 PtCardVo recycleVo = ptCardService.selectOneByBo(cardBo);
-                kafkaNormalProducer.sendKafkaMessage(KafkaTopicConstants.SYNC_DATA_TOPIC, EventTypeConstants.CARD, EventSenderEnum.BACKSTAGE.code(),
-                                                     recycleVo);
+                //kafkaNormalProducer.sendKafkaMessage(KafkaTopicConstants.SYNC_DATA_TOPIC, EventTypeConstants.CARD, EventSenderEnum.BACKSTAGE.code(),
+                //                                     recycleVo);
             }
+
             return result ? R.ok() : R.fail();
         } else {
             return R.fail(MessageFormat.format("[卡片回收]-[没有对应的卡片]-[{0}]", JSONUtil.toJsonStr(cardBo)));

ruoyi-modules/ruoyi-backstage/src/main/java/org/dromara/backstage/business/payments/ThirdPayBusiness.java

@@ -182,7 +182,7 @@ public class ThirdPayBusiness {
         updateBo.setOriginalId(postResult.getData().getOriginalId());
         updateBo.setCreditStatus(CreditStatusEnum.SUCCESS.code().toString());
         //充值信息发送kafka
-        kafkaNormalProducer.sendKafkaMessage(KafkaTopicConstants.SYNC_DATA_TOPIC, EventTypeConstants.RECHARGE, EventSenderEnum.BACKSTAGE.code(), postResult.getData());
+        //kafkaNormalProducer.sendKafkaMessage(KafkaTopicConstants.SYNC_DATA_TOPIC, EventTypeConstants.RECHARGE, EventSenderEnum.BACKSTAGE.code(), postResult.getData());
 
         return setOrderPostResult(updateBo);
     }

ruoyi-modules/ruoyi-backstage/src/main/java/org/dromara/backstage/cardCenter/service/impl/PtCardServiceImpl.java

@@ -174,7 +174,7 @@ public class PtCardServiceImpl implements IPtCardService {
             }
         }
         PtCardVo vo = baseMapper.selectVoById(bo.getCardId());
-        kafkaNormalProducer.sendKafkaMessage(KafkaTopicConstants.SYNC_DATA_TOPIC, EventTypeConstants.CARD, EventSenderEnum.BACKSTAGE.code(), vo);
+        //kafkaNormalProducer.sendKafkaMessage(KafkaTopicConstants.SYNC_DATA_TOPIC, EventTypeConstants.CARD, EventSenderEnum.BACKSTAGE.code(), vo);
         return flag;
     }
 
@@ -190,7 +190,7 @@ public class PtCardServiceImpl implements IPtCardService {
         validEntityBeforeSave(update);
         int count = baseMapper.updateById(update);
         PtCardVo vo = baseMapper.selectVoById(bo.getCardId());
-        kafkaNormalProducer.sendKafkaMessage(KafkaTopicConstants.SYNC_DATA_TOPIC, EventTypeConstants.CARD, EventSenderEnum.BACKSTAGE.code(), vo);
+        //kafkaNormalProducer.sendKafkaMessage(KafkaTopicConstants.SYNC_DATA_TOPIC, EventTypeConstants.CARD, EventSenderEnum.BACKSTAGE.code(), vo);
         return count > 0;
     }
 

ruoyi-modules/ruoyi-backstage/src/main/java/org/dromara/backstage/payment/service/impl/PtUserAccountServiceImpl.java

@@ -257,7 +257,7 @@ public class PtUserAccountServiceImpl implements IPtUserAccountService {
             bagService.initAccountBag(bo.getUserId());
         }
         PtUserAccountVo vo = baseMapper.selectVoById(bo.getUserId());
-        kafkaNormalProducer.sendKafkaMessage(KafkaTopicConstants.SYNC_DATA_TOPIC, EventTypeConstants.ACCOUNT, EventSenderEnum.BACKSTAGE.code(), vo);
+        //kafkaNormalProducer.sendKafkaMessage(KafkaTopicConstants.SYNC_DATA_TOPIC, EventTypeConstants.ACCOUNT, EventSenderEnum.BACKSTAGE.code(), vo);
         return flag;
     }
 
@@ -273,7 +273,7 @@ public class PtUserAccountServiceImpl implements IPtUserAccountService {
         validEntityBeforeSave(update);
         int count = baseMapper.updateById(update);
         PtUserAccountVo vo = baseMapper.selectVoById(bo.getUserId());
-        kafkaNormalProducer.sendKafkaMessage(KafkaTopicConstants.SYNC_DATA_TOPIC, EventTypeConstants.ACCOUNT, EventSenderEnum.BACKSTAGE.code(), vo);
+        //kafkaNormalProducer.sendKafkaMessage(KafkaTopicConstants.SYNC_DATA_TOPIC, EventTypeConstants.ACCOUNT, EventSenderEnum.BACKSTAGE.code(), vo);
         return count > 0;
     }