wechat msg xxl

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

 package com.liquidnet.service.sweet.service.impl;
 
 import com.liquidnet.common.cache.redis.util.RedisUtil;
+import com.liquidnet.commons.lang.util.DateUtil;
 import com.liquidnet.service.base.ResponseDto;
 import com.liquidnet.service.kylin.constant.KylinRedisConst;
+import com.liquidnet.service.kylin.dto.vo.middle.KylinTicketTimesVo;
 import com.liquidnet.service.kylin.dto.vo.mongo.KylinPerformanceVo;
 import com.liquidnet.service.sweet.constant.SweetConstant;
 import com.liquidnet.service.sweet.entity.SweetWechatUser;
@@ -53,7 +55,19 @@ public class SweetWechatTemplateServiceImpl {
             for (String rkey : keys) {
                 SweetRemindVo remindInfo = (SweetRemindVo) redisUtil.get(rkey);
                 SweetWechatUser sweetWechatUser = redisDataUtils.getSweetWechatUser(remindInfo.getUnionId());
-                if (null == sweetWechatUser) {
+                KylinPerformanceVo performanceVo = (KylinPerformanceVo) redisUtil.get(KylinRedisConst.PERFORMANCES.concat(remindInfo.getPerformancesId()));
+                KylinTicketTimesVo kylinTicketTimesVo = performanceVo.getTicketTimeList().get(0);
+                if (null == sweetWechatUser || null == performanceVo) {
+                    continue;
+                }
+                String nowTimeStr = DateUtil.getNowTime();
+                String sellTime = performanceVo.getSellTime();
+                String stopSellTime = performanceVo.getStopSellTime();
+                if (1 == DateUtil.compareStrDay(nowTimeStr, stopSellTime)) { // 超过售卖期 不推 删redis
+                    redisDataUtils.delSweetRemind(remindInfo.getUnionId());
+                    continue;
+                }
+                if (-1 == DateUtil.compareStrDay(nowTimeStr, sellTime)) { // 还没到售卖期
                     continue;
                 }
                 // 发送模板消息接口
@@ -63,12 +77,13 @@ public class SweetWechatTemplateServiceImpl {
                         // 模板id
                         .templateId(templateId)
                         // 模板跳转链接
-//                        .url("")
+                        // .url("")
                         .build();
                 // 添加模板数据
                 templateMessage.addData(new WxMpTemplateData("first", "您好"))
-                        .addData(new WxMpTemplateData("keyword1", "演出名称"))
-                        .addData(new WxMpTemplateData("keyword3", "场馆"))
+                        .addData(new WxMpTemplateData("keyword1", performanceVo.getTitle()))
+                        .addData(new WxMpTemplateData("keyword2", kylinTicketTimesVo.getTitle()))
+                        .addData(new WxMpTemplateData("keyword3", performanceVo.getFieldName()))
                         .addData(new WxMpTemplateData("remark", "备注"));
                 String msgId = null;
                 try {
@@ -76,6 +91,9 @@ public class SweetWechatTemplateServiceImpl {
                     WxMpConfigStorage wxMpConfig = wxMpConfig(appid, secret);
                     WxMpService wxMpService = wxMpService(wxMpConfig);
                     msgId = wxMpService.getTemplateMsgService().sendTemplateMsg(templateMessage);
+                    if (null != msgId) {
+                        redisDataUtils.delSweetRemind(remindInfo.getUnionId());
+                    }
                 } catch (WxErrorException e) {
                     e.printStackTrace();
                 }
@@ -105,8 +123,7 @@ public class SweetWechatTemplateServiceImpl {
     }
 
     public ResponseDto remind(String openId, String unionId, String performancesId) {
-        KylinPerformanceVo performanceInfo = (KylinPerformanceVo) redisUtil.get(KylinRedisConst.PERFORMANCES);
-        redisDataUtils.setSweetRemind(openId, unionId, performancesId, performanceInfo);
+        redisDataUtils.setSweetRemind(openId, unionId, performancesId);
         return ResponseDto.success();
     }
 }

liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/utils/RedisDataUtils.java

@@ -4,7 +4,6 @@ import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.liquidnet.common.cache.redis.util.RedisUtil;
 import com.liquidnet.commons.lang.util.CollectionUtil;
 import com.liquidnet.commons.lang.util.DateUtil;
-import com.liquidnet.service.kylin.dto.vo.mongo.KylinPerformanceVo;
 import com.liquidnet.service.sweet.constant.SweetConstant;
 import com.liquidnet.service.sweet.dto.SweetManualAppletDto;
 import com.liquidnet.service.sweet.dto.SweetManualArtistList2Dto;
@@ -263,7 +262,7 @@ public class RedisDataUtils {
     }
 
     // 小程序演出提醒
-    public void setSweetRemind(String openId, String unionId, String performancesId, KylinPerformanceVo performanceInfo) {
+    public void setSweetRemind(String openId, String unionId, String performancesId) {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_REMIND.concat(unionId);
         SweetRemindVo sweetRemindVo = SweetRemindVo.getNew();
         sweetRemindVo.setCreatedAt(DateUtil.getNowTime());
@@ -271,14 +270,12 @@ public class RedisDataUtils {
         sweetRemindVo.setUnionId(unionId);
         sweetRemindVo.setOpenId(openId);
 
-        if (null != performanceInfo) {
-            sweetRemindVo.setFieldName(performanceInfo.getFieldName());
-            sweetRemindVo.setTitle(performanceInfo.getTitle());
-            sweetRemindVo.setTimeStart(performanceInfo.getTimeStart());
-            sweetRemindVo.setSellTime(performanceInfo.getSellTime());
-        }
         redisUtil.set(redisKey, sweetRemindVo);
     }
+    public void delSweetRemind(String unionId) {
+        String redisKey = SweetConstant.REDIS_KEY_SWEET_REMIND.concat(unionId);
+        redisUtil.del(redisKey);
+    }
 
     // 正在现场服务号关注事件储存用户信息
     public void setSweetWechatUser(SweetWechatUser sweetWechatUser) {

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

@@ -9,10 +9,10 @@ public class SweetRemindVo implements Serializable, Cloneable {
     private String performancesId;
     private String openId;
     private String unionId;
-    private String title;
+    /*private String title;
     private String timeStart;
     private String sellTime;
-    private String fieldName;
+    private String fieldName;*/
 
     private String createdAt;
     private String updatedAt;