feature: 管理后台

1.自助机充值后更新本地余额

ruoyi-common/ruoyi-common-message/src/main/java/org/dromara/common/message/kafka/constant/EventTypeConstants.java

@@ -45,11 +45,11 @@ public interface EventTypeConstants {
     String RECHARGE = "11000004";
     //endregion
 
+    //region 一卡通
     /**
      * 消费请求
      */
     String CONSUME = "12000001";
-    //region 一卡通
     /**
      * 消费记录
      */

ruoyi-common/ruoyi-common-message/src/main/java/org/dromara/common/message/kafka/enums/EventTypeEnum.java

@@ -39,6 +39,7 @@ public enum EventTypeEnum {
     USER("10000002", "用户数据"),
     ACCOUNT("11000001", "消费账户数据"),
     CARD("11000002", "卡片数据"),
+    RECHARGE("11000004", "充值请求"),
     CONSUME("12000001", "消费请求");
     //endregion
 

ruoyi-common/ruoyi-common-message/src/main/java/org/dromara/common/message/kafka/producer/KafkaCommonProducer.java

@@ -8,7 +8,6 @@ import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.kafka.clients.producer.ProducerRecord;
 import org.dromara.common.core.config.DefaultConfig;
-import org.dromara.common.core.enums.CloudMqEventEnum;
 import org.dromara.common.core.utils.SpringUtils;
 import org.dromara.common.message.kafka.domain.KafkaHeader;
 import org.dromara.common.message.kafka.domain.KafkaMessage;
@@ -39,7 +38,7 @@ public class KafkaCommonProducer {
             send.whenComplete((result, ex) -> {
                 if (ex != null) {
                     log.error("[{}]-[{}]-[发送到kafka消息异常]-[{}]", EventSenderEnum.getMessage(sender),
-                              CloudMqEventEnum.getMessage(eventType), data, ex);
+                        EventTypeEnum.getMessage(eventType), data, ex);
                 } else {
                     log.info("[{}]-[{}]-[发送到kafka消息成功]-[{}]", EventSenderEnum.getMessage(sender), EventTypeEnum.getMessage(eventType), data);
                 }