|
|
@ -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; |
|
|
|
} |
|
|
|
} |
|
|
|