perf(消费服务): 发送消费kafka消息时采用异步

ruoyi-server/ruoyi-server-consume/src/main/java/org/dromara/server/consume/business/BaseBusiness.java

@@ -430,10 +430,7 @@ public class BaseBusiness {
      */
     public void completeUploadRecord(ConsumptionBo bo, RemoteUserAccountVo accountVo) {
         // 消费记录上传完成,还有一些后续工作，不需要知道处理结果，采用异步任务提交
-        // threadPoolTaskExecutor.execute(() -> sendConsumeToKafka(bo, accountVo));
-        log.info("[向教务系统发送就餐打卡]-[{}]", JsonUtils.toJsonString(bo));
-         sendConsumeToKafka(bo, accountVo);
-        //taskExecutor.submit(() -> sendCloudConsume(bo));
+        threadPoolTaskExecutor.execute(() -> sendConsumeToKafka(bo, accountVo));
     }
 
 
@@ -445,7 +442,6 @@ public class BaseBusiness {
      */
     private void sendConsumeToKafka(ConsumptionBo bo, RemoteUserAccountVo accountVo) {
         // 只有本地消费完成后才会向教务发kafka消息
-        //if (ObjectUtil.equals(defaultConfig.getLocationFlag(), DefaultConstants.LOCAL_FLAG)) {
             YcPushConsumeInfoVo ycSendConsumeInfo = new YcPushConsumeInfoVo();
             ycSendConsumeInfo.setRecordId(bo.getRecordId().toString());
             ycSendConsumeInfo.setUserId(bo.getUserId().toString());
@@ -473,7 +469,6 @@ public class BaseBusiness {
             log.info("[向教务系统发送就餐打卡]-[{}]", ycSendConsumeInfo);
             kafkaNormalProducer.sendKafkaMessage(KafkaTopicConstants.OLD_SYNC_TOPIC, EventTypeConstants.CONSUME_RECORD, EventSenderEnum.OLD.code(),
                 ycSendConsumeInfo);
-        //}
     }
 
     /**