|
|
@@ -1,7 +1,6 @@
|
|
|
package org.dromara.server.mq.event.kafka.impl.local;
|
|
|
|
|
|
import cn.hutool.core.util.ObjectUtil;
|
|
|
-import cn.hutool.json.JSONObject;
|
|
|
import cn.hutool.json.JSONUtil;
|
|
|
import lombok.RequiredArgsConstructor;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
@@ -13,16 +12,11 @@ import org.dromara.backstage.api.domain.bo.RemoteCardBo;
|
|
|
import org.dromara.backstage.api.domain.bo.RemotePurseInOutBo;
|
|
|
import org.dromara.backstage.api.domain.bo.RemoteUserAccountBo;
|
|
|
import org.dromara.backstage.api.domain.vo.RemoteUserAccountVo;
|
|
|
-import org.dromara.common.core.enums.BalanceUpdateEnum;
|
|
|
-import org.dromara.common.core.enums.CreditTypeEnum;
|
|
|
-import org.dromara.common.core.enums.SystemUseTypeEnum;
|
|
|
import org.dromara.common.message.kafka.constant.EventSenderConstants;
|
|
|
import org.dromara.common.message.kafka.constant.EventTypeConstants;
|
|
|
import org.dromara.server.mq.event.kafka.IYktEventStrategy;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
-import java.math.BigDecimal;
|
|
|
-
|
|
|
/**
|
|
|
* @ClassName BackStageEventStrategyImpl
|
|
|
* @Description 处理管理平台消息队列
|