测试接口

src/main/java/com/yaoyaozw/customer/controller/TestController.java

 package com.yaoyaozw.customer.controller;
 
 import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.json.JSONUtil;
 import com.rabbitmq.client.AMQP;
 import com.rabbitmq.client.Channel;
 import com.yaoyaozw.customer.constants.CustomerCommonConstant;
+import com.yaoyaozw.customer.constants.FollowReplyCommonConstant;
 import com.yaoyaozw.customer.constants.RabbitCommonNameConstant;
 import com.yaoyaozw.customer.dto.integration.IntegrationRequestDTO;
+import com.yaoyaozw.customer.entity.CustomerFollowReply;
 import com.yaoyaozw.customer.mapper.KanbanCommonMapper;
 import com.yaoyaozw.customer.service.AccountOrderService;
 import com.yaoyaozw.customer.service.CustomerDelayPublishService;
@@ -102,4 +105,17 @@ public class TestController {
 
     }
 
+    @GetMapping("/testFollowReply")
+    public void testFollowReply() {
+        Object obj = redisTemplate.opsForHash().get(FollowReplyCommonConstant.FOLLOW_REPLY_REDIS_KEY, "wx9f460fa46420016c");
+        if (ObjectUtil.isNotNull(obj)) {
+
+            List<CustomerFollowReply> list = JSONUtil.toList(JSONUtil.parseArray(obj.toString()), CustomerFollowReply.class);
+            for (CustomerFollowReply customerFollowReply : list) {
+                System.out.println(customerFollowReply);
+            }
+        }
+    }
+
+
 }