添加表 sweet_wechat_users sweet_wechat_users_relation

liquidnet-bus-api/liquidnet-service-sweet-api/src/main/java/com/liquidnet/service/sweet/service/ISweetWechatUsersRelationService.java

+package com.liquidnet.service.sweet.service;
+
+import com.liquidnet.service.sweet.entity.SweetWechatUsersRelation;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * <p>
+ * 微信用户信息关联表 服务类
+ * </p>
+ *
+ * @author jiangxiulong
+ * @since 2021-11-04
+ */
+public interface ISweetWechatUsersRelationService extends IService<SweetWechatUsersRelation> {
+
+}

liquidnet-bus-api/liquidnet-service-sweet-api/src/main/java/com/liquidnet/service/sweet/service/ISweetWechatUsersService.java

+package com.liquidnet.service.sweet.service;
+
+import com.liquidnet.service.sweet.entity.SweetWechatUsers;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * <p>
+ * 微信用户信息表包含小程序公众号 服务类
+ * </p>
+ *
+ * @author jiangxiulong
+ * @since 2021-11-04
+ */
+public interface ISweetWechatUsersService extends IService<SweetWechatUsers> {
+
+}

liquidnet-bus-api/liquidnet-service-sweet-api/src/main/java/com/liquidnet/service/sweet/vo/SweetWechatUsersRelationVo.java

+package com.liquidnet.service.sweet.vo;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+@Data
+public class SweetWechatUsersRelationVo implements Serializable, Cloneable {
+
+    private static final long serialVersionUID = -7943731833999082046L;
+
+    /**
+     * wechat_relation_id
+     */
+    private String wechatRelationId;
+
+    /**
+     * unionId
+     */
+    private String unionId;
+
+    /**
+     * adam用户id
+     */
+    private String userId;
+
+    /**
+     * adam用户手机号
+     */
+    private String userPhone;
+
+    /**
+     * 创建时间
+     */
+    private LocalDateTime createdAt;
+
+    /**
+     * 更新时间
+     */
+    private LocalDateTime updatedAt;
+
+    private static final SweetWechatUsersRelationVo obj = new SweetWechatUsersRelationVo();
+    public static SweetWechatUsersRelationVo getNew() {
+        try {
+            return (SweetWechatUsersRelationVo) obj.clone();
+        } catch (CloneNotSupportedException e) {
+            return new SweetWechatUsersRelationVo();
+        }
+    }
+
+}

liquidnet-bus-api/liquidnet-service-sweet-api/src/main/java/com/liquidnet/service/sweet/vo/SweetWechatUsersVo.java

+package com.liquidnet.service.sweet.vo;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+@Data
+public class SweetWechatUsersVo implements Serializable, Cloneable {
+
+    private static final long serialVersionUID = -8639044068603169141L;
+
+    /**
+     * wechat_id
+     */
+    private String wechatId;
+
+    /**
+     * openId
+     */
+    private String openId;
+
+    /**
+     * unionId
+     */
+    private String unionId;
+
+    /**
+     * 服务类型 1正在 2摩登 21草莓 22五百里 23mdsk 24正在
+     */
+    private Integer type;
+
+    /**
+     * 小程序解密手机号
+     */
+    private String phoneNumber;
+
+    /**
+     * 小程序解密手机号
+     */
+    private String purePhoneNumber;
+
+    /**
+     * 小程序解密地区码
+     */
+    private String countryCode;
+
+    /**
+     * 昵称
+     */
+    private String nickname;
+
+    /**
+     * 性别
+     */
+    private String sexDesc;
+
+    /**
+     * 性别 男1
+     */
+    private Integer sex;
+
+    /**
+     * 头像
+     */
+    private String headImgUrl;
+
+    /**
+     * zh_CN
+     */
+    private String language;
+
+    /**
+     * 国家
+     */
+    private String country;
+
+    /**
+     * 省
+     */
+    private String province;
+
+    /**
+     * 市
+     */
+    private String city;
+
+    /**
+     * 关注时间
+     */
+    private LocalDateTime subscribeTime;
+
+    /**
+     * ADD_SCENE_SEARCH 关注方式
+     */
+    private String subscribeScene;
+
+    /**
+     * 创建时间
+     */
+    private LocalDateTime createdAt;
+
+    /**
+     * 更新时间
+     */
+    private LocalDateTime updatedAt;
+
+    private static final SweetWechatUsersVo obj = new SweetWechatUsersVo();
+    public static SweetWechatUsersVo getNew() {
+        try {
+            return (SweetWechatUsersVo) obj.clone();
+        } catch (CloneNotSupportedException e) {
+            return new SweetWechatUsersVo();
+        }
+    }
+
+}

liquidnet-bus-do/liquidnet-service-sweet-do/src/main/java/com/liquidnet/service/sweet/entity/SweetWechatUsers.java

+package com.liquidnet.service.sweet.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import java.time.LocalDateTime;
+import java.io.Serializable;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * <p>
+ * 微信用户信息表包含小程序公众号
+ * </p>
+ *
+ * @author jiangxiulong
+ * @since 2021-11-04
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+public class SweetWechatUsers implements Serializable {
+
+    private static final long serialVersionUID = 4529970101866070527L;
+
+    @TableId(value = "mid", type = IdType.AUTO)
+    private Long mid;
+
+    /**
+     * wechat_id
+     */
+    private String wechatId;
+
+    /**
+     * openId
+     */
+    private String openId;
+
+    /**
+     * unionId
+     */
+    private String unionId;
+
+    /**
+     * 服务类型 1正在 2摩登 21草莓 22五百里 23mdsk 24正在
+     */
+    private Integer type;
+
+    /**
+     * 小程序解密手机号
+     */
+    private String phoneNumber;
+
+    /**
+     * 小程序解密手机号
+     */
+    private String purePhoneNumber;
+
+    /**
+     * 小程序解密地区码
+     */
+    private String countryCode;
+
+    /**
+     * 昵称
+     */
+    private String nickname;
+
+    /**
+     * 性别
+     */
+    private String sexDesc;
+
+    /**
+     * 性别 男1
+     */
+    private Integer sex;
+
+    /**
+     * 头像
+     */
+    private String headImgUrl;
+
+    /**
+     * zh_CN
+     */
+    private String language;
+
+    /**
+     * 国家
+     */
+    private String country;
+
+    /**
+     * 省
+     */
+    private String province;
+
+    /**
+     * 市
+     */
+    private String city;
+
+    /**
+     * 关注时间
+     */
+    private LocalDateTime subscribeTime;
+
+    /**
+     * ADD_SCENE_SEARCH 关注方式
+     */
+    private String subscribeScene;
+
+    /**
+     * 创建时间
+     */
+    private LocalDateTime createdAt;
+
+    /**
+     * 更新时间
+     */
+    private LocalDateTime updatedAt;
+
+
+}

liquidnet-bus-do/liquidnet-service-sweet-do/src/main/java/com/liquidnet/service/sweet/entity/SweetWechatUsersRelation.java

+package com.liquidnet.service.sweet.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import java.time.LocalDateTime;
+import java.io.Serializable;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * <p>
+ * 微信用户信息关联表
+ * </p>
+ *
+ * @author jiangxiulong
+ * @since 2021-11-04
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+public class SweetWechatUsersRelation implements Serializable {
+
+    private static final long serialVersionUID = 1805653079540343937L;
+
+    @TableId(value = "mid", type = IdType.AUTO)
+    private Long mid;
+
+    /**
+     * wechat_relation_id
+     */
+    private String wechatRelationId;
+
+    /**
+     * unionId
+     */
+    private String unionId;
+
+    /**
+     * adam用户id
+     */
+    private String userId;
+
+    /**
+     * adam用户手机号
+     */
+    private String userPhone;
+
+    /**
+     * 创建时间
+     */
+    private LocalDateTime createdAt;
+
+    /**
+     * 更新时间
+     */
+    private LocalDateTime updatedAt;
+
+
+}

liquidnet-bus-do/liquidnet-service-sweet-do/src/main/java/com/liquidnet/service/sweet/mapper/SweetWechatUsersMapper.java

+package com.liquidnet.service.sweet.mapper;
+
+import com.liquidnet.service.sweet.entity.SweetWechatUsers;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * <p>
+ * 微信用户信息表包含小程序公众号 Mapper 接口
+ * </p>
+ *
+ * @author jiangxiulong
+ * @since 2021-11-04
+ */
+public interface SweetWechatUsersMapper extends BaseMapper<SweetWechatUsers> {
+
+}

liquidnet-bus-do/liquidnet-service-sweet-do/src/main/java/com/liquidnet/service/sweet/mapper/SweetWechatUsersRelationMapper.java

+package com.liquidnet.service.sweet.mapper;
+
+import com.liquidnet.service.sweet.entity.SweetWechatUsersRelation;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * <p>
+ * 微信用户信息关联表 Mapper 接口
+ * </p>
+ *
+ * @author jiangxiulong
+ * @since 2021-11-04
+ */
+public interface SweetWechatUsersRelationMapper extends BaseMapper<SweetWechatUsersRelation> {
+
+}

liquidnet-bus-do/liquidnet-service-sweet-do/src/main/resources/com.liquidnet.service.sweet.mapper/SweetWechatUsersMapper.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.liquidnet.service.sweet.mapper.SweetWechatUsersMapper">
+
+</mapper>

liquidnet-bus-do/liquidnet-service-sweet-do/src/main/resources/com.liquidnet.service.sweet.mapper/SweetWechatUsersRelationMapper.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.liquidnet.service.sweet.mapper.SweetWechatUsersRelationMapper">
+
+</mapper>

liquidnet-bus-service/liquidnet-service-sweet/docu/db_sweet_integral_activity_20211020.sql

@@ -85,3 +85,52 @@ CREATE TABLE `sweet_integral_activity_draw`
   DEFAULT CHARSET utf8mb4
   COLLATE utf8mb4_unicode_ci
   ROW_FORMAT = DYNAMIC COMMENT '积分活动抽奖记录表';
+
+-- 微信用户信息表包含小程序公众号
+drop TABLE if exists `sweet_wechat_users`;
+CREATE TABLE `sweet_wechat_users`
+(
+    `mid`               bigint unsigned NOT NULL AUTO_INCREMENT,
+    `wechat_id`         varchar(200)    NOT NULL DEFAULT '' COMMENT 'wechat_id',
+    `open_id`           varchar(200)    NOT NULL DEFAULT '' COMMENT 'openId',
+    `union_id`          varchar(200)    NOT NULL DEFAULT '' COMMENT 'unionId',
+    `type`              tinyint         NOT NULL DEFAULT 0 COMMENT '服务类型 1正在 2摩登 21草莓 22五百里 23mdsk 24正在',
+    `phone_number`      varchar(200)    NOT NULL DEFAULT '' COMMENT '小程序解密手机号',
+    `pure_phone_number` varchar(200)    NOT NULL DEFAULT '' COMMENT '小程序解密手机号',
+    `country_code`      varchar(200)    NOT NULL DEFAULT '' COMMENT '小程序解密地区码',
+    `nickname`          varchar(200)    NOT NULL DEFAULT '' COMMENT '昵称',
+    `sex_desc`          varchar(200)    NOT NULL DEFAULT '' COMMENT '性别',
+    `sex`               tinyint         NOT NULL DEFAULT 0 COMMENT '性别 男1',
+    `head_img_url`      varchar(200)    NOT NULL DEFAULT '' COMMENT '头像',
+    `language`          varchar(200)    NOT NULL DEFAULT '' COMMENT 'zh_CN',
+    `country`           varchar(200)    NOT NULL DEFAULT '' COMMENT '国家',
+    `province`          varchar(200)    NOT NULL DEFAULT '' COMMENT '省',
+    `city`              varchar(200)    NOT NULL DEFAULT '' COMMENT '市',
+    `subscribe_time`    datetime        NULL     DEFAULT null COMMENT '关注时间',
+    `subscribe_scene`   varchar(200)    NOT NULL DEFAULT '' COMMENT 'ADD_SCENE_SEARCH 关注方式',
+    `created_at`        datetime        NULL     DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+    `updated_at`        datetime        NULL     DEFAULT CURRENT_TIMESTAMP COMMENT '更新时间',
+    PRIMARY KEY (`mid`),
+    KEY `idx_sweet_wechat_id` (`wechat_id`)
+) ENGINE = InnoDB
+  DEFAULT CHARSET utf8mb4
+  COLLATE utf8mb4_unicode_ci
+  ROW_FORMAT = DYNAMIC COMMENT '微信用户信息表包含小程序公众号';
+
+-- 微信用户信息关联表
+drop TABLE if exists `sweet_wechat_users_relation`;
+CREATE TABLE `sweet_wechat_users_relation`
+(
+    `mid`                bigint unsigned NOT NULL AUTO_INCREMENT,
+    `wechat_relation_id` varchar(200)    NOT NULL DEFAULT '' COMMENT 'wechat_relation_id',
+    `union_id`           varchar(200)    NOT NULL DEFAULT '' COMMENT 'unionId',
+    `user_id`            varchar(200)    NOT NULL DEFAULT '' COMMENT 'adam用户id',
+    `user_phone`         varchar(200)    NOT NULL DEFAULT '' COMMENT 'adam用户手机号',
+    `created_at`         datetime        NULL     DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+    `updated_at`         datetime        NULL     DEFAULT CURRENT_TIMESTAMP COMMENT '更新时间',
+    PRIMARY KEY (`mid`),
+    KEY `idx_sweet_wechat_relation_id` (`wechat_relation_id`)
+) ENGINE = InnoDB
+  DEFAULT CHARSET utf8mb4
+  COLLATE utf8mb4_unicode_ci
+  ROW_FORMAT = DYNAMIC COMMENT '微信用户信息关联表';
\ No newline at end of file

liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/service/impl/SweetWechatUsersRelationServiceImpl.java

+package com.liquidnet.service.sweet.service.impl;
+
+import com.liquidnet.service.sweet.entity.SweetWechatUsersRelation;
+import com.liquidnet.service.sweet.mapper.SweetWechatUsersRelationMapper;
+import com.liquidnet.service.sweet.service.ISweetWechatUsersRelationService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ * 微信用户信息关联表 服务实现类
+ * </p>
+ *
+ * @author jiangxiulong
+ * @since 2021-11-04
+ */
+@Service
+public class SweetWechatUsersRelationServiceImpl extends ServiceImpl<SweetWechatUsersRelationMapper, SweetWechatUsersRelation> implements ISweetWechatUsersRelationService {
+
+}

liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/service/impl/SweetWechatUsersServiceImpl.java

+package com.liquidnet.service.sweet.service.impl;
+
+import com.liquidnet.service.sweet.entity.SweetWechatUsers;
+import com.liquidnet.service.sweet.mapper.SweetWechatUsersMapper;
+import com.liquidnet.service.sweet.service.ISweetWechatUsersService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ * 微信用户信息表包含小程序公众号 服务实现类
+ * </p>
+ *
+ * @author jiangxiulong
+ * @since 2021-11-04
+ */
+@Service
+public class SweetWechatUsersServiceImpl extends ServiceImpl<SweetWechatUsersMapper, SweetWechatUsers> implements ISweetWechatUsersService {
+
+}

liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/utils/WechatUsersRedisUtils.java

+package com.liquidnet.service.sweet.utils;
+
+import com.liquidnet.common.cache.redis.util.RedisUtil;
+import com.liquidnet.service.sweet.constant.SweetConstant;
+import com.liquidnet.service.sweet.vo.SweetWechatUsersRelationVo;
+import com.liquidnet.service.sweet.vo.SweetWechatUsersVo;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+@Component
+@Slf4j
+public class WechatUsersRedisUtils {
+
+    @Autowired
+    private RedisUtil redisUtil;
+
+    public SweetWechatUsersVo getSweetWechatUsers(String unionId, Integer type) {
+        String redisKey = SweetConstant.REDIS_KEY_SWEET_WECHAT_USERS.concat(unionId)
+                .concat(SweetConstant.REDIS_KEY_SWEET_WECHAT_USERS_TYPE).concat(String.valueOf(type));
+        Object obj = redisUtil.get(redisKey);
+        if (null == obj) {
+            return null;
+        } else {
+            SweetWechatUsersVo sweetWechatUsersVo = (SweetWechatUsersVo) obj;
+            return sweetWechatUsersVo;
+        }
+    }
+    public void setSweetWechatUsers(SweetWechatUsersVo sweetWechatUsersVo) {
+        String redisKey = SweetConstant.REDIS_KEY_SWEET_WECHAT_USERS.concat(sweetWechatUsersVo.getUnionId())
+                .concat(SweetConstant.REDIS_KEY_SWEET_WECHAT_USERS_TYPE).concat(String.valueOf(sweetWechatUsersVo.getType()));
+        redisUtil.set(redisKey, sweetWechatUsersVo);
+    }
+    public void delSweetWechatUsers(String unionId, Integer type) {
+        String redisKey = SweetConstant.REDIS_KEY_SWEET_WECHAT_USERS.concat(unionId)
+                .concat(SweetConstant.REDIS_KEY_SWEET_WECHAT_USERS_TYPE).concat(String.valueOf(type));
+        redisUtil.del(redisKey);
+    }
+
+    public SweetWechatUsersRelationVo getSweetWechatUsersRelation(String mobile) {
+        String redisKey = SweetConstant.REDIS_KEY_SWEET_WECHAT_USERS_RELATION.concat(mobile);
+        Object obj = redisUtil.get(redisKey);
+        if (null == obj) {
+            return null;
+        } else {
+            SweetWechatUsersRelationVo sweetWechatUsersRelationVo = (SweetWechatUsersRelationVo) obj;
+            return sweetWechatUsersRelationVo;
+        }
+    }
+    public void setSweetWechatUsersRelation(SweetWechatUsersRelationVo usersRelationVo) {
+        String redisKey = SweetConstant.REDIS_KEY_SWEET_WECHAT_USERS_RELATION.concat(usersRelationVo.getUserPhone());
+        redisUtil.set(redisKey, usersRelationVo);
+    }
+
+}