add table applet

liquidnet-bus-service/liquidnet-service-sweet/docu/redis_queue_create.txt

@@ -17,7 +17,7 @@ XGROUP CREATE sweet:stream:rk.answerInsert group.answerInsert 0
 XADD sweet:stream:rk.sweetUserInsert * 0 0
 XGROUP CREATE sweet:stream:rk.sweetUserInsert group.sweetUserInsert 0
 
---     提醒记录     --
+--     开票提醒 模版消息 订阅消息     --
 XADD sweet:stream:rk.remindInsert * 0 0
 XGROUP CREATE sweet:stream:rk.remindInsert group.remindInsert 0
 

liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/config/WechatMaConfigure.java

@@ -179,18 +179,23 @@ public class WechatMaConfigure {
         // 消息去重
 //        router.setMessageDuplicateChecker(wxMessageInMemoryDuplicateChecker);
 
-        // 关注事件
+        // 订阅事件
         router.rule().async(false).msgType(WxConsts.XmlMsgType.EVENT)
-                .event(WxConsts.EventType.SUBSCRIBE)
+                .event("subscribe_msg_popup_event")
                 .handler(subscribeHandler)
                 .end();
 
-        // 取消关注事件
+        // 取消订阅事件
         router.rule().async(false).msgType(WxConsts.XmlMsgType.EVENT)
-                .event(WxConsts.EventType.UNSUBSCRIBE)
+                .event("subscribe_msg_popup_event")
                 .handler(unsubscribeHandler)
                 .end();
 
+        router.rule().async(false)
+                .content("订阅消息")
+                .handler(subscribeHandler)
+                .end();
+
         return router;
     }
 }

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

@@ -4,16 +4,19 @@ import cn.binarywang.wx.miniapp.api.WxMaService;
 import cn.binarywang.wx.miniapp.bean.WxMaMessage;
 import cn.binarywang.wx.miniapp.message.WxMaMessageHandler;
 import cn.binarywang.wx.miniapp.message.WxMaXmlOutMessage;
+import com.liquidnet.commons.lang.util.CollectionUtil;
+import com.liquidnet.commons.lang.util.IDGenerator;
+import com.liquidnet.service.base.SqlMapping;
+import com.liquidnet.service.base.constant.MQConst;
 import com.liquidnet.service.sweet.config.WechatMpConfigure;
-import com.liquidnet.service.sweet.service.impl.SweetWechatTemplateServiceImpl;
 import com.liquidnet.service.sweet.utils.QueueUtils;
-import com.liquidnet.service.sweet.utils.WechatUsersRedisUtils;
 import lombok.extern.slf4j.Slf4j;
 import me.chanjar.weixin.common.error.WxErrorException;
 import me.chanjar.weixin.common.session.WxSessionManager;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
+import java.util.LinkedList;
 import java.util.Map;
 
 /**
@@ -27,18 +30,27 @@ import java.util.Map;
 @Component
 @Slf4j
 public class ApplySubscribeHandler implements WxMaMessageHandler {
-    @Autowired
-    private WechatUsersRedisUtils redisUtils;
+
     @Autowired
     private QueueUtils queueUtils;
     @Autowired
     WechatMpConfigure wechatMpConfigure;
 
-    @Autowired
-    private SweetWechatTemplateServiceImpl sweetWechatTemplateService;
-
     @Override
     public WxMaXmlOutMessage handle(WxMaMessage message, Map<String, Object> context, WxMaService service, WxSessionManager sessionManager) throws WxErrorException {
+        log.info("ApplySubscribeHandler message{},context{},service{},sessionManager{}", message, context, service, sessionManager);
+        String openId = message.getFromUser();
+        String templateId = "ue0Ehbk0u-akw4hIx_xUsrElT4gFOgc_Ch-CSsJlXas";
+
+        LinkedList<String> sqls = CollectionUtil.linkedListString();
+        LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr();
+        sqls.add(SqlMapping.get("sweet_applet_sub_msg.insert"));
+        sqlsDataA.add(new Object[]{
+                IDGenerator.nextSnowId(), openId, templateId
+        });
+        queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_REMIND_INSERT.getKey(),
+                SqlMapping.gets(sqls, sqlsDataA));
+
         return null;
     }
 }

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

@@ -37,6 +37,7 @@ 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_remind.insert=INSERT INTO sweet_remind (remind_id,openId,unionId,performancesId) VALUES (?,?,?,?)
+sweet_applet_sub_msg.insert=INSERT INTO sweet_applet_sub_msg (msg_id,open_id,template_id) VALUES (?,?,?)
 # --------------------------用户投票记录--------------------------
 sweet_city_vote.insert=INSERT INTO sweet_city_vote (vote_id,phone,openId,unionId,type,city_code,city_name,day_time) VALUES (?,?,?,?,?,?,?,?)
 sweet_city_vote_stat.insert=INSERT INTO sweet_city_vote_stat (stat_id,city_code,city_name,vote_num,type) VALUES (?,?,?,?,?)