feat: 销售线索

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/content/message/InteractRecordMessageListener.java

 package com.gic.haoban.manage.service.service.content.message;
 
+import com.alibaba.fastjson.JSON;
+import com.gic.haoban.manage.service.pojo.bo.content.message.InteractRecordMessageBO;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.kafka.clients.consumer.ConsumerRecord;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.kafka.listener.MessageListener;
 import org.springframework.stereotype.Component;
 
@@ -14,13 +17,17 @@ import org.springframework.stereotype.Component;
 @Slf4j
 public class InteractRecordMessageListener implements MessageListener<String, String> {
 
-    /**
-     * Invoked with data from kafka.
-     *
-     * @param data the data to be processed.
-     */
-    @Override
-    public void onMessage(ConsumerRecord<String, String> data) {
+    @Autowired
+    InteractRecordMessageService interactRecordMessageService;
 
+    @Override
+    public void onMessage(ConsumerRecord<String, String> consumerRecord) {
+        String value = consumerRecord.value();
+        InteractRecordMessageBO recordMessageBO = JSON.parseObject(value, InteractRecordMessageBO.class);
+        if (recordMessageBO == null) {
+            log.info("互动记录解析异常 {}", value);
+            return;
+        }
+        interactRecordMessageService.dealRecord(recordMessageBO);
     }
 }

haoban-manage3-service/src/test/java/InteractRecordMessageServiceTest.java

+import com.gic.haoban.manage.service.pojo.bo.content.message.InteractRecordMessageBO;
+import com.gic.haoban.manage.service.service.content.message.InteractRecordMessageService;
+import com.sun.org.apache.bcel.internal.generic.DADD;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.test.context.ContextConfiguration;
+import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
+
+import java.util.Date;
+import java.util.UUID;
+
+/**
+ * @Author MUSI
+ * @Date 2023/4/6 10:13 AM
+ * @Description
+ * @Version
+ **/
+
+@RunWith(SpringJUnit4ClassRunner.class)
+@ContextConfiguration(locations = {"classpath:applicationContext-conf.xml"})
+public class InteractRecordMessageServiceTest {
+
+    @Autowired
+    InteractRecordMessageService interactRecordMessageService;
+
+    String eid = "ff8080815dacd3a2015dacd3ef5c0000";
+    String wxEid = "ca66a01b79474c40b3e7c7f93daf1a3b";
+    String staffId = "e608b51b267e4943b87e222a343b4f25";
+    String clerkId = "300b60c7f8874ca2b9cc696ad6b6a480";
+    String memberId = "ff8080818147efc8018148d1759903c8";
+
+    String materialId = "516810122152927247";
+
+    @Test
+    public void dealRecord() {
+        String runningUUid = UUID.randomUUID().toString();
+        InteractRecordMessageBO interactRecordMessageBO = new InteractRecordMessageBO();
+        interactRecordMessageBO.setEnterpriseId(eid);
+        interactRecordMessageBO.setMaterialId(materialId);
+        interactRecordMessageBO.setMemberId(memberId);
+        interactRecordMessageBO.setUnionId(memberId);
+        interactRecordMessageBO.setClerkId(clerkId);
+        interactRecordMessageBO.setStoreId("ff8080816e216c04016e34294282004a");
+        interactRecordMessageBO.setChannelSource(1);
+        interactRecordMessageBO.setEventType(1);
+        interactRecordMessageBO.setDurationTime(3200);
+        interactRecordMessageBO.setGoodsId(runningUUid);
+        interactRecordMessageBO.setLastAccessTime(new Date().getTime());
+        interactRecordMessageService.dealRecord(interactRecordMessageBO);
+    }
+}