From 046476cb412140e8fc589845d5079cd784a64ba0 Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@63.com>
Date: 星期一, 06 九月 2021 13:45:07 +0800
Subject: [PATCH] #
---
src/main/java/zy/cloud/wms/common/service/task/DetectionScheduler.java | 83 +++++++++++++++++++++++++++++++++++++++++
1 files changed, 83 insertions(+), 0 deletions(-)
diff --git a/src/main/java/zy/cloud/wms/common/service/task/DetectionScheduler.java b/src/main/java/zy/cloud/wms/common/service/task/DetectionScheduler.java
new file mode 100644
index 0000000..4260dac
--- /dev/null
+++ b/src/main/java/zy/cloud/wms/common/service/task/DetectionScheduler.java
@@ -0,0 +1,83 @@
+package zy.cloud.wms.common.service.task;
+
+import com.baomidou.mybatisplus.mapper.EntityWrapper;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+import zy.cloud.wms.manager.entity.DocLog;
+import zy.cloud.wms.manager.service.DocLogService;
+import zy.cloud.wms.manager.service.MatService;
+
+import java.util.HashSet;
+import java.util.List;
+import java.util.Set;
+
+/**
+ * Created by vincent on 2021/9/3
+ */
+@Slf4j
+@Component
+public class DetectionScheduler {
+
+ @Autowired
+ private MatService matService;
+ @Autowired
+ private JdbcTemplate jdbcTemplate;
+ @Autowired
+ private DocLogService docLogService;
+
+ /**
+ * 璁㈠崟杞巻鍙叉。澶勭悊鍣�
+ */
+ @Scheduled(cron = "0/10 * * * * ? ")
+ public void orderBeLogExecute(){
+ List<String> matnrList = jdbcTemplate.queryForList("select distinct matnr from man_mat", String.class);
+ for (String matnr : matnrList) {
+ // 鏌ユ壘绔嬪簱搴撳瓨
+ double asrsAnfme = jdbcTemplate.queryForObject("select isnull(sum(anfme), 0) from asr_loc_detl where matnr ='" + matnr + "'", Double.class);
+ // 鏌ユ壘骞充粨搴撳瓨
+ double wmsAnfme = jdbcTemplate.queryForObject("select isnull(sum(anfme), 0) from man_loc_detl where matnr ='" + matnr + "'", Double.class);
+ double total = asrsAnfme + wmsAnfme;
+ // 鍗曟嵁搴撳瓨
+ List<DocLog> docLogs = docLogService.selectList(new EntityWrapper<DocLog>().eq("matnr", matnr));
+
+ double stock = 0.0D;
+ Set<String> set = new HashSet<>();
+ for (DocLog docLog : docLogs) {
+ // 闃叉閲嶅鍗曟嵁
+ if (set.contains(docLog.getDocNum())) {
+ break;
+ }
+ set.add(docLog.getDocNum());
+ int docId = Math.toIntExact(docLog.getDocId());
+ // 璁＄畻搴撳瓨
+ switch (docId) {
+ case 6:
+
+ break;
+ case 9:
+ break;
+ case 11:
+ break;
+ case 14:
+ break;
+ case 34:
+ break;
+ default:
+ break;
+ }
+ }
+ // 姣旇緝宸紓鍊�
+ if (stock != total) {
+ // todo
+ }
+
+
+ }
+
+ }
+
+}
--
Gitblit v1.9.1