增加type字段 区分正在摩登用户

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

@@ -439,6 +439,7 @@ CREATE TABLE `sweet_wechat_user`
   DEFAULT CHARSET utf8mb4
   COLLATE utf8mb4_unicode_ci
   ROW_FORMAT = DYNAMIC COMMENT '正在现场服务号关注事件储存用户信息表';
+alter table sweet_wechat_user add type tinyint NOT NULL DEFAULT 1 COMMENT '服务类型 1正在 2摩登' after user_id;
 
 -- 小程序登录记录用户解密后信息表
 drop TABLE if exists `sweet_applet_user`;

liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/handler/SubscribeHandler.java

@@ -81,7 +81,7 @@ public class SubscribeHandler implements WxMpMessageHandler {
                 LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr();
                 sqls.add(SqlMapping.get("sweet_user.insert"));
                 sqlsDataA.add(new Object[]{
-                        sweetWechatUser.getUserId(), sweetWechatUser.getOpenId(), sweetWechatUser.getUnionId(), sweetWechatUser.getNickname(),
+                        sweetWechatUser.getUserId(), 1, sweetWechatUser.getOpenId(), sweetWechatUser.getUnionId(), sweetWechatUser.getNickname(),
                         sweetWechatUser.getSexDesc(), sweetWechatUser.getSex(), sweetWechatUser.getHeadImgUrl(), sweetWechatUser.getLanguage(),
                         sweetWechatUser.getCountry(), sweetWechatUser.getProvince(), sweetWechatUser.getCity(),
                         sweetWechatUser.getSubscribeTime(), sweetWechatUser.getSubscribeScene()
@@ -115,7 +115,7 @@ public class SubscribeHandler implements WxMpMessageHandler {
                 LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr();
                 sqls.add(SqlMapping.get("sweet_user.insert"));
                 sqlsDataA.add(new Object[]{
-                        sweetWechatUser.getUserId(), sweetWechatUser.getOpenId(), sweetWechatUser.getUnionId(), sweetWechatUser.getNickname(),
+                        sweetWechatUser.getUserId(), 2, sweetWechatUser.getOpenId(), sweetWechatUser.getUnionId(), sweetWechatUser.getNickname(),
                         sweetWechatUser.getSexDesc(), sweetWechatUser.getSex(), sweetWechatUser.getHeadImgUrl(), sweetWechatUser.getLanguage(),
                         sweetWechatUser.getCountry(), sweetWechatUser.getProvince(), sweetWechatUser.getCity(),
                         sweetWechatUser.getSubscribeTime(), sweetWechatUser.getSubscribeScene()

liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/handler/UnsubscribeHandler.java

@@ -66,7 +66,7 @@ public class UnsubscribeHandler implements WxMpMessageHandler {
                     LocalDateTime now = LocalDateTime.now();
                     sqls.add(SqlMapping.get("sweet_user.update"));
                     sqlsDataA.add(new Object[]{
-                            2, now, sweetWechatUserUnionid
+                            2, now, sweetWechatUserUnionid, 1
                     });
                     queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_USER_INSERT_DRAW.getKey(),
                             SqlMapping.gets(sqls, sqlsDataA));
@@ -84,7 +84,7 @@ public class UnsubscribeHandler implements WxMpMessageHandler {
                     LocalDateTime now = LocalDateTime.now();
                     sqls.add(SqlMapping.get("sweet_user.update"));
                     sqlsDataA.add(new Object[]{
-                            2, now, sweetWechatUserUnionid
+                            2, now, sweetWechatUserUnionid, 2
                     });
                     queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_USER_INSERT_DRAW.getKey(),
                             SqlMapping.gets(sqls, sqlsDataA));

liquidnet-bus-service/liquidnet-service-sweet/src/main/resources/sqlmap.properties

@@ -43,8 +43,8 @@ sweet_luck_draw.insert=INSERT INTO sweet_luck_draw (mobile,union_id,luck_draw_nu
 # --------------------------答案--------------------------
 sweet_answer.insert=INSERT INTO sweet_answer (answer_id,phone,answer_json,img_url) VALUES (?,?,?,?)
 # --------------------------关注/取消服务号的用户信息--------------------------
-sweet_user.insert=INSERT INTO sweet_wechat_user (user_id,openId,unionId,nickname,sexDesc,sex,headImgUrl,language,country,province,city,subscribeTime,subscribeScene) VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?)
-sweet_user.update=UPDATE sweet_wechat_user SET is_cancel = ?, updated_at = ?  WHERE unionId = ?
+sweet_user.insert=INSERT INTO sweet_wechat_user (user_id,type,openId,unionId,nickname,sexDesc,sex,headImgUrl,language,country,province,city,subscribeTime,subscribeScene) VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?)
+sweet_user.update=UPDATE sweet_wechat_user SET is_cancel = ?, updated_at = ?  WHERE unionId = ? and type = ?
 # --------------------------提醒记录--------------------------
 sweet_remind.insert=INSERT INTO sweet_remind (remind_id,openId,unionId,performancesId) VALUES (?,?,?,?)
 # --------------------------小程序登录记录用户解密后信息--------------------------