소스 검색

入库时间问题

xucaiqin 1 년 전
부모
커밋
78c01532b5

+ 1 - 1
iot-module/iot-module-data/iot-module-data-biz/src/main/java/com/middle/platform/data/biz/service/rabbitmq/QueueService.java

@@ -97,7 +97,7 @@ public class QueueService {
                 productPara.setReserve(String.valueOf(in.getTime()));
                 productPara.setVal(map.getValue().getVal());
                 productPara.setMsgId(msgId);
-                productPara.setTs(TsUtil.getAndIncrement());
+                productPara.setTs(new Date(TsUtil.getAndIncrement()));
                 productPara.setOriginTime(new Date());//todo 有则获取
                 list.add(productPara);
                 cacheService.setHashKey(String.format(CacheConstant.D_DATA_CACHE, in.getGuid()), map.getKey(), map.getValue());