From 227eff61120aaca63e068035d745d86452e6499a Mon Sep 17 00:00:00 2001
From: hsy <1029150275@qq.com>
Date: 星期一, 17 八月 2026 09:35:12 +0800
Subject: [PATCH] feat(mes): 优化生产订单与排产任务列表显示，新增启停工及校验逻辑 1. 生产订单列表展示优化 (WorkOrder) - 新增「生产状态」列，全局注册 `ORDER_PRODUCTION_STATUS` 常量并绑定系统动态字典。 - 彻底重构「工序生产进度」单元格显示：弃用臃肿的 Steps 组件，改为极简横向布局（彩色状态圆点 + 进度百分比），解决表格行高被强行撑开及内容截断问题，支持横向滚动。 - 优化「完成进度」列宽及展示样式，将百分比数值外置同行显示，更加直观。 2. 排产任务列表改造 (Task) - 顶部表头重构，由单一标题重构为「全部 / 未完成 / 已完成」的 Tabs 标签页切换结构。 - 重写数据过滤逻辑，剥离写死的 status 查询，改为使用 `scheduleStatus` 字段动态响应 Tabs 切换 (0: 未完成, 1: 已完成)。 3. 工单业务逻辑增强与状态流转 - 落实「工单查询逻辑设计方案」，优化底层的工单条件检索逻辑。 - 实现「添加工单启停功能」与「停工状态」，支持工单在执行过程中的暂停与恢复业务流转。 - 强化容错与防呆设计：操作「完成订单」时增加前置校验 `handleCheckFinish`，若生产状态为未完成，强制弹出二次确认 Modal，避免误操作。 # 相关讨论/参考方案 # - 添加工单启停功能 # - 停工状态功能设计方案 # - 工单查询逻辑设计方案 # - 工单完成进度显示优化
---
yudao-module-ai/src/main/java/cn/iocoder/yudao/module/ai/service/knowledge/AiKnowledgeDocumentServiceImpl.java | 62 ++++++++++++++++++++++++++++--
1 files changed, 57 insertions(+), 5 deletions(-)
diff --git a/yudao-module-ai/src/main/java/cn/iocoder/yudao/module/ai/service/knowledge/AiKnowledgeDocumentServiceImpl.java b/yudao-module-ai/src/main/java/cn/iocoder/yudao/module/ai/service/knowledge/AiKnowledgeDocumentServiceImpl.java
index c11c264..5f671a2 100644
--- a/yudao-module-ai/src/main/java/cn/iocoder/yudao/module/ai/service/knowledge/AiKnowledgeDocumentServiceImpl.java
+++ b/yudao-module-ai/src/main/java/cn/iocoder/yudao/module/ai/service/knowledge/AiKnowledgeDocumentServiceImpl.java
@@ -28,6 +28,10 @@
import org.apache.tika.parser.Parser;
import org.apache.tika.extractor.EmbeddedDocumentExtractor;
import org.apache.tika.sax.BodyContentHandler;
+import org.apache.poi.xwpf.extractor.XWPFWordExtractor;
+import org.apache.poi.xwpf.usermodel.XWPFDocument;
+import org.apache.poi.hwpf.HWPFDocument;
+import org.apache.poi.hwpf.extractor.WordExtractor;
import org.xml.sax.ContentHandler;
import java.io.ByteArrayOutputStream;
import java.io.InputStream;
@@ -57,6 +61,8 @@
private AiKnowledgeSegmentService segmentService;
@Resource
private AiModelService modelService;
+ @Resource
+ private cn.iocoder.yudao.module.system.service.storage.SystemStorageBlobService storageBlobService;
@Override
@Transactional(rollbackFor = Exception.class)
@@ -113,11 +119,28 @@
}
}
+ /**
+ * 浠� storage-blob URL 瑙ｆ瀽鍑� fileName 鍜� token
+ */
+ private static java.util.regex.Pattern STORAGE_URL_PATTERN =
+ java.util.regex.Pattern.compile("/storage-blob/(?:preview|download)/([^?]+)\\?.*token=([^&]+)");
+
private byte[] downloadFile(String fileUrl) {
+ // 浼樺厛閫氳繃 storage-blob 鏈湴璇诲彇锛岄伩鍏� HTTP 璁よ瘉闂
+ var matcher = STORAGE_URL_PATTERN.matcher(fileUrl);
+ if (matcher.find()) {
+ String fileName = matcher.group(1);
+ String token = matcher.group(2);
+ try {
+ java.io.File file = storageBlobService.getFileByToken(fileName, token);
+ return java.nio.file.Files.readAllBytes(file.toPath());
+ } catch (Exception e) {
+ log.warn("鏈湴璇诲彇瀛樺偍鏂囦欢澶辫触锛屽洖閫� HTTP 涓嬭浇: {}", e.getMessage());
+ }
+ }
+ // 鍥為�� HTTP 涓嬭浇
try {
- // 鎵嬪姩缂栫爜 URL 璺緞涓殑闈� ASCII 瀛楃锛岄伩鍏� URI 鏋勯�犲嚱鏁版姤閿�
- String encodedUrl = encodeUrlPath(fileUrl);
- URL url = URL.of(new URI(encodedUrl), null);
+ URL url = URL.of(new URI(encodeUrlPath(fileUrl)), null);
HttpURLConnection conn = (HttpURLConnection) url.openConnection();
conn.setConnectTimeout(30000);
conn.setReadTimeout(60000);
@@ -184,7 +207,36 @@
if (ArrayUtil.contains(new String[]{"txt", "md", "json", "xml", "csv", "yaml", "yml"}, ext)) {
return new String(fileBytes, StandardCharsets.UTF_8);
}
- // 浣跨敤 AutoDetectParser + EmbeddedDocumentExtractor 璺宠繃宓屽叆鍥剧墖锛岄伩鍏嶆彁鍙栧埌浜岃繘鍒朵贡鐮�
+ // .docx 浼樺厛浣跨敤 POI 鎻愬彇锛屼腑鏂囨敮鎸佹洿濂�
+ if ("docx".equals(ext)) {
+ try (XWPFDocument doc = new XWPFDocument(new java.io.ByteArrayInputStream(fileBytes));
+ XWPFWordExtractor extractor = new XWPFWordExtractor(doc)) {
+ String text = extractor.getText();
+ if (StrUtil.isNotEmpty(text)) return text.trim();
+ } catch (Exception e) {
+ log.warn("POI 瑙ｆ瀽 docx 澶辫触锛屽洖閫� Tika: {}", e.getMessage());
+ }
+ }
+ // .doc 浼樺厛浣跨敤 POI 鎻愬彇
+ if ("doc".equals(ext)) {
+ try (HWPFDocument doc = new HWPFDocument(new java.io.ByteArrayInputStream(fileBytes));
+ WordExtractor extractor = new WordExtractor(doc)) {
+ String text = extractor.getText();
+ if (StrUtil.isNotEmpty(text)) return text.trim();
+ } catch (Exception e) {
+ log.warn("POI 瑙ｆ瀽 doc 澶辫触锛屽洖閫� Tika: {}", e.getMessage());
+ }
+ }
+ // 鍏朵粬鏍煎紡鎴� POI 澶辫触鏃跺洖閫� Tika
+ return extractTextWithTika(fileBytes);
+ } catch (Exception e) {
+ log.warn("鏂囨。鍐呭鎻愬彇澶辫触锛屽皾璇� UTF-8 鏂囨湰璇诲彇: {}", e.getMessage());
+ return "";
+ }
+ }
+
+ private String extractTextWithTika(byte[] fileBytes) {
+ try {
Parser parser = new AutoDetectParser();
ParseContext context = new ParseContext();
context.set(EmbeddedDocumentExtractor.class, new EmbeddedDocumentExtractor() {
@@ -203,7 +255,7 @@
}
return handler.toString().trim();
} catch (Exception e) {
- log.warn("Tika 瑙ｆ瀽鏂囨。澶辫触锛屽皾璇� UTF-8 鏂囨湰璇诲彇: {}", e.getMessage());
+ log.warn("Tika 瑙ｆ瀽澶辫触: {}", e.getMessage());
return "";
}
}
--
Gitblit v1.9.3