暂无图片
暂无图片
暂无图片
暂无图片
暂无图片

SpringBoot+Neo4j在社交电商中,讲述你是怎么被绑定为下线的

码咖 2020-01-13
174

点击上方蓝色字体,选择“设为星标”

优质文章,及时送达

上两篇文章我们主要讲解了Neo4j的基本知识以及Neo4j的基本使用,这篇文章我们就以实例来深入的理解一下,我们以社交电商中的绑定关系为例,使用SpringBoot+Neo4j来实现。

Neo4j文章回顾:

一、分析

社交电商中,现在做的比较出色的就应该属于花生日记,以及最近比较火的芬香。或许你经常会收到朋友或者亲戚发来的分享出的商品,而当你点击这些分享出来的商品后,那么,恭喜你,你可能已经被绑定为下级(粉丝)了。当然,我们这里只是举例说明下。

下面我们就用SpringBoot+Neo4j实现别人分享出来的商品,你点击了,注册成为新用户,进而被绑定为下线来详细说明。

二、代码架构

代码架构如下,这里没有写controller和service,以test来测试,也是为了方便。

三、代码实现

1.引入Neo4j依赖

2.添加 neo4j 配置

3.添加Neo4j 节点类

这里添加一个MemberInvit节点,有点注解类似于Mysql中的table 映射的对象类,mysql中叫做ORM,neo4j中叫做OGM。这里要使用到的是 @NodeEntity 注解和 @Id注解。

  • @NodeEntity声明该类为Neo4j的节点类

  • @Id Neo4j的主键。

  1. package com.xsjt.learn.neo4j.model;


  2. import lombok.*;

  3. import org.neo4j.ogm.annotation.Id;

  4. import org.neo4j.ogm.annotation.NodeEntity;

  5. import org.neo4j.ogm.annotation.Relationship;

  6. import java.io.Serializable;

  7. import java.util.HashSet;

  8. import java.util.Set;


  9. /**

  10. * @author Joe

  11. */

  12. @Data

  13. @Builder

  14. @AllArgsConstructor

  15. @NoArgsConstructor

  16. @NodeEntity(label = "MemberInvit")

  17. public class MemberInvit implements Serializable {


  18. /** 用户id */

  19. @Id

  20. private Long mId;


  21. /** 用户名称 */

  22. private String name;


  23. /** 用户等级 */

  24. private Integer level;


  25. /** 发展的下级 */

  26. @Relationship(type = "develop")

  27. private Set<MemberInvit> fans;


  28. /**

  29. * 发展 方法

  30. * @param memberInvit 用户邀请信息

  31. */

  32. public void develop(MemberInvit memberInvit) {

  33. if (fans == null) {

  34. fans = new HashSet<>();

  35. }

  36. fans.add(memberInvit);

  37. }

  38. }

复制

4.创建repositories类

当然,下面的方法不一定在我们绑定示例中用得到,但是在社交电商中这些都是基本要用的。

  1. package com.xsjt.learn.neo4j.dao;


  2. import com.xsjt.learn.neo4j.model.MemberInvit;

  3. import org.springframework.data.neo4j.annotation.Query;

  4. import org.springframework.data.neo4j.repository.Neo4jRepository;

  5. import org.springframework.data.repository.query.Param;

  6. import org.springframework.stereotype.Repository;

  7. import java.util.List;


  8. /**

  9. * dao层

  10. * @author Joe

  11. * @date 2020-01-13

  12. */

  13. @Repository

  14. public interface MemberInvitRepository extends Neo4jRepository<MemberInvit, String> {


  15. /**

  16. * 根据节点id查询节点信息

  17. * @param mId

  18. * @return

  19. */

  20. MemberInvit findBymId(Long mId);


  21. /**

  22. * 查询某个节点的所有子节点

  23. * @param mId

  24. * @return

  25. */

  26. @Query("Match (p:MemberInvit{mId:{mId}})-[*]->(s:MemberInvit) return s ")

  27. List<MemberInvit> findChildList(Long mId);


  28. /**

  29. * 查询某个节点的直属父节点

  30. * @param mId

  31. * @return

  32. */

  33. @Query("Match (p:MemberInvit)-[*]->(s:MemberInvit{mId:{mId}}) return p limit 1")

  34. MemberInvit findParent(@Param("mId") Long mId);


  35. /**

  36. * 查询某个节点的所有父节点

  37. * @param mId

  38. * @return

  39. */

  40. @Query("Match (p:MemberInvit)-[*]->(s:MemberInvit{mId:{mId}}) return p")

  41. List<MemberInvit> findParentList(@Param("mId") Long mId);



  42. /**

  43. * 查询某个节点的 指定等级的 最近的父节点

  44. * @param mId

  45. * @param level

  46. * @return

  47. */

  48. @Query("Match (p:MemberInvit{level:{level}})-[*]->(s:MemberInvit{mId:{mId}}) return p limit 1")

  49. MemberInvit findParentInfoByLevel(@Param("mId") Long mId, @Param("level") Integer level);


  50. /**

  51. * 查询某个节点的 指定等级的所有父节点

  52. * @param mId

  53. * @param level

  54. * @return

  55. */

  56. @Query("Match (p:MemberInvit{level:{level}})-[*]->(s:MemberInvit{mId:{mId}}) return p")

  57. List<MemberInvit> findParentByLevel(@Param("mId") Long mId, @Param("level") Integer level);


  58. }

复制

这里继承了Neo4jRepository,点击查看源码会发现,这里面封装好了简单的增删改查。

5.增加一个官方用户

增加完后,我们有两种方法查看,一是在Neo4j的控制台查看,另一个是在代码中查看。这里我们先在Neo4j的控制台查询下:

说明官方用户已经增加成功了。

6.查询官方用户

这里我们使用代码查询刚刚创建的官方用户。

7.绑定用户

除了官方用户外,假设第一个注册的是 隔壁老王,即隔壁老王绑定在了官方用户下,也可以叫官方用户发展了 隔壁老王为下线。

我们在控制台查看下创建的关系:

  1. match (p:MemberInvit) return p

  2. 或者

  3. match (p:MemberInvit)-[d:develop]->(s:MemberInvit) return p,d,s

复制

隔壁老王人缘广,发展了小张、小李、小吴、小周等人:

我们从控制台上查看绑定关系:

这样,绑定关系就已经形成了。

四、源码下载

为了方便,已经将源码上传到github 了,地址:https://github.com/joeBeckham/springboot-learn

五、说在最后

社交电商中经常会存在返佣,你买了东西,你的上级就会得到百分之多少,这样,就会用到dao层中的 《查询某个节点的直属父节点》 方法,即:findParent。

你买了东西,可能并不会直接返佣到你的上级,可能会找某个等级的上级,这时候你就会用到dao层中的《查询某个节点的 指定等级的所有父节点》,即:findParentByLevel。

你买了东西,可能会返佣给指定等级的最近的一个父节点,这时候你就会用到dao层中的《查询某个节点的 指定等级的 最近的父节点》,即:findParentInfoByLevel。

这些我们就不一一举例了。

以上就是我们今天介绍的使用SpringBoot + Neo4j来实现社交电商中的绑定逻辑。



文章转载自码咖,如果涉嫌侵权,请发送邮件至:contact@modb.pro进行举报,并提供相关证据,一经查实,墨天轮将立刻删除相关内容。

评论