消息推送

pom.xml

@@ -30,6 +30,17 @@
     </dependencyManagement>
 
     <dependencies>
+        <!--实体类校验注解-->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-validation</artifactId>
+        </dependency>
+        <!--邮件依赖-->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-mail</artifactId>
+        </dependency>
+
 		<dependency>
 			<groupId>org.springframework.boot</groupId>
 			<artifactId>spring-boot-starter-web</artifactId>

src/main/java/com/caimei365/tools/controller/MessageApi.java

@@ -0,0 +1,81 @@
+package com.caimei365.tools.controller;
+
+import com.caimei365.tools.model.ResponseJson;
+import com.caimei365.tools.model.dto.message.*;
+import com.caimei365.tools.model.dto.message.enums.MessageType;
+import com.caimei365.tools.service.MessageSender;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.RequiredArgsConstructor;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.ArrayList;
+
+@Api(tags = "消息工具")
+@RestController
+@RequiredArgsConstructor
+@RequestMapping("/tools")
+public class MessageApi {
+
+    private final MessageSender messageSender;
+
+    /**
+     * 发送消息
+     *
+     * @param messageModel {
+     *                     信息类型枚举类  code;
+     *                     mq消息参数     mqInfo;
+     *                     消息体        info;
+     *                     }
+     * @return
+     */
+    @ApiOperation("综合消息工具")
+    @PostMapping("/message/send")
+    public ResponseJson sendCommonMessage(MessageModel messageModel) {
+        messageSender.messageSend(messageModel);
+        return ResponseJson.success();
+    }
+
+    @ApiOperation("综合消息工具测试")
+    @GetMapping("/message/send/try")
+    public ResponseJson sendCommonMessagetry(Integer status) {
+        //    WECHAT_TEMPLATE_MESSAGE(1, "微信模板消息"),
+        //    WEB_INSIDE_MESSAGE(2, "站内消息"),
+        //    EMAILS(3, "邮件"),
+        //    SYS_MESSAGE(4, "短信");
+        MessageModel messageModel = new MessageModel();
+        if (4 == status) {
+            MqInfo messageLine = new MqInfo().topic("MessageLine").async(1).delay(4);
+            SmsMessage smsMessage = new SmsMessage().type(3).mobile("15827317748").smsMessageContent("亲，好久没登陆采美了，" +
+                    "近期在找新项目吗？采美新品橱窗有多款院线产品和仪器，现在登陆采美https://www.caimei365.com/，可获一张包邮券！退订回T");
+            messageModel = messageModel.code(MessageType.SYS_MESSAGE).mqInfo(messageLine).info(smsMessage);
+        }
+        if (3 == status) {
+            EmailMessage subject = new EmailMessage().emailMessageContent("测试接口").cc("z525282777@163.com").receiverAddress("525282777@qq.com").subject("接口测试");
+            messageModel = new MessageModel().code(MessageType.EMAILS).info(subject);
+        }
+        if (2 == status) {
+            InsideMessage sud = new InsideMessage().content("测工具").clubId(1111).productId(1111);
+            MqInfo messageLine = new MqInfo().topic("MessageLine").delay(3).async(0);
+            messageModel = messageModel.code(MessageType.WEB_INSIDE_MESSAGE).mqInfo(messageLine).info(sud);
+        }
+        if (1 == status) {
+            WechatTemplateMessage wechatTemplateMessage = new WechatTemplateMessage();
+            ArrayList<String> keyWords = new ArrayList<>();
+            keyWords.add("我测一下");
+            keyWords.add("110");
+            keyWords.add("北京天安门广场");
+            keyWords.add("2022-10-20");
+            wechatTemplateMessage = wechatTemplateMessage.url("https://www.caimei365.com/").templateId("o1nMAIsHAFr0VOu0qEbI1rEFDS14hl40UXbt52I5row")
+                    .openId("o9nzn5wFDZ_WjNo1-SfhqbKNXr4A").appid("wxf3cd4ae0cdd11c36").pagePath("pages/seller/club/list?type=wechat")
+                    .keyWords(keyWords).first("你有一个新机构用户，请及时跟进").remark("点击查看详情，了解更多客户信息。");
+            MqInfo messageLine = new MqInfo().topic("MessageLine").delay(3).async(0);
+            messageModel = messageModel.code(MessageType.WECHAT_TEMPLATE_MESSAGE).info(wechatTemplateMessage).mqInfo(messageLine);
+        }
+        messageSender.messageSend(messageModel);
+        return ResponseJson.success();
+    }
+}

src/main/java/com/caimei365/tools/controller/RocketMqApi.java

@@ -21,7 +21,7 @@ import org.springframework.web.bind.annotation.RestController;
  * @author : Charles
  * @date : 2021/6/17
  */
-@Api(tags="MQ消息中间件API")
+@Api(tags = "MQ消息中间件API")
 @RestController
 @RequiredArgsConstructor
 @RequestMapping("/tools")
@@ -33,23 +33,23 @@ public class RocketMqApi {
      * 发送消息
      *
      * @param messageDto {
-     *                    topic    消息主题
-     *                    content  消息内容
-     *                    tag      消息标签(可选)
-     *                    sort     有序消息(可选)：1是，0否
-     *                    async    异步消息(可选)：1是，0否
-     *                    oneway   单向消息(可选)：1是，0否
-     *                    delay    延时消息等级(可选)：1-18，0否，对应时间依次：1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h
-     *                  }
-     Posteturn SendResult
+     *                   topic    消息主题
+     *                   content  消息内容
+     *                   tag      消息标签(可选)
+     *                   sort     有序消息(可选)：1是，0否
+     *                   async    异步消息(可选)：1是，0否
+     *                   oneway   单向消息(可选)：1是，0否
+     *                   delay    延时消息等级(可选)：1-18，0否，对应时间依次：1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h
+     *                   }
+     *                   Posteturn SendResult
      */
     @ApiOperation("发送消息")
     @PostMapping("/mq/send")
     public ResponseJson<SendResult> sendCommonMessage(MessageDto messageDto) {
-        if (StringUtils.isEmpty(messageDto.getTopic())) {
+        if (StringUtils.isEmpty(messageDto.topic())) {
             return ResponseJson.error("消息主题不能为空！", null);
         }
-        if (StringUtils.isEmpty(messageDto.getContent())) {
+        if (StringUtils.isEmpty(messageDto.content())) {
             return ResponseJson.error("消息内容不能为空！", null);
         }
         SendResult sendResult = rocketMqService.sendCommonMessage(messageDto);

src/main/java/com/caimei365/tools/listener/MessageLIne.java

@@ -0,0 +1,34 @@
+package com.caimei365.tools.listener;
+
+import com.alibaba.fastjson.JSONObject;
+import com.caimei365.tools.model.dto.message.MessageModel;
+import com.caimei365.tools.model.dto.message.MqInfo;
+import com.caimei365.tools.service.MessageSender;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
+import org.apache.rocketmq.spring.core.RocketMQListener;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+
+@Slf4j
+@Component
+@RocketMQMessageListener(
+        topic = "MessageLine",
+        // messageModel = MessageModel.BROADCASTING,//指定为广播消费
+        // consumeMode = ConsumeMode.ORDERLY, // 指定消费模式为顺序消费，消费的顺序也和发送顺序一致
+        // selectorType = SelectorType.TAG,// 如果我们的生产者指定了Tag，但是消费者的selectorExpression没有设置，即用默认的“*”,那么这个消费者也会消费到
+        // selectorExpression = "tag",     // 指定了tag后，发送的消息如果不带tag，将会消费不到
+        consumerGroup = "message_group")
+public class MessageLIne implements RocketMQListener<String> {
+    @Resource
+    private MessageSender messageSender;
+
+    @Override
+    public void onMessage(String model) {
+        MessageModel mod = JSONObject.parseObject(model,MessageModel.class);
+        //重置mq参数
+        mod.mqInfo(new MqInfo());
+        messageSender.messageSend(mod);
+    }
+}

src/main/java/com/caimei365/tools/mapper/MessageCenterMapper.java

@@ -1,8 +1,10 @@
 package com.caimei365.tools.mapper;
 
+import com.caimei365.tools.model.dto.message.InsideMessage;
 import com.caimei365.tools.model.po.CmCouponPo;
 import com.caimei365.tools.model.po.CmUserPo;
 import com.caimei365.tools.model.po.MessageCenterPo;
+import com.caimei365.tools.model.po.ShopReceiptVo;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 
@@ -26,10 +28,6 @@ public interface MessageCenterMapper {
 
     List<Integer> receiptShopID();
 
-//    UserVo clubList(Integer userId);
-//
-//    CouponVo CouponList(Integer couponType);
-
     Integer MessageCount(Integer userType,Integer messageType,Integer commonId);
 
     /**
@@ -49,13 +47,11 @@ public interface MessageCenterMapper {
      */
     Integer listingfeeExpire(Integer shopID);
 
-//    List<MessageCenter> MessageList(Integer userType,Integer messageType,Integer commonId);
-
     String contractMobile(Integer clubID);
 
     String contractMobiles(Integer ShopID);
 
-    String getOpenidListByPermission(String unionId);
+    String getOpenidListByPermission(Integer shopId);
 
     String FromUnionId(Integer userID);
 
@@ -96,4 +92,8 @@ public interface MessageCenterMapper {
     List<CmCouponPo> CouponLists(Integer userID);
 
     List<Integer> CouponUserId();
+
+    void sendInsideMessage(InsideMessage insideMessage);
+
+    List<ShopReceiptVo> findExpireShopId(Integer day);
 }

src/main/java/com/caimei365/tools/model/dto/MessageDto.java

@@ -3,6 +3,7 @@ package com.caimei365.tools.model.dto;
 import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
+import lombok.experimental.Accessors;
 
 import javax.validation.constraints.NotNull;
 import java.io.Serializable;
@@ -15,6 +16,7 @@ import java.io.Serializable;
  */
 @ApiModel("发送消息接收参数")
 @Data
+@Accessors(fluent = true)
 public class MessageDto implements Serializable {
     private static final long serialVersionUID = 1L;
     /**
@@ -55,4 +57,59 @@ public class MessageDto implements Serializable {
     @ApiModelProperty("延时消息(可选),延时等级：1-18，0否，对应时间依次：1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h")
     private Integer delay;
 
+    public String getTopic() {
+        return topic;
+    }
+
+    public void setTopic(String topic) {
+        this.topic = topic;
+    }
+
+    public String getContent() {
+        return content;
+    }
+
+    public void setContent(String content) {
+        this.content = content;
+    }
+
+    public String getTag() {
+        return tag;
+    }
+
+    public void setTag(String tag) {
+        this.tag = tag;
+    }
+
+    public Integer getSort() {
+        return sort;
+    }
+
+    public void setSort(Integer sort) {
+        this.sort = sort;
+    }
+
+    public Integer getAsync() {
+        return async;
+    }
+
+    public void setAsync(Integer async) {
+        this.async = async;
+    }
+
+    public Integer getOneway() {
+        return oneway;
+    }
+
+    public void setOneway(Integer oneway) {
+        this.oneway = oneway;
+    }
+
+    public Integer getDelay() {
+        return delay;
+    }
+
+    public void setDelay(Integer delay) {
+        this.delay = delay;
+    }
 }

src/main/java/com/caimei365/tools/model/dto/message/EmailMessage.java

@@ -0,0 +1,74 @@
+package com.caimei365.tools.model.dto.message;
+
+
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import lombok.ToString;
+import lombok.experimental.Accessors;
+
+import javax.validation.constraints.Email;
+import javax.validation.constraints.NotNull;
+
+@Data
+@Accessors(fluent = true)
+@NoArgsConstructor
+@ToString
+public class EmailMessage {
+    /**
+     * 邮件主题
+     */
+    @NotNull
+    private String subject;
+    /**
+     * 收件人地址
+     */
+    @NotNull
+    @Email
+    private String receiverAddress;
+    /**
+     * 内容
+     */
+    @NotNull
+    private String emailMessageContent;
+    /**
+     * 抄送地址
+     */
+    private String[] cc;
+
+    public EmailMessage cc(String cc) {
+        this.cc = new String[]{cc};
+        return this;
+    }
+
+    public String getSubject() {
+        return subject;
+    }
+
+    public void setSubject(String subject) {
+        this.subject = subject;
+    }
+
+    public String getReceiverAddress() {
+        return receiverAddress;
+    }
+
+    public void setReceiverAddress(String receiverAddress) {
+        this.receiverAddress = receiverAddress;
+    }
+
+    public String getEmailMessageContent() {
+        return emailMessageContent;
+    }
+
+    public void setEmailMessageContent(String emailMessageContent) {
+        this.emailMessageContent = emailMessageContent;
+    }
+
+    public String[] getCc() {
+        return cc;
+    }
+
+    public void setCc(String[] cc) {
+        this.cc = cc;
+    }
+}

src/main/java/com/caimei365/tools/model/dto/message/InsideMessage.java

@@ -0,0 +1,306 @@
+package com.caimei365.tools.model.dto.message;
+
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+
+/**
+ * @author Administrator
+ * 站内信model
+ */
+@Data
+@Accessors(fluent = true)
+public class InsideMessage implements Serializable {
+
+    /**
+     * 消息id
+     */
+    private Integer id;
+    /**
+     * 供应商id
+     */
+    private Integer shopId;
+    /**
+     * 机构id
+     */
+    private Integer clubId;
+    /**
+     * 订单ID
+     */
+    private Integer orderId;
+    /**
+     * 用户类型1.机构2.供应商
+     */
+    private Integer userType;
+    /**
+     * 消息类型1.交易物流2.账户通知3.服务通知4.优惠促销
+     */
+    private Integer messageType;
+    /**
+     * 消息内容
+     */
+    private String content;
+    /**
+     * 操作完成时间
+     */
+    private String time;
+    /**
+     * 账户通知类型 1.注册成功通知 2.购买超级会员成功 3.超级会员到期提醒 4.超级会员到期提醒 5.升级资质机构成功 6.升级资质机构失败 7.成为机构运营人员通知
+     */
+    private Integer accountType;
+    /**
+     * 优惠券类型 1.优惠券待领取通知 2.优惠券过期通知
+     */
+    private Integer couponType;
+    /**
+     * 优惠券金额
+     */
+    private Double couponFee;
+    /**
+     * 主图
+     */
+    private String mainImage;
+    /**
+     * 是否能走线上支付 0可以 1不可以 只能线下
+     */
+    private Integer onlinePayFlag;
+    /**
+     * 商品名称
+     */
+    private String productName;
+    /**
+     * 供应商消息类型 1,账号审核通知,2.成为公司运营人员通知,3.商品上架审核通知,4.新品展示审核通知,5.上架费到期通知 6.商品资质到期通知
+     */
+    private Integer shopMessType;
+    /**
+     * 供应商服务消息类型 1.上架费
+     */
+    private Integer shopTieredType;
+    /**
+     * 交易物流1.下单成功通知  2.订单支付完成 3.退款/货成功通知 4.订单取消通知 5.订单发货通知 6.自动收货通知
+     */
+    private Integer orderMessageType;
+    /**
+     * 0.未读 , 1.已读
+     */
+    private Integer saved;
+    /**
+     * 优惠券类型 1.优惠券待领取通知 2.优惠券过期通知
+     */
+    private Integer couponMessageType;
+    /**
+     * 商品记录数
+     */
+    private Integer productCount;
+    /**
+     * 退货退款类型：1部分退、2全部退
+     */
+    private Integer refundType;
+
+    /**
+     * 订单状态
+     */
+    private Integer status;
+    /**
+     * 商品ID
+     */
+    private Integer productId;
+
+    /**
+     * 供应商公司名称
+     */
+    private String shopName;
+
+    public Integer getId() {
+        return id;
+    }
+
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    public Integer getShopId() {
+        return shopId;
+    }
+
+    public void setShopId(Integer shopId) {
+        this.shopId = shopId;
+    }
+
+    public Integer getClubId() {
+        return clubId;
+    }
+
+    public void setClubId(Integer clubId) {
+        this.clubId = clubId;
+    }
+
+    public Integer getOrderId() {
+        return orderId;
+    }
+
+    public void setOrderId(Integer orderId) {
+        this.orderId = orderId;
+    }
+
+    public Integer getUserType() {
+        return userType;
+    }
+
+    public void setUserType(Integer userType) {
+        this.userType = userType;
+    }
+
+    public Integer getMessageType() {
+        return messageType;
+    }
+
+    public void setMessageType(Integer messageType) {
+        this.messageType = messageType;
+    }
+
+    public String getContent() {
+        return content;
+    }
+
+    public void setContent(String content) {
+        this.content = content;
+    }
+
+    public String getTime() {
+        return time;
+    }
+
+    public void setTime(String time) {
+        this.time = time;
+    }
+
+    public Integer getAccountType() {
+        return accountType;
+    }
+
+    public void setAccountType(Integer accountType) {
+        this.accountType = accountType;
+    }
+
+    public Integer getCouponType() {
+        return couponType;
+    }
+
+    public void setCouponType(Integer couponType) {
+        this.couponType = couponType;
+    }
+
+    public Double getCouponFee() {
+        return couponFee;
+    }
+
+    public void setCouponFee(Double couponFee) {
+        this.couponFee = couponFee;
+    }
+
+    public String getMainImage() {
+        return mainImage;
+    }
+
+    public void setMainImage(String mainImage) {
+        this.mainImage = mainImage;
+    }
+
+    public Integer getOnlinePayFlag() {
+        return onlinePayFlag;
+    }
+
+    public void setOnlinePayFlag(Integer onlinePayFlag) {
+        this.onlinePayFlag = onlinePayFlag;
+    }
+
+    public String getProductName() {
+        return productName;
+    }
+
+    public void setProductName(String productName) {
+        this.productName = productName;
+    }
+
+    public Integer getShopMessType() {
+        return shopMessType;
+    }
+
+    public void setShopMessType(Integer shopMessType) {
+        this.shopMessType = shopMessType;
+    }
+
+    public Integer getShopTieredType() {
+        return shopTieredType;
+    }
+
+    public void setShopTieredType(Integer shopTieredType) {
+        this.shopTieredType = shopTieredType;
+    }
+
+    public Integer getOrderMessageType() {
+        return orderMessageType;
+    }
+
+    public void setOrderMessageType(Integer orderMessageType) {
+        this.orderMessageType = orderMessageType;
+    }
+
+    public Integer getSaved() {
+        return saved;
+    }
+
+    public void setSaved(Integer saved) {
+        this.saved = saved;
+    }
+
+    public Integer getCouponMessageType() {
+        return couponMessageType;
+    }
+
+    public void setCouponMessageType(Integer couponMessageType) {
+        this.couponMessageType = couponMessageType;
+    }
+
+    public Integer getProductCount() {
+        return productCount;
+    }
+
+    public void setProductCount(Integer productCount) {
+        this.productCount = productCount;
+    }
+
+    public Integer getRefundType() {
+        return refundType;
+    }
+
+    public void setRefundType(Integer refundType) {
+        this.refundType = refundType;
+    }
+
+    public Integer getStatus() {
+        return status;
+    }
+
+    public void setStatus(Integer status) {
+        this.status = status;
+    }
+
+    public Integer getProductId() {
+        return productId;
+    }
+
+    public void setProductId(Integer productId) {
+        this.productId = productId;
+    }
+
+    public String getShopName() {
+        return shopName;
+    }
+
+    public void setShopName(String shopName) {
+        this.shopName = shopName;
+    }
+}

src/main/java/com/caimei365/tools/model/dto/message/MessageModel.java

@@ -0,0 +1,44 @@
+package com.caimei365.tools.model.dto.message;
+
+import com.caimei365.tools.model.dto.message.enums.MessageType;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import lombok.experimental.Accessors;
+
+/**
+ * @author Administrator
+ */
+@Data
+@Accessors(fluent = true)
+@NoArgsConstructor
+public class MessageModel<T> {
+    private MessageType code;
+
+    private MqInfo mqInfo;
+
+    private T info;
+
+    public MessageType getCode() {
+        return code;
+    }
+
+    public void setCode(MessageType code) {
+        this.code = code;
+    }
+
+    public MqInfo getMqInfo() {
+        return mqInfo;
+    }
+
+    public void setMqInfo(MqInfo mqInfo) {
+        this.mqInfo = mqInfo;
+    }
+
+    public T getInfo() {
+        return info;
+    }
+
+    public void setInfo(T info) {
+        this.info = info;
+    }
+}

src/main/java/com/caimei365/tools/model/dto/message/MqInfo.java

@@ -0,0 +1,66 @@
+package com.caimei365.tools.model.dto.message;
+
+
+import lombok.Data;
+import lombok.experimental.Accessors;
+import org.hibernate.validator.constraints.Range;
+
+
+
+@Data
+@Accessors(fluent = true)
+public class MqInfo {
+    /**
+     * 异步消息(可选)：1是，0否
+     */
+    @Range(min = 0, max = 1)
+    private Integer async;
+
+    /**
+     * 1-18，0否，对应时间依次：1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h
+     */
+    @Range(min = 0, max = 18)
+    private Integer delay;
+
+    /**
+     * 消息主题
+     */
+    private String topic;
+
+    /**
+     * 消息标签(可选)
+     */
+    private String tag;
+
+    public Integer getAsync() {
+        return async;
+    }
+
+    public void setAsync(Integer async) {
+        this.async = async;
+    }
+
+    public Integer getDelay() {
+        return delay;
+    }
+
+    public void setDelay(Integer delay) {
+        this.delay = delay;
+    }
+
+    public String getTopic() {
+        return topic;
+    }
+
+    public void setTopic(String topic) {
+        this.topic = topic;
+    }
+
+    public String getTag() {
+        return tag;
+    }
+
+    public void setTag(String tag) {
+        this.tag = tag;
+    }
+}

src/main/java/com/caimei365/tools/model/dto/message/SmsMessage.java

@@ -0,0 +1,53 @@
+package com.caimei365.tools.model.dto.message;
+
+
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import lombok.experimental.Accessors;
+
+import javax.validation.constraints.NotNull;
+
+@Data
+@Accessors(fluent = true)
+@NoArgsConstructor
+public class SmsMessage {
+    /**
+     * 短信类型：1通知短信，2验证码短信，3营销短信
+     */
+    @NotNull
+    private Integer type;
+    /**
+     *  手机号   接收的手机号；多个手机号使用英文逗号间隔，一次不要超过1000个；
+     */
+    @NotNull
+    private String mobile ;
+    /**
+     * 短信内容
+     */
+    @NotNull
+    private String smsMessageContent;
+
+    public Integer getType() {
+        return type;
+    }
+
+    public void setType(Integer type) {
+        this.type = type;
+    }
+
+    public String getMobile() {
+        return mobile;
+    }
+
+    public void setMobile(String mobile) {
+        this.mobile = mobile;
+    }
+
+    public String getSmsMessageContent() {
+        return smsMessageContent;
+    }
+
+    public void setSmsMessageContent(String smsMessageContent) {
+        this.smsMessageContent = smsMessageContent;
+    }
+}

src/main/java/com/caimei365/tools/model/dto/message/WechatTemplateMessage.java

@@ -0,0 +1,232 @@
+package com.caimei365.tools.model.dto.message;
+
+import com.alibaba.fastjson.JSONObject;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import lombok.experimental.Accessors;
+
+import javax.validation.constraints.NotNull;
+import java.util.ArrayList;
+import java.util.List;
+
+@Data
+@Accessors(fluent = true)
+@AllArgsConstructor
+@NoArgsConstructor
+public class WechatTemplateMessage {
+    /**
+     *  {
+     *            "touser":"OPENID",
+     *            "template_id":"ngqIpbwh8bUfcSsECmogfXcV14J0tQlEpBO27izEYtY",
+     *            "url":"http://weixin.qq.com/download",
+     *            "miniprogram":{
+     *              "appid":"xiaochengxuappid12345",
+     *              "pagepath":"index?foo=bar"
+     *            },
+     *            "client_msg_id":"MSG_000001",
+     *            "data":{
+     *                    "first": {
+     *                        "value":"恭喜你购买成功！",
+     *                        "color":"#173177"
+     *                    },
+     *                    "keyword1":{
+     *                        "value":"巧克力",
+     *                        "color":"#173177"
+     *                    },
+     *                    "keyword2": {
+     *                        "value":"39.8元",
+     *                        "color":"#173177"
+     *                    },
+     *                    "keyword3": {
+     *                        "value":"2014年9月22日",
+     *                        "color":"#173177"
+     *                    },
+     *                    "remark":{
+     *                        "value":"欢迎再次购买！",
+     *                        "color":"#173177"
+     *                    }
+     *            }
+     *        }
+     */
+
+    /**
+     * 推送内容抬头
+     */
+    @NotNull
+    private JSONObject first;
+    /**
+     * 推送内容
+     */
+    @NotNull
+    private List<JSONObject> keyWords;
+    /**
+     * 推送内容页尾
+     */
+    @NotNull
+    private JSONObject remark;
+    /**
+     * 所需跳转到的小程序appid（该小程序 appid 必须与发模板消息的公众号是绑定关联关系，暂不支持小游戏）
+     */
+    private String appid;
+
+    /**
+     * 接收者openid
+     */
+    @NotNull
+    private String openId;
+    /**
+     * 模板ID
+     */
+    @NotNull
+    private String templateId;
+    /**
+     * 模板跳转链接
+     */
+    private String url;
+    /**
+     * 所需跳转到小程序的具体页面路径，支持带参数,（示例index?foo=bar），要求该小程序已发布，暂不支持小游戏
+     */
+    private String pagePath;
+
+
+    /**
+     * 跳小程序所需数据，不需跳小程序可不用传该数据
+     */
+    private JSONObject miniProgram;
+    /**
+     * 模板数据
+     */
+    private JSONObject data;
+    private JSONObject json;
+
+    public JSONObject getFirst() {
+        return first;
+    }
+
+    public void setFirst(JSONObject first) {
+        this.first = first;
+    }
+
+    public List<JSONObject> getKeyWords() {
+        return keyWords;
+    }
+
+
+    public JSONObject getRemark() {
+        return remark;
+    }
+
+    public void setRemark(JSONObject remark) {
+        this.remark = remark;
+    }
+
+    public String getAppid() {
+        return appid;
+    }
+
+    public void setAppid(String appid) {
+        this.appid = appid;
+    }
+
+    public String getOpenId() {
+        return openId;
+    }
+
+    public void setOpenId(String openId) {
+        this.openId = openId;
+    }
+
+    public String getTemplateId() {
+        return templateId;
+    }
+
+    public void setTemplateId(String templateId) {
+        this.templateId = templateId;
+    }
+
+    public String getUrl() {
+        return url;
+    }
+
+    public void setUrl(String url) {
+        this.url = url;
+    }
+
+    public String getPagePath() {
+        return pagePath;
+    }
+
+    public void setPagePath(String pagePath) {
+        this.pagePath = pagePath;
+    }
+
+    public WechatTemplateMessage first(String title) {
+        JSONObject jsonObject = new JSONObject();
+        jsonObject.put("value", title);
+        this.setFirst(jsonObject);
+        return this;
+    }
+
+    public WechatTemplateMessage keyWords(List<String> words) {
+        List<JSONObject> collect = new ArrayList<>();
+        words.forEach(w -> {
+            JSONObject jsonObject = new JSONObject();
+            jsonObject.put("value", w);
+            collect.add(jsonObject);
+        });
+        this.setKeyWords(collect);
+        return this;
+    }
+
+    public void setKeyWords(List<JSONObject> keyWords) {
+        this.keyWords = keyWords;
+    }
+
+    public WechatTemplateMessage remark(String r) {
+        JSONObject jsonObject = new JSONObject();
+        jsonObject.put("value", r);
+        this.setRemark(jsonObject);
+        return this;
+    }
+
+    public JSONObject getMiniProgram() {
+        return miniProgram;
+    }
+
+    private void setMiniProgram(JSONObject miniProgram) {
+        this.miniProgram = miniProgram;
+    }
+
+    private JSONObject getData() {
+        return data;
+    }
+
+    private void setData(JSONObject data) {
+        this.data = data;
+    }
+
+    public String getJson() {
+        JSONObject json = new JSONObject();
+        json.put("touser", openId);
+        json.put("template_id", templateId);
+        json.put("url", url);
+
+        JSONObject miniProgram = new JSONObject();
+        miniProgram.put("appid", appid);
+        miniProgram.put("pagepath", pagePath);
+        json.put("miniprogram", miniProgram);
+
+        JSONObject data = new JSONObject();
+        data.put("first", first);
+        if (!keyWords.isEmpty()) {
+            for (int i = 0; i < keyWords.size(); i++) {
+                String key = "keyword" + (i + 1);
+                data.put(key, keyWords.get(i));
+            }
+        }
+        data.put("remark", remark);
+        json.put("data", data);
+        return json.toJSONString();
+    }
+}

src/main/java/com/caimei365/tools/model/dto/message/enums/MessageType.java

@@ -0,0 +1,42 @@
+package com.caimei365.tools.model.dto.message.enums;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.ToString;
+
+/**
+ * @author Administrator
+ */
+
+@ToString
+@AllArgsConstructor
+public enum MessageType {
+    /**
+     * 1.微信模板消息
+     * 2.站内消息
+     * 3.邮件
+     * 4.短信
+     */
+    WECHAT_TEMPLATE_MESSAGE(1, "微信模板消息"),
+    WEB_INSIDE_MESSAGE(2, "站内消息"),
+    EMAILS(3, "邮件"),
+    SYS_MESSAGE(4, "短信");
+    private Integer code;
+    private String description;
+
+    public Integer getCode() {
+        return code;
+    }
+
+    public void setCode(Integer code) {
+        this.code = code;
+    }
+
+    public String getDescription() {
+        return description;
+    }
+
+    public void setDescription(String description) {
+        this.description = description;
+    }
+}

src/main/java/com/caimei365/tools/model/dto/message/enums/SmsMessageType.java

@@ -0,0 +1,37 @@
+package com.caimei365.tools.model.dto.message.enums;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.ToString;
+
+@ToString
+@AllArgsConstructor
+public enum SmsMessageType {
+    /**
+     * 1通知短信
+     * 2验证码短信
+     * 3营销短信
+     */
+    NOTIFICATION_SMS(1, "通知短信"),
+    CHECK_CODE_SMS(2, "验证码短信"),
+    SALES_SMS(3, "营销短信");
+
+    private Integer code;
+    private String description;
+
+    public Integer getCode() {
+        return code;
+    }
+
+    public void setCode(Integer code) {
+        this.code = code;
+    }
+
+    public String getDescription() {
+        return description;
+    }
+
+    public void setDescription(String description) {
+        this.description = description;
+    }
+}

src/main/java/com/caimei365/tools/model/po/ShopReceiptVo.java

@@ -0,0 +1,21 @@
+package com.caimei365.tools.model.po;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+@Data
+public class ShopReceiptVo implements Serializable {
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 生效时间
+     */
+    private String validityDate;
+    /**
+     * 到期时间
+     */
+    private String dateStrings;
+    private Integer shopId;
+    private Double receiptAmount;
+}

src/main/java/com/caimei365/tools/service/MessageSender.java

@@ -0,0 +1,8 @@
+package com.caimei365.tools.service;
+
+
+import com.caimei365.tools.model.dto.message.MessageModel;
+
+public interface MessageSender {
+    void messageSend(MessageModel model);
+}

src/main/java/com/caimei365/tools/service/impl/MessageSenderImpl.java

@@ -0,0 +1,100 @@
+package com.caimei365.tools.service.impl;
+
+
+import com.alibaba.fastjson.JSONObject;
+import com.caimei365.tools.model.dto.MessageDto;
+import com.caimei365.tools.model.dto.message.*;
+import com.caimei365.tools.model.dto.message.enums.MessageType;
+import com.caimei365.tools.service.MessageSender;
+import com.caimei365.tools.service.RocketMqService;
+import com.caimei365.tools.utils.EmailUtil;
+import com.caimei365.tools.utils.InsideMessageUtil;
+import com.caimei365.tools.utils.SmsUtil;
+import com.caimei365.tools.utils.WeChatUtil;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+
+@Service
+@Slf4j
+public class MessageSenderImpl implements MessageSender {
+    @Resource
+    private EmailUtil emailSender;
+    @Resource
+    private WeChatUtil weChatSender;
+    @Resource
+    private InsideMessageUtil messageUtil;
+    @Resource
+    private RocketMqService mqService;
+
+    @Override
+    public void messageSend(MessageModel model) {
+        MessageType code = model.code();
+        switch (code) {
+            case SYS_MESSAGE:
+                sendSMS(model);
+                break;
+            case EMAILS:
+                sendEmail(model);
+                break;
+            case WEB_INSIDE_MESSAGE:
+                sendInside(model);
+                break;
+            case WECHAT_TEMPLATE_MESSAGE:
+                sendWechat(model);
+                break;
+            default:
+                throw new IllegalStateException("Unexpected value: " + code);
+        }
+    }
+
+    public void sendSMS(MessageModel model) {
+        String info = JSONObject.toJSONString(model.info());
+        SmsMessage smsMessage = JSONObject.parseObject(info, SmsMessage.class);
+        if (null != model.mqInfo() && StringUtils.isNotBlank(model.mqInfo().topic())) {
+            mqService.sendCommonMessage(setMessageDto(model));
+        } else {
+            SmsUtil.sendSms(smsMessage.type(), smsMessage.mobile(), smsMessage.smsMessageContent());
+        }
+    }
+
+    public void sendEmail(MessageModel model) {
+        if (null != model.mqInfo() && StringUtils.isNotBlank(model.mqInfo().topic())) {
+            mqService.sendCommonMessage(setMessageDto(model));
+        } else {
+            String info = JSONObject.toJSONString(model.info());
+            EmailMessage emailMessage = JSONObject.parseObject(info, EmailMessage.class);
+            emailSender.sendSimpleMail(emailMessage);
+        }
+    }
+
+    public void sendInside(MessageModel model) {
+        if (null != model.mqInfo() && StringUtils.isNotBlank(model.mqInfo().topic())) {
+            mqService.sendCommonMessage(setMessageDto(model));
+        } else {
+            String info = JSONObject.toJSONString(model.info());
+            InsideMessage insideMessage = JSONObject.parseObject(info, InsideMessage.class);
+            messageUtil.sendInsideMessage(insideMessage);
+        }
+    }
+
+    public void sendWechat(MessageModel model) {
+        if (null != model.mqInfo() && StringUtils.isNotBlank(model.mqInfo().topic())) {
+            mqService.sendCommonMessage(setMessageDto(model));
+        } else {
+            String info = JSONObject.toJSONString(model.info());
+            WechatTemplateMessage wechatTemplateMessage = JSONObject.parseObject(info, WechatTemplateMessage.class);
+            weChatSender.sendMessage(wechatTemplateMessage);
+        }
+    }
+
+    private MessageDto setMessageDto(MessageModel model) {
+        MessageDto messageDto = new MessageDto();
+        MqInfo mqInfo = model.mqInfo();
+        messageDto = messageDto.async(mqInfo.async()).tag(mqInfo.tag()).topic(mqInfo.topic()).
+                delay(mqInfo.delay()).content(JSONObject.toJSONString(model));
+        return messageDto;
+    }
+}

src/main/java/com/caimei365/tools/service/impl/RocketMqServiceImpl.java

@@ -46,21 +46,21 @@ public class RocketMqServiceImpl implements RocketMqService {
      */
     @Override
     public SendResult sendCommonMessage(MessageDto messageDto) {
-        String destination = messageDto.getTopic();
-        if (StringUtils.isNotEmpty(messageDto.getTag())) {
-            destination += ":" + messageDto.getTag();
+        String destination = messageDto.topic();
+        if (StringUtils.isNotEmpty(messageDto.tag())) {
+            destination += ":" + messageDto.tag();
         }
-        Message<String> message = MessageBuilder.withPayload(messageDto.getContent()).build();
+        Message<String> message = MessageBuilder.withPayload(messageDto.content()).build();
         SendResult returnResult = null;
-        boolean isAsync = (messageDto.getAsync() != null && messageDto.getAsync() == 1);
-        boolean isSort = (messageDto.getSort() != null && messageDto.getSort() == 1);
-        boolean isOneway = (messageDto.getOneway() != null && messageDto.getOneway() == 1);
-        boolean isDelay = (messageDto.getDelay() != null && messageDto.getDelay() > 0);
+        boolean isAsync = (messageDto.async() != null && messageDto.async() == 1);
+        boolean isSort = (messageDto.sort() != null && messageDto.sort() == 1);
+        boolean isOneway = (messageDto.oneway() != null && messageDto.oneway() == 1);
+        boolean isDelay = (messageDto.delay() != null && messageDto.delay() > 0);
         if (!isAsync) {
             // 同步消息
             if (isDelay) {
                 // 延时
-                returnResult = rocketMQTemplate.syncSend(destination, message, timeout, messageDto.getDelay());
+                returnResult = rocketMQTemplate.syncSend(destination, message, timeout, messageDto.delay());
             } else {
                 if (isSort && isOneway) {
                     // 单向有序
@@ -91,7 +91,7 @@ public class RocketMqServiceImpl implements RocketMqService {
                         //可以处理相应的业务
                         log.info("异步消息发送失败:{}", JSON.toJSONString(throwable));
                     }
-                }, timeout, messageDto.getDelay());
+                }, timeout, messageDto.delay());
             } else {
                 if (isSort) {
                     // 异步有序

src/main/java/com/caimei365/tools/task/ShopMessTask.java

@@ -3,11 +3,14 @@ package com.caimei365.tools.task;
 import com.alibaba.fastjson.JSONObject;
 import com.caimei365.tools.mapper.MessageCenterMapper;
 import com.caimei365.tools.mapper.OrderClubMapper;
-import com.caimei365.tools.model.po.CmCouponPo;
-import com.caimei365.tools.model.po.CmUserPo;
-import com.caimei365.tools.model.po.MessageCenterPo;
-import com.caimei365.tools.model.po.OrderVo;
+import com.caimei365.tools.model.dto.message.InsideMessage;
+import com.caimei365.tools.model.dto.message.MessageModel;
+import com.caimei365.tools.model.dto.message.WechatTemplateMessage;
+import com.caimei365.tools.model.dto.message.enums.MessageType;
+import com.caimei365.tools.model.po.*;
+import com.caimei365.tools.service.MessageSender;
 import com.caimei365.tools.service.WeChatService;
+import com.caimei365.tools.utils.InsideMessageUtil;
 import com.caimei365.tools.utils.SmsUtil;
 import lombok.RequiredArgsConstructor;
 import lombok.SneakyThrows;
@@ -22,9 +25,11 @@ import redis.clients.jedis.Jedis;
 import javax.annotation.Resource;
 import java.text.ParseException;
 import java.text.SimpleDateFormat;
+import java.util.ArrayList;
 import java.util.Calendar;
 import java.util.Date;
 import java.util.List;
+import java.util.concurrent.Executor;
 import java.util.concurrent.Executors;
 import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.TimeUnit;
@@ -46,181 +51,55 @@ public class ShopMessTask {
 
     @Resource
     private OrderClubMapper orderClubMapper;
+
     @Resource
     private WeChatService weChatService;
 
-//    @SneakyThrows
-//    public static void main(String[] args) {
-//        Calendar calendar = Calendar.getInstance();
-//
-//        Date d = new Date();
-//        Date time=new Date();
-//        //1.日期格式
-//        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH");
-//        String receiptDate="2022-08-02 19:07:46";
-////        if(!receiptDate.contains(":")){
-////            receiptDate+=" 00:00:01";
-////        }
-//
-//           Date s= sdf.parse(receiptDate);
-//
-//        calendar.setTime(time);
-//        calendar.add(Calendar.HOUR, -1);
-//       String hTime= sdf.format(calendar.getTime());
-//      Integer i=  hTime.compareTo(sdf.format(s));
-//      System.out.println(i);
-//        System.out.println(hTime);
-//        System.out.println(s);
-////if(i==0){
-////
-////}
-////        time = sdf.parse(receiptDate);
-////
-////        calendar.setTime(time);
-//////        calendar.add(Calendar.YEAR, 1);
-////        String dateStrings = sdf.format(calendar.getTime());
-////        //2.到期时间
-////
-////                Date da1 =    da1 = sdf.parse(dateStrings);
-////        //到期时间-当前时间=还剩多少天
-////        Long s = (da1.getTime() - d.getTime()) / 24 / 60 / 60 / 1000;
-////        System.out.println(da1);
-////        System.out.println(d);
-////        System.out.println(s);
-//    }
+    @Resource
+    private MessageSender messageSender;
 
     @Scheduled(cron = "0 0 15 * * ?")
-//    @Scheduled(cron = "0 0/15 * * * ?")
     public void Timesjf() {
         log.info("上架费过期推送开始");
-        //1.获取下午3点的时间
-        List<Integer> shopIDs = messageCenterMapper.receiptShopID();
-        shopIDs.forEach(shopID -> {
-            if (shopID != null) {
-                String receiptDate = messageCenterMapper.receiptDate(shopID);
-                Double receiptAmount = messageCenterMapper.receiptAmount(shopID);
-                Calendar calendar = Calendar.getInstance();
-
-                String firsts = "";
-
-                Date d = new Date();
-                Date time = new Date();
-                //1.日期格式
-                SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
-                if (!receiptDate.contains(":")) {
-                    receiptDate += " 00:00:01";
-                }
-                try {
-                    time = sdf.parse(receiptDate);
-                } catch (ParseException e) {
-                    e.printStackTrace();
-                }
-                calendar.setTime(time);
-                calendar.add(Calendar.YEAR, 1);
-                String dateStrings = sdf.format(calendar.getTime());
-                //2.到期时间
-                Date da1 = new Date();
-                try {
-                    da1 = sdf.parse(dateStrings);
-                } catch (ParseException e) {
-                    e.printStackTrace();
-                }
-                //到期时间-当前时间=还剩多少天
-                Long s = (da1.getTime() - d.getTime()) / 24 / 60 / 60 / 1000;
-                //3.输出间隔天数         getTime获取的是毫秒
-                SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
-                String current = dateFormat.format(new Date());
-                MessageCenterPo messageCenter = new MessageCenterPo();
-                //推送信息中心-上架费服务通知
-                if (s <= 0) {
-                    messageCenter.setShopId(shopID);
-                    messageCenter.setClubId(null);
-                    messageCenter.setUserType(2);
-                    messageCenter.setMessageType(3);
-                    messageCenter.setShopTieredType(1);
-                    messageCenter.setContent("已过期");
-                    messageCenter.setTime(current);
-                    messageCenterMapper.addMessageCenter(messageCenter);
-                } else if (s == 1) {
-                    messageCenter.setShopId(shopID);
-                    messageCenter.setClubId(null);
-                    messageCenter.setUserType(2);
-                    messageCenter.setMessageType(3);
-                    messageCenter.setShopTieredType(1);
-                    messageCenter.setContent("今日后到期");
-                    messageCenter.setTime(current);
-                    messageCenterMapper.addMessageCenter(messageCenter);
-                    String mobile = messageCenterMapper.contractMobiles(shopID);
-                    String content = "您的供应商账号上架费将于今日后到期，到期后将无法发布和编辑商品，同时也会影响到其他采美提供的支持服务。请联系采美工作人员进行续费，联系电话0755-22907771 或15338851365。退订回T";
-                    String result = SmsUtil.sendSms(3, mobile, content);
-                    JSONObject json = (JSONObject) JSONObject.parse(result);
-                    log.info("发送结果：" + result + "，短信内容：" + content);
-                    if (null != json && json.getInteger("code") == 0) {
-                        log.info(mobile + "发送成功");
-                    } else {
-                        log.error(mobile + "发送失败");
-                    }
-                    firsts = "尊敬的采美供应商用户，您的账号维护费用今天后即将到期！";
-                } else if (s == 7) {
-                    messageCenter.setShopId(shopID);
-                    messageCenter.setClubId(null);
-                    messageCenter.setUserType(2);
-                    messageCenter.setMessageType(3);
-                    messageCenter.setShopTieredType(1);
-                    messageCenter.setContent("7日后到期");
-                    messageCenter.setTime(current);
-                    messageCenterMapper.addMessageCenter(messageCenter);
-                    String mobile = messageCenterMapper.contractMobiles(shopID);
-                    String content = "您的供应商账号上架费将于7日后到期，到期后将无法发布和编辑商品，同时也会影响到其他采美提供的支持服务。请联系采美工作人员进行续费，联系电话0755-22907771 或15338851365。退订回T";
-                    String result = SmsUtil.sendSms(3, mobile, content);
-                    JSONObject json = (JSONObject) JSONObject.parse(result);
-                    log.info("发送结果：" + result + "，短信内容：" + content);
-                    if (null != json && json.getInteger("code") == 0) {
-                        log.info(mobile + "发送成功");
-                    } else {
-                        log.error(mobile + "发送失败");
-                    }
-                    firsts = "尊敬的采美供应商用户，您的账号维护费用7天后即将到期！";
-                } else if (s == 30) {
-                    messageCenter.setShopId(shopID);
-                    messageCenter.setClubId(null);
-                    messageCenter.setUserType(2);
-                    messageCenter.setMessageType(3);
-                    messageCenter.setShopTieredType(1);
-                    messageCenter.setContent("30日后到期");
-                    messageCenter.setTime(current);
-                    messageCenterMapper.addMessageCenter(messageCenter);
-                    String mobile = messageCenterMapper.contractMobiles(shopID);
-                    String content = "您的供应商账号上架费将于30日后到期，到期后将无法发布和编辑商品，同时也会影响到其他采美提供的支持服务。请联系采美工作人员进行续费，联系电话0755-22907771 或15338851365。退订回T";
-                    String result = SmsUtil.sendSms(3, mobile, content);
-                    JSONObject json = (JSONObject) JSONObject.parse(result);
-                    log.info("发送结果：" + result + "，短信内容：" + content);
-                    if (null != json && json.getInteger("code") == 0) {
-                        log.info(mobile + "发送成功");
-                    } else {
-                        log.error(mobile + "发送失败");
-                    }
-                    firsts = "尊敬的采美供应商用户，您的账号维护费用30天后即将到期！";
-                }
-                try {
-                    Integer userId = messageCenterMapper.userIds(shopID);
-                    String accessToken = weChatService.getAccessToken();
-                    String openid = messageCenterMapper.getOpenidListByPermission(messageCenterMapper.FromUnionId(userId));
-                    // 跳转到【小程序付款-选择支付方式页面】
-                    String pagePath = "https://www.caimei365.com/";
-                    // sendTemplateMsg(openid, 标题, 金额, 收款日期, 备注, 跳转链接
-                    weChatService.messtemes(accessToken, openid, firsts, receiptDate, sdf.format(da1), receiptAmount, pagePath);
-                } catch (Exception e) {
-
-                }
-            }
-            log.info("上架费过期推送结束");
+        List<ShopReceiptVo> shopIds=messageCenterMapper.findExpireShopId(1);
+
+        String  firsts = "尊敬的采美供应商用户，您的账号维护费用今天后即将到期！";
+        firsts = "尊敬的采美供应商用户，您的账号维护费用7天后即将到期！";
+        firsts = "尊敬的采美供应商用户，您的账号维护费用30天后即将到期！";
+        String content="30日后到期";
+        content="7日后到期";
+        shopIds.forEach(s->{
+            //站内信
+            MessageModel<InsideMessage> insideMessageMessageModel = new MessageModel<>();
+            insideMessageMessageModel.code(MessageType.WEB_INSIDE_MESSAGE).info(new InsideMessage().shopId(s).userType(2)
+                    .messageType(3).shopTieredType(1).content("今日后到期"));
+            messageSender.messageSend(insideMessageMessageModel);
+            //短信
+            String mobile = messageCenterMapper.contractMobiles(s.getShopId());
+            content = "您的供应商账号上架费将于今日后到期，到期后将无法发布和编辑商品，同时也会影响到其他采美提供的支持服务。请联系采美工作人员进行续费，联系电话0755-22907771 或15338851365。退订回T";
+            String result = SmsUtil.sendSms(3, mobile, content);
+            log.info("发送结果：" + result + "，短信内容：" + content);
+            //微信模板消息
+            MessageModel<WechatTemplateMessage> wechatTemplateMessageMessageModel = new MessageModel<>();
+            String pagePath = "https://www.caimei365.com/";
+            //todo 傻逼写法，拿不到值，有空再改
+            String openid = messageCenterMapper.getOpenidListByPermission(s.getShopId());
+            ArrayList<String> strings = new ArrayList<>();
+            strings.add("维护费");
+            strings.add("年付");
+            strings.add(s.getValidityDate());
+            strings.add(s.getDateStrings());
+            strings.add(s.getReceiptAmount().toString());
+            WechatTemplateMessage weChat = new WechatTemplateMessage().first(firsts).openId(openid).pagePath(pagePath)
+                    .templateId("jYUIq63wP6mGFvkgNHgTOXAgF7j6h_VZKgST_-2fqCo").remark("为了更好给您服务，请及时联系采美客服缴费!").appid("wx91c4152b60ca91a3").url(pagePath);
+            MessageModel<WechatTemplateMessage> weChatMessage = wechatTemplateMessageMessageModel.code(MessageType.WECHAT_TEMPLATE_MESSAGE).info(weChat);
+            messageSender.messageSend(weChatMessage);
         });
+
     }
 
 
     @Scheduled(cron = "0 0 10 15 * ?")
-//@Scheduled(cron = "0 0/10 * * * ?")
     public void gwc() {
         log.info("------------开始推送购物车相关短信------------------------>");
         List<Integer> userId = orderClubMapper.userIds();

src/main/java/com/caimei365/tools/utils/EmailUtil.java

@@ -0,0 +1,40 @@
+package com.caimei365.tools.utils;
+
+
+import com.caimei365.tools.model.dto.message.EmailMessage;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.mail.SimpleMailMessage;
+import org.springframework.mail.javamail.JavaMailSender;
+import org.springframework.stereotype.Component;
+
+
+@Component
+@Slf4j
+public class EmailUtil {
+    @Autowired
+    private JavaMailSender mailSender;
+
+    @Value("${spring.mail.username}")
+    private String from;
+
+    /**
+     * 发送文本邮件
+     *
+     * @param receiverAddress 收件人地址
+     * @param subject         邮件主题
+     * @param content         邮件内容
+     * @param cc              抄送地址
+     */
+    public void sendSimpleMail(EmailMessage emailMessage) {
+        SimpleMailMessage message = new SimpleMailMessage();
+        message.setFrom(from);
+        message.setTo(emailMessage.receiverAddress());
+        message.setSubject(emailMessage.subject());
+        message.setText(emailMessage.emailMessageContent());
+        message.setCc(emailMessage.cc());
+        log.info("邮件发送参数---------------------->" + message);
+        mailSender.send(message);
+    }
+}

src/main/java/com/caimei365/tools/utils/InsideMessageUtil.java

@@ -0,0 +1,20 @@
+package com.caimei365.tools.utils;
+
+import com.caimei365.tools.mapper.MessageCenterMapper;
+import com.caimei365.tools.model.dto.message.InsideMessage;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+
+@Slf4j
+@Component
+public class InsideMessageUtil {
+    @Resource
+    private MessageCenterMapper messageCenterMapper;
+
+    public void sendInsideMessage(InsideMessage insideMessage){
+        log.info("站内消息收到参数------------------->"+insideMessage.toString());
+        messageCenterMapper.sendInsideMessage(insideMessage);
+    }
+}

src/main/java/com/caimei365/tools/utils/WeChatUtil.java

@@ -0,0 +1,39 @@
+package com.caimei365.tools.utils;
+
+import com.alibaba.fastjson.JSONObject;
+
+import com.caimei365.tools.model.dto.message.WechatTemplateMessage;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+
+import java.util.Map;
+
+@Component
+@Slf4j
+public class WeChatUtil {
+    public void sendMessage(WechatTemplateMessage wechatTemplateMessage){
+        try {
+            String requestUrl = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=" + getAccessToken();
+            // 发送请求
+            String json = wechatTemplateMessage.getJson();
+            log.info("微信发消息的-------------------------->"+json);
+            String result = RequestUtil.httpRequest(requestUrl, "POST", json);
+            log.info(">>>>>>>>微信模板消息推送结果：" + result);
+        } catch (Exception e) {
+            log.error("推送微信模板消息失败：" + e);
+        }
+    }
+
+    public String getAccessToken() throws Exception {
+        String link = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=APPID&secret=APPSECRET";
+        link = link.replace("APPID", "wx91c4152b60ca91a3");
+        link = link.replace("APPSECRET", "a563dd2c07c9c815a4e697c8b6cb73dc");
+        String result = RequestUtil.sendGet(link);
+        log.info("微信公众号获取access_token>>>" + result);
+        Map<String, Object> map = JSONObject.parseObject(result, Map.class);
+        String access_token = (String) map.get("access_token");
+        return access_token;
+    }
+
+}

src/main/resources/bootstrap.yml

@@ -18,3 +18,15 @@ spring:
     multipart:
       max-file-size: 20MB
       max-request-size: 100MB
+  #邮件设置
+  mail:
+    host: smtp.qq.com
+    username: 525282777@qq.com
+    password: uvgkjjlusyczcagg #*****  //授权码
+    default-encoding: UTF-8
+    properties:
+      mail.smtp.auth: true
+      mail.smtp.starttls.enable: true
+      mail.smtp.starttls.required: true
+      mail.smtp.ssl.enable: true
+      mail.display.sendmail: spring-boot-demo

src/main/resources/mapper/MessageCenter.xml

@@ -2,43 +2,40 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.caimei365.tools.mapper.MessageCenterMapper">
     <insert id="addMessageCenter">
-        INSERT INTO message_center (shopID, clubID, userType, messageType, content,time,accountType,couponType,couponFee,couponMessageType,ShopMessType,ShopTieredType)
-        VALUES (#{shopId}, #{clubId}, #{userType}, #{messageType}, #{content},#{time},#{accountType},#{couponType},#{couponFee},#{couponMessageType},#{shopMessType},#{shopTieredType})
+        INSERT INTO message_center (shopID, clubID, userType, messageType, content, time, accountType, couponType,
+                                    couponFee, couponMessageType, ShopMessType, ShopTieredType)
+        VALUES (#{shopId}, #{clubId}, #{userType}, #{messageType}, #{content}, #{time}, #{accountType}, #{couponType},
+                #{couponFee}, #{couponMessageType}, #{shopMessType}, #{shopTieredType})
+    </insert>
+    <insert id="sendInsideMessage">
+        INSERT INTO message_center (shopID, clubID, orderID, userType, messageType, accountType, orderMessageType,
+                                    couponMessageType, couponFee, content, time, saved, shopMessType,
+                                    shopTieredType, couponType, productID)
+        VALUES (#{shopId}, #{clubId}, #{orderId}, #{userType}, #{messageType}, #{accountType}, #{orderMessageType},
+                #{couponMessageType}, #{couponFee}, #{content}, now(), 0, #{shopMessType},
+                #{shopTieredType}, #{couponType}, #{productId})
     </insert>
 
     <select id="clubIdCule" resultType="java.lang.Integer">
-        SELECT clubID FROM `user` WHERE userId=#{userId}
+        SELECT clubID
+        FROM `user`
+        WHERE userId = #{userId}
     </select>
 
     <select id="shopID" resultType="java.lang.Integer">
-        SELECT shopID FROM `shop` WHERE userId=#{userId}
+        SELECT shopID
+        FROM `shop`
+        WHERE userId = #{userId}
     </select>
 
-<!--    <select id="shopID" resultType="java.lang.Integer">-->
-<!--        SELECT shopID FROM `shop` WHERE userId=#{userId}-->
-<!--    </select>-->
-
-<!--    <select id="clubList" resultType="com.caimei365.user.model.vo.UserVo">-->
-<!--        SELECT * FROM `user` WHERE userId=#{userId}-->
-<!--    </select>-->
-
-<!--    <select id="CouponList" resultType="com.caimei365.user.model.vo.CouponVo">-->
-<!--        SELECT * FROM cm_coupon WHERE couponType=#{couponType}-->
-<!--         AND NOW() >= startDate-->
-<!--         AND endDate >= NOW()-->
-<!--         AND status=1-->
-<!--         AND delFlag=0-->
-<!--        LIMIT 1-->
-<!--    </select>-->
-
     <select id="MessageCount" resultType="java.lang.Integer">
         SELECT COUNT(1) FROM `message_center`
         <where>
             <if test="userType == 1">
-                and  clubID=#{commonId}
+                and clubID=#{commonId}
             </if>
             <if test="userType == 2">
-                and  shopID=#{commonId}
+                and shopID=#{commonId}
             </if>
             AND messageType=#{messageType}
             and userType=#{userType}
@@ -50,10 +47,10 @@
         SELECT COUNT(1) FROM `message_center`
         <where>
             <if test="userType == 1">
-                and  clubID=#{commonId}
+                and clubID=#{commonId}
             </if>
             <if test="userType == 2">
-                and  shopID=#{commonId}
+                and shopID=#{commonId}
             </if>
             and userType=#{userType}
             AND saved=0
@@ -62,75 +59,88 @@
 
 
     <select id="receStatct" resultType="java.lang.Integer">
-        SELECT COUNT(*) FROM `cm_discern_receipt` WHERE newReceiptType=1 AND shopID=#{shopID} AND receStatct=2
+        SELECT COUNT(*)
+        FROM `cm_discern_receipt`
+        WHERE newReceiptType = 1
+          AND shopID = #{shopID}
+          AND receStatct = 2
     </select>
 
     <select id="listingFee" resultType="java.lang.Integer">
-        SELECT COUNT(*) FROM `cm_discern_receipt` WHERE newReceiptType=1 AND shopID=#{shopID}
+        SELECT COUNT(*)
+        FROM `cm_discern_receipt`
+        WHERE newReceiptType = 1
+          AND shopID = #{shopID}
     </select>
 
     <select id="listingfeeExpire" resultType="java.lang.Integer">
-        SELECT COUNT(*) FROM `cm_discern_receipt` WHERE newReceiptType=1 AND shopID=#{shopID} AND NOW()> DATE_ADD(receiptDate, INTERVAL 1 YEAR)
+        SELECT COUNT(*)
+        FROM `cm_discern_receipt`
+        WHERE newReceiptType = 1
+          AND shopID = #{shopID}
+          AND NOW() > DATE_ADD(receiptDate, INTERVAL 1 YEAR)
     </select>
 
-<!--    <select id="MessageList" resultType="com.caimei365.user.model.vo.MessageCenter">-->
-<!--        SELECT * FROM `message_center`-->
-<!--        <where>-->
-<!--            <if test="messageType !=null">-->
-<!--            AND messageType=#{messageType}-->
-<!--           </if>-->
-<!--            <if test="userType == 1">-->
-<!--                and  clubID=#{commonId}-->
-<!--            </if>-->
-<!--            <if test="userType == 2">-->
-<!--                and  shopID=#{commonId}-->
-<!--            </if>-->
-<!--           and userType=#{userType}-->
-<!--        </where>-->
-<!--        ORDER BY id DESC-->
-<!--    </select>-->
-
     <select id="contractMobile" resultType="java.lang.String">
-        SELECT contractMobile FROM club WHERE clubID=#{clubID}
+        SELECT contractMobile
+        FROM club
+        WHERE clubID = #{clubID}
     </select>
 
     <select id="contractMobiles" resultType="java.lang.String">
-        SELECT contractMobile FROM shop WHERE shopID=#{shopID}
+        SELECT contractMobile
+        FROM shop
+        WHERE shopID = #{shopID}
     </select>
 
     <select id="getOpenidListByPermission" resultType="java.lang.String">
-        SELECT openid FROM `wechat_user` WHERE unionId= #{unionId}
+        SELECT openid
+        FROM wechat_user
+        WHERE unionId = (
+            SELECT unionID
+            FROM cm_order co
+            LEFT JOIN shop s ON co.userId = s.userId
+            WHERE s.shopId = #{shopId}
+              AND unionID IS NOT NULL
+            ORDER BY orderID DESC
+            LIMIT 1)
     </select>
 
     <select id="FromUnionId" resultType="java.lang.String">
-        SELECT unionID FROM `cm_order` WHERE userID=#{userID} AND unionID IS NOT NULL  ORDER BY orderID DESC LIMIT 1
+        SELECT unionID
+        FROM `cm_order`
+        WHERE userID = #{userID}
+          AND unionID IS NOT NULL
+        ORDER BY orderID DESC
+        LIMIT 1
     </select>
 
     <select id="getVipHistoryCount" resultType="java.lang.Integer">
         SELECT count(1)
         FROM cm_svip_history
-        WHERE  userId = #{userId}
+        WHERE userId = #{userId}
     </select>
 
     <select id="MainImage" resultType="com.caimei365.tools.model.po.MessageCenterPo">
-        SELECT co.refundType,COUNT(p.productID)AS productCount ,p.mainImage,co.onlinePayFlag,ifnull(p.name,'') as productName,co.orderID as orderID,co.status as status
+        SELECT co.refundType,COUNT(p.productID)AS productCount ,p.mainImage,co.onlinePayFlag,ifnull(p.name,'') as
+        productName,co.orderID as orderID,co.status as status
         FROM cm_order co
-                 LEFT JOIN bp_order_userinfo bou ON bou.orderId = co.orderID
-                 LEFT JOIN USER u ON u.userID = co.userID
-                 LEFT JOIN club c ON u.userID = c.userID
-                 LEFT JOIN serviceprovider sp ON c.spID = sp.serviceProviderID AND sp.status = 90
-                 LEFT JOIN cm_order_product cop ON co.orderID = cop.orderID
-                 LEFT JOIN product p ON cop.productID = p.productID
-                 LEFT JOIN cm_shop_order cso ON co.orderid=cso.orderID
+        LEFT JOIN bp_order_userinfo bou ON bou.orderId = co.orderID
+        LEFT JOIN USER u ON u.userID = co.userID
+        LEFT JOIN club c ON u.userID = c.userID
+        LEFT JOIN serviceprovider sp ON c.spID = sp.serviceProviderID AND sp.status = 90
+        LEFT JOIN cm_order_product cop ON co.orderID = cop.orderID
+        LEFT JOIN product p ON cop.productID = p.productID
+        LEFT JOIN cm_shop_order cso ON co.orderid=cso.orderID
         <where>
 
             <if test="userType == 1">
-              and  c.clubID=#{commonId}
+                and c.clubID=#{commonId}
             </if>
             <if test="userType == 2">
-              and  p.shopID=#{commonId}
+                and p.shopID=#{commonId}
             </if>
-        and co.orderID=#{orderID}
+            and co.orderID=#{orderID}
         </where>
         LIMIT 1
     </select>
@@ -144,123 +154,132 @@
             <if test="productID != null">
                 and p.productID=#{productID}
             </if>
-                and p.shopID=#{shopID}
+            and p.shopID=#{shopID}
         </where>
         LIMIT 1
     </select>
 
     <select id="productCount" resultType="java.lang.Integer">
-        SELECT COUNT(productID) FROM cm_order_product
-        WHERE orderID=#{orderID}
+        SELECT COUNT(productID)
+        FROM cm_order_product
+        WHERE orderID = #{orderID}
     </select>
 
 
     <select id="receiptDate" resultType="java.lang.String">
-        SELECT
-            c.dateStrings
+        SELECT c.dateStrings
         FROM cm_receipt c
-                 LEFT JOIN cm_discern_receipt a ON c.receiptID = a.id
-                 LEFT JOIN shop s ON s.shopID = a.shopID
-        WHERE
-            a.shopID=10324
-          AND a.newReceiptType=1
+        LEFT JOIN cm_discern_receipt a ON c.receiptID = a.id
+        LEFT JOIN shop s ON s.shopID = a.shopID
+        WHERE a.shopID = 10324
+          AND a.newReceiptType = 1
         ORDER BY a.id DESC
         LIMIT 1
     </select>
 
     <select id="receiptAmount" resultType="java.lang.Double">
-        SELECT
-            a.receiptAmount
+        SELECT a.receiptAmount
         FROM cm_discern_receipt a
-                 LEFT JOIN shop s ON s.shopID = a.shopID
-        where
-            a.shopID=#{shopID}
-          AND a.newReceiptType=1
+        LEFT JOIN shop s ON s.shopID = a.shopID
+        where a.shopID = #{shopID}
+          AND a.newReceiptType = 1
         LIMIT 1
     </select>
 
-<select id="newReceiptType" resultType="java.lang.Integer">
-    SELECT
-        a.newReceiptType
-    FROM cm_discern_receipt a
-             LEFT JOIN shop s ON s.shopID = a.shopID
-    where
-        a.shopID=#{shopID}
-    LIMIT 1
-</select>
+    <select id="newReceiptType" resultType="java.lang.Integer">
+        SELECT a.newReceiptType
+        FROM cm_discern_receipt a
+        LEFT JOIN shop s ON s.shopID = a.shopID
+        where a.shopID = #{shopID}
+        LIMIT 1
+    </select>
     <update id="updateMessageAsRead">
         UPDATE message_center SET saved = 1
         <where>
-      <if test="userType == 1">
-          and  clubID=#{commonId}
-      </if>
-      <if test="userType == 2">
-          and  shopID=#{commonId}
-      </if>
-        <if test="messageType !=null">
-           and messageType = #{messageType}
-        </if>
-          and userType=#{userType}
+            <if test="userType == 1">
+                and clubID=#{commonId}
+            </if>
+            <if test="userType == 2">
+                and shopID=#{commonId}
+            </if>
+            <if test="messageType !=null">
+                and messageType = #{messageType}
+            </if>
+            and userType=#{userType}
         </where>
     </update>
 
     <select id="userId" resultType="java.lang.Integer">
-        SELECT userID FROM `cm_mall_operation_user` WHERE openid=#{openid}  LIMIT 1
+        SELECT userID
+        FROM `cm_mall_operation_user`
+        WHERE openid = #{openid}
+        LIMIT 1
     </select>
 
- <delete id="deleteMessage">
-        DELETE FROM message_center WHERE id = #{id}
+    <delete id="deleteMessage">
+        DELETE
+        FROM message_center
+        WHERE id = #{id}
     </delete>
 
     <update id="updateRead">
-        UPDATE message_center SET saved = 1
-        where userType=#{userType} and id=#{Id}
+        UPDATE message_center
+        SET saved = 1
+        where userType = #{userType}
+          and id = #{Id}
     </update>
 
     <select id="receiptShopID" resultType="java.lang.Integer">
-        SELECT DISTINCT
-            a.shopID
-        FROM cm_discern_receipt a
-                 LEFT JOIN shop s ON s.shopID = a.shopID
-        WHERE
-            a.newReceiptType=1
+        SELECT DISTINCT shopID
+        FROM cm_discern_receipt
+        WHERE newReceiptType = 1
     </select>
 
     <select id="userIds" resultType="java.lang.Integer">
-        SELECT DISTINCT
-            a.userID
+        SELECT DISTINCT a.userID
         FROM shop a
-        WHERE
-            a.shopOD=#{shopID}
+        WHERE a.shopOD = #{shopID}
     </select>
 
     <select id="ClubIds" resultType="java.lang.Integer">
-        SELECT clubID FROM `user` WHERE YEAR(loginTime)>YEAR(NOW())-3 AND clubID IS NOT NULL
+        SELECT clubID
+        FROM `user`
+        WHERE YEAR(loginTime) > YEAR(NOW()) - 3
+          AND clubID IS NOT NULL
 #         ORDER BY clubID DESC
     </select>
 
     <select id="couponTime" resultType="com.caimei365.tools.model.po.CmCouponPo">
-        SELECT * FROM `cm_coupon` WHERE
-            NOW() >= startDate
-             AND endDate >= NOW()
-             AND STATUS = 1
-             AND delFlag=0
+        SELECT *
+        FROM `cm_coupon`
+        WHERE NOW() >= startDate
+          AND endDate >= NOW()
+          AND STATUS = 1
+          AND delFlag = 0
     </select>
 
     <select id="clubList" resultType="com.caimei365.tools.model.po.CmUserPo">
-        SELECT * FROM `user` WHERE clubId=#{clubId}  LIMIT 1
+        SELECT *
+        FROM `user`
+        WHERE clubId = #{clubId}
+        LIMIT 1
     </select>
 
     <select id="clubLists" resultType="com.caimei365.tools.model.po.CmUserPo">
-        SELECT * FROM `user` WHERE userId=#{userId}  LIMIT 1
+        SELECT *
+        FROM `user`
+        WHERE userId = #{userId}
+        LIMIT 1
     </select>
 
     <select id="CouponList" resultType="com.caimei365.tools.model.po.CmCouponPo">
-        SELECT * FROM cm_coupon WHERE couponType=#{couponType}
-        AND NOW() >= startDate
-        AND endDate >= NOW()
-        AND status=1
-        AND delFlag=0
+        SELECT *
+        FROM cm_coupon
+        WHERE couponType = #{couponType}
+          AND NOW() >= startDate
+          AND endDate >= NOW()
+          AND status = 1
+          AND delFlag = 0
         ORDER BY id DESC
         LIMIT 1
     </select>
@@ -272,13 +291,20 @@
     </select>
 
     <select id="CouponLists" resultType="com.caimei365.tools.model.po.CmCouponPo">
-        SELECT * FROM cm_coupon a
+        SELECT *
+        FROM cm_coupon a
         LEFT JOIN cm_coupon_club s ON s.couponId = a.id
-        WHERE  s.userId=#{userID}
+        WHERE s.userId = #{userID}
           AND NOW() >= a.startDate
           AND a.endDate >= NOW()
-          AND a.status=1
-          AND a.delFlag=0
+          AND a.status = 1
+          AND a.delFlag = 0
     </select>
 
+    <select id="findExpireShopId" resultType="com.caimei365.tools.model.po.ShopReceiptVo">
+        SELECT cr.dateStrings,cdr.shopId,cdr.receiptAmount,cr.validityDate
+        FROM cm_receipt cr
+        LEFT JOIN cm_discern_receipt cdr ON cr.receiptId = cdr.id
+        WHERE DATE_FORMAT(cr.dateStrings, '%y-%m-%d') = DATE_FORMAT(DATE_ADD(NOW(), INTERVAL #{day} DAY), '%y-%m-%d')
+    </select>
 </mapper>

src/test/java/com/caimei365/tools/ToolsApplicationTests.java

@@ -1,131 +1,131 @@
-package com.caimei365.tools;
-
-import com.caimei365.tools.utils.SmsUtil;
-import org.junit.jupiter.api.Test;
-import org.springframework.boot.test.context.SpringBootTest;
-import org.yaml.snakeyaml.scanner.ScannerImpl;
-
-import java.util.Calendar;
-import java.util.Date;
-
-@SpringBootTest
-class ToolsApplicationTests {
-
-    @Test
-    void contextLoads() {
-
-    }
-
-//    @Test
-//    void testSms1() {
-//        String s = SmsUtil.sendSms(1, "15814011616", "您好，您的验证码是12345");
-//        System.out.println(s);
-//    }
-//
-//    @Test
-//    void testSms2() {
-//        String s = SmsUtil.sendSms(2, "15814011616", "您好，您的验证码是98765");
-//        System.out.println(s);
-//    }
-//
-//    @Test
-//    void testSms3() {
-//        String s = SmsUtil.sendSms(2, "15814011616", "欢迎成为采美机构用户，您的登录账号为：15814011616，初始密码为：123456，您可使用该账号密码登录采美365网和“采美采购商城”小程序。");
-//        System.out.println(s);
-//    }
-
-    //欢迎成为采美机构用户，您的登录账号为：${name}，初始密码为：cm${content}，您可使用该账号密码登录采美365网和“采美采购商城”小程序。
-    /**
-     * kuaidi100.key = bEZlgVkW1438
-     * kuaidi100.customer = 1414E0E533E3311FBA5E633C10F78306
-     * kuaidi100.secret = e3bb51a0c8bd40c69342c7c88650c035
-     * kuaidi100.userid = 31872248ba914ac289db3ed3244d527c
-     */
-//    private String key = "bEZlgVkW1438";
-//    private String customer = "1414E0E533E3311FBA5E633C10F78306";
-//    /**
-//     * 查询物流轨迹
-//     */
-//    @Test
-//    public void testQueryTrack() throws Exception{
-//
-//        QueryTrackReq queryTrackReq = new QueryTrackReq();
-//        QueryTrackParam queryTrackParam = new QueryTrackParam();
-//        queryTrackParam.setCom(CompanyConstant.SF);
-//        queryTrackParam.setNum("SF1108462182157");
-//        queryTrackParam.setPhone("15828171629");
-//        String param = new Gson().toJson(queryTrackParam);
-//
-//        queryTrackReq.setParam(param);
-//        queryTrackReq.setCustomer(customer);
-//        queryTrackReq.setSign(SignUtils.querySign(param ,key,customer));
+//package com.caimei365.tools;
 //
-//        IBaseClient baseClient = new QueryTrack();
-//        System.out.println(baseClient.execute(queryTrackReq));
-//    }
-//
-//     /**
-//     * 快递信息地图轨迹
-//     */
-//    @Test
-//    public void testQueryMapView() throws Exception{
+//import com.caimei365.tools.utils.SmsUtil;
+//import org.junit.jupiter.api.Test;
+//import org.springframework.boot.test.context.SpringBootTest;
+//import org.yaml.snakeyaml.scanner.ScannerImpl;
 //
-//        QueryTrackReq queryTrackReq = new QueryTrackReq();
-//        QueryTrackParam queryTrackParam = new QueryTrackParam();
-//        queryTrackParam.setCom(CompanyConstant.YD);
-//        queryTrackParam.setNum("4311159956248");
-//        queryTrackParam.setPhone("17725390266");
-//        queryTrackParam.setFrom("河北保定市");
-//        queryTrackParam.setTo("湖南岳阳市");
-//        queryTrackParam.setResultv2("2");
-//        String param = new Gson().toJson(queryTrackParam);
+//import java.util.Calendar;
+//import java.util.Date;
 //
-//        queryTrackReq.setParam(param);
-//        queryTrackReq.setCustomer(customer);
-//        queryTrackReq.setSign(SignUtils.querySign(param ,key,customer));
-//
-//        IBaseClient baseClient = new QueryTrackMap();
-//        HttpResult result = baseClient.execute(queryTrackReq);
-//
-//        QueryTrackMapResp queryTrackMapResp = new Gson().fromJson(result.getBody(),QueryTrackMapResp.class);
-//        System.out.println(queryTrackMapResp);
-//    }
+//@SpringBootTest
+//class ToolsApplicationTests {
 //
-//    /**
-//     * 订阅
-//     */
 //    @Test
-//    public void testSubscribe() throws Exception{
-//        SubscribeParameters subscribeParameters = new SubscribeParameters();
-//        subscribeParameters.setCallbackurl("http://www.baidu.com");
-//        subscribeParameters.setPhone("17725390266");
-//
-//        SubscribeParam subscribeParam = new SubscribeParam();
-//        subscribeParam.setParameters(subscribeParameters);
-//        subscribeParam.setCompany(CompanyConstant.ST);
-//        subscribeParam.setNumber("773039762404825");
-//        subscribeParam.setKey(key);
+//    void contextLoads() {
 //
-//        SubscribeReq subscribeReq = new SubscribeReq();
-//        subscribeReq.setSchema(ApiInfoConstant.SUBSCRIBE_SCHEMA);
-//        subscribeReq.setParam(new Gson().toJson(subscribeParam));
-//
-//        IBaseClient subscribe = new Subscribe();
-//        System.out.println(subscribe.execute(subscribeReq));
 //    }
 //
+////    @Test
+////    void testSms1() {
+////        String s = SmsUtil.sendSms(1, "15814011616", "您好，您的验证码是12345");
+////        System.out.println(s);
+////    }
+////
+////    @Test
+////    void testSms2() {
+////        String s = SmsUtil.sendSms(2, "15814011616", "您好，您的验证码是98765");
+////        System.out.println(s);
+////    }
+////
+////    @Test
+////    void testSms3() {
+////        String s = SmsUtil.sendSms(2, "15814011616", "欢迎成为采美机构用户，您的登录账号为：15814011616，初始密码为：123456，您可使用该账号密码登录采美365网和“采美采购商城”小程序。");
+////        System.out.println(s);
+////    }
+//
+//    //欢迎成为采美机构用户，您的登录账号为：${name}，初始密码为：cm${content}，您可使用该账号密码登录采美365网和“采美采购商城”小程序。
 //    /**
-//     * 智能识别接口（正式用户可以使用）
+//     * kuaidi100.key = bEZlgVkW1438
+//     * kuaidi100.customer = 1414E0E533E3311FBA5E633C10F78306
+//     * kuaidi100.secret = e3bb51a0c8bd40c69342c7c88650c035
+//     * kuaidi100.userid = 31872248ba914ac289db3ed3244d527c
 //     */
-//    @Test
-//    public void testAutoNum() throws Exception{
-//        AutoNumReq autoNumReq = new AutoNumReq();
-//        autoNumReq.setKey(key);
-//        autoNumReq.setNum("17725390266");
+////    private String key = "bEZlgVkW1438";
+////    private String customer = "1414E0E533E3311FBA5E633C10F78306";
+////    /**
+////     * 查询物流轨迹
+////     */
+////    @Test
+////    public void testQueryTrack() throws Exception{
+////
+////        QueryTrackReq queryTrackReq = new QueryTrackReq();
+////        QueryTrackParam queryTrackParam = new QueryTrackParam();
+////        queryTrackParam.setCom(CompanyConstant.SF);
+////        queryTrackParam.setNum("SF1108462182157");
+////        queryTrackParam.setPhone("15828171629");
+////        String param = new Gson().toJson(queryTrackParam);
+////
+////        queryTrackReq.setParam(param);
+////        queryTrackReq.setCustomer(customer);
+////        queryTrackReq.setSign(SignUtils.querySign(param ,key,customer));
+////
+////        IBaseClient baseClient = new QueryTrack();
+////        System.out.println(baseClient.execute(queryTrackReq));
+////    }
+////
+////     /**
+////     * 快递信息地图轨迹
+////     */
+////    @Test
+////    public void testQueryMapView() throws Exception{
+////
+////        QueryTrackReq queryTrackReq = new QueryTrackReq();
+////        QueryTrackParam queryTrackParam = new QueryTrackParam();
+////        queryTrackParam.setCom(CompanyConstant.YD);
+////        queryTrackParam.setNum("4311159956248");
+////        queryTrackParam.setPhone("17725390266");
+////        queryTrackParam.setFrom("河北保定市");
+////        queryTrackParam.setTo("湖南岳阳市");
+////        queryTrackParam.setResultv2("2");
+////        String param = new Gson().toJson(queryTrackParam);
+////
+////        queryTrackReq.setParam(param);
+////        queryTrackReq.setCustomer(customer);
+////        queryTrackReq.setSign(SignUtils.querySign(param ,key,customer));
+////
+////        IBaseClient baseClient = new QueryTrackMap();
+////        HttpResult result = baseClient.execute(queryTrackReq);
+////
+////        QueryTrackMapResp queryTrackMapResp = new Gson().fromJson(result.getBody(),QueryTrackMapResp.class);
+////        System.out.println(queryTrackMapResp);
+////    }
+////
+////    /**
+////     * 订阅
+////     */
+////    @Test
+////    public void testSubscribe() throws Exception{
+////        SubscribeParameters subscribeParameters = new SubscribeParameters();
+////        subscribeParameters.setCallbackurl("http://www.baidu.com");
+////        subscribeParameters.setPhone("17725390266");
+////
+////        SubscribeParam subscribeParam = new SubscribeParam();
+////        subscribeParam.setParameters(subscribeParameters);
+////        subscribeParam.setCompany(CompanyConstant.ST);
+////        subscribeParam.setNumber("773039762404825");
+////        subscribeParam.setKey(key);
+////
+////        SubscribeReq subscribeReq = new SubscribeReq();
+////        subscribeReq.setSchema(ApiInfoConstant.SUBSCRIBE_SCHEMA);
+////        subscribeReq.setParam(new Gson().toJson(subscribeParam));
+////
+////        IBaseClient subscribe = new Subscribe();
+////        System.out.println(subscribe.execute(subscribeReq));
+////    }
+////
+////    /**
+////     * 智能识别接口（正式用户可以使用）
+////     */
+////    @Test
+////    public void testAutoNum() throws Exception{
+////        AutoNumReq autoNumReq = new AutoNumReq();
+////        autoNumReq.setKey(key);
+////        autoNumReq.setNum("17725390266");
+////
+////        IBaseClient baseClient = new AutoNum();
+////        System.out.println(baseClient.execute(autoNumReq));
+////    }
+//
+//}
 //
-//        IBaseClient baseClient = new AutoNum();
-//        System.out.println(baseClient.execute(autoNumReq));
-//    }
-
-}
-