MsgData

liquidnet-bus-feign/liquidnet-api-feign-sweet/src/main/java/com/liquidnet/service/feign/sweet/task/FeignSweetWechatClient.java

@@ -16,4 +16,7 @@ public interface FeignSweetWechatClient {
     @GetMapping("sweet/wechatTemplate/send")
     ResponseDto send();
 
+    @GetMapping("sweet/appletSubMsg/send")
+    ResponseDto sendSubMsg();
+
 }

liquidnet-bus-service/liquidnet-service-executor-all/liquidnet-service-executor-main/src/main/java/com/liquidnet/service/executor/main/handler/SweetWechatTaskHandler.java

@@ -34,4 +34,20 @@ public class SweetWechatTaskHandler {
         }
     }
 
+    @XxlJob(value = "sev-sweet:sendSubMsg")
+    public ReturnT<String> sendSubMsgHandler() {
+        try {
+            Object data = feignSweetWechatClient.sendSubMsg().getData();
+            log.info("sendSubMsgHandler：结果：{}", data);
+            ReturnT<String> success = ReturnT.SUCCESS;
+            success.setMsg(String.valueOf(data));
+            return success;
+        } catch (Exception e) {
+            log.error("exception of handler:{}", e.getMessage(), e);
+            ReturnT<String> fail = ReturnT.FAIL;
+            fail.setMsg(e.getLocalizedMessage());
+            return fail;
+        }
+    }
+
 }

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

@@ -86,7 +86,7 @@ public class SweetAppletSubMsgServiceImpl extends ServiceImpl<SweetAppletSubMsgM
                         continue;
                     }
                     // 发送订阅消息接口
-                    boolean subMessage = sendSubMessage(info);
+                    boolean subMessage = sendSubMessage(info, performanceVoData);
                     if (subMessage) {
                         msgIdList.add(msgId);
                     }
@@ -111,7 +111,7 @@ public class SweetAppletSubMsgServiceImpl extends ServiceImpl<SweetAppletSubMsgM
     /**
      * 微信小程序推送订阅消息
      */
-    public boolean sendSubMessage(SweetAppletSubMsg info) {
+    public boolean sendSubMessage(SweetAppletSubMsg info, KylinPerformanceVo performanceVo) {
 
         WxMaSubscribeMessage subscribeMessage = new WxMaSubscribeMessage();
 
@@ -122,20 +122,20 @@ public class SweetAppletSubMsgServiceImpl extends ServiceImpl<SweetAppletSubMsgM
         ArrayList<WxMaSubscribeMessage.MsgData> wxMaSubscribeData = new ArrayList<>();
         WxMaSubscribeMessage.MsgData wxMaSubscribeData1 = new WxMaSubscribeMessage.MsgData();
         wxMaSubscribeData1.setName("thing1");
-        wxMaSubscribeData1.setValue("豪华版");
+        wxMaSubscribeData1.setValue(performanceVo.getTitle());
         //每个参数 存放到大集合中
         wxMaSubscribeData.add(wxMaSubscribeData1);
 
         // 第二个内容：用户昵称
         WxMaSubscribeMessage.MsgData wxMaSubscribeData2 = new WxMaSubscribeMessage.MsgData();
         wxMaSubscribeData2.setName("time2");
-        wxMaSubscribeData2.setValue("2021-07-09 23:20:30");
+        wxMaSubscribeData2.setValue(performanceVo.getTimeStart());
         wxMaSubscribeData.add(wxMaSubscribeData2);
 
         // 第三个内容：领取方式
         WxMaSubscribeMessage.MsgData wxMaSubscribeData3 = new WxMaSubscribeMessage.MsgData();
         wxMaSubscribeData3.setName("thing3");
-        wxMaSubscribeData3.setValue("请联系您的专属");
+        wxMaSubscribeData3.setValue("您关注的演出活动门票即将开售，请准备购票");
         wxMaSubscribeData.add(wxMaSubscribeData3);
 
         subscribeMessage.setData(wxMaSubscribeData);