~opt:queue.order.close;

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/AbstractOrderCloseReceiver.java

@@ -32,7 +32,7 @@ import java.util.Map;
 import static com.liquidnet.commons.lang.util.DateUtil.DTF_YMD_HMS;
 
 @Slf4j
-public abstract class AbstractOrderCloseReceiver implements StreamListener<String, MapRecord<String, String, String>> {
+public abstract class AbstractOrderCloseReceiver implements StreamListener<String, MapRecord<String, String, Object>> {
     @Autowired
     StringRedisTemplate stringRedisTemplate;
     @Autowired
@@ -43,7 +43,7 @@ public abstract class AbstractOrderCloseReceiver implements StreamListener<Strin
     private MongoConverter mongoConverter;
 
     @Override
-    public void onMessage(MapRecord<String, String, String> message) {
+    public void onMessage(MapRecord<String, String, Object> message) {
         log.debug("CONSUMER ORDER_CLOSE [streamKey:{},messageId:{},stream:{},body:{}]",
                 this.getRedisStreamKey(), message.getId(), message.getStream(), message.getValue());
         boolean result = this.consumerOrderCloseHandler(message.getValue());
@@ -63,12 +63,13 @@ public abstract class AbstractOrderCloseReceiver implements StreamListener<Strin
         }
     }
 
-    private boolean consumerOrderCloseHandler(Map<String, String> messageMap) {
+    private boolean consumerOrderCloseHandler(Map<String, Object> messageMap) {
         try {
-            String orderCode = messageMap.get("id"), type = messageMap.get("type"), time = messageMap.get("time");
+            String orderCode = (String) messageMap.get("id"), type = (String) messageMap.get("type");
+            LocalDateTime time = (LocalDateTime) messageMap.get("time");
 
             LocalDateTime now = LocalDateTime.now();
-            LocalDateTime createdAt = StringUtils.isEmpty(time) ? now.minusMinutes(5) : LocalDateTime.parse(time);
+            LocalDateTime createdAt = null == time ? now.minusMinutes(5) : time;
 
             long durationToMillis = Duration.between(createdAt.plusMinutes(5), now).toMillis();
 

liquidnet-bus-service/liquidnet-service-order/liquidnet-service-order-impl/src/main/java/com/liquidnet/service/order/utils/QueueUtils.java

@@ -89,7 +89,7 @@ public class QueueUtils {
         HashMap<String, Object> map = ObjectUtil.cloneHashMapStringAndObject();
         map.put("id", masterOrderCode);
         map.put("type", "GOBLIN");
-        map.put("time", createTime.toString());
+        map.put("time", createTime);
         stringRedisTemplate.opsForStream().add(StreamRecords.mapBacked(map).withStreamKey(streamKey));
     }