Parcourir la source

feature: 消费服务
1.消费服务完善

luoyb il y a 1 an
Parent
commit
a6fa949aa8

+ 0 - 2
ruoyi-server/ruoyi-server-mqdata/src/main/java/org/dromara/server/mq/event/kafka/impl/cloud/ConsumeEventStrategyImpl.java

@@ -34,9 +34,7 @@ public class ConsumeEventStrategyImpl implements IYktEventStrategy {
     @Override
     public void doMsgHandle(String eventType, Object msg) throws Exception {
         if (ObjectUtil.equals(eventType, EventTypeConstants.CONSUME)) {
-            //ConsumptionBo consumptionBo = JSONUtil.toBean(JSONUtil.parseObj(msg), ConsumptionBo.class);
             RemoteConsumeBo recordBo = JSONUtil.toBean(JSONUtil.parseObj(msg), RemoteConsumeBo.class);
-            //RemoteConsumeBo recordBo = BeanUtil.copyProperties(consumptionBo, RemoteConsumeBo.class);
             recordBo.setStatusFlag(4);
             recordBo.setUseType(SystemUseTypeEnum.CONSUME);
             recordBo.setCreditType(CreditTypeEnum.TERM_CONSUME);