Prechádzať zdrojové kódy

fix: 消费服务
1.发送kafka消息的消费时间以消费机上传时间为准

luo.yibo@datuai.com 1 rok pred
rodič
commit
257423e11a

+ 1 - 1
ruoyi-server/ruoyi-server-consume/src/main/java/org/dromara/server/consume/controller/v1/ConsumeController.java

@@ -199,7 +199,7 @@ public class ConsumeController {
             // 发送消息
             if (ObjectUtil.equals(defaultConfig.getLocationFlag(), DefaultConstants.LOCAL_FLAG)) {
                 ConsumptionBo bo = recordConvertStrategy.convert(record, "YC");
-                bo.setConsumeDate(jsonObject.getDate("consumeDate"));
+                // bo.setConsumeDate(jsonObject.getDate("consumeDate"));
                 ThreadUtil.execAsync(() -> baseBusiness.sendCloudConsume(bo));
             }
         }