From 43f0e69715099cfc8c8b8ea5284b874bfad14400 Mon Sep 17 00:00:00 2001
From: zhangherong <571457620@qq.com>
Date: 星期二, 19 八月 2025 10:49:28 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'
---
src/main/java/org/jeecg/modules/andon/service/impl/AndonResponseConfigServiceImpl.java | 35 +++++++++++++++++++++++++++++------
1 files changed, 29 insertions(+), 6 deletions(-)
diff --git a/src/main/java/org/jeecg/modules/andon/service/impl/AndonResponseConfigServiceImpl.java b/src/main/java/org/jeecg/modules/andon/service/impl/AndonResponseConfigServiceImpl.java
index f6f23ae..5129363 100644
--- a/src/main/java/org/jeecg/modules/andon/service/impl/AndonResponseConfigServiceImpl.java
+++ b/src/main/java/org/jeecg/modules/andon/service/impl/AndonResponseConfigServiceImpl.java
@@ -6,6 +6,7 @@
import org.apache.shiro.SecurityUtils;
import org.jeecg.common.system.vo.LoginUser;
import org.jeecg.modules.andon.dto.AndonButtonDTO;
+import org.jeecg.modules.andon.dto.AndonOrdeDto;
import org.jeecg.modules.andon.entity.AndonButtonConfig;
import org.jeecg.modules.andon.entity.AndonOrder;
import org.jeecg.modules.andon.entity.AndonResponseConfig;
@@ -51,10 +52,35 @@
return baseMapper.getAndonResponseConfigByFactoryIdAndButtonId(factoryId, buttonId);
}
+ @Override
+ public String getProductionLineIdByButtonId(String buttonId) {
+ QueryWrapper<AndonResponseConfig> queryWrapper = new QueryWrapper<>();
+ queryWrapper.eq("button_id", buttonId);
+ AndonResponseConfig config = this.getOne(queryWrapper);
+ return config != null ? config.getFactoryId() : null;
+ }
+
+ @Override
+ public String getResponderByButtonId(String buttonId,String factoryId) {
+ QueryWrapper<AndonResponseConfig> queryWrapper = new QueryWrapper<>();
+ queryWrapper.eq("button_id", buttonId);
+ queryWrapper.eq("factory_id", factoryId); // 鍋囪factory_id瀵瑰簲浜х嚎ID
+ AndonResponseConfig config = this.getOne(queryWrapper, false);
+ return config != null ? config.getFirsterResponder() : null;
+ }
+
+ @Override
+ public AndonResponseConfig getResponseConfigByButtonIdAndFactoryId(String buttonId, String factoryId) {
+ QueryWrapper<AndonResponseConfig> queryWrapper = new QueryWrapper<>();
+ queryWrapper.eq("button_id", buttonId);
+ queryWrapper.eq("factory_id", factoryId);
+ // 浣跨敤false鍙傛暟锛屽綋鏌ヨ鍒板鏉¤褰曟椂涓嶄細鎶涘嚭寮傚父锛岃�屾槸杩斿洖绗竴鏉�
+ return this.getOne(queryWrapper, false);
+ }
@Override
- public void sendAndonNotification(AndonButtonDTO andonButtonDTO) {
+ public void sendAndonNotification(AndonOrdeDto andonButtonDTO) {
/**
* 1. 楠岃瘉宸ュ崟鐘舵��
*/
@@ -62,16 +88,13 @@
log.warn("璇锋眰鍙傛暟涓虹┖");
throw new IllegalArgumentException("璇锋眰鍙傛暟涓嶈兘涓虹┖");
}
- /**
- * 璁剧疆瀹夌伅浜�
- */
/**
* 2. 鑾峰彇鍝嶅簲閰嶇疆
*/
- AndonResponseConfig andonResponseConfig = this.getById(andonButtonDTO.getId());
+ AndonResponseConfig andonResponseConfig = getResponseConfigByButtonIdAndFactoryId(andonButtonDTO.getButtonId(), andonButtonDTO.getFactoryId());
- AndonOrder andonOrder = andonOrderService.getById(andonButtonDTO.getOrderIds());
+ AndonOrder andonOrder = andonOrderService.getById(andonButtonDTO.getId());
if (andonOrder == null) {
log.warn("鏈壘鍒癐D涓篬{}]鐨勫畨鐏鍗�");
throw new IllegalArgumentException("鏈壘鍒板搴旂殑瀹夌伅璁㈠崟");
--
Gitblit v1.9.3