取消关注软删除

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

@@ -80,6 +80,11 @@ public class SweetWechatUsersVo implements Serializable, Cloneable {
      */
     private String subscribeScene;
 
+    /**
+     * 是否取消 1正常 2已取消
+     */
+    private Integer isCancel;
+
     /**
      * 创建时间
      */

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

@@ -94,6 +94,11 @@ public class SweetWechatUsers implements Serializable {
      */
     private String subscribeScene;
 
+    /**
+     * 是否取消 1正常 2已取消
+     */
+    private Integer isCancel;
+
     /**
      * 创建时间
      */

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

@@ -441,6 +441,7 @@ CREATE TABLE `sweet_wechat_users`
   ROW_FORMAT = DYNAMIC COMMENT '正在现场服务号关注事件储存用户信息表';
 ALTER TABLE `sweet_wechat_users` ADD INDEX idx_wechat_open_id (`open_id`);
 ALTER TABLE `sweet_wechat_users` ADD INDEX idx_wechat_union_id (`union_id`);
+alter table sweet_wechat_users add is_cancel tinyint NOT NULL DEFAULT 1 COMMENT '是否取消 1正常 2已取消' after subscribe_scene;
 
 -- 小程序登录记录用户解密后信息表
 drop TABLE if exists `sweet_applet_users`;

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

@@ -14,10 +14,10 @@ import me.chanjar.weixin.mp.api.WxMpMessageHandler;
 import me.chanjar.weixin.mp.api.WxMpService;
 import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage;
 import me.chanjar.weixin.mp.bean.message.WxMpXmlOutMessage;
-import me.chanjar.weixin.mp.bean.result.WxMpUser;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
+import java.time.LocalDateTime;
 import java.util.LinkedList;
 import java.util.Map;
 
@@ -68,9 +68,9 @@ public class UnsubscribeHandler implements WxMpMessageHandler {
                 redisUtils.delSweetWechatUsers(sweetWechatUsers.getUnionId(), openId, type);
                 LinkedList<String> sqls = CollectionUtil.linkedListString();
                 LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr();
-                sqls.add(SqlMapping.get("sweet_wechat_users.delete"));
+                sqls.add(SqlMapping.get("sweet_wechat_users.update"));
                 sqlsDataA.add(new Object[]{
-                        sweetWechatUsers.getUnionId(), type
+                        2, LocalDateTime.now(), sweetWechatUsers.getUnionId(), type
                 });
                 queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_WECHAT_USER_INSERT.getKey(),
                         SqlMapping.gets(sqls, sqlsDataA));

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

@@ -48,6 +48,7 @@ sweet_applet_users.insert=INSERT INTO sweet_applet_users (applet_user_id,user_id
 # --------------------------微信用户信息表公众号--------------------------
 sweet_wechat_users.insert=INSERT INTO sweet_wechat_users (wechat_user_id,type,open_id,union_id,nickname,sex_desc,sex,head_img_url,language,country,province,city,subscribe_time,subscribe_scene) VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?)
 sweet_wechat_users.delete=DELETE FROM sweet_wechat_users WHERE union_id = ? and type = ?
+sweet_wechat_users.update=UPDATE sweet_wechat_users SET is_cancel = ?, updated_at = ? WHERE union_id = ? AND type = ?
 
 #---------------------------音乐节活动海报--------------------------------
 sweet_strawberry_poster_user=INSERT INTO sweet_strawberry_poster(open_id,poster_id,union_id,nickname,city_name,city_code,custom_text,created_at,updated_at) VALUES (?,?,?,?,?,?,?,?,?)