From 8d893618487bf34f31cbdeab935ad43c2168863a Mon Sep 17 00:00:00 2001
From: wangpengfei <1928057482@qq.com>
Date: Wed, 2 Aug 2023 14:46:09 +0800
Subject: [PATCH] 1

---
 .../report/biz/stock/ReportStockDayService.java      | 12 ++++++++++++
 .../yxt/supervise/report/biz/wechat/WechatRest.java  |  6 +++---
 2 files changed, 15 insertions(+), 3 deletions(-)

diff --git a/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/stock/ReportStockDayService.java b/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/stock/ReportStockDayService.java
index 88071677..dd214d4a 100644
--- a/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/stock/ReportStockDayService.java
+++ b/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/stock/ReportStockDayService.java
@@ -1,9 +1,11 @@
 package com.yxt.supervise.report.biz.stock;
 
 import cn.hutool.core.date.DateUtil;
+import cn.hutool.core.thread.ThreadUtil;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.fasterxml.jackson.databind.ObjectMapper;
+import com.yxt.supervise.report.biz.wechat.WechatRest;
 import com.yxt.supervise.report.ds.crm.CrmMapper;
 import com.yxt.supervise.report.ds.crm.ProjectInfo;
 import com.yxt.supervise.report.ds.warehouse.ProdStock;
@@ -39,6 +41,8 @@ public class ReportStockDayService extends ServiceImpl<ReportStockDayMapper, Rep
     private CrmMapper crmMapper;
     @Autowired
     private WarehouseMapper warehouseMapper;
+    @Autowired
+    WechatRest wechatRest;
 
     public ReportStockDay fetchByProjectAndDay(String projectSid, String orderDate) {
 
@@ -106,6 +110,14 @@ public class ReportStockDayService extends ServiceImpl<ReportStockDayMapper, Rep
         }catch (Exception e){
             e.printStackTrace();
         }
+        //开启消息推送
+        ThreadUtil.execute(() -> {
+            try {
+                wechatRest.hcsmSendMessage(projectSid,orderDate);
+            } catch (Exception e) {
+                throw new RuntimeException(e);
+            }
+        });
         return null;
     }
 }
diff --git a/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/wechat/WechatRest.java b/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/wechat/WechatRest.java
index 5d4b043c..d84245ee 100644
--- a/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/wechat/WechatRest.java
+++ b/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/wechat/WechatRest.java
@@ -244,9 +244,9 @@ public class WechatRest {
      * @param orderDate
      * @throws Exception
      */
-    @PostMapping("/hcsmSendMessage/{orderDate}")
-    public void hcsmSendMessage(@PathVariable("orderDate") String orderDate) throws Exception {
-        ReportStockDay reportStockDay=stockDayRest.getDayGather("236408a1-c36e-416c-9f49-d6caa7671009",orderDate).getData();
+    @PostMapping("/hcsmSendMessage/{projectSid}/{orderDate}")
+    public void hcsmSendMessage(@PathVariable("projectSid") String projectSid,@PathVariable("orderDate") String orderDate) throws Exception {
+        ReportStockDay reportStockDay=stockDayRest.getDayGather(projectSid,orderDate).getData();
         // 模板参数
         Map<String, Template> sendMag = new HashMap<String, Template>();
         // 公众号的模板id(也有相应的接口可以查询到)