记得上下班打卡 | git大法好,push需谨慎

Commit 03a67ff7 authored by jiangxiulong's avatar jiangxiulong

add table applet

parent 075ae83a
......@@ -39,6 +39,16 @@ public class SweetAppletSubMsg implements Serializable {
*/
private String templateId;
/**
* 目标id 显示是演出id
*/
private String targetId;
/**
* 1草莓 2五百里 3mdsk 4正在
*/
private Integer appletType;
/**
* 是否推送 1未推送 2已推送
*/
......
......@@ -6,7 +6,9 @@ CREATE TABLE `sweet_applet_sub_msg`
`msg_id` varchar(255) NOT NULL DEFAULT '' COMMENT 'msg_id',
`open_id` varchar(255) NOT NULL DEFAULT '' COMMENT 'open_id',
`template_id` varchar(255) NOT NULL DEFAULT '' COMMENT 'template_id',
`is_push` tinyint NOT NULL DEFAULT 1 COMMENT '是否推送 1未推送 2已推送',
`target_id` varchar(255) NOT NULL DEFAULT '' COMMENT '目标id 显示是演出id',
`applet_type` tinyint NOT NULL DEFAULT 0 COMMENT '1草莓 2五百里 3mdsk 4正在',
`is_push` tinyint NOT NULL DEFAULT 1 COMMENT '是否推送 1未推送 2已推送',
`created_at` datetime NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
`updated_at` datetime NULL DEFAULT CURRENT_TIMESTAMP COMMENT '更新时间',
PRIMARY KEY (`mid`),
......
......@@ -177,29 +177,25 @@ public class WechatMaConfigure {
}
public WxMaMessageRouter messageRouter(Integer type) {
log.info("messageRouter1");
WxMaMessageRouter router = getWxMaMessageRouter(type);
// 消息去重
// router.setMessageDuplicateChecker(wxMessageInMemoryDuplicateChecker);
// 订阅事件
router.rule().async(false).msgType(WxConsts.XmlMsgType.EVENT)
/*router.rule().async(false).msgType(WxConsts.XmlMsgType.EVENT)
.event("subscribe_msg_popup_event")
.handler(subscribeHandler)
.end();
log.info("messageRouter2");
.end();*/
router.rule().async(false)
.content("订阅消息")
.handler(subscribeHandler)
.end();
log.info("messageRouter3");
// 取消订阅事件
router.rule().async(false).msgType(WxConsts.XmlMsgType.EVENT)
.event("subscribe_msg_popup_event")
.handler(unsubscribeHandler)
.end();
log.info("messageRouter4");
return router;
}
......
......@@ -41,12 +41,14 @@ public class ApplySubscribeHandler implements WxMaMessageHandler {
log.info("ApplySubscribeHandler message{},context{},service{},sessionManager{}", message, context, service, sessionManager);
String openId = message.getFromUser();
String templateId = "ue0Ehbk0u-akw4hIx_xUsrElT4gFOgc_Ch-CSsJlXas";
String targetId = "4567654235465";
String appletType = "4";
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
IDGenerator.nextSnowId(), openId, templateId, targetId, appletType
});
queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_REMIND_INSERT.getKey(),
SqlMapping.gets(sqls, sqlsDataA));
......
......@@ -37,7 +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_applet_sub_msg.insert=INSERT INTO sweet_applet_sub_msg (msg_id,open_id,template_id,target_id,applet_type) 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 (?,?,?,?,?)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment