feat: 好办sharding 回滚

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/pojo/bo/content/message/InteractRecordBO.java

+package com.gic.haoban.manage.service.pojo.bo.content.message;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * @Author MUSI
+ * @Date 2023/3/28 2:51 PM
+ * @Description
+ * @Version
+ **/
+@Data
+public class InteractRecordBO implements Serializable {
+
+
+    /**
+     * 企业id
+     */
+    private String enterpriseId;
+    /**
+     * 会员id
+     */
+    private String memberId;
+    /**
+     * 会员unionId
+     */
+    private String unionId;
+    /**
+     * 导购id
+     */
+    private String clerkId;
+    /**
+     * 门店id
+     */
+    private String storeId;
+    /**
+     * 来源渠道
+     * 线索来源 1朋友圈; 2客户群; 3 对话框; 0其他
+     */
+    private Integer channelSource;
+    /**
+     * 事件类型 1浏览素材;2查看商品; 3购买商品
+     */
+    private Integer eventType;
+    /**
+     * 停留时长
+     * 单位ms
+     */
+    private Integer durationTime;
+    /**
+     * 购买商品时的 订单id
+     */
+    private String orderId;
+    /**
+     * 查看商品时查看的商品id
+     */
+    private List<String> goodsIds;
+    /**
+     * 业务唯一标识
+     */
+    private String businessUUId;
+}

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

+package com.gic.haoban.manage.service.service.content.message;
+
+import com.gic.haoban.manage.service.pojo.bo.content.message.InteractRecordBO;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+/**
+ * @Author MUSI
+ * @Date 2023/3/28 2:50 PM
+ * @Description
+ * @Version
+ * 互动记录消息处理器
+ **/
+@Slf4j
+@Component
+public class InteractRecordMessageService {
+
+    /**
+     * 处理互动记录
+     * @param interactRecordBO
+     */
+    public void dealRecord(InteractRecordBO interactRecordBO) {
+
+        // 参数是否完整
+
+        // 根据businessId clerkId memberId materialId 构建唯一标识key
+        // 根据key 查询是否存在记录
+
+        // 新增
+            // 通过clerkId、memberId、materialId 查询之前存在的记录总数，本次是第几次访问 在之前的记录总数上加1
+        // 编辑
+            // 合并时间类型
+            //
+    }
+
+}

haoban-manage3-service/src/main/resources/applicationContext-conf.xml

@@ -8,7 +8,7 @@
     <import resource="classpath*:kafka-setting.xml"/>
     <import resource="classpath:dubbo-haoban-manage-service.xml" />
     <import resource="classpath:dubbo-setting-test.xml"/>
-<!--    <import resource="classpath:jdbc-haoban-manage-service.xml" />-->
-    <import resource="classpath*:jdbc-haoban-manage-service-sharding.xml" />
+    <import resource="classpath:jdbc-haoban-manage-service.xml" />
+<!--    <import resource="classpath*:jdbc-haoban-manage-service-sharding.xml" />-->
     <import resource="classpath*:log-record-init.xml" />
 </beans>
\ No newline at end of file