feats

pom.xml

@@ -10,7 +10,7 @@
 	</parent>
 	<groupId>com.shigongli</groupId>
 	<artifactId>shigongli</artifactId>
-	<version>0.0.4</version>
+	<version>0.0.5</version>
 	<name>shigongli</name>
 	<description>ShiGongli Service</description>
 

src/main/java/com/shigongli/controller/LoginController.java

@@ -3,6 +3,7 @@ package com.shigongli.controller;
 import cn.binarywang.wx.miniapp.api.WxMaService;
 import cn.binarywang.wx.miniapp.bean.WxMaJscode2SessionResult;
 import com.shigongli.common.*;
+import com.shigongli.config.WeixinConfig;
 import com.shigongli.constants.StatusConstant;
 import com.shigongli.entity.SysUser;
 import com.shigongli.entity.TaPerson;
@@ -42,6 +43,9 @@ public class LoginController extends BaseController {
     @Autowired
     WxUtils wxUtils;
 
+    @Autowired
+    WeixinConfig weixinConfig;
+
     /**
      * 公众号登录
      * @param code
@@ -135,6 +139,9 @@ public class LoginController extends BaseController {
         String jws = JWTUtils.encode(claims);
         taPerson.setToken(jws);
 
+        // 消息模板
+        taPerson.setSubscribeMessageList(weixinConfig.getMa().getSubscribeMessages());
+
         return ResponseBean.success(taPerson);
     }
 }

src/main/java/com/shigongli/entity/TaPerson.java

@@ -8,6 +8,7 @@ import com.baomidou.mybatisplus.annotation.TableId;
 import java.io.Serializable;
 import java.util.List;
 
+import com.shigongli.config.WeixinConfig;
 import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
@@ -63,4 +64,13 @@ public class TaPerson implements Serializable {
 
     @TableField(exist = false)
     private List<TaShopKeeper> shopKeeperList;
+
+    @TableField(exist = false)
+    private List<WeixinConfig.Ma.SubscribeMessage> subscribeMessageList;
+
+    @TableField(exist = false)
+    private String orderId;
+
+    @TableField(exist = false)
+    private String houseId;
 }

src/main/java/com/shigongli/task/SendCheckOutMessage.java

@@ -1,15 +1,20 @@
 package com.shigongli.task;
 
+import cn.binarywang.wx.miniapp.api.WxMaService;
+import cn.binarywang.wx.miniapp.bean.WxMaSubscribeMessage;
+import com.shigongli.common.WxUtils;
+import com.shigongli.config.WeixinConfig;
 import com.shigongli.entity.TaPerson;
 import com.shigongli.service.ITaPersonService;
 import lombok.extern.slf4j.Slf4j;
-import me.chanjar.weixin.common.util.DataUtils;
+import me.chanjar.weixin.common.error.WxErrorException;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
 import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
+import java.util.ArrayList;
 import java.util.List;
 
 
@@ -23,6 +28,12 @@ public class SendCheckOutMessage {
     @Autowired
     ITaPersonService iTaPersonService;
 
+    @Autowired
+    WeixinConfig weixinConfig;
+
+    @Autowired
+    WxUtils wxUtils;
+
     @Scheduled(cron = "0 0 11 * * ?")
     public void run() {
         DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");
@@ -33,9 +44,50 @@ public class SendCheckOutMessage {
             return;
         }
 
+        // 找到消息模板
+        List<WeixinConfig.Ma.SubscribeMessage> subscribeMessages = weixinConfig.getMa().getSubscribeMessages();
+        WeixinConfig.Ma.SubscribeMessage subscribeMessage = null;
+        if (null == subscribeMessages || subscribeMessages.size() < 1) {
+            log.error("没有找到小程序消息提醒配置");
+            return;
+        }
+        for (WeixinConfig.Ma.SubscribeMessage message : subscribeMessages) {
+            if ("check-out".equals(message.getType())) {
+                subscribeMessage = message;
+                break;
+            }
+        }
+        if (null == subscribeMessage) {
+            log.error("没有找到退房提醒的消息配置");
+            return;
+        }
+
+        String remark = "请于12:00之前退房. 退房时请检查您的随身物品!";
+        WxMaService maService = wxUtils.getMaService();
+
         // 每隔 1s 发送一条离店提醒
         for (TaPerson taPerson : taPersonList) {
-            // todo
+            List<WxMaSubscribeMessage.Data> dataList = new ArrayList<>();
+            dataList.add(new WxMaSubscribeMessage.Data("thing5", remark));
+            dataList.add(new WxMaSubscribeMessage.Data("time8", today));
+
+            WxMaSubscribeMessage wxMaSubscribeMessage = WxMaSubscribeMessage
+                    .builder()
+                    .templateId(subscribeMessage.getCode())
+                    .toUser(taPerson.getOpenid())
+                    .page(String.format("/pages/index/index?orderId=%s&houseId=%s", taPerson.getOrderId(), taPerson.getHouseId()))
+                    .data(dataList)
+                    .build();
+
+            try {
+                maService.getMsgService().sendSubscribeMsg(wxMaSubscribeMessage);
+                Thread.sleep(1000);
+            } catch (WxErrorException e) {
+                log.error("发送退房消息失败: {}", e.getMessage());
+                e.printStackTrace();
+            } catch (InterruptedException e) {
+                e.printStackTrace();
+            }
         }
     }
 }

src/main/resources/application.yml

@@ -49,7 +49,7 @@ weixin:
       - type: settled-in
         code: rMg5CzypZSniRGHoZ7SBdqv_kmf7fPfTJMZ1k1SgobY
       - type: check-out
-        code:
+        code: OtpD30Kb9qbNBJ2-IVnhu5g1hHnuNvCvdVuFh4e6mPU
 
   # 公众号
   mp:

src/main/resources/mapper/TaPersonMapper.xml

@@ -7,7 +7,9 @@
     </select>
     <select id="getCheckoutListBy" resultType="com.shigongli.entity.TaPerson">
         SELECT DISTINCT
-            m.*
+            m.*,
+            max(s.order_id) as order_id,
+            max(t.house_id) as house_id
         FROM
             ta_house_setting t
             INNER JOIN ta_house_order s ON t.setting_id = s.setting_id