del 没有的代码

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.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.liquidnet.common.cache.redis.util.RedisUtil;
 import com.liquidnet.commons.lang.util.CollectionUtil;
@@ -33,7 +32,6 @@ import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
 import java.util.ArrayList;
 import java.util.List;
-import java.util.Map;
 
 /**
  * <p>
@@ -70,24 +68,9 @@ public class SweetWechatTemplateServiceImpl {
     WechatMaConfigure wechatMaConfigure;
 
     public ResponseDto openSendMsg(SweetOpenSendMsgParam param) {
-        WxMpTemplateMessage templateMessage = null;
-        if (param.getJumpType() == 5) {
-            templateMessage = getTemplateMessage(param.getTemplateId(), param.getOpenId(), param.getJumpUrl());
-        } else {
-            templateMessage = getTemplateMessage(param.getTemplateId(), param.getOpenId(), param.getJumpType(), param.getJumpAppletPagePath(), param.getJumpAppletUsePath());
-        }
-        // 添加模板数据
-        String templateData = param.getTemplateData();
-        JSONObject templateDataJObj = JSONObject.parseObject(templateData);
-        for (Map.Entry<String, Object> entry : templateDataJObj.entrySet()) {
-            templateMessage.addData(new WxMpTemplateData(entry.getKey(), String.valueOf(entry.getValue())));
-        }
-        String msgId = sendTmpMsg(templateMessage, param.getSendTargetType());
-        if (null == msgId) {
-            return ResponseDto.failure("模版消息发送失败");
-        } else {
-            return ResponseDto.success(msgId);
-        }
+        queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_TEMPLATE_MSG.getKey(),
+                JsonUtils.toJson(param));
+        return ResponseDto.success();
     }
 
     public ResponseDto sendRemindMsg() {
@@ -217,6 +200,7 @@ public class SweetWechatTemplateServiceImpl {
                 .build();
         return templateMessage;
     }
+
     private WxMpTemplateMessage getTemplateMessage(String templateId, String openId, String appid, String pagePath) {
         //配置小程序信息
         WxMpTemplateMessage.MiniProgram miniProgram = new WxMpTemplateMessage.MiniProgram();
@@ -231,20 +215,6 @@ public class SweetWechatTemplateServiceImpl {
                 .build();
         return templateMessage;
     }
-    private WxMpTemplateMessage getTemplateMessage(String templateId, String openId, Integer jumpType, String jumpAppletPagePath, Boolean jumpAppletUsePath) {
-        //配置小程序信息
-        WxMpTemplateMessage.MiniProgram miniProgram = new WxMpTemplateMessage.MiniProgram();
-        miniProgram.setAppid(wechatMaConfigure.getWxMaAppid(jumpType));//小程序appid
-        miniProgram.setUsePath(jumpAppletUsePath);//true的话需要前端配合处理跳转
-        miniProgram.setPagePath(jumpAppletPagePath);//用户点击时需要跳转的小程序页面
-
-        WxMpTemplateMessage templateMessage = WxMpTemplateMessage.builder()
-                .toUser(openId) // 接收者openid
-                .templateId(templateId) // 模板id
-                .miniProgram(miniProgram) // 模板跳转链接
-                .build();
-        return templateMessage;
-    }
 
     /**
      * 发送消息
@@ -266,20 +236,6 @@ public class SweetWechatTemplateServiceImpl {
         }
         return msgId;
     }
-    private String sendTmpMsg(WxMpTemplateMessage templateMessage, Integer sendTargetType) {
-        String msgId = null;
-        try {
-            // 发送模板消息
-            WxMpService wxMpService = wechatMpConfigure.getWxMpService(sendTargetType);
-            log.info("sendTmpMsg-isAccessTokenExpired：[{}] ", wxMpService.getWxMpConfigStorage().isAccessTokenExpired());
-            log.info("sendTmpMsg-getAccessToken：[{}] ", wxMpService.getWxMpConfigStorage().getAccessToken());
-            msgId = wxMpService.getTemplateMsgService().sendTemplateMsg(templateMessage);
-            log.info("模版消息发送成功：[msgId=[{}]", msgId);
-        } catch (WxErrorException e) {
-            log.error("模版消息发送异常", e);
-        }
-        return msgId;
-    }
 
     public ResponseDto remind(String openId, String unionId, String performancesId) {
         redisDataUtils.setSweetRemind(openId, unionId, performancesId);
@@ -307,9 +263,4 @@ public class SweetWechatTemplateServiceImpl {
         }
     }
 
-    public ResponseDto testSendMsg(SweetOpenSendMsgParam param) {
-        queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_TEMPLATE_MSG.getKey(),
-                JsonUtils.toJson(param));
-        return ResponseDto.success();
-    }
 }