微信收款信息推送

src/main/java/com/caimei365/order/components/WeChatService.java

@@ -312,9 +312,8 @@ public class WeChatService {
         miniProgram.put("pagepath", pagePath);
 
         JSONObject json = new JSONObject();
-        json.put("template_id", messageTemplateReceipt);
-        json.put("topcolor", "#FF0000");
         json.put("touser", openid);
+        json.put("template_id", messageTemplateReceipt);
         json.put("url", "https://www.caimei365.com/");
         json.put("miniprogram", miniProgram);
         json.put("data", data);
@@ -322,9 +321,11 @@ public class WeChatService {
         String jsonString = json.toJSONString();
         log.info(">>>>>>>>推送微信模板消息：" + jsonString);
         try {
+            // https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=ACCESS_TOKEN
             String requestUrl = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token="+accessToken;
             // 发送请求
-            RequestUtil.httpRequest(requestUrl, "POST", jsonString);
+            String result = RequestUtil.httpRequest(requestUrl, "POST", jsonString);
+            log.info(">>>>>>>>推送结果：" + result);
         } catch (Exception e) {
             log.error("推送微信模板消息失败：", e);
         }

src/main/java/com/caimei365/order/service/impl/ReceiptServiceImpl.java

@@ -1179,7 +1179,7 @@ public class ReceiptServiceImpl implements ReceiptService {
             String associateType = receiptMapper.getReceiptTypeStrById(receipt.getPayType());
             String remarkText = "收款类型：" + associateType + "，确认时间："+receipt.getConfirmDate();
             // 跳转到【普通款项待审核】页面
-            String pagePath = "/pages/relation/ordinary/examine-detail?id="+receipt.getId();
+            String pagePath = "pages/relation/ordinary/examine-detail?id="+receipt.getId();
             for (String openid : openidList) {
                 // sendTemplateMsg(openid, 标题, 金额, 收款日期, 备注, 跳转链接)
                 weChatService.sendTemplateMsg(accessToken, openid, associateTitle, associateAmount, associateDate, remarkText, pagePath);
@@ -1685,7 +1685,7 @@ public class ReceiptServiceImpl implements ReceiptService {
                 List<String> openidList = receiptMapper.getOpenidListByPermission(Collections.singletonList(4));
                 openidList.removeIf(Objects::isNull);
                 // 跳转到【普通款项待审核】页面
-                String pagePath = "/pages/relation/ordinary/examine-detail?id="+receipt.getId();
+                String pagePath = "pages/relation/ordinary/examine-detail?id="+receipt.getId();
                 for (String openid : openidList) {
                     // sendTemplateMsg(openid, 标题, 金额, 收款日期, 备注, 跳转链接)
                     weChatService.sendTemplateMsg(accessToken, openid, title, associateAmount, date, remarkText, pagePath);
@@ -1719,15 +1719,15 @@ public class ReceiptServiceImpl implements ReceiptService {
             Integer receiptType = receipt.getReceiptType();
             if (null != receiptType && 1 == receiptType) {
                 // 未关联普通款项
-                pagePath = "/pages/relation/ordinary/index?id="+receipt.getId();
+                pagePath = "pages/relation/ordinary/index?id="+receipt.getId();
             }
             if (null != receiptType && 3 == receiptType) {
                 // 未关联返佣款项
-                pagePath = "/pages/relation/return/index?id="+receipt.getId();
+                pagePath = "pages/relation/return/index?id="+receipt.getId();
             }
             if (null != receiptType && 5 == receiptType) {
                 // 未关联供应商退款
-                pagePath = "/pages/relation/refund/index?id="+receipt.getId();
+                pagePath = "pages/relation/refund/index?id="+receipt.getId();
             }
             double amount = receipt.getReceiptAmount();
             String date = receipt.getReceiptDate();
@@ -1762,7 +1762,7 @@ public class ReceiptServiceImpl implements ReceiptService {
             String receiptTypeStr = receiptMapper.getReceiptTypeStrById(receipt.getPayType());
             String remarkText = "收款类型：" + receiptTypeStr + "，确认时间："+receipt.getConfirmDate();
             // 跳转到【普通款项待审核】页面
-            String pagePath = "/pages/relation/ordinary/examine-detail?id="+receipt.getId();
+            String pagePath = "pages/relation/ordinary/examine-detail?id="+receipt.getId();
             for (String openid : openidList) {
                 // sendTemplateMsg(openid, 标题, 金额, 收款日期, 备注, 跳转链接)
                 weChatService.sendTemplateMsg(accessToken, openid, title, amount, date, remarkText, pagePath);

src/main/java/com/caimei365/order/task/ReceiptMsgTask.java

@@ -1,46 +1,45 @@
-//package com.caimei365.order.task;
-//
-//import com.caimei365.order.components.WeChatService;
-//import com.caimei365.order.service.ReceiptService;
-//import lombok.extern.slf4j.Slf4j;
-//import org.apache.commons.lang3.StringUtils;
-//import org.springframework.scheduling.annotation.EnableScheduling;
-//import org.springframework.scheduling.annotation.Scheduled;
-//import org.springframework.stereotype.Component;
-//
-//import javax.annotation.Resource;
-//
-///**
-// * 线下收款推送模板消息
-// *
-// * @author : Charles
-// * @date : 2022/2/25
-// */
-//@Slf4j
-//@Component
-//@EnableScheduling
-//public class ReceiptMsgTask {
-//    @Resource
-//    private ReceiptService receiptService;
-//    @Resource
-//    private WeChatService weChatService;
-//    /**
-//     * 微信收款信息推送
-//     * 每天九点钟推送
-//     */
-//    @Scheduled(cron = "0 0 09 * * ?")
-//    public void sendWechatMsgTask() {
-//        log.info("-------->微信收款信息定时推送--start<--------------");
-//        try {
-//            String accessToken = weChatService.getAccessToken();
-//            // 待确认超时
-//            receiptService.sendWechatMsgConfirmTimeout(accessToken);
-//            // 待审核超时
-//            receiptService.sendWechatMsgAuditTimeout(accessToken);
-//        } catch (Exception e) {
-//            log.error("获取微信公众号access_token异常！", e);
-//        }
-//        log.info("-------->微信收款信息定时推送--end<--------------");
-//    }
-//
-//}
+package com.caimei365.order.task;
+
+import com.caimei365.order.components.WeChatService;
+import com.caimei365.order.service.ReceiptService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.scheduling.annotation.EnableScheduling;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+
+/**
+ * 线下收款推送模板消息
+ *
+ * @author : Charles
+ * @date : 2022/2/25
+ */
+@Slf4j
+@Component
+@EnableScheduling
+public class ReceiptMsgTask {
+    @Resource
+    private ReceiptService receiptService;
+    @Resource
+    private WeChatService weChatService;
+    /**
+     * 微信收款信息推送
+     * 每天九点钟推送
+     */
+    @Scheduled(cron = "0 0 09 * * ?")
+    public void sendWechatMsgTask() {
+        log.info("-------->微信收款信息定时推送--start<--------------");
+        try {
+            String accessToken = weChatService.getAccessToken();
+            // 待确认超时
+            receiptService.sendWechatMsgConfirmTimeout(accessToken);
+            // 待审核超时
+            receiptService.sendWechatMsgAuditTimeout(accessToken);
+        } catch (Exception e) {
+            log.error("获取微信公众号access_token异常！", e);
+        }
+        log.info("-------->微信收款信息定时推送--end<--------------");
+    }
+
+}