添加订阅记录

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

@@ -15,4 +15,6 @@ import com.baomidou.mybatisplus.extension.service.IService;
 public interface ISweetAppletSubMsgService extends IService<SweetAppletSubMsg> {
 
     ResponseDto sendMsg();
+
+    ResponseDto<Boolean> create(String openId, String templateId, String targetId, String appletType);
 }

liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/controller/SweetAppletSubMsgController.java

@@ -4,6 +4,8 @@ package com.liquidnet.service.sweet.controller;
 import com.liquidnet.service.base.ResponseDto;
 import com.liquidnet.service.sweet.service.impl.SweetAppletSubMsgServiceImpl;
 import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiImplicitParams;
 import io.swagger.annotations.ApiOperation;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -34,5 +36,22 @@ public class SweetAppletSubMsgController {
         return subMsgService.sendMsg();
     }
 
+    @PostMapping("create")
+    @ApiOperation("添加订阅记录")
+    @ApiImplicitParams({
+            @ApiImplicitParam(type = "form", dataType = "String", name = "openId", value = "openId", required = true),
+            @ApiImplicitParam(type = "form", dataType = "String", name = "templateId", value = "templateId 多个用英文逗号分割", required = true),
+            @ApiImplicitParam(type = "form", dataType = "String", name = "targetId", value = "演出id", required = true),
+            @ApiImplicitParam(type = "form", dataType = "String", name = "appletType", value = "1草莓 2五百里 3mdsk 4正在", required = true),
+    })
+    public ResponseDto<Boolean> create(
+            @RequestParam() String openId,
+            @RequestParam() String templateId,
+            @RequestParam() String targetId,
+            @RequestParam() String appletType
+    ) {
+        return subMsgService.create(openId, templateId, targetId, appletType);
+    }
+
 
 }

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

@@ -2,11 +2,13 @@ package com.liquidnet.service.sweet.service.impl;
 
 import cn.binarywang.wx.miniapp.api.WxMaService;
 import cn.binarywang.wx.miniapp.bean.WxMaSubscribeMessage;
-import cn.binarywang.wx.miniapp.bean.WxMaTemplateData;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.liquidnet.commons.lang.util.CollectionUtil;
 import com.liquidnet.commons.lang.util.DateUtil;
+import com.liquidnet.commons.lang.util.IDGenerator;
 import com.liquidnet.service.base.ResponseDto;
+import com.liquidnet.service.base.SqlMapping;
+import com.liquidnet.service.base.constant.MQConst;
 import com.liquidnet.service.feign.kylin.api.FeignKylinPerformancesClient;
 import com.liquidnet.service.kylin.dto.vo.middle.KylinTicketTimesVo;
 import com.liquidnet.service.kylin.dto.vo.mongo.KylinPerformanceVo;
@@ -15,6 +17,7 @@ import com.liquidnet.service.sweet.entity.SweetAppletSubMsg;
 import com.liquidnet.service.sweet.mapper.SweetAppletSubMsgMapper;
 import com.liquidnet.service.sweet.service.ISweetAppletSubMsgService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.liquidnet.service.sweet.utils.QueueUtils;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -24,6 +27,7 @@ import org.springframework.util.ObjectUtils;
 import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
 import java.util.ArrayList;
+import java.util.LinkedList;
 import java.util.List;
 
 /**
@@ -47,6 +51,9 @@ public class SweetAppletSubMsgServiceImpl extends ServiceImpl<SweetAppletSubMsgM
     @Autowired
     WechatMaConfigure wechatMaConfigure;
 
+    @Autowired
+    private QueueUtils queueUtils;
+
     @Override
     public ResponseDto sendMsg() {
         List<SweetAppletSubMsg> msgList = subMsgMapper.selectList(
@@ -108,6 +115,23 @@ public class SweetAppletSubMsgServiceImpl extends ServiceImpl<SweetAppletSubMsgM
         return ResponseDto.success();
     }
 
+    @Override
+    public ResponseDto<Boolean> create(String openId, String templateId, String targetId, String appletType) {
+        String[] templateIdArray = templateId.split(",");
+
+        LinkedList<String> sqls = CollectionUtil.linkedListString();
+        LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr();
+        sqls.add(SqlMapping.get("sweet_applet_sub_msg.insert"));
+        for (String id : templateIdArray) {
+            sqlsDataA.add(new Object[]{
+                    IDGenerator.nextSnowId(), openId, id, targetId, appletType
+            });
+        }
+        queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_REMIND_INSERT.getKey(),
+                SqlMapping.gets(sqls, sqlsDataA));
+        return ResponseDto.success();
+    }
+
     /**
      * 微信小程序推送订阅消息
      */