فهرست منبع

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

luoyb 1 سال پیش
والد
کامیت
b429650b37

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

@@ -34,8 +34,9 @@ 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 = BeanUtil.copyProperties(consumptionBo, RemoteConsumeBo.class);
+            //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);